Node.js連接postgreSQL并進(jì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,
// 擴(kuò)展屬性
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進(jìn)行查詢:
// 查詢
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，運(yùn)行時使用 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()
}
}
// 異步進(jìn)行數(shù)據(jù)庫處理
query().catch(e => console.error(e.message, e.stack));
在升級了nodejs之后，執(zhí)行代碼的時候，需要加參數(shù)--harmony-async-await
npm --harmony-async-await index.js
當(dāng)然，都支持到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])
})
})
上面插入、更新里代碼都沒有進(jìn)行錯誤處理，按道理是要加的，但如果要加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ù)庫進(jìn)行測試（與數(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)系。
總結(jié)
以上就是這篇文章的全部內(nèi)容了，希望本文的內(nèi)容對大家的學(xué)習(xí)或者工作能有一定的幫助，如果有疑問大家可以留言交流。
相關(guān)文章
基于node簡單實(shí)現(xiàn)RSA加解密的方法步驟
這篇文章主要介紹了基于node簡單實(shí)現(xiàn)RSA加解密的方法步驟，小編覺得挺不錯的，現(xiàn)在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2019-03-03
這篇文章介紹了在Ubuntu?18.04上安裝Node.js?14.16.0的詳細(xì)步驟,包括檢查服務(wù)器類型、下載合適的Node.js版本、解壓和移動文件夾、編輯環(huán)境變量文件、重新編譯配置文件以及解決可能遇到的版本沖突問題,感興趣的朋友跟隨小編一起看看吧2024-11-11
本文記錄了連接遠(yuǎn)程MySQL數(shù)據(jù)庫過程中遇到的常見問題及解決方案,包括用戶權(quán)限、防火墻、安全組、VPN等,具有一定的參考價值,感興趣的可以了解一下2025-08-08
本文介紹了Node.js中用于處理文件上傳的Multer中間件,詳細(xì)說明了項(xiàng)目設(shè)置、安裝依賴的步驟,以及如何使用Multer上傳單個和多個文件,還介紹了DiskStorage引擎、其他配置選項(xiàng)和錯誤處理方法,感興趣的朋友跟隨小編一起看看吧2025-03-03
nodejs文件實(shí)現(xiàn)打包成exe, 并設(shè)置開機(jī)自啟動的方法詳解(沒有黑窗口)
這篇文章主要介紹了nodejs文件實(shí)現(xiàn)打包成exe, 并設(shè)置開機(jī)自啟動的方法,結(jié)合實(shí)例形式分析了node.js使用pkg包實(shí)現(xiàn)生成exe可執(zhí)行文件的相關(guān)操作技巧,需要的朋友可以參考下2023-05-05
Node.js對MongoDB進(jìn)行增刪改查操作的實(shí)例代碼
這篇文章主要介紹了Node.js對MongoDB進(jìn)行增刪改查操作 ,需要的朋友可以參考下2019-04-04
這篇文章主要給大家介紹了npm使用淘寶鏡像及切換回官方源的操作命令,文中給大家介紹的非常詳細(xì),對大家的學(xué)習(xí)或工作有一定的幫助,需要的朋友可以參考下2024-02-02
本篇文章主要介紹了node使用UEditor富文本編輯器的方法實(shí)例，具有一定的參考價值，有興趣的可以了解一下2017-07-07
本文主要介紹了淺談如何把Node項(xiàng)目部署到服務(wù)器上，文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值，需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2023-02-02
Node.js中使用mongoose操作mongodb數(shù)據(jù)庫的方法
如何利用mongoose將數(shù)據(jù)寫入mongodb數(shù)據(jù)庫呢？操作方法很簡單，下面小編給大家分享Node.js中使用mongoose操作mongodb數(shù)據(jù)庫的方法，感興趣的朋友一起看看吧2017-09-09