//此处拼接要更新的列名及其参数值
columnsUpdateSql += ("[" + columnsName[i] + "]" + "=@" + columnsName[i] + ",");
paras[i] = new SqlParameter("@" + columnsName[i], columnsName[i]);
}
if (!string.IsNullOrEmpty(columnsUpdateSql))
{
//此处去掉拼接处最后一个","
columnsUpdateSql = columnsUpdateSql.Remove(columnsUpdateSql.Length - 1);
}
//此处生成where条件语句
string limitSql = ("[" + primaryKeyName + "]" + "=@" + primaryKeyName);
SqlCommand updateCmd = new SqlCommand(string.Format(" UPDATE [{0}] SET {1} WHERE {2} ", TableName, columnsUpdateSql, limitSql));
//不修改源DataTable
updateCmd.UpdatedRowSource = UpdateRowSource.None;
da.UpdateCommand = updateCmd;
da.UpdateCommand.Parameters.AddRange(paras);
da.UpdateCommand.Parameters.Add("@" + primaryKeyName, primaryKeyName);
//每次往返处理的行数
da.UpdateBatchSize = onceUpdateNumber;
result = da.Update(ds,TableName);
ds.AcceptChanges();
tran.Commit();
}
catch
{
tran.Rollback();
}
finally
{
sqlconn.Dispose();
sqlconn.Close();
}
}
return result;
}
注:此方法调用时要传入的参数,包括主键名和列名都应与数据库实际的名称相对应。你可以不传入限定的where条件,如果传入,只需传入:Name="chamy" or Name="jundy",不需加入"where"等字符,不可以在此处传入主键的限定。你只需要在主键名这个参数上传入名称即可。