当我的应用程序运行很长时间时,一切都正常。但是,当我将类型a列从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)
此异常偶尔出现。我使用preparedstatement来执行查询,我认为它是从datastax的驱动程序缓存的。
我使用的是aws密钥空间(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
}
2条答案
按热度按时间cuxqih211#
没错。预处理语句是缓存的——这是一种优化方法,它使预处理语句在重用时更加高效,因为它们只需要准备一次(查询不需要再次解析)。
但我怀疑你的问题在于你的询问涉及
SELECT *
. 最佳实践建议(不管您使用的是哪个数据库)是显式枚举从表中检索的列。在prepared语句中,每一列都绑定到一个数据类型。当您通过添加/删除列来更改模式时,列的顺序(及其数据类型)不再与结果集的数据类型匹配,因此您最终会遇到驱动程序获得
int
当它期待一个text
反之亦然。干杯!hs1rzwqc2#
是的,java驱动程序4.x缓存准备好的语句-这与驱动程序3.x有所不同。根据文件:
会话有一个内置的缓存,可以准备两次相同的字符串。
...
请注意,缓存的基础是:查询字符串与您提供的完全相同:驱动程序不执行任何类型的修剪或清理。
我不确定100%的源代码,但缓存中的相关条目可能不会在表上清除掉。我建议打开jira-against-java驱动程序,尽管这样的类型更改通常不太推荐——最好是使用新类型引入新字段,即使可以重新创建表。