NodeJsにおけるデータベース例外処理の詳細説明-jsチュートリアル-php.cn

NodeJsにおけるデータベース例外処理の詳細説明

小云云

リリース： 2018-01-03 11:28:50

オリジナル

1792 人が閲覧しました

この記事は主に 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('../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 ノード-js-best-practice-Exception-handling に関する非常に役立つ Q&A があります