質問をすることでしか得られない、回答やアドバイスがある。

15分調べてもわからないことは、質問しよう!

ただいまの
回答率

90.03%

SpringBoot OracleとPostgresに接続したい

解決済

回答 1

投稿

  • 評価
  • クリップ 2
  • VIEW 9,498

plue

score 83

検索するテーブルによって、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)

お分かりになる方がいらっしゃいましたら、ご教授よろしくお願い致します。
  • 気になる質問をクリップする

    クリップした質問は、後からいつでもマイページで確認できます。

    またクリップした質問に回答があった際、通知やメールを受け取ることができます。

    クリップを取り消します

  • 良い質問の評価を上げる

    以下のような質問は評価を上げましょう

    • 質問内容が明確
    • 自分も答えを知りたい
    • 質問者以外のユーザにも役立つ

    評価が高い質問は、TOPページの「注目」タブのフィードに表示されやすくなります。

    質問の評価を上げたことを取り消します

  • 評価を下げられる数の上限に達しました

    評価を下げることができません

    • 1日5回まで評価を下げられます
    • 1日に1ユーザに対して2回まで評価を下げられます

    質問の評価を下げる

    teratailでは下記のような質問を「具体的に困っていることがない質問」、「サイトポリシーに違反する質問」と定義し、推奨していません。

    • プログラミングに関係のない質問
    • やってほしいことだけを記載した丸投げの質問
    • 問題・課題が含まれていない質問
    • 意図的に内容が抹消された質問
    • 広告と受け取られるような投稿

    評価が下がると、TOPページの「アクティブ」「注目」タブのフィードに表示されにくくなります。

    質問の評価を下げたことを取り消します

    この機能は開放されていません

    評価を下げる条件を満たしてません

    評価を下げる理由を選択してください

    詳細な説明はこちら

    上記に当てはまらず、質問内容が明確になっていない質問には「情報の追加・修正依頼」機能からコメントをしてください。

    質問の評価を下げる機能の利用条件

    この機能を利用するためには、以下の事項を行う必要があります。

回答 1

check解決した方法

+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 {

    /** Topサービス */
    @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");
    }
}

投稿

  • 回答の評価を上げる

    以下のような回答は評価を上げましょう

    • 正しい回答
    • わかりやすい回答
    • ためになる回答

    評価が高い回答ほどページの上位に表示されます。

  • 回答の評価を下げる

    下記のような回答は推奨されていません。

    • 間違っている回答
    • 質問の回答になっていない投稿
    • スパムや攻撃的な表現を用いた投稿

    評価を下げる際はその理由を明確に伝え、適切な回答に修正してもらいましょう。

15分調べてもわからないことは、teratailで質問しよう!

  • ただいまの回答率 90.03%
  • 質問をまとめることで、思考を整理して素早く解決
  • テンプレート機能で、簡単に質問をまとめられる