经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
当前位置:技术经验 » JS/JS库/框架 » Node.js » 查看文章
Nodejs对postgresql基本操作的封装方法
来源:jb51  时间:2019/2/21 9:23:00  对本文有异议

基于nodejs平台对postgresql的增删改查基本操作进行了封装,能满足基本的实际应用,比较复杂的SQL需另外实现。

PG.js文件如下:

  1. var pg = require('pg');
  2. var conString = "postgres://username:password@localhost/databasename";
  3. var client = new pg.Client(conString);
  4. var PG = function(){
  5. console.log("准备向****数据库连接...");
  6. };
  7. PG.prototype.getConnection = function(){
  8. client.connect(function (err) {
  9. if (err) {
  10. return console.error('could not connect to postgres', err);
  11. }
  12. client.query('SELECT NOW() AS "theTime"', function (err, result) {
  13. if (err) {
  14. return console.error('error running query', err);
  15. }
  16. console.log("hbdfxt数据库连接成功...");
  17. });
  18. });
  19. };
  20. // 查询函数
  21. //@param str 查询语句
  22. //@param value 相关值
  23. //@param cb 回调函数
  24. var clientHelper = function(str,value,cb){
  25. client.query(str,value,function(err,result){
  26. if(err) {
  27. cb("err");
  28. }
  29. else{
  30. if(result.rows != undefined)
  31. cb(result.rows);
  32. else
  33. cb();
  34. }
  35. });
  36. }
  37. //增
  38. //@param tablename 数据表名称
  39. //@param fields 更新的字段和值,json格式
  40. //@param cb 回调函数
  41. PG.prototype.save = function(tablename,fields,cb){
  42. if(!tablename) return;
  43. var str = "insert into "+tablename+"(";
  44. var field = [];
  45. var value = [];
  46. var num = [];
  47. var count = 0;
  48. for(var i in fields){
  49. count++;
  50. field.push(i);
  51. value.push(fields[i]);
  52. num.push("$"+count);
  53. }
  54. str += field.join(",") +") values("+num.join(",")+")";
  55. clientHelper(str,value,cb);
  56. };
  57. //删除
  58. //@param tablename 数据表名称
  59. //@param fields 条件字段和值,json格式
  60. //@param cb 回调函数
  61. PG.prototype.remove = function(tablename,fields,cb){
  62. if(!tablename) return;
  63. var str = "delete from "+tablename+" where ";
  64. var field = [];
  65. var value = [];
  66. var count = 0;
  67. for(var i in fields){
  68. count++;
  69. field.push(i+"=$" +count);
  70. value.push(fields[i]);
  71. }
  72. str += field.join(" and ");
  73. clientHelper(str,value,cb);
  74. }
  75. //修改
  76. //@param tablename 数据表名称
  77. //@param fields 更新的字段和值,json格式
  78. //@param mainfields 条件字段和值,json格式
  79. PG.prototype.update = function(tablename,mainfields,fields,cb){
  80. if(!tablename) return;
  81. var str = "update "+tablename+" set ";
  82. var field = [];
  83. var value = [];
  84. var count = 0;
  85. for(var i in fields){
  86. count++;
  87. field.push(i+"=$"+count);
  88. value.push(fields[i]);
  89. }
  90. str += field.join(",") +" where ";
  91. field = [];
  92. for(var j in mainfields){
  93. count++;
  94. field.push(j+"=$"+count);
  95. value.push(mainfields[j]);
  96. }
  97. str += field.join(" and ");
  98. clientHelper(str,value,cb);
  99. }
  100. //查询
  101. //@param tablename 数据表名称
  102. //@param fields 条件字段和值,json格式
  103. //@param returnfields 返回字段
  104. //@param cb 回调函数
  105. PG.prototype.select = function(tablename,fields,returnfields,cb){
  106. if(!tablename) return;
  107. var returnStr = "";
  108. if(returnfields.length == 0)
  109. returnStr = '*';
  110. else
  111. returnStr= returnfields.join(",");
  112. var str = "select "+returnStr+ " from "+tablename+" where ";
  113. var field = [];
  114. var value = [];
  115. var count = 0;
  116. for(var i in fields){
  117. count++;
  118. field.push(i+"=$"+count);
  119. value.push(fields[i]);
  120. }
  121. str += field.join(" and ");
  122. clientHelper(str,value,cb);
  123. };
  124. module.exports = new PG();

用法很简单,如下:

  1. var pgclient = require('./PG');// 引用上述文件
  2. pgclient.getConnection();
  3. // 调用上述四个函数即可
  4. pgclient.save('userinfo',{'name': admin},cb);<span style="font-family: Arial, Helvetica, sans-serif;">.</span>

以上这篇Nodejs对postgresql基本操作的封装方法就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持w3xue。

 友情链接:直通硅谷  点职佳  北美留学生论坛

本站QQ群:前端 618073944 | Java 606181507 | Python 626812652 | C/C++ 612253063 | 微信 634508462 | 苹果 692586424 | C#/.net 182808419 | PHP 305140648 | 运维 608723728

W3xue 的所有内容仅供测试,对任何法律问题及风险不承担任何责任。通过使用本站内容随之而来的风险与本站无关。
关于我们  |  意见建议  |  捐助我们  |  报错有奖  |  广告合作、友情链接(目前9元/月)请联系QQ:27243702 沸活量
皖ICP备17017327号-2 皖公网安备34020702000426号