基于pg的PostgreSQL数据库操作库Postgre-SQL

基于pg的PostgreSQL数据库操作库Postgre-SQL

  • 开源协议:BSD
  • 操作系统: Windows Linux OS X
  • 开发语言:Js
  • 项目所有者:blusewang
  • 收录时间:2017-07-15
  • 分享:
编辑评级
3

项目详细介绍

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).where(condition).find(). 自动在SQL中追加`limit 1`,并返回rows[0]或null。

  • * await db.table(table).where(condition).getField(field). 自动在SQL中追加`limit 1`,并返回rows[0][field]或null。

使用类似ThinkPHP的语法,去操作PostgreSQL数据库。

> 可来这里https://runkit.com/blusewang/postgre-sql-play先过手瘾。

库本身已经包含了连接池功能。所以可以直接连接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_atupdate_atdelete_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