PLEASE HELP ON THIS... Creating a class... | Newbie | | Join Date: Dec 2008
Posts: 1
| |
Hi, im new to csharp and im trying to create a class that can change the application database without no rewriting all connection code... but cause some reason it is not working... it tells me that im not creating the object but im doing it,,, please help im a newbie to c# - using System;
-
using System.Collections.Generic;
-
using System.Text;
-
using System.Data;
-
using System.Data.SQLite;
-
using MySql.Data;
-
using MySql.Data.MySqlClient;
-
using Npgsql;
-
using NpgsqlTypes;
-
using Npgsql.Design;
-
using System.Net;
-
using System.Security.Cryptography;
-
using System.IO;
-
using System.Drawing;
-
using System.Windows.Forms;
-
-
/*Basado en MultipleDB de Wilber Torres
-
* Requiere de librerias de MySQL, PostgreSQL y SQLite.
-
* 2008 - ctEngine Inc. todos los derechos reservados.
-
* */
-
public class multipleDBConnection
-
{
-
public String tipodb;
-
-
public String server;
-
public String basedatos;
-
public String userdb;
-
public String passwdb;
-
-
public NpgsqlConnection _connpgsql;
-
-
public NpgsqlConnection conexionPostgreSQL
-
{
-
set { _connpgsql = value; }
-
get { return _connpgsql; }
-
}
-
-
public SQLiteConnection consqlite;
-
//public SQLiteDataAdapter dtsqlite;
-
-
public MySqlConnection conmysql;
-
//public MySqlDataAdapter dtmysql;
-
-
-
//public NpgsqlDataAdapter dtnpgsql;
-
-
public DataSet midataset = new DataSet();
-
public DataTable midatatable = new DataTable();
-
-
-
-
public multipleDBConnection(string tipodb, string server, string basedatos, string userdb, string passwdb)
-
{
-
//tipo de servidor
-
this.tipodb = tipodb;
-
//host de servidor (en sqlite es el archivo dentro de la carpeta APP_PATH\Datos\Archivo.ctdb o .sqlite)
-
this.server = server;
-
//base de datos (en caso de mysql o postgre)
-
this.basedatos = basedatos;
-
//datos de login (en caso de mysql o postgre)
-
this.userdb = userdb;
-
this.passwdb = passwdb;
-
}
-
public multipleDBConnection(string tipodb, string server)
-
{
-
this.tipodb = tipodb;
-
this.server = server;
-
}
-
-
public bool Open()
-
{
-
if (this.tipodb == "sqlite")
-
{
-
this.server = csEngine.getFileFromDatos(this.server);
-
-
this.consqlite = new SQLiteConnection("Data Source=" + this.server + ";Version=3;New=False;Compress=True;");
-
try
-
{
-
this.consqlite.Open();
-
int var1 = 1000, var2 = 0, var3;
-
var3 = var1 / var2;
-
Console.WriteLine(Convert.ToString(var3));
-
return true;
-
}
-
catch
-
{
-
return false;
-
}
-
}
-
else if (this.tipodb == "mysql")
-
{
-
this.conmysql = new MySqlConnection("Database=" + this.basedatos + ";Data Source=" + this.server + ";User Id=" + this.userdb + ";Password=" + this.passwdb);
-
try
-
{
-
this.conmysql.Open();
-
return true;
-
}
-
catch
-
{
-
return false;
-
}
-
-
}
-
else if (this.tipodb == "postgresql")
-
{
-
this._connpgsql = new NpgsqlConnection("Server=" + this.server + ";User Id=" + this.userdb + ";Password=" + this.passwdb + ";Database=" + this.basedatos + ";");
-
try
-
{
-
this._connpgsql.Open();
-
return true;
-
}
-
catch
-
{
-
return false;
-
}
-
}
-
else
-
return false;
-
-
}
-
-
public Boolean Close()
-
{
-
if (this.tipodb == "sqlite")
-
{
-
this.consqlite.Close();
-
return true;
-
}
-
else if (this.tipodb == "mysql")
-
{
-
this.conmysql.Close();
-
return true;
-
}
-
else if (this.tipodb == "postgresql")
-
{
-
conexionPostgreSQL.Close();
-
return true;
-
}
-
else
-
return false;
-
}
-
-
-
}
-
class multipleDBCommand
-
{
-
-
private String tipo;
-
private multipleDBConnection conexion;
-
//SQLITE
-
private SQLiteCommand sqlitecommand;
-
//MYSQL
-
private MySqlCommand mysqlcommand;
-
//POSTGRE
-
-
private NpgsqlCommand _postgreCmd;
-
public NpgsqlCommand comandoPostgreSQL
-
{
-
set { _postgreCmd = value; }
-
get { return _postgreCmd; }
-
}
-
-
public multipleDBCommand(string queryin, multipleDBConnection conexionbd)
-
{
-
switch (conexionbd.tipodb)
-
{
-
case "sqlite":
-
this.sqlitecommand = new SQLiteCommand(queryin, conexionbd.consqlite);
-
break;
-
case "mysql":
-
this.mysqlcommand = new MySqlCommand(queryin, conexionbd.conmysql);
-
break;
-
case "postgresql":
-
comandoPostgreSQL = new NpgsqlCommand(queryin, conexionbd.conexionPostgreSQL);
-
conexionbd._connpgsql.Open(); // CANT MAKE IT WORK... PLEASE HELP?!!!
-
//csEngine.consolaEscribe(Convert.ToString(comandoPostgreSQL.Connection.State));
-
break;
-
}
-
this.tipo = conexionbd.tipodb;
-
this.conexion = conexionbd;
-
}
-
-
public multipleDBDataReader ExecuteReader()
-
{
-
switch (this.tipo)
-
{
-
case "sqlite":
-
multipleDBDataReader ejecutaLector = new multipleDBDataReader(sqlitecommand, conexion);
-
return ejecutaLector;
-
case "mysql":
-
multipleDBDataReader ejecutaLectorMy = new multipleDBDataReader(mysqlcommand, conexion);
-
return ejecutaLectorMy;
-
case "postgresql":
-
multipleDBDataReader ejecutaLectorPost = new multipleDBDataReader(comandoPostgreSQL, conexion);
-
return ejecutaLectorPost;
-
default:
-
return null;
-
}
-
}
-
-
}
-
class multipleDBDataReader
-
{
-
-
private String tipo;
-
private multipleDBConnection conexionReader;
-
//SQLITE
-
private SQLiteCommand sqlitecommand;
-
private SQLiteDataReader sqlitedatareader;
-
//MYSQL
-
private MySqlCommand mysqlcommand;
-
private MySqlDataReader mysqldatareader;
-
//POSTGRE
-
private NpgsqlCommand postgrecommand;
-
private NpgsqlDataReader postgredatareader;
-
-
public multipleDBDataReader(SQLiteCommand sqlitecommandin, multipleDBConnection conexionbd)
-
{
-
this.tipo = conexionbd.tipodb;
-
this.conexionReader = conexionbd;
-
this.sqlitecommand = sqlitecommandin;
-
}
-
-
public multipleDBDataReader(MySqlCommand mysqlcommandin, multipleDBConnection conexionbd)
-
{
-
this.tipo = conexionbd.tipodb;
-
this.conexionReader = conexionbd;
-
this.mysqlcommand = mysqlcommandin;
-
}
-
public multipleDBDataReader(NpgsqlCommand postgrecommandin, multipleDBConnection conexionbd)
-
{
-
this.tipo = conexionbd.tipodb;
-
this.conexionReader = conexionbd;
-
this.postgrecommand = postgrecommandin;
-
}
-
-
public bool Read()
-
{
-
switch (this.tipo)
-
{
-
case "sqlite":
-
this.tipo = "sqlite";
-
-
this.sqlitedatareader = this.sqlitecommand.ExecuteReader();
-
-
return sqlitedatareader.Read();
-
case "mysql":
-
this.tipo = "mysql";
-
this.mysqldatareader = this.mysqlcommand.ExecuteReader();
-
return mysqldatareader.Read();
-
case "postgresql":
-
this.tipo = "postgre";
-
this.postgredatareader = this.postgrecommand.ExecuteReader();
-
return postgredatareader.Read();
-
default:
-
return false;
-
}
-
}
-
public Int16 GetInt16(int columna)
-
{
-
switch (this.tipo)
-
{
-
case "sqlite":
-
this.tipo = "sqlite";
-
return this.sqlitedatareader.GetInt16(columna);
-
-
case "mysql":
-
this.tipo = "mysql";
-
return this.mysqldatareader.GetInt16(columna);
-
-
case "postgresql":
-
this.tipo = "postgre";
-
return this.postgredatareader.GetInt16(columna);
-
default:
-
return 0;
-
}
-
}
-
}
-
-
class pruebita
-
{
-
public static void pruebitax()
-
{
-
//multipleDBConnection conexion = new multipleDBConnection("sqlite", "ctVentas.ctdb");
-
multipleDBConnection conexion = new multipleDBConnection("postgresql", "localhost", "ctventas", "postgres", "option");
-
string strQuery = "select * from autobackup limit 1";
-
multipleDBCommand conectado = new multipleDBCommand(strQuery, conexion);
-
bool conexionabre = conexion.Open();
-
if (conexionabre)
-
Console.WriteLine("Conexion establecida."); //OK
-
else
-
Console.WriteLine("Conexion imposible"); //ERROR
-
int tiempo = 0, tipo = 0;
-
if (conexion.conexionPostgreSQL.State == ConnectionState.Open)
-
{
-
while (conectado.ExecuteReader().Read())
-
{
-
tiempo = conectado.ExecuteReader().GetInt16(1);
-
tipo = conectado.ExecuteReader().GetInt16(2);
-
}
-
}
-
//conexion.Close();
-
Console.WriteLine(Convert.ToString(tiempo) + " " + Convert.ToString(tipo));
-
}
-
}
-
class csEngine
-
{
-
public static string getFileFromDatos(string file)
-
{
-
string executableName = Application.ExecutablePath;
-
FileInfo executableFileInfo = new FileInfo(executableName);
-
string executableDirectoryName = executableFileInfo.DirectoryName;
-
string backDir = Path.Combine(executableDirectoryName, "Datos");
-
string resFile = Path.Combine(backDir, file);
-
return resFile;
-
}
-
-
}
Dlls needed to compile : MEGAUPLOAD - The leading online storage and file delivery service
thanks in advance and sorry for my bad english.
| | Newbie | | Join Date: Dec 2008
Posts: 9
| | | re: PLEASE HELP ON THIS... Creating a class...
Where does the error occur?
|
Similar C# / C Sharp bytes | | |  /bytes/about
We are a network of experts and professionals in IT and software development that help one another with answers to tough questions and share insights.
Get the best answers to your questions from over 226,327 network members.
|
