proto

Author: isublimity

example/cluster_01_start.php

@@ -19,28 +19,28 @@
 
 // ----------------------------------------------------------------------
 $cluster_name='ads';
-$cl1 = new ClickHouseDB\Cluster($config);
-$cl2= new ClickHouseDB\Cluster($config);
-$cl2->setScanTimeOut(0.45); // 200 ms
+$cl = new ClickHouseDB\Cluster($config);
+$cl->setScanTimeOut(0.45); // 200 ms
 
-
-for ($z=0;$z<100;$z++)
+if (!$cl->isReplicasIsOk())
 {
- $cl1->rescan();
- $cl2->rescan();
- print_r( $cl1->getBadIps() );
- print_r( $cl2->getBadIps() );
-
+ throw new Exception('Replica state is bad');
 }
 
+$sql=[
+'up'=>['CREATE DATABASE IF NOT EXISTS ttests'],
+'down'=>['DROP DATABASE IF EXISTS ttests ']
+];
+echo "getClusterList:\n";
+print_r($cl->getClusterList());
+
+echo "getClusterHosts:model:\n";
+print_r($cl->getClusterHosts('model'));
 
 
 
-echo "END\n";
-//print_r( $db->getAllHostsIps() );
 
-//print_r( );
 
-//print_r($db->getListHostInCluser('ads')); // like $db->getClustersTable()
+echo "\n----\nEND\n";
 
 // ----------------------------------------------------------------------

src/Cluster.php

@@ -27,6 +27,10 @@ class Cluster
  private $badIps=[];
 
 
+ /**
+ * @var array
+ */
+ private $resultScan=[];
  /**
  * @var bool
  */
@@ -105,6 +109,11 @@ public function connect()
  }
  return $this;
  }
+
+ /**
+ * @param $replicas
+ * @return bool
+ */
  private function isReplicasWork($replicas)
  {
  $ok=true;
@@ -127,6 +136,10 @@ private function isReplicasWork($replicas)
  }
  return $ok;
  }
+
+ /**
+ * @return $this
+ */
  public function rescan()
  {
  /*
@@ -139,6 +152,7 @@ public function rescan()
  $statementsReplicas=[];
  $statementsClusters=[];
  $result=[];
+
  $badIps=[];
  $replicasIsOk=true;
 
@@ -168,7 +182,13 @@ public function rescan()
  // ---------------------------------------------------------------------------------------------------
  try
  {
- $result['clusters'][$ip] =$statementsClusters[$ip]->rowsAsTree('cluster.host_address');
+ $c=$statementsClusters[$ip]->rows();
+ $result['clusters'][$ip] = $c;
+ foreach ($c as $row)
+ {
+ $result['cluster.list'][$row['cluster']][$row['host_address']][$row['shard_num']][$row['replica_num']]=['shard_weight'=>$row['shard_weight'],'is_local'=>$row['is_local']];
+ }
+
  }
  catch (\Exception $E)
  {
@@ -207,9 +227,18 @@ public function rescan()
  $this->replicasIsOk=false;
  }
 
+ $this->resultScan=$result;
  // @todo Мы подключаемся ко всем в списке DNS, нужно пререить что запросы вернули все хосты к которым мы подключались
+ return $this;
  }
 
+ /**
+ * @return boolean
+ */
+ public function isReplicasIsOk()
+ {
+ return $this->connect()->replicasIsOk;
+ }
  /**
  * @return Client
  */
@@ -225,7 +254,17 @@ public function activeClient()
  {
  return $this->client($this->ips[0]);
  }
-
+ public function getClusterHosts($cluster)
+ {
+ $this->connect();
+ if (empty($this->resultScan['cluster.list'][$cluster])) throw new QueryException('Cluster not find:'.$cluster);
+ return array_keys($this->resultScan['cluster.list'][$cluster]);
+ }
+ public function getClusterList()
+ {
+ $this->connect();
+ return array_keys($this->resultScan['cluster.list']);
+ }
  /**
  * @param $sql
  * @param array $bindings