pg

Модуль для подключения к СУБД postgres

npm install pg
const pg = require('pg');

Client

class Client(config)

Клиент работы с postgres

  • config - объект параметров

    • database - название базы данных
    • user
    • password
    • host
    • port
    • max
    • idleTimeoutMillis
const pg_client = pg.Client({
    database: "db"
});
Client.connect(callback)

Подключается к субд

pg_client.connect(function(err){
    if (err) throw err;

    // pg_client.query(...);
});
Client.end(callback)

Завершает работу с базой

pg_client.end(function(err) {
    if (err) throw err;
});
Client.query(sql, params, callback)

Выполняет зпрос к базе

pg_client.query(
    "select $1::text as name from table",
    ["ilnurgi"],
    function(err, result) {
        if (err) throw err;

        console.log(result.rows[0]);

        pg_client.end(function(err) {
            if (err) throw err;
        });
    }
)

Pool

class Pool(config)

Создает пул соединении

  • config - объект параметров

    • database - название базы данных
    • user
    • password
    • host
    • port
    • max
    • idleTimeoutMillis
const pg_pool = pg.Pool();
Pool.connect(callback)

Выполняет соединение с базой

pg_pool.connect(function(err, client, done){

});
Pool.query(sql, params, callback)

Выполняет запрос к базе

pg_pool.query(
    "select $1::text as name from table",
    ["ilnurgi"],
    function(err, result) {
        if (err) throw err;

        console.log(result.rows[0]);

        pg_client.end(function(err) {
            if (err) throw err;
        });
    }
)
Pool.on(event, callback)

Задает обработчик события

pg_pool.on('error', function(err, client){
});