使用连接池的方式:
var pg = require('pg');
var config = {
user:"postgres",
database:"test",
password:"postgres",
port:5432,
max:20,
idleTimeoutMillis:3000,
}
var pool = new pg.Pool(config);
pool.connect(function(err, client, done) {
if(err) {
return console.error('数据库连接出错', err);
}
client.query('SELECT $1::varchar AS OUT', ["Hello World"], function(err, result) {
done();
if(err) {
return console.error('查询出错', err);
}
console.log(result.rows[0].out);
});
});
连接客户端:
const pg=require('pg')
var conString = "postgres://username:password@localhost/databaseName";
var client = new pg.Client(conString);
client.connect(function(err) {
if(err) {
return console.error('连接postgreSQL数据库失败', err);
}
client.query('SELECT * FROM tableName', function(err, data) {
if(err) {
return console.error('查询失败', err);
}else{
console.log('成功',JSON.stringify(data.rows));
}
client.end();
});
});