C#链接多种数据库

Question

我想写一个链接数据库类,可以连接DB2,Oracle,SqlServer,acess,有没有什么好的办法

Answer 1

 1.C#连接Access    程序代码：    using System.Data;    using System.Data.OleDb;    string strConnection="Provider=Microsoft.Jet.OleDb.4.0;";    strConnection+=@"DataSource=C:\BegASPNET\Northwind.mdb";    OleDbConnection objConnection=new OleDbConnection(strConnection);
    objConnection.Open();
    objConnection.Close();    解释：    连接Access数据库需要导入额外的命名空间，所以有了最前面的两条using命令，这是必不可少的!    strConnection这个变量里存放的是连接数据库所需要的连接字符串，他指定了要使用的数据提供者和要使用的数据源。    “Provider=Microsoft.Jet.OleDb.4.0;”是指数据提供者，这里使用的是Microsoft Jet引擎，也就是Access中的数据引擎，asp.net就是靠这个和Access的数据库连接的。
    “Data Source=C:\BegASPNET\Northwind.mdb”是指明数据源的位置，他的标准形式是“Data Source=MyDrive:MyPath\MyFile.MDB”。    PS：    1.“+=”后面的“@”符号是防止将后面字符串中的“\”解析为转义字符。    2.如果要连接的数据库文件和当前文件在同一个目录下，还可以使用如下的方法连接：    strConnection+="Data Source=";strConnection+=MapPath("Northwind.mdb");    3.要注意连接字符串中的参数之间要用分号来分隔。    “OleDbConnection objConnection=new OleDbConnection(strConnection);”这一句是利用定义好的连接字符串来建立了一个链接对象，以后对数据库的操作我们都要和这个对象打交道。    “objConnection.Open();”这用来打开连接。至此，与Access数据库的连接完成。    2.C#连接SQL Server
    程序代码：    using System.Data;    using System.Data.SqlClient;..    string strConnection="user id=sa;password=;";    strConnection+="initial catalog=Northwind;Server=YourSQLServer;";    strConnection+="Connect Timeout=30";
    SqlConnection objConnection=new SqlConnection(strConnection);..    objConnection.Open();    objConnection.Close();    解释：    连接SQL Server数据库的机制与连接Access的机制没有什么太大的区别，只是改变了Connection对象和连接字符串中的不同参数。    首先，连接SQL Server使用的命名空间不是“System.Data.OleDb”，而是“System.Data.SqlClient”。    其次就是他的连接字符串了，我们一个一个参数来介绍(注意：参数间用分号分隔)：    “user id=sa”：连接数据库的验证用户名为sa。他还有一个别名“uid”，所以这句我们还可以写成“uid=sa”。　    “password=”：连接数据库的验证密码为空。他的别名为“pwd”，所以我们可以写为“pwd=”。    这里注意，你的SQL Server必须已经设置了需要用户名和密码来登录，否则不能用这样的方式来登录。如果你的SQL Server设置为Windows登录，那么在这里就不需要使用“user id”和“password”这样的方式来登录，而需要使用“Trusted_Connection=SSPI”来进行登录。    “initial catalog=Northwind”：使用的数据源为“Northwind”这个数据库。他的别名为“Database”，本句可以写成“Database=Northwind”。    “Server=YourSQLServer”：使用名为“YourSQLServer”的服务器。他的别名为“Data Source”，“Address”，“Addr”。如果使用的是本地数据库且定义了实例名，则可以写为“Server=(local)\实例名”;如果是远程服务器，则将“(local)”替换为远程服务器的名称或IP地址。
    “Connect Timeout=30”：连接超时时间为30秒。
    在这里，建立连接对象用的构造函数为：SqlConnection。    3.C#连接Oracle
    程序代码：    using System.Data.OracleClient;using System.Data;//在窗体上添加一个按钮，叫Button1，双击Button1，输入以下代码private void Button1_Click(object sender, System.EventArgs e){string ConnectionString="Data Source=sky;user=system;password=manager;";//写连接串OracleConnection conn=new OracleConnection(ConnectionString);//创建一个新连接try{conn.Open();OracleCommand cmd=conn.CreateCommand();cmd.CommandText="select * from MyTable";//在这儿写sql语句OracleDataReader odr=cmd.ExecuteReader();//创建一个OracleDateReader对象while(odr.Read())//读取数据，如果odr.Read()返回为false的话，就说明到记录集的尾部了 {Response.Write(odr.GetOracleString(1).ToString());//输出字段1，这个数是字段索引，具体怎么使用字段名还有待研究}odr.Close();}catch(Exception ee){Response.Write(ee.Message); //如果有错误，输出错误信息}finally{conn.Close(); //关闭连接}}    4.C#连接MySQL    程序代码：    using MySQLDriverCS; // 建立数据库连接MySQLConnection DBConn;DBConn = new MySQLConnection(new MySQLConnectionString("localhost","mysql","root","",3306).AsString);DBConn.Open(); // 执行查询语句MySQLCommand DBComm;DBComm = new MySQLCommand("select Host,User from user",DBConn); // 读取数据MySQLDataReader DBReader = DBComm.ExecuteReaderEx(); // 显示数据try{while (DBReader.Read()){Console.WriteLine("Host = {0} and User = {1}", DBReader.GetString(0),DBReader.GetString(1));}}finally{DBReader.Close();DBConn.Close();} //关闭数据库连接DBConn.Close();    5.C#连接IBM DB2    程序代码：    OleDbConnection1.Open();//打开数据库连接OleDbDataAdapter1.Fill(dataSet1,"Address");//将得来的数据填入dataSetDataGrid1.DataBind();//绑定数据OleDbConnection1.Close();//关闭连接 //增加数据库数据在Web Form上新增对应字段数量个数的TextBox，及一个button，为该按键增加Click响应事件代码如下：this.OleDbInsertCommand1.CommandText = "INSERTsintosADDRESS(NAME,EMAIL, AGE, ADDRESS) VALUES('"+TextBox1.Text+"','"+TextBox2.Text+"','"+TextBox3.Text+"','"+TextBox4.Text+"')";OleDbInsertCommand1.Connection.Open();//打开连接OleDbInsertCommand1.ExecuteNonQuery();//执行该SQL语句OleDbInsertCommand1.Connection.Close();//关闭连接    6.C#连接SyBase
    程序代码：    Provider=Sybase.ASEOLEDBProvider.2;Initial Catalog=数据库名;User ID=用户名;Data Source=数据源;Extended Properties="";Server Name=ip地址;Network Protocol=Winsock;Server Port Address=5000;

Answer 2

最好定义个数据库处理的接口，然后用工厂模式。要操作哪个数据库就返回相应的数据操作类。
我最近做那个是用反射来操作。
下载地址http://www.heyant.com/html/Download49.html

Answer 3

        private static readonly object _syncLock = new object();//线程同步锁；
        private static DataAccessorFactory _instance;
        /// <summary>
        /// 返回 DataAccessorFactory 的唯一实例；
        /// </summary>
        public static DataAccessorFactory Instance
        {
            get
            {
                if (_instance == null)
                {
                    lock (_syncLock)
                    {
                        if (_instance == null)
                        {
                            _instance = new DataAccessorFactory();
                        }
                    }
                }
                return _instance;
            }
        }        public IDataAccessor GetDataAccessor(AccessorType type)
        {
            if (type == AccessorType.SqlServer)
            {
                return new SqlDataAccessor();
            }
            else
            {
                return new AccessDataAccessor();
            }
        }        /// <summary>
        /// 保证单例的私有构造函数；
        /// </summary>
        private DataAccessorFactory() { }        public enum AccessorType
        {
            SqlServer,
            Access
        }
    }
目前只有Sql Server和Access的

Answer 4

   public class DBHelper
    {
        /// <summary>
        /// 枚举：数据库类型
        /// </summary>
        public enum DatabaseTypes
        {
            Sql, MySql, Oracle, OleDb
        }        private DatabaseTypes _databaseType;
        private string _connectionString;
        private IDBHelper _iDBHelper;        public DBHelper()
        { }        public DBHelper(DatabaseTypes databaseType, string connectionString)
        {
            DatabaseType = databaseType;
            this._connectionString = connectionString;
        }        /// <summary>
        /// 数据库类型
        /// </summary>
        public DatabaseTypes DatabaseType
        {
            get
            {
                return _databaseType;
            }
            set
            {
                _databaseType = value;                switch (value)
                {
                    case DatabaseTypes.OleDb:
                        _iDBHelper = new OleDbHelper();
                        break;
                    case DatabaseTypes.MySql:
                        _iDBHelper = new MySqlHelper();
                        break;
                    case DatabaseTypes.Oracle:
                        _iDBHelper = new OracleHelper();
                        break;
                    case DatabaseTypes.Sql:
                    default:
                        _iDBHelper = new SqlHelper();
                        break;
                }
            }
        }        /// <summary>
        /// 数据库连接字符串
        /// </summary>
        public string ConnectionString
        {
            get { return _connectionString; }
            set { _connectionString = value; }
        }        /// <summary>
        /// 创建数据库连接
        /// </summary>
        public DbConnection CreateConnection()
        {
            switch (_databaseType)
            {
                case DatabaseTypes.MySql:
                    return new MySqlConnection(_connectionString);
                case DatabaseTypes.Oracle:
                    return new OracleConnection(_connectionString);
                case DatabaseTypes.OleDb:
                    return new OleDbConnection(_connectionString);
                case DatabaseTypes.Sql:
                default:
                    return new SqlConnection(_connectionString);
            }
        }

Answer 5

http://hi.baidu.com/jjg0513/blog/item/23174d551c795ecdb745aef5.html

Answer 6

参考微软的PetShop
或则开源的WebSharp

Answer 7

我的意见稍微不同点楼主去看看数据库的接口吧:IConnection,ICommand...
通过接口编程，通过配置文件反射接口的实例

Answer 8

参见设计模式<<大话设计模式>>中也有讲,很easy

Answer 9

ok了,已经测试通过
using System;
using System.Collections.Generic;
using System.Text;
using System.Data.SqlClient;
using System.Data;
using System.Data.Odbc;
using System.Data.OleDb;
using System.Xml;
using System.Data.Common;
using System.Data.OracleClient;namespace WindowsApplication1
{
    class DBCONN
    {
        //1为SqlServer 2为Oracle 3为MySQL 4 Access或db2或Sybase
        public static int DBTYPE = 0;
        string connstring = null;//连接字符串        public DBCONN()//获取数据类型与连接字符串 
        {
            String[] StringArray = new String[5];
            string xmlfile = "Connection.xml";
            XmlDocument xmldoc = new XmlDocument();
            xmldoc.Load(xmlfile);
            XmlNode xn = xmldoc.GetElementsByTagName("Connection")[0];
            XmlElement xe = (XmlElement)((XmlElement)xn).GetElementsByTagName("DB")[0];
            StringArray[0] = xe.GetElementsByTagName("Server")[0].InnerText;
            StringArray[1] = xe.GetElementsByTagName("Database")[0].InnerText;
            StringArray[2] = xe.GetElementsByTagName("User")[0].InnerText;
            StringArray[3] = xe.GetElementsByTagName("Password")[0].InnerText;
            StringArray[4] = xe.GetElementsByTagName("Port")[0].InnerText;
            switch (xe.GetElementsByTagName("Driver")[0].InnerText)
            {
                case "1":
                    connstring = "Data Source=" + StringArray[0] + "," + StringArray[4] + ";Initial Catalog=" + StringArray[1] + ";User ID=" + StringArray[2] + ";Password=" + StringArray[3] + ";";
                    DBTYPE = 1;
                    break;
                case "2":
                    connstring = "Data Source = (DESCRIPTION = (ADDRESS_LIST = (ADDRESS =(PROTOCOL = TCP)(HOST = " + StringArray[0] + ")(PORT = " + StringArray[4] + ")))(CONNECT_DATA = (SERVER = DEDICATED)(SERVICE_NAME = " + StringArray[1] + "))); User Id = " + StringArray[2] + "; Password = " + StringArray[3] + "";
                    DBTYPE = 2;
                    break;
                case "3":
                    connstring = "DRIVER={MySQL ODBC 3.51 Driver};SERVER=" + StringArray[0] + ";DATABASE=" + StringArray[1] + ";User ID=" + StringArray[2] + ";Password=" + StringArray[3] + ";";
                    DBTYPE = 3;
                    break;
                case "4":
                    connstring = "Provider=Microsoft.Jet.OleDb.4.0;Data Source=" + StringArray[1];
                    DBTYPE = 4;
                    break;
                case "5":
                    connstring = "Data Source=" + StringArray[0] + "," + StringArray[4] + ";Initial Catalog=" + StringArray[1] + ";User ID=" + StringArray[2] + ";Password=" + StringArray[3] + ";";
                    DBTYPE = 5;
                    break;
                case "6":
                    connstring = "driver={IBM DB2 ODBC DRIVER};Database=" + StringArray[1] + ";hostname=" + StringArray[0] + ";port=" + StringArray[4] + ";protocol=TCPIP; uid=" + StringArray[2] + "; pwd=" + StringArray[3] + ";";
                    DBTYPE = 6;
                    break;
                default:
                    break;
            }
        }        public DataSet ReTurnDataSet(string comm)//返回dataset
        {
            DataSet DS = new DataSet();
            try
            {
                DbConnection DbConn =GetConn();
                DbDataAdapter DbDa = GetDa(comm, DbConn);
                DbDa.Fill(DS);
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.ToString());
            }
            return DS;
        }        public bool execut(string comm)
        {
            DbCommand DbComm = GetComm(comm);
            DbConnection DbConn = GetConn();
            try
            {
                DbConn.Open();
                DbComm.ExecuteNonQuery();
                return true;
            }
            catch (Exception ex)
            {
                Console.WriteLine(ex.ToString());
                return false;
            }
            finally
            {
                DbConn.Close();
                DbComm.Dispose();
            }
        }        public DbConnection GetConn()//产生数据库连接
        {
            DbConnection DbConn = null;
            switch (DBTYPE)
            {
                case 1:
                    DbConn = new SqlConnection(connstring);
                    break;
                case 2:
                    DbConn = new OracleConnection(connstring);
                    break;
                case 3:
                    DbConn = new OdbcConnection(connstring);
                    break;
                case 4:
                    DbConn = new OleDbConnection(connstring);
                    break;
            }
            return DbConn;
        }
        public DbCommand GetComm(string comtext)//产生数据库命令
        {
            DbCommand DbConn = null;
            switch (DBTYPE)
            {
                case 1:
                    DbConn = new SqlCommand(comtext);
                    break;
                case 2:
                    DbConn = new OracleCommand(comtext);
                    break;
                case 3:
                    DbConn = new OdbcCommand(comtext);
                    break;
                case 4:
                    DbConn = new OleDbCommand(comtext);
                    break;
            }
            return DbConn;
        }
        public DbDataAdapter GetDa(string cmdText, DbConnection Dbconn)//产生数据适配器
        {
            DbDataAdapter DBda = null;
            switch (DBTYPE)
            {
                case 1:
                    DBda = new SqlDataAdapter(cmdText, (SqlConnection)Dbconn);
                    break;
                case 2:
                    DBda = new OracleDataAdapter(cmdText, (OracleConnection)Dbconn);
                    break;
                case 3:
                    DBda = new OdbcDataAdapter(cmdText, (OdbcConnection)Dbconn);
                    break;
                case 4:
                    DBda = new OleDbDataAdapter(cmdText, (OleDbConnection)Dbconn);
                    break;
            }
            return DBda;
        }
    }
}