1

这是我的场景，考虑我的表有 cloumnsid主键和clusterkey集群键。我想删除一条属于主键的记录并插入具有相同主键但不同簇键的新记录。在这种情况下，由于某些并发性，似乎一直没有发生插入？尝试使用时间戳，但同样的问题。

const query1 = 'delete from table where id=? and clusterkey=?';
const query2 = 'INSERT INTO table (id, clusterkey, name) VALUES (?, ?, ?)';
const queries = [
   { query: query1, params: ['1', '3'] },
   { query: query2, params: ['1', '8', 'GoodName'] } 
];
client.batch(queries, { prepare: true }, function (err) {
   console.log(err, 'done')
});

使用时间戳

const query1 = 'delete from table where id=? and clusterkey=? using timestamp ?';
const query2 = 'INSERT INTO table (id, clusterkey, name) VALUES (?, ?, ?) using timestamp ?';
const queries = [
   { query: query1, params: ['1', '3', Date.now() * 1000] },
   { query: query2, params: ['1', '8', 'GoodName', Date.now() * 1000] } 
];
client.batch(queries, { prepare: true }, function (err) {
   console.log(err, 'done')
});

表信息：

create table sample (id text, group text, name text, PRIMARY KEY (id, group))

查询结果：

批处理前选择结果

    id  |clusterkey |name 
----------------------------- 
    1   |3       |wrongname 
    2   |2       |Hello

批后

    id  |clusterkey |name 
----------------------------- 
    2   |2       |Hello
4

2 回答 2

0

除了@ruhul 的回答，如果你还没有执行批处理，那么删除也不应该起作用。但是您只提到了插入。

如果不是@ruhul 提到的情况，请检查您的集群是否一致。当集群失去一致性时会发生这种情况。

在您的集群 ( ) 上运行修复nodetool repair并再次检查。

于 2018-03-03T08:35:36.107 回答
0

您将这些查询添加到批处理中，但可能忘记执行这些查询。

尝试使用，

client.execute( queries, function (err, result) { 
     if (!err) {
         console.log("executed.");
     }
} );

请点击此链接了解更多详细信息：Cassandra 执行查询

于 2018-03-03T06:59:21.737 回答