服务器之家:专注于服务器技术及软件下载分享
分类导航

Mysql|Sql Server|Oracle|Redis|MongoDB|PostgreSQL|Sqlite|DB2|mariadb|Access|数据库技术|

服务器之家 - 数据库 - Sql Server - 存储过程配合UpdateDaset方法批量插入Dataset数据实现代码

存储过程配合UpdateDaset方法批量插入Dataset数据实现代码

2019-12-31 15:53MSSQL教程网 Sql Server

用存储过程配合UpdateDaset方法批量插入Dataset数据,感兴趣的你可不要错过了哈,希望本文提供知识点可以帮助到你

代码如下:


public bool SaveSMSMessage(SMSBatch smsBatch, DataSet smsMessages) 

//using (TransactionScope ts = new TransactionScope(TransactionScopeOption.Suppress)) 
//{ 
foreach (DataRow row in smsMessages.Tables[0].Rows) 
row.SetModified(); 
SqlDatabase db = new SqlDatabase(this.ConsultantsConnString); 
string sqlCmd = "EXEC cn.SMSSaveSMSMessage @SMSBatchID, @SMSTypeID, @SubsidiaryID, @ContactID, @Message, @PhoneNumber"; 
using (SqlCommand cmd = db.GetSqlStringCommand(sqlCmd) as SqlCommand) 

cmd.CommandTimeout = 600; 
cmd.Parameters.AddWithValue("@SMSBatchID", smsBatch.SMSBatchID); 
cmd.Parameters.AddWithValue("@SMSTypeID", smsBatch.SMSType.SMSTypeID); 
cmd.Parameters.AddWithValue("@SubsidiaryID", smsBatch.SMSType.SubsidiaryID); 
db.AddInParameter(cmd, "@ContactID", DbType.Int64, "ContactID", DataRowVersion.Current); 
db.AddInParameter(cmd, "@Message", DbType.String, "Message", DataRowVersion.Current); 
if (smsMessages.Tables[0].Columns.Contains("PhoneNumber")) 

db.AddInParameter(cmd, "@PhoneNumber", DbType.String, "PhoneNumber", DataRowVersion.Current); 

else 

db.AddInParameter(cmd, "@PhoneNumber", DbType.String, DBNull.Value); 

int rowsEffected = db.UpdateDataSet(smsMessages, "SMSMessage", null, cmd, null, UpdateBehavior.Transactional); 
sqlCmd = rowsEffected.ToString(); 

// ts.Complete(); 
//} 
return true; 

延伸 · 阅读

精彩推荐