Apache Cassandra 的 Sprin
寂寞的心情wang 发布于2021-12 浏览:1199 回复:0
0
收藏

9.8.1.实例化 CassandraTemplate
CassandraTemplate应该始终配置为 Spring bean,尽管我们之前展示了一个示例,您可以在其中直接实例化它。但是,因为我们假设了创建 Spring 模块的上下文,所以我们假设存在 Spring 容器。

有两种方法可以获取 a CassandraTemplate,具体取决于您加载 Spring 的方式ApplicationContext:

自动装配
Bean 查找 ApplicationContext
自动装配
您可以将 a 自动装配CassandraOperations到您的项目中,如以下示例所示:

@Autowired
private CassandraOperations cassandraOperations;
同所有的Spring自动装配,这是假定只有一种类型的豆CassandraOperations中ApplicationContext。如果您有多个CassandraTemplatebean(如果您在同一个项目中使用多个键空间就是这种情况),那么您可以使用@Qualifier注释来指定要自动装配的 bean。

@Autowired
@Qualifier("keyspaceOneTemplateBeanId")
private CassandraOperations cassandraOperations;
Bean 查找ApplicationContext
您还可以CassandraTemplate从 中查找bean ApplicationContext,如以下示例所示:

CassandraOperations cassandraOperations = applicationContext.getBean("cassandraTemplate", CassandraOperations.class);
9.9.保存、更新和删除行
CassandraTemplate 为您提供了一种简单的方法来保存、更新和删除域对象并将这些对象映射到 Cassandra 中管理的表。

9.9.1.类型映射
Spring Data for Apache Cassandra 依赖于 DataStax Java 驱动程序CodecRegistry来确保类型支持。随着类型的添加或更改,Apache Cassandra 模块的 Spring Data 继续运行而无需更改。有关当前类型映射矩阵,请参阅CQL 数据类型 和“数据映射和类型转换”。

9.9.2.插入和更新行的方法
CassandraTemplate有几种方便的方法来保存和插入您的对象。要对转换过程进行更细粒度的控制,您可以Converter使用MappingCassandraConverter (例如,Converter)注册 Spring实例。

插入和更新操作的区别在于INSERT操作不插入null值。

使用该INSERT操作的简单案例是保存一个 POJO。在这种情况下,表名由简单的类名(而不是完全限定的类名)确定。可以使用映射元数据覆盖存储对象的表。

插入或更新时,id必须设置该属性。Apache Cassandra 无法生成 ID。

以下示例使用保存操作并检索其内容:

示例 64. 使用 CassandraTemplate

import static org.springframework.data.cassandra.core.query.Criteria.where;
import static org.springframework.data.cassandra.core.query.Query.query;

Person bob = new Person("Bob", 33);
cassandraTemplate.insert(bob);

Person queriedBob = cassandraTemplate.selectOneById(query(where("age").is(33)), Person.class);
您可以使用以下操作进行插入和保存:

void insert (Object objectToSave):在 Apache Cassandra 表中插入对象。
WriteResult 插入 (Object objectToSave, InsertOptions options):在 Apache Cassandra 表中插入对象并应用InsertOptions。
您可以使用以下更新操作:

void update (Object objectToSave):更新 Apache Cassandra 表中的对象。
WriteResult 更新 (Object objectToSave, UpdateOptions options):更新 Apache Cassandra 表中的对象并应用UpdateOptions。
您还可以使用老式的方式编写自己的 CQL 语句,如下例所示:

String cql = "INSERT INTO person (age, name) VALUES (39, 'Bob')";

cassandraTemplate().getCqlOperations().execute(cql);
您还可以在使用InsertOptions和时配置其他选项,例如 TTL、一致性级别和轻量级事务UpdateOptions。

我的行插入到哪个表中?
您可以通过两种方式管理用于对表进行操作的表名。默认表名是更改为以小写字母开头的简单类名。因此,com.example.Person类的一个实例将存储在person表中。第二种方式是在@Table注解中指定表名。

批量插入、更新和删除单个对象
Cassandra 协议支持使用批处理在一个操作中插入一组行。

CassandraTemplate接口中的以下方法支持此功能:

batchOps:创建一个新CassandraBatchOperations的填充批次。
CassandraBatchOperations

insert: 接受单个对象、数组 (var-args) 或Iterable要插入的对象。
update: 接受单个对象、数组 (var-args) 或Iterable要更新的对象。
delete: 接受单个对象、数组 (var-args) 或Iterable要删除的对象。
withTimestamp:对批次应用 TTL。
execute: 执行批处理。
9.9.3.更新表中的行
对于更新,您可以选择更新多行。

以下示例显示了通过向具有+分配的余额添加一次性 50.00 美元奖金来更新单个帐户对象:

示例 65. 使用更新行 CasandraTemplate

import static org.springframework.data.cassandra.core.query.Criteria.where;
import org.springframework.data.cassandra.core.query.Query;
import org.springframework.data.cassandra.core.query.Update;

boolean applied = cassandraTemplate.update(Query.query(where("id").is("foo")),
Update.create().increment("balance", 50.00), Account.class);
除了Query前面讨论的之外,我们还通过使用Update对象来提供更新定义。该Update班有匹配可用的Apache Cassandra的更新任务,从而方法。

大多数方法返回Update对象以提供用于代码样式目的的流畅 API。

对行执行更新的方法
update方法可以更新行,如下:

boolean update (Query query, Update update, Class entityClass):更新 Apache Cassandra 表中的对象选择。
Update 类的方法
本Update类可以用一点点“语法糖”被使用,因为它的方法是为了链接在一起。此外,您可以使用静态Update方法public static Update update(String key, Object value)和使用静态导入来启动新实例的创建。

该Update班有以下方法:

AddToBuilder 添加到 (String columnName) AddToBuilder入口点:更新prepend(Object value):使用+更新分配将集合值预先添加到现有集合。更新prependAll(Object… values):使用+更新分配将所有集合值添加到现有集合中。更新append(Object value):使用+更新分配将集合值附加到现有集合。更新append(Object… values):使用+更新分配将所有集合值附加到现有集合。更新entry(Object key, Object value):使用+更新分配添加地图条目。更新addAll(Map map):使用+更新分配将所有地图条目添加到地图。
Update remove (String columnName, Object value):使用-更新分配从集合中删除值。
Update clear (String columnName) : 清除集合。
Update increment (String columnName, Number delta):使用+更新分配进行更新。
Update decrement (String columnName, Number delta):使用-更新分配进行更新。
Update set (String columnName, Object value):使用=更新分配进行更新。
SetBuilder 设置 (String columnName) SetBuilder入口点:更新atIndex(int index).to(Object value):使用=更新分配将给定索引处的集合设置为一个值。更新atKey(String object).to(Object value):将给定键处的映射条目设置为=更新分配的值。
以下清单显示了一些更新示例:

// UPDATE … SET key = 'Spring Data';
Update.update("key", "Spring Data")

// UPDATE … SET key[5] = 'Spring Data';
Update.empty().set("key").atIndex(5).to("Spring Data");

// UPDATE … SET key = key + ['Spring', 'DATA'];
Update.empty().addTo("key").appendAll("Spring", "Data");
请注意,Update一旦创建,它就是不可变的。调用方法会创建新的不可变(中间)Update对象。

9.9.4.删除行的方法
您可以使用以下重载方法从数据库中删除对象:

boolean 删除 (Query query, Class entityClass):删除由 选择的对象Query。
T delete (T entity) : 删除给定的对象。
T delete (T entity, QueryOptions queryOptions):删除给定的对象应用QueryOptions。
boolean deleteById (Object id, Class entityClass):使用给定的 Id 删除对象。
9.9.5.乐观锁定
该@Version注释在 Cassandra 的上下文中提供类似于 JPA 的语法,并确保更新仅应用于具有匹配版本的行。乐观锁利用 Cassandra 的轻量级事务来有条件地插入、更新和删除行。因此,INSERT语句是在IF NOT EXISTS条件下执行的。对于更新和删除,版本属性的实际值被添加到UPDATE条件中,这样如果在此期间另一个操作更改了行,则修改不会产生任何影响。在这种情况下,
OptimisticLockingFailureException会抛出an 。以下示例显示了这些功能:

@Table
class Person {

@Id String id;
String firstname;
String lastname;
@Version Long version;
}

Person daenerys = template.insert(new Person("Daenerys"));

Person tmp = template.findOne(query(where("id").is(daenerys.getId())), Person.class);

daenerys.setLastname("Targaryen");
template.save(daenerys);

template.save(tmp); // throws OptimisticLockingFailureException
最初插入文档。version设置为0。

加载刚刚插入的文档。version还在0。

用 更新文档version = 0。将lastname和设置version为1。

尝试更新先前加载的文档,但仍有version = 0. 操作失败并显示
OptimisticLockingFailureException,因为当前version是1。

 
乐观锁定仅支持单实体操作,不支持批处理操作。

9.10.查询行
你可以表达使用您的查询Query和Criteria类别,其中有反映本地卡桑德拉谓词运营商名称,如方法名lt,lte,is,等。

在Query和Criteria类遵循流畅API风格,让您可以轻松地串联多个方法标准和查询在一起,同时具有易于理解的代码。在 Java 中创建Query 和Criteria实例时使用静态导入以提高可读性。

9.10.1.查询表中的行
在前面的部分中,我们看到了如何使用selectOneByIdon 方法检索单个对象CassandraTemplate。这样做会返回单个域对象。我们还可以查询要作为域对象列表返回的行集合。假设我们有许多Person名称和年龄值作为行存储在表中的对象,并且每个人都有一个帐户余额,我们现在可以使用以下代码运行查询:

示例 66. 查询行使用 CassandraTemplate

import static org.springframework.data.cassandra.core.query.Criteria.where;
import static org.springframework.data.cassandra.core.query.Query.query;

List result = cassandraTemplate.select(query(where("age").is(50))
.and(where("balance").gt(1000.00d)).withAllowFiltering(), Person.class);
的select,selectOne和stream方法采取一个Query对象作为参数。此对象定义用于执行查询的条件和选项。该标准是通过使用一个Criteria对象来指定的,该对象具有一个名为where实例化新Criteria对象的静态工厂方法。我们建议对
org.springframework.data.cassandra.core.query.Criteria.whereand使用静态导入Query.query,以使查询更具可读性。

此查询应返回Person满足指定条件的对象列表。的Criteria类有下列方法,对应于运营商的Apache卡桑德拉提供:

Criteria 类的方法
CriteriaDefinition gt (Object value):使用>运算符创建条件。
CriteriaDefinition gte (Object value):使用>=运算符创建条件。
CriteriaDefinition in (Object… values):通过IN对 varargs 参数使用运算符来创建条件。
CriteriaDefinition in (Collection collection):通过使用IN集合的运算符创建条件。
CriteriaDefinition is (Object value):通过使用字段匹配 ( column = value)创建条件。
CriteriaDefinition lt (Object value):使用<运算符创建条件。
CriteriaDefinition lte (Object value):使用⇐运算符创建条件。
CriteriaDefinition like (Object value):使用LIKE运算符创建条件。
CriteriaDefinition contains (Object value):使用CONTAINS运算符创建条件。
CriteriaDefinition containsKey (Object key):使用CONTAINS KEY运算符创建条件。
Criteria 一经创建即不可变。

Query 类的方法
本Query类有一些额外的方法,你可以用它来提供的查询选项:

Query by (CriteriaDefinition…​ criteria):用于创建Query对象。
Query 和 (CriteriaDefinition criteria):用于向查询添加附加条件。
Query columns (Columns columns):用于定义要包含在查询结果中的列。
Query limit (long limit):用于将返回结果的大小限制为提供的限制(用于分页)。
Query pageRequest (Pageable pageRequest):用于关联Sort,PagingState以及fetchSize与查询(用于寻呼)。
Query pagingState (ByteBuffer pagingState):用于将 aByteBuffer与查询关联(用于分页)。
Query queryOptions (QueryOptions queryOptions):用于QueryOptions与查询关联。
Query sort (Sort sort):用于为结果提供排序定义。
Query withAllowFiltering ():用于呈现ALLOW FILTERING查询。
Query一经创建即不可变。调用方法会创建新的不可变(中间)Query对象。

9.10.2.查询行的方法
本Query类有以下方法,返回行:

List select (Query query, Class entityClass):T从表中查询类型的对象列表。
T selectOne (Query query, Class entityClass):T从表中查询单个类型的对象。
Slice slice (Query query, Class entityClass):通过从表中查询 a Sliceof 类型的对象来开始或继续分页T。
Stream stream (Query query, Class entityClass):T从表中查询类型对象的流。
List select (String cql, Class entityClass):T通过提供 CQL 语句对表中类型对象列表的临时查询。
T selectOne (String cql, Class entityClass):T通过提供 CQL 语句对表中的单个类型对象进行临时查询。
Stream stream (String cql, Class entityClass):T通过提供 CQL 语句对表中类型的对象流进行临时查询。
查询方法必须指定T返回的目标类型。

9.10.3.流畅的模板API
CassandraOperations当涉及到与 Apache Cassandra 的更底层交互时,该接口是核心组件之一。它提供了广泛的方法。您可以为每个方法找到多个重载。它们中的大多数涵盖了 API 的可选(可为空)部分。

FluentCassandraOperations为CassandraOperations 提供更易读、更流畅的 API 的常用方法提供更窄的接口。入口点(query(…)、insert(…)、update(…)和delete(…))遵循基于要执行的操作的自然命名方案。从入口点开始,该 API 旨在仅提供依赖于上下文的方法,引导开发人员使用调用实际CassandraOperation. 以下示例显示了流畅的 API:

List all = ops.query(SWCharacter.class)
.inTable("star_wars")
.all();
如果使用类名SWCharacter定义表名@Table或使用类名作为表名没有问题,请跳过此步骤。

如果 Cassandra 中的一个表包含不同类型的实体,例如Jedi在一个 Table of 中的实体SWCharacters,则可以使用不同的类型来映射查询结果。您可以使用as(Class targetType)将结果映射到不同的目标类型,同时query(Class entityType)仍然适用于查询和表名。以下示例使用query和as方法:

List all = ops.query(SWCharacter.class)
.as(Jedi.class)
.matching(query(where("jedi").is(true)))
.all();
查询字段根据SWCharacter类型进行映射。

结果行被映射到Jedi.

您可以直接应用于预测由仅提供以产生的文件interface通过类型as(Class)。

终止方法 ( first(), one(), all(), 和stream()) 处理检索单个实体和检索多个实体之间的切换List或Stream类似操作。

新流利的模板API方法(即query(..),insert(..),update(..)和delete(..))使用有效线程安全的支持对象组成的CQL语句。然而,它带来了额外的年轻代 JVM 堆开销的额外成本,因为设计基于各种 CQL 语句组件的最终字段和变异构造。在可能插入或删除大量对象时(例如在循环内部),您应该小心。

收藏
点赞
0
个赞
TOP
切换版块