diff --git a/lib/MySQL/store.js b/lib/MySQL/store.js index 3f52137..41fc0bf 100644 --- a/lib/MySQL/store.js +++ b/lib/MySQL/store.js @@ -238,26 +238,12 @@ class MysqlStore extends CascadeStore_1.CascadeStore { const { data } = operation; const sql = translator.translateInsert(entity, data instanceof Array ? data : [data]); await connector.exec(sql, txn); - if (!option?.dontCollect) { - context.opRecords.push({ - a: 'c', - d: data, - e: entity, - }); - } return data instanceof Array ? data.length : 1; } case 'remove': { const sql = translator.translateRemove(entity, operation, option); await connector.exec(sql, txn); // todo 这里对sorter和indexfrom/count的支持不完整 - if (!option?.dontCollect) { - context.opRecords.push({ - a: 'r', - e: entity, - f: operation.filter, - }); - } return 1; } default: { @@ -265,14 +251,6 @@ class MysqlStore extends CascadeStore_1.CascadeStore { const sql = translator.translateUpdate(entity, operation, option); await connector.exec(sql, txn); // todo 这里对sorter和indexfrom/count的支持不完整 - if (!option?.dontCollect) { - context.opRecords.push({ - a: 'u', - e: entity, - d: operation.data, - f: operation.filter, - }); - } return 1; } } diff --git a/src/MySQL/store.ts b/src/MySQL/store.ts index 59bfd4b..aa8b0f8 100644 --- a/src/MySQL/store.ts +++ b/src/MySQL/store.ts @@ -266,43 +266,19 @@ export class MysqlStore