基於nodejs平臺對postgresql的增刪改查基本操作進行了封裝，能滿足基本的實際應用，比較複雜的SQL需另外實現。

PG.js檔案如下：

var pg = require('pg');
var conString = "postgres://username:[email protected]/databasename";
var client = new pg.Client(conString);

var PG = function(){
    console.log("準備向****資料庫連線...");
};

PG.prototype.getConnection = function(){
    client.connect(function (err) {
        if (err) {
            return console.error('could not connect to postgres', err);
        }
        client.query('SELECT NOW() AS "theTime"', function (err, result) {
            if (err) {
                return console.error('error running query', err);
            }
            console.log("hbdfxt資料庫連線成功...");
        });
    });
};

// 查詢函式
//@param str 查詢語句
//@param value 相關值
//@param cb 回撥函式
var clientHelper = function(str,value,cb){
    client.query(str,value,function(err,result){
        if(err) {
            cb("err");
        }
        else{
            if(result.rows != undefined)
                cb(result.rows);
            else
                cb();
        }
    });
}
//增
//@param tablename 資料表名稱
//@param fields 更新的欄位和值，json格式
//@param cb 回撥函式
PG.prototype.save = function(tablename,fields,cb){
    if(!tablename) return;
    var str = "insert into "+tablename+"(";
    var field = [];
    var value = [];
    var num = [];
    var count = 0;
    for(var i in fields){
        count++;
        field.push(i);
        value.push(fields[i]);
        num.push("$"+count);
    }
    str += field.join(",") +") values("+num.join(",")+")";
    clientHelper(str,value,cb);
};

//刪除
//@param tablename 資料表名稱
//@param fields 條件欄位和值，json格式
//@param cb 回撥函式
PG.prototype.remove = function(tablename,fields,cb){
    if(!tablename) return;
    var str = "delete from "+tablename+" where ";
    var field = [];
    var value = [];
    var count = 0;
    for(var i in fields){
        count++;
        field.push(i+"=$" +count);
        value.push(fields[i]);
    }
    str += field.join(" and ");
    clientHelper(str,value,cb);
}

//修改
//@param tablename 資料表名稱
//@param fields 更新的欄位和值，json格式
//@param mainfields 條件欄位和值，json格式
PG.prototype.update = function(tablename,mainfields,fields,cb){
    if(!tablename) return;
    var str = "update "+tablename+" set ";
    var field = [];
    var value = [];
    var count = 0;
    for(var i in fields){
        count++;
        field.push(i+"=$"+count);
        value.push(fields[i]);
    }
    str += field.join(",") +" where ";
    field = [];
    for(var j in mainfields){
        count++;
        field.push(j+"=$"+count);
        value.push(mainfields[j]);
    }
    str += field.join(" and ");
    clientHelper(str,value,cb);
}

//查詢
//@param tablename 資料表名稱
//@param fields 條件欄位和值，json格式
//@param returnfields 返回欄位
//@param cb 回撥函式
PG.prototype.select = function(tablename,fields,returnfields,cb){
    if(!tablename) return;
    var returnStr = "";
    if(returnfields.length == 0)
        returnStr = '*';
    else
        returnStr= returnfields.join(",");
    var str = "select "+returnStr+ " from "+tablename+" where ";
    var field = [];
    var value = [];
    var count = 0;
    for(var i in fields){
        count++;
        field.push(i+"=$"+count);
        value.push(fields[i]);
    }
    str += field.join(" and ");
    clientHelper(str,value,cb);
};

module.exports = new PG();

 

var pgclient = require('./PG');// 引用上述檔案
pgclient.getConnection();

// 呼叫上述四個函式即可
pgclient.save('userinfo',{'name': admin},cb);<span style="font-family: Arial, Helvetica, sans-serif;">.</span>