From 03d55b4fb59b95d54b9387379876fd6ee4289b02 Mon Sep 17 00:00:00 2001 From: Mikhail Chechnev Date: Tue, 27 Nov 2018 17:13:32 +0300 Subject: [PATCH] =?UTF-8?q?=D0=9A=D0=BE=D1=80=D1=80=D0=B5=D0=BA=D1=82?= =?UTF-8?q?=D0=B8=D1=80=D0=BE=D0=B2=D0=BA=D0=B0=20=D1=81=D0=BE=D0=BE=D0=B1?= =?UTF-8?q?=D1=89=D0=B5=D0=BD=D0=B8=D0=B9=20=D0=BE=D0=B1=20=D0=BE=D1=88?= =?UTF-8?q?=D0=B8=D0=B1=D0=BA=D0=B0=D1=85=20=D0=B2=D0=B0=D0=BB=D0=B8=D0=B4?= =?UTF-8?q?=D0=B0=D1=86=D0=B8=D0=B8=20=D0=B2=20=D0=BA=D0=BE=D0=BD=D1=81?= =?UTF-8?q?=D1=82=D1=80=D1=83=D0=BA=D1=82=D0=BE=D1=80=D0=B5=20=D0=B8=20?= =?UTF-8?q?=D0=B8=D0=BD=D0=B8=D1=86=D0=B8=D0=B0=D0=BB=D0=B8=D0=B7=D0=B0?= =?UTF-8?q?=D1=86=D0=B8=D1=8F=20=D0=B0=D1=82=D1=80=D0=B8=D0=B1=D1=83=D1=82?= =?UTF-8?q?=D0=B0=20=D0=B4=D0=BB=D1=8F=20=D0=BF=D0=BE=D0=BB=D1=8C=D0=B7?= =?UTF-8?q?=D0=BE=D0=B2=D0=B0=D1=82=D0=B5=D0=BB=D1=8C=D1=81=D0=BA=D0=BE?= =?UTF-8?q?=D0=B3=D0=BE=20=D0=BC=D0=BE=D0=B4=D1=83=D0=BB=D1=8F=20=D0=B2?= =?UTF-8?q?=D0=B7=D0=B0=D0=B8=D0=BC=D0=BE=D0=B4=D0=B5=D0=B9=D1=81=D1=82?= =?UTF-8?q?=D0=B2=D0=B8=D1=8F=20=D1=81=20=D0=91=D0=94?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- core/db_connector.js | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/core/db_connector.js b/core/db_connector.js index db70e4d..7faec5e 100644 --- a/core/db_connector.js +++ b/core/db_connector.js @@ -12,7 +12,7 @@ const EventEmitter = require("events"); //Обработчик пользова const glConst = require("../core/constants"); //Глобальные константы const { ServerError } = require("../core/server_errors"); //Типовая ошибка const { makeModuleFullPath, validateObject } = require("../core/utils"); //Вспомогательные функции -const prmsDBConnectorSchema = require("../models/prms_db_connector"); //Схемы валидации параметров процедур модуля +const prmsDBConnectorSchema = require("../models/prms_db_connector"); //Схемы валидации параметров функций модуля const intfDBConnectorModuleSchema = require("../models/intf_db_connector_module"); //Схема валидации интерфейса модуля взаимодействия с БД const objServicesSchema = require("../models/obj_services"); //Схема валидации списка сервисов const objQueueSchema = require("../models/obj_queue"); //Схема валидации сообщения очереди обмена @@ -43,7 +43,11 @@ class DBConnector extends EventEmitter { //создадим экземпляр родительского класса super(); //Проверяем структуру переданного объекта для подключения - let sCheckResult = validateObject(prms, prmsDBConnectorSchema.DBConnector, "Параметры конструктора"); + let sCheckResult = validateObject( + prms, + prmsDBConnectorSchema.DBConnector, + "Параметры конструктора класса DBConnector" + ); //Если структура объекта в норме if (!sCheckResult) { //Проверяем наличие модуля для работы с БД в настройках подключения @@ -62,7 +66,7 @@ class DBConnector extends EventEmitter { //Всё успешно - сохраним настройки подключения this.connectSettings = _.cloneDeep(prms); //Инициализируем остальные свойства - this.connection = {}; + this.connection = null; this.bConnected = false; } else { throw new ServerError( @@ -100,7 +104,7 @@ class DBConnector extends EventEmitter { //Отключаемся await this.connector.disconnect({ connection: this.connection }); //Забываем подключение и удаляем флаги подключенности - this.connection = {}; + this.connection = null; this.bConnected = false; //Расскажем всем, что отключились this.emit(SEVT_DB_CONNECTOR_DISCONNECTED);