数据模型：多主键的Cassandra表

Question

请针对以下需求对Cassandra表的数据模型给出一些建议/想法。我不确定这是否可以实现。如果可以实现，我们就不需要编写外部程序了

注意：这有助于连接两个Kafka主题和任何更新发生在任何一个Kafka，两者将反映在非ormalized格式在卡桑德拉表

create table stackoverflow_composite (
      key_part_one text,
      key_part_two int,
      data text,
      PRIMARY KEY(key_part_one, key_part_two)      
  );

insert into stackoverflow_composite (key_part_one, key_part_two, data) 
  VALUES ('ronaldo', 9, 'football player');
insert into stackoverflow_composite (key_part_one, key_part_two, data) 
  VALUES ('ronaldo', 10, 'ex-football player');
insert into stackoverflow_composite (key_part_one, key_part_two, data) 
  VALUES ('ronaldo', 11, 'ex-football player');

select * from stackoverflow_composite where key_part_one = 'ronaldo';

 key_part_one | key_part_two | data
--------------+--------------+--------------------
      ronaldo |            9 |    football player
      ronaldo |           10 | ex-football player

根据我们的要求，任何一个主键的值是相同的，应该向上。未插入。

insert into stackoverflow_composite (key_part_one, key_part_two, data) 
  VALUES ('Messi', 10, 'ex-football player');

cqlsh:key1> select * from stackoverflow_composite ;

 key_part_one | key_part_two | data
--------------+--------------+--------------------
      ronaldo |            9 |    football player
      Messi   |           10 | ex-football player

insert into stackoverflow_composite (key_part_one, key_part_two, data) 
  VALUES ('Messi', 12, 'ex-football player');

 cqlsh:key1> select * from stackoverflow_composite ;

 key_part_one | key_part_two | data
--------------+--------------+--------------------
      ronaldo |            9 |    football player
      Messi   |           12 | ex-football player

Answer 1

这里有一个有点复杂的解决方案（因为您的需求也很复杂）。

首先，您需要使主键只有一列key_part_one。

创建表stackoverflow_composite(key_part_one text,key_part_two int,data text,PRIMARY KEY(key_part_one))；

然后在插入以下内容之前执行如下查询：

从stackoverflow_composite中选择*，其中key_part_two=10；

如果您发现返回了任何行，则应该执行更新而不是插入，例如，如果您想插入一行：

插入stackoverflow_composite(key_part_one,key_part_two,data）值('messice'，10，'ex-football player')；

请注意，即使key_part_one的值在此之前已经存在，所有行也将被这个新的insert覆盖，因为此列单独构成了整行的主键。

这种解决方案的缺点是，您必须执行两个查询来进行插入，而不是一个，并且使用辅助索引可能会使查询变慢。为了提高辅助索引的性能，请尝试选择一个基数不是很高的列（太多不同的值），因此必须在key_part_one和key_part_two之间选择哪一个作为新的主键，哪一个作为用于创建辅助索引的列。