【Spring】複数データベースを参照すると、beanが複数存在しているというエラーが出ます

Question

前提・実現したいこと

Springで一つのデータベースから情報を持ってくることは出来ているのですが、複数のデータベースを指定するとエラーが出ます。
データベースの参照は、（データベース名）Config.javaというファイル内に記述しており、@Beanもこの中で記述しています。

@Configurationというアノテーションを付与しており、これを外せば付いている方のデータベースを参照して、外した方のファイルは読み込まれないようになります。
また、エラーは実際に処理させたいタイミングではなく、アプリケーションを起動する時に発生しています。

同じアプリケーション内で複数データベースを同時に参照したいため、@Configurationをどちらにも付与している状態で処理したいです。

@ConfigurationProperties(prefix = "config.hoge")というアノテーションを付与したり、
createDtaSourceで作成されるものの名称を変えてみるといった対処をしてみたのですが、解決できませんでした。
対処法をご存知の方いらっしゃいましたら、ご教示よろしくお願いいたします。

発生している問題・エラーメッセージ

Parameter 0 of constructor in com.example.sample.repository.hoge.HogeDaoImpl required a single bean, but 2 were found:
	- hogeConfig: defined in file [/Users/＊＊＊＊/sample/target/classes/com/example/sample/config/HogeConfig.class]
	- fugaConfig: defined in file [/Users/＊＊＊＊/sample/target/classes/com/example/sample/config/FugaConfig.class]


Action:

Consider marking one of the beans as @Primary, updating the consumer to accept multiple beans, or using @Qualifier to identify the bean that should be consumed

HogeConfig.class

package com.example.sample.config;
 
import javax.sql.DataSource;
import org.seasar.doma.jdbc.Config;
import org.seasar.doma.jdbc.JdbcLogger;
import org.seasar.doma.jdbc.SimpleDataSource;
import org.seasar.doma.jdbc.dialect.Dialect;
import org.seasar.doma.jdbc.dialect.MysqlDialect;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.jdbc.datasource.TransactionAwareDataSourceProxy;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.annotation.EnableTransactionManagement;
 
@Configuration
@EnableTransactionManagement
public class HogeConfig implements Config {
    private DataSource dataSource = createDataSource();

    private Dialect dialect = new MysqlDialect();

    @Override
    public DataSource getDataSource() {
        // TODO Auto-generated method stub
        return dataSource;
    }

    @Override
    public Dialect getDialect() {
        // TODO Auto-generated method stub
        return dialect;
    }

    @Bean
    public PlatformTransactionManager transactionManager() {
        return new DataSourceTransactionManager(dataSource);
    }

    protected static DataSource createDataSource() {
        SimpleDataSource dataSource = new SimpleDataSource();
        dataSource.setUrl("jdbc:postgresql://localhost:1234/hoge");
        dataSource.setUser("******");
        dataSource.setPassword("******");
        return new TransactionAwareDataSourceProxy(dataSource);
    }
}

FugaConfig.class

package com.example.sample.config;
 
import javax.sql.DataSource;
import org.seasar.doma.jdbc.Config;
import org.seasar.doma.jdbc.JdbcLogger;
import org.seasar.doma.jdbc.SimpleDataSource;
import org.seasar.doma.jdbc.dialect.Dialect;
import org.seasar.doma.jdbc.dialect.MysqlDialect;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import org.springframework.jdbc.datasource.TransactionAwareDataSourceProxy;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.annotation.EnableTransactionManagement;
 
@Configuration
@EnableTransactionManagement
public class FugaConfig implements Config {
    private DataSource dataSource = createDataSource();

    private Dialect dialect = new MysqlDialect();

    @Override
    public DataSource getDataSource() {
        // TODO Auto-generated method stub
        return dataSource;
    }

    @Override
    public Dialect getDialect() {
        // TODO Auto-generated method stub
        return dialect;
    }

    @Bean
    public PlatformTransactionManager transactionManager() {
        return new DataSourceTransactionManager(dataSource);
    }

    protected static DataSource createDataSource() {
        SimpleDataSource dataSource = new SimpleDataSource();
        dataSource.setUrl("jdbc:postgresql://localhost:1234/fuga");
        dataSource.setUser("******");
        dataSource.setPassword("******");
        return new TransactionAwareDataSourceProxy(dataSource);
    }
}

補足情報（FW/ツールのバージョンなど）

Spring Tool Suit 4
Postgres
Mac OS

Answer 1

複数のデータソースが DataSource の名前で重複してしまっているので、@Beanで名前を明示的につけてあげると解決するかと思います。

なお、よくひっかかる問題でもあるようです。
以下Qiitaを参考にしてください。

Spring Boot 1.5で複数データベースを扱うウェブアプリケーションのサンプル
SpringBootで2つのデータソースを使う(MyBatis)

Comments

[rinimaruranran]

ご回答ありがとうございます！

参考にしつつ下記のように変更してみたのですが、HogeDao.javaからHogeConfigを呼び出すと正常にhogeデータベースが呼ばれるのですが、FugaDao.javaからFugaConfigを呼び出そうとしても、@PrimaryのせいかHogeConfigが呼ばれてしまい、「FugaテーブルはHogeデータベースに存在しません」と怒られてしまいます。

おそらく@Primaryの影響でDAOで記述しているアノテーションが効いておらず、常に@PrimaryがついたConfigを参照してしまっていると思われます。

なぜDAOに記述してあるアノテーションが効いていないのか分かりますでしょうか。。
ご教示いただけると幸いです。

＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝

【HogeDao.java】
@ConfigAutowireable
@Dao(config = HogeConfig.class)
@Transactional(transactionManager = "txManager1")
public interface HogeDao {
:
}

＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝

【FugaDao.java】
@ConfigAutowireable
@Dao(config = FugaConfig.class)
@Transactional(transactionManager = "txManager2")
public interface FugaDao {
:
}

＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝

【HogeConfig.class】
@Configuration
@EnableTransactionManagement
@Primary
public class HogeConfig implements Config {
@Bean
@ConfigurationProperties(prefix = "spring.datasource")
public DataSourceProperties datasource2Properties() {
return new DataSourceProperties();
}

@Bean(name = {"datasource2"})
public DataSource datasource2(
@Qualifier("datasource2Properties") DataSourceProperties properties) {
return properties.initializeDataSourceBuilder().build();
}

@Bean(name = {"txManager2"})
public PlatformTransactionManager txManager2(DataSource dataSource2) {
return new DataSourceTransactionManager(dataSource2);
}

@Bean(name = {"sqlSessionFactory2"})
public SqlSessionFactory sqlSessionFactory(@Qualifier("datasource2") DataSource datasource2)
throws Exception {
SqlSessionFactoryBean sqlSessionFactory = new SqlSessionFactoryBean();
sqlSessionFactory.setDataSource(datasource2);
return (SqlSessionFactory) sqlSessionFactory.getObject();
}

private DataSource dataSource = createDataSource();

private Dialect dialect = new MysqlDialect();

@Override
public DataSource getDataSource() {
// TODO Auto-generated method stub
return dataSource;
}

@Override
public Dialect getDialect() {
// TODO Auto-generated method stub
return dialect;
}

@Bean
public PlatformTransactionManager transactionManager() {
return new DataSourceTransactionManager(dataSource);
}

protected static DataSource createDataSource() {
SimpleDataSource dataSource = new SimpleDataSource();
dataSource.setUrl("jdbc:postgresql://localhost:1234/hoge");
dataSource.setUser("******");
dataSource.setPassword("******");
return new TransactionAwareDataSourceProxy(dataSource);
}
}

＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝＝

【FugaConfig.class】
@Configuration
@EnableTransactionManagement
@Primary
public class FugaConfig implements Config {
@Bean
@ConfigurationProperties(prefix = "spring.datasource")
public DataSourceProperties datasource2Properties() {
return new DataSourceProperties();
}

@Bean(name = {"datasource2"})
public DataSource datasource2(
@Qualifier("datasource2Properties") DataSourceProperties properties) {
return properties.initializeDataSourceBuilder().build();
}

@Bean(name = {"txManager2"})
public PlatformTransactionManager txManager2(DataSource dataSource2) {
return new DataSourceTransactionManager(dataSource2);
}

@Bean(name = {"sqlSessionFactory2"})
public SqlSessionFactory sqlSessionFactory(@Qualifier("datasource2") DataSource datasource2)
throws Exception {
SqlSessionFactoryBean sqlSessionFactory = new SqlSessionFactoryBean();
sqlSessionFactory.setDataSource(datasource2);
return (SqlSessionFactory) sqlSessionFactory.getObject();
}

private DataSource dataSource = createDataSource();

private Dialect dialect = new MysqlDialect();

@Override
public DataSource getDataSource() {
// TODO Auto-generated method stub
return dataSource;
}

@Override
public Dialect getDialect() {
// TODO Auto-generated method stub
return dialect;
}

@Bean
public PlatformTransactionManager transactionManager() {
return new DataSourceTransactionManager(dataSource);
}

protected static DataSource createDataSource() {
SimpleDataSource dataSource = new SimpleDataSource();
dataSource.setUrl("jdbc:postgresql://localhost:1234/fuga");
dataSource.setUser("******");
dataSource.setPassword("******");
return new TransactionAwareDataSourceProxy(dataSource);
}
}

[A-pZ]

詳細なコードありがとうございました。内容を確認しますのでしばらくお待ちください。

[rinimaruranran]

お手数おかけして申し訳ございません。
よろしくお願い致します。

[rinimaruranran]

http://chonaso.hatenablog.com/entry/20160621/1466516585

こちらのサイトを参考に、Daoで@ConfigAutoWiredとしていた部分を、@AnnotateWithで書き換えることで解決することができました！

【HogeDao.java】
@AnnotateWith(annotations = {
@Annotation(target = AnnotationTarget.CLASS, type = Repository.class),
@Annotation(target = AnnotationTarget.CLASS, type = Component.class),
@Annotation(target = AnnotationTarget.CONSTRUCTOR, type = Autowired.class),
@Annotation(target = AnnotationTarget.CONSTRUCTOR_PARAMETER, type = Qualifier.class, elements = "\"HogeConfig\"")
})
@Dao
public interface HogeDao {
:
}

【DomaConfig.class】
@Configuration
@EnableTransactionManagement
@Primary
public class HogeConfig implements Config {

private DataSource dataSource = createDataSource();

private Dialect dialect = new MysqlDialect();

@Override
public DataSource getDataSource() {
return dataSource;
}

@Override
public Dialect getDialect() {
return dialect;
}

@Bean
public PlatformTransactionManager transactionManager() {
return new DataSourceTransactionManager(dataSource);
}

protected static DataSource createDataSource() {
SimpleDataSource dataSource = new SimpleDataSource();
dataSource.setUrl("jdbc:postgresql://localhost:1234/hoge");
dataSource.setUser("******");
dataSource.setPassword("******");
return new TransactionAwareDataSourceProxy(dataSource);
}
}

【HogeConfig.class】
@Configuration
@EnableTransactionManagement
@Component("HogeConfig")
public class HogeConfig implements Config {

private DataSource dataSource = createDataSource();

private Dialect dialect = new MysqlDialect();

@Override
public DataSource getDataSource() {
return dataSource;
}

@Override
public Dialect getDialect() {
return dialect;
}

@Bean
public PlatformTransactionManager transactionManager() {
return new DataSourceTransactionManager(dataSource);
}

protected static DataSource createDataSource() {
SimpleDataSource dataSource = new SimpleDataSource();
dataSource.setUrl("jdbc:postgresql://localhost:1234/hoge");
dataSource.setUser("******");
dataSource.setPassword("******");
return new TransactionAwareDataSourceProxy(dataSource);
}
}