Postgre-SQL- PostgreSQL 数据库操作库
JavaScript 数据库管理工具
共0Star
详细介绍
Postgre-SQL
一个用于node.js上的,基于pg/pg-native/pg-pool的一个PostgreSQL数据库操作库。
设计目标是:用更少的代码,写出更直观的(复杂)查询。
比如:
-
- await db.table(table).add(data). 在insert into 之后,自动检测是否有主键,主键是否是序列,如果是,返回ID。否则返回影响的行数。如果
table
表中有create_at
字段,会自动填充NOW()
。
- await db.table(table).add(data). 在insert into 之后,自动检测是否有主键,主键是否是序列,如果是,返回ID。否则返回影响的行数。如果
-
- await db.table(table).where(condition).find(). 自动在SQL中追加
limit 1
,并返回rows[0]或null。
- await db.table(table).where(condition).find(). 自动在SQL中追加
-
- await db.table(table).where(condition).getField(field). 自动在SQL中追加
limit 1
,并返回rows[0][field]或null。
- await db.table(table).where(condition).getField(field). 自动在SQL中追加
使用类似ThinkPHP的语法,去操作PostgreSQL数据库。
库本身已经包含了连接池功能。所以可以直接连接PostgreSQL不必经过pgbouncer。
可以在业务里按需要在三个不同的级别自由切换。更灵活更高效。
有了连接池可以很好的避免因为node.js过载产生的连锁反应,波及到PostgreSQL数据库。
安装
npm i postgre-sql
配置
const {connect} = require('postgre-sql');
connect({user:'postgres',database:'test',max:2,idleTimeoutMillis:100});
使用DEMO
const {client} = require('postgre-sql');
let db = new client();
(async ()=>{
try{
let res = await db.table('public.users')
.where({vip:true},"create_at>'2017-01-01' and coordinate <-> point(116,39) < 1")
.field('uid,user_name').order('uid desc').page(2).select();
// res -> [{uid:34,use_name:'alice'},{uid:35,user_name:'david'}...]
}catch (e){
// something else
}
try{
await db.begin();
let new_uid = await db.table('public.users').add({user_name:'charles'});
await db.commit();
}catch (e){
db.rollback();
}
})();
会话模式
默认是statement
模式,这个模式的语句会平均负载到池中所有的连接。适合并行查询!
会话模式会根据业务自动调整。
语句模式 statement
const {client} = require('postgre-sql');
let db = new client();
(async ()=>{
try{
let res = await db.table('public.users')
.where({vip:true},"create_at>'2017-01-01' and coordinate <-> point(116,39) < 1")
.field('uid,user_name').order('uid desc').page(2).select();
// res -> [{uid:34,use_name:'alice'},{uid:35,user_name:'david'}...]
}catch (e){
// something else
}
})();
会话模式 session
const {client} = require('postgre-sql');
let db = new client();
(async ()=>{
try{
await db.connect();
let res = await db.table('public.users')
.where({vip:true},"create_at>'2017-01-01' and coordinate <-> point(116,39) < 1")
.field('uid,user_name').order('uid desc').page(2).select();
// res -> [{uid:34,use_name:'alice'},{uid:35,user_name:'david'}...]
await db.release(); // Attention! if connection a session don't forget release it!
}catch (e){
await db.release(); // Attention! if connection a session don't forget release it!
// something else
}
})();
事务模式 transaction
const {client} = require('postgre-sql');
let db = new client();
(async ()=>{
try{
await db.begin();
let new_uid = await db.table('public.users').add({user_name:'charles'});
await db.commit(); // Attention! if start a transaction don't forget finish it!
}catch (e){
db.rollback(); // Attention! if start a transaction don't forget finish it!
}
})();
自动完成
如果表中有create_at
、update_at
、delete_at
。在CUD的操作中会自动填充NOW()
。
软删除只在db.table(tableName).where(conditions).delete();
时影响结果。
在SELECT
类型的语句中,不会主动识,别并剔除delete_at
非空的记录。需要手动写在conditions
中。
更多姿势,见:https://github.com/blusewang/postgre- sql/blob/master/test/main.test.js