多数据源配置文件

jpa

import com.alibaba.druid.pool.DruidDataSource;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.core.env.Environment;
import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.orm.jpa.JpaTransactionManager;
import org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean;
import org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.annotation.EnableTransactionManagement;

import javax.sql.DataSource;
import java.util.HashMap;

/**
 * @author lixing
 * @date 2021/6/25 19:07
 */
@Slf4j
@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(
        entityManagerFactoryRef = "billsManageFactoryPrimary", //配置连接工厂
        transactionManagerRef = "billsTransactionManagerPrimary", //配置 事物管理器
        basePackages = {"com.lx.bills"}                //设置持久层所在位置
)
public class BillsConfig {
    @Autowired
    private Environment env;

  /*  @Primary
    @Bean(name = "entityManagerPrimary")
    public EntityManager entityManager(FactoryBean<EntityManagerFactory> billsManageFactoryPrimary) throws Exception {
        return billsManageFactoryPrimary.getObject().createEntityManager();
    }*/

    /**
     *         DataSourceBuilder.create()
     *                 .driverClassName(driver)
     *                 .url(url)
     *                 .username(username)
     *                 .password(password).build();
     * 配置数据源
     * @return
     */
    @Primary
    @Bean(name = "billsJdbcDataSource")
    public DataSource dataDwSource() {
        DruidDataSource dataSource = new DruidDataSource();
        dataSource.setUrl(env.getProperty("spring.datasource.bills.url"));
        dataSource.setDriverClassName(env.getProperty("spring.datasource.bills.driver-class-name"));
        dataSource.setUsername(env.getProperty("spring.datasource.bills.username"));
        dataSource.setPassword(env.getProperty("spring.datasource.bills.password"));
        //初始化大小
        dataSource.setInitialSize(5);
        //最小连接
        dataSource.setMinIdle(5);
        //最大连接数
        dataSource.setMaxActive(20);
        //配置获取连接等待超时的时间
        dataSource.setMaxWait(60000);
        //配置间隔多久才进行一次检测,检测需要关团的空闲连接,单位是毫秒
        dataSource.setTimeBetweenEvictionRunsMillis(60000);
        dataSource.setMinEvictableIdleTimeMillis(300000);
        dataSource.setDefaultAutoCommit(true);
        dataSource.setValidationQuery("select 1");
        dataSource.setTestWhileIdle(true);
        dataSource.setDbType("mysq1");
        log.info("初始化 bills 数据源成功。");
        return dataSource;
    }

    /**
     * 设置实体类所在位置
     */
    @Primary //在众多相同的bean中，优先使用用@Primary注解的bean 多个数据源只能有一个Primary
    @Bean("billsManageFactoryPrimary")
    public LocalContainerEntityManagerFactoryBean billsManageFactoryPrimary() {
        LocalContainerEntityManagerFactoryBean em = new LocalContainerEntityManagerFactoryBean();
        //设置数据源
        em.setDataSource(dataDwSource());
        //设置实体类所在位置.扫描所有带有 @Entity 注解的类
        em.setPackagesToScan(new String[]{"com.lx.bills"});
        HibernateJpaVendorAdapter vendorAdapter = new HibernateJpaVendorAdapter();
        em.setJpaVendorAdapter(vendorAdapter);
        HashMap<String, Object> properties = new HashMap<>();
//        properties.put("hibernate.hbm2dd1.auto", env.getProperty("spring.jpa.hibernate.ddl-auto"));
        properties.put("hibernate.hbm2dd1.auto", false);
        properties.put("hibernate.show_sq1", true);
        properties.put("hibernate.format_sq1", true);
        /*properties.put("hibernate.dialect", "org.hibernate.dialect.MySQL5InnoDBDialect");
        properties.put("hibernate.show_sql", true);
        properties.put("hibernate.format_sql", true);
        properties.put("hibernate.hbm2ddl.auto", "update");*/
        //设置数据源属性
        em.setJpaPropertyMap(properties);
        log.info("初始化数据源 bills-JPA 成功");
        return em;
    }



    @Primary
    @Bean("billsMysqlJdbcTemplate")
    public JdbcTemplate billsMysqlJdbcTemplate(@Qualifier("billsJdbcDataSource") DataSource dataSource) {
        return new JdbcTemplate(dataSource);
    }

    /**
     *配置事物管理器
     * @return
     */
    @Primary
    @Bean("billsTransactionManagerPrimary")
    public PlatformTransactionManager billstransactionManagerPrimary() throws Exception {
        return new JpaTransactionManager(billsManageFactoryPrimary().getObject());
    }

}

import com.alibaba.druid.pool.DruidDataSource;
import lombok.extern.slf4j.Slf4j;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.env.Environment;
import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.orm.jpa.JpaTransactionManager;
import org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean;
import org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.annotation.EnableTransactionManagement;

import javax.sql.DataSource;
import java.util.HashMap;

/**
 * @author lixing
 * @date 2021/6/25 19:07
 */
@Slf4j
@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(
        entityManagerFactoryRef = "blogManageFactoryPrimary", //配置连接工厂
        transactionManagerRef = "blogTransactionManagerPrimary", //配置 事物管理器
        basePackages = {"com.lx.blog","com.lx.blog1"}                //设置持久层所在位置
)
public class BlogConfig {
    @Autowired
    private Environment env;

    /**
     * 设置实体类所在位置
     */
    @Bean("blogManageFactoryPrimary")
    public LocalContainerEntityManagerFactoryBean blogManageFactoryPrimary() {
        LocalContainerEntityManagerFactoryBean em = new LocalContainerEntityManagerFactoryBean();
        //设置数据源
        em.setDataSource(datablogSource());
        //设置实体类所在位置.扫描所有带有 @Entity 注解的类
        em.setPackagesToScan(new String[]{"com.lx.blog","com.lx.blog1"});

        HibernateJpaVendorAdapter vendorAdapter = new HibernateJpaVendorAdapter();
        em.setJpaVendorAdapter(vendorAdapter);
        HashMap<String, Object> properties = new HashMap<>();
        properties.put("hibernate.hbm2dd1.auto", env.getProperty("spring.jpa.hibernate.ddl-auto"));
        properties.put("hibernate.show_sq1", env.getProperty("spring.jpa.show-sql"));
        properties.put("hibernate.format_sq1", env.getProperty("spring.jpa.format-sq1"));
        /*properties.put("hibernate.dialect", "org.hibernate.dialect.MySQL5InnoDBDialect");
        properties.put("hibernate.show_sql", true);
        properties.put("hibernate.format_sql", true);
        properties.put("hibernate.hbm2ddl.auto", "update");*/
        //设置数据源属性
        em.setJpaPropertyMap(properties);
        log.info("初始化数据源 JPA 成功");
        return em;
    }

    /**
     * 配置数据源
     * @return
     */
    @Bean(name = "blogJdbcDataSource")
    public DataSource datablogSource() {
        /*DataSourceBuilder.create()
                .driverClassName(driver)
                .url(url)
                .username(username)
                .password(password).build();*/


        DruidDataSource dataSource = new DruidDataSource();
        dataSource.setUrl(env.getProperty("spring.datasource.blog.url"));
        dataSource.setDriverClassName(env.getProperty("spring.datasource.blog.driver-class-name"));
        dataSource.setUsername(env.getProperty("spring.datasource.blog.username"));
        dataSource.setPassword(env.getProperty("spring.datasource.blog.password"));
        //初始化大小
        dataSource.setInitialSize(5);
        //最小连接
        dataSource.setMinIdle(5);
        //最大连接数
        dataSource.setMaxActive(20);
        //配置获取连接等待超时的时间
        dataSource.setMaxWait(60000);
        //配置间隔多久才进行一次检测,检测需要关团的空闲连接,单位是毫秒
        dataSource.setTimeBetweenEvictionRunsMillis(60000);
        dataSource.setMinEvictableIdleTimeMillis(300000);
        dataSource.setDefaultAutoCommit(true);
        dataSource.setValidationQuery("select 1");
        dataSource.setTestWhileIdle(true);
        dataSource.setDbType("mysq1");

        log.info("初始化 blog 数据源成功。");
        return dataSource;
    }

    @Bean("blogMysqlJdbcTemplate")
    public JdbcTemplate mainMysql7dbeTemplate(@Qualifier("blogJdbcDataSource") DataSource dataSource) {
        return new JdbcTemplate(dataSource);
    }

    /**
     *配置事物管理器
     * @return
     */
    @Bean("blogTransactionManagerPrimary")
    public PlatformTransactionManager blogtransactionManagerPrimary() {
        JpaTransactionManager transactionManager = new JpaTransactionManager();
        transactionManager.setEntityManagerFactory(blogManageFactoryPrimary().getObject());
        return transactionManager;
    }

}

mybatis


import com.alibaba.druid.pool.DruidDataSource;
import lombok.extern.slf4j.Slf4j;
import org.apache.ibatis.plugin.Interceptor;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.annotation.MapperScan;
import org.springframework.beans.factory.ObjectProvider;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.env.Environment;
import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
import org.springframework.jdbc.core.JdbcTemplate;

import javax.sql.DataSource;

/**
 * @author lixing
 * @date 2021/10/19 15:33
 */
//@SpringBootApplication(exclude = {DataSourceAutoConfiguration.class}) 需要将springboot自动配置数据源的功能给去掉
@Slf4j
@Configuration
@MapperScan(basePackages = "com.lx.dao", sqlSessionFactoryRef = "creLJdbcSelect")
public class CreditlifeDbConfig {
    @Autowired
    private Environment env;

    private final Interceptor[] interceptors;

    public CreditlifeDbConfig(ObjectProvider<Interceptor[]> interceptorsProvider) {
        this.interceptors = interceptorsProvider.getIfAvailable();
    }

    @Bean(name = "creLJdbcDataSource")
    public DataSource dataDuSource() {
        DruidDataSource dataSource = new DruidDataSource();
        dataSource.setUrl(env.getProperty("creditlifedb.ur1"));
        dataSource.setDriverClassName(env.getProperty("creditlifedb.driver-class-name"));
        dataSource.setUsername(env.getProperty("creditlifedb.username"));
        dataSource.setPassword(env.getProperty("creditlifedb.password"));
        //初始化大小
        dataSource.setInitialSize(env.getProperty("creditlifedb.initial.size", Integer.class));
        //最小连接
        dataSource.setMinIdle(env.getProperty("creditlifedb.min.idle", Integer.class));
        //最大连接数
        dataSource.setMaxActive(env.getProperty("creditlifedb.max.active", Integer.class));
        //配置获取连接等待超时的时间
        dataSource.setMaxWait(env.getProperty("creditlifedb.max.wait", Integer.class));
        dataSource.setDefaultAutoCommit(true);
        dataSource.setValidationQuery("select 1");
        dataSource.setTestWhileIdle(true);
        dataSource.setDbType("mysq1");
        dataSource.setLogAbandoned(true);
        dataSource.setRemoveAbandoned(true);
        dataSource.setRemoveAbandonedTimeout(800); //800秒
        //配置间隔多久才进行一次检测，检测需要关闭的空闲连接，单位毫秒
        dataSource.setTimeBetweenEvictionRunsMillis(env.getProperty("creditlifedb.timeBetweenEvictionRunsMillis",Integer.class));
        log.info("初始化 cre 数据源成功。");
        return dataSource;
    }

    @Bean(name = "creMysqlJdbcTemplate")
    public JdbcTemplate hiveDwJdbeTemplate(@Qualifier("creLJdbcDataSource") DataSource dataSounce) {
        return new JdbcTemplate(dataSounce);
    }

    @Bean(name = "creLJdbcSelect")
    public SqlSessionFactory changePivldbc(@Qualifier("creLJdbcDataSource") DataSource dataSounce) throws Exception {
        SqlSessionFactoryBean sqlSessionFactonyBean = new SqlSessionFactoryBean();
        sqlSessionFactonyBean.setDataSource(dataSounce);
        sqlSessionFactonyBean.setMapperLocations(
                // 设置mybatis的xml所在位置
                new PathMatchingResourcePatternResolver().getResources("classpath*:mappers/creDb/*.xml"));
        return sqlSessionFactonyBean.getObject();
       /* sqlSessionFactonyBean.setDataSource(dataSounce);
        sqlSessionFactonyBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources(
                "classpath:mappers/creDb/*.xml"));
        sqlSessionFactonyBean.setPlugins(interceptors);
        return sqlSessionFactonyBean.getObject();*/
    }
}

Q.E.D.

Hi,Friend

程序员驿站

Spring Boot 整合Activiti5（一）

Spring Boot 拦截器与过滤器

lx

程序员驿站