泛型+反射 實現泛型向資料庫插入資訊類 並返回插入資料的Id值
阿新 • • 發佈:2019-01-23
static string conStr = @"server=.;database=a;uid=sa;pwd=a;";
/// <summary> /// ExecuteScalar /// </summary> /// <param name="sql">sql語句</param> /// <param name="ps">SqlParameter</param> /// <returns>查詢結果表中最左上角單元格的資料</returns> private static object ExecuteScalar(string sql, params SqlParameter[] ps) { using (SqlConnection con = new SqlConnection(conStr)) { using (SqlCommand cmd = new SqlCommand(sql, con)) { cmd.Parameters.AddRange(ps); con.Open(); return cmd.ExecuteScalar(); } } }
//新增一條資訊 並返回插入後該資料的Id public static int InsertModel<T>(T t) where T : BaseModel, new() { //獲取型別 Type type=typeof(T); //獲得欄位列表 PropertyInfo[] Prop= type.GetProperties(); //拼接字串 string sql = string.Format("insert into [{0}]({1}) values({2});select @@identity", type.Name, string.Join(",",Prop.Where(s=>s.Name!="Id").Select(s=>string.Format("[{0}]",s.Name))), string.Join(",", Prop.Where(s => s.Name != "Id").Select(s => string.Format("@{0}", s.Name))) ); SqlParameter[] ps = Prop.Where(s => s.Name != "Id").Select(s => new SqlParameter(string.Format("@{0}",s.Name),s.GetValue(t,null)??DBNull.Value)).ToArray(); return int.Parse(ExecuteScalar(sql,ps).ToString()); }