asyncphp /
icicle-database
| @@ 127-136 (lines=10) @@ | ||
| 124 | * |
|
| 125 | * @return PromiseInterface |
|
| 126 | */ |
|
| 127 | public function insert(array $data) |
|
| 128 | { |
|
| 129 | return Coroutine\create(function () use ($data) { |
|
| 130 | $builder = $this->builder->insert($data); |
|
| 131 | $builder = $this->applyOperationsTo($builder); |
|
| 132 | ||
| 133 | list($statement, $values) = $builder->build(); |
|
| 134 | yield $this->connector->query($statement, $values); |
|
| 135 | }); |
|
| 136 | } |
|
| 137 | ||
| 138 | /** |
|
| 139 | * @param array $data |
|
| @@ 143-152 (lines=10) @@ | ||
| 140 | * |
|
| 141 | * @return PromiseInterface |
|
| 142 | */ |
|
| 143 | public function update(array $data) |
|
| 144 | { |
|
| 145 | return Coroutine\create(function () use ($data) { |
|
| 146 | $builder = $this->builder->update($data); |
|
| 147 | $builder = $this->applyOperationsTo($builder); |
|
| 148 | ||
| 149 | list($statement, $values) = $builder->build(); |
|
| 150 | yield $this->connector->query($statement, $values); |
|
| 151 | }); |
|
| 152 | } |
|
| 153 | ||
| 154 | /** |
|
| 155 | * @return PromiseInterface |
|
| @@ 157-166 (lines=10) @@ | ||
| 154 | /** |
|
| 155 | * @return PromiseInterface |
|
| 156 | */ |
|
| 157 | public function delete() |
|
| 158 | { |
|
| 159 | return Coroutine\create(function () { |
|
| 160 | $builder = $this->builder->delete(); |
|
| 161 | $builder = $this->applyOperationsTo($builder); |
|
| 162 | ||
| 163 | list($statement, $values) = $builder->build(); |
|
| 164 | yield $this->connector->query($statement, $values); |
|
| 165 | }); |
|
| 166 | } |
|
| 167 | } |
|
| 168 | ||
