@@ -9,5 +9,8 @@ |
||
| 9 | 9 | */ |
| 10 | 10 | interface TableNameResolverInterface |
| 11 | 11 | { |
| 12 | + /** |
|
| 13 | + * @return string |
|
| 14 | + */ |
|
| 12 | 15 | public function getTableName($instance); |
| 13 | 16 | } |
@@ -9,5 +9,8 @@ |
||
| 9 | 9 | */ |
| 10 | 10 | interface ModelJoinerInterface |
| 11 | 11 | { |
| 12 | + /** |
|
| 13 | + * @return string |
|
| 14 | + */ |
|
| 12 | 15 | public function getJunctionClassName($classA, $classB); |
| 13 | 16 | } |
@@ -190,6 +190,10 @@ |
||
| 190 | 190 | return $return; |
| 191 | 191 | } |
| 192 | 192 | |
| 193 | + /** |
|
| 194 | + * @param integer $level |
|
| 195 | + * @param string $opr |
|
| 196 | + */ |
|
| 193 | 197 | private function parseRightExpression($level, $opr) { |
| 194 | 198 | switch ($opr) { |
| 195 | 199 | case 'between': return $this->parseBetween(); |
@@ -90,6 +90,9 @@ |
||
| 90 | 90 | return $relationshipDetails; |
| 91 | 91 | } |
| 92 | 92 | |
| 93 | + /** |
|
| 94 | + * @param string $type |
|
| 95 | + */ |
|
| 93 | 96 | private function createRelationships($type, $relationships) { |
| 94 | 97 | foreach ($relationships as $relationship) { |
| 95 | 98 | $relationship = $this->getRelationshipDetails($relationship); |
@@ -67,7 +67,9 @@ |
||
| 67 | 67 | } |
| 68 | 68 | |
| 69 | 69 | public static function getInstance() { |
| 70 | - if(self::$instance === null) throw new NibiiException("A context has not yet been initialized"); |
|
| 70 | + if(self::$instance === null) { |
|
| 71 | + throw new NibiiException("A context has not yet been initialized"); |
|
| 72 | + } |
|
| 71 | 73 | return self::$instance; |
| 72 | 74 | } |
| 73 | 75 | |
@@ -6,10 +6,16 @@ discard block |
||
| 6 | 6 | |
| 7 | 7 | private $db; |
| 8 | 8 | |
| 9 | + /** |
|
| 10 | + * @param \ntentan\atiaa\Driver $driver |
|
| 11 | + */ |
|
| 9 | 12 | public function setDriver($driver) { |
| 10 | 13 | $this->db = $driver; |
| 11 | 14 | } |
| 12 | 15 | |
| 16 | + /** |
|
| 17 | + * @param string $query |
|
| 18 | + */ |
|
| 13 | 19 | private function filter($query) { |
| 14 | 20 | return $query; |
| 15 | 21 | } |
@@ -39,6 +45,11 @@ discard block |
||
| 39 | 45 | ); |
| 40 | 46 | } |
| 41 | 47 | |
| 48 | + /** |
|
| 49 | + * @param QueryParameters $parameters |
|
| 50 | + * |
|
| 51 | + * @return string |
|
| 52 | + */ |
|
| 42 | 53 | public function getBulkUpdateQuery($data, $parameters) { |
| 43 | 54 | $updateData = []; |
| 44 | 55 | foreach ($data as $field => $value) { |
@@ -84,6 +95,11 @@ discard block |
||
| 84 | 95 | ); |
| 85 | 96 | } |
| 86 | 97 | |
| 98 | + /** |
|
| 99 | + * @param QueryParameters $parameters |
|
| 100 | + * |
|
| 101 | + * @return string |
|
| 102 | + */ |
|
| 87 | 103 | public function getSelectQuery($parameters) { |
| 88 | 104 | return $this->filter(sprintf( |
| 89 | 105 | "SELECT %s FROM %s%s%s%s%s", |
@@ -97,6 +113,11 @@ discard block |
||
| 97 | 113 | ); |
| 98 | 114 | } |
| 99 | 115 | |
| 116 | + /** |
|
| 117 | + * @param QueryParameters $parameters |
|
| 118 | + * |
|
| 119 | + * @return string |
|
| 120 | + */ |
|
| 100 | 121 | public function getCountQuery($parameters) { |
| 101 | 122 | return $this->filter(sprintf( |
| 102 | 123 | "SELECT count(*) as count FROM %s%s", |
@@ -106,6 +127,11 @@ discard block |
||
| 106 | 127 | ); |
| 107 | 128 | } |
| 108 | 129 | |
| 130 | + /** |
|
| 131 | + * @param QueryParameters $parameters |
|
| 132 | + * |
|
| 133 | + * @return string |
|
| 134 | + */ |
|
| 109 | 135 | public function getDeleteQuery($parameters) { |
| 110 | 136 | return $this->filter(sprintf( |
| 111 | 137 | "DELETE FROM %s%s", |
@@ -146,7 +146,7 @@ discard block |
||
| 146 | 146 | |
| 147 | 147 | /** |
| 148 | 148 | * @method |
| 149 | - * @param type $name |
|
| 149 | + * @param string $name |
|
| 150 | 150 | * @param type $arguments |
| 151 | 151 | * @return type |
| 152 | 152 | */ |
@@ -176,6 +176,10 @@ discard block |
||
| 176 | 176 | return $this->retrieveItem($name); |
| 177 | 177 | } |
| 178 | 178 | |
| 179 | + /** |
|
| 180 | + * @param Relationship[] $relationships |
|
| 181 | + * @param integer $depth |
|
| 182 | + */ |
|
| 179 | 183 | private function expandArrayValue($array, $relationships, $depth, $index = null) { |
| 180 | 184 | foreach ($relationships as $name => $relationship) { |
| 181 | 185 | $array[$name] = $this->fetchRelatedFields($relationship, $index)->toArray($depth); |
@@ -336,6 +340,9 @@ discard block |
||
| 336 | 340 | |
| 337 | 341 | } |
| 338 | 342 | |
| 343 | + /** |
|
| 344 | + * @param string $id |
|
| 345 | + */ |
|
| 339 | 346 | public function postSaveCallback($id) { |
| 340 | 347 | |
| 341 | 348 | } |
@@ -360,7 +367,7 @@ discard block |
||
| 360 | 367 | |
| 361 | 368 | /** |
| 362 | 369 | * |
| 363 | - * @return DataAdapter |
|
| 370 | + * @return DriverAdapter |
|
| 364 | 371 | */ |
| 365 | 372 | public function getAdapter() { |
| 366 | 373 | $this->initialize(); |
@@ -63,7 +63,9 @@ |
||
| 63 | 63 | private $initialized = false; |
| 64 | 64 | |
| 65 | 65 | private function initialize() { |
| 66 | - if($this->initialized) return; |
|
| 66 | + if($this->initialized) { |
|
| 67 | + return; |
|
| 68 | + } |
|
| 67 | 69 | $this->context = ORMContext::getInstance(); |
| 68 | 70 | $this->container = $this->context->getContainer(); |
| 69 | 71 | $this->adapter = $this->container->resolve(DriverAdapter::class); |