从Quarkus应用程序执行插入时，Cassandra数据库expion

Question

在我们的项目中，我们使用Quarkus版本2.8.0. -final 以及DataStax版本1.1.1访问Cassandra数据库版本3.11

WA时，当我们通过Java执行插入物时，将获得以下异常。

com.datastax.oss.oss.driver.api.core.servererrors.invalidqueryException：主键列“ col_4”不能限制为前面的列“ col_3”，不限制

我们不明白为什么会发生这种情况，因为以下语句从vscode中执行了以下语句，成功没有任何问题

INSERT INTO my_table  (
    col_1,
    col_2,
    col_3,
    col_4,
    col_5,
    col_6,
    col_7
  )
VALUES (
    'Some Value',
    '5ea20642-e9e7-44bd-b4f0-97b84ae97f2c',
    '1ed91e32-a7ba-4b5f-b4dd-9cfe3e522914',
    'Another Value',
    '2010-01-01',
    '24afc036-21e8-41c6-9f7a-1994fba71223',
    'Just one mor value'
  );

我们的桌子如下

CREATE TABLE IF NOT EXISTS my_table (
    col_1 text,
    col_2 text,
    col_3 text,
    col_4 text,
    col_5 text,
    col_6 text,
    col_7 date,
    PRIMARY KEY(col_1, col_2, col_3, col_4)
);

所示

@Entity
@CqlName("my_entity")
public class MyEntity {

  @PartitionKey
  private String col_1;
  @ClusterinColumn
  private String col_2;
  @ClusterinColumn(1)
  private String col_3;
  @ClusterinColumn(2)
  private String col_4;
  
  private String col_5;
  private String col_6;
  private LocalDate col_1;

}

，

@Dao
public interface MyEntityDao {

  @Insert
  void insert (MyEntity myEntity)

}

Answer 1

所以，我发现了。
DataStax确实很难

在这种情况下，

@Select (custimWhereClause = "col2 = :col_2_value and col4 = :col_4_value")
PagingIterable<MyEntity> findByCriteria(String col_2_value, String col_4_value)

Quarkus或

Answer 2

您获得的错误与Cassandra驱动程序对象映射有关，在引擎盖下创建一个CQL语句，违反了表的某些约束。可能没有提供强制性属性。

由于设计薄弱，并且可能误解了Cassandra数据建模方法，因此发生了这种情况。让我们改进这个！ （最后在github上的工作项目）。

关于表的评论：

您提供的创建表语句等同于

CREATE TABLE IF NOT EXISTS my_table (
   col_1 text,
   col_2 text,
   col_3 text,
   col_4 text,
   col_5 text,
   col_6 text,
   col_7 date,
PRIMARY KEY((col_1), col_2, col_3, col_4)
WITH CLUSTERING ORDER BY (col_2 DESC, col_3 DESC, col_4 DESC);

• col_1称为您的分区密钥。它不能确保记录的统一性，并且在每个条款针对表的每个请求中绝对是强制性的。当省略双括号时，第一列被视为分区键。

• col_2 to col_4的列称为聚类列，用于完成确保在该条款中允许的单调和标记列的主要键。该顺序在声明中很重要。例如。如果要过滤col_4，则需要提供col_1（分区密钥），但还需要col_2 et col_3

才能了解有关方法的更多信息 https://academy.datastax.com

Strong>

这是一个更新的版本，您会遇到一些错误：

• 表名是my_table

• 您提供了col_1两次

• 您忘记了第一个clusteringColumn（0）

  中的偏移

   @entity
  @cqlname（“ my_table”）
  公共班级MENTITY {
  
    @PartitionKey
    @cqlname（“ col_1”）
    私人字符串col1;
  
    @ClusteringColumn（0）
    @cqlname（“ col_2”）
    私人字符串COL2;
  
    @ClusteringColumn（1）
    @cqlname（“ col_3”）
    私人字符串Col3;
  
    @ClusteringColumn（2）
    @cqlname（“ col_4”）
    私人字符串col4;
  
    @cqlname（“ col_5”）
    私人字符串col5;
  
    @cqlname（“ col_6”）
    私人字符串Col6;
  
    @cqlname（“ col_7”）
    私人localdate col7;
  
    //构造函数
    //获取器和固定器
  }
   

对DAO的评论：

  @Dao
  @DefaultNullSavingStrategy(NullSavingStrategy.SET_TO_NULL)
  public interface MyEntityDao {

    @Delete(entityClass = MyEntity.class)
    void deleteByCol1(String col1);

    @Select
    PagingIterable<MyEntity> findByPkCol1(String col1);

    @Select
    Optional<MyEntity> findById(String col1, String col2, String col3, String col4);

    @Insert
    void save(MyEntity product);    

  }

我注意到您使用的是相当新的Quarkus版本，但是Cassandra的旧版本。如果您开始一个项目跳到4.0，则会拥有。免费的完美提升。

在这里，我为您提供了带有数据库架构的工作Quarkus应用程序，并且您的实体=＆gt; https://github.com/clun/qlun/quarkus_cassandra

现在，请永远不要使用允许过滤。它将对您的群集进行全面扫描，并且仍然很慢，然后将返回超时（在DEV工作时）。如果您需要在相同数据上进行多个查询...请在多个表中复制数据。