Модуль для подключения к СУБД postgres
npm install pg
const pg = require('pg');
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
(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){
});