springboot配置多数据源并配置事务

悠悠 2023-02-11 13:27 12阅读 0赞

**目录**

1.springboot配置多数据源

2.配置多数据源的事务

--------------------

1.springboot配置多数据源

1、配置文件读取的java配置

spring:
    datasource:
        member:
          #springboot2 多数据源读取名称存在bug，使用jdbc-url替代url
          url: jdbc:mysql://localhost:3306/member
          username: root
          password: 123456
          borrowConnectTimeot: 30
          logoutTimeout: 30
          maintenanceInterval: 60
          maxIdelTime: 60
          maxLifeTime: 20000
          maxPoolSize: 25
          minPoolSize: 5
          uniqueResourceName: memberDatasource
        #订单数据库
        order:
          #springboot2 多数据源读取名称存在bug，使用jdbc-url替代url
          url: jdbc:mysql://localhost:3306/order
          username: root
          password: 123456
          borrowConnectTimeot: 30
          logoutTimeout: 30
          maintenanceInterval: 60
          maxIdelTime: 60
          maxLifeTime: 20000
          maxPoolSize: 25
          minPoolSize: 5
          uniqueResourceName: orderDatasource

2、数据源配置 DBConfig

OrderDBConfig.java

package com.cherish_lailai.atomikosjta.config;
     
    import org.springframework.boot.context.properties.ConfigurationProperties;
    import org.springframework.stereotype.Component;
     
    @Component
    @ConfigurationProperties(prefix="mysql.datasource.order")
    public class OrderDBConfig {
        private String url;
        private String username;
        private String password;
        private int minPoolSize;
        private int maxPoolSize;
        private int maxLifetime;
        private int borrowConnectionTimeout;
        private int loginTimeout;
        private int maintenanceInterval;
        private int maxIdleTime;
        public String getUrl() {
            return url;
        }
        public void setUrl(String url) {
            this.url = url;
        }
        public String getUsername() {
            return username;
        }
        public void setUsername(String username) {
            this.username = username;
        }
        public String getPassword() {
            return password;
        }
        public void setPassword(String password) {
            this.password = password;
        }
        public int getMinPoolSize() {
            return minPoolSize;
        }
        public void setMinPoolSize(int minPoolSize) {
            this.minPoolSize = minPoolSize;
        }
        public int getMaxPoolSize() {
            return maxPoolSize;
        }
        public void setMaxPoolSize(int maxPoolSize) {
            this.maxPoolSize = maxPoolSize;
        }
        public int getMaxLifetime() {
            return maxLifetime;
        }
        public void setMaxLifetime(int maxLifetime) {
            this.maxLifetime = maxLifetime;
        }
        public int getBorrowConnectionTimeout() {
            return borrowConnectionTimeout;
        }
        public void setBorrowConnectionTimeout(int borrowConnectionTimeout) {
            this.borrowConnectionTimeout = borrowConnectionTimeout;
        }
        public int getLoginTimeout() {
            return loginTimeout;
        }
        public void setLoginTimeout(int loginTimeout) {
            this.loginTimeout = loginTimeout;
        }
        public int getMaintenanceInterval() {
            return maintenanceInterval;
        }
        public void setMaintenanceInterval(int maintenanceInterval) {
            this.maintenanceInterval = maintenanceInterval;
        }
        public int getMaxIdleTime() {
            return maxIdleTime;
        }
        public void setMaxIdleTime(int maxIdleTime) {
            this.maxIdleTime = maxIdleTime;
        }
    }

MemberDBConfig.java

package com.cmbc.multiDatasourcetransaction;
    
    import org.springframework.boot.context.properties.ConfigurationProperties;
    import org.springframework.stereotype.Component;
    
    
    @Component
    @ConfigurationProperties(prefix = "mysql.datasource.user")
    public class MemberDBConfig {
        private String url;
        private String username;
        private String password;
        private int minPoolSize;
        private int maxPoolSize;
        private int maxLifetime;
        private int borrowConnectionTimeout;
        private int loginTimeout;
        private int maintenanceInterval;
        private int maxIdleTime;
    
        public String getUrl() {
            return url;
        }
    
        public void setUrl(String url) {
            this.url = url;
        }
    
        public String getUsername() {
            return username;
        }
    
        public void setUsername(String username) {
            this.username = username;
        }
    
        public String getPassword() {
            return password;
        }
    
        public void setPassword(String password) {
            this.password = password;
        }
    
        public int getMinPoolSize() {
            return minPoolSize;
        }
    
        public void setMinPoolSize(int minPoolSize) {
            this.minPoolSize = minPoolSize;
        }
    
        public int getMaxPoolSize() {
            return maxPoolSize;
        }
    
        public void setMaxPoolSize(int maxPoolSize) {
            this.maxPoolSize = maxPoolSize;
        }
    
        public int getMaxLifetime() {
            return maxLifetime;
        }
    
        public void setMaxLifetime(int maxLifetime) {
            this.maxLifetime = maxLifetime;
        }
    
        public int getBorrowConnectionTimeout() {
            return borrowConnectionTimeout;
        }
    
        public void setBorrowConnectionTimeout(int borrowConnectionTimeout) {
            this.borrowConnectionTimeout = borrowConnectionTimeout;
        }
    
        public int getLoginTimeout() {
            return loginTimeout;
        }
    
        public void setLoginTimeout(int loginTimeout) {
            this.loginTimeout = loginTimeout;
        }
    
        public int getMaintenanceInterval() {
            return maintenanceInterval;
        }
    
        public void setMaintenanceInterval(int maintenanceInterval) {
            this.maintenanceInterval = maintenanceInterval;
        }
    
        public int getMaxIdleTime() {
            return maxIdleTime;
        }
    
        public void setMaxIdleTime(int maxIdleTime) {
            this.maxIdleTime = maxIdleTime;
        }
    }