zwei Datenquelle in Spring Integration eingehenden Kanal

Question

Ich verwende int-jdbc:inbound-channel-adapter von Spring Integration.

Meine Abfrage verwendet zwei verschiedene Datenquellen, d. H. Datenquelle A für die Abfrage und Datenquelle B für die Aktualisierung, in einem einzigen Adapter?

Answer 1

Sie können nicht; das gleiche JdbcTemplate wird für beide Operationen verwendet; Sie können die Aktualisierungsabfrage weglassen und das Update für einen Outbound-Channel-Adapter durchführen.

Answer 2

Im Frühjahr JDBC-Modul haben wir so etwas wie AbstractRoutingDataSource. Welche Sie basierend auf einigen Variablen ThreadLocal implementieren können.

Von anderer Seite der JdbcPollingChannelAdapter hat Code wie folgt:

private Object poll() { 
    List<?> payload = doPoll(this.sqlQueryParameterSource); 
    ... 
    executeUpdateQuery(payload); 

    return payload; 
} 

Also, sollten Sie irgendwie zwischen doPoll() und executeUpdateQuery und daher ändern Sie den Schlüssel in der ThreadLocal in einzuhaken zum anderen wechseln zu können, DataSource in der AbstractRoutingDataSource.

Ich nur den Hack wie benutzerdefinierte sqlParameterSourceFactory.createParameterSource() und die ThreadLocal Modifikation dort. Nur weil der Code wie:

private void executeUpdateQuery(Object obj) { 
    SqlParameterSource updateParamaterSource = this.sqlParameterSourceFactory.createParameterSource(obj); 
    this.jdbcOperations.update(this.updateSql, updateParamaterSource); 
} 

(Wird das Update für updateParamaterSource Typo bald :-) begehen).

Aber! Wie Gary in seiner Antwort erwähnt, wäre es besser, mehrere JDBC-Adapter für verschiedene DataSource s zu haben: einen für SELECT und einen weiteren für UPDATE. Beide können in derselben XA-Transaktion arbeiten (<transactional> auf der <poller>). Und von da unterscheiden wir wirklich die Geschäftslogik und das Verantwortungsniveau.