当前位置: 首页 > 图文教程 > 网络编程 > ASP.NET > asp.net 执行事务代码

ASP.NET
用 Asp.Net 建立一个在线 RSS 新闻聚合器的方法
关于前台调用后台事件__doPostBack函数
Bin 和 App_Code 文件夹介绍
.NET 2.0 的压缩功能代码
解决Visual Studio 2005 无法显示设计视图的方法
asp.net(c#)两种随机数的算法,可用抽考题
asp.net下url传递中文的解决方案
XmlReader 读取器读取内存流 MemoryStream 的注意事项
asp.net下创建、查询、修改带名称空间的 XML 文件的例子
使用.NET存储XML数据的方法
XslTransform.Transform将结果输出到字符串里的方法
安装 VS2005 SP1 有关问题的解决办法
asp.net下中文验证码,免费开源代码
自定义应用程序配置文件(app.config)
asp.net下使用DIME协议上传文件
动态改变ASP.net页面标题和动态指定页面样式表的方法
WEB上调用HttpWebRequest奇怪问题的解决方法
HTTP协议下用Web Service上传大文件的解决方案
asp.net下Response.ContentType类型汇总
ASP.NET User Control使用技巧一则

ASP.NET 中的 asp.net 执行事务代码


出处:互联网   整理: 软晨网(RuanChen.com)   发布: 2009-09-13   浏览: 94 ::
收藏到网摘: n/a

asp.net 执行事务的实现代码 //数据库执行区,
SqlConnection _sqlConn = null;
SqlTransaction _SqlTrans = null;
try
{
//数据库操作类
_sqlConn = System.mySQLConnection.SqlConnections.GetSQLConnection();//见下面的类
_sqlConn.Open();
// sql事务对象
_SqlTrans = _sqlConn.BeginTransaction();
//基本信息执行SQL语句情况
bool StudentInfo_YN = false;
if (hid_StudentIDValue == "")
{
StudentInfo_YN = (System.mySQLConnection.SqlConnections.UpdateOrDelete(_sqlConn, _SqlTrans, sql语句) > 0) ? true : false;
}
else
{
StudentInfo_YN = true;
}
bool baoMing_YN = false;
//报名基本信息执行SQL语句情况
if (StudentInfo_YN)
{
//获取报名的o_flowid号,由数据库产生
baoMing_YN = (System.mySQLConnection.SqlConnections.UpdateOrDelete(_sqlConn, _SqlTrans, sql语句) > 0) ? true : false;
}
else
{
baoMing_YN = false;
}
bool baomingdetail_YN = false;
//报名的课程详细信息执行SQL语句情况
if (baoMing_YN)
{
baomingdetail_YN = (System.mySQLConnection.SqlConnections.UpdateOrDelete(_sqlConn, _SqlTrans, sql语句) > 0) ? true : false;
}
else
{
baomingdetail_YN = false;
}
//收费表SQL语句情况
//if (baoMing_YN)
//{
// baomingdetail_YN = (System.mySQLConnection.SqlConnections.UpdateOrDelete(_sqlConn, _SqlTrans, sql语句) > 0) ? true : false;
//}
//else
//{
// baomingdetail_YN = false;
//}
//总的判断全部释放成功。
if (baomingdetail_YN)
{
//提交事务,清除Session验证码
_SqlTrans.Commit();
MessageBox.alert(Page, "报名成功。", "window.location.href='addBaoMing.aspx'");
}
else
{
_SqlTrans.Rollback();
MessageBox.alert(Page, "报名失败。");
return;
}
}
catch (SqlException sqlE)
{
MessageBox.alert(Page, "提交异常 " + sqlE.Message.Replace("\"", "'"));
}
finally
{
if (_sqlConn != null)
_sqlConn.Close();
if (_SqlTrans != null)
_SqlTrans.Dispose();
}
写在SqlConnections的类中(一般放在app_code,也可放在三层架构的类中)
//当前连接的是第几个。
static int count = 0;
//最大连接量
static int maxCount = 30;
static SqlConnection[] sqlConns = new SqlConnection[maxCount];
//自己创建自己
static SqlConnections myConn = new SqlConnections();
//初始化
private SqlConnections()
{
for (int i = 0; i < maxCount; i++)
{
sqlConns[i] = new SqlConnection(System.Configuration.ConfigurationSettings.AppSettings["ADOStr"].ToString());
}
}
// 获取数据库连接
public static int UpdateOrDelete(String sqlTxt)
{
SqlConnection sqlConnTemp = SqlConnections.GetSQLConnection();
try
{
SqlCommand sqlCommT = new SqlCommand(sqlTxt, sqlConnTemp);
sqlConnTemp.Open();
return sqlCommT.ExecuteNonQuery();
}
catch (SqlException sqlE)
{
return 0;
}
finally
{
sqlConnTemp.Close();
}
}
public static SqlConnection GetSQLConnection()
{
try
{
try
{
sqlConns[count].Close();
}
catch (Exception eeX)
{
}
return sqlConns[count];
}
finally
{
//当前个数自加。。
if (count == (maxCount - 1))
{
count = 0;
}
else
{
count++;
}
}
}