数据库链接错误
使用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函数中打日志异常了。
以上就是nodejs之关于数据库异常处理的解决方法的详细内容。
   
 
   