Spring Data Cassandra和PresaredStatementCache

Question

我不明白如何使用Spring Data Cassandra实现非常简单的目标。

我想用不同的参数值多次执行“INSERT”语句。我目前没有映射域类，所以我使用SpringData提供的CqlOperations接口。

当我使用<代码>执行(字符串cql，对象...args)，Cassandra驱动程序抱怨“重新准备已经准备好的查询通常是一种反模式，可能会影响性能。考虑只准备一次语句”。因为Spring数据使用< code > SimplePreparedStatementCreator 。但是我看不出有什么方法可以告诉Spring Data使用< code > CachedPreparedStatementCreator 来代替。我只看到< code > execute(PreparedStatementCreator PSC)方法不允许我提供参数值。

那么，有没有办法告诉Spring Data使用正确的语句缓存或实现类似于执行的东西（准备声明创建者，对象...）？

Answer 1

CqlTemplate公开回调和自定义挂钩，允许根据应用程序的需要定制其部分功能。

CqlTemplate确实故意不进行缓存，因为缓存会导致时间与空间的考虑。春之数据卡桑德拉无法做出决策，因为我们无法假设应用程序通常需要什么。

Spring Data Cassandra的包＜code＞core.sql。support＜/code＞附带了对＜code＞CachedPreparedStatementCreator＜/code＞的支持，以及您可以用于此目的的＜code＜Prepared StatementCache＞。

子类＜code＞CqlTemplate＜/code＞并重写其＜code＞newPreparedStatementCreator（…）＜/code>方法，以指定要使用的＜code＞Prepared语句Creator＜/code＞。以下示例显示了具有无限保留的缓存的示例：

public class MyCachedCqlTemplate extends CqlTemplate {

    PreparedStatementCache cache = MapPreparedStatementCache.create();

    @Override
    protected PreparedStatementCreator newPreparedStatementCreator(String cql) {
        return CachedPreparedStatementCreator.of(cache, cql);
    }

}