Datastax Cassandra似乎缓存了准备状态

Question

当我的应用程序长时间运行时，一切都会正常运行。但当我将列类型从int更改为text（删除表并重新创建）时，我发现了一个异常：

com.datastax.oss.driver.api.core.type.codec.CodecNotFoundException: Codec not found for requested operation: [INT <-> java.lang.String]
    at com.datastax.oss.driver.internal.core.type.codec.registry.CachingCodecRegistry.createCodec(CachingCodecRegistry.java:609)
    at com.datastax.oss.driver.internal.core.type.codec.registry.DefaultCodecRegistry$1.load(DefaultCodecRegistry.java:95)
    at com.datastax.oss.driver.internal.core.type.codec.registry.DefaultCodecRegistry$1.load(DefaultCodecRegistry.java:92)
    at com.datastax.oss.driver.shaded.guava.common.cache.LocalCache$LoadingValueReference.loadFuture(LocalCache.java:3527)
    at com.datastax.oss.driver.shaded.guava.common.cache.LocalCache$Segment.loadSync(LocalCache.java:2276)
    at com.datastax.oss.driver.shaded.guava.common.cache.LocalCache$Segment.lockedGetOrLoad(LocalCache.java:2154)
    at com.datastax.oss.driver.shaded.guava.common.cache.LocalCache$Segment.get(LocalCache.java:2044)
    at com.datastax.oss.driver.shaded.guava.common.cache.LocalCache.get(LocalCache.java:3951)
    at com.datastax.oss.driver.shaded.guava.common.cache.LocalCache.getOrLoad(LocalCache.java:3973)
    at com.datastax.oss.driver.shaded.guava.common.cache.LocalCache$LocalLoadingCache.get(LocalCache.java:4957)
    at com.datastax.oss.driver.shaded.guava.common.cache.LocalCache$LocalLoadingCache.getUnchecked(LocalCache.java:4963)
    at com.datastax.oss.driver.internal.core.type.codec.registry.DefaultCodecRegistry.getCachedCodec(DefaultCodecRegistry.java:117)
    at com.datastax.oss.driver.internal.core.type.codec.registry.CachingCodecRegistry.codecFor(CachingCodecRegistry.java:215)
    at com.datastax.oss.driver.api.core.data.SettableByIndex.set(SettableByIndex.java:132)
    at com.datastax.oss.driver.api.core.data.SettableByIndex.setString(SettableByIndex.java:338)

这个异常偶尔会出现。我正在使用准备语句执行查询，我认为它是从DataStax的驱动程序缓存的。

我正在使用AWS Keyspace（Cassandra版本3.11.2），DataStax驱动程序4.6。这是我的application.conf：

  basic.request {
    timeout = 5 seconds
    consistency = LOCAL_ONE
  }
  advanced.connection {
    max-requests-per-connection = 1024
    pool {
      local.size = 1
      remote.size = 1
    }
  }
  advanced.reconnect-on-init = true
  advanced.reconnection-policy {
    class = ExponentialReconnectionPolicy
    base-delay = 1 second
    max-delay = 60 seconds
  }
  advanced.retry-policy {
    class = DefaultRetryPolicy
  }
  advanced.protocol {
    version = V4
  }
  advanced.heartbeat {
   interval = 30 seconds
   timeout = 1 second
  }
  advanced.session-leak.threshold = 8
  advanced.metadata.token-map.enabled = false
}

Answer 1

没错。准备好的语句被缓存——如果准备好的语句被重用，这种优化会使它们更高效，因为它们只需要准备一次（查询不需要再次解析）。

但我怀疑您案例中的潜在问题是您的查询涉及 SELECT *。最佳做法建议（无论使用哪种数据库）是显式枚举要从表中检索的列。

在准备好的语句中，每一列都绑定到一个数据类型。当您通过添加/删除列来更改架构时，列的顺序（及其数据类型）不再与结果集的数据类型匹配，因此您最终会遇到驱动程序在期望text时获得int的情况，反之亦然。干杯！

Answer 2

是的，Java驱动程序4. x缓存准备好的语句-它与驱动程序3. x不同。从留档：

会话具有内置缓存，可以准备两次相同的字符串。

...

请注意，缓存基于：与您提供的查询字符串完全相同：驱动程序不执行任何类型的修剪或清理。

我不能百分之百确定源代码，但是缓存中的相关条目可能不会在表拖放中清除。我建议打开JIRAJava驱动程序，尽管这种类型更改通常不太推荐——最好用新类型引入新字段，即使可以重新创建表。