【问题标题】:Getting error while inserting data into Cassandra将数据插入 Cassandra 时出错
【发布时间】:2020-08-10 17:09:34
【问题描述】:

我正在尝试将数据插入到我的 cassandra db 表中,但是我不断收到错误并且无法找出确切的问题。

这是我的表架构

CREATE TABLE discoveryassignment.connector_assignments (
    connector_id text,
    assignment_time timestamp,
    connector_type text,
    org_id uuid,
    user_ids text,
    PRIMARY KEY (connector_id, assignment_time));

还有我的查询

Insert into discoveryassignment.connector_assignments(connector_id,assignment_time,connector_type,org_id,user_ids) values('f1b987df-2dfbd-437b-bda8-ff459e016f86',"2020-04-24 11:07:37+0000",'migrated',584cf4cd-eea7-4c8c-83ee-67d88fc6ccc5,"[{“userId":"ca38a547-4de4-26ab-bacb-5de9e7449958","fusionType":"calendar"},{"userId":"09d8f28e-2cab-4ce0-9941-34db1de2b000","fusionType":"calendar”}]");```

【问题讨论】:

    标签: database cassandra cql cqlsh


    【解决方案1】:

    这是您的查询的工作版本;

    insert into discoveryassignment.connector_assignments(connector_id, assignment_time, connector_type, org_id, user_ids)
    values ('f1b987df-2dfbd-437b-bda8-ff459e016f86', '2020-04-24 11:07:37+0000', 'migrated', 584cf4cd-eea7-4c8c-83ee-67d88fc6ccc5,
        '[{"userId":"ca38a547-4de4-26ab-bacb-5de9e7449958","fusionType":"calendar"},{"userId":"09d8f28e-2cab-4ce0-9941-34db1de2b000","fusionType":"calendar"}]');
    

    我将 assignment_time 从双引号改为单引号,您的 user_ids 查询中有 - 我也修复了这个问题。

    如果您要保留 json 格式的列,我建议您阅读Cassandra collections

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 2012-01-14
      • 1970-01-01
      • 2014-07-07
      • 1970-01-01
      • 2013-04-25
      • 2014-11-15
      相关资源
      最近更新 更多