點擊下載
本文文檔

當前位置：首頁 - 科技 - 知識百科 - 正文

關(guān)于Node.js連接postgreSQL并進行數(shù)據(jù)操作的介紹

來源：懂視網(wǎng) 責編：小采時間：2020-11-27 19:34:43

關(guān)于Node.js連接postgreSQL并進行數(shù)據(jù)操作的介紹

關(guān)于Node.js連接postgreSQL并進行數(shù)據(jù)操作的介紹:這篇文章就給大家介紹了關(guān)于Node.js如何連接postgreSQL數(shù)據(jù)庫，并進行數(shù)據(jù)操作的方法，有需要的朋友們可以參考借鑒，下面來一起看看吧。自從MySQL被Oracle收購以后，PostgreSQL逐漸成為開源關(guān)系型數(shù)據(jù)庫的首選前言PostgreSql是一個面向?qū)ο蟮年P(guān)系數(shù)據(jù)

推薦度：

點擊下載本文 文檔為doc格式

導讀關(guān)于Node.js連接postgreSQL并進行數(shù)據(jù)操作的介紹:這篇文章就給大家介紹了關(guān)于Node.js如何連接postgreSQL數(shù)據(jù)庫，并進行數(shù)據(jù)操作的方法，有需要的朋友們可以參考借鑒，下面來一起看看吧。自從MySQL被Oracle收購以后，PostgreSQL逐漸成為開源關(guān)系型數(shù)據(jù)庫的首選前言PostgreSql是一個面向?qū)ο蟮年P(guān)系數(shù)據(jù)

這篇文章就給大家介紹了關(guān)于Node.js如何連接postgreSQL數(shù)據(jù)庫，并進行數(shù)據(jù)操作的方法，有需要的朋友們可以參考借鑒，下面來一起看看吧。

自從MySQL被Oracle收購以后，PostgreSQL逐漸成為開源關(guān)系型數(shù)據(jù)庫的首選

前言

PostgreSql是一個面向?qū)ο蟮年P(guān)系數(shù)據(jù)庫，postgis是一個基于PostgreSql的空間數(shù)據(jù)庫插件，主要用于管理地理空間數(shù)據(jù)。因此在GIS領(lǐng)域，廣泛使用PostgreSql作為空間數(shù)據(jù)庫。

首先使用npm安裝數(shù)據(jù)庫連接模塊：

npm install --save pg

連接池創(chuàng)建

然后代碼中引入pg模塊，并編寫數(shù)據(jù)庫配置：

var pg = require('pg');
// 數(shù)據(jù)庫配置
var config = { 
 user:"postgres",
 database:"ghost",
 password:"123456",
 port:5432,

 // 擴展屬性
 max:20, // 連接池最大連接數(shù)
 idleTimeoutMillis:3000, // 連接最大空閑時間 3s
}

pg模塊中有兩種數(shù)據(jù)庫連接方式，先講連接池模式，下面是創(chuàng)建連接池：

// 創(chuàng)建連接池
var pool = new pg.Pool(config);

傳入配置后就創(chuàng)建好了連接池。

查詢數(shù)據(jù)

查詢首先創(chuàng)建好連接，然后調(diào)用api進行查詢:

// 查詢
pool.connect(function(err, client, done) { 
 if(err) {
 return console.error('數(shù)據(jù)庫連接出錯', err);
 }
 // 簡單

輸出個 Hello World client.query('SELECT $1::varchar AS OUT', ["Hello World"], function(err, result) { done();// 釋放連接（將其返回給連接池） if(err) { return console.error('查詢出錯', err); } console.log(result.rows[0].out); //output: Hello World }); });

輸出：

Hello World

參數(shù)done是一個函數(shù)，調(diào)用這個函數(shù)可以將關(guān)閉連接（即將連接還給連接池）。

上面的是需要寫回調(diào)的異步查詢，可以使用ES 7中await和async（但需安裝最新版本的pg，另外，需要使用7.2以上的nodejs，最好就是用最新的nodejs）優(yōu)化代碼，如下：

// Async & Await 方式（需 node ^7.2.1，運行時使用 node --harmony-async-await index.js）
var query = async () => { 
 // 同步創(chuàng)建連接
 var connect = await pool.connect()
 try {
 // 同步等待結(jié)果
 var res = await connect.query('SELECT $1::varchar AS OUT', ['Hello World By Async&Await'])
 console.log(res.rows[0].out) // 可以通過rows遍歷數(shù)據(jù)
 } finally {
 connect.release()
 }
}

// 異步進行數(shù)據(jù)庫處理
query().catch(e => console.error(e.message, e.stack));

在升級了nodejs之后，執(zhí)行代碼的時候，需要加參數(shù)--harmony-async-await

npm --harmony-async-await index.js

當然，都支持到ES7了，ES6的Promise方法肯定是支持的，如下：

pool.connect().then(client=>{ 
 client.query('SELECT $1::varchar AS OUT', ['Hello World By Promise']).then(res=>{
 client.release()
 console.log(res.rows[0].out)
 }).catch(e => {
 client.release()
 console.error('query error', e.message, e.stack)
 })
})

插入、修改、刪除數(shù)據(jù)

插入、修改、刪除數(shù)據(jù)和查詢的差不多

// 在表test中插入、修改、刪除數(shù)據(jù)，共兩個字段 (name, age)
pool.connect().then(client=>{ 
 // insert 數(shù)據(jù)
 client.query("INSERT INTO test(name, age) VALUES($1::varchar, $2::int)", ["xiaoming","20"]).then(res=>{
 console.log("Insert Success")
 // 如果是自增ID，有返回值的，在res里
 return res;
 }).then(res=>{
 // 查詢xiaoming
 return client.query("Select * FROM test WHERE name = $1", ["xiaoming"]);
 }).then(res=>{
 //

輸出結(jié)果，看是否插入成功 console.log(res.rows[0]) }).then(res=>{ // update 數(shù)據(jù)，將age改為21 return client.query("UPDATE test SET age=$1 WHERE name=$2", [21, "xiaoming"]) }).then(res=>{ // 再查詢一次xiaoming return client.query("Select * FROM test WHERE name = $1", ["xiaoming"]); }).then(res=>{ // 再輸出結(jié)果，看是否改為了21 console.log(res.rows[0]) }).then(res=>{ // 刪除數(shù)據(jù) client.query("DELETE FROM test WHERE name=$1", ["xiaoming"]) }).then(res=>{ // 最后再查詢一次xiaoming res = client.query("Select * FROM test WHERE name = $1", ["xiaoming"]); // 釋放連接 client.release() return res }).then(res=>{ // 再輸出結(jié)果，沒數(shù)據(jù) undefined console.log(res.rows[0]) }) })

上面插入、更新里代碼都沒有進行錯誤處理，按道理是要加的，但如果要加try...catch...的話，就太麻煩了（畢竟只是示例）.

事件監(jiān)聽

可以添加error事件方法監(jiān)聽連接池情況

pool.on("error", function(err, client){ 
 console.log("error --> ", err)
})

現(xiàn)在連接池的最大空閑時間是3s，也就是3s還沒使用連接，就釋放連接，可將這個時間設(shè)置得長一些，比如30s，這就讓我們有足夠的時間關(guān)掉數(shù)據(jù)庫進行測試（與數(shù)據(jù)庫連接一斷開，這個事件就被觸發(fā)了，生產(chǎn)環(huán)境中，可以用來寫日志啊、發(fā)郵件短信通知什么的。。）。

另外，還可以監(jiān)聽acquire和connect事件，前者在連接被客戶端獲取時觸發(fā)，后者在連接生成以及客戶端與數(shù)據(jù)庫交互時觸發(fā)。

pool.on('acquire', function (client) { 
 console.log("acquire Event")
})

pool.on('connect', function () { 
 console.log("connect Event")
})

不使用連接池的客戶端

不使用連接池時，直接創(chuàng)建客戶端即可：

var client = new pg.Client();

連接池只是用來管理（緩存）連接（即客戶端）的，查詢之類的方法跟它沒關(guān)系。

聲明：本網(wǎng)頁內(nèi)容旨在傳播知識，若有侵權(quán)等問題請及時與本網(wǎng)聯(lián)系，我們將在第一時間刪除處理。TEL:177 7030 7066 E-MAIL:11247931@qq.com

關(guān)于Node.js連接postgreSQL并進行數(shù)據(jù)操作的介紹

推薦度：

點擊下載本文 文檔為doc格式

標簽：操作數(shù)據(jù) js

熱門焦點

關(guān)于Node.js連接postgreSQL并進行數(shù)據(jù)操作的介紹

關(guān)于Node.js連接postgreSQL并進行數(shù)據(jù)操作的介紹

關(guān)于Node.js連接postgreSQL并進行數(shù)據(jù)操作的介紹

最新推薦

猜你喜歡

熱門推薦