2. 程式人生 > >我的DbHelper資料操作類

我的DbHelper資料操作類

阿新 • • 發佈：2019-01-08
      其實,微軟的企業庫中有一個非常不錯的資料操作類了.但是,不少公司(起碼我遇到的幾個...),對一些"封裝"了些什麼的東西不太敢用,雖然我推薦過微軟的企業庫框架了...但是還是要"評估"...一評就是幾個月...而且,一些公司有的根本就是裸ado.net開發,或者自己封裝的資料庫操作類非常彆扭,很不好用.

      這裡我給大家共享一個我參照企業庫中的資料操作元件編碼風格寫的資料庫操作類,對使用它的程式設計師來說,編碼是很舒服滴(起碼我覺得很好撒).以下是程式碼,很簡單的,沒有做任何多餘的封裝,只是改變了ADO.NET的編碼步驟,方便了具體開發資料庫操作程式碼的程式設計師.

    using System;
    using System.Data;
    using System.Data.Common;
    using System.Configuration;

    public class DbHelper
    {
        private static string dbProviderName = ConfigurationManager.AppSettings["DbHelperProvider"];
        private static string dbConnectionString = ConfigurationManager.AppSettings["DbHelperConnectionString"];

        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
    }

    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();
            }
        }
    }
那麼如何使用它呢?下面我給出一些基本的使用示例,基本能滿足你大部分的資料庫操作需要了.

1)直接執行sql語句

        DbHelper db = new DbHelper();
        DbCommand cmd = db.GetSqlStringCommond("insert t1 (id)values('haha')");
        db.ExecuteNonQuery(cmd);

2)執行儲存過程 
        DbHelper db = new DbHelper();
        DbCommand cmd = db.GetStoredProcCommond("t1_insert");
        db.AddInParameter(cmd, "@id", DbType.String, "heihei");
        db.ExecuteNonQuery(cmd);

3)返回DataSet

        DbHelper db = new DbHelper();
        DbCommand cmd = db.GetSqlStringCommond("select * from t1");
        DataSet ds = db.ExecuteDataSet(cmd);

4)返回DataTable

        DbHelper db = new DbHelper();
        DbCommand cmd = db.GetSqlStringCommond("t1_findall");
        DataTable dt = db.ExecuteDataTable(cmd);

5)輸入引數/輸出引數/返回值的使用(比較重要哦)

        DbHelper db = new DbHelper();
        DbCommand cmd = db.GetStoredProcCommond("t2_insert");
        db.AddInParameter(cmd, "@timeticks", DbType.Int64, DateTime.Now.Ticks);
        db.AddOutParameter(cmd, "@outString", DbType.String, 20);
        db.AddReturnParameter(cmd, "@returnValue", DbType.Int32);

        db.ExecuteNonQuery(cmd);

        string s = db.GetParameter(cmd, "@outString").Value as string;//out parameter
        int r = Convert.ToInt32(db.GetParameter(cmd, "@returnValue").Value);//return value

6)DataReader使用

        DbHelper db = new DbHelper();
        DbCommand cmd = db.GetStoredProcCommond("t2_insert");
        db.AddInParameter(cmd, "@timeticks", DbType.Int64, DateTime.Now.Ticks);
        db.AddOutParameter(cmd, "@outString", DbType.String, 20);
        db.AddReturnParameter(cmd, "@returnValue", DbType.Int32);

        using (DbDataReader reader = db.ExecuteReader(cmd))
        {
            dt.Load(reader);
        }        
        string s = db.GetParameter(cmd, "@outString").Value as string;//out parameter
        int r = Convert.ToInt32(db.GetParameter(cmd, "@returnValue").Value);//return value

7)事務的使用.(專案中需要將基本的資料庫操作組合成一個完整的業務流時,程式碼級的事務是必不可少的哦)

    pubic void DoBusiness()
    {
        using (Trans t = new Trans())
        {
            try
            {
                D1(t);
                throw new Exception();//如果有異常,會回滾滴
                D2(t);
                t.Commit();
            }
            catch
            {
                t.RollBack();
            }
        }
    }
    public void D1(Trans t)
    {
        DbHelper db = new DbHelper();
        DbCommand cmd = db.GetStoredProcCommond("t2_insert");
        db.AddInParameter(cmd, "@timeticks", DbType.Int64, DateTime.Now.Ticks);
        db.AddOutParameter(cmd, "@outString", DbType.String, 20);
        db.AddReturnParameter(cmd, "@returnValue", DbType.Int32);

        if (t == null) db.ExecuteNonQuery(cmd);
        else db.ExecuteNonQuery(cmd,t);

        string s = db.GetParameter(cmd, "@outString").Value as string;//out parameter
        int r = Convert.ToInt32(db.GetParameter(cmd, "@returnValue").Value);//return value
    }
    public void D2(Trans t)
    {
        DbHelper db = new DbHelper();
        DbCommand cmd = db.GetSqlStringCommond("insert t1 (id)values('..')");        
        if (t == null) db.ExecuteNonQuery(cmd);
        else db.ExecuteNonQuery(cmd, t);
    }

以上我們好像沒有指定資料庫連線字串,大家如果看下DbHelper的程式碼,就知道要使用它必須在config中配置兩個引數,如下:

    <appSettings>
        <add key="DbHelperProvider" value="System.Data.SqlClient"/>
        <add key="DbHelperConnectionString" value="Data Source=(local);Initial Catalog=DbHelperTest;Persist Security Info=True;User ID=sa;Password=sa"/>
    </appSettings>

其實,DbHelper需要的僅僅是兩個字串,你可以自己修改,作成加密什麼的...

好了,就這樣,DbHelper的程式碼是非常簡單和透明的,只是在ado.net上做了一點小包裝,改變了一下使用它的程式設計師的編碼方式,去除掉一些比較"物理級"的程式設計概念,如connection的open和close之類的,使程式設計師更專注於業務邏輯程式碼的編寫,少死掉點腦細胞,另外,統一了資料操作層的資料操作程式碼的風格和格式,維護起來很方便的撒~~~

另:以上程式碼大家可以隨意使用, 不需要給我版權費的啦,嘿嘿.如果大家發現有什麼BUG,或者有更好的資料操作類的實現方式,請聯絡我哦.

相關推薦

我的DbHelper資料操作類

      其實,微軟的企業庫中有一個非常不錯的資料操作類了.但是,不少公司(起碼我遇到的幾個...),對一些"封裝"了些什麼的東西不太敢用,雖然我推薦過微軟的企業庫框架了...但是還是要"評估"...一評就是幾個月...而且,一些公司有的根本就是裸ado.net開發,或者

C#資料庫程式設計 之 DbHelper資料操作類【DBHelper.CS】

其實,微軟的企業庫中有一個非常不錯的資料操作類了.但是,不少公司(起碼我遇到的幾個...),對一些"封裝"了些什麼的東西不太敢用,雖然我推薦過微軟的企業庫框架了...但是還是要"評估"...一評就是幾個月...而且,一些公司有的根本就是裸ado.net開發,或者自己封裝的資

關於面對物件過程中的三大架構以及資料訪問層（實體類、資料操作類）

關於面對物件過程中的三大架構以及資料訪問層（實體類、資料操作類） 面向物件開發專案三層架構： 介面層、業務邏輯層、資料訪問層 資料訪問層，分為實體類和資料訪問類 在專案的下面新增一個App_Code資料夾把所有的類放在App_Code這個資料夾下邊。

【Qt】資料型別和有用的資料操作類

除了C++提供的基本資料型別之外，Qt還提供了了對開發者而言非常有用的多種資料型別。Qt提供的資料型別分為基本資料型別和類形態的資料型別。   基本資料型別 Qt支援多個平臺，建立的應用程式需要在多種平臺上都具有相同大小的資料型別。為了能精確指定資料型別的大小，Qt提供了一

Python：MySQL資料操作類封裝

#!/usr/bin/env python # coding:UTF-8 """ @version: python3.x @author:曹新健 @contact: [email protected] @software: PyCharm @file: dbSq

一個比較常用的關於php下的mysql資料操作類

<?php /************************************************************* MySql類封裝： 首先連線資料庫，需要有引數 引數如何傳？ 1、可以用配置檔案 2、可以通過建構函式傳參 ************

【無私分享：從入門到精通ASP.NET MVC】從0開始，一起搭框架、做專案（3）公共基礎資料操作類 RepositoryBase

索引 簡述 今天我們寫一個基礎資料的操作類，如果裡面有大家不理解的地方，可採取兩種方式，第一：提出來，第二：會用就行。這個類呢我一般不去修改它，因為基礎操作類，大家也可以直接拷貝到自己的專案中。 專案準備 我們用的工具是：VS 2013 + SqlServer 2012 + IIS7.5 希望大

Java連線mysql資料操作類

Java中連線mysql資料庫 把jar檔案匯入到專案裡。 1.右擊要匯入jar包的專案，點properties 2.左邊選擇java build path,右邊選擇libraries 3.選擇

10）SpringBoot 資料操作04 -> JPA實體類註解、springboot測試類、lombok的使用

前提準備： 　　搭建一個springboot專案，詳情請參見其它部落格：點選前往 1 引入相關依賴 　　web、mysql、jpa、lombok <?xml version="1.0" encoding="UTF-8"?> <project

Util應用程式框架公共操作類（一）:資料型別轉換公共操作類（介紹篇）

　　本系列文章將介紹一些對初學者有幫助的輔助類，這些輔助類本身並沒有什麼稀奇之處，如何能發現需要封裝它們可能更加重要，所謂授之以魚不如授之以漁，掌握封裝公共操作類的技巧才是關鍵，我會詳細說明建立這些類的動機和思考過程，以幫助初學者發現和封裝自己需要的東西。建立公共操作類的技巧，大家可以參考我的這篇文章——應用

Util應用程式框架公共操作類(二):資料型別轉換公共操作類（原始碼篇）

1 using System; 2 using Microsoft.VisualStudio.TestTools.UnitTesting; 3 4 namespace Util.Tests { 5 /// <summary> 6 /// 型別轉換

Util應用程式框架公共操作類(三):資料型別轉換公共操作類（擴充套件篇）

1 using System; 2 using System.Collections.Generic; 3 using Microsoft.VisualStudio.TestTools.UnitTesting; 4 5 namespace Util.Tests.Extension

強大的資料庫操作類DBHelper

本示例程式碼的關鍵是利用.net庫自帶的DbProviderFactory來生產資料庫操作物件。 從下圖中，可以看到其的多個核心方法，這些方法將在我們的超級DBHelper中使用。 仔細研究，你會發現每個資料庫的官方支援dll都有一

asp.net學習總結——ADO.net（對Sql Server進行操作的資料訪問類）

ADO.net物件     System.Data.SqlClient（對Sql Server進行操作的資料訪問類）： 1)SqlConnection：資料庫聯結器2)SqlCommand：資料庫命名

Java8集合類庫的批量資料操作

第三章：Java集合類庫的批量資料操作 引入批量資料操作的目的是應用lambda函式來實現包含並行操作在內的多種資料處理功能，而支援並行資料操作是其關鍵內容。這個並行操作是在Java7 java.util.concurrency的Fork/Join機制上實現的。 批量操作介

封裝JPA的資料操作DAO類

對JPA的實體操作進行了簡單的封裝，降低了資料操作的難度，提高了開發的效率。裡面可能會有少許hibernate的元素。 DAO.java package com.posoftframework.dao;import java.util.LinkedHashMa

Selenium_Python接口-實例對象操作類WebDriver

cto pac exc lena targe style item github nav WebDriver路徑：from selenium.webdriver.remote.webdriver import WebDriver WebDriver內容：打開指定網頁、執行j

session操作類

expr 說明 mes 代碼 foreach minute geo 使用說明 logs 實現代碼： //聲名一個數據集合 var listString = new List<string>() { "a", "b", "c" };

Cookies操作類

context .text amp add collect syn https sum 分鐘 實現代碼： //聲名一個數據集合 var listString = new List<string>() { "a", "b", "c" };

C#常用工具類——Excel操作類(ZT)

ada fin bject sta area exec public excel文件 站點 本文轉載於： http://www.cnblogs.com/zfanlong1314/p/3916047.html 1 /// 常用工具類—&mdash