使用jta和atomikos配置多数据源（oracle和mysql）
作者：互联网
pom.xml 文件
<!-- 分布式事务 jta+ atomikos -->
<!-- 多个数据源的情况下，事务进行管理 -->
<dependency>
<groupId>com.atomikos</groupId>
<artifactId>transactions-jdbc</artifactId>
<version>4.0.6</version>
</dependency>
<dependency>
<groupId>javax.transaction</groupId>
<artifactId>jta</artifactId>
<version>1.1</version>
</dependency>
<!-- 数据库连接池版本 推荐使用1.0.9的版本-->
<druid.version>1.0.9</druid.version>
spring-dataSource.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:context="http://www.springframework.org/schema/context"
xmlns:aop="http://www.springframework.org/schema/aop"
xmlns:tx="http://www.springframework.org/schema/tx"
xmlns:jdbc="http://www.springframework.org/schema/jdbc"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-4.0.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop-4.0.xsd
http://www.springframework.org/schema/tx
http://www.springframework.org/schema/tx/spring-tx-4.0.xsd">
<!-- 引入配置文件 数据库-->
<bean id="propertyConfigurer"
class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer">
<property name="location" value="classpath:config/db.properties" />
</bean>
<!-- 配置数据druid数据源，密码进行加密处理-->
<!-- <bean id="dataSource" class="com.alibaba.druid.pool.DruidDataSource" destroy-method="close"> -->
<bean id="dataSource" class="com.alibaba.druid.pool.xa.DruidXADataSource" destroy-method="close" init-method="init">
<property name="url" value="${db.core.url}" />
<property name="username" value="${db.core.username}" />
<property name="password" value="${db.core.password}" />
<!-- 密码解密 -->
<property name="connectionProperties" value="config.decrypt=true;config.decrypt.key=${db.core.publickey}" />
<property name="proxyFilters">
<list><ref bean="log-filter" /></list>
</property>
<!-- 配置初始化大小、最小、最大 -->
<property name="initialSize" value="${druid.initialSize}" />
<property name="minIdle" value="${druid.minIdle}" />
<property name="maxActive" value="${druid.maxActive}" />
<!-- 配置获取连接等待超时的时间 -->
<property name="maxWait" value="${druid.maxWait}" />
<!-- 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒 -->
<property name="timeBetweenEvictionRunsMillis" value="${druid.timeBetweenEvictionRunsMillis}" />
<!-- 配置一个连接在池中最小生存的时间，单位是毫秒 -->
<property name="minEvictableIdleTimeMillis" value="${druid.minEvictableIdleTimeMillis}" />
<property name="validationQuery" value="${druid.validationQuery}" />
<property name="testWhileIdle" value="${druid.testWhileIdle}" />
<property name="testOnBorrow" value="${druid.testOnBorrow}" />
<property name="testOnReturn" value="${druid.testOnReturn}" />
<!-- 打开PSCache，并且指定每个连接上PSCache的大小 如果用Oracle，则把poolPreparedStatements配置为true，mysql可以配置为false。 -->
<!--
<property name="poolPreparedStatements" value="${druid.poolPreparedStatements}" />
<property name="maxPoolPreparedStatementPerConnectionSize" value="${druid.maxPoolPreparedStatementPerConnectionSize}" />
-->
<!-- 打开removeAbandoned功能 -->
<property name="removeAbandoned" value="${druid.removeAbandoned}" />
<!-- 1800秒，也就是30分钟 -->
<property name="removeAbandonedTimeout" value="${druid.removeAbandonedTimeout}" />
<!-- 关闭abanded连接时输出错误日志 -->
<property name="logAbandoned" value="${druid.logAbandoned}" />
<!-- 配置监控统计拦截的filters -->
<property name="filters" value="${druid.filters}" />
</bean>
<!-- 配置数据druid多数据源（高斯数据库）密码进行加密处理 -->
<!-- <bean id="postgresqlDataSource" class="com.alibaba.druid.pool.DruidDataSource" destroy-method="close"> -->
<bean id="postgresqlDataSource" class="com.alibaba.druid.pool.xa.DruidXADataSource" destroy-method="close" init-method="init">
<property name="driverClassName" value="${dbpg.core.driver}" />
<property name="url" value="${dbpg.core.url}" />
<property name="username" value="${dbpg.core.username}" />
<property name="password" value="${dbpg.core.password}" />
<!-- 密码解密 -->
<property name="connectionProperties" value="config.decrypt=true;config.decrypt.key=${dbpg.core.publickey}" />
<property name="proxyFilters">
<list><ref bean="log-filter" /></list>
</property>
<!-- 配置初始化大小、最小、最大 -->
<property name="initialSize" value="${druid.initialSize}" />
<property name="minIdle" value="${druid.minIdle}" />
<property name="maxActive" value="${druid.maxActive}" />
<!-- 配置获取连接等待超时的时间 -->
<property name="maxWait" value="${druid.maxWait}" />
<!-- 配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位是毫秒 -->
<property name="timeBetweenEvictionRunsMillis" value="${druid.timeBetweenEvictionRunsMillis}" />
<!-- 配置一个连接在池中最小生存的时间，单位是毫秒 -->
<property name="minEvictableIdleTimeMillis" value="${druid.minEvictableIdleTimeMillis}" />
<property name="validationQuery" value="${druid.validationQuery}" />
<property name="testWhileIdle" value="${druid.testWhileIdle}" />
<property name="testOnBorrow" value="${druid.testOnBorrow}" />
<property name="testOnReturn" value="${druid.testOnReturn}" />
<!-- 打开PSCache，并且指定每个连接上PSCache的大小 如果用Oracle，则把poolPreparedStatements配置为true，mysql可以配置为false。 -->
<!--
<property name="poolPreparedStatements" value="${druid.poolPreparedStatements}" />
<property name="maxPoolPreparedStatementPerConnectionSize" value="${druid.maxPoolPreparedStatementPerConnectionSize}" />
-->
<!-- 打开removeAbandoned功能 -->
<property name="removeAbandoned" value="${druid.removeAbandoned}" />
<!-- 1800秒，也就是30分钟 -->
<property name="removeAbandonedTimeout" value="${druid.removeAbandonedTimeout}" />
<!-- 关闭abanded连接时输出错误日志 -->
<property name="logAbandoned" value="${druid.logAbandoned}" />
<!-- 配置监控统计拦截的filters -->
<property name="filters" value="${druid.filters}" />
</bean>
<!-- druid日志输出filter -->
<bean id="log-filter" class="com.alibaba.druid.filter.logging.Log4jFilter">
<property name="statementExecutableSqlLogEnable" value="true" />
<property name="resultSetLogEnabled" value="false" />
<property name="statementLogEnabled" value="false" />
<property name="connectionLogEnabled" value="false" />
<property name="dataSourceLogEnabled" value="false" />
</bean>
<!-- Oracle库datasource数据源 -->
<bean id="oracleDataSource" class="com.atomikos.jdbc.AtomikosDataSourceBean"
destroy-method="close" init-method="init">
<property name="uniqueResourceName" value="ads" />
<property name="xaDataSource" ref="dataSource" />
<property name="maintenanceInterval" value="28000" />
<!-- <property name="testQuery" value="SELECT 1" /> -->
<!-- <property name="minPoolSize" value="5" />
<property name="maxPoolSize" value="20" />
<property name="borrowConnectionTimeout" value="60" /> -->
</bean>
<!-- 高斯库datasource数据源 -->
<bean id="dataSourcePostgresql" class="com.atomikos.jdbc.AtomikosDataSourceBean"
destroy-method="close" init-method="init">
<property name="uniqueResourceName" value="bds" />
<property name="xaDataSource" ref="postgresqlDataSource" />
<property name="maintenanceInterval" value="28000" />
<!-- <property name="testQuery" value="SELECT 1" /> -->
<!-- <property name="minPoolSize" value="5" />
<property name="maxPoolSize" value="20" />
<property name="borrowConnectionTimeout" value="60" /> -->
</bean>
<!-- atomitos事务管理器 -->
<bean id="atomitosTransactionManager" class="com.atomikos.icatch.jta.UserTransactionManager"
init-method="init" destroy-method="close">
<property name="forceShutdown" value="true" />
</bean>
<!-- atomitos事务 -->
<bean id="atomikosTransaction" class="com.atomikos.icatch.jta.UserTransactionImp">
<property name="transactionTimeout" value="600" />
</bean>
<!-- Spring JTA事务管理器 -->
<bean id="transactionManager"
class="org.springframework.transaction.jta.JtaTransactionManager">
<property name="transactionManager" ref="atomitosTransactionManager" />
<property name="userTransaction" ref="atomikosTransaction" />
<property name="allowCustomIsolationLevels" value="true" />
<property name="globalRollbackOnParticipationFailure" value="true" />
</bean>
<!-- 开启事务注解驱动 -->
<tx:annotation-driven transaction-manager="transactionManager" />
<!-- interceptor事务拦截器 -->
<bean id="transactionInterceptor"
class="org.springframework.transaction.interceptor.TransactionInterceptor">
<property name="transactionManager" ref="transactionManager" />
<property name="transactionAttributes">
<props>
<prop key="*">PROPAGATION_REQUIRED,-Exception</prop>
</props>
</property>
</bean>
<!-- proxy代理所有Mapper结尾的bean实例 -->
<bean
class="org.springframework.aop.framework.autoproxy.BeanNameAutoProxyCreator">
<property name="beanNames">
<list>
<value>*Mapper</value>
</list>
</property>
<property name="interceptorNames">
<list>
<value>transactionInterceptor</value>
</list>
</property>
</bean>
<!-- 开启事务注解驱动 -->
<!-- <tx:annotation-driven transaction-manager="transactionManager" /> -->
<!-- 事务管理器 -->
<!-- <bean id="transactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
<property name="dataSource" ref="dataSource" />
<property name="DataSource" ref="postgresqlDataSource" />
</bean> -->
<!-- 事务管理器 高斯数据源事务-->
<!-- <bean id="transactionManagerPG" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
高斯数据源事务
<property name="dataSource" ref="postgresqlDataSource" />
</bean> -->
</beans>
spring-mybatis.xml
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context" xmlns:aop="http://www.springframework.org/schema/aop" xmlns:p="http://www.springframework.org/schema/p"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-4.0.xsd
http://www.springframework.org/schema/context
http://www.springframework.org/schema/context/spring-context-4.0.xsd
http://www.springframework.org/schema/aop
http://www.springframework.org/schema/aop/spring-aop-4.0.xsd">
<!-- spring与mybatis整合配置，扫描所有dao -->
<!-- 根据实际情况增加 -->
<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer" p:basePackage="com.**.**.dao" p:sqlSessionFactoryBeanName="sqlSessionFactory" />
<!-- 高斯库加载所有dao -->
<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer" p:basePackage="com.**.**.daopg" p:sqlSessionFactoryBeanName="sqlSessionFactoryPG" />
<!-- scanner批量创建bean -->
<bean class="org.mybatis.spring.mapper.MapperScannerConfigurer">
<property name="basePackage" value="com.**.**.daopg" />
<property name="sqlSessionFactoryBeanName" value="sqlSessionFactoryPG" />
</bean>
<bean id="globalConfig" class="com.baomidou.mybatisplus.core.config.GlobalConfig">
<!--逻辑删除 0 是默认未删除 1 是删除-->
<property name="dbConfig">
<bean class="com.baomidou.mybatisplus.core.config.GlobalConfig$DbConfig">
<property name="logicDeleteValue" value="1"/>
<property name="logicNotDeleteValue" value="0"/>
</bean>
</property>
</bean>
<!-- <bean id="sqlSessionFactory" class="org.mybatis.spring.SqlSessionFactoryBean"> -->
<bean id="sqlSessionFactory" class="com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean">
<property name="globalConfig" ref="globalConfig"/>
<!--dataSource属性指定要用到的连接池 -->
<property name="dataSource" ref="oracleDataSource" />
<!--configLocation属性指定mybatis的核心配置文件 -->
<property name="configLocation" value="classpath:spring/mybatis-config.xml" />
<property name="mapperLocations">
<array>
<value>classpath*:com/**/**/dao/mapper/*.xml</value>
</array>
</property>
<!-- mybatis物理分页插件 -->
<property name="plugins">
<array>
<!-- 权限插件 add by zhaoyunhua 20200513-->
<!-- enabled:是否启用true|false -->
<!-- ignoreroles:忽略得角色列表，逗号分隔(R001系统管理角色) -->
<!-- debugable:是否调试模式，输出更多日志true|false -->
<!--
正式环境推荐使用：enabled=true,ignoreroles=R001,debugable=false
-->
<bean class="com.actuary.utils.mybatis.PermissionHelper">
<property name="properties">
<value>
enabled=true
ignoreroles=R001
debugable=false
</value>
</property>
</bean>
<bean class="com.github.pagehelper.PageHelper">
<property name="properties">
<value>
offsetAsPageNum=true
rowBoundsWithCount=true
pageSizeZero=true
reasonable=true
supportMethodsArguments=false
</value>
</property>
</bean>
</array>
</property>
</bean>
<!-- sql会话模版 -->
<!-- <bean id="sqlSessionTemplate" class="org.mybatis.spring.SqlSessionTemplate" scope="prototype">
<constructor-arg ref="sqlSessionFactory"/>
<constructor-arg ref="sqlSessionFactory"/>
</bean> -->
<!-- 配置高斯数据库 sqlSessionFactoryPG -->
<bean id="sqlSessionFactoryPG" class="com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean">
<property name="globalConfig" ref="globalConfig"/>
<!--dataSource属性指定要用到的连接池 -->
<property name="dataSource" ref="dataSourcePostgresql" />
<!--configLocation属性指定mybatis的核心配置文件 -->
<property name="configLocation" value="classpath:spring/mybatis-config.xml" />
<property name="mapperLocations">
<array>
<value>classpath*:com/**/**/daopg/mapper/*.xml</value>
</array>
</property>
<!-- mybatis物理分页插件 -->
<property name="plugins">
<array>
<!-- 权限插件 add by zhaoyunhua 20200513-->
<!-- enabled:是否启用true|false -->
<!-- ignoreroles:忽略得角色列表，逗号分隔(R001系统管理角色) -->
<!-- debugable:是否调试模式，输出更多日志true|false -->
<!--
正式环境推荐使用：enabled=true,ignoreroles=R001,debugable=false
-->
<bean class="com.actuary.utils.mybatis.PermissionHelper">
<property name="properties">
<value>
enabled=true
ignoreroles=R001
debugable=false
</value>
</property>
</bean>
<bean class="com.github.pagehelper.PageHelper">
<property name="properties">
<value>
offsetAsPageNum=true
rowBoundsWithCount=true
pageSizeZero=true
reasonable=true
supportMethodsArguments=false
</value>
</property>
</bean>
</array>
</property>
</bean>
</beans>
######durid数据源 #db.core.url=jdbc:oracle:thin:@192.168.1.133:1521:utf8db db.core.url=jdbc:oracle:thin:@127.0.0.1:1521:orcl1 #db.core.username=username #db.core.password=YbKBbfbRSBUXsBooZthhtOZ9cFMdxpKTfkIYPiaEYlL60sdsCwja3Yb6AhdmzTKOZemmL/R2IhBPkfFze2JDyw== #db.core.publickey=MFwwDQYJKoZIhvcNAQEBBQADSwAwSAJBAID/knRsgdpUE1u1eSp1Sz5MYWmHFi3tTX+dpdoYfX2Izz32cdKYx3gOpPaNHdgYurccjVxP4SHj2cSsKnunLdMCAwEAAQ== db.core.username=username db.core.password=X9fsOexysXatYqn8jMJqStH39S59u2puixOajW9JdPgq/I6m0TA8J/XnqXWEknxzxbzSxdUs0L/DTVSkVxXo1g== db.core.publickey=MFwwDQYJKoZIhvcNAQEBBQADSwAwSAJBALDtpiwe4riGVTipIFK3ai6dcNx65gFTtXoByt+kcHseqxblzZxMfwO8nZsbFQ6KOxZgIfFFpy1viJy9tOGiQI8CAwEAAQ== ######durid多数据源(高斯库) #dbpg.core.driver=org.postgresql.Driver dbpg.core.driver=com.mysql.jdbc.Driver #db2.core.url=jdbc:postgresql:@9.16.98.105:25308:postgres #dbpg.core.url=jdbc:postgresql://9.16.98.105:25308/postgres dbpg.core.url=jdbc:mysql://localhost:3306/mybatis #db.core.username=abc #db.core.password=YbKBbfbRSBUXsBooZthhtOZ9cFMdxpKTfkIYPiaEYlL60sdsCwja3Yb6AhdmzTKOZemmL/R2IhBPkfFze2JDyw== #db.core.publickey=MFwwDQYJKoZIhvcNAQEBBQADSwAwSAJBAID/knRsgdpUE1u1eSp1Sz5MYWmHFi3tTX+dpdoYfX2Izz32cdKYx3gOpPaNHdgYurccjVxP4SHj2cSsKnunLdMCAwEAAQ== dbpg.core.username=root dbpg.core.password=vPY0JPHPcPB/E7jqLd+I+JGgrZH55NyHQf5ZGlicmVoHUUo/ucSHIvV8iEoyxRmd/QJXohF6JLlj7zfMez7T7g== dbpg.core.publickey=MFwwDQYJKoZIhvcNAQEBBQADSwAwSAJBANSthDqkg3th6mRtw2FP4SS6WjF9X6PD27qF6vMhK9eO0ObuxT/hXgt7VIb0IuxV1ZTC3/ONexum0tTbthnnqjkCAwEAAQ== #dbpg.core.username=abc #dbpg.core.password=LsCt/K4DFAwWpgOV6CczSBWFyYs6YzSYEZ9VCbXQmr1U50LIc9zKAEgTMufg+TUprIJIGPwgJpdc+kfKT32+8Q== #dbpg.core.publickey=MFwwDQYJKoZIhvcNAQEBBQADSwAwSAJBAM02pyMsQAwUfHiZMKfpbHtc4jUBksh0AXFOti4o3hVVWqBL0d50O5OxidVd/QFcfIJDgGKyfIXX439uCiUl1mUCAwEAAQ== #druid datasource config druid.initialSize=10 druid.minIdle=1 druid.maxActive=200 druid.maxWait=60000 druid.timeBetweenEvictionRunsMillis=60000 druid.minEvictableIdleTimeMillis=300000 druid.validationQuery=SELECT 'x' FROM dual druid.testWhileIdle=true druid.testOnBorrow=false druid.testOnReturn=false druid.removeAbandoned=true druid.removeAbandonedTimeout=1800 druid.logAbandoned=true druid.poolPreparedStatements=false druid.maxPoolPreparedStatementPerConnectionSize=20 druid.filters=config,mergeStat,log4j
标签：core,atomikos,--,数据源,db,druid,dbpg,mysql,true 来源： https://www.cnblogs.com/hnzj/p/15896367.html