@@ -53,6 +53,9 @@ discard block |
||
53 | 53 | $this->conn = DriverManager::getConnection($connectionParams); |
54 | 54 | } |
55 | 55 | |
56 | + /** |
|
57 | + * @param string $collection |
|
58 | + */ |
|
56 | 59 | public function create($collection, $fields) |
57 | 60 | { |
58 | 61 | $columns = []; |
@@ -86,6 +89,9 @@ discard block |
||
86 | 89 | return $schemaManager->createTable($table); |
87 | 90 | } |
88 | 91 | |
92 | + /** |
|
93 | + * @param string $collection |
|
94 | + */ |
|
89 | 95 | public function drop($collection) |
90 | 96 | { |
91 | 97 | $schemaManager = $this->conn->getSchemaManager(); |
@@ -126,6 +132,9 @@ discard block |
||
126 | 132 | |
127 | 133 | } |
128 | 134 | |
135 | + /** |
|
136 | + * @param string $collection |
|
137 | + */ |
|
129 | 138 | public function insert($collection, $values) |
130 | 139 | { |
131 | 140 | $insertion = $this->conn->insert($collection, $values); |
@@ -140,6 +149,9 @@ discard block |
||
140 | 149 | return $this->conn->update($collection, $values, $filter); |
141 | 150 | } |
142 | 151 | |
152 | + /** |
|
153 | + * @param string $collection |
|
154 | + */ |
|
143 | 155 | public function delete($collection, $filter) |
144 | 156 | { |
145 | 157 | $numberOfDeletedItems = $this->conn->delete($collection, $filter); |
@@ -149,11 +161,18 @@ discard block |
||
149 | 161 | return 0; |
150 | 162 | } |
151 | 163 | |
164 | + /** |
|
165 | + * @param string $collection |
|
166 | + * @param string|null $docId |
|
167 | + */ |
|
152 | 168 | public function get($collection, $docId) |
153 | 169 | { |
154 | 170 | return $this->conn->fetchAssoc('SELECT * FROM '.$collection.' WHERE id = ?', array($docId)); |
155 | 171 | } |
156 | 172 | |
173 | + /** |
|
174 | + * @param string $collection |
|
175 | + */ |
|
157 | 176 | public function find($collection, $filters, $fields = null, $sort = null, $start = 0, $limit = 25, $debug = false) |
158 | 177 | { |
159 | 178 | $result = null; |