PSR-2

Author: bixuehujin

examples/query-with-callback.php

@@ -6,24 +6,24 @@
 
 //create a mysql connection for executing queries
 $connection = new React\MySQL\Connection($loop, array(
-	'dbname' => 'test',
-	'user'   => 'test',
-	'passwd' => 'test',
+    'dbname' => 'test',
+    'user'   => 'test',
+    'passwd' => 'test',
 ));
 
 //connecting to mysql server, not required.
 
-$connection->connect(function (){});
+$connection->connect(function () {});
 
 $connection->query('select * from book', function ($command, $conn) use ($loop) {
-	if ($command->hasError()) { //test whether the query was executed successfully
-		//error 
-		$error = $command->getError();// get the error object, instance of Exception.
-	}else {
-		$results = $command->resultRows; //get the results
-		$fields  = $command->resultFields; // get table fields
-	}
-	$loop->stop(); //stop the main loop.
+    if ($command->hasError()) { //test whether the query was executed successfully
+        //error
+        $error = $command->getError();// get the error object, instance of Exception.
+    } else {
+        $results = $command->resultRows; //get the results
+        $fields  = $command->resultFields; // get table fields
+    }
+    $loop->stop(); //stop the main loop.
 });
 
 $loop->run();

src/React/MySQL/Client.php

@@ -4,40 +4,43 @@
 use React\EventLoop\LoopInterface;
 use React\SocketClient\ConnectorInterface;
 
-class Client {
-	
-	private $loop;
-	private $connector;
-	private $secureConnector;
-	private $params;
-	private $request;
-	
-	public function __construct(LoopInterface $loop, ConnectorInterface $connector, ConnectorInterface $secureConnector, $params) {
-		$this->loop = $loop;
-		$this->connector = $connector;
-		$this->secureConnector = $secureConnector;
-		$this->request = new Request($loop, $connector);
-	}
-	
-	
-	
-	public function auth(array $options) {
-		return $this->request->auth($options);
-	}
-	
-	public function query($sql) {
-		return $this->request->query($sql);
-	}
-	
-	public function execute($sql) {
-		return $this->request->execute($sql);
-	}
-	
-	public function ping() {
-		return $this->request->ping();
-	}
-	
-	public function lastInsertId() {
-		
-	}
+class Client
+{
+    private $loop;
+    private $connector;
+    private $secureConnector;
+    private $params;
+    private $request;
+
+    public function __construct(LoopInterface $loop, ConnectorInterface $connector, ConnectorInterface $secureConnector, $params)
+    {
+        $this->loop = $loop;
+        $this->connector = $connector;
+        $this->secureConnector = $secureConnector;
+        $this->request = new Request($loop, $connector);
+    }
+
+    public function auth(array $options)
+    {
+        return $this->request->auth($options);
+    }
+
+    public function query($sql)
+    {
+        return $this->request->query($sql);
+    }
+
+    public function execute($sql)
+    {
+        return $this->request->execute($sql);
+    }
+
+    public function ping()
+    {
+        return $this->request->ping();
+    }
+
+    public function lastInsertId()
+    {
+    }
 }