使用Nodejs怎么操作postgresql？针对这个问题，这篇文章详细介绍了相对应的分析和解答，希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。
站在用户的角度思考问题，与客户深入沟通，找到龙子湖网站设计与龙子湖网站推广的解决方案，凭借多年的经验，让设计与互联网技术结合，创造个性化、用户体验好的作品，建站类型包括：成都做网站、成都网站制作、企业官网、英文网站、手机端网站、网站推广、申请域名、虚拟主机、企业邮箱。业务覆盖龙子湖地区。
PG.js文件如下：
var pg = require('pg');
var conString = "postgres://username:password@localhost/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);. 关于使用Nodejs怎么操作postgresql问题的解答就分享到这里了，希望以上内容可以对大家有一定的帮助，如果你还有很多疑惑没有解开，可以关注创新互联行业资讯频道了解更多相关知识。
