@@ -128,26 +128,26 @@ discard block |
||
128 | 128 | function getTitleNames() |
129 | 129 | { |
130 | 130 | $titles = $this->getTitles(); |
131 | - if($titles === false) |
|
131 | + if ($titles === false) |
|
132 | 132 | { |
133 | 133 | return false; |
134 | 134 | } |
135 | - if(self::$titlenames === null) |
|
135 | + if (self::$titlenames === null) |
|
136 | 136 | { |
137 | 137 | $dataSet = \DataSetFactory::get_data_set('profiles'); |
138 | 138 | $dataTable = $dataSet['position']; |
139 | 139 | $titlenames = $dataTable->read(); |
140 | 140 | self::$titlenames = array(); |
141 | 141 | $count = count($titlenames); |
142 | - for($i = 0; $i < $count; $i++) |
|
142 | + for ($i = 0; $i < $count; $i++) |
|
143 | 143 | { |
144 | 144 | self::$titlenames[$titlenames[$i]['short_name']] = $titlenames[$i]; |
145 | 145 | } |
146 | 146 | } |
147 | 147 | $count = count($titles); |
148 | - for($i = 0; $i < $count; $i++) |
|
148 | + for ($i = 0; $i < $count; $i++) |
|
149 | 149 | { |
150 | - if(isset(self::$titlenames[$titles[$i]])) |
|
150 | + if (isset(self::$titlenames[$titles[$i]])) |
|
151 | 151 | { |
152 | 152 | $title = self::$titlenames[$titles[$i]]; |
153 | 153 | $titles[$i] = $title['name']; |
@@ -280,11 +280,11 @@ discard block |
||
280 | 280 | function canLoginWith($provider) |
281 | 281 | { |
282 | 282 | $hosts = $this->getLoginProviders(); |
283 | - if($hosts === false) return false; |
|
283 | + if ($hosts === false) return false; |
|
284 | 284 | $count = count($hosts); |
285 | - for($i = 0; $i < $count; $i++) |
|
285 | + for ($i = 0; $i < $count; $i++) |
|
286 | 286 | { |
287 | - if(strcasecmp($hosts[$i], $provider) === 0) return true; |
|
287 | + if (strcasecmp($hosts[$i], $provider) === 0) return true; |
|
288 | 288 | } |
289 | 289 | return false; |
290 | 290 | } |
@@ -308,9 +308,9 @@ discard block |
||
308 | 308 | */ |
309 | 309 | function isProfileComplete() |
310 | 310 | { |
311 | - if($this->getCountry() === false || $this->getAddress() === false || |
|
311 | + if ($this->getCountry() === false || $this->getAddress() === false || |
|
312 | 312 | $this->getPostalCode() === false || $this->getCity() === false || |
313 | - $this->getState() === false || $this->getPhoneNumber() === false) |
|
313 | + $this->getState() === false || $this->getPhoneNumber() === false) |
|
314 | 314 | { |
315 | 315 | return false; |
316 | 316 | } |
@@ -354,17 +354,17 @@ discard block |
||
354 | 354 | * |
355 | 355 | * @return true|false true if the user's password was changed, false otherwise |
356 | 356 | */ |
357 | - function change_pass($oldpass, $newpass, $isHash=false) |
|
357 | + function change_pass($oldpass, $newpass, $isHash = false) |
|
358 | 358 | { |
359 | - if($isHash === false && $this->validate_password($oldpass) === false) |
|
359 | + if ($isHash === false && $this->validate_password($oldpass) === false) |
|
360 | 360 | { |
361 | 361 | throw new \Exception('Invalid Password!', 3); |
362 | 362 | } |
363 | - if($isHash === true && $this->validate_reset_hash($oldpass) === false) |
|
363 | + if ($isHash === true && $this->validate_reset_hash($oldpass) === false) |
|
364 | 364 | { |
365 | 365 | throw new \Exception('Invalid Reset Hash!', 3); |
366 | 366 | } |
367 | - if($this->setPass($newpass) === false) |
|
367 | + if ($this->setPass($newpass) === false) |
|
368 | 368 | { |
369 | 369 | throw new \Exception('Unable to set password!', 6); |
370 | 370 | } |
@@ -602,99 +602,99 @@ discard block |
||
602 | 602 | $auth = \AuthProvider::getInstance(); |
603 | 603 | $ldap = $auth->getAuthenticator('Auth\LDAPAuthenticator'); |
604 | 604 | $ldap->get_and_bind_server(true); |
605 | - if(isset($data->oldpass) && isset($data->password)) |
|
605 | + if (isset($data->oldpass) && isset($data->password)) |
|
606 | 606 | { |
607 | 607 | $this->change_pass($data->oldpass, $data->password); |
608 | 608 | unset($data->oldpass); |
609 | 609 | unset($data->password); |
610 | 610 | } |
611 | - else if(isset($data->hash) && isset($data->password)) |
|
611 | + else if (isset($data->hash) && isset($data->password)) |
|
612 | 612 | { |
613 | 613 | $this->change_pass($data->hash, $data->password, true); |
614 | 614 | return; |
615 | 615 | } |
616 | - if(isset($data->displayName)) |
|
616 | + if (isset($data->displayName)) |
|
617 | 617 | { |
618 | 618 | $this->setDisplayName($data->displayName); |
619 | 619 | unset($data->displayName); |
620 | 620 | } |
621 | - if(isset($data->givenName)) |
|
621 | + if (isset($data->givenName)) |
|
622 | 622 | { |
623 | 623 | $this->setGivenName($data->givenName); |
624 | 624 | unset($data->givenName); |
625 | 625 | } |
626 | - if(isset($data->jpegPhoto)) |
|
626 | + if (isset($data->jpegPhoto)) |
|
627 | 627 | { |
628 | 628 | $this->setPhoto(base64_decode($data->jpegPhoto)); |
629 | 629 | unset($data->jpegPhoto); |
630 | 630 | } |
631 | - if(isset($data->mail)) |
|
631 | + if (isset($data->mail)) |
|
632 | 632 | { |
633 | - if($data->mail !== $this->getEmail()) |
|
633 | + if ($data->mail !== $this->getEmail()) |
|
634 | 634 | { |
635 | 635 | throw new \Exception('Unable to change email!'); |
636 | 636 | } |
637 | 637 | unset($data->mail); |
638 | 638 | } |
639 | - if(isset($data->uid)) |
|
639 | + if (isset($data->uid)) |
|
640 | 640 | { |
641 | - if($data->uid !== $this->getUid()) |
|
641 | + if ($data->uid !== $this->getUid()) |
|
642 | 642 | { |
643 | 643 | throw new \Exception('Unable to change uid!'); |
644 | 644 | } |
645 | 645 | unset($data->uid); |
646 | 646 | } |
647 | - if(isset($data->mobile)) |
|
647 | + if (isset($data->mobile)) |
|
648 | 648 | { |
649 | 649 | $this->setPhoneNumber($data->mobile); |
650 | 650 | unset($data->mobile); |
651 | 651 | } |
652 | - if(isset($data->o)) |
|
652 | + if (isset($data->o)) |
|
653 | 653 | { |
654 | 654 | $this->setOrganization($data->o); |
655 | 655 | unset($data->o); |
656 | 656 | } |
657 | - if(isset($data->title)) |
|
657 | + if (isset($data->title)) |
|
658 | 658 | { |
659 | 659 | $this->setTitles($data->title); |
660 | 660 | unset($data->title); |
661 | 661 | } |
662 | - if(isset($data->st)) |
|
662 | + if (isset($data->st)) |
|
663 | 663 | { |
664 | 664 | $this->setState($data->st); |
665 | 665 | unset($data->st); |
666 | 666 | } |
667 | - if(isset($data->l)) |
|
667 | + if (isset($data->l)) |
|
668 | 668 | { |
669 | 669 | $this->setCity($data->l); |
670 | 670 | unset($data->l); |
671 | 671 | } |
672 | - if(isset($data->sn)) |
|
672 | + if (isset($data->sn)) |
|
673 | 673 | { |
674 | 674 | $this->setLastName($data->sn); |
675 | 675 | unset($data->sn); |
676 | 676 | } |
677 | - if(isset($data->cn)) |
|
677 | + if (isset($data->cn)) |
|
678 | 678 | { |
679 | 679 | $this->setNickName($data->cn); |
680 | 680 | unset($data->cn); |
681 | 681 | } |
682 | - if(isset($data->postalAddress)) |
|
682 | + if (isset($data->postalAddress)) |
|
683 | 683 | { |
684 | 684 | $this->setAddress($data->postalAddress); |
685 | 685 | unset($data->postalAddress); |
686 | 686 | } |
687 | - if(isset($data->postalCode)) |
|
687 | + if (isset($data->postalCode)) |
|
688 | 688 | { |
689 | 689 | $this->setPostalCode($data->postalCode); |
690 | 690 | unset($data->postalCode); |
691 | 691 | } |
692 | - if(isset($data->c)) |
|
692 | + if (isset($data->c)) |
|
693 | 693 | { |
694 | 694 | $this->setCountry($data->c); |
695 | 695 | unset($data->c); |
696 | 696 | } |
697 | - if(isset($data->ou)) |
|
697 | + if (isset($data->ou)) |
|
698 | 698 | { |
699 | 699 | $this->setOrganizationUnits($data->ou); |
700 | 700 | unset($data->ou); |
@@ -749,13 +749,13 @@ discard block |
||
749 | 749 | public function getVcard() |
750 | 750 | { |
751 | 751 | $ret = "BEGIN:VCARD\nVERSION:2.1\n"; |
752 | - $ret.= 'N:'.$this->getLastName().';'.$this->getGivenName()."\n"; |
|
753 | - $ret.= 'FN:'.$this->getGivenName()."\n"; |
|
754 | - $ret.= 'TITLE:'.implode(',', $this->getTitles())."\n"; |
|
755 | - $ret.= "ORG: Austin Artistic Reconstruction\n"; |
|
756 | - $ret.= 'TEL;TYPE=MOBILE,VOICE:'.$this->getPhoneNumber()."\n"; |
|
757 | - $ret.= 'EMAIL;TYPE=PREF,INTERNET:'.$this->getEmail()."\n"; |
|
758 | - $ret.= "END:VCARD\n"; |
|
752 | + $ret .= 'N:'.$this->getLastName().';'.$this->getGivenName()."\n"; |
|
753 | + $ret .= 'FN:'.$this->getGivenName()."\n"; |
|
754 | + $ret .= 'TITLE:'.implode(',', $this->getTitles())."\n"; |
|
755 | + $ret .= "ORG: Austin Artistic Reconstruction\n"; |
|
756 | + $ret .= 'TEL;TYPE=MOBILE,VOICE:'.$this->getPhoneNumber()."\n"; |
|
757 | + $ret .= 'EMAIL;TYPE=PREF,INTERNET:'.$this->getEmail()."\n"; |
|
758 | + $ret .= "END:VCARD\n"; |
|
759 | 759 | return $ret; |
760 | 760 | } |
761 | 761 | } |
@@ -25,7 +25,7 @@ discard block |
||
25 | 25 | |
26 | 26 | private function getUserFromSession() |
27 | 27 | { |
28 | - if(FlipSession::isLoggedIn()) |
|
28 | + if (FlipSession::isLoggedIn()) |
|
29 | 29 | { |
30 | 30 | return FlipSession::getUser(); |
31 | 31 | } |
@@ -41,7 +41,7 @@ discard block |
||
41 | 41 | $auth = \AuthProvider::getInstance(); |
42 | 42 | $auth->login($_SERVER['PHP_AUTH_USER'], $_SERVER['PHP_AUTH_PW']); |
43 | 43 | $user = FlipSession::getUser(); |
44 | - if($user === false) |
|
44 | + if ($user === false) |
|
45 | 45 | { |
46 | 46 | $data = substr($header['Authorization'], 6); |
47 | 47 | $userpass = explode(':', base64_decode($data)); |
@@ -62,7 +62,7 @@ discard block |
||
62 | 62 | |
63 | 63 | private function getUserFromHeader($header) |
64 | 64 | { |
65 | - if(strncmp($header, 'Basic', 5) == 0) |
|
65 | + if (strncmp($header, 'Basic', 5) == 0) |
|
66 | 66 | { |
67 | 67 | return $this->getUserFromBasicAuth($header); |
68 | 68 | } |
@@ -72,7 +72,7 @@ discard block |
||
72 | 72 | public function call() |
73 | 73 | { |
74 | 74 | // no auth header |
75 | - if(!isset($this->headers['Authorization'])) |
|
75 | + if (!isset($this->headers['Authorization'])) |
|
76 | 76 | { |
77 | 77 | $this->app->user = $this->getUserFromSession(); |
78 | 78 | } |
@@ -82,7 +82,7 @@ discard block |
||
82 | 82 | $this->app->user = $this->getUserFromHeader($header); |
83 | 83 | } |
84 | 84 | |
85 | - if($this->app->user === false) |
|
85 | + if ($this->app->user === false) |
|
86 | 86 | { |
87 | 87 | $this->app->getLog()->error("No user found for call"); |
88 | 88 | } |
@@ -96,19 +96,19 @@ discard block |
||
96 | 96 | { |
97 | 97 | private function fix_encoded_element($key, $value, &$array, $prefix = '') |
98 | 98 | { |
99 | - if(is_array($value)) |
|
99 | + if (is_array($value)) |
|
100 | 100 | { |
101 | 101 | $array[$key] = implode(';', $value); |
102 | 102 | } |
103 | - else if($key === '_id' && is_object($value)) |
|
103 | + else if ($key === '_id' && is_object($value)) |
|
104 | 104 | { |
105 | 105 | $array[$key] = $value->{'$id'}; |
106 | 106 | } |
107 | - else if(is_object($value)) |
|
107 | + else if (is_object($value)) |
|
108 | 108 | { |
109 | 109 | $array[$key] = $this->app->request->getUrl().$this->app->request->getPath().$prefix.'/'.$key; |
110 | 110 | } |
111 | - else if(strncmp($value, 'data:', 5) === 0) |
|
111 | + else if (strncmp($value, 'data:', 5) === 0) |
|
112 | 112 | { |
113 | 113 | $array[$key] = $this->app->request->getUrl().$this->app->request->getPath().$prefix.'/'.$key; |
114 | 114 | } |
@@ -122,40 +122,40 @@ discard block |
||
122 | 122 | } |
123 | 123 | ob_start(); |
124 | 124 | $df = fopen("php://output", 'w'); |
125 | - if(is_array($array)) |
|
125 | + if (is_array($array)) |
|
126 | 126 | { |
127 | 127 | $first = reset($array); |
128 | 128 | $keys = FALSE; |
129 | - if(is_array($first)) |
|
129 | + if (is_array($first)) |
|
130 | 130 | { |
131 | 131 | $keys = array_keys($first); |
132 | 132 | } |
133 | - else if(is_object($first)) |
|
133 | + else if (is_object($first)) |
|
134 | 134 | { |
135 | 135 | $keys = array_keys(get_object_vars($first)); |
136 | 136 | } |
137 | 137 | fputcsv($df, $keys); |
138 | 138 | foreach ($array as $row) |
139 | 139 | { |
140 | - if(is_array($row)) |
|
140 | + if (is_array($row)) |
|
141 | 141 | { |
142 | 142 | $id = $row[$keys[0]]; |
143 | - foreach($row as $key=>$value) |
|
143 | + foreach ($row as $key=>$value) |
|
144 | 144 | { |
145 | 145 | $this->fix_encoded_element($key, $value, $row, '/'.$id); |
146 | 146 | } |
147 | 147 | fputcsv($df, $row); |
148 | 148 | } |
149 | - else if(is_object($row)) |
|
149 | + else if (is_object($row)) |
|
150 | 150 | { |
151 | 151 | $keyName = $keys[0]; |
152 | 152 | $id = $row->$keyName; |
153 | - if(is_object($id)) |
|
153 | + if (is_object($id)) |
|
154 | 154 | { |
155 | 155 | $id = $id->{'$id'}; |
156 | 156 | } |
157 | 157 | $values = get_object_vars($row); |
158 | - foreach($values as $key=>$value) |
|
158 | + foreach ($values as $key=>$value) |
|
159 | 159 | { |
160 | 160 | $this->fix_encoded_element($key, $value, $values, '/'.$id); |
161 | 161 | } |
@@ -167,7 +167,7 @@ discard block |
||
167 | 167 | { |
168 | 168 | $array = get_object_vars($array); |
169 | 169 | fputcsv($df, array_keys($array)); |
170 | - foreach($array as $key=>$value) |
|
170 | + foreach ($array as $key=>$value) |
|
171 | 171 | { |
172 | 172 | $this->fix_encoded_element($key, $value, $array); |
173 | 173 | } |
@@ -185,34 +185,34 @@ discard block |
||
185 | 185 | |
186 | 186 | public function call() |
187 | 187 | { |
188 | - if($this->app->request->isOptions()) |
|
188 | + if ($this->app->request->isOptions()) |
|
189 | 189 | { |
190 | 190 | return; |
191 | 191 | } |
192 | 192 | $params = $this->app->request->params(); |
193 | 193 | $fmt = null; |
194 | - if(isset($params['fmt'])) |
|
194 | + if (isset($params['fmt'])) |
|
195 | 195 | { |
196 | 196 | $fmt = $params['fmt']; |
197 | 197 | } |
198 | - if($fmt === null && isset($params['$format'])) |
|
198 | + if ($fmt === null && isset($params['$format'])) |
|
199 | 199 | { |
200 | 200 | $fmt = $params['$format']; |
201 | - if(strstr($fmt, 'odata.streaming=true')) |
|
201 | + if (strstr($fmt, 'odata.streaming=true')) |
|
202 | 202 | { |
203 | 203 | $this->app->response->setStatus(406); |
204 | 204 | return; |
205 | 205 | } |
206 | 206 | } |
207 | - if($fmt === null) |
|
207 | + if ($fmt === null) |
|
208 | 208 | { |
209 | 209 | $mimeType = $this->app->request->headers->get('Accept'); |
210 | - if(strstr($mimeType, 'odata.streaming=true')) |
|
210 | + if (strstr($mimeType, 'odata.streaming=true')) |
|
211 | 211 | { |
212 | 212 | $this->app->response->setStatus(406); |
213 | 213 | return; |
214 | 214 | } |
215 | - switch($mimeType) |
|
215 | + switch ($mimeType) |
|
216 | 216 | { |
217 | 217 | case 'text/csv': |
218 | 218 | $fmt = 'csv'; |
@@ -232,11 +232,11 @@ discard block |
||
232 | 232 | |
233 | 233 | $this->next->call(); |
234 | 234 | |
235 | - if($this->app->response->getStatus() == 200 && $this->app->fmt !== 'json') |
|
235 | + if ($this->app->response->getStatus() == 200 && $this->app->fmt !== 'json') |
|
236 | 236 | { |
237 | 237 | $data = json_decode($this->app->response->getBody()); |
238 | 238 | $text = ''; |
239 | - switch($this->app->fmt) |
|
239 | + switch ($this->app->fmt) |
|
240 | 240 | { |
241 | 241 | case 'data-table': |
242 | 242 | $this->app->response->headers->set('Content-Type', 'application/json'); |
@@ -263,7 +263,7 @@ discard block |
||
263 | 263 | } |
264 | 264 | $this->app->response->setBody($text); |
265 | 265 | } |
266 | - else if($this->app->response->getStatus() == 200) |
|
266 | + else if ($this->app->response->getStatus() == 200) |
|
267 | 267 | { |
268 | 268 | $this->app->response->headers->set('Content-Type', 'application/json;odata.metadata=none'); |
269 | 269 | } |
@@ -293,12 +293,12 @@ discard block |
||
293 | 293 | return $this->post($uri, $handler); |
294 | 294 | } |
295 | 295 | |
296 | - function get_json_body($array=false) |
|
296 | + function get_json_body($array = false) |
|
297 | 297 | { |
298 | 298 | return $this->getJsonBody($array); |
299 | 299 | } |
300 | 300 | |
301 | - function getJsonBody($array=false) |
|
301 | + function getJsonBody($array = false) |
|
302 | 302 | { |
303 | 303 | $body = $this->request->getBody(); |
304 | 304 | return json_decode($body, $array); |
@@ -26,16 +26,16 @@ |
||
26 | 26 | { |
27 | 27 | $namespace = substr($classname, 0, $lastNsPos); |
28 | 28 | $classname = substr($classname, $lastNsPos + 1); |
29 | - $filename = str_replace('\\', DIRECTORY_SEPARATOR, $namespace) . DIRECTORY_SEPARATOR; |
|
29 | + $filename = str_replace('\\', DIRECTORY_SEPARATOR, $namespace).DIRECTORY_SEPARATOR; |
|
30 | 30 | } |
31 | 31 | $filename = __DIR__.DIRECTORY_SEPARATOR.$filename.'class.'.$classname.'.php'; |
32 | - if(is_readable($filename)) |
|
32 | + if (is_readable($filename)) |
|
33 | 33 | { |
34 | 34 | require $filename; |
35 | 35 | } |
36 | 36 | } |
37 | 37 | |
38 | -if(version_compare(PHP_VERSION, '5.3.0', '>=')) |
|
38 | +if (version_compare(PHP_VERSION, '5.3.0', '>=')) |
|
39 | 39 | { |
40 | 40 | spl_autoload_register('FlipsideAutoload', true, true); |
41 | 41 | } |
@@ -5,18 +5,18 @@ discard block |
||
5 | 5 | { |
6 | 6 | protected $data = null; |
7 | 7 | |
8 | - function count($filter=false) |
|
8 | + function count($filter = false) |
|
9 | 9 | { |
10 | 10 | throw new \Exception('Unimplemented'); |
11 | 11 | } |
12 | 12 | |
13 | - function search($filter=false, $select=false, $count=false, $skip=false, $sort=false, $params=false) |
|
13 | + function search($filter = false, $select = false, $count = false, $skip = false, $sort = false, $params = false) |
|
14 | 14 | { |
15 | - if($this->data === null) |
|
15 | + if ($this->data === null) |
|
16 | 16 | { |
17 | 17 | throw new \Exception('Unimplemented'); |
18 | 18 | } |
19 | - if($filter !== false) |
|
19 | + if ($filter !== false) |
|
20 | 20 | { |
21 | 21 | $array = $filter->filter_array($this->data); |
22 | 22 | } |
@@ -28,7 +28,7 @@ discard block |
||
28 | 28 | throw new \Exception('Unimplemented'); |
29 | 29 | } |
30 | 30 | |
31 | - function read($filter=false, $select=false, $count=false, $skip=false, $sort=false, $params=false) |
|
31 | + function read($filter = false, $select = false, $count = false, $skip = false, $sort = false, $params = false) |
|
32 | 32 | { |
33 | 33 | return $this->search($filter, $select, $count, $skip, $sort, $params); |
34 | 34 | } |
@@ -7,7 +7,7 @@ discard block |
||
7 | 7 | |
8 | 8 | function __construct($params) |
9 | 9 | { |
10 | - if(isset($params['user'])) |
|
10 | + if (isset($params['user'])) |
|
11 | 11 | { |
12 | 12 | $this->pdo = new \PDO($params['dsn'], $params['user'], $params['pass']); |
13 | 13 | } |
@@ -20,12 +20,12 @@ discard block |
||
20 | 20 | function _get_row_count_for_query($sql) |
21 | 21 | { |
22 | 22 | $stmt = $this->pdo->query($sql); |
23 | - if($stmt === false) |
|
23 | + if ($stmt === false) |
|
24 | 24 | { |
25 | 25 | return 0; |
26 | 26 | } |
27 | 27 | $count = $stmt->rowCount(); |
28 | - if($count === 0) |
|
28 | + if ($count === 0) |
|
29 | 29 | { |
30 | 30 | $array = $stmt->fetchAll(); |
31 | 31 | $count = count($array); |
@@ -35,11 +35,11 @@ discard block |
||
35 | 35 | |
36 | 36 | function _tableExistsNoPrefix($name) |
37 | 37 | { |
38 | - if($this->_get_row_count_for_query('SHOW TABLES LIKE '.$this->pdo->quote($name)) > 0) |
|
38 | + if ($this->_get_row_count_for_query('SHOW TABLES LIKE '.$this->pdo->quote($name)) > 0) |
|
39 | 39 | { |
40 | 40 | return true; |
41 | 41 | } |
42 | - else if($this->_get_row_count_for_query('SELECT * FROM sqlite_master WHERE name LIKE '.$this->pdo->quote($name)) > 0) |
|
42 | + else if ($this->_get_row_count_for_query('SELECT * FROM sqlite_master WHERE name LIKE '.$this->pdo->quote($name)) > 0) |
|
43 | 43 | { |
44 | 44 | return true; |
45 | 45 | } |
@@ -48,11 +48,11 @@ discard block |
||
48 | 48 | |
49 | 49 | function _tableExists($name) |
50 | 50 | { |
51 | - if($this->_get_row_count_for_query('SHOW TABLES LIKE '.$this->pdo->quote('tbl'.$name)) > 0) |
|
51 | + if ($this->_get_row_count_for_query('SHOW TABLES LIKE '.$this->pdo->quote('tbl'.$name)) > 0) |
|
52 | 52 | { |
53 | 53 | return true; |
54 | 54 | } |
55 | - else if($this->_get_row_count_for_query('SELECT * FROM sqlite_master WHERE name LIKE '.$this->pdo->quote('tbl'.$name)) > 0) |
|
55 | + else if ($this->_get_row_count_for_query('SELECT * FROM sqlite_master WHERE name LIKE '.$this->pdo->quote('tbl'.$name)) > 0) |
|
56 | 56 | { |
57 | 57 | return true; |
58 | 58 | } |
@@ -61,11 +61,11 @@ discard block |
||
61 | 61 | |
62 | 62 | function _viewExists($name) |
63 | 63 | { |
64 | - if($this->_get_row_count_for_query('SHOW TABLES LIKE '.$this->pdo->quote('v'.$name)) > 0) |
|
64 | + if ($this->_get_row_count_for_query('SHOW TABLES LIKE '.$this->pdo->quote('v'.$name)) > 0) |
|
65 | 65 | { |
66 | 66 | return true; |
67 | 67 | } |
68 | - else if($this->_get_row_count_for_query('SELECT * FROM sqlite_master WHERE name LIKE '.$this->pdo->quote('v'.$name)) > 0) |
|
68 | + else if ($this->_get_row_count_for_query('SELECT * FROM sqlite_master WHERE name LIKE '.$this->pdo->quote('v'.$name)) > 0) |
|
69 | 69 | { |
70 | 70 | return true; |
71 | 71 | } |
@@ -74,15 +74,15 @@ discard block |
||
74 | 74 | |
75 | 75 | function tableExists($name) |
76 | 76 | { |
77 | - if($this->_tableExists($name)) |
|
77 | + if ($this->_tableExists($name)) |
|
78 | 78 | { |
79 | 79 | return true; |
80 | 80 | } |
81 | - if($this->_tableExistsNoPrefix($name)) |
|
81 | + if ($this->_tableExistsNoPrefix($name)) |
|
82 | 82 | { |
83 | 83 | return true; |
84 | 84 | } |
85 | - if($this->_viewExists($name)) |
|
85 | + if ($this->_viewExists($name)) |
|
86 | 86 | { |
87 | 87 | return true; |
88 | 88 | } |
@@ -91,60 +91,60 @@ discard block |
||
91 | 91 | |
92 | 92 | function getTable($name) |
93 | 93 | { |
94 | - if($this->_tableExists($name)) |
|
94 | + if ($this->_tableExists($name)) |
|
95 | 95 | { |
96 | 96 | return new SQLDataTable($this, 'tbl'.$name); |
97 | 97 | } |
98 | - if($this->_viewExists($name)) |
|
98 | + if ($this->_viewExists($name)) |
|
99 | 99 | { |
100 | 100 | return new SQLDataTable($this, 'v'.$name); |
101 | 101 | } |
102 | - if($this->_tableExistsNoPrefix($name)) |
|
102 | + if ($this->_tableExistsNoPrefix($name)) |
|
103 | 103 | { |
104 | 104 | return new SQLDataTable($this, $name); |
105 | 105 | } |
106 | 106 | throw new \Exception('No such table '.$name); |
107 | 107 | } |
108 | 108 | |
109 | - function read($tablename, $where=false, $select='*', $count=false, $skip=false, $sort=false) |
|
109 | + function read($tablename, $where = false, $select = '*', $count = false, $skip = false, $sort = false) |
|
110 | 110 | { |
111 | - if($select === false) |
|
111 | + if ($select === false) |
|
112 | 112 | { |
113 | 113 | $select = '*'; |
114 | 114 | } |
115 | 115 | $sql = "SELECT $select FROM $tablename"; |
116 | - if($where !== false) |
|
116 | + if ($where !== false) |
|
117 | 117 | { |
118 | - $sql.=' WHERE '.$where; |
|
118 | + $sql .= ' WHERE '.$where; |
|
119 | 119 | } |
120 | - if($count !== false) |
|
120 | + if ($count !== false) |
|
121 | 121 | { |
122 | - if($skip === false) |
|
122 | + if ($skip === false) |
|
123 | 123 | { |
124 | - $sql.=' LIMIT '.(int)$count; |
|
124 | + $sql .= ' LIMIT '.(int)$count; |
|
125 | 125 | } |
126 | 126 | else |
127 | 127 | { |
128 | - $sql.=" LIMIT $skip, $count"; |
|
128 | + $sql .= " LIMIT $skip, $count"; |
|
129 | 129 | } |
130 | 130 | } |
131 | - if($sort !== false) |
|
131 | + if ($sort !== false) |
|
132 | 132 | { |
133 | - $sql.=' ORDER BY '; |
|
133 | + $sql .= ' ORDER BY '; |
|
134 | 134 | $tmp = array(); |
135 | - foreach($sort as $sort_col=>$dir) |
|
135 | + foreach ($sort as $sort_col=>$dir) |
|
136 | 136 | { |
137 | - array_push($tmp, $sort_col.' '.($dir === 1?'ASC':'DESC')); |
|
137 | + array_push($tmp, $sort_col.' '.($dir === 1 ? 'ASC' : 'DESC')); |
|
138 | 138 | } |
139 | - $sql.=implode($tmp,','); |
|
139 | + $sql .= implode($tmp, ','); |
|
140 | 140 | } |
141 | 141 | $stmt = $this->pdo->query($sql, \PDO::FETCH_ASSOC); |
142 | - if($stmt === false) |
|
142 | + if ($stmt === false) |
|
143 | 143 | { |
144 | 144 | return false; |
145 | 145 | } |
146 | 146 | $ret = $stmt->fetchAll(); |
147 | - if($ret === false || empty($ret)) |
|
147 | + if ($ret === false || empty($ret)) |
|
148 | 148 | { |
149 | 149 | return false; |
150 | 150 | } |
@@ -154,19 +154,19 @@ discard block |
||
154 | 154 | function update($tablename, $where, $data) |
155 | 155 | { |
156 | 156 | $set = array(); |
157 | - if(is_object($data)) |
|
157 | + if (is_object($data)) |
|
158 | 158 | { |
159 | 159 | $data = (array)$data; |
160 | 160 | } |
161 | 161 | $cols = array_keys($data); |
162 | 162 | $count = count($cols); |
163 | - for($i = 0; $i < $count; $i++) |
|
163 | + for ($i = 0; $i < $count; $i++) |
|
164 | 164 | { |
165 | 165 | array_push($set, $cols[$i].'='.$this->pdo->quote($data[$cols[$i]])); |
166 | 166 | } |
167 | 167 | $set = implode(',', $set); |
168 | 168 | $sql = "UPDATE $tablename SET $set WHERE $where"; |
169 | - if($this->pdo->exec($sql) === false) |
|
169 | + if ($this->pdo->exec($sql) === false) |
|
170 | 170 | { |
171 | 171 | return false; |
172 | 172 | } |
@@ -176,20 +176,20 @@ discard block |
||
176 | 176 | function create($tablename, $data) |
177 | 177 | { |
178 | 178 | $set = array(); |
179 | - if(is_object($data)) |
|
179 | + if (is_object($data)) |
|
180 | 180 | { |
181 | 181 | $data = (array)$data; |
182 | 182 | } |
183 | 183 | $cols = array_keys($data); |
184 | 184 | $count = count($cols); |
185 | - for($i = 0; $i < $count; $i++) |
|
185 | + for ($i = 0; $i < $count; $i++) |
|
186 | 186 | { |
187 | 187 | array_push($set, $this->pdo->quote($data[$cols[$i]])); |
188 | 188 | } |
189 | 189 | $cols = implode(',', $cols); |
190 | 190 | $set = implode(',', $set); |
191 | 191 | $sql = "INSERT INTO $tablename ($cols) VALUES ($set);"; |
192 | - if($this->pdo->exec($sql) === false) |
|
192 | + if ($this->pdo->exec($sql) === false) |
|
193 | 193 | { |
194 | 194 | return false; |
195 | 195 | } |
@@ -199,7 +199,7 @@ discard block |
||
199 | 199 | function delete($tablename, $where) |
200 | 200 | { |
201 | 201 | $sql = "DELETE FROM $tablename WHERE $where"; |
202 | - if($this->pdo->exec($sql) === false) |
|
202 | + if ($this->pdo->exec($sql) === false) |
|
203 | 203 | { |
204 | 204 | return false; |
205 | 205 | } |
@@ -209,7 +209,7 @@ discard block |
||
209 | 209 | function raw_query($sql) |
210 | 210 | { |
211 | 211 | $stmt = $this->pdo->query($sql, \PDO::FETCH_ASSOC); |
212 | - if($stmt === false) |
|
212 | + if ($stmt === false) |
|
213 | 213 | { |
214 | 214 | return false; |
215 | 215 | } |
@@ -9,7 +9,7 @@ discard block |
||
9 | 9 | |
10 | 10 | function __construct($string = false) |
11 | 11 | { |
12 | - if($string !== false) |
|
12 | + if ($string !== false) |
|
13 | 13 | { |
14 | 14 | $this->string = $string; |
15 | 15 | $this->children = self::process_string($this->string); |
@@ -20,21 +20,21 @@ discard block |
||
20 | 20 | { |
21 | 21 | $parens = false; |
22 | 22 | //First check for parenthesis... |
23 | - if($string[0] === '(' && substr($string, -1) === ')') |
|
23 | + if ($string[0] === '(' && substr($string, -1) === ')') |
|
24 | 24 | { |
25 | - $string = substr($string, 1, strlen($string)-2); |
|
25 | + $string = substr($string, 1, strlen($string) - 2); |
|
26 | 26 | $parens = true; |
27 | 27 | } |
28 | - if(preg_match('/(.+?)( and | or )(.+)/', $string, $clauses) === 0) |
|
28 | + if (preg_match('/(.+?)( and | or )(.+)/', $string, $clauses) === 0) |
|
29 | 29 | { |
30 | 30 | return array(new FilterClause($string)); |
31 | 31 | } |
32 | 32 | $children = array(); |
33 | - if($parens) array_push($children, '('); |
|
33 | + if ($parens) array_push($children, '('); |
|
34 | 34 | $children = array_merge($children, self::process_string($clauses[1])); |
35 | 35 | array_push($children, trim($clauses[2])); |
36 | 36 | $children = array_merge($children, self::process_string($clauses[3])); |
37 | - if($parens) array_push($children, ')'); |
|
37 | + if ($parens) array_push($children, ')'); |
|
38 | 38 | return $children; |
39 | 39 | } |
40 | 40 | |
@@ -42,23 +42,23 @@ discard block |
||
42 | 42 | { |
43 | 43 | $ret = ''; |
44 | 44 | $count = count($this->children); |
45 | - for($i = 0; $i < $count; $i++) |
|
45 | + for ($i = 0; $i < $count; $i++) |
|
46 | 46 | { |
47 | - if($this->children[$i] === '(' || $this->children[$i] === ')') |
|
47 | + if ($this->children[$i] === '(' || $this->children[$i] === ')') |
|
48 | 48 | { |
49 | - $ret.=$this->children[$i]; |
|
49 | + $ret .= $this->children[$i]; |
|
50 | 50 | } |
51 | - else if($this->children[$i] === 'and') |
|
51 | + else if ($this->children[$i] === 'and') |
|
52 | 52 | { |
53 | - $ret.=' AND '; |
|
53 | + $ret .= ' AND '; |
|
54 | 54 | } |
55 | - else if($this->children[$i] === 'or') |
|
55 | + else if ($this->children[$i] === 'or') |
|
56 | 56 | { |
57 | - $ret.=' OR '; |
|
57 | + $ret .= ' OR '; |
|
58 | 58 | } |
59 | 59 | else |
60 | 60 | { |
61 | - $ret.=$this->children[$i]->to_sql_string(); |
|
61 | + $ret .= $this->children[$i]->to_sql_string(); |
|
62 | 62 | } |
63 | 63 | } |
64 | 64 | return $ret.$this->sqlAppend; |
@@ -69,19 +69,19 @@ discard block |
||
69 | 69 | $ret = ''; |
70 | 70 | $count = count($this->children); |
71 | 71 | $prefix = ''; |
72 | - for($i = 0; $i < $count; $i++) |
|
72 | + for ($i = 0; $i < $count; $i++) |
|
73 | 73 | { |
74 | - if($this->children[$i] === 'and') |
|
74 | + if ($this->children[$i] === 'and') |
|
75 | 75 | { |
76 | - if($prefix == '|') |
|
76 | + if ($prefix == '|') |
|
77 | 77 | { |
78 | 78 | throw new \Exception('Do not support both and or'); |
79 | 79 | } |
80 | 80 | $prefix = '&'; |
81 | 81 | } |
82 | - else if($this->children[$i] === 'or') |
|
82 | + else if ($this->children[$i] === 'or') |
|
83 | 83 | { |
84 | - if($prefix == '&') |
|
84 | + if ($prefix == '&') |
|
85 | 85 | { |
86 | 86 | throw new \Exception('Do not support both and or'); |
87 | 87 | } |
@@ -89,10 +89,10 @@ discard block |
||
89 | 89 | } |
90 | 90 | else |
91 | 91 | { |
92 | - $ret.=$this->children[$i]->to_ldap_string(); |
|
92 | + $ret .= $this->children[$i]->to_ldap_string(); |
|
93 | 93 | } |
94 | 94 | } |
95 | - if($count === 1 && $prefix === '') |
|
95 | + if ($count === 1 && $prefix === '') |
|
96 | 96 | { |
97 | 97 | return $ret; |
98 | 98 | } |
@@ -103,14 +103,14 @@ discard block |
||
103 | 103 | { |
104 | 104 | $ret = array(); |
105 | 105 | $count = count($this->children); |
106 | - for($i = 0; $i < $count; $i++) |
|
106 | + for ($i = 0; $i < $count; $i++) |
|
107 | 107 | { |
108 | - if($this->children[$i] === 'and') |
|
108 | + if ($this->children[$i] === 'and') |
|
109 | 109 | { |
110 | 110 | $old = array_pop($ret); |
111 | 111 | array_push($ret, array('$and'=>array($old, $this->children[++$i]->to_mongo_filter()))); |
112 | 112 | } |
113 | - else if($this->children[$i] === 'or') |
|
113 | + else if ($this->children[$i] === 'or') |
|
114 | 114 | { |
115 | 115 | $old = array_pop($ret); |
116 | 116 | array_push($ret, array('$or'=>array($old, $this->children[++$i]->to_mongo_filter()))); |
@@ -120,7 +120,7 @@ discard block |
||
120 | 120 | array_push($ret, $this->children[$i]->to_mongo_filter()); |
121 | 121 | } |
122 | 122 | } |
123 | - if(count($ret) == 1 && is_array($ret[0])) |
|
123 | + if (count($ret) == 1 && is_array($ret[0])) |
|
124 | 124 | { |
125 | 125 | //print_r(json_encode($ret[0])); die(); |
126 | 126 | return $ret[0]; |
@@ -131,27 +131,27 @@ discard block |
||
131 | 131 | function filter_array(&$array) |
132 | 132 | { |
133 | 133 | $res = array(); |
134 | - if(is_array($array)) |
|
134 | + if (is_array($array)) |
|
135 | 135 | { |
136 | 136 | $search = $array; |
137 | 137 | $count = count($this->children); |
138 | - for($i = 0; $i < $count; $i++) |
|
138 | + for ($i = 0; $i < $count; $i++) |
|
139 | 139 | { |
140 | - if($this->children[$i] === 'and') |
|
140 | + if ($this->children[$i] === 'and') |
|
141 | 141 | { |
142 | 142 | $search = $res; |
143 | 143 | } |
144 | - else if($this->children[$i] === 'or') |
|
144 | + else if ($this->children[$i] === 'or') |
|
145 | 145 | { |
146 | 146 | $search = $array; |
147 | 147 | } |
148 | 148 | else |
149 | 149 | { |
150 | - foreach($search as $subarray) |
|
150 | + foreach ($search as $subarray) |
|
151 | 151 | { |
152 | - if(isset($subarray[$this->children[$i]->var1])) |
|
152 | + if (isset($subarray[$this->children[$i]->var1])) |
|
153 | 153 | { |
154 | - if($this->children[$i]->php_compare($subarray[$this->children[$i]->var1])) |
|
154 | + if ($this->children[$i]->php_compare($subarray[$this->children[$i]->var1])) |
|
155 | 155 | { |
156 | 156 | array_push($res, $subarray); |
157 | 157 | } |
@@ -171,10 +171,10 @@ discard block |
||
171 | 171 | public function getClause($substr) |
172 | 172 | { |
173 | 173 | $count = count($this->children); |
174 | - for($i = 0; $i < $count; $i++) |
|
174 | + for ($i = 0; $i < $count; $i++) |
|
175 | 175 | { |
176 | - if(!is_object($this->children[$i])) continue; |
|
177 | - if(strstr($this->children[$i]->var1, $substr) !== false || |
|
176 | + if (!is_object($this->children[$i])) continue; |
|
177 | + if (strstr($this->children[$i]->var1, $substr) !== false || |
|
178 | 178 | strstr($this->children[$i]->var2, $substr) !== false) |
179 | 179 | { |
180 | 180 | return $this->children[$i]; |
@@ -184,17 +184,17 @@ discard block |
||
184 | 184 | |
185 | 185 | public function addToSQLString($string) |
186 | 186 | { |
187 | - $this->sqlAppend.=$string; |
|
187 | + $this->sqlAppend .= $string; |
|
188 | 188 | } |
189 | 189 | |
190 | 190 | public function appendChild($child) |
191 | 191 | { |
192 | - if($child === 'and' || $child === 'or') |
|
192 | + if ($child === 'and' || $child === 'or') |
|
193 | 193 | { |
194 | 194 | array_push($this->children, $child); |
195 | 195 | return; |
196 | 196 | } |
197 | - else if(is_a($child, '\Data\Filter')) |
|
197 | + else if (is_a($child, '\Data\Filter')) |
|
198 | 198 | { |
199 | 199 | $this->children = array_merge($this->children, $child->children); |
200 | 200 | } |
@@ -6,9 +6,9 @@ discard block |
||
6 | 6 | protected $collection; |
7 | 7 | protected $namespace; |
8 | 8 | |
9 | - function __construct($collection, $collection_name=false) |
|
9 | + function __construct($collection, $collection_name = false) |
|
10 | 10 | { |
11 | - if($collection_name !== false) |
|
11 | + if ($collection_name !== false) |
|
12 | 12 | { |
13 | 13 | $this->namespace = $collection.'.'.$collection_name; |
14 | 14 | } |
@@ -18,12 +18,12 @@ discard block |
||
18 | 18 | } |
19 | 19 | } |
20 | 20 | |
21 | - function count($filter=false) |
|
21 | + function count($filter = false) |
|
22 | 22 | { |
23 | 23 | $criteria = array(); |
24 | - if($filter !== false) |
|
24 | + if ($filter !== false) |
|
25 | 25 | { |
26 | - if($filter instanceof \Data\Filter) |
|
26 | + if ($filter instanceof \Data\Filter) |
|
27 | 27 | { |
28 | 28 | $criteria = $filter->to_mongo_filter(); |
29 | 29 | } |
@@ -35,13 +35,13 @@ discard block |
||
35 | 35 | return $this->collection->count($criteria); |
36 | 36 | } |
37 | 37 | |
38 | - function search($filter=false, $select=false, $count=false, $skip=false, $sort=false, $params=false) |
|
38 | + function search($filter = false, $select = false, $count = false, $skip = false, $sort = false, $params = false) |
|
39 | 39 | { |
40 | 40 | $fields = array(); |
41 | 41 | $criteria = array(); |
42 | - if($filter !== false) |
|
42 | + if ($filter !== false) |
|
43 | 43 | { |
44 | - if(is_array($filter)) |
|
44 | + if (is_array($filter)) |
|
45 | 45 | { |
46 | 46 | $criteria = $filter; |
47 | 47 | } |
@@ -50,29 +50,29 @@ discard block |
||
50 | 50 | $criteria = $filter->to_mongo_filter(); |
51 | 51 | } |
52 | 52 | } |
53 | - if($select !== false) |
|
53 | + if ($select !== false) |
|
54 | 54 | { |
55 | 55 | $fields = array_fill_keys($select, 1); |
56 | 56 | } |
57 | - $cursor = $this->collection->find($criteria, $fields); |
|
58 | - if($params !== false && isset($params['fields'])) |
|
57 | + $cursor = $this->collection->find($criteria, $fields); |
|
58 | + if ($params !== false && isset($params['fields'])) |
|
59 | 59 | { |
60 | 60 | $cursor->fields($params['fields']); |
61 | 61 | } |
62 | - if($sort !== false) |
|
62 | + if ($sort !== false) |
|
63 | 63 | { |
64 | 64 | $cursor->sort($sort); |
65 | 65 | } |
66 | - if($skip !== false) |
|
66 | + if ($skip !== false) |
|
67 | 67 | { |
68 | 68 | $cursor->skip($skip); |
69 | 69 | } |
70 | - if($count !== false) |
|
70 | + if ($count !== false) |
|
71 | 71 | { |
72 | 72 | $cursor->limit($count); |
73 | 73 | } |
74 | - $ret = array(); |
|
75 | - foreach($cursor as $doc) |
|
74 | + $ret = array(); |
|
75 | + foreach ($cursor as $doc) |
|
76 | 76 | { |
77 | 77 | array_push($ret, $doc); |
78 | 78 | } |
@@ -82,7 +82,7 @@ discard block |
||
82 | 82 | function create($data) |
83 | 83 | { |
84 | 84 | $res = $this->collection->insert($data); |
85 | - if($res === false || $res['err'] !== null) |
|
85 | + if ($res === false || $res['err'] !== null) |
|
86 | 86 | { |
87 | 87 | return false; |
88 | 88 | } |
@@ -92,9 +92,9 @@ discard block |
||
92 | 92 | function update($filter, $data) |
93 | 93 | { |
94 | 94 | $criteria = array(); |
95 | - if($filter !== false) |
|
95 | + if ($filter !== false) |
|
96 | 96 | { |
97 | - if(is_array($filter)) |
|
97 | + if (is_array($filter)) |
|
98 | 98 | { |
99 | 99 | $criteria = $filter; |
100 | 100 | } |
@@ -103,12 +103,12 @@ discard block |
||
103 | 103 | $criteria = $filter->to_mongo_filter(); |
104 | 104 | } |
105 | 105 | } |
106 | - if(isset($data['_id'])) |
|
106 | + if (isset($data['_id'])) |
|
107 | 107 | { |
108 | 108 | unset($data['_id']); |
109 | 109 | } |
110 | 110 | $res = $this->collection->update($criteria, array('$set' => $data)); |
111 | - if($res === false || $res['err'] !== null) |
|
111 | + if ($res === false || $res['err'] !== null) |
|
112 | 112 | { |
113 | 113 | return false; |
114 | 114 | } |
@@ -118,9 +118,9 @@ discard block |
||
118 | 118 | function delete($filter) |
119 | 119 | { |
120 | 120 | $criteria = array(); |
121 | - if($filter !== false) |
|
121 | + if ($filter !== false) |
|
122 | 122 | { |
123 | - if(is_array($filter)) |
|
123 | + if (is_array($filter)) |
|
124 | 124 | { |
125 | 125 | $criteria = $filter; |
126 | 126 | } |
@@ -130,7 +130,7 @@ discard block |
||
130 | 130 | } |
131 | 131 | } |
132 | 132 | $res = $this->collection->remove($criteria); |
133 | - if($res === false || $res['err'] !== null) |
|
133 | + if ($res === false || $res['err'] !== null) |
|
134 | 134 | { |
135 | 135 | return false; |
136 | 136 | } |
@@ -11,14 +11,14 @@ discard block |
||
11 | 11 | { |
12 | 12 | $namespace = substr($classname, 0, $lastNsPos); |
13 | 13 | $classname = substr($classname, $lastNsPos + 1); |
14 | - $filename = str_replace('\\', DIRECTORY_SEPARATOR, $namespace) . DIRECTORY_SEPARATOR; |
|
14 | + $filename = str_replace('\\', DIRECTORY_SEPARATOR, $namespace).DIRECTORY_SEPARATOR; |
|
15 | 15 | } |
16 | - if(strlen($namespace)) |
|
16 | + if (strlen($namespace)) |
|
17 | 17 | { |
18 | - $namespace.=DIRECTORY_SEPARATOR; |
|
18 | + $namespace .= DIRECTORY_SEPARATOR; |
|
19 | 19 | } |
20 | 20 | $filename = __DIR__.'/../libs/mongofill/src/'.$namespace.$classname.'.php'; |
21 | - if(is_readable($filename)) |
|
21 | + if (is_readable($filename)) |
|
22 | 22 | { |
23 | 23 | require $filename; |
24 | 24 | } |
@@ -37,18 +37,18 @@ discard block |
||
37 | 37 | $this->mangaer = null; |
38 | 38 | $this->db = null; |
39 | 39 | $this->db_name = null; |
40 | - if(class_exists('MongoClient')) |
|
40 | + if (class_exists('MongoClient')) |
|
41 | 41 | { |
42 | 42 | $this->setupMongoClient($params); |
43 | 43 | } |
44 | - else if(class_exists('\MongoDB\Driver\Manager')) |
|
44 | + else if (class_exists('\MongoDB\Driver\Manager')) |
|
45 | 45 | { |
46 | 46 | $this->setupMongoManager($params); |
47 | 47 | } |
48 | 48 | else |
49 | 49 | { |
50 | 50 | require __DIR__.'/../libs/mongofill/src/functions.php'; |
51 | - if(version_compare(PHP_VERSION, '5.3.0', '>=')) |
|
51 | + if (version_compare(PHP_VERSION, '5.3.0', '>=')) |
|
52 | 52 | { |
53 | 53 | spl_autoload_register('\Data\MongofillAutoload', true, true); |
54 | 54 | } |
@@ -63,7 +63,7 @@ discard block |
||
63 | 63 | function tableExists($name) |
64 | 64 | { |
65 | 65 | $collections = $this->db->getCollectionNames(); |
66 | - if(in_array($name, $collections)) |
|
66 | + if (in_array($name, $collections)) |
|
67 | 67 | { |
68 | 68 | return true; |
69 | 69 | } |
@@ -72,7 +72,7 @@ discard block |
||
72 | 72 | |
73 | 73 | function getTable($name) |
74 | 74 | { |
75 | - if($this->db !== null) |
|
75 | + if ($this->db !== null) |
|
76 | 76 | { |
77 | 77 | return new MongoDataTable($this->db->selectCollection($name)); |
78 | 78 | } |
@@ -84,7 +84,7 @@ discard block |
||
84 | 84 | |
85 | 85 | private function setupMongoClient($params) |
86 | 86 | { |
87 | - if(isset($params['user'])) |
|
87 | + if (isset($params['user'])) |
|
88 | 88 | { |
89 | 89 | $this->client = new \MongoClient('mongodb://'.$params['host'].'/'.$params['db'], array('username'=>$params['user'], 'password'=>$params['pass'])); |
90 | 90 | } |
@@ -97,7 +97,7 @@ discard block |
||
97 | 97 | |
98 | 98 | private function setupMongoManager($params) |
99 | 99 | { |
100 | - if(isset($params['user'])) |
|
100 | + if (isset($params['user'])) |
|
101 | 101 | { |
102 | 102 | $this->manager = new \MongoDB\Driver\Manager('mongodb://'.$params['user'].':'.$params['pass'].'@'.$params['host'].'/'.$params['db']); |
103 | 103 | } |
@@ -15,7 +15,7 @@ discard block |
||
15 | 15 | function get_primary_key() |
16 | 16 | { |
17 | 17 | $res = $this->dataset->raw_query("SHOW INDEX FROM $this->tablename WHERE Key_name='PRIMARY'"); |
18 | - if($res === false) |
|
18 | + if ($res === false) |
|
19 | 19 | { |
20 | 20 | return false; |
21 | 21 | } |
@@ -25,17 +25,17 @@ discard block |
||
25 | 25 | function prefetch_all($key = false) |
26 | 26 | { |
27 | 27 | $array = $this->read(false, false); |
28 | - if($key === false) |
|
28 | + if ($key === false) |
|
29 | 29 | { |
30 | 30 | $key = $this->get_primary_key(); |
31 | 31 | } |
32 | 32 | $count = count($array); |
33 | 33 | $this->data = array(); |
34 | - for($i = 0; $i < $count; $i++) |
|
34 | + for ($i = 0; $i < $count; $i++) |
|
35 | 35 | { |
36 | - if(isset($this->data[$array[$i][$key]])) |
|
36 | + if (isset($this->data[$array[$i][$key]])) |
|
37 | 37 | { |
38 | - if(isset($this->data[$array[$i][$key]][0])) |
|
38 | + if (isset($this->data[$array[$i][$key]][0])) |
|
39 | 39 | { |
40 | 40 | array_push($this->data[$array[$i][$key]], $array[$i]); |
41 | 41 | } |
@@ -51,19 +51,19 @@ discard block |
||
51 | 51 | } |
52 | 52 | } |
53 | 53 | |
54 | - function count($filter=false) |
|
54 | + function count($filter = false) |
|
55 | 55 | { |
56 | - if($this->data !== null) |
|
56 | + if ($this->data !== null) |
|
57 | 57 | { |
58 | 58 | return parent::count($filter); |
59 | 59 | } |
60 | 60 | $where = false; |
61 | - if($filter !== false) |
|
61 | + if ($filter !== false) |
|
62 | 62 | { |
63 | 63 | $where = $filter->to_sql_string(); |
64 | 64 | } |
65 | 65 | $ret = $this->dataset->read($this->tablename, $where, 'COUNT(*)'); |
66 | - if($ret === false || !isset($ret[0]) || !isset($ret[0]['COUNT(*)'])) |
|
66 | + if ($ret === false || !isset($ret[0]) || !isset($ret[0]['COUNT(*)'])) |
|
67 | 67 | { |
68 | 68 | return false; |
69 | 69 | } |
@@ -73,18 +73,18 @@ discard block |
||
73 | 73 | } |
74 | 74 | } |
75 | 75 | |
76 | - function search($filter=false, $select=false, $count=false, $skip=false, $sort=false, $params=false) |
|
76 | + function search($filter = false, $select = false, $count = false, $skip = false, $sort = false, $params = false) |
|
77 | 77 | { |
78 | - if($this->data !== null) |
|
78 | + if ($this->data !== null) |
|
79 | 79 | { |
80 | 80 | return parent::search($filter, $select); |
81 | 81 | } |
82 | 82 | $where = false; |
83 | - if($filter !== false) |
|
83 | + if ($filter !== false) |
|
84 | 84 | { |
85 | 85 | $where = $filter->to_sql_string(); |
86 | 86 | } |
87 | - if($select !== false && is_array($select)) |
|
87 | + if ($select !== false && is_array($select)) |
|
88 | 88 | { |
89 | 89 | $select = implode(',', $select); |
90 | 90 | } |
@@ -105,7 +105,7 @@ discard block |
||
105 | 105 | function delete($filter) |
106 | 106 | { |
107 | 107 | $where = false; |
108 | - if($filter !== false) |
|
108 | + if ($filter !== false) |
|
109 | 109 | { |
110 | 110 | $where = $filter->to_sql_string(); |
111 | 111 | } |