@@ -34,7 +34,7 @@ |
||
34 | 34 | }); |
35 | 35 | |
36 | 36 | $db->beginTransaction() |
37 | - ->then(function (TransactionInterface $trans) use ($loop) { |
|
37 | + ->then(function (TransactionInterface $trans) use ($loop) { |
|
38 | 38 | $trans->query('select * from demo order by id desc limit 1') |
39 | 39 | ->then(function (TupleResultStatement $tuple) { |
40 | 40 | print_r($tuple->fetchAll()); |
@@ -45,11 +45,11 @@ |
||
45 | 45 | $promise = $this->conn->getPromise(); |
46 | 46 | |
47 | 47 | return $promise |
48 | - ->success(function (ConnectorInterface $connector) use ($connection) { |
|
49 | - $connection->setConnector($connector); |
|
48 | + ->success(function (ConnectorInterface $connector) use ($connection) { |
|
49 | + $connection->setConnector($connector); |
|
50 | 50 | |
51 | - return $connection; |
|
52 | - }); |
|
51 | + return $connection; |
|
52 | + }); |
|
53 | 53 | } |
54 | 54 | |
55 | 55 | public function connect() |
@@ -78,13 +78,13 @@ discard block |
||
78 | 78 | */ |
79 | 79 | public function commit() |
80 | 80 | { |
81 | - return $this->connector->execute('COMMIT')->success(function (CommandResultStatement $result) { |
|
82 | - if ($result) { |
|
83 | - $this->emitter->emit('transaction:end'); |
|
84 | - } |
|
81 | + return $this->connector->execute('COMMIT')->success(function (CommandResultStatement $result) { |
|
82 | + if ($result) { |
|
83 | + $this->emitter->emit('transaction:end'); |
|
84 | + } |
|
85 | 85 | |
86 | - return $result; |
|
87 | - }); |
|
86 | + return $result; |
|
87 | + }); |
|
88 | 88 | } |
89 | 89 | |
90 | 90 | /** |
@@ -93,12 +93,12 @@ discard block |
||
93 | 93 | */ |
94 | 94 | public function rollback() |
95 | 95 | { |
96 | - return $this->connector->execute('ROLLBACK')->success(function (CommandResultStatement $result) { |
|
97 | - if ($result) { |
|
98 | - $this->emitter->emit('transaction:end'); |
|
99 | - } |
|
96 | + return $this->connector->execute('ROLLBACK')->success(function (CommandResultStatement $result) { |
|
97 | + if ($result) { |
|
98 | + $this->emitter->emit('transaction:end'); |
|
99 | + } |
|
100 | 100 | |
101 | - return $result; |
|
102 | - }); |
|
101 | + return $result; |
|
102 | + }); |
|
103 | 103 | } |
104 | 104 | } |