NodeJs之數據庫異常處理

數據庫異常

---

NodeJs版本:4.4.4

數據庫連接錯誤

使用nodejs處理異常最麻煩不過，這裏我拋開nodejs提供的domain和一些第三方庫專門處理的東西。操做數據庫是咱們經常使用的功能。經過回調，咱們這裏會有不少err出沒。

以下：

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

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:     '192.168.6.101',
    database: 'web123',
    user:     'root',
    password: 'passw0rd',
    protocol: 'mysql',
    port:     '330666',
    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('../db.js');
var runtimeLog = require('../log.js').getLogger('runlog');
var Promise = require('bluebird');

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('[err]',err)
            })
    })
}

報錯信息：

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

能夠看到錯誤都是經過catch拋出。

因此若是使用了Promise咱們能夠直接在catch中抓到下面拋出的異常。不須要再去queryPromise函數中打日誌異常了。

這裏有一篇stackoverflow處理錯誤的很是有用的問答node-js-best-practice-exception-handling