@newbility/database
Advanced tools
| import { AppModule, ISettingManager } from '@newbility/core'; | ||
| import { DatabaseType } from './DatabaseOptions'; | ||
| export declare abstract class DatabaseModuleBase extends AppModule { | ||
| protected readonly SettingManager: ISettingManager; | ||
| protected readonly DbType: DatabaseType; | ||
| constructor(dbType: DatabaseType); | ||
| OnPreApplicationInitialization(): void; | ||
| protected RegisterDbProvider(dbKey: string): void; | ||
| protected abstract GetDbProvider(key: string): any; | ||
| } |
| "use strict"; | ||
| var __decorate = (this && this.__decorate) || function (decorators, target, key, desc) { | ||
| var c = arguments.length, r = c < 3 ? target : desc === null ? desc = Object.getOwnPropertyDescriptor(target, key) : desc, d; | ||
| if (typeof Reflect === "object" && typeof Reflect.decorate === "function") r = Reflect.decorate(decorators, target, key, desc); | ||
| else for (var i = decorators.length - 1; i >= 0; i--) if (d = decorators[i]) r = (c < 3 ? d(r) : c > 3 ? d(target, key, r) : d(target, key)) || r; | ||
| return c > 3 && r && Object.defineProperty(target, key, r), r; | ||
| }; | ||
| var __metadata = (this && this.__metadata) || function (k, v) { | ||
| if (typeof Reflect === "object" && typeof Reflect.metadata === "function") return Reflect.metadata(k, v); | ||
| }; | ||
| Object.defineProperty(exports, "__esModule", { value: true }); | ||
| exports.DatabaseModuleBase = void 0; | ||
| const core_1 = require("@newbility/core"); | ||
| const DatabaseModule_1 = require("./DatabaseModule"); | ||
| const DatabaseProvider_1 = require("./DatabaseProvider"); | ||
| let DatabaseModuleBase = class DatabaseModuleBase extends core_1.AppModule { | ||
| constructor(dbType) { | ||
| super(); | ||
| this.SettingManager = core_1.Container.resolve(core_1.SETTING_INJECT_TOKEN); | ||
| this.DbType = dbType; | ||
| } | ||
| OnPreApplicationInitialization() { | ||
| const dbSettings = this.SettingManager.GetConfig('databases'); | ||
| if (dbSettings) { | ||
| const dbKeys = Object.getOwnPropertyNames(dbSettings); | ||
| if (dbKeys && dbKeys.length) { | ||
| for (const dbKey in dbKeys) { | ||
| const dbOptions = dbSettings[dbKey]; | ||
| if (dbOptions.type === this.DbType) { | ||
| this.RegisterDbProvider(dbKey); | ||
| } | ||
| } | ||
| } | ||
| } | ||
| } | ||
| RegisterDbProvider(dbKey) { | ||
| const ProviderType = this.GetDbProvider(dbKey); | ||
| const dbToken = (0, DatabaseProvider_1.GetDatabaseProviderToken)(dbKey); | ||
| core_1.Container.registerSingleton(dbToken, ProviderType); | ||
| } | ||
| }; | ||
| DatabaseModuleBase = __decorate([ | ||
| (0, core_1.DependsOn)(DatabaseModule_1.DatabaseModule), | ||
| __metadata("design:paramtypes", [String]) | ||
| ], DatabaseModuleBase); | ||
| exports.DatabaseModuleBase = DatabaseModuleBase; | ||
| //# sourceMappingURL=DatabaseModuleBase.js.map |
| {"version":3,"file":"DatabaseModuleBase.js","sourceRoot":"","sources":["../../src/DatabaseModuleBase.ts"],"names":[],"mappings":";;;;;;;;;;;;AAAA,0CAAyG;AACzG,qDAAkD;AAElD,yDAAiF;AAG1E,IAAe,kBAAkB,GAAjC,MAAe,kBAAmB,SAAQ,gBAAS;IAIxD,YAAY,MAAoB;QAC9B,KAAK,EAAE,CAAC;QACR,IAAI,CAAC,cAAc,GAAG,gBAAS,CAAC,OAAO,CAAkB,2BAAoB,CAAC,CAAC;QAC/E,IAAI,CAAC,MAAM,GAAG,MAAM,CAAC;IACvB,CAAC;IAEQ,8BAA8B;QACrC,MAAM,UAAU,GAAG,IAAI,CAAC,cAAc,CAAC,SAAS,CAAkB,WAAW,CAAC,CAAC;QAC/E,IAAI,UAAU,EAAE;YACd,MAAM,MAAM,GAAG,MAAM,CAAC,mBAAmB,CAAC,UAAU,CAAC,CAAC;YACtD,IAAI,MAAM,IAAI,MAAM,CAAC,MAAM,EAAE;gBAC3B,KAAK,MAAM,KAAK,IAAI,MAAM,EAAE;oBAC1B,MAAM,SAAS,GAAG,UAAU,CAAC,KAAK,CAAC,CAAC;oBACpC,IAAI,SAAS,CAAC,IAAI,KAAK,IAAI,CAAC,MAAM,EAAE;wBAClC,IAAI,CAAC,kBAAkB,CAAC,KAAK,CAAC,CAAC;qBAChC;iBACF;aACF;SACF;IACH,CAAC;IAES,kBAAkB,CAAC,KAAa;QACxC,MAAM,YAAY,GAAG,IAAI,CAAC,aAAa,CAAC,KAAK,CAAC,CAAC;QAC/C,MAAM,OAAO,GAAG,IAAA,2CAAwB,EAAC,KAAK,CAAC,CAAC;QAChD,gBAAS,CAAC,iBAAiB,CAAoB,OAAO,EAAE,YAAY,CAAC,CAAC;IACxE,CAAC;CAGF,CAAA;AAhCqB,kBAAkB;IADvC,IAAA,gBAAS,EAAC,+BAAc,CAAC;;GACJ,kBAAkB,CAgCvC;AAhCqB,gDAAkB"} |
+3
-2
| import { IDatabaseClient, ExecuteResult, DatabaseClient } from './src/DatabaseClient'; | ||
| import { DatabaseModule } from './src/DatabaseModule'; | ||
| import { DatabaseType, DatabaseOptions, DatabaseOptionsBase } from './src/DatabaseOptions'; | ||
| import { DatabaseModuleBase } from './src/DatabaseModuleBase'; | ||
| import { DatabaseType, DatabaseOptions, DatabaseOptionsBase, DatabaseSetting } from './src/DatabaseOptions'; | ||
| import { DB_PROVIDER_INJECT_TOKEN, GetDatabaseProviderToken, IDatabaseProvider, DatabaseProvider } from './src/DatabaseProvider'; | ||
| import { DatabaseProviderFactory, DB_PROVIDER_FAC_INJECT_TOKEN, IDatabaseProviderFactory } from './src/DatabaseProviderFactory'; | ||
| export { DatabaseModule, DatabaseType, DatabaseOptions, DatabaseOptionsBase, IDatabaseClient, ExecuteResult, DatabaseClient, DB_PROVIDER_INJECT_TOKEN, GetDatabaseProviderToken, IDatabaseProvider, DatabaseProvider, DB_PROVIDER_FAC_INJECT_TOKEN, IDatabaseProviderFactory, DatabaseProviderFactory, }; | ||
| export { DatabaseModule, DatabaseModuleBase, DatabaseType, DatabaseSetting, DatabaseOptions, DatabaseOptionsBase, IDatabaseClient, ExecuteResult, DatabaseClient, DB_PROVIDER_INJECT_TOKEN, GetDatabaseProviderToken, IDatabaseProvider, DatabaseProvider, DB_PROVIDER_FAC_INJECT_TOKEN, IDatabaseProviderFactory, DatabaseProviderFactory, }; |
+3
-1
| "use strict"; | ||
| Object.defineProperty(exports, "__esModule", { value: true }); | ||
| exports.DatabaseProviderFactory = exports.DB_PROVIDER_FAC_INJECT_TOKEN = exports.DatabaseProvider = exports.GetDatabaseProviderToken = exports.DB_PROVIDER_INJECT_TOKEN = exports.DatabaseClient = exports.DatabaseModule = void 0; | ||
| exports.DatabaseProviderFactory = exports.DB_PROVIDER_FAC_INJECT_TOKEN = exports.DatabaseProvider = exports.GetDatabaseProviderToken = exports.DB_PROVIDER_INJECT_TOKEN = exports.DatabaseClient = exports.DatabaseModuleBase = exports.DatabaseModule = void 0; | ||
| const DatabaseClient_1 = require("./src/DatabaseClient"); | ||
@@ -8,2 +8,4 @@ Object.defineProperty(exports, "DatabaseClient", { enumerable: true, get: function () { return DatabaseClient_1.DatabaseClient; } }); | ||
| Object.defineProperty(exports, "DatabaseModule", { enumerable: true, get: function () { return DatabaseModule_1.DatabaseModule; } }); | ||
| const DatabaseModuleBase_1 = require("./src/DatabaseModuleBase"); | ||
| Object.defineProperty(exports, "DatabaseModuleBase", { enumerable: true, get: function () { return DatabaseModuleBase_1.DatabaseModuleBase; } }); | ||
| const DatabaseProvider_1 = require("./src/DatabaseProvider"); | ||
@@ -10,0 +12,0 @@ Object.defineProperty(exports, "DB_PROVIDER_INJECT_TOKEN", { enumerable: true, get: function () { return DatabaseProvider_1.DB_PROVIDER_INJECT_TOKEN; } }); |
@@ -1,1 +0,1 @@ | ||
| {"version":3,"file":"index.js","sourceRoot":"","sources":["../index.ts"],"names":[],"mappings":";;;AAAA,yDAAsF;AAapF,+FAbuC,+BAAc,OAavC;AAZhB,yDAAsD;AAMpD,+FANO,+BAAc,OAMP;AAJhB,6DAAiI;AAW/H,yGAXO,2CAAwB,OAWP;AACxB,yGAZiC,2CAAwB,OAYjC;AAExB,iGAd8E,mCAAgB,OAc9E;AAblB,2EAAgI;AAgB9H,wGAhBO,iDAAuB,OAgBP;AAFvB,6GAdgC,sDAA4B,OAchC"} | ||
| {"version":3,"file":"index.js","sourceRoot":"","sources":["../index.ts"],"names":[],"mappings":";;;AAAA,yDAAsF;AAgBpF,+FAhBuC,+BAAc,OAgBvC;AAfhB,yDAAsD;AAOpD,+FAPO,+BAAc,OAOP;AANhB,iEAA8D;AAO5D,mGAPO,uCAAkB,OAOP;AALpB,6DAAiI;AAa/H,yGAbO,2CAAwB,OAaP;AACxB,yGAdiC,2CAAwB,OAcjC;AAExB,iGAhB8E,mCAAgB,OAgB9E;AAflB,2EAAgI;AAkB9H,wGAlBO,iDAAuB,OAkBP;AAFvB,6GAhBgC,sDAA4B,OAgBhC"} |
+1
-1
| { | ||
| "name": "@newbility/database", | ||
| "version": "0.2.2", | ||
| "version": "0.2.3", | ||
| "main": "build/index.js", | ||
@@ -5,0 +5,0 @@ "author": "jameshu", |
16271
36.03%23
15%238
32.96%