存储过程配合UpdateDaset方法批量插入Dataset数据实现代码
<div class="codetitle"><a style="CURSOR: pointer" data="85270" class="copybut" id="copybut85270" onclick="doCopy('code85270')"> 代码如下:
<div class="codebody" id="code85270">
public bool SaveSMSMessage(SMSBatch smsBatch,DataSet smsMessages)
{
//using (TransactionS
cope ts = new TransactionS
cope(TransactionS
copeOption.Suppress))
//{
foreach (Da
Tarow 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.Get
sqlStringCommand(
sqlCmd) as
sqlCommand)
{
cmd.CommandTimeout = 600;
cmd.P
arameters.AddWithValue("@SMSBatchID",smsBatch.SMSBatchID);
cmd.P
arameters.AddWithValue("@SMSTypeID",smsBatch.SMSType.SMSTypeID);
cmd.P
arameters.AddWithValue("@SubsidiaryID",smsBatch.SMSType.SubsidiaryID);
db.AddInP
arameter(cmd,"@ContactID",DbType.Int64,"ContactID",Da
TarowVersion.Current);
db.AddInP
arameter(cmd,"@Message",DbType.String,"Message",Da
TarowVersion.Current);
if (smsMessages.Tables[0].Columns.Contains("PhoneNumber"))
{
db.AddInP
arameter(cmd,"@PhoneNumber","PhoneNumber",Da
TarowVersion.Current);
}
else
{
db.AddInP
arameter(cmd,
dbnull.Value);
}
int rowsEffected = db.UpdateDataSet(smsMessages,"SMSMessage",null,cmd,UpdateBehavior.Transactional);
sqlCmd = rowsEffected.ToString();
}
// ts.Complete();
//}
return true;
}
