데이터베이스 예외 처리에 대한 NodeJs의 솔루션

데이터베이스 링크 오류

nodejs를 사용하여 예외를 처리하는 것이 가장 번거롭습니다. 하지만 여기서는 nodejs에서 제공하는 domain과 이를 특별히 처리하는 일부 타사 라이브러리를 제쳐두겠습니다. 데이터베이스를 운영하는 것은 우리가 흔히 사용하는 기능입니다. 콜백을 통해 여기서는 많은 오류가 발생합니다.

다음과 같습니다.

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)
      })
  })
}

두 콜백 모두 오류가 발생할 가능성이 있음을 알 수 있습니다.

그리고 이것은 모듈이고, 우리는 그것을 내보냈습니다.

여기서는 의도적으로 데이터베이스 연결을 위해 잘못된 포트 번호를 입력하여 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의 솔루션의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!