如何在knex.js中执行show create table语句及实现replace into操作

你给出的写法是可行的，knex.schema.raw() 可以执行任意原生SQL语句，也可以直接用更常用的 knex.raw() 写法，两者效果一致。需要注意raw方法返回的是Promise对象，必须通过await或者then回调才能拿到返回结果。

MySQL环境下的完整示例：

// 异步调用示例
const res = await knex.raw('show create table 目标表名');
// 返回结果的第一层是查询结果元信息，第二层的第一个元素就是建表语句内容
const createTableSql = res[0][0]['Create Table'];
console.log(createTableSql);

不同数据库的返回结构会略有差异，拿到raw返回结果后可以先打印整体结构，再按需取对应字段即可。

replace into是MySQL专属的语法，Knex.js本身没有内置对应的查询构造器方法，你可以通过以下两种方式实现：

• 方式1：直接写原生SQL，适合简单插入场景

// 用占位符传参避免SQL注入
await knex.raw('replace into 表名 (id, name, age) values (?, ?, ?)', [1, '张三', 25]);

• 方式2：封装通用工具方法，适合多处调用的场景

// 封装可复用的replace方法
async function replaceInto(table, data) {
  const fields = Object.keys(data).join(',');
  const placeholders = Object.keys(data).map(() => '?').join(',');
  const values = Object.values(data);
  return knex.raw(`replace into ${table} (${fields}) values (${placeholders})`, values);
}

// 调用示例
await replaceInto('user', {
  id: 1,
  name: '张三',
  age: 25
});

注意：replace into的执行逻辑是，当插入数据命中主键或唯一索引冲突时，会先删除原有冲突行再插入新行，和on duplicate key update直接更新原有行的逻辑不同，请根据业务需求选择合适的实现方案。

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