java - 使用

转载 作者：搜寻专家 更新时间：2023-11-01 01:53:52 25 4

我可能在这里遗漏了一些东西，但我似乎找不到任何关于使用 Spring Integration JPA Outbound Channel Adapter 保留实体列表的文档。我有一个非常简单的场景，应该轮询一个数据库并将新数据复制到另一个数据库。因此:

<int-jpa:inbound-channel-adapter channel="myChannel"
    entity-class="my.package.MyClass"
    entity-manager="mysqlEntityManager"
    auto-startup="true">
    <int:poller fixed-rate="5000">
        <int:transactional propagation="REQUIRED" transaction-manager="mysqlTransactionManager"/>
    </int:poller>
</int-jpa:inbound-channel-adapter>

<int:channel id="myChannel" />

<int-jpa:outbound-channel-adapter channel="myChannel" 
    entity-class="my.package.MyClass"
    entity-manager="hsqldbEntityManager">
    <int-jpa:transactional transaction-manager="hsqldbTransactionManager" />                                    
</int-jpa:outbound-channel-adapter>

inbound-channel-adapter返回 List<MyClass>然后是 outbound-channel-adapter在下面抛出堆栈跟踪...

如何配置适配器以接受实体列表？我不想在入站适配器/轮询器中设置每个轮询的最大消息数，因为我更喜欢最少的数据库操作。

感谢任何帮助。

Spring 文档: http://static.springsource.org/spring-integration/docs/3.0.0.M1/reference/html/jpa.html

[task-scheduler-1] ERROR org.springframework.integration.handler.LoggingHandler - org.springframework.integration.MessageHandlingException: error occurred in message handler [org.springframework.integration.jpa.outbound.JpaOutboundGateway@165d2be]
    at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:79)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
    at java.lang.reflect.Method.invoke(Unknown Source)
    at org.springframework.aop.support.AopUtils.invokeJoinpointUsingReflection(AopUtils.java:319)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.invokeJoinpoint(ReflectiveMethodInvocation.java:183)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:150)
    at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:110)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:172)
    at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:202)
    at $Proxy24.handleMessage(Unknown Source)
    at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:115)
    at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:102)
    at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:77)
    at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:157)
    at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:128)
    at org.springframework.integration.core.MessagingTemplate.doSend(MessagingTemplate.java:288)
    at org.springframework.integration.core.MessagingTemplate.send(MessagingTemplate.java:149)
    at org.springframework.integration.endpoint.SourcePollingChannelAdapter.handleMessage(SourcePollingChannelAdapter.java:97)
    at org.springframework.integration.endpoint.AbstractTransactionSynchronizingPollingEndpoint.doPoll(AbstractTransactionSynchronizingPollingEndpoint.java:82)
    at org.springframework.integration.endpoint.AbstractPollingEndpoint$1.call(AbstractPollingEndpoint.java:146)
    at org.springframework.integration.endpoint.AbstractPollingEndpoint$1.call(AbstractPollingEndpoint.java:144)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
    at java.lang.reflect.Method.invoke(Unknown Source)
    at org.springframework.aop.support.AopUtils.invokeJoinpointUsingReflection(AopUtils.java:319)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.invokeJoinpoint(ReflectiveMethodInvocation.java:183)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:150)
    at org.springframework.transaction.interceptor.TransactionInterceptor.invoke(TransactionInterceptor.java:110)
    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:172)
    at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:202)
    at $Proxy23.call(Unknown Source)
    at org.springframework.integration.endpoint.AbstractPollingEndpoint$Poller$1.run(AbstractPollingEndpoint.java:236)
    at org.springframework.integration.util.ErrorHandlingTaskExecutor$1.run(ErrorHandlingTaskExecutor.java:52)
    at org.springframework.core.task.SyncTaskExecutor.execute(SyncTaskExecutor.java:48)
    at org.springframework.integration.util.ErrorHandlingTaskExecutor.execute(ErrorHandlingTaskExecutor.java:49)
    at org.springframework.integration.endpoint.AbstractPollingEndpoint$Poller.run(AbstractPollingEndpoint.java:231)
    at org.springframework.scheduling.support.DelegatingErrorHandlingRunnable.run(DelegatingErrorHandlingRunnable.java:53)
    at org.springframework.scheduling.concurrent.ReschedulingRunnable.run(ReschedulingRunnable.java:81)
    at java.util.concurrent.Executors$RunnableAdapter.call(Unknown Source)
    at java.util.concurrent.FutureTask$Sync.innerRun(Unknown Source)
    at java.util.concurrent.FutureTask.run(Unknown Source)
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$301(Unknown Source)
    at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(Unknown Source)
    at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(Unknown Source)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(Unknown Source)
    at java.lang.Thread.run(Unknown Source)
Caused by: java.lang.IllegalArgumentException: Unknown entity: java.util.ArrayList
    at org.hibernate.ejb.AbstractEntityManagerImpl.merge(AbstractEntityManagerImpl.java:692)
    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
    at sun.reflect.NativeMethodAccessorImpl.invoke(Unknown Source)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(Unknown Source)
    at java.lang.reflect.Method.invoke(Unknown Source)
    at org.springframework.orm.jpa.SharedEntityManagerCreator$SharedEntityManagerInvocationHandler.invoke(SharedEntityManagerCreator.java:240)
    at $Proxy18.merge(Unknown Source)
    at org.springframework.integration.jpa.core.DefaultJpaOperations.merge(DefaultJpaOperations.java:175)
    at org.springframework.integration.jpa.core.JpaExecutor.executeOutboundJpaOperation(JpaExecutor.java:223)
    at org.springframework.integration.jpa.outbound.JpaOutboundGateway.handleRequestMessage(JpaOutboundGateway.java:81)
    at org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.java:134)
    at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:73)
    ... 48 more
Caused by: org.hibernate.MappingException: Unknown entity: java.util.ArrayList
    at org.hibernate.impl.SessionFactoryImpl.getEntityPersister(SessionFactoryImpl.java:693)
    at org.hibernate.impl.SessionImpl.getEntityPersister(SessionImpl.java:1485)
    at org.hibernate.event.def.DefaultMergeEventListener.onMerge(DefaultMergeEventListener.java:232)
    at org.hibernate.event.def.DefaultMergeEventListener.onMerge(DefaultMergeEventListener.java:84)
    at org.hibernate.impl.SessionImpl.fireMerge(SessionImpl.java:867)
    at org.hibernate.impl.SessionImpl.merge(SessionImpl.java:851)
    at org.hibernate.impl.SessionImpl.merge(SessionImpl.java:855)
    at org.hibernate.ejb.AbstractEntityManagerImpl.merge(AbstractEntityManagerImpl.java:686)
    ... 59 more

最佳答案

我创建了一个 Jira 来进行改进:

https://jira.springsource.org/browse/INT-3029

作为变通方法，您还可以扩展 DefaultJpaOperations (org.springframework.integration.jpa.core) 并自定义 persist() 方法，从而允许您处理集合类型参数。有关详细信息，请参阅:

Batch inserts with JPA/EJB3

适配器具有 XML 命名空间属性 jpa-operations，允许您提供对自定义实现的引用。更多详情请见http://static.springsource.org/spring-integration/docs/latest-ga/reference/html/jpa.html#jpa-namespace-support-common-attributes

关于java - 使用 <int-jpa :outbound-channel-adapter 保留实体列表，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/16712700/

25 4 0

• 选择 channel <- <- channel

  我很好奇为什么以下不起作用。一般select用default:防止死锁，但在这种情况下不是: package main import "fmt" func main () { a := mak

• python - 在先 channel 和最后 channel 之间更改图像 channel 顺序的正确方法是什么？

  我一生都无法弄清楚如何切换图像排序。图像以 (x,x,3) 格式读取，theano 要求它是 (3,x,x) 格式。我尝试更改顺序numpy.array([img[:,:,i] for i in ra

• c - 如何向libnl发送单 channel 扫描请求，并接收相应 channel 的单 channel 扫描完成响应

  我正在向 libnl 发送单个 SSID 和频率进行扫描，但我得到了多个扫描结果以及我请求的 SSID 和频率，但我需要单个扫描结果(仅适用于请求的 SSID)，如何实现这一点。请帮助我，我也发送了我

• golang，goroutines，如何在另一个 channel 中设置 channel ，然后在关闭母 channel 后阅读

  我是 Golang 的新手，但正在努力理解这门伟大的语言!请帮帮我.. 我有 2 个 channel 。 “进”和“出” channel in, out := make(chan Work),

• 转到 channel : consume data from channel although not push anything to channel

  例如我有这段代码: package main import ( "fmt" ) func main() { c1 := make(chan interface{}) close

• youtube-api - 如何获取经过身份验证的用户拥有的 YouTube channel 列表和关联的 channel URL(用户或 channel )

  我们使用以下调用来获取经过身份验证的用户的 ChannelID，它适用于大多数情况。一些 YouTube 用户将他们的 channel 连接到 Google+ 信息页，但在这种情况下，我们的一位用户无

• javascript - 统计文本 channel 、语音 channel 、所有 channel 和 Angular 色

  case 'sinfo': const sinfo = new Discord.MessageEmbed() .addField('Server Name 🔎 :', message.guild.n

• channel - 如何使用discord.py获取所有文本 channel ？

  我需要让所有 channel 来创建一个 bunker 命令，这使得所有 channel 都是只读的。 最佳答案 他们变了Client.servers至 Client.guilds在 newer ve

• 去教程: Channels and Buffered Channels

  为什么当第二个值通过另一个 go routine 发送并且没有收到发送的第一个值时， channel c 没有缓冲？ package main import "fmt" func sum(s []in

• opencv - 是否有将 3 channel 垫拆分为三个 3 channel 垫而不是分成三个 1 channel 垫的内置函数？

  据我所知，内置的 split 会将一个 3 channel Mat 拆分为三个 1 channel Mat。结果，这三个 Mat 只是具有一些不同强度的灰度。 我的意图是获得三个 3 channel

• windows - 我如何询问 Windows RAM 是在单 channel 、双 channel 还是四 channel 中运行？

  如何检测当前的 RAM 配置？我需要询问 Windows RAM 当前是在单 channel 、双 channel 还是四 channel 中运行。 我搜索了很多，并没有在这个网站或其他网站上找到任何

• audio - gstreamer 将多 channel wav 文件拆分为单独的 channel 并将每个 channel 编码为 mp3、alac 等并保存到文件

  我需要拆分一个多 channel wav 文件并将每个 channel 编码为 mp3 文件。 我知道 gtresamer 的 deinterleave 插件，但我不确定如何将它用于 wav 文件以及

• android - Android Studio Beta Channel、Android Studio Canary Channel、Android Studio Dev Channel 有什么区别？

  关闭。这个问题需要details or clarity .它目前不接受答案。 想要改进这个问题吗？ 通过 editing this post 添加详细信息并澄清问题. 关闭 8 年前。 Improve

• hyperledger-fabric - "channel [{channel-name}]: MSP error: channel doesn' t exist”警告无法在 Hyperledger Fabric 上实例化链代码

  我正在尝试运行 Hyperledger Fabric 网络，它由单个订购者、单个对等节点和一个 cli 组成。为了学习启动 Hyperledger Fabric 网络的过程，从创建与加密相关的工件到将

• 拉拉维尔。每个用户的多个 channel 或个人 channel ？

  我在 Laravel 中使用事件广播。我正在使用基于角色的通知访问权限。我有用于广播的自定义 auth guard。当用户连接到 channel 时，客户端将具有内部权限的 access_token

• sockets - Phoenix Channels - 每个插槽有多个 channel

  我正在编写一个使用 Elixir Channels 来处理实时事件的应用程序。我知道每个客户端将打开 1 个套接字，并且可以在其上多路复用多个 channel 。所以我的应用程序是一个聊天应用程序，其

• ffmpeg - 使用ffmpeg将两个 channel 转换为左或右的单个 channel

  我有一些 .wav 文件，我想转换它们的频率 (fs) 和 channel 数 (nchannels)。我在jupyter笔记本python3.6上使用ffmpeg。我使用了以下命令并且它有效。 cm

• ffmpeg - 将PNG序列的Alpha channel 转换为H265的Y channel

  我有一个视频渲染器，它需要两个 H265 流(YUV420)，我需要烘焙它们以使它们中的一个与另一个形成 alpha 蒙版。这一切都已解决并且效果很好，但是如果我按照此处的说明进行操作: ffmpeg

• ffmpeg 从具有多个 channel 的输入中输出单独的 channel

  我运行此命令以便能够将 udp 直播流传输到可使用正在构建的移动应用程序播放的 http 直播流。 它只是一个只有音频流的流。 ffmpeg -i udp://@localhost:1111 -map

• javascript - 在与原始 channel 相同的位置制作克隆 channel

  我在我的 discord.js 机器人中创建了 nuke 命令，它创建了具有相同名称、权限、主题等的 channel ，并删除了“原始” channel 。但是有一个问题，如何使 channel 与“