如何在Spring Data Cassandra中创建自动处理类型转换的Statement？

针对Spring Data Cassandra中使用UDT类型时创建Statement的问题，有两种无需手动转换参数的直接实现方式：

1. 使用Spring Data的Update构建器 + CassandraTemplate #

通过Spring Data提供的API构建更新操作，完全避开原生CQL的手动拼接，Spring会自动处理UDT类型转换：

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

// 注入Spring管理的CassandraTemplate实例
private final CassandraTemplate cassandraTemplate;

// 执行UDT列表追加更新
public void appendProfilePictures(List<MyPicture> pictures, String userId) {
    Query query = Query.query(Criteria.where("id").is(userId));
    Update update = Update.update("profilePictures", "profilePictures + ?", pictures);
    cassandraTemplate.update(query, update, User.class);
}

这种方式依赖Spring Data的MappingCassandraConverter自动完成List<MyPicture>到Cassandra UDT列表的转换，无需手动调用转换器处理参数。

2. 使用CqlTemplate执行原生CQL #

如果需要保留原生CQL写法，可以通过CqlTemplate执行语句，它会自动利用Spring的转换体系处理UDT参数：

import org.springframework.data.cassandra.core.CqlTemplate;

// 注入Spring管理的CqlTemplate实例
private final CqlTemplate cqlTemplate;

// 执行UDT列表追加更新
public void appendProfilePictures(List<MyPicture> pictures, String userId) {
    String cql = "UPDATE User SET profilePictures = profilePictures + ? WHERE id = ?";
    cqlTemplate.update(cql, pictures, userId);
}

CqlTemplate内部会自动将自定义UDT实体类转换为Cassandra驱动可识别的类型，避免了直接使用SimpleStatement时的Codec缺失问题。

原理说明 #

直接使用Cassandra原生驱动的SimpleStatement.newInstance时，驱动无法识别Spring Data定义的UDT映射规则；而CassandraTemplate和CqlTemplate都集成了Spring Data的转换机制，会自动调用MappingCassandraConverter完成Java对象与Cassandra数据类型的转换。

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