如何从Oracle表并发获取数据到Java应用

你提到的用ROWID拆分查询是业内常用的并行读取思路，除此之外还有几种更成熟的标准化实现，适配不同场景：

1. ROWID范围拆分（你的思路落地版） #

Oracle的ROWID是记录的物理存储标识，能快速定位数据。可以按以下步骤拆分：

• 先拿到表的最小和最大ROWID：

  SELECT MIN(ROWID), MAX(ROWID) FROM your_table;
  

• 根据你要开的线程数，把ROWID区间切成N份，每个线程查自己的区间：

  SELECT * FROM your_table WHERE ROWID BETWEEN :start_rowid AND :end_rowid;
  

  注意：如果表做过重组（比如ALTER TABLE MOVE），ROWID会变，所以这个方案更适合静态或低频变更的表，优点是查询速度极快，无额外锁开销。

2. 主键/序列列范围拆分 #

如果表有自增主键（比如ID），这比ROWID更稳妥——不受表结构变更影响：

• 先查主键的最小最大值：

  SELECT MIN(id), MAX(id) FROM your_table;
  

• 按线程数均分区间，比如1000万条分4个线程，每个线程扛250万条的ID范围：

  SELECT * FROM your_table WHERE id BETWEEN :start_id AND :end_id;
  

  要是主键有间隙（比如删过数据），可以用NTILE()提前分片：

  SELECT id, NTILE(4) OVER(ORDER BY id) AS slice FROM your_table;
  

  之后每个线程只查对应slice的记录就行。

3. Oracle JDBC原生并行查询 #

Oracle JDBC驱动自带并行查询支持，不用手动拆分，直接靠驱动和数据库协作实现：

• 要么在JDBC URL里加参数：

  jdbc:oracle:thin:@//host:port/service?defaultRowPrefetch=250&parallel=true
  

• 要么在代码里给Statement设置：

  OracleStatement stmt = (OracleStatement) conn.createStatement();
  stmt.setParallel(true);
  stmt.setFetchSize(250);
  ResultSet rs = stmt.executeQuery("SELECT * FROM your_table");
  

  这个方案的前提是DBA已经给数据库开了并行权限（比如设置PARALLEL_MAX_SERVERS参数），优点是不用自己写拆分逻辑，驱动自动搞定。

4. 用批量处理框架封装好的分区能力 #

如果你的业务是批量处理，直接用Spring Batch这类框架的分区Step就行，它已经把并行读取的逻辑封装好了：

• 配置一个分区器，基于主键或ROWID切分数据范围；
• 框架自动给每个分区分配线程，处理读取和后续逻辑；
• 线程调度、异常重试这些杂事都不用你管，省代码。

踩坑提醒 #

• 并行拉数据会加数据库负载，别上来就开几十个线程，先从4-8个测起，看数据库CPU、IO扛不扛得住；
• 要是后续处理是CPU密集型，线程数别超CPU核心数；如果是IO密集型，可适当加几个；
• 尽量用无锁的范围查询，别搞表锁，不然会堵其他业务；
• 如果表有实时写入，要注意数据一致性——比如用FOR UPDATE SKIP LOCKED跳过被锁的记录，避免线程卡着等锁。

内容的提问来源于stack exchange，提问作者vs777