JDBC Spring集成与注解

Question

我找的例子有注解的类，完全XML免费的这样：

<int-jdbc:inbound-channel-adapter query="select * from item where status=2" 
channel="target" data-source="dataSource" 
update="update item set status=10 where id in (:id)" /> 

OR

<int-jdbc:inbound-channel-adapter query="..." 
    channel="target" data-source="dataSource" update="..."> 
<int:poller fixed-rate="1000"> 
    <int:transactional/> 
</int:poller> 
</int-jdbc:inbound-channel-adapter> 

也许存在一个更好的解决方案，如输入消息网关通过使用CRON语句查询数据库来创建入口点。 克朗编程查询 - >第一通道

Answer 1

Java的&注解配置变种：

@Bean 
public PollerMetadata poller(PlatformTransactionManager transactionManager) { 
    PeriodicTrigger trigger = new PeriodicTrigger(1000); 
    trigger.setFixedRate(true); 

    MatchAlwaysTransactionAttributeSource attributeSource = new MatchAlwaysTransactionAttributeSource(); 
    attributeSource.setTransactionAttribute(new DefaultTransactionAttribute()); 
    TransactionInterceptor interceptor = new TransactionInterceptor(transactionManager, attributeSource); 

    PollerMetadata poller = new PollerMetadata(); 
    poller.setTrigger(trigger); 
    poller.setAdviceChain(Collections.singletonList(interceptor)); 
    return poller; 
} 

@Bean 
@InboundChannelAdapter(value = "target", poller = @Poller("poller")) 
public MessageSource<?> counterMessageSource(DataSource dataSource) { 
    JdbcPollingChannelAdapter adapter = 
      new JdbcPollingChannelAdapter(dataSource, "select * from item where status = 2"); 
    adapter.setUpdateSql("update item set status = 10 where id in (:id)"); 
    return adapter; 
} 

权，本次交易构成长相丑陋，但尚未提供TX Advice到PollerMetadata的简单方法。

你可以考虑对此事使用Spring Integration Java DSL：

@Bean 
public MessageSource<?> jdbcAdapter(DataSource dataSource) { 
    JdbcPollingChannelAdapter adapter = 
      new JdbcPollingChannelAdapter(dataSource, "select * from item where status = 2"); 
    adapter.setUpdateSql("update item set status = 10 where id in (:id)"); 
    return adapter; 
} 

@Bean 
public IntegrationFlow jdbcFlow(MessageSource<?> jdbcAdapter) { 
    return IntegrationFlows 
      .from(jdbcAdapter, e -> 
        e.poller(p -> p.fixedRate(1000).transactional(transactionManager()))) 
      .channel(c -> c.direct("target")) 
      .get(); 
} 

随意，以提高对DSL项目GH-问题，为JDBC适配器提供了DSL。