使用Nodejs怎么操作postgresql-創(chuàng)新互聯(lián)

使用Nodejs怎么操作postgresql？針對這個問題，這篇文章詳細介紹了相對應的分析和解答，希望可以幫助更多想解決這個問題的小伙伴找到更簡單易行的方法。

創(chuàng)新互聯(lián)專注于甕安網(wǎng)站建設服務及定制，我們擁有豐富的企業(yè)做網(wǎng)站經(jīng)驗。 熱誠為您提供甕安營銷型網(wǎng)站建設，甕安網(wǎng)站制作、甕安網(wǎng)頁設計、甕安網(wǎng)站官網(wǎng)定制、重慶小程序開發(fā)公司服務，打造甕安網(wǎng)絡公司原創(chuàng)品牌,更為您提供甕安網(wǎng)站排名全網(wǎng)營銷落地服務。

PG.js文件如下：

var pg = require('pg');
var conString = "postgres://username:password@localhost/databasename";
var client = new pg.Client(conString);
 
var PG = function(){
 console.log("準備向****數(shù)據(jù)庫連接...");
};
 
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數(shù)據(jù)庫連接成功...");
 });
 });
};
 
// 查詢函數(shù)
//@param str 查詢語句
//@param value 相關值
//@param cb 回調函數(shù)
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 數(shù)據(jù)表名稱
//@param fields 更新的字段和值，json格式
//@param cb 回調函數(shù)
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 數(shù)據(jù)表名稱
//@param fields 條件字段和值，json格式
//@param cb 回調函數(shù)
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 數(shù)據(jù)表名稱
//@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 數(shù)據(jù)表名稱
//@param fields 條件字段和值，json格式
//@param returnfields 返回字段
//@param cb 回調函數(shù)
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();
 
// 調用上述四個函數(shù)即可
pgclient.save('userinfo',{'name': admin},cb);<span >.</span>

關于使用Nodejs怎么操作postgresql問題的解答就分享到這里了，希望以上內容可以對大家有一定的幫助，如果你還有很多疑惑沒有解開，可以關注創(chuàng)新互聯(lián)行業(yè)資訊頻道了解更多相關知識。

網(wǎng)頁名稱：使用Nodejs怎么操作postgresql-創(chuàng)新互聯(lián)
分享路徑：http://muchs.cn/article2/dchjic.html

成都網(wǎng)站建設公司_創(chuàng)新互聯(lián)，為您提供搜索引擎優(yōu)化、微信小程序、網(wǎng)站導航、移動網(wǎng)站建設、面包屑導航、網(wǎng)站排名

廣告

聲明：本網(wǎng)站發(fā)布的內容（圖片、視頻和文字）以用戶投稿、用戶轉載內容為主，如果涉及侵權請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內容未經(jīng)允許不得轉載，或轉載時需注明來源： 創(chuàng)新互聯(lián)

小程序開發(fā)