JDBC 批处理操作 (JDBC Batch Operations) _ Spring Framework 6.1.10 中文文档(官方文档中文翻译) —

如果对同一 JDBC 进行多个调用，则大多数 JDBC 驱动程序都会提供改进的性能准备好的语句。通过将更新分组到批处理中，可以限制往返次数到数据库。Spring中文文档

基本批处理操作`JdbcTemplate`

通过实现特殊接口的两种方法，并将该实现作为第二个参数传入，可以完成批处理在方法调用中。您可以使用该方法提供当前批次。您可以使用该方法设置准备好的语句。此方法调用您在调用中指定的次数。以下示例根据列表中的条目更新表，整个列表用作批处理：JdbcTemplateBatchPreparedStatementSetterbatchUpdategetBatchSizesetValuesgetBatchSizet_actorSpring中文文档

JavaSpring中文文档
KotlinSpring中文文档

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
}

如果处理更新流或从文件中读取，则可能会有一个首选批大小，但最后一批可能没有该数量的条目。在这个情况下，您可以使用该接口，它允许一旦输入源耗尽，您就会中断批处理。方法允许您发出批处理结束的信号。InterruptibleBatchPreparedStatementSetterisBatchExhaustedSpring中文文档

使用对象列表进行批处理操作

和都提供了另一种方式提供批量更新。无需实现特殊的批处理接口，而是以列表形式提供调用中的所有参数值。框架循环覆盖这些值并使用内部预备语句设置器。API 各不相同，具体取决于是否使用命名参数。对于命名参数，您可以为批处理的每个成员提供一个的数组，一个条目。您可以使用方便的方法创建此数组，通过在 Bean 样式对象数组中（具有与参数对应的 getter 方法）、-keyed 实例（包含相应的参数作为值）或两者的混合。JdbcTemplateNamedParameterJdbcTemplateSqlParameterSourceSqlParameterSourceUtils.createBatchStringMapSpring中文文档

以下示例显示了使用命名参数的批量更新：Spring中文文档

JavaSpring中文文档
KotlinSpring中文文档

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 语句中定义。?Spring中文文档

以下示例与前面的示例相同，只是它使用 classic JDBC 占位符：?Spring中文文档

JavaSpring中文文档
KotlinSpring中文文档

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-2Spring中文文档

在这种情况下，通过自动设置基础值，每个值的相应 JDBC 类型需要从给定的 Java 类型派生。虽然这通常效果很好，但可能会出现问题（例如，包含 Map 的值）。默认情况下，Spring 调用这样的案例，这对于您的 JDBC 驱动程序来说可能很昂贵。您应该使用最近的驱动程序版本，并考虑将属性设置为（作为 JVM 系统属性或通过 SpringProperties 机制），如果您遇到性能问题（如 Oracle 12c、JBoss 和 PostgreSQL 上报告的那样）。PreparedStatementnullParameterMetaData.getParameterTypespring.jdbc.getParameterType.ignoretrueSpring中文文档

或者，您可以考虑显式指定相应的 JDBC 类型，通过 a（如前所述），通过显式类型数组通过对自定义实例，或者通过从 Java 声明的属性类型派生 SQL 类型，即使对于 null 值也是如此。BatchPreparedStatementSetterList<Object[]>registerSqlTypeMapSqlParameterSourceBeanPropertySqlParameterSourceSpring中文文档

具有多个批处理的批处理操作

前面的批量更新示例处理的批处理量太大，以至于您想要将它们分解成几个较小的批次。您可以使用以下方法执行此操作前面通过对方法进行多次调用来提到，但现在有一个更方便的方法。除了 SQL 语句之外，此方法还对包含参数的对象进行更新，以及要对每个对象进行的更新次数 batch 和 a 设置参数的值准备好的声明。框架循环访问提供的值并中断将调用更新为指定大小的批处理。batchUpdateCollectionParameterizedPreparedStatementSetterSpring中文文档

以下示例演示使用批大小 100 的批处理更新：Spring中文文档

JavaSpring中文文档
KotlinSpring中文文档

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-2Spring中文文档

基本批处理操作JdbcTemplate

使用对象列表进行批处理操作

具有多个批处理的批处理操作

基本批处理操作`JdbcTemplate`