fix ver

Author: isublimity

example/cluster_02_create.php

@@ -51,7 +51,7 @@
 $mclq->addSqlDowngrade('DROP DATABASE IF EXISTS shara');
 
 
-if (!$cl->sendMigration($mclq))
+if (!$cl->sendMigration($mclq,true))
 {
  throw new Exception('sendMigration is bad , error='.$cl->getError());
 }

src/Cluster.php

@@ -348,7 +348,7 @@ public function getError()
  return $this->error;
  }
 
- public function sendMigration(Cluster\Migration $migration)
+ public function sendMigration(Cluster\Migration $migration,$showDebug=false)
  {
  $node_hosts=$this->getClusterNodes($migration->getClusterName());
 
@@ -359,21 +359,32 @@ public function sendMigration(Cluster\Migration $migration)
  foreach ($node_hosts as $node) {
  try {
  $this->client($node)->ping();
+
+ if ($showDebug)
+ {
+ echo "client($node)->ping() OK!\n";
+ }
+
  } catch (QueryException $E) {
  $this->error = "Can`t connect or ping ip/node : " . $node;
  return false;
  }
  }
 
 
-
  // Выполняем запрос на каждый client(IP) , если хоть одни не отработал то делаем на каждый Down
  $need_undo=false;
  $undo_ip=[];
  foreach ($node_hosts as $node)
  {
  foreach ($sql_up as $s_u) {
  try {
+
+ if ($showDebug)
+ {
+ echo "client($node)->write(".substr($s_u,0,45).")....\n";
+ }
+
  if ($this->client($node)->write($s_u)->isError()) {
  $need_undo = true;
  $this->error = "Host $node result error";