Spring Cassandra是CachedPreparedStatementCreator类threadsafe？

Question

我们正在使用Spring Cassandra和数据税驱动程序使用CachedPreparedStatementCreator/PreparedStatement向Cassandr发出请求。在启动时，这些WARN消息显示在日志文件中（还有其他消息，这只是一个例子）

:WARN LG:com . datas tax . driver . core . cluster-重新准备已经准备好的查询insert into active (id) values(？)用TTL？。请注意，多次准备同一个查询通常是一种反模式，可能会影响性能。考虑只准备一次语句。

预准备语句是使用高速缓存预语句创建器类创建的。查看源代码，似乎存在“争用条件”，并且实现不是线程安全的。

         Map<String, PreparedStatement> sessionMap = psMap.get(session);

        if (sessionMap == null) {

              sessionMap = new ConcurrentHashMap<String, PreparedStatement>();

              psMap.put(session, sessionMap);

        }



        PreparedStatement pstmt = sessionMap.get(keyspaceCQLKey.toString());

        if (pstmt == null) {

              log.debug("No Cached PreparedStatement found...Creating and Caching");

              pstmt = session.prepare(this.cql);

              sessionMap.put(keyspaceCQLKey.toString(), pstmt);

        } else {

              log.debug("Found cached PreparedStatement");

        }

这门课的目的是什么？它应该是线程安全的吗？有人知道这个缓存的性能吗？

Answer 1

在检查语句是否存在和创建一个新的准备好的语句之间肯定存在竞争条件。我会寻求一个类似于ReentantReadWriteLock文档中的解决方案。

请注意，在实现写锁定后，将验证该值仍然存在。这将解决您在此处看到的情况。

考虑在Spring数据卡桑德拉JIRA中提交票证或在Github上提交PR。