java - 序列化 BoundStatement cassandra

Question

我有一个用例，我想要序列化 Cassandra BoundStatement 并将其转换为 byte[] 数组并通过网络发送并将其反序列化回来到Bound Statement对象。

我正在使用Java 8。

但是问题是BoundStatement 没有实现Serialized 接口(interface)。

有什么方法可以序列化 BoundStatement，通过 HTTP 发送它并将其反序列化回 BoundStatement

Answer 1

如果你想序列化BoundStatement，那么你还必须序列化PreparedStatement、DataWrapper，因为BoundStatement使用他们俩。

即使您能够序列化 BoundStatement，如果没有创建它的 session ，您也无法执行它。如果您使用其他 session 执行 BoundStatement，Driver 将抛出 InvalidQueryException

Exception in thread "main" com.datastax.driver.core.exceptions.InvalidQueryException: Tried to execute unknown prepared query : 0x0c245df8681f7dc939aba0c76164e4d3. You may have used a PreparedStatement that was created with another Cluster instance.
    at com.datastax.driver.core.SessionManager.makeRequestMessage(SessionManager.java:571)
    at com.datastax.driver.core.SessionManager.executeAsync(SessionManager.java:131)
    at com.datastax.driver.core.AbstractSession.execute(AbstractSession.java:68)
    ...