{"id":1879,"date":"2017-11-28T06:59:27","date_gmt":"2017-11-28T06:59:27","guid":{"rendered":"http:\/\/www.msinterdev.org\/wp\/2017\/11\/28\/spring-boot-multiple-datasource\/"},"modified":"2017-11-28T06:59:27","modified_gmt":"2017-11-28T06:59:27","slug":"spring-boot-multiple-datasource","status":"publish","type":"post","link":"http:\/\/www.msinterdev.org\/wp\/2017\/11\/28\/spring-boot-multiple-datasource\/","title":{"rendered":"[Spring-Boot] Multiple Datasource"},"content":{"rendered":"

[DateSouece – 1]<\/strong>
@Configuration
@EnableJpaRepositories(
    basePackages = “com.haii.hmt.component.business.entity.admin”,
    entityManagerFactoryRef = “adminEntityManager”,
    transactionManagerRef = “adminTransactionManager”
)
public class AdminDataConfig
{
    @Inject
    private AdminDatasourceProp adminDatasourceProp;<\/p>\n

    @Inject
    private JpaHibernateProp jpaHibernateProp;<\/p>\n

    @Inject
    private HikariConnectionPoolProp hikariConnectionPoolProp;<\/p>\n

    @Bean
    @Primary
    public LocalContainerEntityManagerFactoryBean adminEntityManager() {
        LocalContainerEntityManagerFactoryBean em
                = new LocalContainerEntityManagerFactoryBean();
        em.setDataSource(adminDataSource());
        em.setPackagesToScan(
                new String[] { “com.hi.entity” });<\/p>\n

        HibernateJpaVendorAdapter vendorAdapter
                = new HibernateJpaVendorAdapter();
        em.setJpaVendorAdapter(vendorAdapter);
        HashMap<String, Object> properties = new HashMap<>();
        properties.put(“hibernate.hbm2ddl.auto”, this.jpaHibernateProp.getDdlAauto() );
        properties.put(“hibernate.dialect”, this.jpaHibernateProp.getDialect() );
        em.setJpaPropertyMap(properties);<\/p>\n

        return em;
    }<\/p>\n

    @Primary
    @Bean
    public DataSource adminDataSource() {
        HikariDataSource ds = new HikariDataSource();
        ds.setDataSourceProperties(this.getProperties());<\/p>\n

        ds.setPoolName( this.adminDatasourceProp.getPoolName());
        \/\/ds.setConnectionTestQuery(datasourceProperties.getConnectionTes\\
          \/\/      tQuery());
        ds.setDataSourceClassName( this.adminDatasourceProp.getDataSourceClassName());
        \/\/ds.setIdleTimeout(datasourceProperties.getIdleTimeout());
        ds.setMaximumPoolSize( this.hikariConnectionPoolProp.getMaximumPoolSize() );
        return ds;
    }<\/p>\n

    private Properties getProperties()
    {
        Properties prop = new Properties();
        prop.put(“serverName”, this.adminDatasourceProp.getServerName() );
        prop.put(“databaseName”, this.adminDatasourceProp.getDatabaseName());
        prop.put(“user”, this.adminDatasourceProp.getUsername());
        prop.put(“password”, this.adminDatasourceProp.getPassword());<\/p>\n

        prop.put(“cachePrepStmts”, “true”);
        prop.put(“prepStmtCacheSize”, “250”);
        prop.put(“prepStmtCacheSqlLimit”, “2048”);
        prop.put(“encoding”, “UTF-8”);
        return prop;
    }<\/p>\n

    @Primary
    @Bean
    public PlatformTransactionManager adminTransactionManager() {
        JpaTransactionManager transactionManager
                = new JpaTransactionManager();
        transactionManager.setEntityManagerFactory(
                adminEntityManager().getObject());
        return transactionManager;
    }
}<\/p>\n

[DataSource – 2]<\/strong><\/p>\n

@Configuration
@EnableJpaRepositories(
        basePackages = “com.hello.entity”,
        entityManagerFactoryRef = “userEntityManager”,
        transactionManagerRef = “userTransactionManager”
)
public class SensorDataConfig
{
    @Inject
    private UserDatasourceProp userDatasourceProp;<\/p>\n

    @Inject
    private JpaHibernateProp jpaHibernateProp;<\/p>\n

    @Inject
    private HikariConnectionPoolProp hikariConnectionPoolProp;<\/p>\n

    @Bean
    public LocalContainerEntityManagerFactoryBean  userEntityManager() {
        LocalContainerEntityManagerFactoryBean em
                = new LocalContainerEntityManagerFactoryBean();
        em.setDataSource(userDataSource());
        em.setPackagesToScan(
                new String[] { “com.haii.hmt.component.business.entity.sensor” });<\/p>\n

        HibernateJpaVendorAdapter vendorAdapter
                = new HibernateJpaVendorAdapter();
        em.setJpaVendorAdapter(vendorAdapter);
        HashMap<String, Object> properties = new HashMap<>();
        properties.put(“hibernate.hbm2ddl.auto”, this.jpaHibernateProp.getDdlAauto() );
        properties.put(“hibernate.dialect”, this.jpaHibernateProp.getDialect() );
        em.setJpaPropertyMap(properties);<\/p>\n

        return em;
    }<\/p>\n

    public DataSource userDataSource() {
        HikariDataSource ds = new HikariDataSource();
        ds.setDataSourceProperties(this.getProperties());<\/p>\n

        ds.setPoolName( this.userDatasourceProp.getPoolName());
        \/\/ds.setConnectionTestQuery(datasourceProperties.getConnectionTes\\
        \/\/      tQuery());
        ds.setDataSourceClassName( this.userDatasourceProp.getDataSourceClassName());
        \/\/ds.setIdleTimeout(datasourceProperties.getIdleTimeout());
        ds.setMaximumPoolSize( this.hikariConnectionPoolProp.getMaximumPoolSize() );
        return ds;
    }<\/p>\n

    private Properties getProperties()
    {
        Properties prop = new Properties();
        prop.put(“serverName”, this.userDatasourceProp.getServerName() );
        prop.put(“databaseName”, this.userDatasourceProp.getDatabaseName());
        prop.put(“user”, this.userDatasourceProp.getUsername());
        prop.put(“password”, this.userDatasourceProp.getPassword());<\/p>\n

        prop.put(“cachePrepStmts”, “true”);
        prop.put(“prepStmtCacheSize”, “250”);
        prop.put(“prepStmtCacheSqlLimit”, “2048”);
        prop.put(“encoding”, “UTF-8”);
        return prop;
    }<\/p>\n

    @Bean
    public PlatformTransactionManager userTransactionManager() {
        JpaTransactionManager transactionManager
                = new JpaTransactionManager();
        transactionManager.setEntityManagerFactory(
                userEntityManager().getObject());
        return transactionManager;
    }<\/p>\n

}]<\/p>\n

[Apply Transactional ]<\/strong><\/p>\n

<\/code>@Transactional<\/code>(<\/code>\"userTransactionManager\"<\/code>)<\/code><\/p>\n

    <\/code>public<\/code> void<\/code> whenCreatingUsersWithSameEmail_thenRollback() {<\/code><\/div>\n
        <\/code>User user1 = <\/code>new<\/code> User();<\/code><\/div>\n
        <\/code>user1.setName(<\/code>\"John\"<\/code>);<\/code><\/div>\n
        <\/code>user1.setEmail(<\/code>\"john@test.com\"<\/code>);<\/code><\/div>\n
        <\/code>user1.setAge(<\/code>20<\/code>);<\/code><\/div>\n
        <\/code>user1 = userRepository.save(user1);<\/code><\/div>\n
        <\/code>assertNotNull(userRepository.findOne(user1.getId()));<\/code><\/div>\n
 <\/div>\n
        <\/code>User user2 = <\/code>new<\/code> User();<\/code><\/div>\n
        <\/code>user2.setName(<\/code>\"Tom\"<\/code>);<\/code><\/div>\n
        <\/code>user2.setEmail(<\/code>\"john@test.com\"<\/code>);<\/code><\/div>\n
        <\/code>user2.setAge(<\/code>10<\/code>);<\/code><\/div>\n
        <\/code>try<\/code> {<\/code><\/div>\n
            <\/code>user2 = userRepository.save(user2);<\/code><\/div>\n
        <\/code>} <\/code>catch<\/code> (DataIntegrityViolationException e) {<\/code><\/div>\n
        <\/code>}<\/code><\/div>\n
 <\/div>\n
        <\/code>assertNull(userRepository.findOne(user2.getId()));<\/code><\/div>\n
    <\/code>}<\/code><\/div>\n
 <\/div>\n","protected":false},"excerpt":{"rendered":"

[DateSouece – 1]@Configuration@EnableJpaRepositories(    basePackages = “com.haii.hmt.component.business.entity.admin”,    entityManagerFactoryRef = “adminEntityManager”,    transactionManagerRef = “adminTransactionManager”)public class AdminDataConfig{    @Inject    private AdminDatasourceProp adminDatasourceProp;     @Inject    private JpaHibernateProp jpaHibernateProp;     @Inject    private HikariConnectionPoolProp hikariConnectionPoolProp;     @Bean    @Primary    public LocalContainerEntityManagerFactoryBean adminEntityManager() {        LocalContainerEntityManagerFactoryBean em                = new LocalContainerEntityManagerFactoryBean();        em.setDataSource(adminDataSource());        em.setPackagesToScan(                new String[] { “com.hi.entity” });         HibernateJpaVendorAdapter vendorAdapter                = new HibernateJpaVendorAdapter();        em.setJpaVendorAdapter(vendorAdapter);        HashMap<String, […]<\/p>\n","protected":false},"author":1,"featured_media":0,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"footnotes":""},"categories":[163],"tags":[],"class_list":["post-1879","post","type-post","status-publish","format-standard","hentry","category-about-knowledge-programs_java"],"_links":{"self":[{"href":"http:\/\/www.msinterdev.org\/wp\/wp-json\/wp\/v2\/posts\/1879","targetHints":{"allow":["GET"]}}],"collection":[{"href":"http:\/\/www.msinterdev.org\/wp\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"http:\/\/www.msinterdev.org\/wp\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"http:\/\/www.msinterdev.org\/wp\/wp-json\/wp\/v2\/users\/1"}],"replies":[{"embeddable":true,"href":"http:\/\/www.msinterdev.org\/wp\/wp-json\/wp\/v2\/comments?post=1879"}],"version-history":[{"count":0,"href":"http:\/\/www.msinterdev.org\/wp\/wp-json\/wp\/v2\/posts\/1879\/revisions"}],"wp:attachment":[{"href":"http:\/\/www.msinterdev.org\/wp\/wp-json\/wp\/v2\/media?parent=1879"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"http:\/\/www.msinterdev.org\/wp\/wp-json\/wp\/v2\/categories?post=1879"},{"taxonomy":"post_tag","embeddable":true,"href":"http:\/\/www.msinterdev.org\/wp\/wp-json\/wp\/v2\/tags?post=1879"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}