C# 执行多条SQL语句,实现数据库事务(通过Hashtable存储数据) .
2011-12-19 22:27
941 查看
1)Web.config中添加连接数据库的语句
<add key="ConnectionString" value="server=./sqlexpress;database=transactionDemo;uid=sa;pwd=123456"/>
2)在表现层Default.aspx.cs中添加多条需要插入数据库的数据。
public void Add()
{
List<Maticsoft.Model.ClassDemo> modellist = new List<Maticsoft.Model.ClassDemo>();
modellist.Add(new Maticsoft.Model.ClassDemo("张三1", "浙江1"));
modellist.Add(new Maticsoft.Model.ClassDemo("张三2", "浙江2"));
modellist.Add(new Maticsoft.Model.ClassDemo("张三3张三3张三3张三3", "浙江3"));
bll.Add(modellist);
}
3)在业务逻辑层ClassDemo.cs中添加业务逻辑
public void Add(List<Maticsoft.Model.ClassDemo> modellist)
{
dal.Add(modellist);
}
4)在数据访问层ClassDemo.cs、DbHelperSQL.cs中添加将数据插入数据库
/// <summary>
/// 通过事务添加多条数据
/// </summary>
/// <param name="modellist"></param>
public void Add(List<Maticsoft.Model.ClassDemo> modellist)
{
Hashtable SQLStringList = new Hashtable();
for (int i = 0; i < modellist.Count;i++ )
{
SqlParameter[] parameters = {
new SqlParameter(string.Format("@name{0}",i), SqlDbType.NVarChar,50),
new SqlParameter(string.Format("@address{0}",i), SqlDbType.NVarChar,50)};
parameters[0].Value = modellist[i].name;
parameters[1].Value = modellist[i].address;
SQLStringList.Add(string.Format("insert into ClassDemo (name,address) values (@name{0},@address{0})", i), parameters);
}
DbHelperSQL.ExecuteSqlTran(SQLStringList);
}
public static string connectionString = ConfigurationManager.AppSettings["ConnectionString"].ToString();
/// <summary>
/// 执行多条SQL语句,实现数据库事务。
/// </summary>
/// <param name="SQLStringList">SQL语句的哈希表(key为sql语句,value是该语句的SqlParameter[])</param>
public static void ExecuteSqlTran(Hashtable SQLStringList)
{
using (SqlConnection conn = new SqlConnection(connectionString))
{
conn.Open();
using (SqlTransaction trans = conn.BeginTransaction())
{
SqlCommand cmd = new SqlCommand();
try
{
//循环
foreach (DictionaryEntry myDE in SQLStringList)
{
string cmdText = myDE.Key.ToString();
SqlParameter[] cmdParms = (SqlParameter[])myDE.Value;
PrepareCommand(cmd, conn, trans, cmdText, cmdParms);
int val = cmd.ExecuteNonQuery();
cmd.Parameters.Clear();
}
trans.Commit();
}
catch(Exception ex)
{
trans.Rollback();
}
}
}
}
<add key="ConnectionString" value="server=./sqlexpress;database=transactionDemo;uid=sa;pwd=123456"/>
2)在表现层Default.aspx.cs中添加多条需要插入数据库的数据。
public void Add()
{
List<Maticsoft.Model.ClassDemo> modellist = new List<Maticsoft.Model.ClassDemo>();
modellist.Add(new Maticsoft.Model.ClassDemo("张三1", "浙江1"));
modellist.Add(new Maticsoft.Model.ClassDemo("张三2", "浙江2"));
modellist.Add(new Maticsoft.Model.ClassDemo("张三3张三3张三3张三3", "浙江3"));
bll.Add(modellist);
}
3)在业务逻辑层ClassDemo.cs中添加业务逻辑
public void Add(List<Maticsoft.Model.ClassDemo> modellist)
{
dal.Add(modellist);
}
4)在数据访问层ClassDemo.cs、DbHelperSQL.cs中添加将数据插入数据库
/// <summary>
/// 通过事务添加多条数据
/// </summary>
/// <param name="modellist"></param>
public void Add(List<Maticsoft.Model.ClassDemo> modellist)
{
Hashtable SQLStringList = new Hashtable();
for (int i = 0; i < modellist.Count;i++ )
{
SqlParameter[] parameters = {
new SqlParameter(string.Format("@name{0}",i), SqlDbType.NVarChar,50),
new SqlParameter(string.Format("@address{0}",i), SqlDbType.NVarChar,50)};
parameters[0].Value = modellist[i].name;
parameters[1].Value = modellist[i].address;
SQLStringList.Add(string.Format("insert into ClassDemo (name,address) values (@name{0},@address{0})", i), parameters);
}
DbHelperSQL.ExecuteSqlTran(SQLStringList);
}
public static string connectionString = ConfigurationManager.AppSettings["ConnectionString"].ToString();
/// <summary>
/// 执行多条SQL语句,实现数据库事务。
/// </summary>
/// <param name="SQLStringList">SQL语句的哈希表(key为sql语句,value是该语句的SqlParameter[])</param>
public static void ExecuteSqlTran(Hashtable SQLStringList)
{
using (SqlConnection conn = new SqlConnection(connectionString))
{
conn.Open();
using (SqlTransaction trans = conn.BeginTransaction())
{
SqlCommand cmd = new SqlCommand();
try
{
//循环
foreach (DictionaryEntry myDE in SQLStringList)
{
string cmdText = myDE.Key.ToString();
SqlParameter[] cmdParms = (SqlParameter[])myDE.Value;
PrepareCommand(cmd, conn, trans, cmdText, cmdParms);
int val = cmd.ExecuteNonQuery();
cmd.Parameters.Clear();
}
trans.Commit();
}
catch(Exception ex)
{
trans.Rollback();
}
}
}
}
相关文章推荐
- C# 执行多条SQL语句,实现数据库事务(通过Hashtable存储数据) .
- [置顶] c# 执行多条SQL语句,实现数据库事务 线性表 Hashtable
- c# 执行多条SQL语句,实现数据库事务 线性表 Hashtable
- C# 执行多条SQL更新语句,实现数据库事务
- C# 通过事务向数据库插入多条数据(通过Hashtable存储数据)
- C#实现执行多条SQl语句,实现数据库事务
- 数据库存储过程中定义一个变量,通过sql语句在数据表中获取这个变量值的方法。
- 执行多条SQL语句,实现数据库事务(不可传入Sql参数)
- lotusscript通过ODBC实现与关系型数据库SQL的数据存储
- C#实现连接SQL Server2012数据库并执行SQL语句的方法
- 执行多条SQL语句,实现数据库事务。
- 执行多条SQL语句,实现数据库事务
- PageOffice+C#+SqlServer+Aspose.Word+Aspose.Cells实现上传word模板,通过标签保存填写的数据到数据库中
- 执行多条SQL语句,实现数据库事务。
- 执行多条SQL语句,实现数据库事务(不可传入Sql参数)
- 通过MyEclipse操作数据库,执行sql语句使我们不用切换多个工具,直接工作,方便快捷
- c#学习之-c#通过sql存储过程实现分页
- C#拼接SQL语句,SQL Server 2005+,多行多列大数据量情况下,使用ROW_NUMBER实现的高效分页排序
- 通过MyEclipse工具直接操作数据库,执行sql语句,方便快捷
- 执行多条SQL语句,执行数据库事务(可传入Sql参数)