数据库组件 Hxj.Data (十九) (事务二)

对事务有进行了更新,又得去下载一下新版本,对上一版本兼容,扩充了DbTrans方法。

相比十七节(事务)中的事务写法简洁了一些。如下

using (DbTrans trans = DbSession.Default.BeginTransaction())
{
     trans.Update<Products>(Products._.ProductName, "apple", Products._.ProductID == 1);
     trans.Update<Products>(Products._.ProductName, "egg", Products._.ProductID == 2);
     trans.Commit();
}

生成的sql:

Text:

UPDATE [Products] SET [ProductName]=@e6b783222bb34b98b56fc3012500a0d5
WHERE [Products].[ProductID] = @bdb38c8f8fab405d93231e1b2f19c1e2 

Parameters:

@e6b783222bb34b98b56fc3012500a0d5[String] = apple
@bdb38c8f8fab405d93231e1b2f19c1e2[Int32] = 1

Text:

UPDATE [Products] SET [ProductName]=@4184e5de4ed545d9bf3f0ba9a38ed6fa
WHERE [Products].[ProductID] = @f1da00f3628a43c2a9c66678e71049c7 

Parameters:

@4184e5de4ed545d9bf3f0ba9a38ed6fa[String] = egg 
@f1da00f3628a43c2a9c66678e71049c7[Int32] = 2

执行效果是一样的。

try catch的写法也是一样的。

DbTrans trans = DbSession.Default.BeginTransaction();
try
{
     trans.Update<Products>(Products._.ProductName, "apple", Products._.ProductID == 1);
     trans.Update<Products>(Products._.ProductName, "egg", Products._.ProductID == 2);
     trans.Commit();
}
catch
{
     trans.Rollback();
}
finally
{
     trans.Close();
}

组件中的事务并不是分布式事务,只是简单的事务封装。

时间: 2024-10-29 18:47:52

数据库组件 Hxj.Data (十九) (事务二)的相关文章

数据库组件 Hxj.Data (九) (DbSession的其他介绍)

本节将讲述DbSession的其他简单辅助方法. SUM方法 DbSession.Default.Sum<Products>(Products._.UnitPrice, Products._.CategoryID == 2); 返回categroyid=2的unitprice合计. AVG方法 DbSession.Default.Avg<Products>(Products._.UnitPrice, Products._.CategoryID == 2); 返回categroyid

数据库组件 Hxj.Data (二十八)

数据库组件 Hxj.Data (二十八)(事务中的查询,查询字段字中的子查询,WhereClip的隐式转换) 本节讲述新版本中新加的功能,以及如何使用. 事务中的查询 应用场景,有时我们需要事务更新.添加.删除表的操作,在提交事务又需要对这些进行查询(不想 降低事务级别让其他连接查询事务中的数据变动),在事务内部进行的查询. 其实只是在DbTrans中增加了FromSection方法. 示例代码如下: using (DbTrans trans = DbSession.Default.BeginT

数据库组件 Hxj.Data (二十五)(数据库连接配置

本节补充讲述connectionStrings的设置. 组件读取connectionStrings节点的配置的时候会根据providerName来判断是哪个数据库. 数据库 providerName Sql server 2000 1.System.Data.SqlClient 2.Hxj.Data.SqlServer Sql server 2005 Hxj.Data.SqlServer9 MS Access Hxj.Data.MsAccess Sqlite 1.System.Data.SQLi

数据库组件 Hxj.Data (二十四)(Sqlite数据库)

Hxj.Data(V1.3)组件增加了对Sqlite数据库的支持. 以及实体生成工具也同时发布(V1.3)版本支持Sqlite数据库的实体生成. 使用Sqlite数据库开发,需要引用Hxj.Data.Hxj.Data.Sqlite.System.Data.SQLite这三个DLL. config配置数据库连接例如: <add name="SqliteConnectionString" connectionString="Data Source=C:\sqldb.db&q

数据库组件 Hxj.Data (二十二) (缓存)

首先我是做web开发的,所以很多会偏向web的,组件使用的缓存是System.Web.HttpRuntime.Cache. 组件在默认情况下是关闭缓存的. 所以要开启缓存查询要做一下配置. 先看一下例子配置: <configSections> <section name="HxjCacheConfig" type="Hxj.Data.CacheConfiguration,Hxj.Data"/> </configSections>

数据库组件 Hxj.Data (二十六)(Oracle配置)

Oracle配置在connectionStrings节点的providerName为System.Data.OracleClient或者 Hxj.Data.Oracle之外,其他操作使用并没有什么不同. 不过相对于Oracle的自增长列有所不同,要做适当的处理. Oracle是通过Sequence来获取增长的值,不同于Sql Server可以方便的设置列的自增长. 在这里通过修改生成的实体就可以完成自增长列的设置. 例如: 建了一个Sequence,名为:mysequence 表中需要自增的字段

数据库组件 Hxj.Data (二十七)(字段组合更新)

Hxj.Data V1.5.1版本开始支持字段组合更新. 例如:update table set a=b+c update table set a=a+1 (+.-.*./.%)依次类推. 下面将举具体的例子.(例子只是为了测试效果,没有实际意义) 例一. DbSession.Default.Update<Products>(Products._.UnitPrice, Products._.ReorderLevel + Products._.UnitPrice, Products._.Prod

数据库组件 Hxj.Data (十七) (事务)

首先对事务进行了升级,所以又要重新去下载一下新版本. 组件提供了简单的事务,并没有过多的封装. 先上个例子: using (DbTrans trans = DbSession.Default.BeginTransaction()) { DbSession.Default.Update<Products>(Products._.ProductName, "apple", Products._.ProductID == 1, trans); DbSession.Default.

数据库组件 Hxj.Data (三十一)(MySQL篇)

组件V1.7版本增加对MySQL的支持(测试了MySQL 5.1版本). 下面来演示如何使用. 首先添加Connectionstring <add name="MySQLConnectionString" connectionString="server=192.168.1.175;user id=root; password=huxj; Port=3306;database=test;" providerName="Hxj.Data.MySql&q

数据库组件 Hxj.Data (三)(查询操作篇)

Hxj.Data使用入口在Hxj.Data.DbSession,DbSession类封装常用的操作,比如: From<T>,Insert<T>,Update<T>,Delete<T>等常用方法. DbSession.Default是一个默认的DbSession.在默认情况下会自动读取web.config/app.config配置文件中connectionStrings节点的最后一 个配置. 可以通过条用DbSession的SetDefault方法来修改这个D