dbBeginTransaction
Version 24.2.8986
dbBeginTransaction
执行BEGIN TRANSACTION
SQL 命令。 指示显式 SQL 事务的起点。 将此操作与 dbEndTransaction 一起使用,其中其他数据库操作在 dbBeginTransaction 和 dbEndTransaction 的调用之间执行。 有关详细信息,请参阅示例。
必需的参数
可选的参数
- transactiontimeout:此事务的超时(以秒为单位)。 零 (
0
) 表示没有超时。 默认值为60
。 - transactionid:交易的 ID。 如果未设置,知行之桥会生成一个 GUID 用作事务 ID。
输出参数
- transactionid:交易的 ID。
示例
在此示例中,在 dbBeginTransaction 和 dbEndTransaction 之间执行数据库查询,创建 SQL 事务。 为了确定事务的状态,需要检查每个查询的状态。 如果所有查询都成功,则提交事务; 否则回滚事务。
<!-- 创建输入项并定义 SQL 查询 -->
<arc:set attr="db.driver" value="cdata.jdbc.mysql.MySQLDriver" />
<arc:set attr="db.conn" value="jdbc:cdata:mysql:server=localhost;port=3306;database=sakila;user=root;password=Password123;"/>
<arc:set attr="db.transactionaction" value="COMMIT" />
<arc:set attr="sql.queries#" value="ALTER TABLE Colors ADD Example varchar(255);"/>
<arc:set attr="sql.queries#" value="INSERT INTO Colors VALUES (27, Blue, Sky);" />
<arc:set attr="sql.queries#" value="INSERT INTO Colors VALUES (28, Red, Apple);" />
<arc:set attr="sql.queries#" value="INSERT INTO Colors VALUES (29, Yellow, Banana);" />
<arc:call op="dbBeginTransaction" in="db" out="dbbeginout">
<arc:try>
<!-- 枚举并执行所有查询并根据结果设置transactionaction -->
<arc:enum attr="sql.queries">
<arc:set attr="db.query" value="[_value]"/>
<arc:call op="dbNonQuery" in="db" out="results" >
<arc:set attr="db.transactionaction" value="[results.db:result | equals('success', 'COMMIT', 'ROLLBACK')]" />
</arc:call>
<!-- 如果任何查询被标记为回滚,请停止运行查询 -->
<arc:if exp="[db.transactionaction | equals('ROLLBACK')]">
<arc:break />
</arc:if>
</arc:enum>
<!-- 如果引发任何异常,捕获它并将事务操作设置为回滚 -->
<arc:catch>
<arc:set attr="db.transactionaction" value="ROLLBACK" />
</arc:catch>
<!-- 最后,调用 dbEndTransaction 来提交或回滚 SQL 事务 -->
<arc:finally>
<arc:set attr="db.transactionid" value="[dbbeginout.transactionid]" />
<arc:call op="dbEndTransaction" in="db" />
</arc:finally>
</arc:try>
</arc:call>
只要在安装并运行知行之桥的计算机上安装驱动程序,就可以修改上面的示例以定位其他数据库。 针对 .NET 调整此示例涉及更改driver
和conn
输入,如下所示:
<arc:set attr="db.driver" value="System.Data.CData.MySql" />
<arc:set attr="db.conn" value="Server=localhost;Database=sakila;UID=root;Password=Password123;"/>