使用 node-sqlite 将数据从一个数据库复制到另一个数据库 - 格式化 'insert' 语句

Question

我正在编写一个小实用程序来将数据从一个 sqlite 数据库文件复制到另一个。两个文件具有相同的 table 结构——这完全是关于将行从一个数据库移动到另一个数据库。

我现在的代码：

let tables: Array<string> = [
        "OneTable", "AnotherTable", "DataStoredHere", "Video"
    ]

tables.forEach((table) => {
    console.log(`Copying ${table} table`);

    sourceDB.each(`select * from ${table}`, (error, row) => {
        console.log(row);
        destDB.run(`insert into ${table} values (?)`, ...row) // this is the problem
    })
})

row 这是一个 js 对象，其中包含每个 table 中的所有键控数据。我确信有一种简单的方法可以做到这一点，它不涉及转义字符串化数据。

Answer 1

您可以使用动态生成的参数和引用遍历 row 和 setup 查询。

let tables: Array<string> = [
        "OneTable", "AnotherTable", "DataStoredHere", "Video"
    ]

tables.forEach((table) => {
    console.log(`Copying ${table} table`);

    sourceDB.each(`select * from ${table}`, (error, row) => {
        console.log(row);
        const keys = Object.keys(row); // ['column1', 'column2']
        const columns = keys.toString(); // 'column1,column2'
        let parameters = {};
        let values = '';

        // Generate values and named parameters
        Object.keys(row).forEach((r) => {
          var key = '$' + r;
          // Generates '$column1,$column2'
          values = values.concat(',', key);
          // Generates { $column1: 'foo', $column2: 'bar' }
          parameters[key] = row[r];
        });

        // SQL: insert into OneTable (column1,column2) values ($column1,$column2)
        // Parameters: { $column1: 'foo', $column2: 'bar' }
        destDB.run(`insert into ${table} (${columns}) values (${values})`, parameters);
    })
})

Answer 2

如果您的数据库驱动程序没有阻塞 ATTACH，您可以简单地告诉数据库复制所有内容：

ATTACH '/some/where/source.db' AS src;
INSERT INTO main.MyTable SELECT * FROM src.MyTable;

Answer 3

尝试编辑 @Cl. 的答案，但被拒绝了。因此，添加到答案中，这是实现相同目的的 JS 代码：

let sqlite3 = require('sqlite3-promise').verbose();
let sourceDBPath = '/source/db/path/logic.db';
let tables = ["OneTable", "AnotherTable", "DataStoredHere", "Video"];
let destDB = new sqlite3.Database('/your/dest/logic.db');
await destDB.runAsync(`ATTACH '${sourceDBPath}' AS sourceDB`);
await Promise.all(tables.map(table => {
    return new Promise(async (res, rej) => {
        await destDB.runAsync(`
            CREATE TABLE ${table} AS
            SELECT * FROM sourceDB.${table}`
        ).catch(e=>{
            console.error(e);
            rej(e);
        });
        res('');
    })
}));

使用 node-sqlite 将数据从一个数据库复制到另一个数据库 - 格式化 'insert' 语句

Copying data from one DB to another with node-sqlite - formatting the 'insert' statement

sqlite

node.js

typescript

node-sqlite3