在上一篇的基础上增加了 SqlDataReader 的扩展方法
以下代码是调用
using System;
using System.Collections.Generic;
using System.Data;
using System.Data.Common;
using System.Data.SqlClient;
using System.Diagnostics;
using System.Linq;
using System.Reflection;
using System.Text;
using System.Threading.Tasks;
namespace Demo1
{
class Program
{
static void Main(string[] args)
{
String conString = "Data Source=.; Initial Catalog=master; Integrated Security=true;";
Func<SqlDataReader, Usr> func = null;
List<Usr> usrs = new List<Usr>();
using (SqlDataReader reader = GetReader(conString, "select object_id 'ID',name 'Name' from sys.objects", CommandType.Text, null))
{
while (reader.Read())
{
if (func == null)
{
func = reader.ToExpression<Usr>();
}
Usr usr = func(reader);
usrs.Add(usr);
}
}
usrs.Clear();
Console.ReadKey();
}
public static SqlDataReader GetReader(String conString, String sql, CommandType type, params SqlParameter[] pms)
{
SqlConnection conn = new SqlConnection(conString);
SqlCommand cmd = new SqlCommand(sql, conn);
cmd.CommandType = type;
if (pms != null && pms.Count() > 0)
{
cmd.Parameters.AddRange(pms);
}
conn.Open();
return cmd.ExecuteReader(CommandBehavior.CloseConnection);
}
}
class Usr
{
public Int32 ID { get; set; }
public String Name { get; set; }
}
}
目前只能处理sqlserver返回的对象,处理其它数据库本来是想增加 DbDataReader 的扩展方法,但发现动态生成lambda表达式的地方出错,所以先将现在的
方案记录下来。








