bboss多数据库事务管理

本文以一个简单的实例来介绍bbossgroups中持久层框架如何实现多数据库事务：

@Test
	public void testMutiDBTX()
	{
		TransactionManager tm =  new TransactionManager();
		try
		{
			tm.begin();
			SQLExecutor.deleteWithDBName("bspf","delete from table1 where id=1");
			SQLExecutor.updateWithDBName("query","update table1 set value='test' where id=1");
			tm.commit();
			DBUtil.debugStatus();//debug连接池实时状态
		}
		catch(Exception e)
		{
			
		}
		finally
		{
			tm.release();
		}

	}
    
}

这个示例展示的在两个数据源（数据源名称为bspf和query）上分别执行一个delete操作和一个删除操作，通过TransactionManager事务管理组件来控制两个操作的事务，从而保证两个数据源事务的一致性，也就是说在bspf和query两个数据源上的操作都包含在一个事务中，这就是所谓的多数据库事务。

另外还可以支持嵌套的事务处理，例如：

@Test
	public void testNestedMutiDBTX()
	{
		TransactionManager tm =  new TransactionManager();
		try
		{
			tm.begin();
			SQLExecutor.deleteWithDBName("bspf","delete from table1 where id=1");
			SQLExecutor.updateWithDBName("query","update table1 set value='test' where id=1");
			testMutiDBButSampleDatabaseTX();
			tm.commit();
			DBUtil.debugStatus();//debug连接池实时状态
		}
		catch(Exception e)
		{
			
		}
		finally
		{
			tm.release();
		}

	}
	@Test
	public void testMutiDBButSampleDatabaseTX()
	{
		TransactionManager tm =  new TransactionManager();
		try
		{
			tm.begin();
			SQLExecutor.deleteWithDBName("bspf","delete from table1 where id=1");
			SQLExecutor.updateWithDBName("mq","update table1 set value='test' where id=1");
			tm.commit();
			DBUtil.debugStatus();//debug连接池实时状态
		}
		catch(Exception e)
		{
			
		}
		finally
		{
			tm.release();
		}
		DBUtil.debugStatus();;//debug连接池实时状态

	}

bspf和query两个数据源的配置（poolman.xml）：

<?xml version="1.0" encoding="utf-8"?>
<poolman>
    
    <datasource>
        <dbname>bspf</dbname>
        <loadmetadata>false</loadmetadata>
      ......
    </datasource>
    <datasource>
        <dbname>query</dbname>
        。。。。。
    </datasource>
</poolman>

详细的配置请参考：
bbossgroups持久层框架数据源配置文件实例

评论

2 楼 yin_bp 2010-10-19  

凤舞凰扬 写道

   真没看懂你的例子想说明什么，这完全就是最基本的JTA的应用，而且还根本没有到XA的级别。
    应该还是要多了解分布式事务先。

例子简单明了，就是使用DBUtil操作不同的数据库，然后把这些操作都包含在同一个数据库事务中，这里的不同的数据是通过例如executeDelete的操作中的第一个参数指定的：

   db.executeDelete("bspf","delete from table2 where id=1");  
   db.executeUpdate("query","update table2 set value='test' where id=1");  

分别为bspf和query两个datasource，具体的配置对应于文章后面的poolman.xml中的两个数据库连接池。

凤舞凰扬指出没有到XA级别，确实这里只是bbosspersistent框架中提供的一个单纯数据库的多事务管理功能，没有涵盖其他比如jms或者第三方工作流系统事务的分布式事务体制，这个问题目前正在构思实现中，还请各位大拿多多指教啊。

1 楼 凤舞凰扬 2010-10-18  

   真没看懂你的例子想说明什么，这完全就是最基本的JTA的应用，而且还根本没有到XA的级别。
    应该还是要多了解分布式事务先。