簡化基于數(shù)據(jù)庫的DotNet應(yīng)用程序開發(fā)

2019-11-17 04:16:31

字體：大中小

供稿：網(wǎng)友

分析

　　要做一個(gè)基于數(shù)據(jù)庫的應(yīng)用程序，我們有大量的重復(fù)勞動(dòng)要去做，建表，寫增刪改查的SQL語句，寫與數(shù)據(jù)庫表對應(yīng)的實(shí)體類，寫執(zhí)行SQL的c#代碼，寫添加、修改、列表、詳細(xì)頁面等等。這些活動(dòng)都是圍繞著一個(gè)個(gè)都數(shù)據(jù)表來開展的，在.NET領(lǐng)域有很多的OR Mapping的方案，但好多方案用起來好用，但原理很復(fù)雜，而且性能也不好把握，所以我們可以做一個(gè)輕型的ORM方案。有了ORM框架，根據(jù)數(shù)據(jù)表寫c#實(shí)體類這些勞動(dòng)，其實(shí)也可以寫一個(gè)代碼生成器來幫我們生成，甚至代碼生成器還能幫我們生成一些界面的代碼。我們大概需要解決如下問題
1、我們要有一個(gè)通用的數(shù)據(jù)庫操作幫助類，類似微軟的DAAB，但最好能支持多種數(shù)據(jù)庫；
2、我們要有一個(gè)使用簡單的orm框架，能方便的用c#代碼來進(jìn)行數(shù)據(jù)庫存取操作，而且要盡量保證性能，比如使用參數(shù)化查詢；
3、我們要有一個(gè)代碼生成器幫助我們解決一些重復(fù)性勞動(dòng)，比如生成實(shí)體類，生成調(diào)用存儲(chǔ)過程的c#代碼等；

圍繞這3個(gè)問題，我們一一來展開

一、通用的數(shù)據(jù)庫吃操作幫助類

　　ADO.NET 2.0為我們訪問數(shù)據(jù)庫提供了一套與具體數(shù)據(jù)庫無關(guān)的模型，其核心類是DbPRoviderFactory，它遵循了Provider模式，就是把對各種數(shù)據(jù)庫的操作抽象出一個(gè)Provider，再由各種數(shù)據(jù)庫去寫與具體數(shù)據(jù)庫相關(guān)的Provider，然后通過配置在運(yùn)行時(shí)方便的切換數(shù)據(jù)庫，而盡量少的不修改業(yè)務(wù)邏輯層的代碼，業(yè)務(wù)邏輯層依賴的是抽象的Provider。這也是典型的依賴倒置，就是說業(yè)務(wù)邏輯說我需要哪些接口，我依賴這些接口，而讓別人去實(shí)現(xiàn)這些接口，在運(yùn)行的時(shí)候再去加載調(diào)用實(shí)現(xiàn)這些接口的具體類。
　　為了提高性能，減少SQLSERVER執(zhí)行計(jì)劃的重編譯，我們盡量使用參數(shù)化的查詢，而一個(gè)固定的語句或者存儲(chǔ)過程它的ADO.NET參數(shù)是固定的，所以我們可以把這些參數(shù)緩存起來，避免每次執(zhí)行SQL語句都創(chuàng)新新的參數(shù)對象。另外oledb的ado.net provider的參數(shù)是不能命名的，所以給參數(shù)賦值要按順序賦值。

　　為了使用方便，我們?yōu)閳?zhí)行SQL語句提供如下的API

public system.Data.DataSet SqlExecuteDateSet(string sql, string[] paramters, params object[] values)
public system.Data.DataTable SqlExecuteDateTable(string sql, string[] paramters, params object[] values)
public int SqlExecuteNonQuery(string sql, string[] paramters, params object[] values)
public system.Data.Common.DbDataReader SqlExecuteReader(string sql, string[] paramters, params object[] values)
public object SqlExecuteScalar(string sql, string[] paramters, params object[] values)

　　當(dāng)然，為了支持存儲(chǔ)過程的執(zhí)行，以及數(shù)據(jù)庫事務(wù)，還需要提供相關(guān)的重載的API。大概的使用示例（面向SQLSERVER）如下：

DbHelper dbhelper = new DbHelper();
string sql = "delete from Citys where CityId = @id";
using (DatabaseTrans trans = new DatabaseTrans(dbhelper))
{
    try
    {
        dbhelper.SqlExecuteNonQuery(trans, sql, new string[] { "@id" }, 1);
        dbhelper.SqlExecuteNonQuery(trans, sql, new string[] { "@id" }, 2);
        trans.Commit();
        OutPut("ok");
    }
    catch (Exception)
    {
        trans.RollBack();
        OutPut("no ok");
    }
}

二、通用的ORM框架

先看如下的代碼

//1、添加
xxxCase xxxCase = new xxxCase();
xxxCase.Title = "abc";
xxxCase.Content = "呵呵";
xxxCase.CaseFrom = CaseFrom.客服投訴;
xxxCase.PostUser = "huhao";
xxxCase.CreateTime = DateTime.Now;
xxxCase.CaseType = CaseType.生產(chǎn)環(huán)境查詢;
xxxCase.Priority = CasePriority.中;
xxxCase.ReleationServices = "aaa,bbb";
xxxCase.ReleationClient = "ccc,ddd";
EntityBase.Insert(xxxCase);

//2、修改
xxxCase.ClearInnerData();
xxxCase.CaseId = 1;
xxxCase.Title = "嘿嘿";
EntityBase.Update(xxxCase);

//3、刪除
xxxCase.ClearInnerData();
xxxCase.CaseId = 1;
EntityBase.Delete(xxxCase);

//4、復(fù)雜條件查詢，查詢大于昨天的客服投訴或者wawa關(guān)閉的問題
WhereCondition condition = new WhereCondition(
    xxxCase.CaseFromColName,SqlOperator.Equal, (short)CaseFrom.客服投訴)
    .And(
    new WhereCondition(xxxCase.CreateTimeColName, SqlOperator.GreaterThan ,
        DateTime.Now.AddDays(-1)))
    .Group()
    .Or(
    new WhereCondition(xxxCase.CloseUserColName, SqlOperator.Equal, "wawa"));

IList<xxxCase> list = EntityBase.Select<xxxCase>(
new string[] {"Title", "PostUser"}, condition);

foreach (xxxCase item in list)
{
Console.WriteLine("{0}-{1}",item.Title,item.PostUser);
}
Console.ReadKey();

　　上面的代碼是以面向?qū)ο螅ㄕ埡雎阅切╆P(guān)于貧血模型的討論，說上面的代碼不夠OO，上面的代碼至少相對的面向?qū)ο螅铱雌饋砗苤庇^）的方式去執(zhí)行一些業(yè)務(wù)，這應(yīng)該比到處寫SQL語句要強(qiáng)很多吧，而且如果這些操作內(nèi)部使用的仍然是參數(shù)化查詢而不是拼sql字符串的話，性能也不會(huì)很差（請忽略具體語句是否能使用索引的討論，那得具體分析）。

　　我們看一下EntityBase.Insert方法的實(shí)現(xiàn)，邏輯很簡單明了，其他的Update,Delete,Select也是類似的思路。

private static DbHelper _db = new DbHelper();
public static void Insert(EntityBase entity) {
    string sql = GetInsertSql(entity);
    string[] parameters = GetParameters(entity.InnerData);
    object[] parameterValues = GetParameterValuess(entity.InnerData);
    _db.SqlExecuteNonQuery(sql, parameters, parameterValues);
}
private static string GetInsertSql(EntityBase entity) {
    int len = entity.InnerData.Count;
    StringBuilder sql = new StringBuilder();
    sql.AppendFormat("INSERT INTO [{0}]/r/n", entity.TableName);
    sql.Append("(/r/n");
    for (int i = 0; i < len; i++) {
        if (i != len - 1)
            sql.AppendFormat("[{0}],", entity.InnerData[i].Key);
        else
            sql.AppendFormat("[{0}]", entity.InnerData[i].Key);
    }
    sql.Append(")/r/n");
    sql.Append("VALUES(/r/n");
    for (int i = 0; i < len; i++) {
        if (i != len - 1)
            sql.AppendFormat("@{0},", entity.InnerData[i].Key);
        else
            sql.AppendFormat("@{0}", entity.InnerData[i].Key);
    }
    sql.Append(")/r/n");
    return sql.ToString();
}
private static string[] GetParameters(IList<DbCommonClass<string, object>> items) {
    int len = items.Count;
    List<string> parameters = new List<string>();
    for (int i = 0; i < len; i++) {
        parameters.Add(string.Format("@{0}", items[i].Key));
    }
    return parameters.ToArray();
}
private static object[] GetParameterValuess(List<DbCommonClass<string, object>> items) {
    int len = items.Count;
    List<object> parameters = new List<object>();
    for (int i = 0; i < len; i++) {
        parameters.Add(items[i].Value);
    }
    return parameters.ToArray();
}

當(dāng)然Select方法稍微復(fù)雜一些，因?yàn)槲覀円紤]復(fù)雜的Where字句，Top字句，OrderBy字句等，我們?yōu)閃here字句建立了一個(gè)WhereCondition對象，來方便的用c#代碼來描述SQL的where語句，但是為了實(shí)現(xiàn)簡單，我們不去實(shí)現(xiàn)表連接，復(fù)雜的子語句等支持（我個(gè)人認(rèn)為向NBear等框架做的過于強(qiáng)大了）。

三、代碼生成器

　　ADO.NET的各種數(shù)據(jù)庫實(shí)現(xiàn)都有獲取某個(gè)數(shù)據(jù)庫Schema的API，其中最重要的是SqlConnection.GetSchema(SqlClientMetaDataCollectionNames.Tables)和SqlCommand.ExecuteReader( CommandBehavior.KeyInfo | CommandBehavior.CloseConnection)方法，有了這兩個(gè)方法，我們可以枚舉一個(gè)數(shù)據(jù)庫的所有表，及某個(gè)表的所有字段，及每個(gè)字段的類型，長度、可否為空，是否為主鍵，是否為標(biāo)識(shí)列等信息，有了這些元數(shù)據(jù)，我們再根據(jù)一個(gè)模板就可以生成特定格式的代碼了。而且我們需要新增加一種代碼生成的格式的話，

只需添加一個(gè)模板就可以了，這樣的代碼生成器還有擴(kuò)展性，而不是一個(gè)寫死的針對特定框架的代碼生成器。
　　為了脫離對特定數(shù)據(jù)庫的依賴，我們建立一個(gè)代碼生成器的元數(shù)據(jù)模型，如下

public class CodeModel
{
public string ClassName;
public string TableName;
public string Descript;
public string Namespace;
public string PkColName;
public List<CodeProperty> Properties;
}
public class CodeProperty
{
public string DbColName;
public int? DbLength;
public bool DbAllowNull
public SqlDbType DbType;
public string DbTypeStr;
public bool DbIsIdentity;
public bool DbIsPk;

public string Descript;
public string PropertyName;
public system.Type CSharpType;
public string CSharpTypeStr;

public bool UiAllowEmpty;
public bool UiIsShowOn;
public long? UiMaxCheck;
public long? UiMinCheck;
public string UiRegxCheck;
}

得到元數(shù)據(jù)后，剩下的就是讀取模板，然后替換字符串了，比如實(shí)體類的模板，如下

using system;
using system.Collections.Generic;
using WawaSoft.Common;

namespace $model.namespace$ {
    public class $model.classname$ : EntityBase {
$foreach.prop$
        public const string $prop.property$ColName = "$prop.dbcolname$";
$endforeach$
        private static readonly List<string> _Cols = new List<string>();

        static $model.classname$()
        {
$foreach.prop$
            _Cols.Add($prop.property$ColName);
$endforeach$

}

        public $model.classname$() {
            _tableName = "$model.tablename$";
            _PkName = "$model.pkcolname$";
        }

$foreach.prop$
        private $prop.csharptype$ $prop.property2$;
$endforeach$

$foreach.prop$
        public $prop.csharptype$ $prop.property$ {
            get { return $prop.property2$; }
            set {
                $prop.property2$ = value;
                AddInnerData("$prop.property2$", value);
            }
        }
$endforeach$
        protected override IList<string> Cols
        {
            get { return _Cols; }
        }

        public override void ConvertToEntity(IEnumerable<DbCommonClass<string, object>> items) {
            foreach (DbCommonClass<string, object> item in items) {
                switch (item.Key) {
$foreach.prop$
                    case $prop.property$ColName:
                        $prop.property2$ = ($prop.csharptype$)item.Value;
                        break;
$endforeach$
                }
            }
        }
    }
}

生成的實(shí)體類，如下

using system;
using system.Collections.Generic;
using WawaSoft.Common;

namespace Entities {
    public class User : EntityBase {
        public const string UserIdColName = "UserId";
        public const string UsernameColName = "Username";
        public const string NameColName = "Name";
        public const string PassWordColName = "Password";
        public const string CreateTimeColName = "CreateTime";
        public const string IsAdminColName = "IsAdmin";
        private static readonly List<string> _Cols = new List<string>();

        static User() {
            _Cols.Add(UserIdColName);
            _Cols.Add(UsernameColName);
            _Cols.Add(NameColName);
            _Cols.Add(PasswordColName);
            _Cols.Add(CreateTimeColName);
            _Cols.Add(IsAdminColName);

}

        public User() {
            _tableName = "User";
            _PkName = "UserId";
        }

        private Nullable<Int32> userid;
        private String username;
        private String name;
        private String password;
        private Nullable<DateTime> createtime;
        private Nullable<Boolean> isadmin;

        public Nullable<Int32> UserId {
            get { return userid; }
            set {
                userid = value;
                AddInnerData("userid", value);
            }
        }
        public String Username {
            get { return username; }
            set {
                username = value;
                AddInnerData("username", value);
            }
        }
        public String Name {
            get { return name; }
            set {
                name = value;
                AddInnerData("name", value);
            }
        }
        public String Password {
            get { return password; }
            set {
                password = value;
                AddInnerData("password", value);
            }
        }
        public Nullable<DateTime> CreateTime {
            get { return createtime; }
            set {
                createtime = value;
                AddInnerData("createtime", value);
            }
        }
        public Nullable<Boolean> IsAdmin {
            get { return isadmin; }
            set {
                isadmin = value;
                AddInnerData("isadmin", value);
            }
        }
        protected override IList<string> Cols {
            get { return _Cols; }
        }

        public override void ConvertToEntity(IEnumerable<DbCommonClass<string, object>> items) {
            foreach (DbCommonClass<string, object> item in items) {
                switch (item.Key) {
                    case UserIdColName:
                        userid = (Nullable<Int32>)item.Value;
                        break;
                    case UsernameColName:
                        username = (String)item.Value;

                        break;
                    case NameColName:
                        name = (String)item.Value;
                        break;
                    case PasswordColName:
                        password = (String)item.Value;
                        break;
                    case CreateTimeColName:
                        if (item.Value != DBNull.Value)
                            createtime = (Nullable<DateTime>)item.Value;
                        break;
                    case IsAdminColName:
                        if (item.Value != DBNull.Value)
                            isadmin = (Nullable<Boolean>)item.Value;
                        break;
                }
            }
        }
    }
}