Node.js連接postgres

一、下載Node.js postgres驅動

　　Node.js里面沒有postgres模塊的，我們需要安裝node-postgres模塊。 node-postgres模塊的下載地址為：https://github.com/brianc/node-postgres。下載完成后，解壓到pg目錄，pg里面的文件目錄結構如下圖所示：

二、編寫js代碼

1、在D盤新建文本文件重命名為，test-postgres.js。內容如下： 

var pg = require('./pg'); //加載模塊node-postgres,該模塊要與本文件放於同一個目錄下
var conString = "postgres://postgres:postgres@localhost:5432/node-test";//此時數據庫必須已經創建
                //anything://user:password@host:port/database
var client = new pg.Client(conString);

client.connect(function(err) {
    if(err) {
        return console.error('could not connect to postgres', err);
    }
     
    //刪除存在表
    console.log("Dropping table 'person'")
    var query = client.query("drop table if exists person");
    query.on('end', function() {
        console.log("Dropped!");
    });
     
    //創建表
    console.log("Creating table 'person'");
    query = client.query("create table person(id serial, username varchar(10), password varchar(10), age integer)");
    query.on('end', function(){
        console.log("Created!");
     }); 
    
    //添加
    client.query('INSERT INTO person(username, password, age) VALUES($1, $2, $3)', ["zhangsan", "123456", 20], function(err, result) {
    console.log( "====================add========================");
    if(err) {
        console.log(err); 
        return rollback(client);
    }
        console.log( result);
    }); 


    //查詢
    client.query('select username, password, age from person where id = $1', [3], function(err, result) {
    console.log( "===================query=========================");
    if(err) {
        console.log(err);  
    }
        console.log(result.rows[0]);
    });

    //更新
    client.query('update person set password=$1 where id = $2', ["11a",1], function(err, result) {
    console.log( "=====================update=======================");
    if(err) {
        console.log(err);  
    }
        console.log(result);
    });

    //刪除
    client.query('delete from person where id = $1', [1], function(err, result) {
    console.log( "====================remove=======================");
    if(err) {
        console.log(err);  
    }
        console.log(result);
        client.end();
    });
    
});
 
 var rollback = function(client) { 
  client.query('ROLLBACK', function() {
    client.end();
  });
};

2、將pg目錄拷貝至test-postgres.js文件相同目錄下,cmd進入D盤 運行命令 node testmysql.js 回車即可運行。