3

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

我现在的代码：

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 对象，其中包含每个表中的所有键控数据。我确信有一种简单的方法可以做到这一点，它不涉及转义字符串化数据。

4

3 回答 3

2

您可以迭代row并使用动态生成的参数和引用设置查询。

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);
    })
})
于 2017-04-05T07:53:31.230 回答
2

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

ATTACH '/some/where/source.db' AS src;
INSERT INTO main.MyTable SELECT * FROM src.MyTable;
于 2017-04-05T09:22:51.353 回答
0

尝试通过@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('');
    })
}));
于 2019-04-10T02:35:26.130 回答