1
1
<?php
2
2
3
- namespace Reactphp \ Framework \Orm ;
3
+ namespace ReactphpX \Orm ;
4
4
5
5
use Illuminate \Database \Connection ;
6
6
use Closure ;
@@ -176,7 +176,7 @@ protected function prepared(PDOStatement $statement)
176
176
* Get the PDO connection to use for a select query.
177
177
*
178
178
* @param bool $useReadPdo
179
- * @return \Reactphp\Framework \MySQL\Pool;
179
+ * @return \ReactphpX \MySQL\Pool;
180
180
*/
181
181
protected function getPdoForSelect ($ useReadPdo = true )
182
182
{
@@ -335,7 +335,7 @@ public function beginTransaction()
335
335
throw new Exception ("no connection " );
336
336
}
337
337
338
- if (!($ this ->getPdo () instanceof \Reactphp \ Framework \MySQL \Pool)) {
338
+ if (!($ this ->getPdo () instanceof \ReactphpX \MySQL \Pool)) {
339
339
throw new Exception ("had in transaction " );
340
340
}
341
341
@@ -351,7 +351,7 @@ public function beginTransaction()
351
351
352
352
public function commit ()
353
353
{
354
- if ($ this ->getPdo () && !($ this ->getPdo () instanceof \Reactphp \ Framework \MySQL \Pool)) {
354
+ if ($ this ->getPdo () && !($ this ->getPdo () instanceof \ReactphpX \MySQL \Pool)) {
355
355
\React \Async \await ($ this ->getPdo ()->query ('COMMIT ' ));
356
356
DB ::getPdo ()->releaseConnection ($ this ->getPdo ());
357
357
} else {
@@ -371,7 +371,7 @@ public function commit()
371
371
*/
372
372
public function rollBack ($ toLevel = null )
373
373
{
374
- if ($ this ->getPdo () && !($ this ->getPdo () instanceof \Reactphp \ Framework \MySQL \Pool)) {
374
+ if ($ this ->getPdo () && !($ this ->getPdo () instanceof \ReactphpX \MySQL \Pool)) {
375
375
\React \Async \await ($ this ->getPdo ()->query ('ROLLBACK ' ));
376
376
DB ::getPdo ()->releaseConnection ($ this ->getPdo ());
377
377
} else {
0 commit comments