@@ -301,6 +301,9 @@ |
||
301 | 301 | { |
302 | 302 | private $refresher; |
303 | 303 | |
304 | + /** |
|
305 | + * @param \Closure $refresher |
|
306 | + */ |
|
304 | 307 | public function __construct($refresher) |
305 | 308 | { |
306 | 309 | $this->refresher = $refresher; |
@@ -40,6 +40,9 @@ discard block |
||
40 | 40 | } |
41 | 41 | |
42 | 42 | |
43 | + /** |
|
44 | + * @param string $propertyName |
|
45 | + */ |
|
43 | 46 | public function handleSetForTransaction($propertyName) |
44 | 47 | { |
45 | 48 | if ($this->inTrans) { |
@@ -47,6 +50,9 @@ discard block |
||
47 | 50 | } |
48 | 51 | } |
49 | 52 | |
53 | + /** |
|
54 | + * @param string $propertyName |
|
55 | + */ |
|
50 | 56 | public function handleSetForSession($propertyName) |
51 | 57 | { |
52 | 58 | if ($this->inTrans) { |
@@ -157,6 +163,9 @@ discard block |
||
157 | 163 | } |
158 | 164 | } |
159 | 165 | |
166 | + /** |
|
167 | + * @param string $name |
|
168 | + */ |
|
160 | 169 | private function findSavepoint($name) |
161 | 170 | { |
162 | 171 | for ($idx = $this->tailIdx - 1; $idx >= 0; $idx--) { |
@@ -108,6 +108,9 @@ |
||
108 | 108 | return new $exClass($resultHandler, $query); |
109 | 109 | } |
110 | 110 | |
111 | + /** |
|
112 | + * @param resource $resultHandler |
|
113 | + */ |
|
111 | 114 | private function inferExceptionClass($resultHandler, StatementExceptionFactory $fallbackFactory = null) |
112 | 115 | { |
113 | 116 | if ($this->bySqlStateCodeAndMessage || $this->bySqlStateCode || $this->bySqlStateClass) { |
@@ -166,7 +166,7 @@ |
||
166 | 166 | } |
167 | 167 | |
168 | 168 | /** |
169 | - * @param IConnection|string $conn (name of) connection to use as the default connection |
|
169 | + * @param IConnection $conn (name of) connection to use as the default connection |
|
170 | 170 | * @throws \RuntimeException if the requested connection is not defined |
171 | 171 | */ |
172 | 172 | public static function useConnectionAsDefault($conn) |
@@ -14,6 +14,9 @@ |
||
14 | 14 | /** @var IQueryResult */ |
15 | 15 | private $result = null; |
16 | 16 | |
17 | + /** |
|
18 | + * @param string $query |
|
19 | + */ |
|
17 | 20 | public function __construct(IStatementExecution $conn, $query, ...$args) |
18 | 21 | { |
19 | 22 | parent::__construct(); |
@@ -15,6 +15,9 @@ discard block |
||
15 | 15 | */ |
16 | 16 | trait RelationMacros |
17 | 17 | { |
18 | + /** |
|
19 | + * @param string[] $columns |
|
20 | + */ |
|
18 | 21 | abstract public function project($columns); |
19 | 22 | |
20 | 23 | /** |
@@ -74,6 +77,9 @@ discard block |
||
74 | 77 | return $this->tuple($tupleOffset)->value($colOffsetOrNameOrEvaluator); |
75 | 78 | } |
76 | 79 | |
80 | + /** |
|
81 | + * @param IColumn[] $columns |
|
82 | + */ |
|
77 | 83 | final protected function _colImpl($offsetOrNameOrEvaluator, $columns, $colNameMap, IRelation $relation) |
78 | 84 | { |
79 | 85 | if (is_scalar($offsetOrNameOrEvaluator)) { |
@@ -29,6 +29,9 @@ discard block |
||
29 | 29 | private $delim; |
30 | 30 | private $elemNeedsQuotesRegex; |
31 | 31 | |
32 | + /** |
|
33 | + * @param string $delimiter |
|
34 | + */ |
|
32 | 35 | public function __construct(INamedType $elemType, $delimiter) |
33 | 36 | { |
34 | 37 | $this->elemType = $elemType; |
@@ -284,6 +287,11 @@ discard block |
||
284 | 287 | return $out; |
285 | 288 | } |
286 | 289 | |
290 | + /** |
|
291 | + * @param string $str |
|
292 | + * @param string $errMsg |
|
293 | + * @param integer $offset |
|
294 | + */ |
|
287 | 295 | private static function throwArrayParseException($str, $errMsg = null, $offset = null) |
288 | 296 | { |
289 | 297 | $msg = "Value '$str' is not valid for an array"; |
@@ -293,6 +301,11 @@ discard block |
||
293 | 301 | throw new ParseException($msg, $offset); |
294 | 302 | } |
295 | 303 | |
304 | + /** |
|
305 | + * @param string $str |
|
306 | + * @param integer $offset |
|
307 | + * @param ParseException $cause |
|
308 | + */ |
|
296 | 309 | private function throwParseException($str, $errMsg = null, $offset = null, $cause = null) |
297 | 310 | { |
298 | 311 | $elemTypeName = $this->elemType->getSchemaName() . '.' . $this->elemType->getName(); |
@@ -8,6 +8,9 @@ discard block |
||
8 | 8 | private $connection; |
9 | 9 | private $connHandler; |
10 | 10 | |
11 | + /** |
|
12 | + * @param resource|null $connHandler |
|
13 | + */ |
|
11 | 14 | public function __construct(IConnection $connection, $connHandler) |
12 | 15 | { |
13 | 16 | $this->connection = $connection; |
@@ -190,6 +193,10 @@ discard block |
||
190 | 193 | } |
191 | 194 | } |
192 | 195 | |
196 | + /** |
|
197 | + * @param string $query |
|
198 | + * @param string $errorDesc |
|
199 | + */ |
|
193 | 200 | private function query($query, $errorDesc) |
194 | 201 | { |
195 | 202 | $result = pg_query($this->connHandler, $query); |
@@ -17,6 +17,10 @@ discard block |
||
17 | 17 | private $subtype; |
18 | 18 | private $canonicalFunc; |
19 | 19 | |
20 | + /** |
|
21 | + * @param string $schemaName |
|
22 | + * @param string $name |
|
23 | + */ |
|
20 | 24 | public function __construct($schemaName, $name, ITotallyOrderedType $subtype, IRangeCanonicalFunc $canonicalFunc = null) |
21 | 25 | { |
22 | 26 | $this->setName($schemaName, $name); |
@@ -69,6 +73,9 @@ discard block |
||
69 | 73 | return Range::createFromBounds($this->subtype, $this->canonicalFunc, $lower, $upper, $lowerInc, $upperInc); |
70 | 74 | } |
71 | 75 | |
76 | + /** |
|
77 | + * @param string $str |
|
78 | + */ |
|
72 | 79 | private function parseBoundStr($str) |
73 | 80 | { |
74 | 81 | if (strlen($str) == 0) { |
@@ -152,6 +159,11 @@ discard block |
||
152 | 159 | } |
153 | 160 | } |
154 | 161 | |
162 | + /** |
|
163 | + * @param integer $sgn |
|
164 | + * @param boolean|null $aIsInc |
|
165 | + * @param boolean|null $bIsInc |
|
166 | + */ |
|
155 | 167 | private function compareBounds($sgn, $aVal, $aIsInc, $bVal, $bIsInc) |
156 | 168 | { |
157 | 169 | if ($aVal === null && $bVal === null) { |