Fix bug #837

sysown · Dec 20, 2016 · d20e130 · d20e130
1 parent 1246786
commit d20e130
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/lib/MySQL_Session.cpp b/lib/MySQL_Session.cpp
@@ -2527,7 +2527,11 @@ int MySQL_Session::handler() {
 						myconn->async_state_machine=ASYNC_IDLE;
 						myds->DSS=STATE_MARIADB_GENERIC;
 						if (transaction_persistent==true) {
-							transaction_persistent_hostgroup=current_hostgroup;
+							if (transaction_persistent_hostgroup==-1) { // change only if not set already, do not allow to change it again
+								if (myds->myconn->IsActiveTransaction()==true) { // only active transaction is important here. Ignore other criterias
+									transaction_persistent_hostgroup=current_hostgroup;
+								}
+							}
 						}
 					}
 				} else {