EasyWeb下配置Atomikos+SQLServer分布式数据源

灰太狼 2021-03-28 15:54 585阅读 0赞

**初次尝试：**

配置Mysql时候使用的是Atomikos+DruidXADataSource，所以觉得配置SQLServer应该也是仅仅配置配置就够了，于是引入JDBC驱动依赖后，配置了文件

spring.datasource.system.xa-properties.dataSourceURL=jdbc:sqlserver://XXX;DatabaseName=XXX
     spring.datasource.system.xa-properties.username=sa
     spring.datasource.system.xa-properties.password=XXX
     spring.datasource.system.xa-data-source-class-name=com.alibaba.druid.pool.xa.DruidXADataSource
     spring.datasource.system.unique-resource-name=systemDataSource

但是通过修改配置文件配置SQLServer发现：当我配置url=jdbc:sqlserver://XXX;DatabaseName=XXX时启动Spring Boot会报

1 xa not support dbType :sqlserver

查了下资料，说是Druid会通过url前缀选择JDBC驱动，再追踪错误查看了报错的地方，在源码com.alibaba.druid.pool.xa.DruidXADataSource下

private XAConnection createPhysicalXAConnection(Connection physicalConn) throws SQLException {
             if (JdbcUtils.ORACLE.equals(dbType)) {
                 try {
                     return OracleUtils.OracleXAConnection(physicalConn);
                 } catch (XAException xae) {
                     LOG.error("create xaConnection error", xae);
                     return null;
                 }
             }
     
             if (JdbcUtils.MYSQL.equals(dbType) || JdbcUtils.MARIADB.equals(dbType)) {
                 return MySqlUtils.createXAConnection(driver, physicalConn);
             }
     
             if (JdbcUtils.POSTGRESQL.equals(dbType)) {
                 return PGUtils.createXAConnection(physicalConn);
             }
     
             if (JdbcUtils.H2.equals(dbType)) {
                 return H2Utils.createXAConnection(h2Factory, physicalConn);
             }
     
             if (JdbcUtils.JTDS.equals(dbType)) {
                 return new JtdsXAConnection(physicalConn);
             }
     
             throw new SQLException("xa not support dbType : " + this.dbType);
         }

看了下源码，发现里面有部分是从/META-INF/druid-driver.properties下读取的，但是都没有以前缀jdbc:sqlserver的属性，这说明DruidXADataSorce并不支持SQLServer 2008

**解决思路：**

1.发现里面有个配置jdbc:microsoft:=com.microsoft.jdbc.sqlserver.SQLServerDriver，那么就代表我可以配置成jdbc:microsoft:的url，但是发现这个对应的JDBC驱动是以前sqljdbc，而现在基本都是sqljdbc4，找不到这驱动，同时这驱动不能用于2008版本，所以放弃了这个做法

2.不使用DruidXADataSource，改为SQLServerXADataSource；最终选择的就是这种

**具体操作：**

1.暂时不用properties配置参数，直接在java配置文件中声明Bean

@Bean(name="systemDataSource")
         @Primary
         //@ConfigurationProperties(prefix = "spring.datasource.system") 
         public DataSource dataSource() {
             AtomikosDataSourceBean dataSourceBean = new AtomikosDataSourceBean();
     
             SQLServerXADataSource datasource = new SQLServerXADataSource();
             datasource.setURL("jdbc:sqlserver://XXX;DatabaseName=XXX");
             datasource.setUser("sa");
             datasource.setPassword("XXX");
     
             dataSourceBean.setXaDataSource(datasource);
             dataSourceBean.setUniqueResourceName("systemDataSource");
             dataSourceBean.setPoolSize(20);
             return dataSourceBean;
         }

2.还需要去数据库服务器处理一下

![782803-20190429182335311-448242835.png][]

** 补充说明：**

声明Bean用到的属性使用安全属性注入的话，可以使用如下配置

spring.datasource.system.xa-properties.URL=jdbc:sqlserver://XXX;DatabaseName=XXX
     spring.datasource.system.xa-properties.user=sa
     spring.datasource.system.xa-properties.password=XXX
     spring.datasource.system.pool-size=20
     spring.datasource.system.xa-data-source-class-name=com.microsoft.sqlserver.jdbc.SQLServerXADataSource
     spring.datasource.system.unique-resource-name=systemDataSource

[782803-20190429182335311-448242835.png]: /images/20210328/1616946798541.png