在Dorado提供默認的提交操作中，用戶可能會有其他自定義的數(shù)據(jù)更新操作，如何使他們都處于一個事務中呢？
方法一: 使用標準的JDBC對象完成數(shù)據(jù)操作.
Dorado提供了一個工具類，com.bstek.dorado.common.TransactionManager，該類提供一個靜態(tài)方法：
Transaction getTransaction(DoradoContext context) throws java.lang.Exception
獲取與指定的上下文(DoradoContext)相關的事務對象.
這樣我們得到一個默認的處理事務對象，通過該事務對象提供的方法：
Connection getConnection(java.lang.String dataSource) throws java.lang.Exception
獲取一個與本事務相關的Connection，自定義的更新就通過這個Connection對象處理，最后系統(tǒng)會自動管理整個事務。
代碼示例:
Transaction transaction = TransactionManager.getTransaction(context);
Connection connection = transaction.getConnection(null);
try 
{
// 利用connection對象進行數(shù)據(jù)操作.
}
finally {
connection.close();
}
|
注意 |
該Connection 對象，你可以執(zhí)行close操作，但是不允許執(zhí)行commit或rollback操作。因為commit或rollback操作將在系統(tǒng)所有更新完成之后才允許進行, commit或rollback操作是由Transaction對象管理的。
即使您在Transaction執(zhí)行commit之前對Connection執(zhí)行了close操作也不會影響到你在該Connection上所作得數(shù)據(jù)修改. 您不必擔心由于提前關閉了Connection而導致所作的數(shù)據(jù)修改脫離了事務. |
方法二: 使用標準的dorado的Dataset和DBStatement對象完成數(shù)據(jù)操作.
除了使用上面的方法之外, 我們還可以使用dorado中提供的Dataset和DBStatement對象完成數(shù)據(jù)操作. 這種做法優(yōu)點在于:
1. 可直接集成Context中的當前事務, 代碼量小.
2. 支持命名參數(shù), 使用方便.
使用SqlDataset添加記錄的代碼示例:
AutoSqlDataset dataset = new AutoSqlDataset();
dataset.setOriginTable("employee"); //設置要操作的數(shù)據(jù)庫表名
dataset.setKeyFields("employee_id"); //設置該表的主鍵(在更新或刪除記錄時必須設置)
dataset.insertRecord(); //插入一條空記錄
// 以下代碼設置新記錄的值
dataset.setString("employee_id", "GUOLIWEI");
dataset.setString("employee_name", "國蒞偉");
dataset.setBoolean("sex", false);
dataset.insertRecord(); //插入另一條空記錄
// 以下代碼設置新記錄的值
dataset.setString("employee_id", "PANLONG");
dataset.setString("employee_name", "盤龍");
dataset.setBoolean("sex", true);
dataset.update(context); //將所做的修改更新到數(shù)據(jù)庫中
使用DBStatement對象的代碼示例:
DBStatement statement = new DBStatement(
null, "INSERT INTO LOG (MSG_TIME, MSG) VALUES (:timestamp, :message)");
ParameterSet parameters = statement.parameters();
//添加一條記錄
parameters.setDate("timestamp", new Date());
parameters.setString("message", "XXX XXX XXX");
statement.execute(context);
//添加另一條記錄
parameters.setDate("timestamp", new Date());
parameters.setString("message", "YYY YYY YYY");
statement.execute(context);