never下sqlcient

【一】参数的输入

如执行update，我们写的代码应该是

sqlclient.Update("update xx set a.Moblie = '13800138000' where Id in (@Id) and Name = @Name;",new { @Id = new [] { ,, },@Name = "eee" })；

表示更新Id =1，2，3这三行的信息。这里的参数是一个匿名类型：Id是数组类型，Name是string类型。@Id参数是如何变成(@Id1,@Id2,@Id3)的呢？我们跟踪一下

 /// <summary>

 /// sql语句拼接

 /// </summary>

 public class SqlParamerBuilder

 {

     /// <summary>

     /// 准备参数

     /// </summary>

     /// <param name="prefix"></param>

     /// <param name="parameter"></param>

     /// <returns></returns>

     public SqlParamerBuilder Build(string prefix, object @parameter)

     {

         if (string.IsNullOrEmpty(this.sql))

             return this;

         if (this.builded)

             return this;

         var table = PreParameters(@parameter);

         if (table == null || table.Count == )

         {

             this.parameters = new List<KeyValuePair<string, object>>();

             return this;

         }

         this.parameters = new List<KeyValuePair<string, object>>(table.Count);

         var keys = new List<string>(table.Count);

         sql = rxParamers.Replace(sql, m =>

         {

             var name = m.Groups["name"].Value;

             if (!table.ContainsKey(name))

             {

                 var i = m.Groups["name"].Index;

                 var count = ;

                 while (i >= )

                 {

                     if (this.sql[i] == '\'')

                     {

                         count = ;

                         break;

                     }

                     i--;

                 }

                 if (count > )

                 {

                     i = m.Groups["name"].Index;

                     while (i < this.sql.Length)

                     {

                         if (this.sql[i] == '\'')

                         {

                             count = ;

                             break;

                         }

                         i++;

                     }

                 }

                 if (count != )

                     throw new Exception(string.Format("当前在sql语句中参数为{0}的值在所提供的参数列表中找不到", name));

                 return string.Concat(this.sql[m.Groups["name"].Index - ], name);

             }

             var stValue = table[name] as string;

             if (stValue != null)

             {

                 if (!keys.Contains(name))

                 {

                     keys.Add(name);

                     parameters.Add(new KeyValuePair<string, object>(name, table[name]));

                 }

                 return string.Concat(prefix, name);

             }

             var value = table[name] as IEnumerable;

             if (value != null)

             {

                 int totalCount = ;

                 var ator = value.GetEnumerator();

                 var newNameList = new List<string>();

                 while (ator.MoveNext())

                 {

                     totalCount++;

                     var newkey = string.Format("{0}{1}x{2}z", prefix, name, totalCount);

                     newNameList.Add(newkey);

                     parameters.Add(new KeyValuePair<string, object>(newkey, ator.Current));

                 }

                 return string.Concat(string.Join(",", newNameList.ToArray()));

             }

             if (!keys.Contains(name))

             {

                 keys.Add(name);

                 parameters.Add(new KeyValuePair<string, object>(name, table[name]));

             }

             return string.Concat(prefix, name);

         });

         this.builded = true;

         keys.Clear();

         return this;

     }

 }

通过SqlParamerBuilder的Build方法可以知道：将匿名对象参数parameter转成Hashtable的同时将sql语句变成了"update xx where Id in (@Id1,@Id2,@Id3) and Name = @Name，并且只是遍历传入参数所有的Property属性（并不遍历Field字段）。

@Id根据数组变成(@Id1,@Id2,@Id3) 参数，而@Name会不会变成(@Name1,@Name2,@Name3)？我们的参数@Id传入的是数组，而@Name是字符串（可以认为是char的数组），如果没有对string特殊处理，@Name就是(@Name1,@Name2,@Name3)这三个参数。

 //注意是string，实现了IEnumerable接口

 var stValue = table[name] as string;

 if (stValue != null)

 {

     if (!keys.Contains(name))

     {

         keys.Add(name);

         parameters.Add(new KeyValuePair<string, object>(name, table[name]));

     }

     return string.Concat(prefix, name);

 }

 var value = table[name] as IEnumerable;

 if (value != null)

 {

     int totalCount = ;

     var ator = value.GetEnumerator();

     var newNameList = new List<string>();

     while (ator.MoveNext())

     {

         totalCount++;

         var newkey = string.Format("{0}{1}x{2}z", prefix, name, totalCount);

         newNameList.Add(newkey);

         parameters.Add(new KeyValuePair<string, object>(newkey, ator.Current));

     }

     return string.Concat(string.Join(",", newNameList.ToArray()));

 }

可以知道string是特殊处理，所以可以认为遇上了IEnumerable接口的就是数组参数。

定位到@Id这一位置是用了下面的正则

/// <summary>

/// 分析sql语句中的参数

/// </summary>

Regex rxParamers = new Regex(@"(?<prefix>(?<![?@:])[?@:](?![?@:]))(?<name>\w+)", RegexOptions.Compiled);

这个正则可以帮我们找到【@?:】这三种开头的前缀，譬如上面的 where Id = @Id and Name = ?Name and Mobile = :Mobile

参数可以是匿名类，也可以对象。

【二】结果的输出

对update,delete执行的方法是ExecuteNonQuery，得到是Int类型的结果。而insert是使用ExecuteScalar，所以这个结果是看sql的语句的，打个比方，我们拿自增Id，不同的sql是不同的写法

sqlserver  select @@identity;

mysql  select last_insert_id();

sqlite  select last_insert_rowid();

对于select的结果，我们对QueryForObject<T>方法进行分析

 /// <summary>

 /// 查询列表

 /// </summary>

 /// <typeparam name="T">返回对象类型</typeparam>

 /// <param name="command">查询命令</param>

 /// <param name="closeConnection">关闭数据库连接</param>

 /// <returns></returns>

 protected virtual T QueryForObject<T>(IDbCommand command, bool closeConnection)

 {

     var @delegate = DataRecordBuilder<T>.Func;

     IDataReader reader = null;

     try

     {

         using (reader = this.CreateReader(command))

         {

             var rd = new IDataRecordDecorator(reader);

             if (reader.Read())

             {

                 return @delegate(rd.Load(reader));

             }

         }

     }

     catch

     {

         throw;

     }

     finally

     {

         if (this.Transaction == null && closeConnection && reader != null && !reader.IsClosed)

             reader.Close();

     }

     return default(T);

 }

看到这一行代码，是一个Func的委托

 var @delegate = DataRecordBuilder<T>.Func;

我们定位到DataRecordBuilder<T>这一个类

 /// <summary>

 /// 对对象进行emit操作

 /// </summary>

 /// <param name="emit">The emit.</param>

 public static void BuildObject(EasyEmitBuilder<Func<IDataRecord, T>> emit)

 {

     var type = typeof(T);

     var targetMembers = GetMembers(type);

     /*实例*/

     var instanceLocal = emit.DeclareLocal(type);

     if (type.IsValueType)

     {

         if (targetMembers == null || targetMembers.Count == )

         {

             emit.LoadLocalAddress(instanceLocal);

             emit.InitializeObject(type);

             emit.LoadLocal(instanceLocal);

             emit.Return();

             return;

         }

         emit.LoadLocalAddress(instanceLocal);

         emit.InitializeObject(type);

         emit.LoadLocal(instanceLocal);

         emit.StoreLocal(instanceLocal);

         goto _Read;

     }

 }

可以看到，里面是使用emit技术实现对对象T的属性或字段进行读写与赋值的（emit是后面所有技术点的基础）。

TypeHandler，有时候阻抗失败使用的方式，还是在DataRecordBuilder<T>这一个类中，我们拿属性进行get或set的时候，会对该属性或字段进行查询TypeHandlerAttribute这个attribute，

 var attribute = member.GetCustomAttribute<TypeHandlerAttribute>();

那么是怎么用呢？拿demo一个Typehander例子来看其使用

 public class User

 {

     public int Id { get; set; }

     public long UserId { get; set; }

     [Never.SqlClient.TypeHandler(typeof(UserNameTypeHandler))]

     public char[] UserName { get; set; }

 }

 public class UserNameTypeHandler : IReadingFromDataRecordToValueTypeHandler<char[]>, ICastingValueToParameterTypeHandler<string>

 {

     /// <summary>

     ///

     /// </summary>

     /// <param name="value"></param>

     /// <returns></returns>

     public string ToParameter(object value)

     {

         if (value == null)

             return string.Empty;

         return new string((char[])value);

     }

     /// <summary>

     /// 获取结果

     /// </summary>

     /// <param name="dataRecord">读取器</param>

     /// <param name="ordinal">column的位置，如果未-1表示没有找到这个值</param>

     /// <param name="columnName">行名字</param>

     /// <returns></returns>

     public char[] ToValue(IDataRecord dataRecord, int ordinal, string columnName)

     {

         var value = dataRecord.GetString(ordinal);

         return value == null ? new char[] : value.ToCharArray();

     }

 }

这个UserNameTypeHandler对象实现了2个接口，一个是从数据库到程序的类型转换IReadingFromDataRecordToValueTypeHandler<char[]>，一个是将程序的char[]类型换成数据库的string类型ICastingValueToParameterTypeHandler<string>，而User对象的UserName属性恰好也是char[]类型。

总结：组件使用emit实现核心方法，性能不底；并且有TypeHandler的支持，应该来说大部分数据结构应该还是可以应付的。本人没有测试过图片字段的，所以在对binary等字段处理，我想可以通过TypeHandler来实现

文章导航：

巴特西

never下sqlcient

【一】参数的输入

【二】结果的输出

最新文章

热门文章