每次我运行配置文件时它都不起作用

Question

我正在使用带有 PSQL 的 node.js，以及 express 和 node-postgres。我有一个名为 config.js 的文件。目的是让它删除数据库，然后在每次运行时将其与表一起重新创建。这会每隔一秒运行一次，在另一半时间返回错误，而不是重新创建数据库。

(node:11300) UnhandledPromiseRejectionWarning: error: database "abc" does not exist

有人知道怎么回事吗？请告诉我是否需要包含完整的错误消息，我没有，因为它看起来不是很有用。

代码：

const { Pool, Client } = require('pg')

let dbName = "abc"

let tables = [{
    name: "users",
    content: "id SERIAL, username VARCHAR, email VARCHAR, passcode VARCHAR"
}]

let pool = new Pool({
    user: 'postgres',
    host: 'localhost',
    database: 'postgres',
    password: 'postgres',
    port: 5432
})

deleteDb()
createDbAndTables()

function deleteDb() {
    pool.query("DROP DATABASE IF EXISTS abc", (err, res) => {

        if (err) {

            console.log(err)
        } else {

            console.log("deleted db " + dbName)
        }
    })
}

function createDbAndTables() {
    pool.query("CREATE DATABASE abc", (err, res) => {

        console.log("created db " + dbName)

        const client = new Client({
            host: 'localhost',
            port: 5432,
            user: 'postgres',
            password: 'postgres',
            database: dbName,
        })

        client.connect()

        for (let i = 0; i < tables.length; i++) {

            let table = tables[i]

            client.query("CREATE TABLE " + table.name + "(" + table.content + ")", (err, res) => {
                if (err) {

                    console.log(err)
                } else {

                    console.log("created table " + table.name)
                }
                if (i == tables.length) {

                    client.end()
                }
            })
        }
        pool.end()
    })
}

如果我做错了什么或可以进行优化，我也很想听听。 提前感谢您的帮助！

Answer 1

这是确保deleteDb 和createDbAndTables 两个函数按顺序运行的非常快速而肮脏的方法：

const { Pool, Client } = require('pg');

let dbName = 'abc';

let tables = [
  {
    name: 'users',
    content: 'id SERIAL, username VARCHAR, email VARCHAR, passcode VARCHAR',
  },
];

let pool = new Pool({
  user: 'postgres',
  host: 'localhost',
  database: 'postgres',
  password: 'postgres',
  port: 5432,
});

deleteDb().then(() => {
  createDbAndTables();
});

function deleteDb() {
  return new Promise((resolve, reject) => {
    pool.query('DROP DATABASE IF EXISTS abc', (err, res) => {
      if (err) {
        reject(err);
      } else {
        resolve('deleted db ' + dbName);
      }
    });
  });
}

function createDbAndTables() {
  pool.query('CREATE DATABASE abc', (err, res) => {
    console.log('created db ' + dbName);

    const client = new Client({
      host: 'localhost',
      port: 5432,
      user: 'postgres',
      password: 'postgres',
      database: dbName,
    });

    client.connect();

    for (let i = 0; i < tables.length; i++) {
      let table = tables[i];
      client.query(
        'CREATE TABLE ' + table.name + '(' + table.content + ')',
        (err, res) => {
          if (err) {
            console.log(err);
          } else {
            console.log('created table ' + table.name);
          }
          if (i == tables.length) {
            client.end();
          }
        }
      );
    }
    pool.end();
  });
}

请注意，我只对其中一个做出了承诺，但如果您想在之后运行，您可能必须同时执行这两个。 我也没有使用async / await，因为我认为这不是在函数中运行，并且为了简单起见，您没有运行最新的节点。