CQL 模板 API (CQL Template API) | Spring Data for Apache Cassandra4.4.0-M1中文文档|Spring官方文档|SpringBoot 教程|Spring中文网

此版本仍在开发中，尚未被视为稳定版本。对于最新的稳定版本，请使用 Spring Data Cassandra 4.3.4！spring-doc.cn

CqlTemplate 类（及其反应式变体 ReactiveCqlTemplate）是核心 CQL 包中的中心类。它处理资源的创建和释放。它执行核心 CQL 工作流的基本任务，例如语句创建和执行，并让应用程序代码提供 CQL 和提取结果。该类执行 CQL 查询和更新语句，对实例执行迭代并提取返回的参数值。它还捕获 CQL 异常，并将它们转换为包中定义的通用、信息量更大的异常层次结构。CqlTemplateResultSetorg.springframework.daospring-doc.cn

当您使用 for your code 时，您只需实现回调接口，这些接口具有明确定义的协定。给定一个，PreparedStatementCreator 回调接口使用提供的 CQL 和任何必要的参数参数创建一个准备好的语句。 RowCallbackHandler 接口从 .CqlTemplateCqlSessionResultSetspring-doc.cn

CqlTemplate可以通过使用SessionFactory引用的直接实例化在 DAO 实现中使用，也可以在 Spring 容器中进行配置并作为 Bean 引用提供给 DAO。是 CassandraTemplate 的基础构建块。CqlTemplatespring-doc.cn

此类发出的所有 CQL 都记录在与模板实例的完全限定类名相对应的 category 下的级别（通常为，但如果您使用类的自定义子类，则可能会有所不同）。DEBUGCqlTemplateCqlTemplatespring-doc.cn

您可以通过在 CQL API 实例上配置以下参数来控制提取大小、一致性级别和重试策略默认值：CqlTemplate、AsyncCqlTemplate 和 ReactiveCqlTemplate。如果未设置特定查询选项，则默认值适用。spring-doc.cn

CqlTemplate具有不同的执行模型风格。基本使用阻塞执行模型。您可以用于异步执行和与实例同步，也可以用于反应执行。CqlTemplateAsyncCqlTemplateListenableFutureReactiveCqlTemplate

类用法示例`CqlTemplate`

本节提供了该类的一些实际示例。这些示例并不是 . 请参阅 Javadoc 了解这一点。CqlTemplateCqlTemplatespring-doc.cn

查询（SELECT）`CqlTemplate`

以下查询获取表中的行数：spring-doc.cn

Imperativespring-doc.cn
Reactivespring-doc.cn

int rowCount = cqlTemplate.queryForObject("SELECT COUNT(*) FROM t_actor", Integer.class);

Mono<Integer> rowCount = reactiveCqlTemplate.queryForObject("SELECT COUNT(*) FROM t_actor", Integer.class);

以下查询使用 bind 变量：spring-doc.cn

Imperativespring-doc.cn
Reactivespring-doc.cn

int countOfActorsNamedJoe = cqlTemplate.queryForObject(
		"SELECT COUNT(*) FROM t_actor WHERE first_name = ?", Integer.class, "Joe");

Mono<Integer> countOfActorsNamedJoe = reactiveCqlTemplate.queryForObject(
	"SELECT COUNT(*) FROM t_actor WHERE first_name = ?", Integer.class, "Joe");

以下示例查询：Stringspring-doc.cn

Imperativespring-doc.cn
Reactivespring-doc.cn

String lastName = cqlTemplate.queryForObject(
		"SELECT last_name FROM t_actor WHERE id = ?",
		String.class, 1212L);

Mono<String> lastName = reactiveCqlTemplate.queryForObject(
	"SELECT last_name FROM t_actor WHERE id = ?",
	String.class, 1212L);

以下示例查询并填充单个域对象：spring-doc.cn

Imperativespring-doc.cn
Reactivespring-doc.cn

Actor actor = cqlTemplate.queryForObject("SELECT first_name, last_name FROM t_actor WHERE id = ?",
		new RowMapper<Actor>() {
			public Actor mapRow(Row row, int rowNum) {
				Actor actor = new Actor();
				actor.setFirstName(row.getString("first_name"));
				actor.setLastName(row.getString("last_name"));
				return actor;
			}
		}, 1212L);

Mono<Actor> actor = reactiveCqlTemplate.queryForObject(
	"SELECT first_name, last_name FROM t_actor WHERE id = ?",
	new RowMapper<Actor>() {
		public Actor mapRow(Row row, int rowNum) {
			Actor actor = new Actor();
			actor.setFirstName(row.getString("first_name"));
			actor.setLastName(row.getString("last_name"));
			return actor;
		}},
	1212L);

以下示例查询并填充多个域对象：spring-doc.cn

Imperativespring-doc.cn
Reactivespring-doc.cn

List<Actor> actors = cqlTemplate.query(
		"SELECT first_name, last_name FROM t_actor",
		new RowMapper<Actor>() {
			public Actor mapRow(Row row, int rowNum) {
				Actor actor = new Actor();
				actor.setFirstName(row.getString("first_name"));
				actor.setLastName(row.getString("last_name"));
				return actor;
			}
		});

Flux<Actor> actors = reactiveCqlTemplate.query(
"SELECT first_name, last_name FROM t_actor",
	new RowMapper<Actor>() {
		public Actor mapRow(Row row, int rowNum) {
			Actor actor = new Actor();
			actor.setFirstName(row.getString("first_name"));
			actor.setLastName(row.getString("last_name"));
			return actor;
		}
});

如果最后两个代码片段确实存在于同一个应用程序中，那么删除两个匿名内部类中存在的重复项并将它们提取到一个类（通常是嵌套类）中，然后由 DAO 方法引用是有意义的。RowMapperstaticspring-doc.cn

例如，最好按如下方式编写最后一个代码片段：spring-doc.cn

Imperativespring-doc.cn
Reactivespring-doc.cn

List<Actor> findAllActors() {
	return cqlTemplate.query("SELECT first_name, last_name FROM t_actor", ActorMapper.INSTANCE);
}

enum ActorMapper implements RowMapper<Actor> {

	INSTANCE;

	public Actor mapRow(Row row, int rowNum) {
		Actor actor = new Actor();
		actor.setFirstName(row.getString("first_name"));
		actor.setLastName(row.getString("last_name"));
		return actor;
	}
}

Flux<Actor> findAllActors() {
	return reactiveCqlTemplate.query("SELECT first_name, last_name FROM t_actor", ActorMapper.INSTANCE);
}

enum ActorMapper implements RowMapper<Actor> {

	INSTANCE;

	public Actor mapRow(Row row, int rowNum) {
		Actor actor = new Actor();
		actor.setFirstName(row.getString("first_name"));
		actor.setLastName(row.getString("last_name"));
		return actor;
	}
}

`INSERT`、和`UPDATEDELETECqlTemplate`

您可以使用该方法执行、、和操作。参数值通常作为变量参数提供，或者作为对象数组提供。execute(…)INSERTUPDATEDELETEspring-doc.cn

以下示例显示如何使用执行操作：INSERTCqlTemplatespring-doc.cn

Imperativespring-doc.cn
Reactivespring-doc.cn

cqlTemplate.execute(
		"INSERT INTO t_actor (first_name, last_name) VALUES (?, ?)",
		"Leonor", "Watling");

Mono<Boolean> applied = reactiveCqlTemplate.execute(
	"INSERT INTO t_actor (first_name, last_name) VALUES (?, ?)",
	"Leonor", "Watling");

以下示例显示如何使用执行操作：UPDATECqlTemplatespring-doc.cn

Imperativespring-doc.cn
Reactivespring-doc.cn

cqlTemplate.execute(
		"UPDATE t_actor SET last_name = ? WHERE id = ?",
		"Banjo", 5276L);

Mono<Boolean> applied = reactiveCqlTemplate.execute(
	"UPDATE t_actor SET last_name = ? WHERE id = ?",
	"Banjo", 5276L);

以下示例显示如何使用执行操作：DELETECqlTemplatespring-doc.cn

Imperativespring-doc.cn
Reactivespring-doc.cn

cqlTemplate.execute(
		"DELETE FROM t_actor WHERE id = ?",
		5276L);

Mono<Boolean> applied = reactiveCqlTemplate.execute(
	"DELETE FROM actor WHERE id = ?",
	actorId);

其他操作`CqlTemplate`

您可以使用该方法执行任何任意 CQL。因此，该方法通常用于 DDL 语句。它严重重载了采用回调接口、绑定变量数组等的变体。execute(..)spring-doc.cn

以下示例演示如何使用全部传递给方法的不同 API 对象来创建和删除表：execute()spring-doc.cn

		cqlTemplate.execute("CREATE TABLE test_table (id uuid primary key, event text)");

		DropTableSpecification dropper = DropTableSpecification.dropTable("test_table");
		String cql = DropTableCqlGenerator.toCql(dropper);

		cqlTemplate.execute(cql);

控制 Cassandra 连接

应用程序使用对象连接到 Apache Cassandra。 Cassandra 跟踪与各个节点的多个连接，并被设计为线程安全的长寿命对象。通常，您可以对整个应用程序使用 single。CqlSessionCqlSessionCqlSessionspring-doc.cn

Spring 通过 . 是 Spring Data for Apache Cassandra 的一部分，是一个通用连接工厂。它允许容器或框架在应用程序代码中隐藏连接处理和路由问题。CqlSessionSessionFactorySessionFactoryspring-doc.cn

以下示例显示如何配置 default ：SessionFactoryspring-doc.cn

Imperativespring-doc.cn
Reactivespring-doc.cn

CqlSession session = … // get a Cassandra Session

CqlTemplate template = new CqlTemplate();

template.setSessionFactory(new DefaultSessionFactory(session));

CqlSession session = … // get a Cassandra Session

ReactiveCqlTemplate template = new ReactiveCqlTemplate(new DefaultBridgedReactiveSession(session));

CqlTemplate和其他 Template API 实现为每个操作获取一个。由于会话的生命周期较长，因此在调用所需操作后不会关闭会话。正确处置资源的责任在于使用会话的容器或框架。CqlSessionspring-doc.cn

您可以在包中找到各种实现。SessionFactoryorg.springframework.data.cassandra.core.cql.sessionspring-doc.cn

异常转换

Spring Framework 为各种数据库和 Map 技术提供了异常转换。传统上，这是 JDBC 和 JPA 的专利。 Spring Data for Apache Cassandra 通过提供接口的实现，将此功能扩展到 Apache Cassandra。org.springframework.dao.support.PersistenceExceptionTranslatorspring-doc.cn

映射到 Spring 的一致数据访问异常层次结构的动机是让您编写可移植的描述性异常处理代码，而无需对特定的 Cassandra 异常进行编码和处理。 Spring 的所有数据访问异常都是从该类继承的，因此您可以确保可以在单个 try-catch 块中捕获所有与数据库相关的异常。DataAccessExceptionspring-doc.cn

ReactiveCqlTemplate并尽早传播异常。在处理反应序列期间发生的异常将作为错误信号发出。ReactiveCassandraTemplatespring-doc.cn

类用法示例CqlTemplate

查询 （SELECT）CqlTemplate

INSERT、 和UPDATEDELETECqlTemplate