springboot配置主副双数据库

淩亂°似流年 2022-05-15 08:21 261阅读 0赞

第一步：导入所需要的jar包

<dependency>
                <groupId>com.oracle</groupId>
                <artifactId>ojdbc8</artifactId>
                <version>12.1.0.2</version>
            </dependency>

第二步：配置application.properties文件

# 数据库访问配置
    # 主数据源，默认的
    spring.datasource.type=com.alibaba.druid.pool.DruidDataSource
    spring.datasource.driver-class-name=oracle.jdbc.driver.OracleDriver
    #测试
    spring.datasource.url=数据库连接
    spring.datasource.username=admin
    spring.datasource.password=123456
    # pmsdev数据源
    pms.datasource.type=com.alibaba.druid.pool.DruidDataSource
    pms.datasource.driver-class-name=oracle.jdbc.driver.OracleDriver
    pms.datasource.url=链接地址
    pms.datasource.username=admin
    pms.datasource.password=123456

第三步：config配置

/**
     * @Description:主数据库
     */
    @Configuration
    @MapperScan(basePackages = MainDataSourceConfig.PACKAGE, sqlSessionFactoryRef = "mainSqlSessionFactory")
    public class MainDataSourceConfig {
        static final String PACKAGE = "com.mmm.dao.main";
    
        @Value("${spring.datasource.driver-class-name}")
        private String DriverClassName;
        @Value("${spring.datasource.url}")
        private String dbUrl;
        @Value("${spring.datasource.username}")
        private String dbUser;
        @Value("${spring.datasource.password}")
        private String dbPassword;
    
        @Bean(name = "mainDataSource")
        @Primary
        public DataSource mainDataSource() {
            DruidDataSource dataSource = new DruidDataSource();
            dataSource.setDriverClassName(DriverClassName);
            dataSource.setUrl(dbUrl);
            dataSource.setUsername(dbUser);
            dataSource.setPassword(dbPassword);
            dataSource.setTestWhileIdle(true);
            dataSource.setValidationQuery("select count(1) from dual");
            return dataSource;
        }
    
        @Bean(name = "mainTransactionManager")
        @Primary
        public DataSourceTransactionManager mainTransactionManager() {
            return new DataSourceTransactionManager(mainDataSource());
        }
    
        @Bean(name = "mainSqlSessionFactory")
        @Primary
        public SqlSessionFactory mainSqlSessionFactory(@Qualifier("mainDataSource") DataSource mainDataSource) throws Exception {
            final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
            sessionFactory.setDataSource(mainDataSource);
            //指定mapper xml目录
            ResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();
            sessionFactory.setMapperLocations(resolver.getResources("classpath*:mapper/main/*.xml"));
            sessionFactory.setTypeAliasesPackage("com.mmm.model");
            sessionFactory.setTypeAliasesPackage("org.apache.ibatis.type.JdbcType");
            org.apache.ibatis.session.Configuration configuration =new org.apache.ibatis.session.Configuration();
            //当返回数据类型为map，设置callSettersOnNulls会把值为null的key也返回
            configuration.setCallSettersOnNulls(true);
            //设置但JDBC类型为空时,某些驱动程序 要指定值,default:OTHER，插入空值时不需要指定类型
            configuration.setJdbcTypeForNull(null);
            sessionFactory.setConfiguration(configuration);
            return sessionFactory.getObject();
        }
    }

/**
     * @Description:pms数据库连接
     */
    @Configuration
    @MapperScan(basePackages = PmsDataSourceConfig.PACKAGE, sqlSessionFactoryRef = "pmsSqlSessionFactory")
    public class PmsDataSourceConfig {
        static final String PACKAGE = "com.mmm.dao.pms";
    
        @Value("${pms.datasource.driver-class-name}")
        private String DriverClassName;
        @Value("${pms.datasource.url}")
        private String dbUrl;
        @Value("${pms.datasource.username}")
        private String dbUser;
        @Value("${pms.datasource.password}")
        private String dbPassword;
    
        @Bean(name = "pmsDataSource")
        public DataSource pmsDataSource() {
            DruidDataSource dataSource = new DruidDataSource();
            dataSource.setDriverClassName(DriverClassName);
            dataSource.setUrl(dbUrl);
            dataSource.setUsername(dbUser);
            dataSource.setPassword(dbPassword);
            return dataSource;
        }
    
        @Bean(name = "pmsTransactionManager")
        public DataSourceTransactionManager pmsTransactionManager() {
            return new DataSourceTransactionManager(pmsDataSource());
        }
    
        @Bean(name = "pmsSqlSessionFactory")
        public SqlSessionFactory pmsSqlSessionFactory(@Qualifier("pmsDataSource") DataSource pmsDataSource) throws Exception {
            final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
            sessionFactory.setDataSource(pmsDataSource);
            //指定mapper xml目录
            ResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();
            sessionFactory.setMapperLocations(resolver.getResources("classpath*:mapper/pms/*.xml"));
            sessionFactory.setTypeAliasesPackage("com.mmm.model");
            org.apache.ibatis.session.Configuration configuration =new org.apache.ibatis.session.Configuration();
            //当返回数据类型为map，设置callSettersOnNulls会把值为null的key也返回
            configuration.setCallSettersOnNulls(true);
            //设置但JDBC类型为空时,某些驱动程序 要指定值,default:OTHER，插入空值时不需要指定类型
            configuration.setJdbcTypeForNull(null);
            sessionFactory.setConfiguration(configuration);;
            return sessionFactory.getObject();
        }
    }