SqlDatabase db
=
new
SqlDatabase(
@"
server=.\sql2008;uid=sa;pwd=123456;database=DBTEST
"
);
using (DbConnection connection = db.CreateConnection())
{
// 打开链接
connection.Open();
// 创建事务
DbTransaction Tran = connection.BeginTransaction();
try
{
db.ExecuteNonQuery(Tran, CommandType.Text, " Insert Into TLog (DEC) Values('123') " );
db.ExecuteNonQuery(Tran, CommandType.Text, " Insert Into TLog (DEC) Values('124') " );
db.ExecuteNonQuery(Tran, CommandType.Text, " Insert Into TLog (DEC) Values(125) " );
// 提交事务
Tran.Commit();
}
catch (Exception Ex)
{
// 出错回滚
Tran.Rollback();
Console.WriteLine(Ex.ToString());
}
finally
{
// 关闭连接
connection.Close();
}
Console.WriteLine( " OK " );
Console.ReadKey();
}
using (DbConnection connection = db.CreateConnection())
{
// 打开链接
connection.Open();
// 创建事务
DbTransaction Tran = connection.BeginTransaction();
try
{
db.ExecuteNonQuery(Tran, CommandType.Text, " Insert Into TLog (DEC) Values('123') " );
db.ExecuteNonQuery(Tran, CommandType.Text, " Insert Into TLog (DEC) Values('124') " );
db.ExecuteNonQuery(Tran, CommandType.Text, " Insert Into TLog (DEC) Values(125) " );
// 提交事务
Tran.Commit();
}
catch (Exception Ex)
{
// 出错回滚
Tran.Rollback();
Console.WriteLine(Ex.ToString());
}
finally
{
// 关闭连接
connection.Close();
}
Console.WriteLine( " OK " );
Console.ReadKey();
}
不要忘记在执行时加入“Tran”，否则不起做用的
