asyncphp /
icicle-database
| @@ 112-121 (lines=10) @@ | ||
| 109 | * |
|
| 110 | * @return PromiseInterface |
|
| 111 | */ |
|
| 112 | public function insert(array $data) |
|
| 113 | { |
|
| 114 | return Coroutine\create(function () use ($data) { |
|
| 115 | $builder = $this->builder->insert($data); |
|
| 116 | $builder = $this->applyOperationsTo($builder); |
|
| 117 | ||
| 118 | list($statement, $values) = $builder->build(); |
|
| 119 | yield $this->connector->query($statement, $values); |
|
| 120 | }); |
|
| 121 | } |
|
| 122 | ||
| 123 | /** |
|
| 124 | * @param Builder $builder |
|
| @@ 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 | ||
