java - Cassandra LWT 能否在 PRIMARY KEY 方面具有 IF 部分

Question

Cassandra 轻量级事务是否使用隐含的 SET，因此在主键方面不能有 IF 部分？

我问是因为 Datastax Cassandra Java 驱动程序(版本 2.1.5)在我准备语句时抛出 InvalidQueryException。异常消息很清楚:

PRIMARY KEY part name found in SET part

除了它正在准备的查询不尝试设置主键。查询是

 UPDATE operator SET password = :password WHERE name = :name IF name = :name;

如您所见，查询确实设置了 password 而没有设置 name； name 是operator 表的主键。仅当轻量事务的 IF name = :name 是使用 SET name = ... 实现时，异常消息才有意义。

如果我从查询中删除 IF name = :name 部分，驱动程序不会提示试图设置主键。

这是完整的堆栈跟踪:

org.springframework.dao.InvalidDataAccessResourceUsageException: PRIMARY KEY part name found in SET part; nested exception is com.datastax.driver.core.exceptions.InvalidQueryException: PRIMARY KEY part name found in SET part    at com.example.application.datalayer.DriverExceptionTranslator.translateExceptionIfPossible(DriverExceptionTranslator.java:200) ~[application-user.jar:1.0.0-SNAPSHOT]    at com.example.application.datalayer.DriverExceptionTranslator$ExceptionTranslationAdvice.afterThrowing(DriverExceptionTranslator.java:50) ~[application-user.jar:1.0.0-SNAPSHOT]    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.7.0_75]    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) ~[na:1.7.0_75]    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.7.0_75]    at java.lang.reflect.Method.invoke(Method.java:606) ~[na:1.7.0_75]    at org.springframework.aop.framework.adapter.ThrowsAdviceInterceptor.invokeHandlerMethod(ThrowsAdviceInterceptor.java:145) ~[application-user.jar:1.0.0-SNAPSHOT]    at org.springframework.aop.framework.adapter.ThrowsAdviceInterceptor.invoke(ThrowsAdviceInterceptor.java:130) ~[application-user.jar:1.0.0-SNAPSHOT]    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:179) ~[application-user.jar:1.0.0-SNAPSHOT]    at org.springframework.aop.framework.JdkDynamicAopProxy.invoke(JdkDynamicAopProxy.java:207) ~[application-user.jar:1.0.0-SNAPSHOT]    at com.example.application.user.$Proxy0.addUser(Unknown Source) ~[na:1.0.0-SNAPSHOT]    at com.example.application.user.Add.tryToAddUser(Add.java:294) [application-user.jar:1.0.0-SNAPSHOT]    at com.example.application.user.Add.performOperation(Add.java:266) [application-user.jar:1.0.0-SNAPSHOT]    at com.example.application.user.Mode.run(Mode.java:812) [application-user.jar:1.0.0-SNAPSHOT]    at com.example.application.user.Mode.runProgram(Mode.java:79) [application-user.jar:1.0.0-SNAPSHOT]    at com.example.application.user.Add.main(Add.java:63) [application-user.jar:1.0.0-SNAPSHOT]Caused by: com.datastax.driver.core.exceptions.InvalidQueryException: PRIMARY KEY part name found in SET part    at com.datastax.driver.core.exceptions.InvalidQueryException.copy(InvalidQueryException.java:35) ~[application-user.jar:1.0.0-SNAPSHOT]    at com.datastax.driver.core.DefaultResultSetFuture.extractCauseFromExecutionException(DefaultResultSetFuture.java:289) ~[application-user.jar:1.0.0-SNAPSHOT]    at com.datastax.driver.core.AbstractSession.prepare(AbstractSession.java:79) ~[application-user.jar:1.0.0-SNAPSHOT]    at com.example.application.user.CassandraUserRepository$SessionAdapter.(CassandraUserRepository.java:80) ~[application-user.jar:1.0.0-SNAPSHOT]    at com.example.application.user.CassandraUserRepository.getSessionAdapter(CassandraUserRepository.java:447) ~[application-user.jar:1.0.0-SNAPSHOT]    at com.example.application.user.CassandraUserRepository.addUser(CassandraUserRepository.java:317) ~[application-user.jar:1.0.0-SNAPSHOT]    at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) ~[na:1.7.0_75]    at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) ~[na:1.7.0_75]    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) ~[na:1.7.0_75]    at java.lang.reflect.Method.invoke(Method.java:606) ~[na:1.7.0_75]    at org.springframework.aop.support.AopUtils.invokeJoinpointUsingReflection(AopUtils.java:317) ~[application-user.jar:1.0.0-SNAPSHOT]    at org.springframework.aop.framework.ReflectiveMethodInvocation.invokeJoinpoint(ReflectiveMethodInvocation.java:190) ~[application-user.jar:1.0.0-SNAPSHOT]    at org.springframework.aop.framework.ReflectiveMethodInvocation.proceed(ReflectiveMethodInvocation.java:157) ~[application-user.jar:1.0.0-SNAPSHOT]    at org.springframework.aop.framework.adapter.ThrowsAdviceInterceptor.invoke(ThrowsAdviceInterceptor.java:125) ~[application-user.jar:1.0.0-SNAPSHOT]    ... 8 common frames omittedCaused by: com.datastax.driver.core.exceptions.InvalidQueryException: PRIMARY KEY part name found in SET part    at com.datastax.driver.core.Responses$Error.asException(Responses.java:103) ~[application-user.jar:1.0.0-SNAPSHOT]    at com.datastax.driver.core.SessionManager$1.apply(SessionManager.java:185) ~[application-user.jar:1.0.0-SNAPSHOT]    at com.datastax.driver.core.SessionManager$1.apply(SessionManager.java:160) ~[application-user.jar:1.0.0-SNAPSHOT]    at com.google.common.util.concurrent.Futures$1.apply(Futures.java:720) ~[application-user.jar:1.0.0-SNAPSHOT]    at com.google.common.util.concurrent.Futures$ChainingListenableFuture.run(Futures.java:859) ~[application-user.jar:1.0.0-SNAPSHOT]    at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1145) ~[na:1.7.0_75]    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:615) ~[na:1.7.0_75]    at java.lang.Thread.run(Thread.java:745) ~[na:1.7.0_75]

Answer 1

您不能在分区键列 (IF name = 'foo') 上设置条件，因为该列已经在 where 子句 (WHERE name = 'foo' ').

报错信息确实有问题。这显然已修复，使用 Cassandra 2.1.4 我得到:PRIMARY KEY column 'name' cannot have IF conditions。