从客户端传一个字符串,在服务器端根据这个字符对三个表进行insert操作.如果不加事务处理,示意代码如下:
public static int insertinto(string str)
{
string sql_table1="insert into table1 ()";
string sql_table2="insert into table2()";
string sql_table3="insert into table3()";
if (DataAccess.inserttable(sql_table1)!=-1)
{
if (DataAccess.inserttable(sql_table2)!=-1)
{
if(DataAccess.inserttable(sql_table3)!=-1)
return 1;
else return -1;
}
else return -1;
}
else return -1
}
DataAccess是一个类里面有方法inserttable用来对数据库的插入操作!
inserttable()方法如下:
try
{
SqlConnection sqlconn = new SqlConnection(connstr);
sqlconn.Open();
SqlCommand sqlcomm = new SqlCommand(sql, sqlconn);
int resultnum = sqlcomm.ExecuteNonQuery();
sqlconn.Close();
return resultnum;
}
catch (Exception e)
{
return -1;
}
public static int insertinto(string str)
{
string sql_table1="insert into table1 ()";
string sql_table2="insert into table2()";
string sql_table3="insert into table3()";
if (DataAccess.inserttable(sql_table1)!=-1)
{
if (DataAccess.inserttable(sql_table2)!=-1)
{
if(DataAccess.inserttable(sql_table3)!=-1)
return 1;
else return -1;
}
else return -1;
}
else return -1
}
DataAccess是一个类里面有方法inserttable用来对数据库的插入操作!
inserttable()方法如下:
try
{
SqlConnection sqlconn = new SqlConnection(connstr);
sqlconn.Open();
SqlCommand sqlcomm = new SqlCommand(sql, sqlconn);
int resultnum = sqlcomm.ExecuteNonQuery();
sqlconn.Close();
return resultnum;
}
catch (Exception e)
{
return -1;
}
begin trancommit tran