也来写写基于单表的Orm（使用Dapper）
前言
这两天看园子里有个朋友写Dapper的拓展，想到本身以前也尝试用过，但不顺手，曾写过几个方法来完成自动的Insert操做。而对于Update、Delete、Select等，我一直对Dictionary<string,object>参数类型有很深的感情，旨在页面传递的条件基本上都是Json，很容易用字典类型存储，想过在遵循某种命名规则的前提下，自动完成查询，简单的业务，直接能获得相应条件的数据，为此研究过一段时间，若是须要详细的了解，请看这里：html
看了下文章的时间，吓我一条，竟然在2个月前，事实上，这个念头在内心也一直有很长时间了，却以为本身很难去处理好它，封装的没问题，但用起来特别不顺手。现在新年来临，再来挑战本身。缓存
以前遇到的最大的问题就是处理值与类型的映射。因为页面传递的是Json数据源，后来序列化成Dictionary<string,object>后，不少类型就丢失了。如直接引发程序错误的DateTime类型了。原来的处理方式是各类手动的映射，更改数据类型，再提交ado.net操做。app
现在查看Poto这个Orm的源代码，它在实体增删改的时候将类型缓存起来，并且还有该类型的属性，在使用的时候，作过几回转换，而我像发现新大陆似得，以为这彻底能够解决个人问题呀。因而照搬了它的缓存部分代码，并结合Dapper实现了实体的增删改查，固然查询是经过Dictionary的传参。ide
对Dapper和Poto的拓展与修改
1.在Dapper的1219行代码处有方法 GetCacheInfo，在其中增长IDictionary参数支持。修改后的方法为:测试
private static CacheInfo GetCacheInfo(Identity identity) { CacheInfo info; if (!TryGetQueryCache(identity, out info)) { info = new CacheInfo(); if (identity.parametersType != null) { if (typeof(IDynamicParameters).IsAssignableFrom(identity.parametersType)) { info.ParamReader = (cmd, obj) => { (obj as IDynamicParameters).AddParameters(cmd, identity); }; } #if !CSHARP30 else if ( //支持传递Dictionary<K,V>为参数 typeof(IDictionary).IsAssignableFrom(identity.parametersType) || typeof(IEnumerable<KeyValuePair<string, object>>).IsAssignableFrom(identity.parametersType) && typeof(System.Dynamic.IDynamicMetaObjectProvider).IsAssignableFrom(identity.parametersType) ) { info.ParamReader = (cmd, obj) => { IDynamicParameters mapped = new DynamicParameters(obj); mapped.AddParameters(cmd, identity); }; } #endif else { info.ParamReader = CreateParamInfoGenerator(identity, false); } } SetQueryCache(identity, info); } return info; }
2.在Poto中，增长了OrderAttribute，定义在实体上，指定自动生成的Select排序规则。ui
再谈Orm的具体实现
基于实体的增删改，参数是object，则能够根据对象获取到它的类型、属性，还有定义在类上的Attribute。很容易就能够构造出 insert、update、delete。另外因为Dapper支持一次SQL，在多个对象上执行，我对方法作了这样的改进，以充分利用Dapper。解释下，一次SQL，在多个对象上执行，如批量Insert，批量Update，批量Delete。SQL语句使用参数化，则是同一条，执行时参数来自于不一样的对象而已。因此增删改查，参数为object时，还能够传递List、数组等。spa
在Update和Delete方法中，我还但愿经过条件来操做，运用到上面说的基于命名规则拼接SQL的方式，固然Select操做也不例外。主要实现代码:.net
private readonly Regex reg = new Regex(@"^(?<tab>\w+\.)?(?<Pre>(PK|Begin|End|Like|UnLike|Null|In))?(?<Key>\w+)$"); private string CreateWhere(PocoData t, IDictionary<string, object> condition) { var sql = new StringBuilder(); //遍历条件 foreach (var key in condition.Keys.ToArray()) { var match = reg.Match(key); //正则获取到属性对应的字段名 var pre = match.Groups["Pre"].Value;//获取命名规则中的比较谓词 var colName = match.Groups["Key"].Value;//获取字段名称 //if (string.IsNullOrEmpty(tableName)) // tableName = match.Groups["tab"].Value;//获取字段表名限定 var paraName = string.Format("{0}{1}", pre, colName);//获取该条件被分配的过程参数名 var value = condition[key]; //拼接Sql语句 sql.AppendFormat(" {0} AND", Builder(pre, colName, paraName, t.TableInfo.TableName, value));//拼接SQL条件 if (pre == "In") //In拼接没有使用过程参数，直接拼接了，将参数从字典中移除 { condition.Remove(key); continue; } //若该字段值的类型为字符串，检测实体中的类型 if (value.GetType() == typeof(string)) { PocoColumn prop; if (!t.Columns.TryGetValue(colName, out prop)) throw new Exception(string.Format("can't find any property in object.propertyName:{0},object:{1}", key, t.TableInfo.TableName)); if (prop.PropertyInfo.PropertyType != typeof(string)) condition[key] = prop.ChangeType(value); } } if (sql.Length > 3) sql.Length -= 3; return sql.ToString(); }
说到这里，有个小插曲，我发现当我在SQL和Oracle下测试成功后，我传递的Dictionary，并无指定参数符号，如@或者: 。最后执行的DbCommand对象使用的参数名固然也没有，可竟然没有出现任何问题。不知道该怎么解释。这里Sql的库使用的System.Data.SqlClient, net4.0 。而Oracle是使用的官方的，Oracle.ManagedDataAccess.dll ,net4.0。若是有朋友知道，还请告知一二。虽然我想偷懒，但这种突如其来的幸福，仍是警戒下。
最后在Update方法上增长参数，指定更新的列。
其余
解释下什么是基于单表的Orm。单表操做，增删改查，全部的方法都是在同一个表或者实体上。因为目前我尚未看Dapper或者Poco在多表下是怎么操做的，而暂时我又须要紧急的使用在项目中，由于我不想在写增删改查，简单业务下linq式的查询我也不想写。好吧，我认可我有点鲁莽，不稳定的东西就投入使用，可实践就是检验真理的惟一标准啊。说到实践，关于Poto这个Orm，我看其余人的介绍，通过各类测试，当我用了，我只想说，这测试不仔细，Oracle下各类错误，连自动分页都是错的。
写到这里，发现具体的实现方式，已然不值一提。在写以前，各类困难，写以后，想要介绍它的时候，发现太简单，没什么可说的。代码中有一点注释，想看的朋友若是看不明白能够咨询。
先贴下封装后的调用方式。
var db = new DbHelp(Program.facotry, Program.connStr); //增///////////////////////////////////////////////////////////////////// var tabAdd = new tab1() { Name = "ggggg", Home = "jjjjjj" }; var row = db.Add(tabAdd); //批量增 var tabAddArrary = new tab1[] { new tab1() { Name = "批量增1", Home = "批量增1" }, new tab1() { Name = "批量增2", Home = "批量增2" }}; row = db.Add(tabAddArrary); //改////////////////////////////////////////////////////////////////////////// var tabUpdate = new tab1() { Name = "fffffff", Home = "fffffff", ID = 5 }; row = db.Update(tabUpdate); //批量改 var tabUpdateArrary = new tab1[] { new tab1() { Name = "批量改1", Home = "批量改1", ID=10 }, new tab1() { Name = "批量改2", Home = "批量改2", ID=11 }}; row = db.Update(tabUpdateArrary); //条件修改 //1 定义要修改的内容 var dic = new Dictionary<string, object>(); dic["Home"] = DateTime.Now.ToString() + ":修改了"; //定义条件 这里使用了命名规则 var condtion = new Dictionary<string, object>(); condtion["InID"] = "1,3,5"; row = db.Update<tab1>(dic, condtion); //删除/////////////////////////////////////////////////// var tabDelete = new tab1() { ID = 10 }; db.Remove(tabDelete); //条件删除 var dicDelete = new Dictionary<string, object>(); dicDelete["BeginID"] = 50; row = db.Remove<tab1>(dicDelete); //查询///////////////////////////////////////////////////// var dicQuery = new Dictionary<string, object>(); dicQuery["EndID"] = 50; var qtab1 = db.Query<tab1>(dicQuery); //分页/////////////////////////////////////////////////////////// int count; var dicPage = new Dictionary<string, object>(); dicPage["BeginID"] = 50; dicPage["EndID"] = 10; var qtabPage = db.Query<tab1>(dicQuery, 3, 5, out count);
最后祝你们立刻有钱。