Node.js中Cassandra批量查询仅插入一行，期望插入全部行的问题

可能的原因及对应解决方法 #

1. 未等待异步操作完成就退出进程 #

Node.js是异步事件驱动模型，如果这是一次性执行的脚本，client.batch是异步操作，若没等Promise完成就结束进程，会导致数据库操作未全部执行就中断，出现只插入部分数据的情况。

解决方法：
用async/await控制流程，确保操作完成后再关闭客户端、退出进程：

const client = new cassandra.Client({
  contactPoints: ['127.0.0.1'],
  localDataCenter: 'eu-west-3',
  keyspace: 'test',
});

async function runBatch() {
  try {
    const query = 'INSERT INTO user_track (key, text, date) VALUES (?, ?, ?)';
    const queries = [
       { query, params: ['hendrix1', 'Changed email1', new Date()]},
       { query, params: ['hendrix2', 'Changed email2', new Date()] } 
    ];
    await client.batch(queries, { prepare: true });
    console.log('所有数据插入成功');
  } catch (err) {
    console.error('插入失败:', err);
  } finally {
    await client.shutdown(); // 关闭客户端，确保操作完成
  }
}

runBatch();

2. 重复定义相同的Prepared Statement #

你的代码里query1和query2是完全一致的SQL语句，虽然驱动理论上能处理，但重复定义可能引发Prepared Statement复用异常，尤其在高并发场景下。

解决方法：
复用同一个SQL语句变量，减少不必要的Prepared Statement创建：

const query = 'INSERT INTO user_track (key, text, date) VALUES (?, ?, ?)';
const queries = [
   { query, params: ['hendrix1', 'Changed email1', new Date()]},
   { query, params: ['hendrix2', 'Changed email2', new Date()] } 
];

3. 未捕获异常导致无法定位问题 #

原代码的catch块仅留注释，未输出错误信息，无法得知是否有异常发生。Cassandra的Batch操作默认是原子性的（Logged Batch），要么全部成功要么全部失败，若只插入一行，大概率是进程提前退出而非Batch本身的原子性问题。

解决方法：
在catch块中打印错误详情，排查具体异常：

.catch(function(err) {
  console.error('批量插入失败:', err.message, err.stack);
});

4. 表结构或主键冲突 #

检查user_track表的主键定义：如果key不是主键（或主键的一部分），可能存在覆盖插入的情况；若插入数据的主键重复（示例中key值不同，此可能性较低），也会导致插入失败。

验证方法：
执行CQL命令DESCRIBE TABLE user_track;查看表结构，确保key是主键的一部分，且插入的params中主键值唯一。

最终优化后的代码 #

const cassandra = require('cassandra-driver');
const client = new cassandra.Client({
  contactPoints: ['127.0.0.1'],
  localDataCenter: 'eu-west-3',
  keyspace: 'test',
});

async function insertBatchData() {
  try {
    const insertQuery = 'INSERT INTO user_track (key, text, date) VALUES (?, ?, ?)';
    const batchQueries = [
      { query: insertQuery, params: ['hendrix1', 'Changed email1', new Date()] },
      { query: insertQuery, params: ['hendrix2', 'Changed email2', new Date()] }
    ];

    await client.batch(batchQueries, { 
      prepare: true,
      consistency: cassandra.types.consistencies.localQuorum // 可选：根据需求调整一致性级别
    });

    console.log('所有记录已成功插入');
  } catch (error) {
    console.error('批量插入出错:', error.message, error.stack);
  } finally {
    await client.shutdown();
  }
}

insertBatchData();

内容的提问来源于stack exchange，提问作者Saurav Verma