using System;
using System.Data;
using System.Data.Common;
using System.Data.SqlServerCe;
using System.Windows.Forms;
using System.Collections;
namespace GeMa.Clases.bbdd
{
class BBDD
{
private static volatile BBDD _instance = null;
//parámetros de conextión
public static SqlCeEngine objEg;
public static SqlCeConnection objCon;
//public static SqlCeDataReader reader;
public static DataSet dataSet;
public static SqlCeDataAdapter dataAdapter;
//----------------------------------------------------------
// PATRON SINGLETON PARA LA CLASE BBDD
//----------------------------------------------------------
public static BBDD getInstance()
{
if (_instance == null)
{
}
return _instance;
}
//----------------------------------------------------------
// CONSTRUCTOR DE LA CLASE
//----------------------------------------------------------
protected BBDD() { }
//----------------------------------------------------------
// CONEXIÓN CON LA BBDD
//----------------------------------------------------------
public static bool conectar()
{
bool conexion = true;
//Indicamos el origen de datos
objEg
= new SqlCeEngine
("Data Source=|DataDirectory|\BBDD\GeMaDataBase.SDF"); objCon
= new SqlCeConnection
("Data Source=|DataDirectory|\BBDD\GeMaDataBase.SDF");
try
{
objCon.Open();
}
catch (SqlCeException ex)
{
MessageBox.Show(ex.Message);
conexion = false;
}
return conexion;
}
//----------------------------------------------------------
// CERRAR CONEXIÓN
//----------------------------------------------------------
public static void desconectar()
{
objCon.Close();
}
//----------------------------------------------------------
// OBTENER CAMPOS
//----------------------------------------------------------
public static void obtenerCamposTabla(string tabla, string[] aCampos, string Where)
{
//preparamos la query
string sqlQuery = "SELECT ";
//obtenemos los campos
for (int i = 0; i < aCampos.Length; i++)
{
string campo = aCampos[i];
sqlQuery += campo + ",";
}
//eliminamos la última coma
sqlQuery = sqlQuery.Remove(sqlQuery.Length - 1, 1);
sqlQuery +=" FROM "+tabla+" WHERE 1=1 ";
if (Where!="")
{
sqlQuery += Where;
}
dataAdapter
= new SqlCeDataAdapter
(sqlQuery, objCon
); dataAdapter.Fill(dataSet,tabla);
}
//----------------------------------------------------------
// GUARDAR CAMPOS EN TABLA
//----------------------------------------------------------
public static bool guardarCamposTabla(string tabla, Hashtable aCampos, string id)
{
bool procesado = false;
string sqlQuery = "";
//estamos ante un insert
if (id == "")
{
//preparamos la query
sqlQuery = "INSERT INTO " + tabla + " (";
//obtenemos las columnas
foreach (DictionaryEntry campo in aCampos)
{
sqlQuery += campo.Key + ",";
}
//eliminamos la última coma
sqlQuery = sqlQuery.Remove(sqlQuery.Length - 1, 1);
//cerramos las columnas
sqlQuery += ") VALUES (";
//obtenemos los campos
foreach (DictionaryEntry campo in aCampos)
{
sqlQuery += "'" + campo.Value + "',";
}
//eliminamos la última coma
sqlQuery = sqlQuery.Remove(sqlQuery.Length - 1, 1);
sqlQuery += ")";
}
else //es un update
{
}
//ejecutamos el query
try
{
//conectamos con la base de datos
BBDD.conectar();
SqlCeCommand cm
= new SqlCeCommand
(); cm.Connection = objCon;
cm.CommandType = CommandType.Text;
cm.CommandText = sqlQuery;
cm.ExecuteNonQuery();
procesado = true;
}
catch (Exception ex)
{
MessageBox.Show(ex.Message);
}
finally
{
aCampos = null;
//desconectar de la base de datos
BBDD.desconectar();
}
return procesado;
}
}
}