SpringBoot OracleとPostgresに接続したい

Question

検索するテーブルによって、OracleとPostgresを切り替えたいのですが、方法が分からず困っています。
現在、以下のような設定をしていますが、postgresのテーブル参照時に
Oracleに接続しに行ってしまい、結果、エラーが発生する状況です。

application.properties

#DB(postgre)
spring.database.driverClassName=org.postgresql.Driver
spring.datasource.url=jdbc:postgresql://localhost:5432/aaa
spring.datasource.username=aaa
spring.datasource.password=aaa

#DB(oracle)
spring.database.driverClassName=oracle.jdbc.driver.OracleDriver
spring.datasource.url=jdbc:oracle:thin:@aaa:1521/aa
spring.datasource.username=aaa
spring.datasource.password=aaa

pom.xml

		<!-- postgres -->
		<dependency>
			<groupId>org.postgresql</groupId>
			<artifactId>postgresql</artifactId>
			<version>9.3-1101-jdbc3</version>
		</dependency>
		<!-- oracle -->
		<dependency>
			<groupId>com.oracle</groupId>
			<artifactId>ojdbc6</artifactId>
			<version>11.2.0</version>
		</dependency>

エラーログ

java.sql.SQLSyntaxErrorException: ORA-01747: user.table.column、table.columnまたは列指定が無効です

	at oracle.jdbc.driver.SQLStateMapping.newSQLException(SQLStateMapping.java:91)
	at oracle.jdbc.driver.DatabaseError.newSQLException(DatabaseError.java:133)
	at oracle.jdbc.driver.DatabaseError.throwSqlException(DatabaseError.java:206)
	at oracle.jdbc.driver.T4CTTIoer.processError(T4CTTIoer.java:455)
	at oracle.jdbc.driver.T4CTTIoer.processError(T4CTTIoer.java:413)
	at oracle.jdbc.driver.T4C8Oall.receive(T4C8Oall.java:1034)
	at oracle.jdbc.driver.T4CPreparedStatement.doOall8(T4CPreparedStatement.java:194)
	at oracle.jdbc.driver.T4CPreparedStatement.executeForDescribe(T4CPreparedStatement.java:791)
	at oracle.jdbc.driver.T4CPreparedStatement.executeMaybeDescribe(T4CPreparedStatement.java:866)
	at oracle.jdbc.driver.OracleStatement.doExecuteWithTimeout(OracleStatement.java:1186)
	at oracle.jdbc.driver.OraclePreparedStatement.executeInternal(OraclePreparedStatement.java:3387)
	at oracle.jdbc.driver.OraclePreparedStatement.executeQuery(OraclePreparedStatement.java:3431)
	at oracle.jdbc.driver.OraclePreparedStatementWrapper.executeQuery(OraclePreparedStatementWrapper.java:1491)
	at org.hibernate.engine.jdbc.internal.ResultSetReturnImpl.extract(ResultSetReturnImpl.java:82)

お分かりになる方がいらっしゃいましたら、ご教授よろしくお願い致します。

Answer 1

以下のサイトを参考に、できるようになりました。
http://m-namiki.hatenablog.jp/entries/2011/11/24

application.properties （使いません）

#DB(postgre)
#spring.database.driverClassName=org.postgresql.Driver
#spring.datasource.url=jdbc:postgresql://localhost:5432/aaa
#spring.datasource.username=aaa
#spring.datasource.password=aaa

#DB(oracle)
#spring.database.driverClassName=oracle.jdbc.driver.OracleDriver
#spring.datasource.url=jdbc:oracle:thin:@aaa:1521/aa
#spring.datasource.username=aaa
#spring.datasource.password=aaa

pom.xml （変更なし）

以下のクラスを新たに定義

/*****************/
/** 接続先の定義 */
/*****************/
public enum SchemaType {
	/** Oracle接続用のデータソースキー */
	ORACLE,
	/** PostgreSql接続用のデータソースキー */
	POSTGRES
}

/***************************/
/** 接続先を保持するクラス */
/***************************/
public class SchemaContextHolder {
    private static ThreadLocal<SchemaType> contextHolder = new ThreadLocal<SchemaType>();
	/**
	 * スレッドローカルに対象スキーマを設定します。
	 *
	 * @param type
	 *            対象スキーマの種類
	 */
	public static void setSchemaType(SchemaType type) {
		contextHolder.set(type);
	}
	/**
	 * 対象スキーマを返却します。
	 *
	 * @return 対象スキーマ
	 */
	public static SchemaType getSchemaType() {
		return contextHolder.get();
	}
	/**
	 * スレッドローカルを空にします。
	 */
	public static void clear() {
		contextHolder.remove();
	}
}

/**********************************/
/** データソースを返却するクラス */
/**********************************/
import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;

public class DynamicRoutingDataSourceResolver extends AbstractRoutingDataSource {

	@Override
	protected Object determineCurrentLookupKey() {

		if (SchemaContextHolder.getSchemaType() == null) {
		} else if(SchemaContextHolder.getSchemaType() == SchemaType.POSTGRES) {
			return "dataSource1";
		} else if(SchemaContextHolder.getSchemaType() == SchemaType.ORACLE) {
			return "dataSource2";
		}
		return "dataSource1";
	}
}

/*********************************/
/** データソースを定義したクラス */
/*********************************/
import java.util.HashMap;
import java.util.Map;
import javax.sql.DataSource;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

@Configuration
public class DatasourceConfig {

	@Bean()
	public DataSource dataSource1() {
		org.apache.tomcat.jdbc.pool.DataSource ds = new org.apache.tomcat.jdbc.pool.DataSource();
		ds.setDriverClassName("org.postgresql.Driver");
		ds.setUrl("jdbc:postgresql://posgredb:5432/aaa");
		ds.setUsername("posgreuser");
		ds.setPassword("posgrepass");
	    return ds;
	}

	@Bean()
	public DataSource dataSource2() {
		org.apache.tomcat.jdbc.pool.DataSource ds = new org.apache.tomcat.jdbc.pool.DataSource();
		ds.setDriverClassName("oracle.jdbc.driver.OracleDriver");
		ds.setUrl("jdbc:oracle:thin:@oradb:1521/aaa");
		ds.setUsername("orauser");
		ds.setPassword("orapass");
		return ds;
	}

	@Bean()
	public DynamicRoutingDataSourceResolver dataSource() {
		DynamicRoutingDataSourceResolver resolver = new DynamicRoutingDataSourceResolver();

		Map<Object, Object> dataSources = new HashMap<Object,Object>();
		dataSources.put("dataSource1", dataSource1());
		dataSources.put("dataSource2", dataSource2());

		resolver.setTargetDataSources(dataSources);

		return resolver;
	}
}

使い方

/*****************/
/** メインクラス */
/*****************/
import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Jsr330ScopeMetadataResolver;

@Configuration
// TODO データソース動的切替え(scopeResolver = Jsr330ScopeMetadataResolver.class)
@ComponentScan(scopeResolver = Jsr330ScopeMetadataResolver.class)
@EnableAutoConfiguration
public class MyApplication {
    public static void main(String[] args) {
        SpringApplication.run(M3SApplication.class, args);
    }
}
/***********************/
/** コントローラクラス */
/***********************/
import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestMethod;
import org.springframework.web.servlet.ModelAndView;

@Controller
public class TopController {

	/** Ｔｏｐサービス */
	@Autowired
	TopService topService;

	@RequestMapping(value="/getOracle", method={RequestMethod.POST, RequestMethod.GET})
	public ModelAndView getOracle(){

		// 接続先データソースにOracleを指定
		SchemaContextHolder.setSchemaType(SchemaType.ORACLE);
		// Oracleからデータ取得
		List<Object[]> list = topService.getOracleData();

		// 遷移先画面の設定
		ModelAndView mv = new ModelAndView("oraclePage");
		// 画面パラメータ設定
		mv.addObject("oracleData",list);

		return  mv;
	}

		@RequestMapping(value="/getPostgres", method={RequestMethod.POST, RequestMethod.GET})
	public ModelAndView getPostgres(){

		// 接続先データソースにPostgresを指定
		SchemaContextHolder.setSchemaType(SchemaType.POSTGRES);
		// POSTGRESからデータ取得
		List<Object[]> list = topService.getPostgresData();

		// 遷移先画面の設定
		ModelAndView mv = new ModelAndView("PostgresPage");
		// 画面パラメータ設定
		mv.addObject("postgresData",list);

		return  mv;
	}
}
/*******************/
/** サービスクラス */
/*******************/
@Service
@Transactional
public class TopService {
	/** Oracleデータ取得用リポジトリ */
	@Autowired
	IOracleRepository oracle_repository;

	/** Postgresデータ取得用リポジトリ */
	@Autowired
	IPostgresRepository postgres_repository;

	// Oracleデータ取得実行
	public List<Object[]> getOracleData(){
		return oracle_repository.findAll();
	}
	// Postgresデータ取得実行
	public List<Object[]> getPostgresData(){
		return postgres_repository.findByYMD("20141222","20141228");
	}
}