根据对象生存新增和更新SQL代码,CSharp代码库,德仔网

代码语言

代码分类

【CSharp】根据对象生存新增和更新SQL

作者:静 / 发布于2015/4/14/ 799


	public static int getInsert(SqlConnection conn, SqlTransaction trans, object obj, string tablename) {
	 if (obj == null) throw new Exception("数据不能为空！");
	 Type type = obj.GetType();
	 PropertyInfo[] pinfo = type.GetProperties();
	 List<SqlParameter> parames = new List<SqlParameter>();
	 StringBuilder keys = new StringBuilder();
	 StringBuilder values = new StringBuilder();
	 foreach (PropertyInfo item in pinfo) {
	 if (item.GetValue(obj, null)!=null) {
	 if (keys.Length > 0) {
	 keys.Append(",");
	 values.Append(",");
	 }
	 keys.Append(" " + item.Name.ToUpper());
	 values.Append(" @" + item.Name.ToUpper());
	// if (item.PropertyType == typeof(System.Nullable<System.DateTime>)) {
	 parames.Add(new SqlParameter("@" + item.Name.ToUpper(), item.GetValue(obj, null)));
	// } else {
	// parames.Add(new SqlParameter("@" + item.Name.ToUpper(), item.GetValue(obj, null)));
	// }
	 }
	 }
	 string sql = "INSERT INTO " + tablename + "(" + keys.ToString() + " ) VALUES ( "+values.ToString()+")";
	 return SqlHelper.ExecuteNonQuery(conn, trans, CommandType.Text, sql, parames.ToArray());
	 }
	
	
	 public static int getUpdate(SqlConnection conn,SqlTransaction trans,object obj, string tablename, string pkey) {
	 if (obj == null) throw new Exception("数据不能为空！");
	 Type type = obj.GetType();
	 PropertyInfo[] pinfo = type.GetProperties();
	 List<SqlParameter> parames = new List<SqlParameter>();
	 StringBuilder keys = new StringBuilder();
	 object pkeyvalue = null;
	 pkey = pkey.ToUpper();
	 foreach (PropertyInfo item in pinfo) {
	 if (item.Name.ToUpper() == pkey) {
	 pkeyvalue = item.GetValue(obj, null);
	 } else {
	 if (keys.Length > 0) {
	 keys.Append(",");
	 }
	 keys.Append(" " + item.Name.ToUpper() + "=@" + item.Name.ToUpper());
	 if (item.GetValue(obj, null) == null) {
	 parames.Add(new SqlParameter("@" + item.Name.ToUpper(), DBNull.Value));
	 } else {
	 parames.Add(new SqlParameter("@" + item.Name.ToUpper(), item.GetValue(obj, null)));
	 }
	 }
	 }
	 parames.Add(new SqlParameter("@" + pkey, pkeyvalue));
	 string sql = "UPDATE " + tablename + " SET " + keys.ToString() + " WHERE " + pkey + "=@" + pkey + "";
	 return SqlHelper.ExecuteNonQuery(conn, trans, CommandType.Text, sql, parames.ToArray());
	 }

试试其它关键字

同语言下

可能有用的

静贡献的其它代码(1)

.根据对象生存新增和更新SQL