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 = new pg.Client({
    database: "db"
});

const pg_client = new pg.Client("pg://user:password@host:port/db_name");

pg_client.connect()

result = pg_client.query('select * from some_table')
result.on('end', function(result){
    console.log(result.rows)
})
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){
});