如何在 Node.JS 中进行多个查询（构建数据库）？

Question

对 node.js 来说真的很新，对 PostgreSQL 来说相对较新。由于某种原因，这只会创建第一个表，而不是第二个。我可能完全做错了。我似乎找不到任何足够相似的代码示例来推断答案。我想创建两个表。看来我只能运行一个查询，仅此而已。不再。建议我的连接在第二个可以执行之前结束。我不知道为什么。在十几个不同的 Google 搜索中，我找不到一个这样做的例子。

var client = new pg.Client(connectionString);
client.connect();
var query = client.query('CREATE TABLE preferences(id SERIAL PRIMARY KEY, food VARCHAR(40) not null, preferred BOOLEAN)');
client.query('CREATE TABLE foods(id SERIAL PRIMARY KEY, food VARCHAR(40) not null, type VARCHAR(40) not null, spicy BOOLEAN, spiciness VARCHAR(10)');
query.on('end', function() { client.end(); });

我怀疑我是否可以只执行另一个 client.query 并在最后执行它。我从教程中取出了这个例子，但是我添加了第二个表。所以我只是在玩它，并尝试通过这个测试在这里学习。

只是为了说明我的最终目标：我想最终创建一个完整的脚本来构建完全包含所有必要表和数据的数据库。

无论我尝试什么都会出错：

$ 节点模型/database.js 事件.js:85 投掷者； // 未处理的“错误”事件 ^ 错误：输入末尾的语法错误 在 Connection.parseE (~/Documents/test01/node_modules/pg/lib/connection.js:534:11) 在 Connection.parseMessage (~/Documents/test01/node_modules/pg/lib/connection.js:361:17) 在套接字。 (~/Documents/test01/node_modules/pg/lib/connection.js:105:22) 在 Socket.emit (events.js:107:17) 在 readableAddChunk (_stream_readable.js:163:16) 在 Socket.Readable.push (_stream_readable.js:126:10) 在 TCP.onread (net.js:538:20)

Answer 1

您正在尝试执行两个异步操作，因此您需要等到两个操作都完成后才能继续。一种方法是使用计数变量。

var client = new pg.Client(connectionString);
client.connect();
var query1 = client.query('CREATE TABLE preferences(id SERIAL PRIMARY KEY, food VARCHAR(40) not null, preferred BOOLEAN)');
var query2 = client.query('CREATE TABLE foods(id SERIAL PRIMARY KEY, food VARCHAR(40) not null, type VARCHAR(40) not null, spicy BOOLEAN, spiciness VARCHAR(10))');
var count = 2;

function endHandler () {
   count--; // decrement count by 1
   if (count === 0) {
       // two queries have ended, lets close the connection.
       client.end();
   }
}

query1.on('end', endHandler);
query2.on('end', endHandler);

请注意，在这种情况下，您可能只是将这两个语句合并为一个，假设 postgres 支持该功能并且您的系统中启用了该功能。

client.query('CREATE TABLE preferences(id SERIAL PRIMARY KEY, food VARCHAR(40) not null, preferred BOOLEAN);CREATE TABLE foods(id SERIAL PRIMARY KEY, food VARCHAR(40) not null, type VARCHAR(40) not null, spicy BOOLEAN, spiciness VARCHAR(10));')

Answer 2

您需要管理多个“查询”变量。在您的情况下，代码可能如下所示：

    var client = new pg.Client(connectionString);
        client.connect();
    var queryPreferences = client.query('CREATE TABLE preferences(id SERIAL PRIMARY KEY, food VARCHAR(40) not null, preferred BOOLEAN)');

    var foods = function() { 
        var queryFoods = client.query('CREATE TABLE foods(id SERIAL PRIMARY KEY, food VARCHAR(40) not null, type VARCHAR(40) not null, spicy BOOLEAN, spiciness VARCHAR(10)');
        queryFoods.on('end', function() { client.end(); });
    }

    queryPreferences.on('end', foods);

这样，您将运行第二个查询，直到完成第一个查询，然后关闭连接。

Answer 3

最好的方法是将所有请求放入一个事务中并在同一个连接中执行。

在pg-promise 的帮助下，您可以这样做：

var pgp = require('pg-promise')(/*options*/);
var db = pgp(connection);

db.tx(t => {
        return t.batch([
            t.none('CREATE TABLE preferences(id SERIAL, etc...'),
            t.none('CREATE TABLE foods(id SERIAL PRIMARY KEY, etc...')
        ]);
    })
    .then(data => {
        // success;
    })
    .catch(error => {
        console.log(error); // print error;
    });

更好的是，将所有 SQL 放入外部 SQL files，库对此提供自动支持。