java - AsyncCqlTemplate 缓存带插入的准备语句

Question

我正在使用 spring-data-cassandra 2.0.7.RELEASE，但我很难弄清楚如何获取缓存准备好的语句。

以类似的方式，我使用了 CqlTemplate 模板并创建了一个 PreparedStatementCache 并且能够创建一个缓存的准备好的语句，如下所示:

    PreparedStatementCreator preparedStatementCreator = ...;
    PreparedStatementBinder  binder                   = ...;

    return selectCqlTemplate.query(preparedStatementCreator,
                                   binder,
                                   resultSetExtractor);

对于 AsyncCqlTemplate，我看到有一个 AsyncPreparedStatementCreator，但不太清楚如何创建其中之一，因为唯一的实现是 SimpleAsyncPreparedStatementCreator，它是私有(private)的。

所以我的问题是，对于插入语句，使用 AsyncCqlTemplate 并拥有缓存的准备好的语句的最佳方法是什么？

Answer 1

Spring Data for Apache Cassandra 不提供内置异步 PreparedStatement 缓存。它仅附带一个同步同步( CachedPreparedStatementCreator 、 PreparedStatementCache )。

实现异步缓存需要在同步方面付出一些努力，并避免重复的准备调用。

一个简单的实现可能如下所示:

public class AsyncCachedPreparedStatementCreator implements AsyncPreparedStatementCreator, CqlProvider {

    private final String cql;

    private final Map<Session, com.google.common.util.concurrent.ListenableFuture<PreparedStatement>> cache = new ConcurrentHashMap<>();

    public AsyncCachedPreparedStatementCreator(String cql) {
        this.cql = cql;
    }

    @Override
    public ListenableFuture<PreparedStatement> createPreparedStatement(Session session) throws DriverException {

        com.google.common.util.concurrent.ListenableFuture<PreparedStatement> future = cache.computeIfAbsent(session,
                s -> s.prepareAsync(cql));

        return new GuavaListenableFutureAdapter<>(future, new CassandraExceptionTranslator());
    }

    @Override
    public String getCql() {
        return cql;
    }
}

此实现假定每个Session 缓存并将其缓存保存在ConcurrentHashMap 中。