如题所述
第1个回答 2016-02-17
SqlTaskAssignInfo类:
using System.Collections.Generic; //添加的引用,使用了
List lstOne = new List(){ sql1, sql2 };
///
/// 组长分配任务(更新任务信息表T_TaskInfo和任务分配表T_TaskAssignInfo)
///
///
/// 任务分配信息实体类(任务ID、小组ID、成员ID、成员姓名、组长分配日期、组长分配时间)
///
/// bool(true:分配成功;false:分配失败)
public bool AssignTask2(Entity.TaskAssignInfoEntity enTaskAssignInfo)
{
//1,sql1语句:根据任务ID和分配等级,更新任务分配信息表T_TaskAssignInfo中任务分配状态字段taskDistributeState的值为‘已分配’
string sql1 = "update T_TaskAssignInfo set taskDistributeState='已分配' where taskID='" + enTaskAssignInfo.taskID + "' and distributeLevel='1'";
//2,sql2语句:向任务分配信息表中插入一条组长分配的任务信息,包括(任务ID,小组ID,成员ID,成员姓名、分配日期、分配时间、分配等级、提交状态)
string sql2 = "insert into T_TaskAssignInfo(taskID,groupID,memberID,memberName,distributeDate,distributeTime,distributeLevel,submitState) values(" + enTaskAssignInfo.taskID + ',' + enTaskAssignInfo.groupID + ',' + enTaskAssignInfo.memberID + ',' + "'" + enTaskAssignInfo.memberName
+ "'" + ',' + "'" + enTaskAssignInfo.distributeDate + "'" + ',' + "'" + enTaskAssignInfo.distributeTime
[csharp] view plain copy
+ "'" + ',' + "'" + '2' + "','未提交'" + ")";
List lstSql = new List() { sql1, sql2 };//泛型集合(此泛型集合只接受字符串类型):sql1、sql2
int rows = DbHelperSQL.ExecuteSqlTran(lstSql);//调用DbHelperSQL类的ExecuteSqlTran()函数(执行多条sql语句,完成数据库事务)
if (rows > 0)//如果几条sql语句均执行成功
{
return true;//返回值为true
}
else//如果执行失败
{
return false;//返回值为false
}
}
(注:DbHelperSQL类代码中的ConnectionString是写在配置文件里的数据库连接字符串)
DbHelperSQL类:
using System.Configuration '这里添加后,还必须在管理器中添加引用
public static string connectionString = ConfigurationManager.AppSettings["ConnectionString"];
///
/// 执行多条SQL语句,实现数据库事务。
///
/// 多条SQL语句
public static int ExecuteSqlTran(List SQLStringList)
{
using (SqlConnection conn = new SqlConnection(connectionString))
{
conn.Open(); //打开数据库连接
SqlCommand cmd = new SqlCommand(); //创建SqlCommand命令
cmd.Connection = conn; //设置命令连接
SqlTransaction tx = conn.BeginTransaction();//开始事务
cmd.Transaction = tx;//设置执行命令的事务
try
{
int count = 0;//定义int类型变量,存放该函数返回值
for (int n = 0; n < SQLStringList.Count; n++)//循环传入的sql语句
{
string strsql = SQLStringList[n]; //第n条sql语句
if (strsql.Trim().Length > 1) //如果第n条sql语句不为空
{
cmd.CommandText = strsql; //设置执行命令的sql语句
count += cmd.ExecuteNonQuery(); //调用执行增删改sql语句的函数ExecuteNonQuery(),执行sql语句
}
}
tx.Commit();//提交事务
return count;//返回受影响行数
}
catch
{
tx.Rollback();
return 0;
}
}
}
配置文件:
using System.Collections.Generic; //添加的引用,使用了
List lstOne = new List(){ sql1, sql2 };
///
/// 组长分配任务(更新任务信息表T_TaskInfo和任务分配表T_TaskAssignInfo)
///
///
/// 任务分配信息实体类(任务ID、小组ID、成员ID、成员姓名、组长分配日期、组长分配时间)
///
/// bool(true:分配成功;false:分配失败)
public bool AssignTask2(Entity.TaskAssignInfoEntity enTaskAssignInfo)
{
//1,sql1语句:根据任务ID和分配等级,更新任务分配信息表T_TaskAssignInfo中任务分配状态字段taskDistributeState的值为‘已分配’
string sql1 = "update T_TaskAssignInfo set taskDistributeState='已分配' where taskID='" + enTaskAssignInfo.taskID + "' and distributeLevel='1'";
//2,sql2语句:向任务分配信息表中插入一条组长分配的任务信息,包括(任务ID,小组ID,成员ID,成员姓名、分配日期、分配时间、分配等级、提交状态)
string sql2 = "insert into T_TaskAssignInfo(taskID,groupID,memberID,memberName,distributeDate,distributeTime,distributeLevel,submitState) values(" + enTaskAssignInfo.taskID + ',' + enTaskAssignInfo.groupID + ',' + enTaskAssignInfo.memberID + ',' + "'" + enTaskAssignInfo.memberName
+ "'" + ',' + "'" + enTaskAssignInfo.distributeDate + "'" + ',' + "'" + enTaskAssignInfo.distributeTime
[csharp] view plain copy
+ "'" + ',' + "'" + '2' + "','未提交'" + ")";
List lstSql = new List() { sql1, sql2 };//泛型集合(此泛型集合只接受字符串类型):sql1、sql2
int rows = DbHelperSQL.ExecuteSqlTran(lstSql);//调用DbHelperSQL类的ExecuteSqlTran()函数(执行多条sql语句,完成数据库事务)
if (rows > 0)//如果几条sql语句均执行成功
{
return true;//返回值为true
}
else//如果执行失败
{
return false;//返回值为false
}
}
(注:DbHelperSQL类代码中的ConnectionString是写在配置文件里的数据库连接字符串)
DbHelperSQL类:
using System.Configuration '这里添加后,还必须在管理器中添加引用
public static string connectionString = ConfigurationManager.AppSettings["ConnectionString"];
///
/// 执行多条SQL语句,实现数据库事务。
///
/// 多条SQL语句
public static int ExecuteSqlTran(List SQLStringList)
{
using (SqlConnection conn = new SqlConnection(connectionString))
{
conn.Open(); //打开数据库连接
SqlCommand cmd = new SqlCommand(); //创建SqlCommand命令
cmd.Connection = conn; //设置命令连接
SqlTransaction tx = conn.BeginTransaction();//开始事务
cmd.Transaction = tx;//设置执行命令的事务
try
{
int count = 0;//定义int类型变量,存放该函数返回值
for (int n = 0; n < SQLStringList.Count; n++)//循环传入的sql语句
{
string strsql = SQLStringList[n]; //第n条sql语句
if (strsql.Trim().Length > 1) //如果第n条sql语句不为空
{
cmd.CommandText = strsql; //设置执行命令的sql语句
count += cmd.ExecuteNonQuery(); //调用执行增删改sql语句的函数ExecuteNonQuery(),执行sql语句
}
}
tx.Commit();//提交事务
return count;//返回受影响行数
}
catch
{
tx.Rollback();
return 0;
}
}
}
配置文件: