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) {
72
72
}
73
73
74
74
unResponseRrns .addAll (session .getTargetKeys ());
75
+ this .performSp = newSp ;
75
76
for (RouteResultsetNode rrn : session .getTargetKeys ()) {
76
77
final BackendConnection conn = session .getTarget (rrn );
77
78
conn .setResponseHandler (this );
78
79
((MySQLConnection ) conn ).execCmd ("savepoint " + spName );
79
80
}
80
- this .performSp = newSp ;
81
81
}
82
82
83
83
private void rollbackTo (String spName ) {
@@ -102,6 +102,7 @@ private void rollbackTo(String spName) {
102
102
103
103
Set lastNodes = sp .getPrev ().getRouteNodes ();
104
104
unResponseRrns .addAll (session .getTargetKeys ());
105
+ this .performSp = sp ;
105
106
for (RouteResultsetNode rrn : session .getTargetKeys ()) {
106
107
final BackendConnection conn = session .getTarget (rrn );
107
108
conn .setResponseHandler (this );
@@ -113,7 +114,6 @@ private void rollbackTo(String spName) {
113
114
((MySQLConnection ) conn ).execCmd ("rollback to " + spName );
114
115
}
115
116
}
116
- this .performSp = sp ;
117
117
}
118
118
119
119
private void release (String spName ) {
You can’t perform that action at this time.
0 commit comments