兩個數(shù)據(jù)庫實例,一個負責讀,一個負責寫。
datasource-reader: type: com.alibaba.druid.pool.DruidDataSource url: jdbc:mysql://192.168.43.61:3306/test?useUnicode=true&characterEncoding=utf8&autoReconnect=true&useSSL=false username: icbc password: icbc driver-class-name: com.mysql.jdbc.Driver continue-on-error: false sql-script-encoding: UTF-8datasource-writer: type: com.alibaba.druid.pool.DruidDataSource url: jdbc:mysql://192.168.43.61:3306/hdfs?useUnicode=true&characterEncoding=utf8&autoReconnect=true&useSSL=false username: icbc password: icbc driver-class-name: com.mysql.jdbc.Driver continue-on-error: false sql-script-encoding: UTF-8
讀數(shù)據(jù)庫配置
@Configuration@EnableTransactionManagement@EnableJpaRepositories(entityManagerFactoryRef = "entityManagerFactoryPrimary", transactionManagerRef = "transactionManagerPrimary", basePackages = { "cn.cib.repository.read"})public class RepositoryPrimaryConfig { @Autowired @Qualifier("r_ds") private DataSource r_ds; @Bean(destroyMethod = "", name = "entityManagerPrimary") @Primary public EntityManager entityManager() { return entityManagerFactoryPrimary().getObject().createEntityManager(); } @Bean(destroyMethod = "", name = "entityManagerFactoryPrimary") @Primary public LocalContainerEntityManagerFactoryBean entityManagerFactoryPrimary() { HibernateJpaVendorAdapter jpaVendorAdapter = new HibernateJpaVendorAdapter(); LocalContainerEntityManagerFactoryBean factoryBean = new LocalContainerEntityManagerFactoryBean(); factoryBean.setDataSource(r_ds); factoryBean.setJpaVendorAdapter(jpaVendorAdapter); factoryBean.setJpaProperties(HibernatePropertiesBuilder.hibernateProperties()); factoryBean.setPackagesToScan("cn.cib.repository.read", "cn.cib.entity.read"); factoryBean.setPersistenceUnitName("read"); return factoryBean; } @Bean(destroyMethod = "", name = "transactionManagerPrimary") @Primary PlatformTransactionManager transactionManagerPrimary() { return new JpaTransactionManager(entityManagerFactoryPrimary().getObject()); }}
寫數(shù)據(jù)庫配置
@Configuration@EnableTransactionManagement@EnableJpaRepositories(entityManagerFactoryRef = "entityManagerFactorySecondary", transactionManagerRef = "transactionManagerSecondary", basePackages = { "cn.cib.repository.write"})public class RepositorySecondaryConfig { @Autowired @Qualifier("w_ds") private DataSource w_ds; @Bean(destroyMethod = "", name = "entityManagerSecondary") public EntityManager entityManager() { return entityManagerFactorySecondary().getObject().createEntityManager(); } @Bean(destroyMethod = "", name = "entityManagerFactorySecondary") public LocalContainerEntityManagerFactoryBean entityManagerFactorySecondary() { HibernateJpaVendorAdapter jpaVendorAdapter = new HibernateJpaVendorAdapter(); LocalContainerEntityManagerFactoryBean factoryBean = new LocalContainerEntityManagerFactoryBean(); factoryBean.setDataSource(w_ds); factoryBean.setJpaVendorAdapter(jpaVendorAdapter); factoryBean.setJpaProperties(HibernatePropertiesBuilder.hibernateProperties()); factoryBean.setPackagesToScan("cn.cib.repository.write","cn.cib.entity.write"); factoryBean.setPersistenceUnitName("write"); return factoryBean; } @Bean(destroyMethod = "", name = "transactionManagerSecondary") PlatformTransactionManager transactionManagerSecondary() { return new JpaTransactionManager(entityManagerFactorySecondary().getObject()); }}
Hibernate相關(guān)屬性配置
public class HibernatePropertiesBuilder { public static Properties hibernateProperties() { final Properties hibernateProperties = new Properties(); hibernateProperties.setProperty("hibernate.dialect", "org.hibernate.dialect.MySQL5Dialect"); hibernateProperties.setProperty("hibernate.hbm2ddl.auto", "update"); hibernateProperties.setProperty("hibernate.show_sql", "true"); hibernateProperties.setProperty("hibernate.format_sql", "true"); return hibernateProperties; }}
總結(jié)
以上所述是小編給大家介紹的Spring Boot 2.0多數(shù)據(jù)源配置方法實例詳解,希望對大家有所幫助,如果大家有任何疑問請給我留言,小編會及時回復大家的。在此也非常感謝大家對VeVb武林網(wǎng)網(wǎng)站的支持!
新聞熱點
疑難解答
圖片精選