public class sqlservershiwu
{
public string sqlconString = "Data Source=.;Initial Catalog=TestDB;User ID=sa;Password=123456789";
public void findAll()
{
bool flag = false;
int result = 0;
using (SqlConnection con = new SqlConnection(sqlconString))
{
con.Open();
SqlCommand com = new SqlCommand();
com.CommandType = System.Data.CommandType.Text;
com.Connection = con;
//共享锁
SqlTransaction st = con.BeginTransaction(IsolationLevel.ReadCommitted);
//开始执行事务
com.Transaction = st;
try
{
string sql1 = "delete from testTable where id = 1";
com.CommandText = sql1;
result += com.ExecuteNonQuery();
string sql2 = "delete from testTable where id = 2";
com.CommandText = sql2;
result += com.ExecuteNonQuery();
string sql3 = "delete from testTable where id = q";
com.CommandText = sql3;
result += com.ExecuteNonQuery();
string sql4 = "insert into testTable(id,name)values('3','3')";
com.CommandText = sql4;
result += com.ExecuteNonQuery();
//提交事务
st.Commit();
flag = true;
}
catch (Exception ex)
{
flag = false;
//事务回滚
st.Rollback();
throw ex;
}
}
}
}