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){ });