>  기사  >  웹 프론트엔드  >  NodeJs 데이터베이스 예외 처리 분석

NodeJs 데이터베이스 예외 처리 분석

小云云
小云云원래의
2018-01-22 10:15:321531검색

이 글은 주로 NodeJs의 데이터베이스 예외 처리에 대한 간략한 논의를 소개합니다. 편집자는 그것이 꽤 좋다고 생각하므로 지금 공유하고 참고용으로 제공하겠습니다. 편집자를 따라 살펴보겠습니다. 모두에게 도움이 되기를 바랍니다.

NodeJs 버전: 4.4.4

데이터베이스 링크 오류

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(&#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 함수에서는 예외를 기록할 필요가 없습니다.

관련 권장 사항:

sqlserver 데이터베이스에 연결하기 위한 mssql 모듈 기반 nodejs의 간단한 캡슐화 작업 분석 예

TP5 데이터베이스 작업

javascript를 통해 odbc를 통해 mysql과 php를 연결하여 모든 데이터베이스에 연결 인스턴스 공유

위 내용은 NodeJs 데이터베이스 예외 처리 분석의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!

성명:
본 글의 내용은 네티즌들의 자발적인 기여로 작성되었으며, 저작권은 원저작자에게 있습니다. 본 사이트는 이에 상응하는 법적 책임을 지지 않습니다. 표절이나 침해가 의심되는 콘텐츠를 발견한 경우 admin@php.cn으로 문의하세요.