如果对同一 JDBC 进行多个调用,则大多数 JDBC 驱动程序都会提供改进的性能 准备好的语句。通过将更新分组到批处理中,可以限制往返次数 到数据库。
基本批处理操作JdbcTemplate
通过实现特殊接口的两种方法,并将该实现作为第二个参数传入,可以完成批处理
在方法调用中。您可以使用该方法提供
当前批次。您可以使用该方法设置
准备好的语句。此方法调用您在调用中指定的次数。以下示例根据列表中的条目更新表,
整个列表用作批处理:JdbcTemplate
BatchPreparedStatementSetter
batchUpdate
getBatchSize
setValues
getBatchSize
t_actor
-
Java
-
Kotlin
public class JdbcActorDao implements ActorDao {
private JdbcTemplate jdbcTemplate;
public void setDataSource(DataSource dataSource) {
this.jdbcTemplate = new JdbcTemplate(dataSource);
}
public int[] batchUpdate(final List<Actor> actors) {
return this.jdbcTemplate.batchUpdate(
"update t_actor set first_name = ?, last_name = ? where id = ?",
new BatchPreparedStatementSetter() {
public void setValues(PreparedStatement ps, int i) throws SQLException {
Actor actor = actors.get(i);
ps.setString(1, actor.getFirstName());
ps.setString(2, actor.getLastName());
ps.setLong(3, actor.getId().longValue());
}
public int getBatchSize() {
return actors.size();
}
});
}
// ... additional methods
}
class JdbcActorDao(dataSource: DataSource) : ActorDao {
private val jdbcTemplate = JdbcTemplate(dataSource)
fun batchUpdate(actors: List<Actor>): IntArray {
return jdbcTemplate.batchUpdate(
"update t_actor set first_name = ?, last_name = ? where id = ?",
object: BatchPreparedStatementSetter {
override fun setValues(ps: PreparedStatement, i: Int) {
ps.setString(1, actors[i].firstName)
ps.setString(2, actors[i].lastName)
ps.setLong(3, actors[i].id)
}
override fun getBatchSize() = actors.size
})
}
// ... additional methods
}
如果处理更新流或从文件中读取,则可能会有一个
首选批大小,但最后一批可能没有该数量的条目。在这个
情况下,您可以使用该接口,它允许
一旦输入源耗尽,您就会中断批处理。方法
允许您发出批处理结束的信号。InterruptibleBatchPreparedStatementSetter
isBatchExhausted
使用对象列表进行批处理操作
和 都提供了另一种方式
提供批量更新。无需实现特殊的批处理接口,而是
以列表形式提供调用中的所有参数值。框架循环覆盖这些
值并使用内部预备语句设置器。API 各不相同,具体取决于
是否使用命名参数。对于命名参数,您可以为批处理的每个成员提供一个 的数组 ,一个条目。您可以使用方便的方法创建此数组,通过
在 Bean 样式对象数组中(具有与参数对应的 getter 方法)、-keyed 实例(包含相应的参数作为值)或两者的混合。JdbcTemplate
NamedParameterJdbcTemplate
SqlParameterSource
SqlParameterSourceUtils.createBatch
String
Map
以下示例显示了使用命名参数的批量更新:
-
Java
-
Kotlin
public class JdbcActorDao implements ActorDao {
private NamedParameterTemplate namedParameterJdbcTemplate;
public void setDataSource(DataSource dataSource) {
this.namedParameterJdbcTemplate = new NamedParameterJdbcTemplate(dataSource);
}
public int[] batchUpdate(List<Actor> actors) {
return this.namedParameterJdbcTemplate.batchUpdate(
"update t_actor set first_name = :firstName, last_name = :lastName where id = :id",
SqlParameterSourceUtils.createBatch(actors));
}
// ... additional methods
}
class JdbcActorDao(dataSource: DataSource) : ActorDao {
private val namedParameterJdbcTemplate = NamedParameterJdbcTemplate(dataSource)
fun batchUpdate(actors: List<Actor>): IntArray {
return this.namedParameterJdbcTemplate.batchUpdate(
"update t_actor set first_name = :firstName, last_name = :lastName where id = :id",
SqlParameterSourceUtils.createBatch(actors));
}
// ... additional methods
}
对于使用经典占位符的 SQL 语句,请传入一个列表
包含具有更新值的对象数组。此对象数组必须有一个条目
对于 SQL 语句中的每个占位符,并且它们的顺序必须与它们相同
在 SQL 语句中定义。?
以下示例与前面的示例相同,只是它使用 classic
JDBC 占位符:?
-
Java
-
Kotlin
public class JdbcActorDao implements ActorDao {
private JdbcTemplate jdbcTemplate;
public void setDataSource(DataSource dataSource) {
this.jdbcTemplate = new JdbcTemplate(dataSource);
}
public int[] batchUpdate(final List<Actor> actors) {
List<Object[]> batch = new ArrayList<>();
for (Actor actor : actors) {
Object[] values = new Object[] {
actor.getFirstName(), actor.getLastName(), actor.getId()};
batch.add(values);
}
return this.jdbcTemplate.batchUpdate(
"update t_actor set first_name = ?, last_name = ? where id = ?",
batch);
}
// ... additional methods
}
class JdbcActorDao(dataSource: DataSource) : ActorDao {
private val jdbcTemplate = JdbcTemplate(dataSource)
fun batchUpdate(actors: List<Actor>): IntArray {
val batch = mutableListOf<Array<Any>>()
for (actor in actors) {
batch.add(arrayOf(actor.firstName, actor.lastName, actor.id))
}
return jdbcTemplate.batchUpdate(
"update t_actor set first_name = ?, last_name = ? where id = ?", batch)
}
// ... additional methods
}
我们前面介绍的所有批量更新方法都返回一个数组
包含每个批处理条目的受影响行数。此计数由以下人员报告
JDBC 驱动程序。如果计数不可用,则 JDBC 驱动程序将返回值 。int
-2
在这种情况下,通过自动设置基础值 ,
每个值的相应 JDBC 类型需要从给定的 Java 类型派生。
虽然这通常效果很好,但可能会出现问题(例如,包含 Map 的值)。默认情况下,Spring 调用这样的
案例,这对于您的 JDBC 驱动程序来说可能很昂贵。您应该使用最近的驱动程序
版本,并考虑将属性设置为(作为 JVM 系统属性或通过 或者,您可以考虑显式指定相应的 JDBC 类型,
通过 a(如前所述),通过显式类型
数组通过对
自定义实例,或者通过从 Java 声明的属性类型派生 SQL 类型,即使对于 null 值也是如此。 |
具有多个批处理的批处理操作
前面的批量更新示例处理的批处理量太大,以至于您想要
将它们分解成几个较小的批次。您可以使用以下方法执行此操作
前面通过对方法进行多次调用来提到,但现在有一个
更方便的方法。除了 SQL 语句之外,此方法还对包含参数的对象进行更新,以及要对每个对象进行的更新次数
batch 和 a 设置参数的值
准备好的声明。框架循环访问提供的值并中断
将调用更新为指定大小的批处理。batchUpdate
Collection
ParameterizedPreparedStatementSetter
以下示例演示使用批大小 100 的批处理更新:
-
Java
-
Kotlin
public class JdbcActorDao implements ActorDao {
private JdbcTemplate jdbcTemplate;
public void setDataSource(DataSource dataSource) {
this.jdbcTemplate = new JdbcTemplate(dataSource);
}
public int[][] batchUpdate(final Collection<Actor> actors) {
int[][] updateCounts = jdbcTemplate.batchUpdate(
"update t_actor set first_name = ?, last_name = ? where id = ?",
actors,
100,
(PreparedStatement ps, Actor actor) -> {
ps.setString(1, actor.getFirstName());
ps.setString(2, actor.getLastName());
ps.setLong(3, actor.getId().longValue());
});
return updateCounts;
}
// ... additional methods
}
class JdbcActorDao(dataSource: DataSource) : ActorDao {
private val jdbcTemplate = JdbcTemplate(dataSource)
fun batchUpdate(actors: List<Actor>): Array<IntArray> {
return jdbcTemplate.batchUpdate(
"update t_actor set first_name = ?, last_name = ? where id = ?",
actors, 100) { ps, argument ->
ps.setString(1, argument.firstName)
ps.setString(2, argument.lastName)
ps.setLong(3, argument.id)
}
}
// ... additional methods
}
此调用的批处理更新方法返回一个数组数组,其中包含
每个批次的数组条目,其中包含每个更新的受影响行数的数组。
顶级数组的长度表示运行的批处理数,第二级表示
数组的长度指示该批处理中的更新次数。中的更新次数
每个批次应为所有批次提供的批次大小(最后一个批次除外)
可能会更少),具体取决于提供的更新对象的总数。更新
每个更新语句的计数是 JDBC 驱动程序报告的计数。如果计数是
不可用时,JDBC 驱动程序返回值 。int
-2