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

以下是相关的代码示例：

public bool SaveSMSMessage(SMSBatch smsBatch, DataSet smsMessages)

{

SqlDatabase db = new SqlDatabase(this.ConsultantsConnString);

string sqlCmd = "EXEC .SMSSaveSMSMessage @SMSBatchID, @SMSTypeID, @SubsidiaryID, @ContactID, @Message, @PhoneNumber";

using (SqlCommand cmd = db.GetSqlStringCommand(sqlCmd) as SqlCommand)

{

cmdmandTimeout = 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);

}

// 使用UpdateDataSet方法更新数据集并执行存储过程，获取影响的行数并返回结果

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

sqlCmd = rowsEffected.ToString(); // 此行代码在实际应用中可能并无实际用途，可根据实际需求进行修改或删除。

}

}