fix: update tx and its outputs in different sqls

nervosnetwork · Nov 15, 2019 · b8fe366 · b8fe366
1 parent 7cb8ad3
commit b8fe366
Showing 1 changed file with 19 additions and 1 deletion.
diff --git a/packages/neuron-wallet/src/services/tx/transaction-persistor.ts b/packages/neuron-wallet/src/services/tx/transaction-persistor.ts
@@ -91,7 +91,25 @@ export class TransactionPersistor {
       txEntity.blockHash = transaction.blockHash
       txEntity.blockNumber = transaction.blockNumber
       txEntity.status = TransactionStatus.Success
-      await connection.manager.save([txEntity, ...outputs.concat(previousOutputs)])
+
+      const sliceSize = 100
+      const queryRunner = connection.createQueryRunner()
+      await TransactionPersistor.waitUntilTransactionFinished(queryRunner)
+      await queryRunner.startTransaction()
+      try {
+        await queryRunner.manager.save(txEntity)
+        for (const slice of Utils.eachSlice(previousOutputs, sliceSize)) {
+          await queryRunner.manager.save(slice)
+        }
+        for (const slice of Utils.eachSlice(outputs, sliceSize)) {
+          await queryRunner.manager.save(slice)
+        }
+        await queryRunner.commitTransaction()
+      } catch (err) {
+        await queryRunner.rollbackTransaction()
+      } finally {
+        await queryRunner.release()
+      }
 
       return txEntity
     }