ASP.NET 多数据库操作类

yaoleshi 2009-03-04 02:31:16

我想在asp.net写意完整的支持多种数据库的链接操作类

之前没写过，来问问个大哥大姐该如何写

多多支持

如何有现成的贴出来最好不过；如有重分感谢分少了在加

...全文

867 33 打赏收藏转发到动态举报

写回复

用AI写文章

33 条回复

切换为时间正序

请发表友善的回复…

发表回复

Icandoeverything 2009-03-24

打赏
举报

学习下，不过还是没有看太懂！

datahandler2 2009-03-08

打赏
举报

多数据库操作考虑用工厂模式的做法就可以了

BossFriday 2009-03-06

打赏
举报

直接用:Sqlhelper上网去下个。

liuyeede 2009-03-06

打赏
举报



  public class Trans : IDisposable

    {

        private DbConnection conn;

        private DbTransaction dbTrans;

        public DbConnection DbConnection

        {

            get { return this.conn; }

        }

        public DbTransaction DbTrans

        {

            get { return this.dbTrans; }

        }



        public Trans()

        {

            conn = DbHelper.CreateConnection();

            conn.Open();

            dbTrans = conn.BeginTransaction();

        }

        public Trans(string connectionString)

        {

            conn = DbHelper.CreateConnection(connectionString);

            conn.Open();

            dbTrans = conn.BeginTransaction();

        }

        public void Commit()

        {

            dbTrans.Commit();

            this.Colse();

        }



        public void RollBack()

        {

            dbTrans.Rollback();

            this.Colse();

        }



        public void Dispose()

        {

            this.Colse();

        }



        public void Colse()

        {

            if (conn.State == System.Data.ConnectionState.Open)

            {

                conn.Close();

            }

        }

    }

}

liuyeede 2009-03-06

打赏
举报



using System;

using System.Data;

using System.Data.Common;

using System.Configuration;

namespace ClothesB2C.DbUtility

{

    public class DbHelper

    {

        private static string dbProviderName = ConfigurationManager.AppSettings["DbHelperProvider"];

        private static string dbConnectionString = ConfigurationManager.ConnectionStrings["ClothesSqlConnection"].ConnectionString;



        private DbConnection connection;

        public DbHelper()

        {

            this.connection = CreateConnection(DbHelper.dbConnectionString);

        }



        public DbHelper(string connectionString)

        {

            this.connection = CreateConnection(connectionString);

        }



        public static DbConnection CreateConnection()

        {

            DbProviderFactory dbfactory = DbProviderFactories.GetFactory(DbHelper.dbProviderName);

            DbConnection dbconn = dbfactory.CreateConnection();

            dbconn.ConnectionString = DbHelper.dbConnectionString;

            return dbconn;

        }

        public static DbConnection CreateConnection(string connectionString)

        {

            DbProviderFactory dbfactory = DbProviderFactories.GetFactory(DbHelper.dbProviderName);

            DbConnection dbconn = dbfactory.CreateConnection();

            dbconn.ConnectionString = connectionString;

            return dbconn;

        }



        public DbCommand GetStoredProcCommond(string storedProcedure)

        {

            DbCommand dbCommand = connection.CreateCommand();

            dbCommand.CommandText = storedProcedure;

            dbCommand.CommandType = CommandType.StoredProcedure;

            return dbCommand;

        }

        public DbCommand GetSqlStringCommond(string sqlQuery)

        {

            DbCommand dbCommand = connection.CreateCommand();

            dbCommand.CommandText = sqlQuery;

            dbCommand.CommandType = CommandType.Text;

            return dbCommand;

        }

        #region 增加参数

        public void AddParameterCollection(DbCommand cmd, DbParameterCollection dbParameterCollection)

        {

            foreach (DbParameter dbParameter in dbParameterCollection)

            {

                cmd.Parameters.Add(dbParameter);

            }

        }

        public void AddOutParameter(DbCommand cmd, string parameterName, DbType dbType, int size)

        {

            DbParameter dbParameter = cmd.CreateParameter();

            dbParameter.DbType = dbType;

            dbParameter.ParameterName = parameterName;

            dbParameter.Size = size;

            dbParameter.Direction = ParameterDirection.Output;

            cmd.Parameters.Add(dbParameter);

        }

        public void AddInParameter(DbCommand cmd, string parameterName, DbType dbType, object value)

        {

            DbParameter dbParameter = cmd.CreateParameter();

            dbParameter.DbType = dbType;

            dbParameter.ParameterName = parameterName;

            dbParameter.Value = value;

            dbParameter.Direction = ParameterDirection.Input;

            cmd.Parameters.Add(dbParameter);

        }

        public void AddReturnParameter(DbCommand cmd, string parameterName, DbType dbType)

        {

            DbParameter dbParameter = cmd.CreateParameter();

            dbParameter.DbType = dbType;

            dbParameter.ParameterName = parameterName;

            dbParameter.Direction = ParameterDirection.ReturnValue;

            cmd.Parameters.Add(dbParameter);

        }

        public DbParameter GetParameter(DbCommand cmd, string parameterName)

        {

            return cmd.Parameters[parameterName];

        }



        #endregion

        #region 执行

        public DataSet ExecuteDataSet(DbCommand cmd)

        {

            DbProviderFactory dbfactory = DbProviderFactories.GetFactory(DbHelper.dbProviderName);

            DbDataAdapter dbDataAdapter = dbfactory.CreateDataAdapter();

            dbDataAdapter.SelectCommand = cmd;

            DataSet ds = new DataSet();

            dbDataAdapter.Fill(ds);

            return ds;

        }



        public DataTable ExecuteDataTable(DbCommand cmd)

        {

            DbProviderFactory dbfactory = DbProviderFactories.GetFactory(DbHelper.dbProviderName);

            DbDataAdapter dbDataAdapter = dbfactory.CreateDataAdapter();

            dbDataAdapter.SelectCommand = cmd;

            DataTable dataTable = new DataTable();

            dbDataAdapter.Fill(dataTable);

            return dataTable;

        }



        public DbDataReader ExecuteReader(DbCommand cmd)

        {

            cmd.Connection.Open();

            DbDataReader reader = cmd.ExecuteReader(CommandBehavior.CloseConnection);

            return reader;

        }

        public int ExecuteNonQuery(DbCommand cmd)

        {

            cmd.Connection.Open();

            int ret = cmd.ExecuteNonQuery();

            cmd.Connection.Close();

            return ret;

        }



        public object ExecuteScalar(DbCommand cmd)

        {

            cmd.Connection.Open();

            object ret = cmd.ExecuteScalar();

            cmd.Connection.Close();

            return ret;

        }

        #endregion

        #region 执行事务

        public DataSet ExecuteDataSet(DbCommand cmd, Trans t)

        {

            cmd.Connection = t.DbConnection;

            cmd.Transaction = t.DbTrans;

            DbProviderFactory dbfactory = DbProviderFactories.GetFactory(DbHelper.dbProviderName);

            DbDataAdapter dbDataAdapter = dbfactory.CreateDataAdapter();

            dbDataAdapter.SelectCommand = cmd;

            DataSet ds = new DataSet();

            dbDataAdapter.Fill(ds);

            return ds;

        }



        public DataTable ExecuteDataTable(DbCommand cmd, Trans t)

        {

            cmd.Connection = t.DbConnection;

            cmd.Transaction = t.DbTrans;

            DbProviderFactory dbfactory = DbProviderFactories.GetFactory(DbHelper.dbProviderName);

            DbDataAdapter dbDataAdapter = dbfactory.CreateDataAdapter();

            dbDataAdapter.SelectCommand = cmd;

            DataTable dataTable = new DataTable();

            dbDataAdapter.Fill(dataTable);

            return dataTable;

        }



        public DbDataReader ExecuteReader(DbCommand cmd, Trans t)

        {

            cmd.Connection.Close();

            cmd.Connection = t.DbConnection;

            cmd.Transaction = t.DbTrans;

            DbDataReader reader = cmd.ExecuteReader();

            DataTable dt = new DataTable();

            return reader;

        }

        public int ExecuteNonQuery(DbCommand cmd, Trans t)

        {

            cmd.Connection.Close();

            cmd.Connection = t.DbConnection;

            cmd.Transaction = t.DbTrans;

            int ret = cmd.ExecuteNonQuery();

            return ret;

        }



        public object ExecuteScalar(DbCommand cmd, Trans t)

        {

            cmd.Connection.Close();

            cmd.Connection = t.DbConnection;

            cmd.Transaction = t.DbTrans;

            object ret = cmd.ExecuteScalar();

            return ret;

        }

        #endregion

    }

liuyeede 2009-03-06

打赏
举报

用DbFactrory吧，写好后只需要在web.config中配置他的Provider就可以了。oracle、MySql、SqlServer都可以先使用的。

Relief_001 2009-03-06

打赏
举报

下载个SqlHelper.cs 自己改

Roc_Lee 2009-03-06

打赏
举报

楼上的实在

gui0605 2009-03-06

打赏
举报

[Quote=引用 6 楼 lovehongyun 的回复:]
楼主可以去下载个微软企业库.

可以用里边的数据访问部分
[/Quote]
MS企业库确实好用

way106vip 2009-03-06

打赏
举报

这么多高手在啊！~~顶起···

jfd198512 2009-03-06

打赏
举报

顶 LZ

jfd198512 2009-03-06

打赏
举报

顶 LZ

jiang_jiajia10 2009-03-06

打赏
举报

工厂模式的就可以还有就是sqlhelper

A海阔天空 2009-03-06

打赏
举报

ls的答的不是他问的

zzxap 2009-03-06

打赏
举报

用oledbconnection

feifeiyiwen 2009-03-06

打赏
举报

wangzhenyue 2009-03-05

打赏
举报

举一反三。。差不了多少

yaoleshi 2009-03-05

打赏
举报

[Quote=引用 10 楼 patrickpan 的回复:]
你的意思是操作不同的数据库（如MySql，SQL Server），还是支持同一种数据库中的不同数据库名（如SQL Server中的两个数据库：Test1，Test2），如果是第一种，前面有答案了，如果是第二种。
public static class DBHelper
{
public static connString="连接一";
public static DataSet Query(string sql)
{
.................
return ds;
}
.................
}

pub…
[/Quote]

是你所说的第一种

patrickpan 2009-03-05

打赏
举报

你的意思是操作不同的数据库（如MySql，SQL Server），还是支持同一种数据库中的不同数据库名（如SQL Server中的两个数据库：Test1，Test2），如果是第一种，前面有答案了，如果是第二种。
public static class DBHelper
{
public static connString="连接一";
public static DataSet Query(string sql)
{
.................
return ds;
}
.................
}

public class DBHelperA
{
public connString = "连接二";
public DataSet Query(string sql)
{
.................
return ds;
}
.................
}