激情内射亚洲一区二区三区_ 用C#打造自己的通用數據訪(fǎng)問(wèn)類(lèi)庫(續)

說(shuō)明：此篇文章是給那些和我一樣仍在使用ADO.NET訪(fǎng)問(wèn)數據庫的.NET開(kāi)發(fā)人員寫(xiě)的，因為某些原因，比如還在使用.NET3.0以下版本開(kāi)發(fā).NET應用或者所使用的數據庫對ORM支持不是很好，或者是對ORM的性能有所懷疑（其實(shí)在訪(fǎng)問(wèn)量不是很大的情況下沒(méi)有必要過(guò)分追求性能的極限）等等，這部分人仍在使用傳統的ADO.NET來(lái)訪(fǎng)問(wèn)數據庫，他們或手寫(xiě)或采用代碼生成工具來(lái)生成實(shí)體類(lèi)和增刪改查的SQL語(yǔ)句，在將DataTable或者DataReader轉換成對應的實(shí)體類(lèi)的時(shí)候仍需要一行行寫(xiě)代碼，本類(lèi)就是為了解決這個(gè)問(wèn)題的，可以用幾個(gè)類(lèi)來(lái)實(shí)現方便快捷的轉換。本類(lèi)庫在SQL Server/MySQL/SQLite下測試通過(guò)，由于條件有限未在所有的數據庫下測試，如果有問(wèn)題請在此留言或者在周公的微博留言(http://weibo.com/zhoufoxcn)。

其實(shí)在寫(xiě)這套類(lèi)庫之前，去年周公就寫(xiě)了兩篇有關(guān)的文章，一篇叫《用C#打造自己的實(shí)體轉換器》，另一篇叫《利用ADO.NET的體系架構打造通用的數據庫訪(fǎng)問(wèn)通用類(lèi)》（兩篇文章的閱讀地址會(huì )在文末給出），本篇的代碼就是在這兩篇文章的基礎上經(jīng)過(guò)實(shí)際應用修改而成，主要是修正了幾個(gè)問(wèn)題：1.如果在SELECT子句的字段中不包含對應實(shí)體類(lèi)的某個(gè)屬性，那么該屬性的值就為它對應Type的默認值（如int,short為0,引用類(lèi)型為null)，而不是像以前那樣用Ignorable，因為有些屬性可能在某個(gè)查詢(xún)中需要而在另外一個(gè)查詢(xún)中不需要，采用Ignorable這樣的Attribute的話(huà)太武斷；2.修正了在泛型類(lèi)型時(shí)的錯誤；3.在類(lèi)的屬性類(lèi)型中除了支持常見(jiàn)數據類(lèi)型（數值類(lèi)型、可空類(lèi)型和string）之外，還支持byte[]這種常見(jiàn)的數據類(lèi)型。

本類(lèi)庫共有5個(gè)類(lèi)：DbProviderType、ProviderFactory、DbUtility、EntityReader、ColumnNameAttribute。

其中DbProviderType、ProviderFactory、DbUtility三個(gè)類(lèi)的相關(guān)代碼如下：

using System; 
using System.Collections.Generic; 
using System.Data; 
using System.Data.Common; 
 
namespace NetSkycn.Data 
{ 
    ///  
    /// 通用數據庫訪(fǎng)問(wèn)類(lèi)，封裝了對數據庫的常見(jiàn)操作 
    /// 作者：周公 
    /// 創(chuàng  )建日期：2011-07-18 
    /// 修改日期：2012-04-12 
    /// 新浪微博地址：http://weibo.com/zhoufoxcn 
    ///  
    public sealed class DbUtility 
    { 
        public string ConnectionString { get; set; } 
        private DbProviderFactory providerFactory; 
        ///  
        /// 構造函數 
        ///  
        /// 數據庫連接字符串 
        /// 數據庫類(lèi)型枚舉，參見(jiàn) 
        public DbUtility(string connectionString, DbProviderType providerType) 
        { 
            ConnectionString = connectionString; 
            providerFactory = ProviderFactory.GetDbProviderFactory(providerType); 
            if (providerFactory == null) 
            { 
                throw new ArgumentException('Can't load DbProviderFactory for given value of providerType'); 
            } 
        } 
        ///     
        /// 對數據庫執行增刪改操作，返回受影響的行數。    
        ///     
        /// 要執行的增刪改的SQL語(yǔ)句    
        /// 執行增刪改語(yǔ)句所需要的參數 
        ///    
        public int ExecuteNonQuery(string sql, IList parameters) 
        { 
            return ExecuteNonQuery(sql, parameters, CommandType.Text); 
        } 
        ///     
        /// 對數據庫執行增刪改操作，返回受影響的行數。    
        ///     
        /// 要執行的增刪改的SQL語(yǔ)句    
        /// 執行增刪改語(yǔ)句所需要的參數 
        /// 執行的SQL語(yǔ)句的類(lèi)型 
        ///  
        public int ExecuteNonQuery(string sql, IList parameters, CommandType commandType) 
        { 
            using (DbCommand command = CreateDbCommand(sql, parameters, commandType)) 
            { 
                command.Connection.Open(); 
                int affectedRows = command.ExecuteNonQuery(); 
                command.Connection.Close(); 
                return affectedRows; 
            } 
        } 
 
        ///     
        /// 執行一個(gè)查詢(xún)語(yǔ)句，返回一個(gè)關(guān)聯(lián)的DataReader實(shí)例    
        ///     
        /// 要執行的查詢(xún)語(yǔ)句    
        /// 執行SQL查詢(xún)語(yǔ)句所需要的參數 
        ///   
        public DbDataReader ExecuteReader(string sql, IList parameters) 
        { 
            return ExecuteReader(sql, parameters, CommandType.Text); 
        } 
 
        ///     
        /// 執行一個(gè)查詢(xún)語(yǔ)句，返回一個(gè)關(guān)聯(lián)的DataReader實(shí)例    
        ///     
        /// 要執行的查詢(xún)語(yǔ)句    
        /// 執行SQL查詢(xún)語(yǔ)句所需要的參數 
        /// 執行的SQL語(yǔ)句的類(lèi)型 
        ///   
        public DbDataReader ExecuteReader(string sql, IList parameters, CommandType commandType) 
        { 
            DbCommand command = CreateDbCommand(sql, parameters, commandType); 
            command.Connection.Open(); 
            return command.ExecuteReader(CommandBehavior.CloseConnection); 
        } 
 
        ///     
        /// 執行一個(gè)查詢(xún)語(yǔ)句，返回一個(gè)包含查詢(xún)結果的DataTable    
        ///     
        /// 要執行的查詢(xún)語(yǔ)句    
        /// 執行SQL查詢(xún)語(yǔ)句所需要的參數 
        ///  
        public DataTable ExecuteDataTable(string sql, IList parameters) 
        { 
            return ExecuteDataTable(sql, parameters, CommandType.Text); 
        } 
        ///     
        /// 執行一個(gè)查詢(xún)語(yǔ)句，返回一個(gè)包含查詢(xún)結果的DataTable    
        ///     
        /// 要執行的查詢(xún)語(yǔ)句    
        /// 執行SQL查詢(xún)語(yǔ)句所需要的參數 
        /// 執行的SQL語(yǔ)句的類(lèi)型 
        ///  
        public DataTable ExecuteDataTable(string sql, IList parameters, CommandType commandType) 
        { 
            using (DbCommand command = CreateDbCommand(sql, parameters, commandType)) 
            { 
                using (DbDataAdapter adapter = providerFactory.CreateDataAdapter()) 
                { 
                    adapter.SelectCommand = command; 
                    DataTable data = new DataTable(); 
                    adapter.Fill(data); 
                    return data; 
                } 
            } 
        } 
 
        ///     
        /// 執行一個(gè)查詢(xún)語(yǔ)句，返回查詢(xún)結果的第一行第一列    
        ///     
        /// 要執行的查詢(xún)語(yǔ)句    
        /// 執行SQL查詢(xún)語(yǔ)句所需要的參數    
        ///     
        public Object ExecuteScalar(string sql, IList parameters) 
        { 
            return ExecuteScalar(sql, parameters, CommandType.Text); 
        } 
 
        ///     
        /// 執行一個(gè)查詢(xún)語(yǔ)句，返回查詢(xún)結果的第一行第一列    
        ///     
        /// 要執行的查詢(xún)語(yǔ)句    
        /// 執行SQL查詢(xún)語(yǔ)句所需要的參數    
        /// 執行的SQL語(yǔ)句的類(lèi)型 
        ///     
        public Object ExecuteScalar(string sql, IList parameters, CommandType commandType) 
        { 
            using (DbCommand command = CreateDbCommand(sql, parameters, commandType)) 
            { 
                command.Connection.Open(); 
                object result = command.ExecuteScalar(); 
                command.Connection.Close(); 
                return result; 
            } 
        } 
 
        ///  
        /// 查詢(xún)多個(gè)實(shí)體集合 
        ///  
        /// 返回的實(shí)體集合類(lèi)型 
        /// 要執行的查詢(xún)語(yǔ)句    
        /// 執行SQL查詢(xún)語(yǔ)句所需要的參數 
        ///  
        public List QueryForList(string sql, IList parameters) where T : new() 
        { 
            return QueryForList(sql, parameters, CommandType.Text); 
        } 
 
        ///  
        ///  查詢(xún)多個(gè)實(shí)體集合 
        ///  
        /// 返回的實(shí)體集合類(lèi)型 
        /// 要執行的查詢(xún)語(yǔ)句    
        /// 執行SQL查詢(xún)語(yǔ)句所需要的參數    
        /// 執行的SQL語(yǔ)句的類(lèi)型 
        ///  
        public List QueryForList(string sql, IList parameters, CommandType commandType) where T : new() 
        { 
            DataTable data = ExecuteDataTable(sql, parameters, commandType); 
            return EntityReader.GetEntities(data); 
        } 
        ///  
        /// 查詢(xún)單個(gè)實(shí)體 
        ///  
        /// 返回的實(shí)體集合類(lèi)型 
        /// 要執行的查詢(xún)語(yǔ)句    
        /// 執行SQL查詢(xún)語(yǔ)句所需要的參數 
        ///  
        public T QueryForObject(string sql, IList parameters) where T : new() 
        { 
            return QueryForObject(sql, parameters, CommandType.Text); 
        } 
 
        ///  
        /// 查詢(xún)單個(gè)實(shí)體 
        ///  
        /// 返回的實(shí)體集合類(lèi)型 
        /// 要執行的查詢(xún)語(yǔ)句    
        /// 執行SQL查詢(xún)語(yǔ)句所需要的參數    
        /// 執行的SQL語(yǔ)句的類(lèi)型 
        ///  
        public T QueryForObject(string sql, IList parameters, CommandType commandType) where T : new() 
        { 
            return QueryForList(sql, parameters, commandType)[0]; 
        } 
 
        public DbParameter CreateDbParameter(string name, object value) 
        { 
            return CreateDbParameter(name, ParameterDirection.Input, value); 
        } 
 
        public DbParameter CreateDbParameter(string name, ParameterDirection parameterDirection, object value) 
        { 
            DbParameter parameter = providerFactory.CreateParameter(); 
            parameter.ParameterName = name; 
            parameter.Value = value; 
            parameter.Direction = parameterDirection; 
            return parameter; 
        } 
 
        ///  
        /// 創(chuàng  )建一個(gè)DbCommand對象 
        ///  
        /// 要執行的查詢(xún)語(yǔ)句    
        /// 執行SQL查詢(xún)語(yǔ)句所需要的參數 
        /// 執行的SQL語(yǔ)句的類(lèi)型 
        ///  
        private DbCommand CreateDbCommand(string sql, IList parameters, CommandType commandType) 
        { 
            DbConnection connection = providerFactory.CreateConnection(); 
            DbCommand command = providerFactory.CreateCommand(); 
            connection.ConnectionString = ConnectionString; 
            command.CommandText = sql; 
            command.CommandType = commandType; 
            command.Connection = connection; 
            if (!(parameters == null || parameters.Count == 0)) 
            { 
                foreach (DbParameter parameter in parameters) 
                { 
                    command.Parameters.Add(parameter); 
                } 
            } 
            return command; 
        } 
    } 
    ///  
    /// 數據庫類(lèi)型枚舉 
    ///  
    public enum DbProviderType : byte 
    { 
        SqlServer, 
        MySql, 
        SQLite, 
        Oracle, 
        ODBC, 
        OleDb, 
        Firebird, 
        PostgreSql, 
        DB2, 
        Informix, 
        SqlServerCe 
    } 
    ///  
    /// DbProviderFactory工廠(chǎng)類(lèi) 
    ///  
    public class ProviderFactory 
    { 
        private static Dictionary<>string> providerInvariantNames = new Dictionary<>string>(); 
        private static Dictionary providerFactoies = new Dictionary(20); 
        static ProviderFactory() 
        { 
            //加載已知的數據庫訪(fǎng)問(wèn)類(lèi)的程序集 
            providerInvariantNames.Add(DbProviderType.SqlServer, 'System.Data.SqlClient'); 
            providerInvariantNames.Add(DbProviderType.OleDb, 'System.Data.OleDb'); 
            providerInvariantNames.Add(DbProviderType.ODBC, 'System.Data.ODBC'); 
            providerInvariantNames.Add(DbProviderType.Oracle, 'Oracle.DataAccess.Client'); 
            providerInvariantNames.Add(DbProviderType.MySql, 'MySql.Data.MySqlClient'); 
            providerInvariantNames.Add(DbProviderType.SQLite, 'System.Data.SQLite'); 
            providerInvariantNames.Add(DbProviderType.Firebird, 'FirebirdSql.Data.Firebird'); 
            providerInvariantNames.Add(DbProviderType.PostgreSql, 'Npgsql'); 
            providerInvariantNames.Add(DbProviderType.DB2, 'IBM.Data.DB2.iSeries'); 
            providerInvariantNames.Add(DbProviderType.Informix, 'IBM.Data.Informix'); 
            providerInvariantNames.Add(DbProviderType.SqlServerCe, 'System.Data.SqlServerCe'); 
        } 
        ///  
        /// 獲取指定數據庫類(lèi)型對應的程序集名稱(chēng) 
        ///  
        /// 數據庫類(lèi)型枚舉 
        ///  
        public static string GetProviderInvariantName(DbProviderType providerType) 
        { 
            return providerInvariantNames[providerType]; 
        } 
        ///  
        /// 獲取指定類(lèi)型的數據庫對應的DbProviderFactory 
        ///  
        /// 數據庫類(lèi)型枚舉 
        ///  
        public static DbProviderFactory GetDbProviderFactory(DbProviderType providerType) 
        { 
            //如果還沒(méi)有加載，則加載該DbProviderFactory 
            if (!providerFactoies.ContainsKey(providerType)) 
            { 
                providerFactoies.Add(providerType, ImportDbProviderFactory(providerType)); 
            } 
            return providerFactoies[providerType]; 
        } 
        ///  
        /// 加載指定數據庫類(lèi)型的DbProviderFactory 
        ///  
        /// 數據庫類(lèi)型枚舉 
        ///  
        private static DbProviderFactory ImportDbProviderFactory(DbProviderType providerType) 
        { 
            string providerName = providerInvariantNames[providerType]; 
            DbProviderFactory factory = null; 
            try 
            { 
                //從全局程序集中查找 
                factory = DbProviderFactories.GetFactory(providerName); 
            } 
            catch (ArgumentException e) 
            { 
                factory = null; 
            } 
            return factory; 
        } 
    } 
}

其中EntityReader、ColumnNameAttribute的代碼如下：

沒(méi)辦法，不能在這里粘貼全部代碼，所以放在附件下載了，這不是我的錯，請大家諒解。

本類(lèi)庫經(jīng)過(guò)NUnit測試通過(guò)，測試截圖如下：

因為測試用的代碼涉及到下一篇博文的內容，所以會(huì )將測試代碼放到下一篇博文中。

2012-04-12

周公

------------------------------------------------

廣告：為便于武漢市的.NET開(kāi)發(fā)人員和學(xué)生參加在武漢舉辦的學(xué)習交流活動(dòng)（本人絕沒(méi)有地域歧視，只為線(xiàn)下交流方便），請有意者加以下QQ群：武漢IT群（11690964），武漢微軟移動(dòng)俱樂(lè )部（198027326）。4月14日本周六 13:30 - 17:00就有一個(gè)有關(guān)WPhone的免費線(xiàn)下交流活動(dòng)，地點(diǎn)在武漢光谷軟件園DEMO咖啡屋。如果有興趣請在新浪微博上報名，報名地址：http://event.weibo.com/405882

本文出自 “周公（周金橋）的專(zhuān)欄” 博客，請務(wù)必保留此出處http://zhoufoxcn.blog.51cto.com/792419/832631

上一篇那些年，我們一起找過(guò)的工作下一篇 “春Phone計劃”51CTO沙龍武漢站分享

文章評論

[1樓]

lyblyxj

2012-04-26

收藏之

[2樓]

股月

2012-05-18

暫時(shí)的水平，有的地方還看不懂

[3樓]

[匿名]123

2012-07-24

沒(méi)有SQL參數化，存在sql注入

[4樓]

[匿名]123

2012-07-24

''<>&

[5樓]樓主

周金橋

2012-07-26

回復 123:[3樓]

兄弟，認真看完再評論也不遲的，string sql, IList parameters, CommandType commandType，這么個(gè)參數列表，還沒(méi)有參數化？

[6樓]

杜軍

2012-09-13

周老師好，你的第二點(diǎn)泛型運行時(shí)錯誤，是指哪里呢？我沒(méi)看出來(lái)。

[7樓]

驛落黃昏

2012-11-22

望評委能夠給予支持和鼓勵http://yiluohuanghun.blog.51cto.com謝謝

[8樓]樓主

周金橋

2012-11-22

回復驛落黃昏:[7樓]

為什么不直接給投票地址呢？

[9樓]

[匿名]aaa

2013-01-07

寫(xiě)的不多

[10樓]

[匿名]aaa

2013-01-07

寫(xiě)的不錯

[11樓]

vsceo

2014-11-22

sealed class怎么調用里面的方法?

[12樓]樓主

周金橋

2014-12-10

回復 vsceo:[11樓]

為什么sealed class就不能調用了？sealed只是限制了不能繼承而已。

[13樓]

wycoo

2015-06-11

不錯，學(xué)習了哦

[14樓]

Mizzy

2015-08-15

好好學(xué)一下篇文章.

本站僅提供存儲服務(wù)，所有內容均由用戶(hù)發(fā)布，如發(fā)現有害或侵權內容，請點(diǎn)擊舉報。

欧美性猛交XXXX免费看蜜桃,成人网18免费韩国,亚洲国产成人精品区综合,欧美日韩一区二区三区高清不卡,亚洲综合一区二区精品久久

文章評論