Web C#2.0 DataSet和Reader封裝元件實作自動多資料庫切換（含元件源碼和執行個體）

WebConf配置：

<?xml version="1.0"?>

<!--

    注意: 除了手動編輯此檔案以外，您還可以使用

    Web 管理工具來配置應用程式的設定。可以使用 Visual Studio 中的

     “網站”->“Asp.Net 配置”選項。

    設定和注釋的完整清單在 

    machine.config.comments 中，該檔案通常位于 

    \Windows\Microsoft.Net\Framework\v2.x\Config 中

-->

<configuration>

 <appSettings>

  <!--***************** 資料庫的設定 *****************

  !— OperatorDataCode：  資料庫操作引擎授權碼(自動判斷域名)

  !— OperatorDataLink：  資料庫連結參數(自動判斷類型)

  !— Access類型：     /安裝目錄/Data/資料庫名.mdb

  !— SQL Server類型： uid=賬号;pwd=密碼;database=資料庫;server=伺服器

 **************************************************-->

  <add key="OperatorDataCode"  value="00000000-00000000"/>

  <!add key="OperatorDataLink"  value="dbAcc.mdb"/>

        <!--add key="OperatorDataLink"  value="uid=sa;pwd=sa;database=dbSQL;server=."/-->

  <!--***********************************************-->

 </appSettings>

 <connectionStrings/>

 <system.web>

  <!--

            設定 compilation debug="true" 将調試符号插入

            已編譯的頁面中。但由于這會 

            影響性能，是以隻在開發過程中将此值 

            設定為 true。

        -->

  <compilation debug="true"/>

            通過 <authentication> 節可以配置 ASP.NET 使用的 

            安全身份驗證模式，

            以辨別傳入的使用者。

  <authentication mode="Windows"/>

        <customErrors mode="RemoteOnly"/>

            如果在執行請求的過程中出現未處理的錯誤，

            則通過 <customErrors> 節可以配置相應的處理步驟。具體說來，

            開發人員通過該節可以配置

            要顯示的 html 錯誤頁

            以代替錯誤堆棧跟蹤。

        <customErrors mode="RemoteOnly" defaultRedirect="GenericErrorPage.htm">

            <error statusCode="403" redirect="NoAccess.htm" />

            <error statusCode="404" redirect="FileNotFound.htm" />

        </customErrors>

 </system.web>

</configuration>

/* •——————————————————————————•

   | Title:  智能判斷資料源                            |

   | Project: DBOperatorService.Data                   |

   | Subarea: DataSet                                  |

   | Author: ξ箫音ξ                                  |

   | Website: www.crfly.com;bbs.52happy.net            |

   | Created date: 01/16/2007                          |

   | Changed date: 01/17/2007                          |

   •——————————————————————————• */

using System;

using System.Configuration;

using System.Web.UI;

using DBOperator.Data;

namespace System.Data

{

    public class osdData : Page

    {

        // Statics

        public static string DataLink;

        // Constructors

        static osdData ()

        {

            osdData.DataLink = ConfigurationManager.AppSettings["OperatorDataLink"];

        }

        public osdData ()

        // Methods

        public static DataSet DataSet (string sql, int startindex, int num, string dataname)

            if (osdData.DataLink.ToUpper().IndexOf(";SERVER=") != -1)

            {

                return OperatorSql.ExecuteDataSet(sql, startindex, num, dataname);

            }

            return OperatorAcc.ExecuteDataSet(sql, startindex, num, dataname);

        public static void ExecuteNonQuery (string sql)

            if (osdData.DataLink.ToUpper().IndexOf("SERVER") != -1)

                OperatorSql.ExecuteNonQuery(sql);

            else

                OperatorAcc.ExecuteNonQuery(sql);

        public static object Executescalar (string SQL, int i)

                return OperatorSql.ExecuteScalar(SQL, i);

            return OperatorAcc.ExecuteScalar(SQL, i);

    }

}

using System.Data.OleDb;

using System.Data.SqlClient;

using System.Reflection;

    //[DefaultMember("Item")]

    public class osdReader

        // Instance Fields

        public osdData myData;

        public OperatorAcc myAcc;

        public OperatorSql mySql;

        private OleDbDataReader OleDR;

        private SqlDataReader SqlDR;

        public osdReader (OleDbDataReader dr)

            this.myData = new osdData();

            this.myAcc = new OperatorAcc();

            this.mySql = new OperatorSql();

            if (osdData.DataLink.ToUpper().IndexOf(";SERVER=") == -1)

                this.OleDR = dr;

        public osdReader (SqlDataReader dr)

                this.SqlDR = dr;

        public osdReader(string SQL)

                OperatorSql.Open();

                this.SqlDR = new SqlCommand(SQL, OperatorSql.ConnSql).ExecuteReader();

                OperatorAcc.Open();

                this.OleDR = new OleDbCommand(SQL, OperatorAcc.ConnAcc).ExecuteReader();

        public bool Read ()

                return this.SqlDR.Read();

            return this.OleDR.Read();

        public void Close ()

                this.SqlDR.Close();

                OperatorSql.Close();

                this.OleDR.Close();

                OperatorAcc.Close();

        // Properties

        public object this[string cs]

            get

                if (osdData.DataLink.ToUpper().IndexOf(";SERVER=") != -1)

                {

                    return this.SqlDR[cs];

                }

                return this.OleDR[cs];

使用方法簡單說明：

1、代碼對比

1)傳統Web網站資料庫程式設計代碼

GridView1.DataSource = ds.Tables[TableName1].DefaultView;

GridView1.DataBind();

2)使用DBOperator.Data資料庫元件

        GridView1.DataSource = ds;

        GridView1.DataBind();

2、資料庫配置

WebConfig裡使用哪個資料庫，就打開哪個。

 <!add key="OperatorDataLink"  value="dbAcc.mdb"/>

3、資料源調用

例如：1) DataSet調用方法：

    protected void Page_Load(object sender, EventArgs e)

    {

        DataSet ds = osdData.DataSet("SELECT * FROM XiaoYin_User", 0, 0, "dsTable");//使用組

       件的scData類，實作DataSet功能

        //資料源

        //為GridView綁定資料

    }

      2) Reader調用方法：

      protected void Page_Load(object sender, EventArgs e)

      {

        //使用scReader類，實作DataReader功能

        osdReader dr = new osdReader("SELECT * FROM XiaoYin_User");

        //循環啟動閱讀器

        while (dr.Read())

        {

            //輸出指定列

            Response.Write(dr["u_name"] + "<br>");

        }

        dr.Close();//關閉閱讀器

      }

實作功能：

osdDataSet類

     讀取(DataSet方式)，插入，更新，删除，統計

     1,讀取

       DataSet ds=osdData.DataSet("SELECT * FROM 表 WHERE 條件",開始行,多少行,"虛拟表名");

     2,插入

       osdData.ExecuteNonQuery("INSERT INTO 表 (列1，列2) VALUES (變量1,變量2)"); 

     3,更新

       osdData.ExecuteNonQuery("UPDATE 表 SET 列1=變量A,列2=變量B WHERE 條件");

     4,删除

       osdData.ExecuteNonQuery("DELETE 表 WHERE 條件"); 

     5,統計

       osdData.ExecuteScalar("SELECT * FROM 表 WHERE 條件",統計類型)

統計類型分兩種：

       int 整型：1

       double 帶小數點：2

//---------- osdReader類 --------------------

實作功能：讀取(DataReader閱讀器方式)

調用方法：

osdReader dr=new osdReader("SELECT * FROM 表 WHERE 條件");

//--------------------------------------------

if(dr.Read())

   //如果特定條件的值存在，立即終止下一行的讀取

while(dr.Read)

   //循環讀取符合條件的值

調用讀取出來的值：

dr["列名"].ToString();

使用完後關閉：

dr.Close();

全部源碼與執行個體打包下載下傳位址：

<a href="http://bbs.crfly.com/19591/ShowPost.aspx">http://bbs.crfly.com/19591/ShowPost.aspx</a>