File tree 1 file changed +5
-5
lines changed
1 file changed +5
-5
lines changed Original file line number Diff line number Diff line change @@ -255,12 +255,12 @@ class _PostgreSQLConnectionStateBusy extends _PostgreSQLConnectionState {
255
255
// print("(${query.statement}) -> $message");
256
256
257
257
if (message is ReadyForQueryMessage ) {
258
+ if (message.state == ReadyForQueryMessage .StateTransactionError ) {
259
+ query.completeError (returningException! );
260
+ return _PostgreSQLConnectionStateReadyInTransaction (
261
+ query.transaction as _TransactionProxy );
262
+ }
258
263
if (returningException != null ) {
259
- if (message.state == ReadyForQueryMessage .StateTransactionError ) {
260
- query.completeError (returningException! );
261
- return _PostgreSQLConnectionStateReadyInTransaction (
262
- query.transaction as _TransactionProxy );
263
- }
264
264
query.completeError (returningException! );
265
265
} else {
266
266
query.complete (rowsAffected);
You can’t perform that action at this time.
0 commit comments