最简单的情况是：

public class PrepStatementCache {
  private static ConcurrentHashMap<String, PreparedStatement> cache = new ConcurrentHashMap<>();

  static PreparedStatement getStatement(Session session, final String query) {
    return cache.computeIfAbsent(query,  q -> session.prepare(query));
  }
}

但由于map在计算过程中可能会被阻塞，因此实现该函数可能会更好 getStatement 具体如下：

static PreparedStatement getStatement(Session session, final String query) {
    PreparedStatement preparedStatement = cache.get(query);
    if (preparedStatement == null) {
      preparedStatement = session.prepare(query);
      if (preparedStatement != null) {
        PreparedStatement p2 = cache.putIfAbsent(query, preparedStatement);
        preparedStatement = p2 == null ? preparedStatement : p2;
      }
    }

    return preparedStatement;
  }

但是要考虑到，对于java驱动程序4，这是自动完成的，因此如果您要启动新项目，那么最好使用它，因为它包含更多的功能。