Quarkus读取`ResultSet`，多线程处理

文章/答案/技术大牛

发布

1回答

java、multithreading、jdbc、quarkus

我正在尝试并行读取JDBC ResultSet，并对Quarkus服务中的每条记录进行一些处理。ResultSet中可能有很多记录，所以我不想预先读取所有数据。我宁愿将结果流式传输到处理器。我包装了ResultSet对象，这样我就可以以线程安全的方式读取它。然而，我正在努力寻找一种在多个线程中读取结果的方法。我尝试了一个ExecutorService，但是DB上下文丢失了，ResultSet在线程中

浏览 98提问于2020-09-25得票数 1

回答已采纳

1回答

Quarkus映射

java、sql、jpa、quarkus

我正在浏览Quarkus & JPA当前可用的指南，但是我找不到任何SQL ResultSet映射的例子，也找不到夸尔库斯支持的任何证据。大多数情况下，我们必须处理不那么简单的查询，这些查询涉及来自不同表、连接或计算字段的字段的混合。使用@SqlResultSetMapping注释。现在我认

浏览 2提问于2021-05-06得票数 0

2回答

Java数据库处理性能建议

java、oracle、performance

我正在开发Java应用程序，它从oracle数据库表中读取记录，并在读取每个记录之后进行一些处理。注意:应用程序只从数据库读取数据，不回写任何东西。userData=new ArrayList<HashMap<String,String>>(); while(resultSet.next()){

浏览 8提问于2017-02-14得票数 0

回答已采纳

1回答

管理java中的Sqlite，以提高在单个线程环境中的性能

java、sqlite

Java程序员似乎总是喜欢关闭连接，以防止错误的代码将连接置于糟糕的状态或使用未关闭的语句等.避免了上述问题，并将允许代码在多线程环境中运行，如果将来需要的话？

浏览 0提问于2013-01-29得票数 2

3回答

如何在Quarkus中通过REST从数据库中流出大量数据

java、hibernate、jpa、jax-rs、quarkus

我在Quarkus中实现了一个GET方法，它应该向客户端发送大量数据。数据使用JPA/Hibernate从数据库中读取，序列化为JSON，然后发送到客户端。这意味着底层的ResultSet也关闭了，写入器不能再从流中读取了。使用StreamingOutput作为Response主体。与2.发生的问题相同.所以我的问题是:用Quarkus发送通过JPA读取的大数据的诀窍是什么？

浏览 3提问于2021-11-26得票数 0

2回答

弹簧批处理-连接步骤和多线程步骤- RowMapper中的空指针异常

java、spring、multithreading、spring-boot、spring-batch

当我在多个线程中运行我的步骤时，我在我的行映射器中得到一个空指针异常，同时处理结果集，即使是对于具有显式空检查的条目。当我在没有taskExecutor()/on单线程的情况下执行它时，它工作得很好。我的理解是，如果我将提交间隔指定为100，而核心线程计数为10，那么每个线程都会提取一个100的块，并独立地处理它。分块的读者行地图三人组是如何工作的？如果我的读取器中有一个查询，获取100万行和1000块大小，这是否意味着读取器将访问数据库1000次？每一次，行映射器将映射获取的所有1000行？，线程

浏览 7提问于2019-09-25得票数 0

回答已采纳

1回答

如何以多线程或其他更快的方式处理ResultSet中的250 K记录？

java、multithreading、resultset、cachedrowset

目前，我的SQL resultSet带来了大约250 K的记录，这些记录需要处理。整个过程需要25秒才能完成。我计划在上面做多线程。但无法将数据从ResultSet中分离出来。

浏览 2提问于2016-06-01得票数 2

1回答

如何在Spring Boot Camel中使用onException()处理异常

java、spring-boot、apache-kafka、apache-camel、spring-camel

Spring boot Apache Camel-Java DSL应用程序从Kafka主题读取消息。org.apache.kafka.common.errors.DisconnectException 我研究了onException(...class).handled(true)，但我不确定如何在我的代码中实现异常处理例如，记录消息或重新尝试读取消息？文档还提到Quarkus。是否需要Quarkus才能使用onException()

浏览 66提问于2020-11-29得票数 0

2回答

多线程JDBC

multithreading、jdbc

从体系结构上讲，使用多线程处理JDBC的最佳方式是什么？我有许多线程并发地访问数据库。使用单个连接和语句时，我得到以下错误消息：我应该使用多个连接，多个语句，还是有更好的方法？

浏览 0提问于2009-07-25得票数 5

回答已采纳

1回答

IO和数据库:哪个更快？

java、mysql、performance、io、bufferedreader

现在，在这种情况下，读取文件或数据库，哪个操作更快？为什么？

浏览 2提问于2014-04-05得票数 1

3回答

是否有用于分页的Quarkus客户端的工作示例？

cassandra、pagination、quarkus

我仍然迷失在使用Quarkus客户端时，我一整天都在尝试用夸克集成完成分页，但是文档实际上根本没有帮助。这里的其他人有一个与Quarkus客户端分页的工作示例？请与我分享你的知识。提前谢谢。

浏览 27提问于2022-05-13得票数 2

回答已采纳

1回答

弹簧批多线程asynchItemWriter

spring、multithreading、spring-batch

我正在尝试在春季批处理中实现多线程。在我的实现中我想我不能实行一般的分块，因为在那里读者将被考虑，我不想。但我看到的是，读取器和编写器是单线程的，只有'asyncItemProcessor‘运行在’异步asyncItemProcessor/异步in‘中的多个线程中。有什么地方我可以运行'Reader‘单线程和处理器和写入器作为多线程？

浏览 2提问于2020-02-22得票数 0

2回答

Oracle和Java :如何避免两个不同的线程从包含百万条记录的表中读取相同的行

java、oracle

如何避免两个不同的java线程从包含百万条记录的表中读取相同的行。我该怎么做呢？不使用任何java框架

浏览 5提问于2022-10-13得票数 -1

4回答

如何使用AJAX读取PHP文件返回的数组中的所有值？

php、ajax、arrays

我使用AJAX来获取多维数组，因此将多维数组返回给AJAX，我如何使用AJAX处理这些数据？我需要读取多维数组中的所有值。我使用以下代码将数组返回给AJAX。$resultset=array();{}如何使用AJAX读取PHP文件返回的数组中的所有值？

浏览 0提问于2009-11-20得票数 0

1回答

在StartupEvent上运行新线程中的任务后的StartupEvent

java、multithreading、dependency-injection、quarkus

Quarkus网站上的文档告诉我，这样做的一种方法是在我试图运行的方法中添加“@ StartupEvent e”构造。(AroundInvokeInvocationContext.java:54)at io.quarkus.arc.runtime.devconsole.InvocationInterceptor.monitor(Invocatio

浏览 10提问于2022-08-16得票数 0

回答已采纳

3回答

每当MySQL表发生更改时从该表读取数据

java、mysql、updates

我有一个MySQL数据库，其中包含一个表，其中的新数据正在获取dumped.Now我已经制作了一个java程序来读取表data.The插入到表中的数据的性质是这样的，有时它是连续添加的，有时是在intervals.While我的要求是一旦数据添加到表中，就从java应用程序中读取数据。下面是我的java类代码。private void Readdata(ResultSet res

浏览 1提问于2014-05-15得票数 0

4回答

java中的多线程读取数据库

java、multithreading

我正在使用java中的多线程从vertica数据库读取数据。start +=5; 上面的查询将从db读取的20K条不同的记录分配给每个线程。例如，第一个线程将读取第一个20k记录，然后从100000个位置开始读取20K记录，依此类推有没有人能指出哪里出了问题？

浏览 0提问于2017-01-29得票数 1

1回答

如何从Quarkus中访问lambda执行上下文？

aws-lambda、jax-rs、quarkus

普通的Lambda处理程序有它，但是在Quarkus生成的JAX处理程序中，我找不到访问它的方法。我想应该有办法注射它什么的..。我为什么要问？我想读取lambda执行ID来传递它，这样我就可以检查这个特定的执行什么时候结束了-而不需要创建额外的资源(包括step函数)或数据库标志。

浏览 5提问于2020-07-22得票数 1

回答已采纳

1回答

(Quarkus，Mutiny，Panache，Reactive)

java、hibernate、websocket、quarkus、hibernate-reactive

import java.util.Date; import javax.persistence.Entity;import io.smallrye.mutiny.Multi; imp

浏览 38提问于2021-07-13得票数 0

2回答

如何使用SPRING批处理w/out将结果集转换为临时对象列表或映射从一个数据库写入另一个数据库？

java、spring-batch

步骤：没有数据库链接。

浏览 4提问于2011-11-15得票数 4

点击加载更多