bboss持久层多数据源配置及多数据库事务控制使用方法

简介: bboss持久层多数据源配置及使用方法,持久层框架及demo下载请参看文档:http://yin-bp.iteye.com/blog/1080824 1.配置多个数据源-poolman.xml 在classes类路径根目录下准备好dbcp.
bboss持久层多数据源配置及使用方法,持久层框架及demo下载请参看文档: http://yin-bp.iteye.com/blog/1080824

1.配置多个数据源-poolman.xml
在classes类路径根目录下准备好dbcp.xml和dbcp1.xml两个配置文件(基于bboss ioc语法)
dbcp.xml:
<property name="datasource" class="com.frameworkset.commons.dbcp2.BasicDataSource">
 	<property name="driverClassName" value="oracle.jdbc.driver.OracleDriver"/>  
	<property name="url" value="jdbc:oracle:thin:@//10.0.15.51:1521/orcl"/>  
	<property name="username" value="afms"/>  
	<property name="password" value="afms"/>  
	<!--initialSize: 初始化连接-->  
	<property name="initialSize" value="5"/>  
	<property name="maxTotal" value="20"/>  
	<!--maxIdle: 最大空闲连接-->  
	<property name="maxIdle" value="20"/>  
	<!--minIdle: 最小空闲连接-->  
	<property name="minIdle" value="20"/>  

	<!--removeAbandoned: 是否自动回收超时连接-->  
	<property name="removeAbandonedOnBorrow" value="false"/>
	<property name="logAbandoned" value="true"/>
	<!--removeAbandonedTimeout: 超时时间(以秒数为单位)-->  
	<property name="removeAbandonedTimeout" value="180"/>  
	<!--maxWait: 超时等待时间以毫秒为单位 6000毫秒/1000等于6秒-->  
	<property name="maxWaitMillis" value="3000"/>  
	<property name="validationQuery" value="SELECT 1 from dual"/>	  
	<property name="testOnBorrow" value="true"/> 
</property>

dbcp1.xml:
<property name="datasource" class="com.frameworkset.commons.dbcp2.BasicDataSource">
 	<property name="driverClassName" value="oracle.jdbc.driver.OracleDriver"/>  
	<property name="url" value="jdbc:oracle:thin:@//10.0.15.51:1521/orcl"/>  
	<property name="username" value="bfms"/>  
	<property name="password" value="bfms"/>  
	<!--initialSize: 初始化连接-->  
	<property name="initialSize" value="5"/>  
	<property name="maxTotal" value="20"/>  
	<!--maxIdle: 最大空闲连接-->  
	<property name="maxIdle" value="20"/>  
	<!--minIdle: 最小空闲连接-->  
	<property name="minIdle" value="20"/>  

	<!--removeAbandoned: 是否自动回收超时连接-->  
	<property name="removeAbandonedOnBorrow" value="false"/>
	<property name="logAbandoned" value="true"/>
	<!--removeAbandonedTimeout: 超时时间(以秒数为单位)-->  
	<property name="removeAbandonedTimeout" value="180"/>  
	<!--maxWait: 超时等待时间以毫秒为单位 6000毫秒/1000等于6秒-->  
	<property name="maxWaitMillis" value="3000"/>  
	<property name="validationQuery" value="SELECT 1 from dual"/>	  
	<property name="testOnBorrow" value="true"/> 
</property>


在poolman.xml中装载这两个数据源:
<poolman>

  <datasource>

		<dbname>ds0</dbname>
		<loadmetadata>false</loadmetadata>
		<enablejta>true</enablejta>
		<jndiName>ds0_datasource_jndiname</jndiName>
		<datasourceFile>dbcp.xml</datasourceFile>
		<autoprimarykey>false</autoprimarykey>
		<showsql>true</showsql>
		<keygenerate>composite</keygenerate>
                <RETURN_GENERATED_KEYS>true</RETURN_GENERATED_KEYS>
                <queryfetchsize>10000</queryfetchsize>
	</datasource>
<datasource>

		<dbname>ds1</dbname>
		<loadmetadata>false</loadmetadata>
		<enablejta>true</enablejta>
		<jndiName>ds1_datasource_jndiname</jndiName>
		<datasourceFile>dbcp1.xml</datasourceFile>
		<autoprimarykey>false</autoprimarykey>
		<showsql>true</showsql>
		<keygenerate>composite</keygenerate>
                <RETURN_GENERATED_KEYS>false</RETURN_GENERATED_KEYS>
	</datasource>
</poolman>


配置了两个数据源ds0和ds1,下面介绍利用持久层api在不同数据源上执行db操作。

queryfetchsize:指定数据源对应的jdbc 查询操作的fetchsize,不指定的话采用jdbc默认设置

2.多数据源api及多数据源事务控制实例
目前bboss常用的数据库访问组件ConfigSQLExecutor和SQLExecutor都提供了多数据源操作api,这种api中都显示地指定dbname参数,也就是数据源的名称,例如上面的ds0和ds1;另外一种api是不带dbname参数,这种api默认在poolman.xml文件中配置的第一个数据源上执行db操作。两种api举例说明如下(以SQLExecutor组件为例来说明,ConfigSQLExecutor组件除了sql语句从配置文件中读取外,它的api与SQLExecutor组件api一致,就不额外介绍ConfigSQLExecutor了。):

TransactionManager tm = new TransactionManager();
try{
tm.begin();//开始事务
SQLExecutor.delete("delete from LISTBEAN where id=?",1);//不带数据源dbname的api,默认在第一个数据源上执行db操作,也就是ds0数据源。
		SQLExecutor.deleteWithDBName("ds0","delete from LISTBEAN where id=?",1);//显示指定db操作在ds0数据源上操作
		SQLExecutor.deleteWithDBName("ds1","delete from LISTBEAN where id=?",1);//显示指定db操作在ds1数据源上操作
tm.commit();//提交事务
}
catch(Exception e)
{
   throw e;
}
finally
{
   tm.release();//释放事务资源,如果有异常发生,则会回滚事务
}

上面是以删除操作来做说明,同时我们将两个数据源上的数据库操作包含到一个事务中,这样很好地保证了多数据库操作事务的一致性。其它操作(插入,修改,查询)类似也不举例一一介绍了,具体可参考以下示例文件:
SimpleApiTest1.java
ConfigSQLExecutorTest.java
SimpleApiTest.java
TestPrepareDBUtilNewInterface.java
目录
相关文章
|
2月前
|
存储 监控 安全
数据库多实例的部署与配置方法
【10月更文挑战第23天】数据库多实例的部署和配置需要综合考虑多个因素,包括硬件资源、软件设置、性能优化、安全保障等。通过合理的部署和配置,可以充分发挥多实例的优势,提高数据库系统的运行效率和可靠性。在实际操作中,要不断总结经验,根据实际情况进行调整和优化,以适应不断变化的业务需求。
|
3月前
|
SQL 关系型数据库 MySQL
乐观锁在分布式数据库中如何与事务隔离级别结合使用
乐观锁在分布式数据库中如何与事务隔离级别结合使用
|
12天前
|
SQL 存储 Java
数据库———事务及bug的解决
事务的一些概念,并发事务以及并发事务引起的bug,脏读,不可重复读,幻读,数据库中的隔离级别,事务的简单应用
|
2月前
|
数据库连接 Linux Shell
Linux下ODBC与 南大通用GBase 8s数据库的无缝连接配置指南
本文详细介绍在Linux系统下配置GBase 8s数据库ODBC的过程,涵盖环境变量设置、ODBC配置文件编辑及连接测试等步骤。首先配置数据库环境变量如GBASEDBTDIR、PATH等,接着修改odbcinst.ini和odbc.ini文件,指定驱动路径、数据库名称等信息,最后通过catalog.c工具或isql命令验证ODBC连接是否成功。
|
2月前
|
消息中间件 资源调度 关系型数据库
如何在Flink on YARN环境中配置Debezium CDC 3.0,以实现实时捕获数据库变更事件并将其传输到Flink进行处理
本文介绍了如何在Flink on YARN环境中配置Debezium CDC 3.0,以实现实时捕获数据库变更事件并将其传输到Flink进行处理。主要内容包括安装Debezium、配置Kafka Connect、创建Flink任务以及启动任务的具体步骤,为构建实时数据管道提供了详细指导。
126 9
|
2月前
|
安全 Nacos 数据库
Nacos是一款流行的微服务注册与配置中心,但直接暴露在公网中可能导致非法访问和数据库篡改
Nacos是一款流行的微服务注册与配置中心,但直接暴露在公网中可能导致非法访问和数据库篡改。本文详细探讨了这一问题的原因及解决方案,包括限制公网访问、使用HTTPS、强化数据库安全、启用访问控制、监控和审计等步骤,帮助开发者确保服务的安全运行。
79 3
|
2月前
|
PHP 数据库 数据安全/隐私保护
布谷直播源码部署服务器关于数据库配置的详细说明
布谷直播系统源码搭建部署时数据库配置明细!
|
2月前
|
Java 数据库连接 数据库
如何构建高效稳定的Java数据库连接池,涵盖连接池配置、并发控制和异常处理等方面
本文介绍了如何构建高效稳定的Java数据库连接池,涵盖连接池配置、并发控制和异常处理等方面。通过合理配置初始连接数、最大连接数和空闲连接超时时间,确保系统性能和稳定性。文章还探讨了同步阻塞、异步回调和信号量等并发控制策略,并提供了异常处理的最佳实践。最后,给出了一个简单的连接池示例代码,并推荐使用成熟的连接池框架(如HikariCP、C3P0)以简化开发。
61 2
|
2月前
|
关系型数据库 MySQL Linux
在 CentOS 7 中通过编译源码方式安装 MySQL 数据库的详细步骤,包括准备工作、下载源码、编译安装、配置 MySQL 服务、登录设置等。
本文介绍了在 CentOS 7 中通过编译源码方式安装 MySQL 数据库的详细步骤,包括准备工作、下载源码、编译安装、配置 MySQL 服务、登录设置等。同时,文章还对比了编译源码安装与使用 RPM 包安装的优缺点,帮助读者根据需求选择最合适的方法。通过具体案例,展示了编译源码安装的灵活性和定制性。
197 2
|
3月前
|
数据库
什么是数据库的事务隔离级别,有什么作用
【10月更文挑战第21】什么是数据库的事务隔离级别,有什么作用
27 3

热门文章

最新文章