github/cool-admin-midway-packages
1
0
Fork 0
mirror of https://github.com/cool-team-official/cool-admin-midway-packages.git synced 2025-12-10 21:32:48 +00:00
Code Issues Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
COOL 2025-02-26 13:01:46 +08:00
parent b612d7eaf8
commit 3a31939f80
4 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
typeorm/package.json
View File

@ -1,7 +1,7 @@
{ {
"name": "@cool-midway/typeorm", "name": "@cool-midway/typeorm",
"private": false, "private": false,
"version": "8.0.0", "version": "0.3.20",
"description": "Data-Mapper ORM for TypeScript, ES7, ES6, ES5. Supports MySQL, PostgreSQL, MariaDB, SQLite, MS SQL Server, Oracle, MongoDB databases.", "description": "Data-Mapper ORM for TypeScript, ES7, ES6, ES5. Supports MySQL, PostgreSQL, MariaDB, SQLite, MS SQL Server, Oracle, MongoDB databases.",
"license": "MIT", "license": "MIT",
"readmeFilename": "README.md", "readmeFilename": "README.md",

2
typeorm/query-builder/DeleteQueryBuilder.js
View File

@ -19,7 +19,6 @@ class DeleteQueryBuilder extends QueryBuilder_1.QueryBuilder {
this["@instanceof"] = Symbol.for("DeleteQueryBuilder"); this["@instanceof"] = Symbol.for("DeleteQueryBuilder");
this.expressionMap.aliasNamePrefixingEnabled = false; this.expressionMap.aliasNamePrefixingEnabled = false;
this.broadcaster = new Broadcaster_1.Broadcaster(this.queryRunner); this.broadcaster = new Broadcaster_1.Broadcaster(this.queryRunner);
this.broadcaster.broadcastAfterQueryBuilder(this, "delete");
} }
// ------------------------------------------------------------------------- // -------------------------------------------------------------------------
// Public Implemented Methods // Public Implemented Methods
@ -37,6 +36,7 @@ class DeleteQueryBuilder extends QueryBuilder_1.QueryBuilder {
* Executes sql generated by query builder and returns raw database results. * Executes sql generated by query builder and returns raw database results.
*/ */
async execute() { async execute() {
this.broadcaster.broadcastAfterQueryBuilder(this, "delete");
const [sql, parameters] = this.getQueryAndParameters(); const [sql, parameters] = this.getQueryAndParameters();
const queryRunner = this.obtainQueryRunner(); const queryRunner = this.obtainQueryRunner();
let transactionStartedByUs = false; let transactionStartedByUs = false;

2
typeorm/query-builder/InsertQueryBuilder.js
View File

@ -21,7 +21,6 @@ class InsertQueryBuilder extends QueryBuilder_1.QueryBuilder {
super(...arguments); super(...arguments);
this["@instanceof"] = Symbol.for("InsertQueryBuilder"); this["@instanceof"] = Symbol.for("InsertQueryBuilder");
this.broadcaster = new Broadcaster_1.Broadcaster(this.queryRunner); this.broadcaster = new Broadcaster_1.Broadcaster(this.queryRunner);
this.broadcaster.broadcastAfterQueryBuilder(this, "insert");
} }
// ------------------------------------------------------------------------- // -------------------------------------------------------------------------
// Public Implemented Methods // Public Implemented Methods
@ -39,6 +38,7 @@ class InsertQueryBuilder extends QueryBuilder_1.QueryBuilder {
* Executes sql generated by query builder and returns raw database results. * Executes sql generated by query builder and returns raw database results.
*/ */
async execute() { async execute() {
this.broadcaster.broadcastAfterQueryBuilder(this, "insert");
// console.time(".value sets"); // console.time(".value sets");
const valueSets = this.getValueSets(); const valueSets = this.getValueSets();
// console.timeEnd(".value sets"); // console.timeEnd(".value sets");

2
typeorm/query-builder/UpdateQueryBuilder.js
View File

@ -23,7 +23,6 @@ class UpdateQueryBuilder extends QueryBuilder_1.QueryBuilder {
this["@instanceof"] = Symbol.for("UpdateQueryBuilder"); this["@instanceof"] = Symbol.for("UpdateQueryBuilder");
this.expressionMap.aliasNamePrefixingEnabled = false; this.expressionMap.aliasNamePrefixingEnabled = false;
this.broadcaster = new Broadcaster_1.Broadcaster(this.queryRunner); this.broadcaster = new Broadcaster_1.Broadcaster(this.queryRunner);
this.broadcaster.broadcastAfterQueryBuilder(this, "update");
} }
// ------------------------------------------------------------------------- // -------------------------------------------------------------------------
// Public Implemented Methods // Public Implemented Methods
@ -43,6 +42,7 @@ class UpdateQueryBuilder extends QueryBuilder_1.QueryBuilder {
* Executes sql generated by query builder and returns raw database results. * Executes sql generated by query builder and returns raw database results.
*/ */
async execute() { async execute() {
this.broadcaster.broadcastAfterQueryBuilder(this, "update");
const queryRunner = this.obtainQueryRunner(); const queryRunner = this.obtainQueryRunner();
let transactionStartedByUs = false; let transactionStartedByUs = false;
try { try {