diff --git a/typeorm/package.json b/typeorm/package.json
index 57460db..1b8d4cd 100644
--- a/typeorm/package.json
+++ b/typeorm/package.json
@@ -1,7 +1,7 @@
 {
   "name": "@cool-midway/typeorm",
   "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.",
   "license": "MIT",
   "readmeFilename": "README.md",
diff --git a/typeorm/query-builder/DeleteQueryBuilder.js b/typeorm/query-builder/DeleteQueryBuilder.js
index eed0da8..8872815 100644
--- a/typeorm/query-builder/DeleteQueryBuilder.js
+++ b/typeorm/query-builder/DeleteQueryBuilder.js
@@ -19,7 +19,6 @@ class DeleteQueryBuilder extends QueryBuilder_1.QueryBuilder {
         this["@instanceof"] = Symbol.for("DeleteQueryBuilder");
         this.expressionMap.aliasNamePrefixingEnabled = false;
         this.broadcaster = new Broadcaster_1.Broadcaster(this.queryRunner);
-        this.broadcaster.broadcastAfterQueryBuilder(this, "delete");
     }
     // -------------------------------------------------------------------------
     // Public Implemented Methods
@@ -37,6 +36,7 @@ class DeleteQueryBuilder extends QueryBuilder_1.QueryBuilder {
      * Executes sql generated by query builder and returns raw database results.
      */
     async execute() {
+        this.broadcaster.broadcastAfterQueryBuilder(this, "delete");
         const [sql, parameters] = this.getQueryAndParameters();
         const queryRunner = this.obtainQueryRunner();
         let transactionStartedByUs = false;
diff --git a/typeorm/query-builder/InsertQueryBuilder.js b/typeorm/query-builder/InsertQueryBuilder.js
index 8b79283..cc88e50 100644
--- a/typeorm/query-builder/InsertQueryBuilder.js
+++ b/typeorm/query-builder/InsertQueryBuilder.js
@@ -21,7 +21,6 @@ class InsertQueryBuilder extends QueryBuilder_1.QueryBuilder {
         super(...arguments);
         this["@instanceof"] = Symbol.for("InsertQueryBuilder");
         this.broadcaster = new Broadcaster_1.Broadcaster(this.queryRunner);
-        this.broadcaster.broadcastAfterQueryBuilder(this, "insert");
     }
     // -------------------------------------------------------------------------
     // Public Implemented Methods
@@ -39,6 +38,7 @@ class InsertQueryBuilder extends QueryBuilder_1.QueryBuilder {
      * Executes sql generated by query builder and returns raw database results.
      */
     async execute() {
+        this.broadcaster.broadcastAfterQueryBuilder(this, "insert");
         // console.time(".value sets");
         const valueSets = this.getValueSets();
         // console.timeEnd(".value sets");
diff --git a/typeorm/query-builder/UpdateQueryBuilder.js b/typeorm/query-builder/UpdateQueryBuilder.js
index 488dad2..9739a16 100644
--- a/typeorm/query-builder/UpdateQueryBuilder.js
+++ b/typeorm/query-builder/UpdateQueryBuilder.js
@@ -23,7 +23,6 @@ class UpdateQueryBuilder extends QueryBuilder_1.QueryBuilder {
         this["@instanceof"] = Symbol.for("UpdateQueryBuilder");
         this.expressionMap.aliasNamePrefixingEnabled = false;
         this.broadcaster = new Broadcaster_1.Broadcaster(this.queryRunner);
-        this.broadcaster.broadcastAfterQueryBuilder(this, "update");
     }
     // -------------------------------------------------------------------------
     // Public Implemented Methods
@@ -43,6 +42,7 @@ class UpdateQueryBuilder extends QueryBuilder_1.QueryBuilder {
      * Executes sql generated by query builder and returns raw database results.
      */
     async execute() {
+        this.broadcaster.broadcastAfterQueryBuilder(this, "update");
         const queryRunner = this.obtainQueryRunner();
         let transactionStartedByUs = false;
         try {