为什么 CQLDataLoader 返回键空间已存在而实际上不存在？

Question

我在创建之前检查了键空间是否存在，但两次检查都返回 null。但是，当我执行键空间创建 cql 文件时，它总是返回键空间已存在。我正在使用 org.cassandra:cassandra:cassandra-unit-spring:3.1.3.2 包。不知道如何解决这个问题。我有另一种方法“EmbeddedCassandraServerHelper.cleanEmbeddedCassandra()”，它似乎会删除键空间，因为在检查库键空间时它也会返回 null。所以在这一点上，我假设这是我的逻辑错误，但我无法弄清楚。

public static void setupEmbeddedCassandra(String cqlFile, String keyspaceName)
          throws IOException, TTransportException, InterruptedException {
    synchronized (lock) {
      if (finalKeyspace == null) {
        System.out.println(CLASS_NAME + " Setting up local embedded cassandra environment");
        EmbeddedCassandraServerHelper.startEmbeddedCassandra();

        int embeddedCassandraPort = EmbeddedCassandraServerHelper.getNativeTransportPort();
        System.setProperty("embeddedCassandraPort", String.valueOf(embeddedCassandraPort));
        cluster =
            (new Cluster.Builder())
                .addContactPoints(new String[] {"localhost"})
                .withPort(embeddedCassandraPort)
                .build();
        session = cluster.connect();
        cluster.getConfiguration();
        System.out.println(cluster.getMetadata().getKeyspace("library"));
        CQLDataLoader dataLoader = new CQLDataLoader(session);
        System.out.println(cluster.getMetadata().getKeyspace("library"));
        dataLoader.load(new ClassPathCQLDataSet(cqlFile, true, keyspaceName));
        System.out.println(
            CLASS_NAME
                + " Embedded Server started on port "
                + EmbeddedCassandraServerHelper.getNativeTransportPort());
      }
      finalKeyspace = keyspaceName;
    }
  }