一个用于node.js上的，基于pg/pg-native/pg-pool的一个PostgreSQL数据库操作库。
设计目标是：用更少的代码，写出更直观的（复杂）查询。
比如：
*awaitdb.table(table).add(data).在insertinto之后，自动检测是否有主键，主键是否是序列，如果是，返回ID。否则返回影响的行数。如果`table`表中有`create_at`字段，会自动填充`NOW()`。
*awaitdb.table(table).where(condition).find().自动在SQL中追加`limit1`,并返回rows[0]或null。
*awaitdb.table(table).where(condition).getField(field).自动在SQL中追加`limit1`,并返回rows[0][field]或null。
使用类似ThinkPHP的语法，去操作PostgreSQL数据库。
>可来这里https://runkit.com/blusewang/postgre-sql-play先过手瘾。
库本身已经包含了连接池功能。所以可以直接连接PostgreSQL不必经过pgbouncer。
可以在业务里按需要在三个不同的级别自由切换。更灵活更高效。
有了连接池可以很好的避免因为node.js过载产生的连锁反应，波及到PostgreSQL数据库。
安装npmipostgre-sql
配置const {connect} = require('postgre-sql');connect({user:'postgres',database:'test',max:2,idleTimeoutMillis:100});使用DEMOconst {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模式，这个模式的语句会平均负载到池中所有的连接。适合并行查询！
会话模式会根据业务自动调整。
语句模式 statementconst {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 }})();会话模式 sessionconst {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 }})();事务模式 transactionconst {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
评论