File tree Expand file tree Collapse file tree 1 file changed +2
-2
lines changed
src/main/java/com/actiontech/dble/backend/mysql/nio/handler/transaction/savepoint Expand file tree Collapse file tree 1 file changed +2
-2
lines changed Original file line number Diff line number Diff line change @@ -72,12 +72,12 @@ private void save(String spName) {
7272 }
7373
7474 unResponseRrns .addAll (session .getTargetKeys ());
75+ this .performSp = newSp ;
7576 for (RouteResultsetNode rrn : session .getTargetKeys ()) {
7677 final BackendConnection conn = session .getTarget (rrn );
7778 conn .setResponseHandler (this );
7879 ((MySQLConnection ) conn ).execCmd ("savepoint " + spName );
7980 }
80- this .performSp = newSp ;
8181 }
8282
8383 private void rollbackTo (String spName ) {
@@ -102,6 +102,7 @@ private void rollbackTo(String spName) {
102102
103103 Set lastNodes = sp .getPrev ().getRouteNodes ();
104104 unResponseRrns .addAll (session .getTargetKeys ());
105+ this .performSp = sp ;
105106 for (RouteResultsetNode rrn : session .getTargetKeys ()) {
106107 final BackendConnection conn = session .getTarget (rrn );
107108 conn .setResponseHandler (this );
@@ -113,7 +114,6 @@ private void rollbackTo(String spName) {
113114 ((MySQLConnection ) conn ).execCmd ("rollback to " + spName );
114115 }
115116 }
116- this .performSp = sp ;
117117 }
118118
119119 private void release (String spName ) {
You can’t perform that action at this time.
0 commit comments