首頁 >web前端 >js教程 >NodeJs資料庫異常處理解析

NodeJs資料庫異常處理解析

小云云原創: 2018-01-22 10:15:321596瀏覽

本文主要介紹了淺談NodeJs之資料庫異常處理,小編覺得挺不錯的，現在分享給大家，也給大家做個參考。一起跟著小編過來看看吧，希望能幫助大家。

NodeJs版本:4.4.4

資料庫連結錯誤

使用nodejs處理異常最麻煩不過，這裡我拋開nodejs提供的domain和一些第三方函式庫專門處理的東西。操作資料庫是我們常用的功能。透過回調，我們這裡會有很多err出沒。

如下：

var pool = require(&#39;../db.js&#39;);
var runtimeLog = require(&#39;../log.js&#39;).getLogger(&#39;runlog&#39;);
var Promise = require(&#39;bluebird&#39;);

function queryPromise(queryString) {
  return new Promise(function(resolve, reject) {
    pool.getConnection(function(err, connection) {
    
      //connection.query(queryString, function(err, rows, fields) {
        
      // if (!err) {
      //   resolve(rows);
      //  } else {
      //   runtimeLog.error(err)
      //   reject(err)
      //  }
      // connection.release();
      //});
    })
  })
}

module.exports = function() {
  return new Promise(function(resolve, reject) {

    queryPromise("select * from wb123_home_map GROUP BY onestair")
      .then(function(results){
        resolve(results);

      })
      .catch(function(err){
        runtimeLog.error(err)
      })
  })
}

可以看到2個回呼的地方都會有出錯的可能。

而這是一個模組，我們將它導出了。

這裡我們故意將資料庫連結的連接埠號碼填錯,寫成330666:

module.exports = {
  host:   &#39;192.168.6.101&#39;,
  database: &#39;web123&#39;,
  user:   &#39;root&#39;,
  password: &#39;passw0rd&#39;,
  protocol: &#39;mysql&#39;,
  port:   &#39;330666&#39;,
  query:  {pool: true}
}

這樣的話，在我們連結資料庫的時候是會出錯的。

這裡我們使用了promise，所以在導出的函數中，我們使用了catch,他會抓到queryPromise函數中的錯誤，並印到日誌中。

[2017-01-05 13:27:59.648] [ERROR] runlog - [err] [RangeError: port should be >= 0 and < 65536: 330666]
RangeError: port should be >= 0 and < 65536: 330666
...

資料庫sql語句錯誤

我們修改一下程式碼，將資料庫連結填對，修改sql語句為錯誤的語句。

var pool = require(&#39;../db.js&#39;);
var runtimeLog = require(&#39;../log.js&#39;).getLogger(&#39;runlog&#39;);
var Promise = require(&#39;bluebird&#39;);

function queryPromise(queryString) {
  return new Promise(function(resolve, reject) {
    pool.getConnection(function(err, connection) {
      
      connection.query(queryString, function(err, rows, fields) {
        //if (err) throw err;
        if (!err) {
          resolve(rows);
         } else {
          reject(err)
         }
        connection.release();
      });
    })
  })
}

module.exports = function() {
  return new Promise(function(resolve, reject) {

    queryPromise("select * from wb123_home_map GROUP BY onestairs")
      .then(function(results){
        resolve(results);

      })
      .catch(function(err){
        runtimeLog.error(&#39;[err]&#39;,err)
      })
  })
}

報錯訊息：

[2017-01-05 14:40:14.518] [ERROR] runlog - [err] { [Error: ER_BAD_FIELD_ERROR: Unknown column &#39;onestairs&#39; in &#39;group statement&#39;]
 code: &#39;ER_BAD_FIELD_ERROR&#39;,
 errno: 1054,
 sqlState: &#39;42S22&#39;,
 index: 0 }
Error: ER_BAD_FIELD_ERROR: Unknown column &#39;onestairs&#39; in &#39;group statement&#39;
  at Query.Sequence._packetToError (E:\zz\zz_wb123\manage\trunk\code\nod
....

可以看到錯誤都是透過catch拋出。

所以如果使用了Promise我們可以直接在catch中抓到下面拋出的例外。不需要再去queryPromise函數中打日誌異常了。

NodeJs資料庫異常處理解析

相關文章