Node -postgres создать базу данных

Я использую node-postgres, а в начале моего приложения хочу проверить, существует ли база данных. Поэтому моя идея работы следующая:

Проверьте, существует ли myDb
Если он существует, создайте таблицы
Если нет, тогда создайте сначала базу данных, затем таблицы

Как вы видите, это очень простой процесс, однако для реализации драйвера требуется, чтобы имя базы данных postgres://username:[email protected]/database было подключено, а это значит, что вам нужно сначала подключиться к базе данных.

Итак, теперь я должен подключиться к базе данных postgres в начале, создав запрос для создания базы данных, создав исключение, если он уже существует, затем закрывает мое соединение и подключается к недавно созданной базе данных, затем создание таблиц. Вот код:

var conStringPri = 'postgres://' + username + ':' + password + '@' + host + 
    '/postgres';
var conStringPost = 'postgres://' + username + ':' + password + '@' + host + 
    '/' + dbName;

pg.connect(conStringPri, function(err, client, done) { // connect to postgres db
    if (err)
        console.log('Error while connecting: ' + err); 
    client.query('CREATE DATABASE ' + dbName, function(err) { // create user db
        if (err) 
            console.log('ignoring the error'); // ignore if the db is there
        client.end(); // close the connection

        // create a new connection to the new db
        pg.connect(conStringPost, function(err, clientOrg, done) {
            // create the table
            clientOrg.query('CREATE TABLE IF NOT EXISTS ' + tableName + ' ' +
                    '(...some sql...)';
        });
    });
});

Как вы видите, я открываю и закрываю соединение дважды, и этот путь мне кажется неправильным. Я буду рад, если вы предложите лучший способ или можете объяснить, как вы это сделали.

Ответ 1

Как вы видите, это действительно простой процесс, однако, драйвер для реализации требуется иметь имя базы данных postgres://имя пользователя: пароль @хост/база данных для подключения, которая означает, что вам нужно сначала подключиться к базе данных.

Это не из-за реализации драйвера, это сам PostgreSQL. Это то же самое с любым другим языком или драйвером.

Клиент должен быть подключен к базе данных, чтобы сделать что-либо, включая CREATE DATABASE. Помимо базы данных postgres, для этой цели часто используется template1.

Затем, поскольку вы должны подключиться к только что созданной базе данных для создания объектов внутри нее, нет способа избежать открытия другого соединения.

Короче говоря, то, что вы делаете, не может быть упрощено, оно уже оптимально.

Ответ 2

Я только что написал для этого модуль: https://github.com/olalonde/pgtools

var pgtools = require('pgtools');
pgtools.createdb({
  user: 'postgres',
  password: 'some pass',
  port: 5432,
  host: 'localhost'
}, 'test-db', function (err, res) {
  if (err) {
    console.error(err);
    process.exit(-1);
  }
  console.log(res);
});

Надеюсь, он может сделать ваш код немного более чистым.

Ответ 3

Это немного устарело, но я просто хочу поделиться тем, как я обрабатывал такие настройки.

Вам нужно вызвать третий параметр из обратного вызова, который является done из pg.connect(conn, (err, client, done) => {}). Это освободит соединение и вернет его в пул.

 async.series([
   done => {
     pg.connect(connPrimary, (err, client, releaseConn) => {
      if (err) return done(err)

      client.query(`CREATE DATABASE ${conf.database}`, (err) => {
        if (err && !~err.message.indexOf('already exists')) {
          return done(err)
        }

        client.end()
        releaseConn()
        done()
      })
    })
  },
  done => {
    let connSecondary = `postgres://${conf.user}:${conf.password}@${conf.host}:${conf.port}/${conf.database}`

    pg.connect(connSecondary, (err, client, releaseConn) => {
      if (err) return done(err)

      let createTableQuery = `CREATE TABLE IF NOT EXISTS test_table(_id bigint primary key, co2_field varchar(40) NOT NULL, temp_field int NOT NULL, quality_field decimal NOT NULL, reading_time_field timestamp NULL)`

      client.query(createTableQuery, err => {
        if (err) return done(err)

        releaseConn()
        done()
      })
    })    
  }
], err => {
  should.ifError(err)
  doneInit()
})

Ответ 4

устанавливать

npm install --save -g pgtools

Пример CLI

createdbjs my_awesome_db --user=admin --password=admin