1、引入using System.Reflection;
/// <summary>
/// 用提供的函數，執行SQL命令，返回一個從指定連接的數據庫記錄集
/// </summary>
/// <param name="connecttionString">一個現有的數據庫連接</param>
/// <param name="cmdText">SqlCommand命令類型</param>
/// <param name="cmdText">存儲過程的名字或者 T-SQL 語句</param>
/// <returns>返回一個表(List<T>)表示查詢得到的數據集</returns>
public static List<T> GetList<T>(string connectionString, CommandType cmdType, string cmdText, params SqlParameter[] cmdParms) where T : new()
{
DataTable table = GetDataTable(connectionString, cmdType, cmdText, null);
List<T> list = new List<T>();
T t = default(T);
PropertyInfo[] propertypes = null;
string tempName = string.Empty;
foreach (DataRow row in table.Rows)
{
t = Activator.CreateInstance<T>();
propertypes = t.GetType().GetProperties();
foreach (PropertyInfo pro in propertypes)
{
tempName = pro.Name;
if (table.Columns.Contains(tempName))
{
var value = row[tempName];
if (!value.ToString().Equals(""))
{
pro.SetValue(t, value);
}
}
}
list.Add(t);
}
return list.Count == 0 ? null : list;
}
/// <summary>
/// 用提供的函數，執行SQL命令，返回一個從指定連接的數據庫記錄集
/// </summary>
/// <param name="cmdType">cmdType CommandType</param>
/// <param name="cmdText">cmdText Sql語句</param>
/// <param name="cmdParms">cmdParms Sql參數數組</param>
/// <returns>Datatable 數據集</returns>
public static DataTable GetDataTable(string connectionString, CommandType cmdType, string cmdText, params SqlParameter[] cmdParms)
{
SqlCommand cmd = new SqlCommand();
DataSet ds = new DataSet();
using (SqlConnection conn = new SqlConnection(connectionString))
{
PrepareCommand(null, cmd, conn, cmdType, cmdText, cmdParms);
SqlDataAdapter adapter = new SqlDataAdapter();
adapter.SelectCommand = cmd;
adapter.Fill(ds, "table");
}
return ds.Tables["table"];
}