仅使用id的JdbcPollingChannelAdapter更新--无bean
JdbcPollingChannelAdapter是Spring Integration框架中的一个组件，用于通过轮询数据库表来获取数据并将其发送到消息通道中。在这个问答中，我们需要使用JdbcPollingChannelAdapter来更新数据库表中的数据，而不使用任何Java Bean。
JdbcPollingChannelAdapter是一个基于JDBC的适配器，它可以通过配置SQL查询语句和相关的JDBC连接信息来轮询数据库表。它会定期执行SQL查询，并将查询结果封装为消息发送到消息通道中。
对于仅使用id的JdbcPollingChannelAdapter更新数据，我们可以按照以下步骤进行操作：
- 配置JdbcPollingChannelAdapter：
- 设置数据源（DataSource）：指定数据库连接信息，包括URL、用户名和密码等。
- 设置SQL查询语句：编写一个SQL查询语句，根据id来更新数据库表中的数据。例如，可以使用类似于"UPDATE table_name SET column_name = new_value WHERE id = ?"的SQL语句，其中"table_name"是表名，"column_name"是要更新的列名，"new_value"是新的值，"id"是要更新的记录的唯一标识。
- 设置查询参数源（QueryParameterSource）：指定查询参数的来源，可以是消息头、消息体等。在这种情况下，我们可以将id作为查询参数传递给SQL查询语句。
- 配置消息处理器（MessageHandler）：
- 设置JdbcPollingChannelAdapter作为消息处理器的输入通道（input channel）。
- 设置一个消息处理器，用于处理从JdbcPollingChannelAdapter接收到的消息。在这个处理器中，我们可以使用JdbcTemplate或其他适当的方式执行SQL更新操作。
- 配置消息通道（MessageChannel）：
- 设置一个消息通道，用于连接JdbcPollingChannelAdapter和消息处理器。
通过以上配置，JdbcPollingChannelAdapter将会定期执行SQL查询，并将查询结果封装为消息发送到消息通道中。消息处理器将接收到这些消息，并根据消息中的id值来更新数据库表中的数据。
在腾讯云的产品中，可以使用云数据库MySQL或云数据库PostgreSQL作为数据源，使用JdbcPollingChannelAdapter来轮询并更新数据库表中的数据。具体的产品介绍和配置信息可以参考以下链接：
- 腾讯云数据库MySQL：https://cloud.tencent.com/product/cdb
- 腾讯云数据库PostgreSQL：https://cloud.tencent.com/product/postgres
请注意，以上答案仅供参考，具体的实现方式可能会根据实际需求和环境而有所不同。
相关·内容
我正在使用spring集成来使用JdbcPollingChannelAdapter轮询数据库，然后使用JmsSendingMessageHandler将结果发布到Activemq队列。我使用MappingJackson2MessageConverter将jdbc结果序列化为json字符串。当消息被发送时，它会以数组列表的形式发送。有没有可能一次只发送一个带有消息有效负载的json序列化对象？这将允许我像这样监听队列
@JmsListener(destination = "${activemq.queue.name}")
public void receive(Domai
浏览 8提问于2017-08-29得票数 0
回答已采纳
我使用spring集成从数据库中读取数据。现在我使用轮询适配器
@Bean
public MessageSource<Object> jdbcMessageSource() {
JdbcPollingChannelAdapter a = new JdbcPollingChannelAdapter(dataSource(), "SELECT id, clientName FROM client");
return a;
}
流程：
@Bean
public IntegrationFlow pollingFlow() throws Exception {
浏览 0提问于2016-05-30得票数 2
3回答
我正在尝试使用spring cloud数据流从oracle DB捕获更改数据，并使用kafka作为代理。为此，我使用了轮询机制。我使用基本的select查询定期轮询数据库，以捕获任何更新的数据。为了获得更好的防故障系统，我将上次轮询时间保存在oracle DB中，并使用它来获取在上次轮询后更新的数据。 public MessageSource<Object> jdbcMessageSource() {
JdbcPollingChannelAdapter jdbcPollingChannelAdapter =
new JdbcPollingChann
浏览 30提问于2019-03-07得票数 2
回答已采纳
我正在使用JDBC计票程序来处理一些db记录，当工作流完成时，我需要更新这些记录。我找不到一种方法，如果用复式键做桌子的话。
这就是我的例子。表事件。使用主键(DATETIME，EVENT_LOCATION，EVENT_TYPE)。我不能更改架构。
行被映射到一个POJO中，其属性名为: dateTime、location、type。
<int-jdbc:inbound-channel-adapter
query="select * from events where uploaded = 0”
channel="fromdb" data-sour
浏览 1提问于2018-12-29得票数 0
回答已采纳
我有一个JDBC:入站通道适配器:用来设置“每个轮询最多行”的动态，以限制在通道上传递的消息。
我有一个容量为200的QueueChannel。入站通道适配器将向此QueueChannel发送消息。我想根据RemainingCapacity的QueueChannel设置‘每个轮询最多行’的值。
为此，我试图将QueueChannel注入到Bean中，但在部署war文件时得到了错误。
错误:由于QueueChannel的原因，无法注入StateConversionError。
我还有别的办法可以做到这一点吗。
更新:我正在使用2.2.0.RC2
这是jdbc入站适配器的配置：
<si-jd
浏览 7提问于2013-12-10得票数 0
回答已采纳
我想从数据库中获取记录并将其转换为json。这在Spring Cloud Dataflow上运行。
我怀疑我错过了IntegrationFlow上的一些通话。
错误输出为：
Caused by: org.springframework.messaging.core.DestinationResolutionException: no output-channel or replyChannel header available
at org.springframework.integration.handler.AbstractMessageProducingHandler.sendO
浏览 1提问于2020-07-30得票数 1
我正在尝试配置一个稳定的连接，它不会对嵌入式ActiveMQ代理超时。我在服务器端使用Camel+ActiveMQ+Spring进行配置。在我的代理配置中，我有下面的配置，我尝试在传输连接器上设置connectionTimeOut，wireFormat.maxInactivityDuration=0，但是没有工作，我使用StompClient连接客户端的ws://localhost:61614/stomp?useInactivityMonitor=false。连接被建立，但在300,000 at之后超时，这似乎是默认的空闲时间，但无法关闭它，请帮助将连接配置在哪个级别，以确保连接不会被丢弃：
浏览 14提问于2014-07-31得票数 1
回答已采纳
我正在尝试实现BeanPostProcessor以返回我自己的JdbcPollingChannelAdapter，这将帮助我添加一些日志并了解轮询活动。我下面有一些代码，请帮助完成这个或如果有更好的方法。
谢谢
public class CustomAdapter extends JdbcPollingChannelAdapter {
private final static Logger logger = LoggerFactory.getLogger(CustomAdapter .class);
public CustomJdbcPollingChannelAdapter(DataSo
浏览 1提问于2014-06-26得票数 1
回答已采纳
spring -integration的xml配置
<int-jdbc:inbound-channel-adapter id="inchannel"
query="query the db" data-source="dataSource" max-rows-per-poll="1"
update="update query">
<int:poller fixed-rate="8000">
<int:transactional />
&l
浏览 1提问于2015-12-10得票数 1
回答已采纳
1回答
我需要构建一个从数据库生成报表的小型报告应用程序。就目前而言，每天和每周只有2篇报道。好了，各位，这就是我要做的，使它在未来容易扩展。
1)扫描reports目录，查找内容类似于以下内容的.properties文件: report.name=Weekly Management report report.datasource=myDataSource report.bootstrap.sql=SELECT getdate() report.cron.expression= 0/2 **MON report.recipient.email=konstantin@localhost
2)对于每个文
浏览 7提问于2014-09-04得票数 0
1回答
在我看来，这是个初学者的问题。
为了便于复制，我几乎把我所有的逻辑都从这个流程中剥离了出来。它看起来什么也不做的原因是因为它从JDBC端点获取数据，而且完全不做任何事情。
setupAdapter = new JdbcPollingChannelAdapter(dbprx.getDatasource(), sql.getSql());
setupAdapter.setRowMapper(rowMapper);
StandardIntegrationFlow flow = IntegrationFlows
.from(se
浏览 2提问于2020-12-29得票数 1
回答已采纳
2回答
因此，我有一个spring引导项目，我需要这样做：
启动事务-A JDBC poller，读取带有状态TO_SEND的行，为每一行提供Jms，-Update状态‘已发送’-Commit事务或失败时回滚
服务器是Weblogic，包含处理行的XA数据源、Jms的XA工厂、jndi上下文和spring集成轮询器(jdbcpollingchaneladapter)和jta事务：
如本中所示，为了做到这一点，我必须在JtaTransaction中使用userTransaction，并创建一个非事务JMS会话
// DATABASE Poller using JdbcPollingCh
浏览 6提问于2020-07-02得票数 0
回答已采纳
我得到了这个异常-“在输入没有可行的替代'?'"，我认为这是因为"+”查询语句。
private static final String CQL_BEAN = "cql:bean:cassandraCluster";
String updataQuery = "UPDATE user_preference SET preference = preference + ? WHERE user_id = ? AND tenant_id = ? IF EXISTS";
.to(CQL_BEAN + "/" + cas
浏览 0提问于2018-10-15得票数 1
我使用Spring 4.1.x APIs、Spring Integration 4.1.x APIs和Spring Integration Java DSL 1.0.x APIs作为EIP流，在这里我们使用来自Oracle数据库表的消息，使用JdbcPollingChannelAdpater作为流的入口点。
尽管我们在ErrorHandler的Poller上配置了一个RuntimeException，但我们看到会话的Transaction仍然是回滚的，并且在RuntimeException被抛出并被ErrorHandler正确处理时没有提交。
在阅读了这个线程：之后，我觉得不可能阻止回滚，而是
浏览 1提问于2015-08-11得票数 1
回答已采纳
我已经用Spring Integration定义了一个很好的流程，在名义上它就像我想要的那样工作。
然而，我还没有想出一种方法来定义处理错误的行为(即将输入行标记为失败)。
下面是我得到的错误：
[ask-scheduler-2] cMessagingTemplate$TemporaryReplyChannel : Reply message received but the receiving thread has exited due to an exception while sending the request message:ErrorMessage [payload=org.s
浏览 2提问于2018-01-19得票数 2
回答已采纳
我已经在Soap 5.0.0中创建了这个项目。它在我的机器上运行得很好。但是当一些使用4.5.1时，无法打开请求。是因为低版本吗？有人能找到解决办法吗
ERROR:com.jgoodies.binding.beans.PropertyAccessException: Failed to read an adapted Java Bean property.
cause=org.apache.xmlbeans.impl.values.XmlValueOutOfRangeException: string value 'No Authorization' is not a vali
浏览 8提问于2014-08-06得票数 7
回答已采纳
1回答
我有一个包含一些配置的bean：
public class CustomerService{
private Config config;
@Required
public void setConfig(Config config){
this.config = config;
}
}
public Config {
private String login;
private String password;
//setters/getters
}
app-context.xml：
<bean id="config" class=
浏览 0提问于2016-09-29得票数 3
回答已采纳
我有一个组件，我想在用户点击commandButton之后显示/隐藏它。
就像这样：
<h:commandButton id="showButton" value="#{bean.wasPressed ? 'Hide' : 'Show'}">
<f:ajax listener="#{bean.toggle()}" render="explanation showButton" />
</h:commandButton>
和
<h:panelGroup
浏览 4提问于2012-12-08得票数 6
回答已采纳
我想有一个输入文本的工具提示，我需要工具提示更新时，我完成了输入文本。我将这些元素放在一个表单中。
inputtext从支持bean中获取值，只有在提交表单时才在bean中设置该值。Y工具提示还从bean中获取值。\
下面是我使用的一些代码(当然，它不起作用)：
<h:inputText id="inp" value="#{individual.givenName}">
<a4j:support event="onchange" reRender="inp" />
</h:inputText&
浏览 0提问于2012-03-19得票数 0
回答已采纳
我的输入如下所示： 1234,9999232
342424,888922,true
45333,799999 这就像id_1, id_2, a_bool中的a_bool是可选的。FieldSetMapper读取令牌并设置模型中的值。线路标记化逻辑如下： <bean id="inputLineTokenizers"
class="org.springframework.batch.item.file.transform.PatternMatchingCompositeLineTokenizer">
<property nam
浏览 16提问于2020-06-10得票数 0
我们试图从jdbc源轮询消息，聚合消息，然后将聚合器的输出发送到kafka流和jdbcMessageHandler (更新我们轮询的行，使它们不再被轮询)。实际上是一张单独的桌子)。我们使用的是IntegrationFlow DSL。投票和汇总工作还很顺利。输出到多个输出/源/通道/处理程序不起作用。
我们当前的流程如下：
IntegrationFlowBuilder flowBuilder = IntegrationFlows.from(jdbcMessageSource(), new Consumer<SourcePollingChannelAdapterSpec>(){
浏览 11提问于2017-09-22得票数 0
回答已采纳
4回答
我尝试将Spring的事务管理器与MyBatis映射器一起使用，如下所示的服务实现
@Service("myService")
class MyServiceImpl implements MyService
{
@Autowired
private MyMapper myMapper;
@Transactional(
value = "transactionManager",
propagation = Propagation.REQUIRED,
rollback
浏览 2提问于2017-10-06得票数 1
比方说，我有一个web应用程序，它具有单例范围的所有bean。现在假设我们有bean Employee，其中定义了name和一些其他属性。现在，我用两个不同的浏览器打开两个不同的会话，在其中一个会话中，我更改了该雇员的值。
我的问题是，
会话2的employee对象状态是什么？(我认为它应该给出修改后的值，因为它是单例的)
浏览 1提问于2013-10-12得票数 0
回答已采纳
我正在尝试使用下面的配置在没有项目写入器的情况下配置spring batch步骤。然而，我得到一个错误，说写入器元素既没有' writer‘属性，也没有元素。
我浏览了的链接。但无法解决问题。谁能告诉我在我提到的代码片段中需要做哪些具体的修改
<batch:job id="helloWorldJob">
<batch:step id="step1">
<batch:tasklet>
<batch:chunk reader="cvsFi
浏览 1提问于2014-10-05得票数 12
回答已采纳
我正在与JSP一起使用SpringSecurity3.0。我已经创建了一个RequireVerificationFilter，它将未经验证的用户重定向到“验证您的电子邮件”页面。
我在最后一个位置将过滤器添加到spring安全过滤器堆栈中，如下所示：
Bean定义在我的app-config.xml中：
<bean id="requireVerificationFilter" class="com.ebisent.web.RequireVerificationFilter" />
过滤器添加到我的security -config.xml中的spring
浏览 4提问于2010-10-17得票数 6
回答已采纳
我已经用Spring实现了一个RESTful web服务。服务基于Accept标头以XML或JSON格式进行响应。下面是context.xml映射：
<bean id="xstreamMarshaller" class="org.springframework.oxm.xstream.XStreamMarshaller"/>
<bean id="xmlMessageConverter"
class="org.springframework.http.converter.xml.Marshallin
浏览 0提问于2011-04-11得票数 6
回答已采纳
当我在web.xml中有：
<param-name>transformWsdlLocations</param-name>
<param-value>true</param-value>
和
<servlet-mapping>
<servlet-name>personWS</servlet-name>
<url-pattern>/*</url-pattern>
</servlet-mapping>
自动生成的WSDL包含正确的URL：
<soap:add
浏览 0提问于2011-07-31得票数 2
回答已采纳
我尝试使用mpm-itk来使用这个教程隔离我的apache虚拟主机。我创建了用户bean和组bean，我使用passwd bean为这个用户创建了一个密码。当我尝试使用sudo su - bean向这个用户发送时，它一点也不改变，我如何才能切换到这个用户呢？
浏览 0提问于2019-03-12得票数 0
2回答
如何从spring注入静态变量？
public class MyClass{
static String str;
// how to set value to this variable through Spring
}
<b>Spring bean</b>
<bean id='myclass' class = 'com.so.MyClass'>
<property name="str" value="xmlpath" />
</bean>.
浏览 1提问于2014-08-11得票数 0
回答已采纳
我有以下的spring安全配置。
<?xml version="1.0" encoding="UTF-8"?>
<beans:beans xmlns="http://www.springframework.org/schema/security"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xmlns:beans="http://www.springframework.org/schema/beans"
xsi:schemaLocat
浏览 0提问于2013-01-22得票数 0
回答已采纳
在Spring中，我想使用声明bean的初始化依赖于另一个bean。问题是，我需要处理包含空格的bean ID，如下所示：
<bean id="Bean A">
<!-- stuff -->
</bean>
<bean id="Bean B" depends-on="Bean A">
<!-- stuff -->
</bean>
不幸的是，这不起作用，因为depends-on属性可以接受一个空格分隔的bean it列表；Spring认为它正在寻找Bean B
浏览 3提问于2015-03-17得票数 0
回答已采纳
在我的页面上，我有带有数据库数据的表单。作为默认行为，我希望将所有更改写入db。
我找到了这样的例子
<h:selectOneMenu value="#{bean.options}" onchange="submit()"
var="#{bean.options}" valueChangeListener="#{bean.changeListernMethod}">
<f:selectItem itemValue=&#
浏览 2提问于2015-07-14得票数 1
回答已采纳
1回答
我有一个简单的导航条使用引导4和BEM方法，当我运行我的应用程序汉堡包菜单显示在桌面设备，而不是隐藏。
下面是到jsfiddle的链接：
HTML
<nav class="main-nav">
<div class="main-nav__logo">
<li class="main-nav__link">
<a>Majeni</a>
</li>
</div>
<but
浏览 2提问于2018-08-11得票数 0
回答已采纳
1回答
DB甲骨文在多个实例之前，只有一个实例。使用"select . for update跳转锁定“解决了重复读取的问题。
JdbcPollingChannelAdapter adapter = new JdbcPollingChannelAdapter(
dataSource, SELECT_QUERY);
adapter.setUpdateSql(UPDATE_QUERY);
adapter.setUpdateSqlParameterSourceFactory(input -> {
List<TableEntry>
浏览 5提问于2022-04-23得票数 1
我面临一个问题，JdbcBatchItemWriter正在挑选最后一条记录进行更新，我创建了ItemPrepartedStatementSetter，它正在对象数组中迭代并设置preparedStatement。请提供任何输入，以下是代码 XML： <bean id="jdbcWriter"
class="org.springframework.batch.item.database.JdbcBatchItemWriter">
<property name="sql"
value=&
浏览 3提问于2014-06-05得票数 0
在JdbcPollingChannelAdapter中，我认为我理解如何使用ExpressionEvaluatingSqlParameterSourceFactory类的createParameterSourceNoCache()方法，以便获得一个非缓存的SqlParameterSource对象，该对象可以通过其setSelectSqlParameterSource()方法应用到JdbcPollingChannelAdapter的select参数。
但是，当涉及更新参数时，我只看到通过SqlParameterSourceFactory通过setUpdateSqlParameterSourceF
浏览 0提问于2018-04-11得票数 1
回答已采纳
在下面的示例(来自)中，列具有名称(小时、ipm、项目、名称)。有没有可能在不命名列的情况下这样做(这样值就只放在前四列中)？如果没有，这些列有没有我可以使用的标准名称，这样我就不必自己命名它们了？(我试过使用A、B、C、D和C1、C2、C3、C4等名称，但它们都不起作用)
<entry xmlns="http://www.w3.org/2005/Atom"
xmlns:gsx="http://schemas.google.com/spreadsheets/2006/extended">
<gsx:hours>1</gs
浏览 1提问于2014-07-17得票数 0
我使用的是Primefaces 5，我想将selectonemenu重置为默认值。
我有一个分页结构，所以：
<p:fragment>
<p:tabView id="tabview1" cache="false" dynamic="true" >
<p:tab title="One" id="tab1">
<ui:include src="tab1.xhtml" />
</
浏览 0提问于2015-09-09得票数 0
我有以下情况：
我希望"methodB“被并行执行10次。但是，只有当从另一个bean调用"methodB“时，才会发生这种情况。
为什么"@Asynchronous“注解在同一个类中的另一个方法调用时不起作用？
谢谢。
浏览 1提问于2012-08-30得票数 8
回答已采纳
我对实体的一个属性有一个独特的约束：
Table(uniqueConstraints = @UniqueConstraint(name = "UniqueByEmail", columnNames = "email"))
public class Player implements Serializable {
@Id
@GeneratedValue(strategy = GenerationType.AUTO)
private long id;
@Column(name = "email")
priva
浏览 2提问于2012-08-23得票数 0
回答已采纳
当我使用camel的2.14版本时，我能够创建jetty实例...然而，在tomcat加载应用程序时，2.15.2显示以下错误
org.springframework.beans.factory.BeanCreationException: Error creating bean with name 'jetty' defined in ServletContext resource [/WEB-INF/classes/camel-context.xml]: Instantiation of bean failed; nested exception is org.spring
浏览 3提问于2015-08-26得票数 1
<rich:tree switchType="client" value="#{Bean.tree}" var="one">
<rich:treeNode>
<h:commandLink value="#{one.item1}"
action="#{Bean.getItem()}
浏览 0提问于2012-07-05得票数 1
回答已采纳
使用Spring Integration，有没有办法模拟单元测试时jdbc:inbound-channel-adapter检索到的结果集？如果没有，推荐的测试策略是什么？
谢谢
浏览 0提问于2014-01-28得票数 0
在我的java类中，我有：
@Autowired
@Qualifier("customerProviderExec")
private DefaultCustomerProvider customerProvider;
在我的上下文中配置XML
<bean id="customerProviderExec" class="my.package.DefaultCustomerProviderExecutor">
<property name="defaultCustomerProviderService"
浏览 5提问于2012-02-01得票数 1
由于某些原因，在MVC2中启用了无cookieless会话，查询字符串中的会话id在每次表单发送时都会被重置。是否有需要设置的特殊路由才能正常工作？
有没有其他我需要注意的问题？
谢谢。
浏览 2提问于2010-10-20得票数 3
回答已采纳
我正在使用spring data jpa仓库来处理我的sql-server数据库，现在我的问题是如何批量更新我的表，因为我的table-java bean不包含表中的所有列，所以如果我使用repository.save(List<>)，如果它们没有映射到我的java bean中，它可能会覆盖所有其他列的默认值，所以现在，我只需像下面这样编写原生sql来更新每一列：
那么如何批量更新一些字段呢？
浏览 2提问于2014-11-06得票数 0
我有一个与页面相关联的存储bean，我希望根据验证失败还是成功来更改它的值。
@ManagedBean(name = "testBean")
@ViewScoped()
public class TestBean implements Serializable {
String value="";
int number;
/*getters-setters*/
}
检查数字是否为正的验证器。
@FacesValidator("Validator")
public class NumValidator implements Validato
浏览 1提问于2014-08-19得票数 0
回答已采纳
1回答
我正在尝试了解我的设计的缺点，下面是我的代码
class Utils {
public static SpringBean bean;
public static void setBean(SpringBean b){
bean = b;
}
public static SpringBean getBean(){
return bean;
}
public static Object getSomethingFromBean(){
return bean.getSomethingFromBean(
浏览 18提问于2017-03-15得票数 1
我目前正在构建一个具有不同ignite配置的应用程序。现在，我正在探索Ignite的缓存特性。我的目标是只使用Ignite作为缓存。数据应存储在第三方数据库(postgres)中。我在数据库中使用tpc-h数据模式。所以，它不是键值存储，而是普通的sql。 现状:我有一个postgres数据库( database -name："db")和一个"Nation“表。该表由几个条目(Postgres Table "Nation")填充。我也已经在我的Google-Kubernetes-Engine中构建了一个Ignite-Cluster。我使用自己的Igni
浏览 99提问于2021-09-08得票数 1
回答已采纳
我使用Hibernate4，Spring3和JSF2作为一个小型应用程序，WebLogic10.3.6作为应用程序服务器。
为了启用JPA2，我在commEnv.cmd中添加了以下内容
@rem Enable JPA 2.0 functionality on WebLogic Server
set PRE_CLASSPATH=%BEA_HOME%\modules\javax.persistence_1.1.0.0_2-0.jar;
%BEA_HOME%\modules\com.oracle.jpa2support_1.0.0.0_2-1.jar
当我运行我的应用程序时，我在下面的行上得到了空指
浏览 0提问于2012-12-21得票数 2
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
