Passed
Branch 1.0.0-dev (4efac2)
by nguereza
04:41
created
core/classes/Response.php 1 patch
Indentation   +11 added lines, -11 removed lines patch added patch discarded remove patch
@@ -22,7 +22,7 @@  discard block
 block discarded – undo
22 22
 	 * You should have received a copy of the GNU General Public License
23 23
 	 * along with this program; if not, write to the Free Software
24 24
 	 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
25
-	*/
25
+	 */
26 26
 
27 27
 	class Response{
28 28
 
@@ -57,9 +57,9 @@  discard block
 block discarded – undo
57 57
 		private $_currentUrlCacheKey = null;
58 58
 		
59 59
 		/**
60
-		* Whether we can compress the output using Gzip
61
-		* @var boolean
62
-		*/
60
+		 * Whether we can compress the output using Gzip
61
+		 * @var boolean
62
+		 */
63 63
 		private static $_canCompressOutput = false;
64 64
 		
65 65
 		/**
@@ -236,8 +236,8 @@  discard block
 block discarded – undo
236 236
 		}
237 237
 		
238 238
 		/**
239
-		* Send the final page output to user
240
-		*/
239
+		 * Send the final page output to user
240
+		 */
241 241
 		public function renderFinalPage(){
242 242
 			$logger = self::getLogger();
243 243
 			$obj = & get_instance();
@@ -301,8 +301,8 @@  discard block
 block discarded – undo
301 301
 		}
302 302
 		
303 303
 		/**
304
-		* Send the final page output to user if is cached
305
-		*/
304
+		 * Send the final page output to user if is cached
305
+		 */
306 306
 		public function renderFinalPageFromCache(&$cache){
307 307
 			$logger = self::getLogger();
308 308
 			$url = $this->_currentUrl;					
@@ -362,9 +362,9 @@  discard block
 block discarded – undo
362 362
 		}
363 363
 		
364 364
 		/**
365
-		* Get the final page to be rendered
366
-		* @return string
367
-		*/
365
+		 * Get the final page to be rendered
366
+		 * @return string
367
+		 */
368 368
 		public function getFinalPageRendered(){
369 369
 			return $this->_pageRender;
370 370
 		}
Please login to merge, or discard this patch.
core/classes/EventInfo.php 1 patch
Indentation   +1 added lines, -1 removed lines patch added patch discarded remove patch
@@ -22,7 +22,7 @@
 block discarded – undo
22 22
 	 * You should have received a copy of the GNU General Public License
23 23
 	 * along with this program; if not, write to the Free Software
24 24
 	 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
25
-	*/
25
+	 */
26 26
 
27 27
 	/**
28 28
 	 * This class represent the event detail to dispatch to correspond listener
Please login to merge, or discard this patch.
core/classes/Controller.php 1 patch
Indentation   +6 added lines, -6 removed lines patch added patch discarded remove patch
@@ -22,7 +22,7 @@  discard block
 block discarded – undo
22 22
 	 * You should have received a copy of the GNU General Public License
23 23
 	 * along with this program; if not, write to the Free Software
24 24
 	 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
25
-	*/
25
+	 */
26 26
 
27 27
 	class Controller{
28 28
 		
@@ -114,12 +114,12 @@  discard block
 block discarded – undo
114 114
 		 */
115 115
 		protected function setLoggerFromParamOrCreateNewInstance(Log $logger = null){
116 116
 			if($logger !== null){
117
-	          $this->logger = $logger;
118
-	        }
119
-	        else{
120
-	            $this->logger =& class_loader('Log', 'classes');
117
+			  $this->logger = $logger;
118
+			}
119
+			else{
120
+				$this->logger =& class_loader('Log', 'classes');
121 121
 				$this->logger->setLogger('MainController');
122
-	        }
122
+			}
123 123
 		}
124 124
 
125 125
 		/**
Please login to merge, or discard this patch.
tests/bootstrap.php 1 patch
Indentation   +128 added lines, -128 removed lines patch added patch discarded remove patch
@@ -21,21 +21,21 @@  discard block
 block discarded – undo
21 21
 	 * You should have received a copy of the GNU General Public License
22 22
 	 * along with this program; if not, write to the Free Software
23 23
 	 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
24
-	*/
24
+	 */
25 25
 	
26 26
 	error_reporting(E_ALL | E_STRICT);
27 27
 	ini_set('display_errors', 1);
28 28
 
29 29
 	/**
30
-	* the directory separator, under windows it is \ and unix, linux /
31
-	*/
30
+	 * the directory separator, under windows it is \ and unix, linux /
31
+	 */
32 32
 	define('DS', DIRECTORY_SEPARATOR);
33 33
 
34 34
 	/**
35
-	* The root directory of the application.
36
-	*
37
-	* you can place this directory outside of your web directory, for example "/home/your_app", etc.
38
-	*/
35
+	 * The root directory of the application.
36
+	 *
37
+	 * you can place this directory outside of your web directory, for example "/home/your_app", etc.
38
+	 */
39 39
 	define('ROOT_PATH', dirname(realpath(__FILE__)) . DS . '..' . DS);
40 40
 	
41 41
 	//tests dir path
@@ -43,176 +43,176 @@  discard block
 block discarded – undo
43 43
 
44 44
 
45 45
 	/**
46
-	* The path to the directory.
47
-	*
48
-	* That contains your static files (javascript, css, images, etc.)
49
-	* Note: the path must be relative to the file index.php (the front-end controller).
50
-	*/
46
+	 * The path to the directory.
47
+	 *
48
+	 * That contains your static files (javascript, css, images, etc.)
49
+	 * Note: the path must be relative to the file index.php (the front-end controller).
50
+	 */
51 51
 	define('ASSETS_PATH', 'assets/');
52 52
 
53 53
 	/**
54
-	* The path to the directory of your cache files.
55
-	*
56
-	* This feature is available currently for database and views.
57
-	*/
54
+	 * The path to the directory of your cache files.
55
+	 *
56
+	 * This feature is available currently for database and views.
57
+	 */
58 58
 	define('CACHE_PATH', ROOT_PATH . 'cache' . DS);
59 59
 
60 60
 	/**
61
-	* Custom application path for tests 
62
-	*/
61
+	 * Custom application path for tests 
62
+	 */
63 63
 	define('APPS_PATH', TESTS_PATH .'hmvc' . DS);
64 64
 
65 65
 	/**
66
-	* The path to the controller directory of your application.
67
-	*
68
-	* If you already know the MVC architecture you know what a controller means; 
69
-	* it is he who makes the business logic of your application in general.
70
-	*/
66
+	 * The path to the controller directory of your application.
67
+	 *
68
+	 * If you already know the MVC architecture you know what a controller means; 
69
+	 * it is he who makes the business logic of your application in general.
70
+	 */
71 71
 	define('APPS_CONTROLLER_PATH', APPS_PATH . 'controllers' . DS);
72 72
 
73 73
 	/**
74
-	* The path to the directory of your model classes of your application. 
75
-	*
76
-	* If you already know the MVC architecture you know what a model means; 
77
-	* it's the one who interacts with the database, in one word persistent data from your application.
78
-	*/
74
+	 * The path to the directory of your model classes of your application. 
75
+	 *
76
+	 * If you already know the MVC architecture you know what a model means; 
77
+	 * it's the one who interacts with the database, in one word persistent data from your application.
78
+	 */
79 79
 	define('APPS_MODEL_PATH', APPS_PATH . 'models' . DS);
80 80
 
81 81
 	/**
82
-	* The path to the directory of your views.
83
-	*
84
-	* If you already know the MVC architecture you know what a view means, 
85
-	* a view is just a user interface (html page, form, etc.) that is to say 
86
-	* everything displayed in the browser interface, etc.
87
-	*/
82
+	 * The path to the directory of your views.
83
+	 *
84
+	 * If you already know the MVC architecture you know what a view means, 
85
+	 * a view is just a user interface (html page, form, etc.) that is to say 
86
+	 * everything displayed in the browser interface, etc.
87
+	 */
88 88
 	define('APPS_VIEWS_PATH', APPS_PATH . 'views' . DS);
89 89
 
90 90
 	/**
91
-	* The path to the configuration directory.
92
-	*
93
-	* That contains most of the configuration files for your 
94
-	* application (database, class loading file, functions, etc.)
95
-	*/
91
+	 * The path to the configuration directory.
92
+	 *
93
+	 * That contains most of the configuration files for your 
94
+	 * application (database, class loading file, functions, etc.)
95
+	 */
96 96
 	define('CONFIG_PATH', ROOT_PATH . 'config' . DS);
97 97
 
98 98
 	/** 
99
-	* The core directory
100
-	*
101
-	* It is recommended to put this folder out of the web directory of your server and 
102
-	* you should not change its content because in case of update you could lose the modified files.
103
-	*/
99
+	 * The core directory
100
+	 *
101
+	 * It is recommended to put this folder out of the web directory of your server and 
102
+	 * you should not change its content because in case of update you could lose the modified files.
103
+	 */
104 104
 	define('CORE_PATH', ROOT_PATH . 'core' . DS);
105 105
 	
106 106
 	/**
107
-	* The path to the directory of core classes that used by the system.
108
-	*
109
-	* It contains PHP classes that are used by the framework internally.
110
-	*/
107
+	 * The path to the directory of core classes that used by the system.
108
+	 *
109
+	 * It contains PHP classes that are used by the framework internally.
110
+	 */
111 111
 	define('CORE_CLASSES_PATH', CORE_PATH . 'classes' . DS);
112 112
 	
113 113
 	/**
114
-	* The path to the directory of core classes for the cache used by the system.
115
-	*
116
-	* It contains PHP classes for the cache drivers.
117
-	*/
114
+	 * The path to the directory of core classes for the cache used by the system.
115
+	 *
116
+	 * It contains PHP classes for the cache drivers.
117
+	 */
118 118
 	define('CORE_CLASSES_CACHE_PATH', CORE_CLASSES_PATH . 'cache' . DS);
119 119
 	
120 120
 	/**
121
-	* The path to the directory of core classes for the model used by the system.
122
-	*
123
-	* It contains PHP classes for the models.
124
-	*/
121
+	 * The path to the directory of core classes for the model used by the system.
122
+	 *
123
+	 * It contains PHP classes for the models.
124
+	 */
125 125
 	define('CORE_CLASSES_MODEL_PATH', CORE_CLASSES_PATH . 'model' . DS);
126 126
 
127 127
 	/**
128
-	* The path to the directory of functions or helper systems.
129
-	*
130
-	* It contains PHP functions that perform a particular task: character string processing, URL, etc.
131
-	*/
128
+	 * The path to the directory of functions or helper systems.
129
+	 *
130
+	 * It contains PHP functions that perform a particular task: character string processing, URL, etc.
131
+	 */
132 132
 	define('CORE_FUNCTIONS_PATH', CORE_PATH . 'functions' . DS);
133 133
 
134 134
 	/**
135
-	* The path to the core directory of languages files. 
136
-	*
137
-	*/
135
+	 * The path to the core directory of languages files. 
136
+	 *
137
+	 */
138 138
 	define('CORE_LANG_PATH', CORE_PATH . 'lang' . DS);
139 139
 
140 140
 	/**
141
-	* The path to the system library directory.
142
-	*
143
-	* Which contains the libraries most often used in your web application, as for the 
144
-	* core directory it is advisable to put it out of the root directory of your application.
145
-	*/
141
+	 * The path to the system library directory.
142
+	 *
143
+	 * Which contains the libraries most often used in your web application, as for the 
144
+	 * core directory it is advisable to put it out of the root directory of your application.
145
+	 */
146 146
 	define('CORE_LIBRARY_PATH', CORE_PATH . 'libraries' . DS);
147 147
 
148 148
 	/**
149
-	* The path to the system view directory.
150
-	*
151
-	* That contains the views used for the system, such as error messages, and so on.
152
-	*/
149
+	 * The path to the system view directory.
150
+	 *
151
+	 * That contains the views used for the system, such as error messages, and so on.
152
+	 */
153 153
 	define('CORE_VIEWS_PATH', CORE_PATH . 'views' . DS);
154 154
 	
155 155
 	/**
156
-	* The path to the directory of your PHP personal functions or helper.
157
-	*
158
-	* It contains your PHP functions that perform a particular task: utilities, etc.
159
-	* Note: Do not put your personal functions or helpers in the system functions directory, 
160
-	* because if you update the system you may lose them.
161
-	*/
156
+	 * The path to the directory of your PHP personal functions or helper.
157
+	 *
158
+	 * It contains your PHP functions that perform a particular task: utilities, etc.
159
+	 * Note: Do not put your personal functions or helpers in the system functions directory, 
160
+	 * because if you update the system you may lose them.
161
+	 */
162 162
 	define('FUNCTIONS_PATH', ROOT_PATH . 'functions' . DS);
163 163
 
164 164
 	/**
165
-	* The path to the app directory of personal language. 
166
-	*
167
-	* This feature is not yet available. 
168
-	* You can help us do this if you are nice or wish to see the developed framework.
169
-	*/
165
+	 * The path to the app directory of personal language. 
166
+	 *
167
+	 * This feature is not yet available. 
168
+	 * You can help us do this if you are nice or wish to see the developed framework.
169
+	 */
170 170
 	define('APP_LANG_PATH', ROOT_PATH . 'lang' . DS);
171 171
 
172 172
 	/**
173
-	* The path to the directory of your personal libraries
174
-	*
175
-	* It contains your PHP classes, package, etc.
176
-	* Note: you should not put your personal libraries in the system library directory, 
177
-	* because it is recalled in case of updating the system you might have surprises.
178
-	*/
173
+	 * The path to the directory of your personal libraries
174
+	 *
175
+	 * It contains your PHP classes, package, etc.
176
+	 * Note: you should not put your personal libraries in the system library directory, 
177
+	 * because it is recalled in case of updating the system you might have surprises.
178
+	 */
179 179
 	define('LIBRARY_PATH', ROOT_PATH . 'libraries' . DS);
180 180
 
181 181
 	/**
182
-	* The path to the directory that contains the log files.
183
-	*
184
-	* Note: This directory must be available in writing and if possible must have as owner the user who launches your web server, 
185
-	* under unix or linux most often with the apache web server it is "www-data" or "httpd" even "nobody" for more
186
-	* details see the documentation of your web server.
187
-	* Example for Unix or linux with apache web server:
188
-	* # chmod -R 700 /path/to/your/logs/directory/
189
-	* # chown -R www-data:www-data /path/to/your/logs/directory/
190
-	*/
182
+	 * The path to the directory that contains the log files.
183
+	 *
184
+	 * Note: This directory must be available in writing and if possible must have as owner the user who launches your web server, 
185
+	 * under unix or linux most often with the apache web server it is "www-data" or "httpd" even "nobody" for more
186
+	 * details see the documentation of your web server.
187
+	 * Example for Unix or linux with apache web server:
188
+	 * # chmod -R 700 /path/to/your/logs/directory/
189
+	 * # chown -R www-data:www-data /path/to/your/logs/directory/
190
+	 */
191 191
 	define('LOGS_PATH', ROOT_PATH . 'logs' . DS);
192 192
 
193 193
 	/**
194
-	* The path to the modules directory. 
195
-	*
196
-	* It contains your modules used files (config, controllers, libraries, etc.) that is to say which contains your files of the modules, 
197
-	* in HMVC architecture (hierichical, controllers, models, views).
198
-	*/
194
+	 * The path to the modules directory. 
195
+	 *
196
+	 * It contains your modules used files (config, controllers, libraries, etc.) that is to say which contains your files of the modules, 
197
+	 * in HMVC architecture (hierichical, controllers, models, views).
198
+	 */
199 199
 	define('MODULE_PATH', dirname(realpath(__FILE__)) . DS .'hmvc' . DS . 'modules' . DS);
200 200
 
201 201
 	/**
202
-	* The path to the directory of sources external to your application.
203
-	*
204
-	* If you have already used "composer" you know what that means.
205
-	*/
202
+	 * The path to the directory of sources external to your application.
203
+	 *
204
+	 * If you have already used "composer" you know what that means.
205
+	 */
206 206
 	define('VENDOR_PATH', ROOT_PATH . 'vendor' . DS);
207 207
 
208 208
 	/**
209
-	* The front controller of your application.
210
-	*
211
-	* "index.php" it is through this file that all the requests come, there is a possibility to hidden it in the url of 
212
-	* your application by using the rewrite module URL of your web server .
213
-	* For example, under apache web server, there is a configuration example file that is located at the root 
214
-	* of your framework folder : "htaccess.txt" rename it to ".htaccess".
215
-	*/
209
+	 * The front controller of your application.
210
+	 *
211
+	 * "index.php" it is through this file that all the requests come, there is a possibility to hidden it in the url of 
212
+	 * your application by using the rewrite module URL of your web server .
213
+	 * For example, under apache web server, there is a configuration example file that is located at the root 
214
+	 * of your framework folder : "htaccess.txt" rename it to ".htaccess".
215
+	 */
216 216
 	define('SELF', pathinfo(__FILE__, PATHINFO_BASENAME));
217 217
 	
218 218
 	/**
@@ -221,14 +221,14 @@  discard block
 block discarded – undo
221 221
 	define('IS_CLI', stripos('cli', php_sapi_name()) !== false);
222 222
 
223 223
 	/**
224
-	* The environment of your application (production, test, development). 
225
-	*
226
-	* if your application is still in development you use the value "development" 
227
-	* so you will have the display of the error messages, etc. 
228
-	* Once you finish the development of your application that is to put it online 
229
-	* you change this value to "production" or "testing", in this case there will be deactivation of error messages, 
230
-	* the loading of the system, will be fast.
231
-	*/
224
+	 * The environment of your application (production, test, development). 
225
+	 *
226
+	 * if your application is still in development you use the value "development" 
227
+	 * so you will have the display of the error messages, etc. 
228
+	 * Once you finish the development of your application that is to put it online 
229
+	 * you change this value to "production" or "testing", in this case there will be deactivation of error messages, 
230
+	 * the loading of the system, will be fast.
231
+	 */
232 232
 	define('ENVIRONMENT', 'testing');
233 233
 	
234 234
 	
@@ -262,13 +262,13 @@  discard block
 block discarded – undo
262 262
 	require_once  'include/testsUtil.php';
263 263
 	
264 264
 	/**
265
-	* Setting of the PHP error message handling function
266
-	*/
265
+	 * Setting of the PHP error message handling function
266
+	 */
267 267
 	set_error_handler('php_error_handler');
268 268
 
269 269
 	/**
270
-	* Setting of the PHP error exception handling function
271
-	*/
270
+	 * Setting of the PHP error exception handling function
271
+	 */
272 272
 	set_exception_handler('php_exception_handler');
273 273
 
274 274
 	/**
@@ -277,8 +277,8 @@  discard block
 block discarded – undo
277 277
 	register_shutdown_function('php_shudown_handler');
278 278
 	
279 279
 	/**
280
-	* Register the tests autoload
281
-	*/
280
+	 * Register the tests autoload
281
+	 */
282 282
 	spl_autoload_register('tests_autoload');
283 283
 	
284 284
 	
Please login to merge, or discard this patch.
core/classes/DatabaseQueryBuilder.php 1 patch
Indentation   +826 added lines, -826 removed lines patch added patch discarded remove patch
@@ -1,5 +1,5 @@  discard block
 block discarded – undo
1 1
 <?php
2
-    defined('ROOT_PATH') || exit('Access denied');
2
+	defined('ROOT_PATH') || exit('Access denied');
3 3
   /**
4 4
    * TNH Framework
5 5
    *
@@ -22,740 +22,740 @@  discard block
 block discarded – undo
22 22
    * You should have received a copy of the GNU General Public License
23 23
    * along with this program; if not, write to the Free Software
24 24
    * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
25
-  */
25
+   */
26 26
   class DatabaseQueryBuilder{
27 27
   	/**
28 28
   	 * The SQL SELECT statment
29 29
   	 * @var string
30
-  	*/
30
+  	 */
31 31
   	private $select              = '*';
32 32
   	
33 33
   	/**
34 34
   	 * The SQL FROM statment
35 35
   	 * @var string
36
-  	*/
37
-      private $from                = null;
36
+  	 */
37
+	  private $from                = null;
38 38
   	
39 39
   	/**
40 40
   	 * The SQL WHERE statment
41 41
   	 * @var string
42
-  	*/
43
-      private $where               = null;
42
+  	 */
43
+	  private $where               = null;
44 44
   	
45 45
   	/**
46 46
   	 * The SQL LIMIT statment
47 47
   	 * @var string
48
-  	*/
49
-      private $limit               = null;
48
+  	 */
49
+	  private $limit               = null;
50 50
   	
51 51
   	/**
52 52
   	 * The SQL JOIN statment
53 53
   	 * @var string
54
-  	*/
55
-      private $join                = null;
54
+  	 */
55
+	  private $join                = null;
56 56
   	
57 57
   	/**
58 58
   	 * The SQL ORDER BY statment
59 59
   	 * @var string
60
-  	*/
61
-      private $orderBy             = null;
60
+  	 */
61
+	  private $orderBy             = null;
62 62
   	
63 63
   	/**
64 64
   	 * The SQL GROUP BY statment
65 65
   	 * @var string
66
-  	*/
67
-      private $groupBy             = null;
66
+  	 */
67
+	  private $groupBy             = null;
68 68
   	
69 69
   	/**
70 70
   	 * The SQL HAVING statment
71 71
   	 * @var string
72
-  	*/
73
-      private $having              = null;
72
+  	 */
73
+	  private $having              = null;
74 74
   	
75 75
   	/**
76 76
   	 * The full SQL query statment after build for each command
77 77
   	 * @var string
78
-  	*/
79
-      private $query               = null;
78
+  	 */
79
+	  private $query               = null;
80 80
   	
81 81
   	/**
82 82
   	 * The list of SQL valid operators
83 83
   	 * @var array
84
-  	*/
85
-    private $operatorList        = array('=','!=','<','>','<=','>=','<>');
84
+  	 */
85
+	private $operatorList        = array('=','!=','<','>','<=','>=','<>');
86 86
   	
87 87
 	
88 88
 	/**
89 89
 	 * The prefix used in each database table
90 90
 	 * @var string
91
-	*/
92
-    private $prefix              = null;
91
+	 */
92
+	private $prefix              = null;
93 93
     
94 94
 
95 95
   /**
96
-	 * The PDO instance
97
-	 * @var object
98
-	*/
96
+   * The PDO instance
97
+   * @var object
98
+   */
99 99
   private $pdo                 = null;
100 100
 	
101 101
   	/**
102 102
   	 * The database driver name used
103 103
   	 * @var string
104
-  	*/
104
+  	 */
105 105
   	private $driver              = null;
106 106
   	
107 107
 	
108
-    /**
109
-     * Construct new DatabaseQueryBuilder
110
-     * @param object $pdo the PDO object
111
-     */
112
-    public function __construct(PDO $pdo = null){
113
-        if (is_object($pdo)){
114
-          $this->setPdo($pdo);
115
-        }
116
-    }
117
-
118
-    /**
119
-     * Set the SQL FROM statment
120
-     * @param  string|array $table the table name or array of table list
121
-     * @return object        the current DatabaseQueryBuilder instance
122
-     */
123
-    public function from($table){
108
+	/**
109
+	 * Construct new DatabaseQueryBuilder
110
+	 * @param object $pdo the PDO object
111
+	 */
112
+	public function __construct(PDO $pdo = null){
113
+		if (is_object($pdo)){
114
+		  $this->setPdo($pdo);
115
+		}
116
+	}
117
+
118
+	/**
119
+	 * Set the SQL FROM statment
120
+	 * @param  string|array $table the table name or array of table list
121
+	 * @return object        the current DatabaseQueryBuilder instance
122
+	 */
123
+	public function from($table){
124 124
 	  if (is_array($table)){
125
-        $froms = '';
126
-        foreach($table as $key){
127
-          $froms .= $this->getPrefix() . $key . ', ';
128
-        }
129
-        $this->from = rtrim($froms, ', ');
130
-      } else {
131
-        $this->from = $this->getPrefix() . $table;
132
-      }
133
-      return $this;
134
-    }
135
-
136
-    /**
137
-     * Set the SQL SELECT statment
138
-     * @param  string|array $fields the field name or array of field list
139
-     * @return object        the current DatabaseQueryBuilder instance
140
-     */
141
-    public function select($fields){
142
-      $select = (is_array($fields) ? implode(', ', $fields) : $fields);
143
-      $this->select = (($this->select == '*' || empty($this->select)) ? $select : $this->select . ', ' . $select);
144
-      return $this;
145
-    }
146
-
147
-    /**
148
-     * Set the SQL SELECT DISTINCT statment
149
-     * @param  string $field the field name to distinct
150
-     * @return object        the current DatabaseQueryBuilder instance
151
-     */
152
-    public function distinct($field){
153
-      $distinct = ' DISTINCT ' . $field;
154
-      $this->select = (($this->select == '*' || empty($this->select)) ? $distinct : $this->select . ', ' . $distinct);
155
-      return $this;
156
-    }
157
-
158
-     /**
159
-     * Set the SQL function COUNT in SELECT statment
160
-     * @param  string $field the field name
161
-     * @param  string $name  if is not null represent the alias used for this field in the result
162
-     * @return object        the current DatabaseQueryBuilder instance
163
-     */
164
-    public function count($field = '*', $name = null){
165
-      return $this->select_min_max_sum_count_avg('COUNT', $field, $name);
166
-    }
125
+		$froms = '';
126
+		foreach($table as $key){
127
+		  $froms .= $this->getPrefix() . $key . ', ';
128
+		}
129
+		$this->from = rtrim($froms, ', ');
130
+	  } else {
131
+		$this->from = $this->getPrefix() . $table;
132
+	  }
133
+	  return $this;
134
+	}
135
+
136
+	/**
137
+	 * Set the SQL SELECT statment
138
+	 * @param  string|array $fields the field name or array of field list
139
+	 * @return object        the current DatabaseQueryBuilder instance
140
+	 */
141
+	public function select($fields){
142
+	  $select = (is_array($fields) ? implode(', ', $fields) : $fields);
143
+	  $this->select = (($this->select == '*' || empty($this->select)) ? $select : $this->select . ', ' . $select);
144
+	  return $this;
145
+	}
146
+
147
+	/**
148
+	 * Set the SQL SELECT DISTINCT statment
149
+	 * @param  string $field the field name to distinct
150
+	 * @return object        the current DatabaseQueryBuilder instance
151
+	 */
152
+	public function distinct($field){
153
+	  $distinct = ' DISTINCT ' . $field;
154
+	  $this->select = (($this->select == '*' || empty($this->select)) ? $distinct : $this->select . ', ' . $distinct);
155
+	  return $this;
156
+	}
157
+
158
+	 /**
159
+	  * Set the SQL function COUNT in SELECT statment
160
+	  * @param  string $field the field name
161
+	  * @param  string $name  if is not null represent the alias used for this field in the result
162
+	  * @return object        the current DatabaseQueryBuilder instance
163
+	  */
164
+	public function count($field = '*', $name = null){
165
+	  return $this->select_min_max_sum_count_avg('COUNT', $field, $name);
166
+	}
167 167
     
168
-    /**
169
-     * Set the SQL function MIN in SELECT statment
170
-     * @param  string $field the field name
171
-     * @param  string $name  if is not null represent the alias used for this field in the result
172
-     * @return object        the current DatabaseQueryBuilder instance
173
-     */
174
-    public function min($field, $name = null){
175
-      return $this->select_min_max_sum_count_avg('MIN', $field, $name);
176
-    }
177
-
178
-    /**
179
-     * Set the SQL function MAX in SELECT statment
180
-     * @param  string $field the field name
181
-     * @param  string $name  if is not null represent the alias used for this field in the result
182
-     * @return object        the current DatabaseQueryBuilder instance
183
-     */
184
-    public function max($field, $name = null){
185
-      return $this->select_min_max_sum_count_avg('MAX', $field, $name);
186
-    }
187
-
188
-    /**
189
-     * Set the SQL function SUM in SELECT statment
190
-     * @param  string $field the field name
191
-     * @param  string $name  if is not null represent the alias used for this field in the result
192
-     * @return object        the current DatabaseQueryBuilder instance
193
-     */
194
-    public function sum($field, $name = null){
195
-      return $this->select_min_max_sum_count_avg('SUM', $field, $name);
196
-    }
197
-
198
-    /**
199
-     * Set the SQL function AVG in SELECT statment
200
-     * @param  string $field the field name
201
-     * @param  string $name  if is not null represent the alias used for this field in the result
202
-     * @return object        the current DatabaseQueryBuilder instance
203
-     */
204
-    public function avg($field, $name = null){
205
-      return $this->select_min_max_sum_count_avg('AVG', $field, $name);
206
-    }
207
-
208
-
209
-    /**
210
-     * Set the SQL JOIN statment
211
-     * @param  string $table  the join table name
212
-     * @param  string $field1 the first field for join conditions	
213
-     * @param  string $op     the join condition operator. If is null the default will be "="
214
-     * @param  string $field2 the second field for join conditions
215
-     * @param  string $type   the type of join (INNER, LEFT, RIGHT)
216
-     * @return object        the current DatabaseQueryBuilder instance
217
-     */
218
-    public function join($table, $field1 = null, $op = null, $field2 = null, $type = ''){
219
-      $on = $field1;
220
-      $table = $this->getPrefix() . $table;
221
-      if (! is_null($op)){
222
-        $on = (! in_array($op, $this->operatorList) 
168
+	/**
169
+	 * Set the SQL function MIN in SELECT statment
170
+	 * @param  string $field the field name
171
+	 * @param  string $name  if is not null represent the alias used for this field in the result
172
+	 * @return object        the current DatabaseQueryBuilder instance
173
+	 */
174
+	public function min($field, $name = null){
175
+	  return $this->select_min_max_sum_count_avg('MIN', $field, $name);
176
+	}
177
+
178
+	/**
179
+	 * Set the SQL function MAX in SELECT statment
180
+	 * @param  string $field the field name
181
+	 * @param  string $name  if is not null represent the alias used for this field in the result
182
+	 * @return object        the current DatabaseQueryBuilder instance
183
+	 */
184
+	public function max($field, $name = null){
185
+	  return $this->select_min_max_sum_count_avg('MAX', $field, $name);
186
+	}
187
+
188
+	/**
189
+	 * Set the SQL function SUM in SELECT statment
190
+	 * @param  string $field the field name
191
+	 * @param  string $name  if is not null represent the alias used for this field in the result
192
+	 * @return object        the current DatabaseQueryBuilder instance
193
+	 */
194
+	public function sum($field, $name = null){
195
+	  return $this->select_min_max_sum_count_avg('SUM', $field, $name);
196
+	}
197
+
198
+	/**
199
+	 * Set the SQL function AVG in SELECT statment
200
+	 * @param  string $field the field name
201
+	 * @param  string $name  if is not null represent the alias used for this field in the result
202
+	 * @return object        the current DatabaseQueryBuilder instance
203
+	 */
204
+	public function avg($field, $name = null){
205
+	  return $this->select_min_max_sum_count_avg('AVG', $field, $name);
206
+	}
207
+
208
+
209
+	/**
210
+	 * Set the SQL JOIN statment
211
+	 * @param  string $table  the join table name
212
+	 * @param  string $field1 the first field for join conditions	
213
+	 * @param  string $op     the join condition operator. If is null the default will be "="
214
+	 * @param  string $field2 the second field for join conditions
215
+	 * @param  string $type   the type of join (INNER, LEFT, RIGHT)
216
+	 * @return object        the current DatabaseQueryBuilder instance
217
+	 */
218
+	public function join($table, $field1 = null, $op = null, $field2 = null, $type = ''){
219
+	  $on = $field1;
220
+	  $table = $this->getPrefix() . $table;
221
+	  if (! is_null($op)){
222
+		$on = (! in_array($op, $this->operatorList) 
223 223
 													? ($this->getPrefix() . $field1 . ' = ' . $this->getPrefix() . $op) 
224 224
 													: ($this->getPrefix() . $field1 . ' ' . $op . ' ' . $this->getPrefix() . $field2));
225
-      }
226
-      if (empty($this->join)){
227
-        $this->join = ' ' . $type . 'JOIN' . ' ' . $table . ' ON ' . $on;
228
-      }
229
-      else{
230
-        $this->join = $this->join . ' ' . $type . 'JOIN' . ' ' . $table . ' ON ' . $on;
231
-      }
232
-      return $this;
233
-    }
234
-
235
-    /**
236
-     * Set the SQL INNER JOIN statment
237
-     * @see  DatabaseQueryBuilder::join()
238
-     * @return object        the current DatabaseQueryBuilder instance
239
-     */
240
-    public function innerJoin($table, $field1, $op = null, $field2 = ''){
241
-      return $this->join($table, $field1, $op, $field2, 'INNER ');
242
-    }
243
-
244
-    /**
245
-     * Set the SQL LEFT JOIN statment
246
-     * @see  DatabaseQueryBuilder::join()
247
-     * @return object        the current DatabaseQueryBuilder instance
248
-     */
249
-    public function leftJoin($table, $field1, $op = null, $field2 = ''){
250
-      return $this->join($table, $field1, $op, $field2, 'LEFT ');
251
-	}
252
-
253
-	/**
254
-     * Set the SQL RIGHT JOIN statment
255
-     * @see  DatabaseQueryBuilder::join()
256
-     * @return object        the current DatabaseQueryBuilder instance
257
-     */
258
-    public function rightJoin($table, $field1, $op = null, $field2 = ''){
259
-      return $this->join($table, $field1, $op, $field2, 'RIGHT ');
260
-    }
261
-
262
-    /**
263
-     * Set the SQL FULL OUTER JOIN statment
264
-     * @see  DatabaseQueryBuilder::join()
265
-     * @return object        the current DatabaseQueryBuilder instance
266
-     */
267
-    public function fullOuterJoin($table, $field1, $op = null, $field2 = ''){
268
-    	return $this->join($table, $field1, $op, $field2, 'FULL OUTER ');
269
-    }
270
-
271
-    /**
272
-     * Set the SQL LEFT OUTER JOIN statment
273
-     * @see  DatabaseQueryBuilder::join()
274
-     * @return object        the current DatabaseQueryBuilder instance
275
-     */
276
-    public function leftOuterJoin($table, $field1, $op = null, $field2 = ''){
277
-      return $this->join($table, $field1, $op, $field2, 'LEFT OUTER ');
278
-    }
279
-
280
-    /**
281
-     * Set the SQL RIGHT OUTER JOIN statment
282
-     * @see  DatabaseQueryBuilder::join()
283
-     * @return object        the current DatabaseQueryBuilder instance
284
-     */
285
-    public function rightOuterJoin($table, $field1, $op = null, $field2 = ''){
286
-      return $this->join($table, $field1, $op, $field2, 'RIGHT OUTER ');
287
-    }
288
-
289
-    /**
290
-     * Set the SQL WHERE CLAUSE for IS NULL
291
-     * @param  string|array $field  the field name or array of field list
292
-     * @param  string $andOr the separator type used 'AND', 'OR', etc.
293
-     * @return object        the current DatabaseQueryBuilder instance
294
-     */
295
-    public function whereIsNull($field, $andOr = 'AND'){
296
-      if (is_array($field)){
297
-        foreach($field as $f){
298
-        	$this->whereIsNull($f, $andOr);
299
-        }
300
-      } else {
301
-          $this->setWhereStr($field.' IS NULL ', $andOr);
302
-      }
303
-      return $this;
304
-    }
305
-
306
-    /**
307
-     * Set the SQL WHERE CLAUSE for IS NOT NULL
308
-     * @param  string|array $field  the field name or array of field list
309
-     * @param  string $andOr the separator type used 'AND', 'OR', etc.
310
-     * @return object        the current DatabaseQueryBuilder instance
311
-     */
312
-    public function whereIsNotNull($field, $andOr = 'AND'){
313
-      if (is_array($field)){
314
-        foreach($field as $f){
315
-          $this->whereIsNotNull($f, $andOr);
316
-        }
317
-      } else {
318
-          $this->setWhereStr($field.' IS NOT NULL ', $andOr);
319
-      }
320
-      return $this;
321
-    }
225
+	  }
226
+	  if (empty($this->join)){
227
+		$this->join = ' ' . $type . 'JOIN' . ' ' . $table . ' ON ' . $on;
228
+	  }
229
+	  else{
230
+		$this->join = $this->join . ' ' . $type . 'JOIN' . ' ' . $table . ' ON ' . $on;
231
+	  }
232
+	  return $this;
233
+	}
234
+
235
+	/**
236
+	 * Set the SQL INNER JOIN statment
237
+	 * @see  DatabaseQueryBuilder::join()
238
+	 * @return object        the current DatabaseQueryBuilder instance
239
+	 */
240
+	public function innerJoin($table, $field1, $op = null, $field2 = ''){
241
+	  return $this->join($table, $field1, $op, $field2, 'INNER ');
242
+	}
243
+
244
+	/**
245
+	 * Set the SQL LEFT JOIN statment
246
+	 * @see  DatabaseQueryBuilder::join()
247
+	 * @return object        the current DatabaseQueryBuilder instance
248
+	 */
249
+	public function leftJoin($table, $field1, $op = null, $field2 = ''){
250
+	  return $this->join($table, $field1, $op, $field2, 'LEFT ');
251
+	}
252
+
253
+	/**
254
+	 * Set the SQL RIGHT JOIN statment
255
+	 * @see  DatabaseQueryBuilder::join()
256
+	 * @return object        the current DatabaseQueryBuilder instance
257
+	 */
258
+	public function rightJoin($table, $field1, $op = null, $field2 = ''){
259
+	  return $this->join($table, $field1, $op, $field2, 'RIGHT ');
260
+	}
261
+
262
+	/**
263
+	 * Set the SQL FULL OUTER JOIN statment
264
+	 * @see  DatabaseQueryBuilder::join()
265
+	 * @return object        the current DatabaseQueryBuilder instance
266
+	 */
267
+	public function fullOuterJoin($table, $field1, $op = null, $field2 = ''){
268
+		return $this->join($table, $field1, $op, $field2, 'FULL OUTER ');
269
+	}
270
+
271
+	/**
272
+	 * Set the SQL LEFT OUTER JOIN statment
273
+	 * @see  DatabaseQueryBuilder::join()
274
+	 * @return object        the current DatabaseQueryBuilder instance
275
+	 */
276
+	public function leftOuterJoin($table, $field1, $op = null, $field2 = ''){
277
+	  return $this->join($table, $field1, $op, $field2, 'LEFT OUTER ');
278
+	}
279
+
280
+	/**
281
+	 * Set the SQL RIGHT OUTER JOIN statment
282
+	 * @see  DatabaseQueryBuilder::join()
283
+	 * @return object        the current DatabaseQueryBuilder instance
284
+	 */
285
+	public function rightOuterJoin($table, $field1, $op = null, $field2 = ''){
286
+	  return $this->join($table, $field1, $op, $field2, 'RIGHT OUTER ');
287
+	}
288
+
289
+	/**
290
+	 * Set the SQL WHERE CLAUSE for IS NULL
291
+	 * @param  string|array $field  the field name or array of field list
292
+	 * @param  string $andOr the separator type used 'AND', 'OR', etc.
293
+	 * @return object        the current DatabaseQueryBuilder instance
294
+	 */
295
+	public function whereIsNull($field, $andOr = 'AND'){
296
+	  if (is_array($field)){
297
+		foreach($field as $f){
298
+			$this->whereIsNull($f, $andOr);
299
+		}
300
+	  } else {
301
+		  $this->setWhereStr($field.' IS NULL ', $andOr);
302
+	  }
303
+	  return $this;
304
+	}
305
+
306
+	/**
307
+	 * Set the SQL WHERE CLAUSE for IS NOT NULL
308
+	 * @param  string|array $field  the field name or array of field list
309
+	 * @param  string $andOr the separator type used 'AND', 'OR', etc.
310
+	 * @return object        the current DatabaseQueryBuilder instance
311
+	 */
312
+	public function whereIsNotNull($field, $andOr = 'AND'){
313
+	  if (is_array($field)){
314
+		foreach($field as $f){
315
+		  $this->whereIsNotNull($f, $andOr);
316
+		}
317
+	  } else {
318
+		  $this->setWhereStr($field.' IS NOT NULL ', $andOr);
319
+	  }
320
+	  return $this;
321
+	}
322 322
     
323
-    /**
324
-     * Set the SQL WHERE CLAUSE statment
325
-     * @param  string|array  $where the where field or array of field list
326
-     * @param  array|string  $op     the condition operator. If is null the default will be "="
327
-     * @param  mixed  $val    the where value
328
-     * @param  string  $type   the type used for this where clause (NOT, etc.)
329
-     * @param  string  $andOr the separator type used 'AND', 'OR', etc.
330
-     * @param  boolean $escape whether to escape or not the $val
331
-     * @return object        the current DatabaseQueryBuilder instance
332
-     */
333
-    public function where($where, $op = null, $val = null, $type = '', $andOr = 'AND', $escape = true){
334
-      $whereStr = '';
335
-      if (is_array($where)){
336
-        $whereStr = $this->getWhereStrIfIsArray($where, $type, $andOr, $escape);
337
-      }
338
-      else{
339
-        if (is_array($op)){
340
-          $whereStr = $this->getWhereStrIfOperatorIsArray($where, $op, $type, $escape);
341
-        } else {
342
-          $whereStr = $this->getWhereStrForOperator($where, $op, $val, $type, $escape = true);
343
-        }
344
-      }
345
-      $this->setWhereStr($whereStr, $andOr);
346
-      return $this;
347
-    }
348
-
349
-    /**
350
-     * Set the SQL WHERE CLAUSE statment using OR
351
-     * @see  DatabaseQueryBuilder::where()
352
-     * @return object        the current DatabaseQueryBuilder instance
353
-     */
354
-    public function orWhere($where, $op = null, $val = null, $escape = true){
355
-      return $this->where($where, $op, $val, '', 'OR', $escape);
356
-    }
357
-
358
-
359
-    /**
360
-     * Set the SQL WHERE CLAUSE statment using AND and NOT
361
-     * @see  DatabaseQueryBuilder::where()
362
-     * @return object        the current DatabaseQueryBuilder instance
363
-     */
364
-    public function notWhere($where, $op = null, $val = null, $escape = true){
365
-      return $this->where($where, $op, $val, 'NOT ', 'AND', $escape);
366
-    }
367
-
368
-    /**
369
-     * Set the SQL WHERE CLAUSE statment using OR and NOT
370
-     * @see  DatabaseQueryBuilder::where()
371
-     * @return object        the current DatabaseQueryBuilder instance
372
-     */
373
-    public function orNotWhere($where, $op = null, $val = null, $escape = true){
374
-    	return $this->where($where, $op, $val, 'NOT ', 'OR', $escape);
375
-    }
376
-
377
-    /**
378
-     * Set the opened parenthesis for the complex SQL query
379
-     * @param  string $type   the type of this grouped (NOT, etc.)
380
-     * @param  string $andOr the multiple conditions separator (AND, OR, etc.)
381
-     * @return object        the current DatabaseQueryBuilder instance
382
-     */
383
-    public function groupStart($type = '', $andOr = ' AND'){
384
-      if (empty($this->where)){
385
-        $this->where = $type . ' (';
386
-      } else {
387
-          if (substr(trim($this->where), -1) == '('){
388
-            $this->where .= $type . ' (';
389
-          } else {
390
-          	$this->where .= $andOr . ' ' . $type . ' (';
391
-          }
392
-      }
393
-      return $this;
394
-    }
395
-
396
-    /**
397
-     * Set the opened parenthesis for the complex SQL query using NOT type
398
-     * @see  DatabaseQueryBuilder::groupStart()
399
-     * @return object        the current DatabaseQueryBuilder instance
400
-     */
401
-    public function notGroupStart(){
402
-      return $this->groupStart('NOT');
403
-    }
404
-
405
-    /**
406
-     * Set the opened parenthesis for the complex SQL query using OR for separator
407
-     * @see  DatabaseQueryBuilder::groupStart()
408
-     * @return object        the current DatabaseQueryBuilder instance
409
-     */
410
-    public function orGroupStart(){
411
-      return $this->groupStart('', ' OR');
412
-    }
413
-
414
-     /**
415
-     * Set the opened parenthesis for the complex SQL query using OR for separator and NOT for type
416
-     * @see  DatabaseQueryBuilder::groupStart()
417
-     * @return object        the current DatabaseQueryBuilder instance
418
-     */
419
-    public function orNotGroupStart(){
420
-      return $this->groupStart('NOT', ' OR');
421
-    }
422
-
423
-    /**
424
-     * Close the parenthesis for the grouped SQL
425
-     * @return object        the current DatabaseQueryBuilder instance
426
-     */
427
-    public function groupEnd(){
428
-      $this->where .= ')';
429
-      return $this;
430
-    }
431
-
432
-    /**
433
-     * Set the SQL WHERE CLAUSE statment for IN
434
-     * @param  string  $field  the field name for IN statment
435
-     * @param  array   $keys   the list of values used
436
-     * @param  string  $type   the condition separator type (NOT)
437
-     * @param  string  $andOr the multiple conditions separator (OR, AND)
438
-     * @param  boolean $escape whether to escape or not the values
439
-     * @return object        the current DatabaseQueryBuilder instance
440
-     */
441
-    public function in($field, array $keys, $type = '', $andOr = 'AND', $escape = true){
442
-      $_keys = array();
443
-      foreach ($keys as $k => $v){
444
-        if (is_null($v)){
445
-          $v = '';
446
-        }
447
-        $_keys[] = (is_numeric($v) ? $v : $this->escape($v, $escape));
448
-      }
449
-      $keys = implode(', ', $_keys);
450
-      $whereStr = $field . ' ' . $type . ' IN (' . $keys . ')';
451
-      $this->setWhereStr($whereStr, $andOr);
452
-      return $this;
453
-    }
454
-
455
-    /**
456
-     * Set the SQL WHERE CLAUSE statment for NOT IN with AND separator
457
-     * @see  DatabaseQueryBuilder::in()
458
-     * @return object        the current DatabaseQueryBuilder instance
459
-     */
460
-    public function notIn($field, array $keys, $escape = true){
461
-      return $this->in($field, $keys, 'NOT ', 'AND', $escape);
462
-    }
463
-
464
-    /**
465
-     * Set the SQL WHERE CLAUSE statment for IN with OR separator
466
-     * @see  DatabaseQueryBuilder::in()
467
-     * @return object        the current DatabaseQueryBuilder instance
468
-     */
469
-    public function orIn($field, array $keys, $escape = true){
470
-      return $this->in($field, $keys, '', 'OR', $escape);
471
-    }
472
-
473
-    /**
474
-     * Set the SQL WHERE CLAUSE statment for NOT IN with OR separator
475
-     * @see  DatabaseQueryBuilder::in()
476
-     * @return object        the current DatabaseQueryBuilder instance
477
-     */
478
-    public function orNotIn($field, array $keys, $escape = true){
479
-      return $this->in($field, $keys, 'NOT ', 'OR', $escape);
480
-    }
481
-
482
-    /**
483
-     * Set the SQL WHERE CLAUSE statment for BETWEEN
484
-     * @param  string  $field  the field used for the BETWEEN statment
485
-     * @param  mixed  $value1 the BETWEEN begin value
486
-     * @param  mixed  $value2 the BETWEEN end value
487
-     * @param  string  $type   the condition separator type (NOT)
488
-     * @param  string  $andOr the multiple conditions separator (OR, AND)
489
-     * @param  boolean $escape whether to escape or not the values
490
-     * @return object        the current DatabaseQueryBuilder instance
491
-     */
492
-    public function between($field, $value1, $value2, $type = '', $andOr = 'AND', $escape = true){
493
-      if (is_null($value1)){
494
-        $value1 = '';
495
-      }
496
-      if (is_null($value2)){
497
-        $value2 = '';
498
-      }
499
-      $whereStr = $field . ' ' . $type . ' BETWEEN ' . $this->escape($value1, $escape) . ' AND ' . $this->escape($value2, $escape);
500
-      $this->setWhereStr($whereStr, $andOr);
501
-      return $this;
502
-    }
503
-
504
-    /**
505
-     * Set the SQL WHERE CLAUSE statment for BETWEEN with NOT type and AND separator
506
-     * @see  DatabaseQueryBuilder::between()
507
-     * @return object        the current DatabaseQueryBuilder instance
508
-     */
509
-    public function notBetween($field, $value1, $value2, $escape = true){
510
-      return $this->between($field, $value1, $value2, 'NOT ', 'AND', $escape);
511
-    }
512
-
513
-    /**
514
-     * Set the SQL WHERE CLAUSE statment for BETWEEN with OR separator
515
-     * @see  DatabaseQueryBuilder::between()
516
-     * @return object        the current DatabaseQueryBuilder instance
517
-     */
518
-    public function orBetween($field, $value1, $value2, $escape = true){
519
-      return $this->between($field, $value1, $value2, '', 'OR', $escape);
520
-    }
521
-
522
-    /**
523
-     * Set the SQL WHERE CLAUSE statment for BETWEEN with NOT type and OR separator
524
-     * @see  DatabaseQueryBuilder::between()
525
-     * @return object        the current DatabaseQueryBuilder instance
526
-     */
527
-    public function orNotBetween($field, $value1, $value2, $escape = true){
528
-      return $this->between($field, $value1, $value2, 'NOT ', 'OR', $escape);
529
-    }
530
-
531
-    /**
532
-     * Set the SQL WHERE CLAUSE statment for LIKE
533
-     * @param  string  $field  the field name used in LIKE statment
534
-     * @param  string  $data   the LIKE value for this field including the '%', and '_' part
535
-     * @param  string  $type   the condition separator type (NOT)
536
-     * @param  string  $andOr the multiple conditions separator (OR, AND)
537
-     * @param  boolean $escape whether to escape or not the values
538
-     * @return object        the current DatabaseQueryBuilder instance
539
-     */
540
-    public function like($field, $data, $type = '', $andOr = 'AND', $escape = true){
541
-      if (empty($data)){
542
-        $data = '';
543
-      }
544
-      $this->setWhereStr($field . ' ' . $type . ' LIKE ' . ($this->escape($data, $escape)), $andOr);
545
-      return $this;
546
-    }
547
-
548
-    /**
549
-     * Set the SQL WHERE CLAUSE statment for LIKE with OR separator
550
-     * @see  DatabaseQueryBuilder::like()
551
-     * @return object        the current DatabaseQueryBuilder instance
552
-     */
553
-    public function orLike($field, $data, $escape = true){
554
-      return $this->like($field, $data, '', 'OR', $escape);
555
-    }
556
-
557
-    /**
558
-     * Set the SQL WHERE CLAUSE statment for LIKE with NOT type and AND separator
559
-     * @see  DatabaseQueryBuilder::like()
560
-     * @return object        the current DatabaseQueryBuilder instance
561
-     */
562
-    public function notLike($field, $data, $escape = true){
563
-      return $this->like($field, $data, 'NOT ', 'AND', $escape);
564
-    }
565
-
566
-    /**
567
-     * Set the SQL WHERE CLAUSE statment for LIKE with NOT type and OR separator
568
-     * @see  DatabaseQueryBuilder::like()
569
-     * @return object        the current DatabaseQueryBuilder instance
570
-     */
571
-    public function orNotLike($field, $data, $escape = true){
572
-      return $this->like($field, $data, 'NOT ', 'OR', $escape);
573
-    }
574
-
575
-    /**
576
-     * Set the SQL LIMIT statment
577
-     * @param  int $limit    the limit offset. If $limitEnd is null this will be the limit count
578
-     * like LIMIT n;
579
-     * @param  int $limitEnd the limit count
580
-     * @return object        the current DatabaseQueryBuilder instance
581
-     */
582
-    public function limit($limit, $limitEnd = null){
583
-      if (empty($limit)){
584
-        $limit = 0;
585
-      }
586
-      if (! is_null($limitEnd)){
587
-        $this->limit = $limit . ', ' . $limitEnd;
588
-      }
589
-      else{
590
-        $this->limit = $limit;
591
-      }
592
-      return $this;
593
-    }
594
-
595
-    /**
596
-     * Set the SQL ORDER BY CLAUSE statment
597
-     * @param  string $orderBy   the field name used for order
598
-     * @param  string $orderDir the order direction (ASC or DESC)
599
-     * @return object        the current DatabaseQueryBuilder instance
600
-     */
601
-    public function orderBy($orderBy, $orderDir = ' ASC'){
602
-      if (stristr($orderBy, ' ') || $orderBy == 'rand()'){
603
-        $this->orderBy = empty($this->orderBy) ? $orderBy : $this->orderBy . ', ' . $orderBy;
604
-      }
605
-      else{
606
-        $this->orderBy = empty($this->orderBy) 
323
+	/**
324
+	 * Set the SQL WHERE CLAUSE statment
325
+	 * @param  string|array  $where the where field or array of field list
326
+	 * @param  array|string  $op     the condition operator. If is null the default will be "="
327
+	 * @param  mixed  $val    the where value
328
+	 * @param  string  $type   the type used for this where clause (NOT, etc.)
329
+	 * @param  string  $andOr the separator type used 'AND', 'OR', etc.
330
+	 * @param  boolean $escape whether to escape or not the $val
331
+	 * @return object        the current DatabaseQueryBuilder instance
332
+	 */
333
+	public function where($where, $op = null, $val = null, $type = '', $andOr = 'AND', $escape = true){
334
+	  $whereStr = '';
335
+	  if (is_array($where)){
336
+		$whereStr = $this->getWhereStrIfIsArray($where, $type, $andOr, $escape);
337
+	  }
338
+	  else{
339
+		if (is_array($op)){
340
+		  $whereStr = $this->getWhereStrIfOperatorIsArray($where, $op, $type, $escape);
341
+		} else {
342
+		  $whereStr = $this->getWhereStrForOperator($where, $op, $val, $type, $escape = true);
343
+		}
344
+	  }
345
+	  $this->setWhereStr($whereStr, $andOr);
346
+	  return $this;
347
+	}
348
+
349
+	/**
350
+	 * Set the SQL WHERE CLAUSE statment using OR
351
+	 * @see  DatabaseQueryBuilder::where()
352
+	 * @return object        the current DatabaseQueryBuilder instance
353
+	 */
354
+	public function orWhere($where, $op = null, $val = null, $escape = true){
355
+	  return $this->where($where, $op, $val, '', 'OR', $escape);
356
+	}
357
+
358
+
359
+	/**
360
+	 * Set the SQL WHERE CLAUSE statment using AND and NOT
361
+	 * @see  DatabaseQueryBuilder::where()
362
+	 * @return object        the current DatabaseQueryBuilder instance
363
+	 */
364
+	public function notWhere($where, $op = null, $val = null, $escape = true){
365
+	  return $this->where($where, $op, $val, 'NOT ', 'AND', $escape);
366
+	}
367
+
368
+	/**
369
+	 * Set the SQL WHERE CLAUSE statment using OR and NOT
370
+	 * @see  DatabaseQueryBuilder::where()
371
+	 * @return object        the current DatabaseQueryBuilder instance
372
+	 */
373
+	public function orNotWhere($where, $op = null, $val = null, $escape = true){
374
+		return $this->where($where, $op, $val, 'NOT ', 'OR', $escape);
375
+	}
376
+
377
+	/**
378
+	 * Set the opened parenthesis for the complex SQL query
379
+	 * @param  string $type   the type of this grouped (NOT, etc.)
380
+	 * @param  string $andOr the multiple conditions separator (AND, OR, etc.)
381
+	 * @return object        the current DatabaseQueryBuilder instance
382
+	 */
383
+	public function groupStart($type = '', $andOr = ' AND'){
384
+	  if (empty($this->where)){
385
+		$this->where = $type . ' (';
386
+	  } else {
387
+		  if (substr(trim($this->where), -1) == '('){
388
+			$this->where .= $type . ' (';
389
+		  } else {
390
+		  	$this->where .= $andOr . ' ' . $type . ' (';
391
+		  }
392
+	  }
393
+	  return $this;
394
+	}
395
+
396
+	/**
397
+	 * Set the opened parenthesis for the complex SQL query using NOT type
398
+	 * @see  DatabaseQueryBuilder::groupStart()
399
+	 * @return object        the current DatabaseQueryBuilder instance
400
+	 */
401
+	public function notGroupStart(){
402
+	  return $this->groupStart('NOT');
403
+	}
404
+
405
+	/**
406
+	 * Set the opened parenthesis for the complex SQL query using OR for separator
407
+	 * @see  DatabaseQueryBuilder::groupStart()
408
+	 * @return object        the current DatabaseQueryBuilder instance
409
+	 */
410
+	public function orGroupStart(){
411
+	  return $this->groupStart('', ' OR');
412
+	}
413
+
414
+	 /**
415
+	  * Set the opened parenthesis for the complex SQL query using OR for separator and NOT for type
416
+	  * @see  DatabaseQueryBuilder::groupStart()
417
+	  * @return object        the current DatabaseQueryBuilder instance
418
+	  */
419
+	public function orNotGroupStart(){
420
+	  return $this->groupStart('NOT', ' OR');
421
+	}
422
+
423
+	/**
424
+	 * Close the parenthesis for the grouped SQL
425
+	 * @return object        the current DatabaseQueryBuilder instance
426
+	 */
427
+	public function groupEnd(){
428
+	  $this->where .= ')';
429
+	  return $this;
430
+	}
431
+
432
+	/**
433
+	 * Set the SQL WHERE CLAUSE statment for IN
434
+	 * @param  string  $field  the field name for IN statment
435
+	 * @param  array   $keys   the list of values used
436
+	 * @param  string  $type   the condition separator type (NOT)
437
+	 * @param  string  $andOr the multiple conditions separator (OR, AND)
438
+	 * @param  boolean $escape whether to escape or not the values
439
+	 * @return object        the current DatabaseQueryBuilder instance
440
+	 */
441
+	public function in($field, array $keys, $type = '', $andOr = 'AND', $escape = true){
442
+	  $_keys = array();
443
+	  foreach ($keys as $k => $v){
444
+		if (is_null($v)){
445
+		  $v = '';
446
+		}
447
+		$_keys[] = (is_numeric($v) ? $v : $this->escape($v, $escape));
448
+	  }
449
+	  $keys = implode(', ', $_keys);
450
+	  $whereStr = $field . ' ' . $type . ' IN (' . $keys . ')';
451
+	  $this->setWhereStr($whereStr, $andOr);
452
+	  return $this;
453
+	}
454
+
455
+	/**
456
+	 * Set the SQL WHERE CLAUSE statment for NOT IN with AND separator
457
+	 * @see  DatabaseQueryBuilder::in()
458
+	 * @return object        the current DatabaseQueryBuilder instance
459
+	 */
460
+	public function notIn($field, array $keys, $escape = true){
461
+	  return $this->in($field, $keys, 'NOT ', 'AND', $escape);
462
+	}
463
+
464
+	/**
465
+	 * Set the SQL WHERE CLAUSE statment for IN with OR separator
466
+	 * @see  DatabaseQueryBuilder::in()
467
+	 * @return object        the current DatabaseQueryBuilder instance
468
+	 */
469
+	public function orIn($field, array $keys, $escape = true){
470
+	  return $this->in($field, $keys, '', 'OR', $escape);
471
+	}
472
+
473
+	/**
474
+	 * Set the SQL WHERE CLAUSE statment for NOT IN with OR separator
475
+	 * @see  DatabaseQueryBuilder::in()
476
+	 * @return object        the current DatabaseQueryBuilder instance
477
+	 */
478
+	public function orNotIn($field, array $keys, $escape = true){
479
+	  return $this->in($field, $keys, 'NOT ', 'OR', $escape);
480
+	}
481
+
482
+	/**
483
+	 * Set the SQL WHERE CLAUSE statment for BETWEEN
484
+	 * @param  string  $field  the field used for the BETWEEN statment
485
+	 * @param  mixed  $value1 the BETWEEN begin value
486
+	 * @param  mixed  $value2 the BETWEEN end value
487
+	 * @param  string  $type   the condition separator type (NOT)
488
+	 * @param  string  $andOr the multiple conditions separator (OR, AND)
489
+	 * @param  boolean $escape whether to escape or not the values
490
+	 * @return object        the current DatabaseQueryBuilder instance
491
+	 */
492
+	public function between($field, $value1, $value2, $type = '', $andOr = 'AND', $escape = true){
493
+	  if (is_null($value1)){
494
+		$value1 = '';
495
+	  }
496
+	  if (is_null($value2)){
497
+		$value2 = '';
498
+	  }
499
+	  $whereStr = $field . ' ' . $type . ' BETWEEN ' . $this->escape($value1, $escape) . ' AND ' . $this->escape($value2, $escape);
500
+	  $this->setWhereStr($whereStr, $andOr);
501
+	  return $this;
502
+	}
503
+
504
+	/**
505
+	 * Set the SQL WHERE CLAUSE statment for BETWEEN with NOT type and AND separator
506
+	 * @see  DatabaseQueryBuilder::between()
507
+	 * @return object        the current DatabaseQueryBuilder instance
508
+	 */
509
+	public function notBetween($field, $value1, $value2, $escape = true){
510
+	  return $this->between($field, $value1, $value2, 'NOT ', 'AND', $escape);
511
+	}
512
+
513
+	/**
514
+	 * Set the SQL WHERE CLAUSE statment for BETWEEN with OR separator
515
+	 * @see  DatabaseQueryBuilder::between()
516
+	 * @return object        the current DatabaseQueryBuilder instance
517
+	 */
518
+	public function orBetween($field, $value1, $value2, $escape = true){
519
+	  return $this->between($field, $value1, $value2, '', 'OR', $escape);
520
+	}
521
+
522
+	/**
523
+	 * Set the SQL WHERE CLAUSE statment for BETWEEN with NOT type and OR separator
524
+	 * @see  DatabaseQueryBuilder::between()
525
+	 * @return object        the current DatabaseQueryBuilder instance
526
+	 */
527
+	public function orNotBetween($field, $value1, $value2, $escape = true){
528
+	  return $this->between($field, $value1, $value2, 'NOT ', 'OR', $escape);
529
+	}
530
+
531
+	/**
532
+	 * Set the SQL WHERE CLAUSE statment for LIKE
533
+	 * @param  string  $field  the field name used in LIKE statment
534
+	 * @param  string  $data   the LIKE value for this field including the '%', and '_' part
535
+	 * @param  string  $type   the condition separator type (NOT)
536
+	 * @param  string  $andOr the multiple conditions separator (OR, AND)
537
+	 * @param  boolean $escape whether to escape or not the values
538
+	 * @return object        the current DatabaseQueryBuilder instance
539
+	 */
540
+	public function like($field, $data, $type = '', $andOr = 'AND', $escape = true){
541
+	  if (empty($data)){
542
+		$data = '';
543
+	  }
544
+	  $this->setWhereStr($field . ' ' . $type . ' LIKE ' . ($this->escape($data, $escape)), $andOr);
545
+	  return $this;
546
+	}
547
+
548
+	/**
549
+	 * Set the SQL WHERE CLAUSE statment for LIKE with OR separator
550
+	 * @see  DatabaseQueryBuilder::like()
551
+	 * @return object        the current DatabaseQueryBuilder instance
552
+	 */
553
+	public function orLike($field, $data, $escape = true){
554
+	  return $this->like($field, $data, '', 'OR', $escape);
555
+	}
556
+
557
+	/**
558
+	 * Set the SQL WHERE CLAUSE statment for LIKE with NOT type and AND separator
559
+	 * @see  DatabaseQueryBuilder::like()
560
+	 * @return object        the current DatabaseQueryBuilder instance
561
+	 */
562
+	public function notLike($field, $data, $escape = true){
563
+	  return $this->like($field, $data, 'NOT ', 'AND', $escape);
564
+	}
565
+
566
+	/**
567
+	 * Set the SQL WHERE CLAUSE statment for LIKE with NOT type and OR separator
568
+	 * @see  DatabaseQueryBuilder::like()
569
+	 * @return object        the current DatabaseQueryBuilder instance
570
+	 */
571
+	public function orNotLike($field, $data, $escape = true){
572
+	  return $this->like($field, $data, 'NOT ', 'OR', $escape);
573
+	}
574
+
575
+	/**
576
+	 * Set the SQL LIMIT statment
577
+	 * @param  int $limit    the limit offset. If $limitEnd is null this will be the limit count
578
+	 * like LIMIT n;
579
+	 * @param  int $limitEnd the limit count
580
+	 * @return object        the current DatabaseQueryBuilder instance
581
+	 */
582
+	public function limit($limit, $limitEnd = null){
583
+	  if (empty($limit)){
584
+		$limit = 0;
585
+	  }
586
+	  if (! is_null($limitEnd)){
587
+		$this->limit = $limit . ', ' . $limitEnd;
588
+	  }
589
+	  else{
590
+		$this->limit = $limit;
591
+	  }
592
+	  return $this;
593
+	}
594
+
595
+	/**
596
+	 * Set the SQL ORDER BY CLAUSE statment
597
+	 * @param  string $orderBy   the field name used for order
598
+	 * @param  string $orderDir the order direction (ASC or DESC)
599
+	 * @return object        the current DatabaseQueryBuilder instance
600
+	 */
601
+	public function orderBy($orderBy, $orderDir = ' ASC'){
602
+	  if (stristr($orderBy, ' ') || $orderBy == 'rand()'){
603
+		$this->orderBy = empty($this->orderBy) ? $orderBy : $this->orderBy . ', ' . $orderBy;
604
+	  }
605
+	  else{
606
+		$this->orderBy = empty($this->orderBy) 
607 607
 						? ($orderBy . ' ' . strtoupper($orderDir)) 
608 608
 						: $this->orderBy . ', ' . $orderBy . ' ' . strtoupper($orderDir);
609
-      }
610
-      return $this;
611
-    }
612
-
613
-    /**
614
-     * Set the SQL GROUP BY CLAUSE statment
615
-     * @param  string|array $field the field name used or array of field list
616
-     * @return object        the current DatabaseQueryBuilder instance
617
-     */
618
-    public function groupBy($field){
619
-      if (is_array($field)){
620
-        $this->groupBy = implode(', ', $field);
621
-      }
622
-      else{
623
-        $this->groupBy = $field;
624
-      }
625
-      return $this;
626
-    }
627
-
628
-    /**
629
-     * Set the SQL HAVING CLAUSE statment
630
-     * @param  string  $field  the field name used for HAVING statment
631
-     * @param  string|array  $op     the operator used or array
632
-     * @param  mixed  $val    the value for HAVING comparaison
633
-     * @param  boolean $escape whether to escape or not the values
634
-     * @return object        the current DatabaseQueryBuilder instance
635
-     */
636
-    public function having($field, $op = null, $val = null, $escape = true){
637
-      if (is_array($op)){
638
-        $this->having = $this->getHavingStrIfOperatorIsArray($field, $op, $escape);
639
-      }
640
-      else if (! in_array($op, $this->operatorList)){
641
-        if (is_null($op)){
642
-          $op = '';
643
-        }
644
-        $this->having = $field . ' > ' . ($this->escape($op, $escape));
645
-      }
646
-      else{
647
-        if (is_null($val)){
648
-          $val = '';
649
-        }
650
-        $this->having = $field . ' ' . $op . ' ' . ($this->escape($val, $escape));
651
-      }
652
-      return $this;
653
-    }
654
-
655
-    /**
656
-     * Insert new record in the database
657
-     * @param  array   $data   the record data
658
-     * @param  boolean $escape  whether to escape or not the values
659
-     * @return object  the current DatabaseQueryBuilder instance        
660
-     */
661
-    public function insert($data = array(), $escape = true){
662
-      $columns = array_keys($data);
663
-      $column = implode(',', $columns);
664
-      $val = implode(', ', ($escape ? array_map(array($this, 'escape'), $data) : $data));
665
-
666
-      $this->query = 'INSERT INTO ' . $this->from . ' (' . $column . ') VALUES (' . $val . ')';
667
-      return $this;
668
-    }
669
-
670
-    /**
671
-     * Update record in the database
672
-     * @param  array   $data   the record data if is empty will use the $this->data array.
673
-     * @param  boolean $escape  whether to escape or not the values
674
-     * @return object  the current DatabaseQueryBuilder instance 
675
-     */
676
-    public function update($data = array(), $escape = true){
677
-      $query = 'UPDATE ' . $this->from . ' SET ';
678
-      $values = array();
679
-      foreach ($data as $column => $val){
680
-        $values[] = $column . ' = ' . ($this->escape($val, $escape));
681
-      }
682
-      $query .= implode(', ', $values);
683
-      if (! empty($this->where)){
684
-        $query .= ' WHERE ' . $this->where;
685
-      }
686
-
687
-      if (! empty($this->orderBy)){
688
-        $query .= ' ORDER BY ' . $this->orderBy;
689
-      }
690
-
691
-      if (! empty($this->limit)){
692
-        $query .= ' LIMIT ' . $this->limit;
693
-      }
694
-      $this->query = $query;
695
-      return $this;
696
-    }
697
-
698
-    /**
699
-     * Delete the record in database
700
-     * @return object  the current DatabaseQueryBuilder instance 
701
-     */
702
-    public function delete(){
703
-    	$query = 'DELETE FROM ' . $this->from;
704
-      $isTruncate = $query;
705
-    	if (! empty($this->where)){
609
+	  }
610
+	  return $this;
611
+	}
612
+
613
+	/**
614
+	 * Set the SQL GROUP BY CLAUSE statment
615
+	 * @param  string|array $field the field name used or array of field list
616
+	 * @return object        the current DatabaseQueryBuilder instance
617
+	 */
618
+	public function groupBy($field){
619
+	  if (is_array($field)){
620
+		$this->groupBy = implode(', ', $field);
621
+	  }
622
+	  else{
623
+		$this->groupBy = $field;
624
+	  }
625
+	  return $this;
626
+	}
627
+
628
+	/**
629
+	 * Set the SQL HAVING CLAUSE statment
630
+	 * @param  string  $field  the field name used for HAVING statment
631
+	 * @param  string|array  $op     the operator used or array
632
+	 * @param  mixed  $val    the value for HAVING comparaison
633
+	 * @param  boolean $escape whether to escape or not the values
634
+	 * @return object        the current DatabaseQueryBuilder instance
635
+	 */
636
+	public function having($field, $op = null, $val = null, $escape = true){
637
+	  if (is_array($op)){
638
+		$this->having = $this->getHavingStrIfOperatorIsArray($field, $op, $escape);
639
+	  }
640
+	  else if (! in_array($op, $this->operatorList)){
641
+		if (is_null($op)){
642
+		  $op = '';
643
+		}
644
+		$this->having = $field . ' > ' . ($this->escape($op, $escape));
645
+	  }
646
+	  else{
647
+		if (is_null($val)){
648
+		  $val = '';
649
+		}
650
+		$this->having = $field . ' ' . $op . ' ' . ($this->escape($val, $escape));
651
+	  }
652
+	  return $this;
653
+	}
654
+
655
+	/**
656
+	 * Insert new record in the database
657
+	 * @param  array   $data   the record data
658
+	 * @param  boolean $escape  whether to escape or not the values
659
+	 * @return object  the current DatabaseQueryBuilder instance        
660
+	 */
661
+	public function insert($data = array(), $escape = true){
662
+	  $columns = array_keys($data);
663
+	  $column = implode(',', $columns);
664
+	  $val = implode(', ', ($escape ? array_map(array($this, 'escape'), $data) : $data));
665
+
666
+	  $this->query = 'INSERT INTO ' . $this->from . ' (' . $column . ') VALUES (' . $val . ')';
667
+	  return $this;
668
+	}
669
+
670
+	/**
671
+	 * Update record in the database
672
+	 * @param  array   $data   the record data if is empty will use the $this->data array.
673
+	 * @param  boolean $escape  whether to escape or not the values
674
+	 * @return object  the current DatabaseQueryBuilder instance 
675
+	 */
676
+	public function update($data = array(), $escape = true){
677
+	  $query = 'UPDATE ' . $this->from . ' SET ';
678
+	  $values = array();
679
+	  foreach ($data as $column => $val){
680
+		$values[] = $column . ' = ' . ($this->escape($val, $escape));
681
+	  }
682
+	  $query .= implode(', ', $values);
683
+	  if (! empty($this->where)){
684
+		$query .= ' WHERE ' . $this->where;
685
+	  }
686
+
687
+	  if (! empty($this->orderBy)){
688
+		$query .= ' ORDER BY ' . $this->orderBy;
689
+	  }
690
+
691
+	  if (! empty($this->limit)){
692
+		$query .= ' LIMIT ' . $this->limit;
693
+	  }
694
+	  $this->query = $query;
695
+	  return $this;
696
+	}
697
+
698
+	/**
699
+	 * Delete the record in database
700
+	 * @return object  the current DatabaseQueryBuilder instance 
701
+	 */
702
+	public function delete(){
703
+		$query = 'DELETE FROM ' . $this->from;
704
+	  $isTruncate = $query;
705
+		if (! empty($this->where)){
706 706
   		  $query .= ' WHERE ' . $this->where;
707
-    	}
707
+		}
708 708
 
709
-    	if (! empty($this->orderBy)){
710
-    	  $query .= ' ORDER BY ' . $this->orderBy;
711
-      }
709
+		if (! empty($this->orderBy)){
710
+		  $query .= ' ORDER BY ' . $this->orderBy;
711
+	  }
712 712
 
713
-    	if (! empty($this->limit)){
714
-    		$query .= ' LIMIT ' . $this->limit;
715
-      }
713
+		if (! empty($this->limit)){
714
+			$query .= ' LIMIT ' . $this->limit;
715
+	  }
716 716
 
717 717
   		if ($isTruncate == $query && $this->driver != 'sqlite'){  
718
-      	$query = 'TRUNCATE TABLE ' . $this->from;
718
+	  	$query = 'TRUNCATE TABLE ' . $this->from;
719 719
   		}
720 720
 	   $this->query = $query;
721 721
 	   return $this;
722
-    }
723
-
724
-    /**
725
-     * Escape the data before execute query useful for security.
726
-     * @param  mixed $data the data to be escaped
727
-     * @param boolean $escaped whether we can do escape of not 
728
-     * @return mixed       the data after escaped or the same data if not
729
-     */
730
-    public function escape($data, $escaped = true){
731
-      return $escaped 
732
-                    ? $this->getPdo()->quote(trim($data)) 
733
-                    : $data; 
734
-    }
735
-
736
-
737
-    /**
738
-     * Return the current SQL query string
739
-     * @return string
740
-     */
741
-    public function getQuery(){
722
+	}
723
+
724
+	/**
725
+	 * Escape the data before execute query useful for security.
726
+	 * @param  mixed $data the data to be escaped
727
+	 * @param boolean $escaped whether we can do escape of not 
728
+	 * @return mixed       the data after escaped or the same data if not
729
+	 */
730
+	public function escape($data, $escaped = true){
731
+	  return $escaped 
732
+					? $this->getPdo()->quote(trim($data)) 
733
+					: $data; 
734
+	}
735
+
736
+
737
+	/**
738
+	 * Return the current SQL query string
739
+	 * @return string
740
+	 */
741
+	public function getQuery(){
742 742
   	  //INSERT, UPDATE, DELETE already set it, if is the SELECT we need set it now
743 743
   	  if(empty($this->query)){
744 744
   		  $query = 'SELECT ' . $this->select . ' FROM ' . $this->from;
745 745
   		  if (! empty($this->join)){
746
-          $query .= $this->join;
746
+		  $query .= $this->join;
747 747
   		  }
748 748
   		  
749 749
   		  if (! empty($this->where)){
750
-          $query .= ' WHERE ' . $this->where;
750
+		  $query .= ' WHERE ' . $this->where;
751 751
   		  }
752 752
 
753 753
   		  if (! empty($this->groupBy)){
754
-          $query .= ' GROUP BY ' . $this->groupBy;
754
+		  $query .= ' GROUP BY ' . $this->groupBy;
755 755
   		  }
756 756
 
757 757
   		  if (! empty($this->having)){
758
-          $query .= ' HAVING ' . $this->having;
758
+		  $query .= ' HAVING ' . $this->having;
759 759
   		  }
760 760
 
761 761
   		  if (! empty($this->orderBy)){
@@ -763,198 +763,198 @@  discard block
 block discarded – undo
763 763
   		  }
764 764
 
765 765
   		  if (! empty($this->limit)){
766
-          $query .= ' LIMIT ' . $this->limit;
766
+		  $query .= ' LIMIT ' . $this->limit;
767 767
   		  }
768 768
   		  $this->query = $query;
769 769
   	  }
770
-      return $this->query;
771
-    }
770
+	  return $this->query;
771
+	}
772 772
 
773 773
 	
774 774
 	 /**
775
-     * Return the PDO instance
776
-     * @return PDO
777
-     */
778
-    public function getPdo(){
779
-      return $this->pdo;
780
-    }
781
-
782
-    /**
783
-     * Set the PDO instance
784
-     * @param PDO $pdo the pdo object
775
+	  * Return the PDO instance
776
+	  * @return PDO
777
+	  */
778
+	public function getPdo(){
779
+	  return $this->pdo;
780
+	}
781
+
782
+	/**
783
+	 * Set the PDO instance
784
+	 * @param PDO $pdo the pdo object
785 785
 	 * @return object DatabaseQueryBuilder
786
-     */
787
-    public function setPdo(PDO $pdo = null){
788
-      $this->pdo = $pdo;
789
-      return $this;
790
-    }
786
+	 */
787
+	public function setPdo(PDO $pdo = null){
788
+	  $this->pdo = $pdo;
789
+	  return $this;
790
+	}
791 791
 	
792 792
    /**
793
-   * Return the database table prefix
794
-   * @return string
795
-   */
796
-    public function getPrefix(){
797
-      return $this->prefix;
798
-    }
799
-
800
-    /**
801
-     * Set the database table prefix
802
-     * @param string $prefix the new prefix
803
-	   * @return object DatabaseQueryBuilder
804
-     */
805
-    public function setPrefix($prefix){
806
-      $this->prefix = $prefix;
807
-      return $this;
808
-    }
793
+    * Return the database table prefix
794
+    * @return string
795
+    */
796
+	public function getPrefix(){
797
+	  return $this->prefix;
798
+	}
799
+
800
+	/**
801
+	 * Set the database table prefix
802
+	 * @param string $prefix the new prefix
803
+	 * @return object DatabaseQueryBuilder
804
+	 */
805
+	public function setPrefix($prefix){
806
+	  $this->prefix = $prefix;
807
+	  return $this;
808
+	}
809 809
 	
810 810
 	   /**
811
-     * Return the database driver
812
-     * @return string
813
-     */
814
-    public function getDriver(){
815
-      return $this->driver;
816
-    }
817
-
818
-    /**
819
-     * Set the database driver
820
-     * @param string $driver the new driver
821
-	   * @return object DatabaseQueryBuilder
822
-     */
823
-    public function setDriver($driver){
824
-      $this->driver = $driver;
825
-      return $this;
826
-    }
811
+	    * Return the database driver
812
+	    * @return string
813
+	    */
814
+	public function getDriver(){
815
+	  return $this->driver;
816
+	}
817
+
818
+	/**
819
+	 * Set the database driver
820
+	 * @param string $driver the new driver
821
+	 * @return object DatabaseQueryBuilder
822
+	 */
823
+	public function setDriver($driver){
824
+	  $this->driver = $driver;
825
+	  return $this;
826
+	}
827 827
 	
828 828
 	   /**
829
-     * Reset the DatabaseQueryBuilder class attributs to the initial values before each query.
830
-	   * @return object  the current DatabaseQueryBuilder instance 
831
-     */
832
-    public function reset(){
833
-      $this->select   = '*';
834
-      $this->from     = null;
835
-      $this->where    = null;
836
-      $this->limit    = null;
837
-      $this->orderBy  = null;
838
-      $this->groupBy  = null;
839
-      $this->having   = null;
840
-      $this->join     = null;
841
-      $this->query    = null;
842
-      return $this;
843
-    }
829
+	    * Reset the DatabaseQueryBuilder class attributs to the initial values before each query.
830
+	    * @return object  the current DatabaseQueryBuilder instance 
831
+	    */
832
+	public function reset(){
833
+	  $this->select   = '*';
834
+	  $this->from     = null;
835
+	  $this->where    = null;
836
+	  $this->limit    = null;
837
+	  $this->orderBy  = null;
838
+	  $this->groupBy  = null;
839
+	  $this->having   = null;
840
+	  $this->join     = null;
841
+	  $this->query    = null;
842
+	  return $this;
843
+	}
844 844
 
845 845
 	   /**
846
-     * Get the SQL HAVING clause when operator argument is an array
847
-     * @see DatabaseQueryBuilder::having
848
-     *
849
-     * @return string
850
-     */
851
-    protected function getHavingStrIfOperatorIsArray($field, $op = null, $escape = true){
852
-        $x = explode('?', $field);
853
-        $w = '';
854
-        foreach($x as $k => $v){
855
-  	      if (!empty($v)){
856
-            if (! isset($op[$k])){
857
-              $op[$k] = '';
858
-            }
859
-  	      	$w .= $v . (isset($op[$k]) ? $this->escape($op[$k], $escape) : '');
860
-  	      }
861
-      	}
862
-        return $w;
863
-    }
864
-
865
-
866
-    /**
867
-     * Get the SQL WHERE clause using array column => value
868
-     * @see DatabaseQueryBuilder::where
869
-     *
870
-     * @return string
871
-     */
872
-    protected function getWhereStrIfIsArray(array $where, $type = '', $andOr = 'AND', $escape = true){
873
-      $_where = array();
874
-      foreach ($where as $column => $data){
875
-        if (is_null($data)){
876
-          $data = '';
877
-        }
878
-        $_where[] = $type . $column . ' = ' . ($this->escape($data, $escape));
879
-      }
880
-      $where = implode(' '.$andOr.' ', $_where);
881
-      return $where;
882
-    }
883
-
884
-     /**
885
-     * Get the SQL WHERE clause when operator argument is an array
886
-     * @see DatabaseQueryBuilder::where
887
-     *
888
-     * @return string
889
-     */
890
-    protected function getWhereStrIfOperatorIsArray($where, array $op, $type = '', $escape = true){
891
-     $x = explode('?', $where);
892
-     $w = '';
893
-      foreach($x as $k => $v){
894
-        if (! empty($v)){
895
-            if (isset($op[$k]) && is_null($op[$k])){
896
-              $op[$k] = '';
897
-            }
898
-            $w .= $type . $v . (isset($op[$k]) ? ($this->escape($op[$k], $escape)) : '');
899
-        }
900
-      }
901
-      return $w;
902
-    }
903
-
904
-    /**
905
-     * Get the default SQL WHERE clause using operator = or the operator argument
906
-     * @see DatabaseQueryBuilder::where
907
-     *
908
-     * @return string
909
-     */
910
-    protected function getWhereStrForOperator($where, $op = null, $val = null, $type = '', $escape = true){
911
-       $w = '';
912
-       if (! in_array((string)$op, $this->operatorList)){
913
-          if (is_null($op)){
914
-            $op = '';
915
-          }
916
-          $w = $type . $where . ' = ' . ($this->escape($op, $escape));
917
-        } else {
918
-          if (is_null($val)){
919
-            $val = '';
920
-          }
921
-          $w = $type . $where . $op . ($this->escape($val, $escape));
922
-        }
923
-        return $w;
924
-      }
925
-
926
-      /**
927
-       * Set the $this->where property 
928
-       * @param string $whereStr the WHERE clause string
929
-       * @param  string  $andOr the separator type used 'AND', 'OR', etc.
930
-       */
931
-      protected function setWhereStr($whereStr, $andOr = 'AND'){
932
-        if (empty($this->where)){
933
-          $this->where = $whereStr;
934
-        } else {
935
-          if (substr(trim($this->where), -1) == '('){
936
-            $this->where = $this->where . ' ' . $whereStr;
937
-          } else {
938
-            $this->where = $this->where . ' '.$andOr.' ' . $whereStr;
939
-          }
940
-        }
941
-      }
846
+	    * Get the SQL HAVING clause when operator argument is an array
847
+	    * @see DatabaseQueryBuilder::having
848
+	    *
849
+	    * @return string
850
+	    */
851
+	protected function getHavingStrIfOperatorIsArray($field, $op = null, $escape = true){
852
+		$x = explode('?', $field);
853
+		$w = '';
854
+		foreach($x as $k => $v){
855
+  		  if (!empty($v)){
856
+			if (! isset($op[$k])){
857
+			  $op[$k] = '';
858
+			}
859
+  		  	$w .= $v . (isset($op[$k]) ? $this->escape($op[$k], $escape) : '');
860
+  		  }
861
+	  	}
862
+		return $w;
863
+	}
864
+
865
+
866
+	/**
867
+	 * Get the SQL WHERE clause using array column => value
868
+	 * @see DatabaseQueryBuilder::where
869
+	 *
870
+	 * @return string
871
+	 */
872
+	protected function getWhereStrIfIsArray(array $where, $type = '', $andOr = 'AND', $escape = true){
873
+	  $_where = array();
874
+	  foreach ($where as $column => $data){
875
+		if (is_null($data)){
876
+		  $data = '';
877
+		}
878
+		$_where[] = $type . $column . ' = ' . ($this->escape($data, $escape));
879
+	  }
880
+	  $where = implode(' '.$andOr.' ', $_where);
881
+	  return $where;
882
+	}
883
+
884
+	 /**
885
+	  * Get the SQL WHERE clause when operator argument is an array
886
+	  * @see DatabaseQueryBuilder::where
887
+	  *
888
+	  * @return string
889
+	  */
890
+	protected function getWhereStrIfOperatorIsArray($where, array $op, $type = '', $escape = true){
891
+	 $x = explode('?', $where);
892
+	 $w = '';
893
+	  foreach($x as $k => $v){
894
+		if (! empty($v)){
895
+			if (isset($op[$k]) && is_null($op[$k])){
896
+			  $op[$k] = '';
897
+			}
898
+			$w .= $type . $v . (isset($op[$k]) ? ($this->escape($op[$k], $escape)) : '');
899
+		}
900
+	  }
901
+	  return $w;
902
+	}
903
+
904
+	/**
905
+	 * Get the default SQL WHERE clause using operator = or the operator argument
906
+	 * @see DatabaseQueryBuilder::where
907
+	 *
908
+	 * @return string
909
+	 */
910
+	protected function getWhereStrForOperator($where, $op = null, $val = null, $type = '', $escape = true){
911
+	   $w = '';
912
+	   if (! in_array((string)$op, $this->operatorList)){
913
+		  if (is_null($op)){
914
+			$op = '';
915
+		  }
916
+		  $w = $type . $where . ' = ' . ($this->escape($op, $escape));
917
+		} else {
918
+		  if (is_null($val)){
919
+			$val = '';
920
+		  }
921
+		  $w = $type . $where . $op . ($this->escape($val, $escape));
922
+		}
923
+		return $w;
924
+	  }
925
+
926
+	  /**
927
+	   * Set the $this->where property 
928
+	   * @param string $whereStr the WHERE clause string
929
+	   * @param  string  $andOr the separator type used 'AND', 'OR', etc.
930
+	   */
931
+	  protected function setWhereStr($whereStr, $andOr = 'AND'){
932
+		if (empty($this->where)){
933
+		  $this->where = $whereStr;
934
+		} else {
935
+		  if (substr(trim($this->where), -1) == '('){
936
+			$this->where = $this->where . ' ' . $whereStr;
937
+		  } else {
938
+			$this->where = $this->where . ' '.$andOr.' ' . $whereStr;
939
+		  }
940
+		}
941
+	  }
942 942
 
943 943
 
944 944
 	 /**
945
-     * Set the SQL SELECT for function MIN, MAX, SUM, AVG, COUNT, AVG
946
-     * @param  string $clause the clause type like MIN, MAX, etc.
947
-     * @see  DatabaseQueryBuilder::min
948
-     * @see  DatabaseQueryBuilder::max
949
-     * @see  DatabaseQueryBuilder::sum
950
-     * @see  DatabaseQueryBuilder::count
951
-     * @see  DatabaseQueryBuilder::avg
952
-     * @return object
953
-     */
954
-    protected function select_min_max_sum_count_avg($clause, $field, $name = null){
955
-      $clause = strtoupper($clause);
956
-      $func = $clause . '(' . $field . ')' . (!is_null($name) ? ' AS ' . $name : '');
957
-      $this->select = ($this->select == '*' ? $func : $this->select . ', ' . $func);
958
-      return $this;
959
-    }
945
+	  * Set the SQL SELECT for function MIN, MAX, SUM, AVG, COUNT, AVG
946
+	  * @param  string $clause the clause type like MIN, MAX, etc.
947
+	  * @see  DatabaseQueryBuilder::min
948
+	  * @see  DatabaseQueryBuilder::max
949
+	  * @see  DatabaseQueryBuilder::sum
950
+	  * @see  DatabaseQueryBuilder::count
951
+	  * @see  DatabaseQueryBuilder::avg
952
+	  * @return object
953
+	  */
954
+	protected function select_min_max_sum_count_avg($clause, $field, $name = null){
955
+	  $clause = strtoupper($clause);
956
+	  $func = $clause . '(' . $field . ')' . (!is_null($name) ? ' AS ' . $name : '');
957
+	  $this->select = ($this->select == '*' ? $func : $this->select . ', ' . $func);
958
+	  return $this;
959
+	}
960 960
 }
Please login to merge, or discard this patch.
core/classes/model/Model.php 1 patch
Indentation   +920 added lines, -920 removed lines patch added patch discarded remove patch
@@ -1,561 +1,561 @@  discard block
 block discarded – undo
1 1
 <?php
2
-    defined('ROOT_PATH') || exit('Access denied');
3
-    /**
4
-     * TNH Framework
5
-     *
6
-     * A simple PHP framework using HMVC architecture
7
-     *
8
-     * This content is released under the GNU GPL License (GPL)
9
-     *
10
-     * Copyright (C) 2017 Tony NGUEREZA
11
-     *
12
-     * This program is free software; you can redistribute it and/or
13
-     * modify it under the terms of the GNU General Public License
14
-     * as published by the Free Software Foundation; either version 3
15
-     * of the License, or (at your option) any later version.
16
-     *
17
-     * This program is distributed in the hope that it will be useful,
18
-     * but WITHOUT ANY WARRANTY; without even the implied warranty of
19
-     * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
20
-     * GNU General Public License for more details.
21
-     *
22
-     * You should have received a copy of the GNU General Public License
23
-     * along with this program; if not, write to the Free Software
24
-     * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
25
-    */
26
-
27
-
28
-    /**
29
-     * A base model with a series of CRUD functions (powered by CI's query builder),
30
-     * validation-in-model support, event callbacks and more.
31
-     *
32
-     * @link http://github.com/jamierumbelow/codeigniter-base-model
33
-     * @copyright Copyright (c) 2012, Jamie Rumbelow <http://jamierumbelow.net>
34
-     */
35
-
36
-    class Model{
37
-
38
-        /* --------------------------------------------------------------
2
+	defined('ROOT_PATH') || exit('Access denied');
3
+	/**
4
+	 * TNH Framework
5
+	 *
6
+	 * A simple PHP framework using HMVC architecture
7
+	 *
8
+	 * This content is released under the GNU GPL License (GPL)
9
+	 *
10
+	 * Copyright (C) 2017 Tony NGUEREZA
11
+	 *
12
+	 * This program is free software; you can redistribute it and/or
13
+	 * modify it under the terms of the GNU General Public License
14
+	 * as published by the Free Software Foundation; either version 3
15
+	 * of the License, or (at your option) any later version.
16
+	 *
17
+	 * This program is distributed in the hope that it will be useful,
18
+	 * but WITHOUT ANY WARRANTY; without even the implied warranty of
19
+	 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
20
+	 * GNU General Public License for more details.
21
+	 *
22
+	 * You should have received a copy of the GNU General Public License
23
+	 * along with this program; if not, write to the Free Software
24
+	 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
25
+	 */
26
+
27
+
28
+	/**
29
+	 * A base model with a series of CRUD functions (powered by CI's query builder),
30
+	 * validation-in-model support, event callbacks and more.
31
+	 *
32
+	 * @link http://github.com/jamierumbelow/codeigniter-base-model
33
+	 * @copyright Copyright (c) 2012, Jamie Rumbelow <http://jamierumbelow.net>
34
+	 */
35
+
36
+	class Model{
37
+
38
+		/* --------------------------------------------------------------
39 39
          * VARIABLES
40 40
          * ------------------------------------------------------------ */
41 41
 
42
-        /**
43
-         * This model's default database table. Automatically
44
-         * guessed by pluralising the model name.
45
-         */
46
-        protected $_table;
47
-
48
-        /**
49
-         * The database connection object. Will be set to the default
50
-         * connection. This allows individual models to use different DBs
51
-         * without overwriting the global database connection.
52
-         */
53
-        protected $_database;
54
-
55
-        /**
56
-         * This model's default primary key or unique identifier.
57
-         * Used by the get(), update() and delete() functions.
58
-         */
59
-        protected $primary_key = 'id';
60
-
61
-        /**
62
-         * Support for soft deletes and this model's 'deleted' key
63
-         */
64
-        protected $soft_delete = false;
65
-        protected $soft_delete_key = 'is_deleted';
66
-        protected $_temporary_with_deleted = FALSE;
67
-        protected $_temporary_only_deleted = FALSE;
68
-
69
-        /**
70
-         * The various callbacks available to the model. Each are
71
-         * simple lists of method names (methods will be run on $this).
72
-         */
73
-        protected $before_create = array();
74
-        protected $after_create = array();
75
-        protected $before_update = array();
76
-        protected $after_update = array();
77
-        protected $before_get = array();
78
-        protected $after_get = array();
79
-        protected $before_delete = array();
80
-        protected $after_delete = array();
81
-
82
-        protected $callback_parameters = array();
83
-
84
-        /**
85
-         * Protected, non-modifiable attributes
86
-         */
87
-        protected $protected_attributes = array();
88
-
89
-        /**
90
-         * Relationship arrays. Use flat strings for defaults or string
91
-         * => array to customise the class name and primary key
92
-         */
93
-        protected $belongs_to = array();
94
-        protected $has_many = array();
95
-
96
-        protected $_with = array();
97
-
98
-        /**
99
-         * An array of validation rules. This needs to be the same format
100
-         * as validation rules passed to the FormValidation library.
101
-         */
102
-        protected $validate = array();
103
-
104
-        /**
105
-         * Optionally skip the validation. Used in conjunction with
106
-         * skip_validation() to skip data validation for any future calls.
107
-         */
108
-        protected $skip_validation = FALSE;
109
-
110
-        /**
111
-         * By default we return our results as objects. If we need to override
112
-         * this, we can, or, we could use the `as_array()` and `as_object()` scopes.
113
-         */
114
-        protected $return_type = 'object';
115
-
116
-        /**
117
-         * Set return type array or object
118
-         * @var string
119
-         */
120
-        protected $_temporary_return_type = NULL;
42
+		/**
43
+		 * This model's default database table. Automatically
44
+		 * guessed by pluralising the model name.
45
+		 */
46
+		protected $_table;
47
+
48
+		/**
49
+		 * The database connection object. Will be set to the default
50
+		 * connection. This allows individual models to use different DBs
51
+		 * without overwriting the global database connection.
52
+		 */
53
+		protected $_database;
54
+
55
+		/**
56
+		 * This model's default primary key or unique identifier.
57
+		 * Used by the get(), update() and delete() functions.
58
+		 */
59
+		protected $primary_key = 'id';
60
+
61
+		/**
62
+		 * Support for soft deletes and this model's 'deleted' key
63
+		 */
64
+		protected $soft_delete = false;
65
+		protected $soft_delete_key = 'is_deleted';
66
+		protected $_temporary_with_deleted = FALSE;
67
+		protected $_temporary_only_deleted = FALSE;
68
+
69
+		/**
70
+		 * The various callbacks available to the model. Each are
71
+		 * simple lists of method names (methods will be run on $this).
72
+		 */
73
+		protected $before_create = array();
74
+		protected $after_create = array();
75
+		protected $before_update = array();
76
+		protected $after_update = array();
77
+		protected $before_get = array();
78
+		protected $after_get = array();
79
+		protected $before_delete = array();
80
+		protected $after_delete = array();
81
+
82
+		protected $callback_parameters = array();
83
+
84
+		/**
85
+		 * Protected, non-modifiable attributes
86
+		 */
87
+		protected $protected_attributes = array();
88
+
89
+		/**
90
+		 * Relationship arrays. Use flat strings for defaults or string
91
+		 * => array to customise the class name and primary key
92
+		 */
93
+		protected $belongs_to = array();
94
+		protected $has_many = array();
95
+
96
+		protected $_with = array();
97
+
98
+		/**
99
+		 * An array of validation rules. This needs to be the same format
100
+		 * as validation rules passed to the FormValidation library.
101
+		 */
102
+		protected $validate = array();
103
+
104
+		/**
105
+		 * Optionally skip the validation. Used in conjunction with
106
+		 * skip_validation() to skip data validation for any future calls.
107
+		 */
108
+		protected $skip_validation = FALSE;
109
+
110
+		/**
111
+		 * By default we return our results as objects. If we need to override
112
+		 * this, we can, or, we could use the `as_array()` and `as_object()` scopes.
113
+		 */
114
+		protected $return_type = 'object';
115
+
116
+		/**
117
+		 * Set return type array or object
118
+		 * @var string
119
+		 */
120
+		protected $_temporary_return_type = NULL;
121 121
     	
122 122
     	
123
-    	/**
123
+		/**
124 124
     		The database cache time 
125
-    	*/
126
-    	protected $dbCacheTime = 0;
127
-
128
-        /**
129
-         * Instance of the Loader class
130
-         * @var Loader
131
-         */
132
-        protected $loaderInstance = null;
133
-
134
-        /**
135
-         * Instance of the FormValidation library
136
-         * @var FormValidation
137
-         */
138
-        protected $formValidationInstance = null;
125
+		 */
126
+		protected $dbCacheTime = 0;
127
+
128
+		/**
129
+		 * Instance of the Loader class
130
+		 * @var Loader
131
+		 */
132
+		protected $loaderInstance = null;
133
+
134
+		/**
135
+		 * Instance of the FormValidation library
136
+		 * @var FormValidation
137
+		 */
138
+		protected $formValidationInstance = null;
139 139
 		
140
-        /* --------------------------------------------------------------
140
+		/* --------------------------------------------------------------
141 141
          * GENERIC METHODS
142 142
          * ------------------------------------------------------------ */
143 143
 
144
-        /**
145
-         * Initialise the model, tie into the CodeIgniter superobject and
146
-         * try our best to guess the table name.
147
-         */
148
-        public function __construct(Database $db = null){
149
-            if (is_object($db)){
150
-                $this->setDatabaseInstance($db);
151
-            }
152
-            else{
153
-                $obj = & get_instance();
154
-        		if (isset($obj->database) && is_object($obj->database)){
155
-                    /**
156
-                    * NOTE: Need use "clone" because some Model need have the personal instance of the database library
157
-                    * to prevent duplication
158
-                    */
159
-        			$this->setDatabaseInstance(clone $obj->database);
160
-                }
161
-            }
162
-
163
-            array_unshift($this->before_create, 'protect_attributes');
164
-            array_unshift($this->before_update, 'protect_attributes');
165
-            $this->_temporary_return_type = $this->return_type;
166
-        }
167
-
168
-        /* --------------------------------------------------------------
144
+		/**
145
+		 * Initialise the model, tie into the CodeIgniter superobject and
146
+		 * try our best to guess the table name.
147
+		 */
148
+		public function __construct(Database $db = null){
149
+			if (is_object($db)){
150
+				$this->setDatabaseInstance($db);
151
+			}
152
+			else{
153
+				$obj = & get_instance();
154
+				if (isset($obj->database) && is_object($obj->database)){
155
+					/**
156
+					 * NOTE: Need use "clone" because some Model need have the personal instance of the database library
157
+					 * to prevent duplication
158
+					 */
159
+					$this->setDatabaseInstance(clone $obj->database);
160
+				}
161
+			}
162
+
163
+			array_unshift($this->before_create, 'protect_attributes');
164
+			array_unshift($this->before_update, 'protect_attributes');
165
+			$this->_temporary_return_type = $this->return_type;
166
+		}
167
+
168
+		/* --------------------------------------------------------------
169 169
          * CRUD INTERFACE
170 170
          * ------------------------------------------------------------ */
171 171
 
172
-        /**
173
-         * Fetch a single record based on the primary key. Returns an object.
174
-         */
175
-        public function get($primary_value)
176
-        {
177
-    		return $this->get_by($this->primary_key, $primary_value);
178
-        }
179
-
180
-        /**
181
-         * Fetch a single record based on an arbitrary WHERE call. Can be
182
-         * any valid value to DatabaseQueryBuilder->where().
183
-         */
184
-        public function get_by()
185
-        {
186
-            $where = func_get_args();
187
-
188
-            if ($this->soft_delete && $this->_temporary_with_deleted !== TRUE)
189
-            {
190
-                $this->getQueryBuilder()->where($this->soft_delete_key, (bool)$this->_temporary_only_deleted);
191
-            }
192
-    		$this->_set_where($where);
193
-
194
-            $this->trigger('before_get');
172
+		/**
173
+		 * Fetch a single record based on the primary key. Returns an object.
174
+		 */
175
+		public function get($primary_value)
176
+		{
177
+			return $this->get_by($this->primary_key, $primary_value);
178
+		}
179
+
180
+		/**
181
+		 * Fetch a single record based on an arbitrary WHERE call. Can be
182
+		 * any valid value to DatabaseQueryBuilder->where().
183
+		 */
184
+		public function get_by()
185
+		{
186
+			$where = func_get_args();
187
+
188
+			if ($this->soft_delete && $this->_temporary_with_deleted !== TRUE)
189
+			{
190
+				$this->getQueryBuilder()->where($this->soft_delete_key, (bool)$this->_temporary_only_deleted);
191
+			}
192
+			$this->_set_where($where);
193
+
194
+			$this->trigger('before_get');
195 195
 			$type = $this->_temporary_return_type == 'array' ? 'array' : false;
196
-            $this->getQueryBuilder()->from($this->_table);
196
+			$this->getQueryBuilder()->from($this->_table);
197 197
 			$row = $this->_database->get($type);
198
-            $this->_temporary_return_type = $this->return_type;
199
-            $row = $this->trigger('after_get', $row);
200
-            $this->_with = array();
201
-            return $row;
202
-        }
203
-
204
-        /**
205
-         * Fetch an array of records based on an array of primary values.
206
-         */
207
-        public function get_many($values)
208
-        {
209
-            $this->getQueryBuilder()->in($this->primary_key, $values);
210
-            return $this->get_all();
211
-        }
212
-
213
-        /**
214
-         * Fetch an array of records based on an arbitrary WHERE call.
215
-         */
216
-        public function get_many_by()
217
-        {
218
-            $where = func_get_args();
219
-            $this->_set_where($where);
220
-            return $this->get_all();
221
-        }
222
-
223
-        /**
224
-         * Fetch all the records in the table. Can be used as a generic call
225
-         * to $this->_database->get() with scoped methods.
226
-         */
227
-        public function get_all()
228
-        {
229
-            $this->trigger('before_get');
230
-            if ($this->soft_delete && $this->_temporary_with_deleted !== TRUE)
231
-            {
232
-                $this->getQueryBuilder()->where($this->soft_delete_key, (bool)$this->_temporary_only_deleted);
233
-            }
198
+			$this->_temporary_return_type = $this->return_type;
199
+			$row = $this->trigger('after_get', $row);
200
+			$this->_with = array();
201
+			return $row;
202
+		}
203
+
204
+		/**
205
+		 * Fetch an array of records based on an array of primary values.
206
+		 */
207
+		public function get_many($values)
208
+		{
209
+			$this->getQueryBuilder()->in($this->primary_key, $values);
210
+			return $this->get_all();
211
+		}
212
+
213
+		/**
214
+		 * Fetch an array of records based on an arbitrary WHERE call.
215
+		 */
216
+		public function get_many_by()
217
+		{
218
+			$where = func_get_args();
219
+			$this->_set_where($where);
220
+			return $this->get_all();
221
+		}
222
+
223
+		/**
224
+		 * Fetch all the records in the table. Can be used as a generic call
225
+		 * to $this->_database->get() with scoped methods.
226
+		 */
227
+		public function get_all()
228
+		{
229
+			$this->trigger('before_get');
230
+			if ($this->soft_delete && $this->_temporary_with_deleted !== TRUE)
231
+			{
232
+				$this->getQueryBuilder()->where($this->soft_delete_key, (bool)$this->_temporary_only_deleted);
233
+			}
234 234
 			$type = $this->_temporary_return_type == 'array' ? 'array':false;
235
-            $this->getQueryBuilder()->from($this->_table);
235
+			$this->getQueryBuilder()->from($this->_table);
236 236
 			$result = $this->_database->getAll($type);
237
-            $this->_temporary_return_type = $this->return_type;
238
-
239
-            foreach ($result as $key => &$row)
240
-            {
241
-                $row = $this->trigger('after_get', $row, ($key == count($result) - 1));
242
-            }
243
-            $this->_with = array();
244
-            return $result;
245
-        }
246
-
247
-        /**
248
-         * Insert a new row into the table. $data should be an associative array
249
-         * of data to be inserted. Returns newly created ID.
237
+			$this->_temporary_return_type = $this->return_type;
238
+
239
+			foreach ($result as $key => &$row)
240
+			{
241
+				$row = $this->trigger('after_get', $row, ($key == count($result) - 1));
242
+			}
243
+			$this->_with = array();
244
+			return $result;
245
+		}
246
+
247
+		/**
248
+		 * Insert a new row into the table. $data should be an associative array
249
+		 * of data to be inserted. Returns newly created ID.
250 250
 		 * @see Database::insert
251
-         */
252
-        public function insert($data = array(), $skip_validation = FALSE, $escape = true)
253
-        {
254
-            if ($skip_validation === FALSE)
255
-            {
256
-                $data = $this->validate($data);
257
-            }
258
-
259
-            if ($data !== FALSE)
260
-            {
261
-                $data = $this->trigger('before_create', $data);
262
-                $this->getQueryBuilder()->from($this->_table);
251
+		 */
252
+		public function insert($data = array(), $skip_validation = FALSE, $escape = true)
253
+		{
254
+			if ($skip_validation === FALSE)
255
+			{
256
+				$data = $this->validate($data);
257
+			}
258
+
259
+			if ($data !== FALSE)
260
+			{
261
+				$data = $this->trigger('before_create', $data);
262
+				$this->getQueryBuilder()->from($this->_table);
263 263
 				$this->_database->insert($data, $escape);
264
-                $insert_id = $this->_database->insertId();
265
-                $this->trigger('after_create', $insert_id);
264
+				$insert_id = $this->_database->insertId();
265
+				$this->trigger('after_create', $insert_id);
266 266
 				//if the table doesn't have the auto increment field or sequence, the value of 0 will be returned 
267 267
 				return ! $insert_id ? true : $insert_id;
268
-            }
269
-            else
270
-            {
271
-                return FALSE;
272
-            }
273
-        }
274
-
275
-        /**
276
-         * Insert multiple rows into the table. Returns an array of multiple IDs.
277
-         */
278
-        public function insert_many($data = array(), $skip_validation = FALSE, $escape = true)
279
-        {
280
-            $ids = array();
281
-            foreach ($data as $key => $row)
282
-            {
283
-                $ids[] = $this->insert($row, $skip_validation, $escape);
284
-            }
285
-            return $ids;
286
-        }
287
-
288
-        /**
289
-         * Updated a record based on the primary value.
290
-         */
291
-        public function update($primary_value, $data = array(), $skip_validation = FALSE, $escape = true)
292
-        {
293
-            $data = $this->trigger('before_update', $data);
294
-            if ($skip_validation === FALSE)
295
-            {
296
-                $data = $this->validate($data);
297
-            }
298
-
299
-            if ($data !== FALSE)
300
-            {
301
-                $this->getQueryBuilder()->where($this->primary_key, $primary_value)
302
-                                        ->from($this->_table);
303
-                $result = $this->_database->update($data, $escape);
304
-                $this->trigger('after_update', array($data, $result));
305
-                return $result;
306
-            }
307
-            else
308
-            {
309
-                return FALSE;
310
-            }
311
-        }
312
-
313
-        /**
314
-         * Update many records, based on an array of primary values.
315
-         */
316
-        public function update_many($primary_values, $data = array(), $skip_validation = FALSE, $escape = true)
317
-        {
318
-            $data = $this->trigger('before_update', $data);
319
-            if ($skip_validation === FALSE)
320
-            {
321
-                $data = $this->validate($data);
322
-            }
323
-            if ($data !== FALSE)
324
-            {
325
-                $this->getQueryBuilder()->in($this->primary_key, $primary_values)
326
-                                        ->from($this->_table);
268
+			}
269
+			else
270
+			{
271
+				return FALSE;
272
+			}
273
+		}
274
+
275
+		/**
276
+		 * Insert multiple rows into the table. Returns an array of multiple IDs.
277
+		 */
278
+		public function insert_many($data = array(), $skip_validation = FALSE, $escape = true)
279
+		{
280
+			$ids = array();
281
+			foreach ($data as $key => $row)
282
+			{
283
+				$ids[] = $this->insert($row, $skip_validation, $escape);
284
+			}
285
+			return $ids;
286
+		}
287
+
288
+		/**
289
+		 * Updated a record based on the primary value.
290
+		 */
291
+		public function update($primary_value, $data = array(), $skip_validation = FALSE, $escape = true)
292
+		{
293
+			$data = $this->trigger('before_update', $data);
294
+			if ($skip_validation === FALSE)
295
+			{
296
+				$data = $this->validate($data);
297
+			}
298
+
299
+			if ($data !== FALSE)
300
+			{
301
+				$this->getQueryBuilder()->where($this->primary_key, $primary_value)
302
+										->from($this->_table);
303
+				$result = $this->_database->update($data, $escape);
304
+				$this->trigger('after_update', array($data, $result));
305
+				return $result;
306
+			}
307
+			else
308
+			{
309
+				return FALSE;
310
+			}
311
+		}
312
+
313
+		/**
314
+		 * Update many records, based on an array of primary values.
315
+		 */
316
+		public function update_many($primary_values, $data = array(), $skip_validation = FALSE, $escape = true)
317
+		{
318
+			$data = $this->trigger('before_update', $data);
319
+			if ($skip_validation === FALSE)
320
+			{
321
+				$data = $this->validate($data);
322
+			}
323
+			if ($data !== FALSE)
324
+			{
325
+				$this->getQueryBuilder()->in($this->primary_key, $primary_values)
326
+										->from($this->_table);
327 327
 				$result = $this->_database->update($data, $escape);
328
-                $this->trigger('after_update', array($data, $result));
329
-                return $result;
330
-            }
331
-            else
332
-            {
333
-                return FALSE;
334
-            }
335
-        }
336
-
337
-        /**
338
-         * Updated a record based on an arbitrary WHERE clause.
339
-         */
340
-        public function update_by()
341
-        {
342
-            $args = func_get_args();
343
-            $data = array();
344
-            if (count($args) == 2){
345
-                if (is_array($args[1])){
346
-                    $data = array_pop($args);
347
-                }
348
-            }
349
-            else if (count($args) == 3){
350
-                if (is_array($args[2])){
351
-                    $data = array_pop($args);
352
-                }
353
-            }
354
-            $data = $this->trigger('before_update', $data);
355
-            if ($this->validate($data) !== FALSE)
356
-            {
357
-                $this->_set_where($args);
358
-                $this->getQueryBuilder()->from($this->_table);
328
+				$this->trigger('after_update', array($data, $result));
329
+				return $result;
330
+			}
331
+			else
332
+			{
333
+				return FALSE;
334
+			}
335
+		}
336
+
337
+		/**
338
+		 * Updated a record based on an arbitrary WHERE clause.
339
+		 */
340
+		public function update_by()
341
+		{
342
+			$args = func_get_args();
343
+			$data = array();
344
+			if (count($args) == 2){
345
+				if (is_array($args[1])){
346
+					$data = array_pop($args);
347
+				}
348
+			}
349
+			else if (count($args) == 3){
350
+				if (is_array($args[2])){
351
+					$data = array_pop($args);
352
+				}
353
+			}
354
+			$data = $this->trigger('before_update', $data);
355
+			if ($this->validate($data) !== FALSE)
356
+			{
357
+				$this->_set_where($args);
358
+				$this->getQueryBuilder()->from($this->_table);
359 359
 				$result = $this->_database->update($data);
360
-                $this->trigger('after_update', array($data, $result));
361
-                return $result;
362
-            }
363
-            else
364
-            {
365
-                return FALSE;
366
-            }
367
-        }
368
-
369
-        /**
370
-         * Update all records
371
-         */
372
-        public function update_all($data = array(), $escape = true)
373
-        {
374
-            $data = $this->trigger('before_update', $data);
375
-            $this->getQueryBuilder()->from($this->_table);
360
+				$this->trigger('after_update', array($data, $result));
361
+				return $result;
362
+			}
363
+			else
364
+			{
365
+				return FALSE;
366
+			}
367
+		}
368
+
369
+		/**
370
+		 * Update all records
371
+		 */
372
+		public function update_all($data = array(), $escape = true)
373
+		{
374
+			$data = $this->trigger('before_update', $data);
375
+			$this->getQueryBuilder()->from($this->_table);
376 376
 			$result = $this->_database->update($data, $escape);
377
-            $this->trigger('after_update', array($data, $result));
378
-            return $result;
379
-        }
380
-
381
-        /**
382
-         * Delete a row from the table by the primary value
383
-         */
384
-        public function delete($id)
385
-        {
386
-            $this->trigger('before_delete', $id);
387
-            $this->getQueryBuilder()->where($this->primary_key, $id);
377
+			$this->trigger('after_update', array($data, $result));
378
+			return $result;
379
+		}
380
+
381
+		/**
382
+		 * Delete a row from the table by the primary value
383
+		 */
384
+		public function delete($id)
385
+		{
386
+			$this->trigger('before_delete', $id);
387
+			$this->getQueryBuilder()->where($this->primary_key, $id);
388 388
 			$result = false;
389
-            if ($this->soft_delete)
390
-            {
391
-                $this->getQueryBuilder()->from($this->_table);	
389
+			if ($this->soft_delete)
390
+			{
391
+				$this->getQueryBuilder()->from($this->_table);	
392 392
 				$result = $this->_database->update(array( $this->soft_delete_key => TRUE ));
393
-            }
394
-            else
395
-            {
396
-                $this->getQueryBuilder()->from($this->_table); 
393
+			}
394
+			else
395
+			{
396
+				$this->getQueryBuilder()->from($this->_table); 
397 397
 				$result = $this->_database->delete();
398
-            }
399
-
400
-            $this->trigger('after_delete', $result);
401
-            return $result;
402
-        }
403
-
404
-        /**
405
-         * Delete a row from the database table by an arbitrary WHERE clause
406
-         */
407
-        public function delete_by()
408
-        {
409
-            $where = func_get_args();
410
-    	    $where = $this->trigger('before_delete', $where);
411
-            $this->_set_where($where);
398
+			}
399
+
400
+			$this->trigger('after_delete', $result);
401
+			return $result;
402
+		}
403
+
404
+		/**
405
+		 * Delete a row from the database table by an arbitrary WHERE clause
406
+		 */
407
+		public function delete_by()
408
+		{
409
+			$where = func_get_args();
410
+			$where = $this->trigger('before_delete', $where);
411
+			$this->_set_where($where);
412 412
 			$result = false;
413
-            if ($this->soft_delete)
414
-            {
415
-                $this->getQueryBuilder()->from($this->_table);	
413
+			if ($this->soft_delete)
414
+			{
415
+				$this->getQueryBuilder()->from($this->_table);	
416 416
 				$result = $this->_database->update(array( $this->soft_delete_key => TRUE ));
417
-            }
418
-            else
419
-            {
420
-                $this->getQueryBuilder()->from($this->_table); 
417
+			}
418
+			else
419
+			{
420
+				$this->getQueryBuilder()->from($this->_table); 
421 421
 				$result = $this->_database->delete();
422
-            }
423
-            $this->trigger('after_delete', $result);
424
-            return $result;
425
-        }
426
-
427
-        /**
428
-         * Delete many rows from the database table by multiple primary values
429
-         */
430
-        public function delete_many($primary_values)
431
-        {
432
-            $primary_values = $this->trigger('before_delete', $primary_values);
433
-            $this->getQueryBuilder()->in($this->primary_key, $primary_values);
422
+			}
423
+			$this->trigger('after_delete', $result);
424
+			return $result;
425
+		}
426
+
427
+		/**
428
+		 * Delete many rows from the database table by multiple primary values
429
+		 */
430
+		public function delete_many($primary_values)
431
+		{
432
+			$primary_values = $this->trigger('before_delete', $primary_values);
433
+			$this->getQueryBuilder()->in($this->primary_key, $primary_values);
434 434
 			$result = false;
435
-            if ($this->soft_delete)
436
-            {
437
-                $this->getQueryBuilder()->from($this->_table);	
435
+			if ($this->soft_delete)
436
+			{
437
+				$this->getQueryBuilder()->from($this->_table);	
438 438
 				$result = $this->_database->update(array( $this->soft_delete_key => TRUE ));
439
-            }
440
-            else
441
-            {
442
-                $this->getQueryBuilder()->from($this->_table); 
439
+			}
440
+			else
441
+			{
442
+				$this->getQueryBuilder()->from($this->_table); 
443 443
 				$result = $this->_database->delete();
444
-            }
445
-            $this->trigger('after_delete', $result);
446
-            return $result;
447
-        }
444
+			}
445
+			$this->trigger('after_delete', $result);
446
+			return $result;
447
+		}
448 448
 
449 449
 
450
-        /**
451
-         * Truncates the table
452
-         */
453
-        public function truncate()
454
-        {
450
+		/**
451
+		 * Truncates the table
452
+		 */
453
+		public function truncate()
454
+		{
455 455
 			$this->getQueryBuilder()->from($this->_table); 
456 456
 			$result = $this->_database->delete();
457
-            return $result;
458
-        }
457
+			return $result;
458
+		}
459 459
 
460
-        /* --------------------------------------------------------------
460
+		/* --------------------------------------------------------------
461 461
          * RELATIONSHIPS
462 462
          * ------------------------------------------------------------ */
463 463
 
464
-        public function with($relationship)
465
-        {
466
-            $this->_with[] = $relationship;
467
-            if (!in_array('relate', $this->after_get))
468
-            {
469
-                $this->after_get[] = 'relate';
470
-            }
471
-            return $this;
472
-        }
464
+		public function with($relationship)
465
+		{
466
+			$this->_with[] = $relationship;
467
+			if (!in_array('relate', $this->after_get))
468
+			{
469
+				$this->after_get[] = 'relate';
470
+			}
471
+			return $this;
472
+		}
473 473
 		
474 474
 		/**
475
-		* Relationship
476
-		*/
477
-        public function relate($row)
478
-        {
479
-    		if (empty($row))
480
-            {
481
-    		    return $row;
482
-            }
483
-
484
-            $row = $this->relateBelongsTo($row);
485
-            $row = $this->relateHasMany($row);
486
-            return $row;
487
-        }
488
-
489
-        /* --------------------------------------------------------------
475
+		 * Relationship
476
+		 */
477
+		public function relate($row)
478
+		{
479
+			if (empty($row))
480
+			{
481
+				return $row;
482
+			}
483
+
484
+			$row = $this->relateBelongsTo($row);
485
+			$row = $this->relateHasMany($row);
486
+			return $row;
487
+		}
488
+
489
+		/* --------------------------------------------------------------
490 490
          * UTILITY METHODS
491 491
          * ------------------------------------------------------------ */
492 492
 
493
-        /**
494
-         * Retrieve and generate a form_dropdown friendly array
495
-         */
496
-        public function dropdown()
497
-        {
498
-            $args = func_get_args();
499
-            if (count($args) == 2)
500
-            {
501
-                list($key, $value) = $args;
502
-            }
503
-            else
504
-            {
505
-                $key = $this->primary_key;
506
-                $value = $args[0];
507
-            }
508
-            $this->trigger('before_dropdown', array( $key, $value ));
509
-            if ($this->soft_delete && $this->_temporary_with_deleted !== TRUE)
510
-            {
511
-                $this->getQueryBuilder()->where($this->soft_delete_key, FALSE);
512
-            }
513
-            $this->getQueryBuilder()
493
+		/**
494
+		 * Retrieve and generate a form_dropdown friendly array
495
+		 */
496
+		public function dropdown()
497
+		{
498
+			$args = func_get_args();
499
+			if (count($args) == 2)
500
+			{
501
+				list($key, $value) = $args;
502
+			}
503
+			else
504
+			{
505
+				$key = $this->primary_key;
506
+				$value = $args[0];
507
+			}
508
+			$this->trigger('before_dropdown', array( $key, $value ));
509
+			if ($this->soft_delete && $this->_temporary_with_deleted !== TRUE)
510
+			{
511
+				$this->getQueryBuilder()->where($this->soft_delete_key, FALSE);
512
+			}
513
+			$this->getQueryBuilder()
514 514
 									 ->select(array($key, $value))
515 515
 									 ->from($this->_table);
516 516
 			$result = $this->_database->getAll();
517
-            $options = array();
518
-            foreach ($result as $row)
519
-            {
520
-                $options[$row->{$key}] = $row->{$value};
521
-            }
522
-            $options = $this->trigger('after_dropdown', $options);
523
-            return $options;
524
-        }
525
-
526
-        /**
527
-         * Fetch a count of rows based on an arbitrary WHERE call.
528
-         */
529
-        public function count_by()
530
-        {
531
-            if ($this->soft_delete && $this->_temporary_with_deleted !== TRUE)
532
-            {
533
-                $this->getQueryBuilder()->where($this->soft_delete_key, (bool)$this->_temporary_only_deleted);
534
-            }
535
-            $where = func_get_args();
536
-            $this->_set_where($where);
537
-            $this->getQueryBuilder()->from($this->_table);
517
+			$options = array();
518
+			foreach ($result as $row)
519
+			{
520
+				$options[$row->{$key}] = $row->{$value};
521
+			}
522
+			$options = $this->trigger('after_dropdown', $options);
523
+			return $options;
524
+		}
525
+
526
+		/**
527
+		 * Fetch a count of rows based on an arbitrary WHERE call.
528
+		 */
529
+		public function count_by()
530
+		{
531
+			if ($this->soft_delete && $this->_temporary_with_deleted !== TRUE)
532
+			{
533
+				$this->getQueryBuilder()->where($this->soft_delete_key, (bool)$this->_temporary_only_deleted);
534
+			}
535
+			$where = func_get_args();
536
+			$this->_set_where($where);
537
+			$this->getQueryBuilder()->from($this->_table);
538 538
 			$this->_database->getAll();
539
-            return $this->_database->numRows();
540
-        }
541
-
542
-        /**
543
-         * Fetch a total count of rows, disregarding any previous conditions
544
-         */
545
-        public function count_all()
546
-        {
547
-            if ($this->soft_delete && $this->_temporary_with_deleted !== TRUE)
548
-            {
549
-                $this->getQueryBuilder()->where($this->soft_delete_key, (bool)$this->_temporary_only_deleted);
550
-            }
539
+			return $this->_database->numRows();
540
+		}
541
+
542
+		/**
543
+		 * Fetch a total count of rows, disregarding any previous conditions
544
+		 */
545
+		public function count_all()
546
+		{
547
+			if ($this->soft_delete && $this->_temporary_with_deleted !== TRUE)
548
+			{
549
+				$this->getQueryBuilder()->where($this->soft_delete_key, (bool)$this->_temporary_only_deleted);
550
+			}
551 551
 			$this->getQueryBuilder()->from($this->_table);
552 552
 			$this->_database->getAll();
553
-            return $this->_database->numRows();
554
-        }
553
+			return $this->_database->numRows();
554
+		}
555 555
 		
556 556
 		/**
557
-		* Enabled cache temporary
558
-		*/
557
+		 * Enabled cache temporary
558
+		 */
559 559
 		public function cached($ttl = 0){
560 560
 		  if ($ttl > 0){
561 561
 			$this->_database = $this->_database->cached($ttl);
@@ -563,424 +563,424 @@  discard block
 block discarded – undo
563 563
 		  return $this;
564 564
 		}
565 565
 
566
-        /**
567
-         * Tell the class to skip the insert validation
568
-         */
569
-        public function skip_validation()
570
-        {
571
-            $this->skip_validation = TRUE;
572
-            return $this;
573
-        }
574
-
575
-        /**
576
-         * Get the skip validation status
577
-         */
578
-        public function get_skip_validation()
579
-        {
580
-            return $this->skip_validation;
581
-        }
582
-
583
-        /**
584
-         * Return the next auto increment of the table. Only tested on MySQL.
585
-         */
586
-        public function get_next_id()
587
-        {
566
+		/**
567
+		 * Tell the class to skip the insert validation
568
+		 */
569
+		public function skip_validation()
570
+		{
571
+			$this->skip_validation = TRUE;
572
+			return $this;
573
+		}
574
+
575
+		/**
576
+		 * Get the skip validation status
577
+		 */
578
+		public function get_skip_validation()
579
+		{
580
+			return $this->skip_validation;
581
+		}
582
+
583
+		/**
584
+		 * Return the next auto increment of the table. Only tested on MySQL.
585
+		 */
586
+		public function get_next_id()
587
+		{
588 588
 			$this->getQueryBuilder()->select('AUTO_INCREMENT')
589 589
 									->from('information_schema.TABLES')
590 590
 									->where('TABLE_NAME', $this->_table)
591 591
 									->where('TABLE_SCHEMA', $this->_database->getDatabaseName());
592
-            return (int) $this->_database->get()->AUTO_INCREMENT;
593
-        }
594
-
595
-        /**
596
-         * Getter for the table name
597
-         */
598
-        public function table()
599
-        {
600
-            return $this->_table;
601
-        }
602
-
603
-        /* --------------------------------------------------------------
592
+			return (int) $this->_database->get()->AUTO_INCREMENT;
593
+		}
594
+
595
+		/**
596
+		 * Getter for the table name
597
+		 */
598
+		public function table()
599
+		{
600
+			return $this->_table;
601
+		}
602
+
603
+		/* --------------------------------------------------------------
604 604
          * GLOBAL SCOPES
605 605
          * ------------------------------------------------------------ */
606 606
 
607
-        /**
608
-         * Return the next call as an array rather than an object
609
-         */
610
-        public function as_array()
611
-        {
612
-            $this->_temporary_return_type = 'array';
613
-            return $this;
614
-        }
615
-
616
-        /**
617
-         * Return the next call as an object rather than an array
618
-         */
619
-        public function as_object()
620
-        {
621
-            $this->_temporary_return_type = 'object';
622
-            return $this;
623
-        }
624
-
625
-        /**
626
-         * Don't care about soft deleted rows on the next call
627
-         */
628
-        public function with_deleted()
629
-        {
630
-            $this->_temporary_with_deleted = TRUE;
631
-            return $this;
632
-        }
633
-
634
-        /**
635
-         * Only get deleted rows on the next call
636
-         */
637
-        public function only_deleted()
638
-        {
639
-            $this->_temporary_only_deleted = TRUE;
640
-            return $this;
641
-        }
642
-
643
-        /* --------------------------------------------------------------
607
+		/**
608
+		 * Return the next call as an array rather than an object
609
+		 */
610
+		public function as_array()
611
+		{
612
+			$this->_temporary_return_type = 'array';
613
+			return $this;
614
+		}
615
+
616
+		/**
617
+		 * Return the next call as an object rather than an array
618
+		 */
619
+		public function as_object()
620
+		{
621
+			$this->_temporary_return_type = 'object';
622
+			return $this;
623
+		}
624
+
625
+		/**
626
+		 * Don't care about soft deleted rows on the next call
627
+		 */
628
+		public function with_deleted()
629
+		{
630
+			$this->_temporary_with_deleted = TRUE;
631
+			return $this;
632
+		}
633
+
634
+		/**
635
+		 * Only get deleted rows on the next call
636
+		 */
637
+		public function only_deleted()
638
+		{
639
+			$this->_temporary_only_deleted = TRUE;
640
+			return $this;
641
+		}
642
+
643
+		/* --------------------------------------------------------------
644 644
          * OBSERVERS
645 645
          * ------------------------------------------------------------ */
646 646
 
647
-        /**
648
-         * MySQL DATETIME created_at and updated_at
649
-         */
650
-        public function created_at($row)
651
-        {
652
-            if (is_object($row))
653
-            {
654
-                $row->created_at = date('Y-m-d H:i:s');
655
-            }
656
-            else
657
-            {
658
-                $row['created_at'] = date('Y-m-d H:i:s');
659
-            }
660
-            return $row;
661
-        }
662
-
663
-        public function updated_at($row)
664
-        {
665
-            if (is_object($row))
666
-            {
667
-                $row->updated_at = date('Y-m-d H:i:s');
668
-            }
669
-            else
670
-            {
671
-                $row['updated_at'] = date('Y-m-d H:i:s');
672
-            }
673
-            return $row;
674
-        }
675
-
676
-        /**
677
-         * Serialises data for you automatically, allowing you to pass
678
-         * through objects and let it handle the serialisation in the background
679
-         */
680
-        public function serialize($row)
681
-        {
682
-            foreach ($this->callback_parameters as $column)
683
-            {
684
-                $row[$column] = serialize($row[$column]);
685
-            }
686
-            return $row;
687
-        }
688
-
689
-        public function unserialize($row)
690
-        {
691
-            foreach ($this->callback_parameters as $column)
692
-            {
693
-                if (is_array($row))
694
-                {
695
-                    $row[$column] = unserialize($row[$column]);
696
-                }
697
-                else
698
-                {
699
-                    $row->$column = unserialize($row->$column);
700
-                }
701
-            }
702
-            return $row;
703
-        }
704
-
705
-        /**
706
-         * Protect attributes by removing them from $row array
707
-         */
708
-        public function protect_attributes($row)
709
-        {
710
-            foreach ($this->protected_attributes as $attr)
711
-            {
712
-                if (is_object($row))
713
-                {
647
+		/**
648
+		 * MySQL DATETIME created_at and updated_at
649
+		 */
650
+		public function created_at($row)
651
+		{
652
+			if (is_object($row))
653
+			{
654
+				$row->created_at = date('Y-m-d H:i:s');
655
+			}
656
+			else
657
+			{
658
+				$row['created_at'] = date('Y-m-d H:i:s');
659
+			}
660
+			return $row;
661
+		}
662
+
663
+		public function updated_at($row)
664
+		{
665
+			if (is_object($row))
666
+			{
667
+				$row->updated_at = date('Y-m-d H:i:s');
668
+			}
669
+			else
670
+			{
671
+				$row['updated_at'] = date('Y-m-d H:i:s');
672
+			}
673
+			return $row;
674
+		}
675
+
676
+		/**
677
+		 * Serialises data for you automatically, allowing you to pass
678
+		 * through objects and let it handle the serialisation in the background
679
+		 */
680
+		public function serialize($row)
681
+		{
682
+			foreach ($this->callback_parameters as $column)
683
+			{
684
+				$row[$column] = serialize($row[$column]);
685
+			}
686
+			return $row;
687
+		}
688
+
689
+		public function unserialize($row)
690
+		{
691
+			foreach ($this->callback_parameters as $column)
692
+			{
693
+				if (is_array($row))
694
+				{
695
+					$row[$column] = unserialize($row[$column]);
696
+				}
697
+				else
698
+				{
699
+					$row->$column = unserialize($row->$column);
700
+				}
701
+			}
702
+			return $row;
703
+		}
704
+
705
+		/**
706
+		 * Protect attributes by removing them from $row array
707
+		 */
708
+		public function protect_attributes($row)
709
+		{
710
+			foreach ($this->protected_attributes as $attr)
711
+			{
712
+				if (is_object($row))
713
+				{
714 714
 					if (isset($row->$attr)){
715 715
 						unset($row->$attr);
716 716
 					}
717
-                }
718
-                else
719
-                {
717
+				}
718
+				else
719
+				{
720 720
 					if (isset($row[$attr])){
721 721
 						unset($row[$attr]);
722 722
 					}
723
-                }
724
-            }
725
-            return $row;
726
-        }
723
+				}
724
+			}
725
+			return $row;
726
+		}
727 727
 		
728 728
 		 /**
729
-         * Return the database instance
730
-         * @return Database the database instance
731
-         */
732
-        public function getDatabaseInstance(){
733
-            return $this->_database;
734
-        }
735
-
736
-        /**
737
-         * set the Database instance for future use
738
-         * @param Database $db the database object
739
-         */
740
-         public function setDatabaseInstance($db){
741
-            $this->_database = $db;
742
-            if ($this->dbCacheTime > 0){
743
-                $this->_database->setCache($this->dbCacheTime);
744
-            }
745
-            return $this;
746
-        }
747
-
748
-        /**
749
-         * Return the loader instance
750
-         * @return Loader the loader instance
751
-         */
752
-        public function getLoader(){
753
-            return $this->loaderInstance;
754
-        }
755
-
756
-        /**
757
-         * Set the loader instance for future use
758
-         * @param Loader $loader the loader object
729
+		  * Return the database instance
730
+		  * @return Database the database instance
731
+		  */
732
+		public function getDatabaseInstance(){
733
+			return $this->_database;
734
+		}
735
+
736
+		/**
737
+		 * set the Database instance for future use
738
+		 * @param Database $db the database object
739
+		 */
740
+		 public function setDatabaseInstance($db){
741
+			$this->_database = $db;
742
+			if ($this->dbCacheTime > 0){
743
+				$this->_database->setCache($this->dbCacheTime);
744
+			}
745
+			return $this;
746
+		}
747
+
748
+		/**
749
+		 * Return the loader instance
750
+		 * @return Loader the loader instance
751
+		 */
752
+		public function getLoader(){
753
+			return $this->loaderInstance;
754
+		}
755
+
756
+		/**
757
+		 * Set the loader instance for future use
758
+		 * @param Loader $loader the loader object
759 759
 		 * @return object
760
-         */
761
-         public function setLoader($loader){
762
-            $this->loaderInstance = $loader;
763
-            return $this;
764
-        }
760
+		 */
761
+		 public function setLoader($loader){
762
+			$this->loaderInstance = $loader;
763
+			return $this;
764
+		}
765
+
766
+		/**
767
+		 * Return the queryBuilder instance this is the shortcut to database queryBuilder
768
+		 * @return object the DatabaseQueryBuilder instance
769
+		 */
770
+		public function getQueryBuilder(){
771
+			return $this->_database->getQueryBuilder();
772
+		}
765 773
 
766 774
 		/**
767
-         * Return the queryBuilder instance this is the shortcut to database queryBuilder
768
-         * @return object the DatabaseQueryBuilder instance
769
-         */
770
-        public function getQueryBuilder(){
771
-            return $this->_database->getQueryBuilder();
772
-        }
773
-
774
-        /**
775
-         * Set the DatabaseQueryBuilder instance for future use
776
-         * @param object $queryBuilder the DatabaseQueryBuilder object
775
+		 * Set the DatabaseQueryBuilder instance for future use
776
+		 * @param object $queryBuilder the DatabaseQueryBuilder object
777 777
 		 * @return object
778
-         */
779
-         public function setQueryBuilder($queryBuilder){
780
-            $this->_database->setQueryBuilder($queryBuilder);
781
-            return $this;
782
-        }
778
+		 */
779
+		 public function setQueryBuilder($queryBuilder){
780
+			$this->_database->setQueryBuilder($queryBuilder);
781
+			return $this;
782
+		}
783 783
 
784 784
 		
785
-        /**
786
-         * Return the FormValidation instance
787
-         * @return FormValidation the form validation instance
788
-         */
789
-        public function getFormValidation(){
790
-            return $this->formValidationInstance;
791
-        }
792
-
793
-        /**
794
-         * Set the form validation instance for future use
795
-         * @param FormValidation $fv the form validation object
785
+		/**
786
+		 * Return the FormValidation instance
787
+		 * @return FormValidation the form validation instance
788
+		 */
789
+		public function getFormValidation(){
790
+			return $this->formValidationInstance;
791
+		}
792
+
793
+		/**
794
+		 * Set the form validation instance for future use
795
+		 * @param FormValidation $fv the form validation object
796 796
 		 * @return object
797
-         */
798
-         public function setFormValidation($fv){
799
-            $this->formValidationInstance = $fv;
800
-            return $this;
801
-        }
797
+		 */
798
+		 public function setFormValidation($fv){
799
+			$this->formValidationInstance = $fv;
800
+			return $this;
801
+		}
802 802
 
803
-        /* --------------------------------------------------------------
803
+		/* --------------------------------------------------------------
804 804
          * QUERY BUILDER DIRECT ACCESS METHODS
805 805
          * ------------------------------------------------------------ */
806 806
 
807
-        /**
808
-         * A wrapper to $this->getQueryBuilder()->orderBy()
809
-         */
810
-        public function order_by($criteria, $order = 'ASC')
811
-        {
812
-            if ( is_array($criteria) )
813
-            {
814
-                foreach ($criteria as $key => $value)
815
-                {
816
-                    $this->getQueryBuilder()->orderBy($key, $value);
817
-                }
818
-            }
819
-            else
820
-            {
821
-                $this->getQueryBuilder()->orderBy($criteria, $order);
822
-            }
823
-            return $this;
824
-        }
825
-
826
-        /**
827
-         * A wrapper to $this->getQueryBuilder()->limit()
828
-         */
829
-        public function limit($offset = 0, $limit = 10)
830
-        {
831
-            $this->getQueryBuilder()->limit($offset, $limit);
832
-            return $this;
833
-        }
834
-
835
-        /* --------------------------------------------------------------
807
+		/**
808
+		 * A wrapper to $this->getQueryBuilder()->orderBy()
809
+		 */
810
+		public function order_by($criteria, $order = 'ASC')
811
+		{
812
+			if ( is_array($criteria) )
813
+			{
814
+				foreach ($criteria as $key => $value)
815
+				{
816
+					$this->getQueryBuilder()->orderBy($key, $value);
817
+				}
818
+			}
819
+			else
820
+			{
821
+				$this->getQueryBuilder()->orderBy($criteria, $order);
822
+			}
823
+			return $this;
824
+		}
825
+
826
+		/**
827
+		 * A wrapper to $this->getQueryBuilder()->limit()
828
+		 */
829
+		public function limit($offset = 0, $limit = 10)
830
+		{
831
+			$this->getQueryBuilder()->limit($offset, $limit);
832
+			return $this;
833
+		}
834
+
835
+		/* --------------------------------------------------------------
836 836
          * INTERNAL METHODS
837 837
          * ------------------------------------------------------------ */
838 838
 
839 839
 		/**
840
-		* relate for the relation "belongs_to"
841
-		* @return mixed
842
-		*/
840
+		 * relate for the relation "belongs_to"
841
+		 * @return mixed
842
+		 */
843 843
 		protected function relateBelongsTo($row){
844 844
 			foreach ($this->belongs_to as $key => $value)
845
-            {
846
-                if (is_string($value))
847
-                {
848
-                    $relationship = $value;
849
-                    $options = array( 'primary_key' => $value . '_id', 'model' => $value . '_model' );
850
-                }
851
-                else
852
-                {
853
-                    $relationship = $key;
854
-                    $options = $value;
855
-                }
856
-
857
-                if (in_array($relationship, $this->_with))
858
-                {
859
-                    if (is_object($this->loaderInstance)){
860
-                        $this->loaderInstance->model($options['model'], $relationship . '_model');
861
-                    }
862
-                    else{
863
-                        Loader::model($options['model'], $relationship . '_model');    
864
-                    }
865
-                    if (is_object($row))
866
-                    {
867
-                        $row->{$relationship} = $this->{$relationship . '_model'}->get($row->{$options['primary_key']});
868
-                    }
869
-                    else
870
-                    {
871
-                        $row[$relationship] = $this->{$relationship . '_model'}->get($row[$options['primary_key']]);
872
-                    }
873
-                }
874
-            }
845
+			{
846
+				if (is_string($value))
847
+				{
848
+					$relationship = $value;
849
+					$options = array( 'primary_key' => $value . '_id', 'model' => $value . '_model' );
850
+				}
851
+				else
852
+				{
853
+					$relationship = $key;
854
+					$options = $value;
855
+				}
856
+
857
+				if (in_array($relationship, $this->_with))
858
+				{
859
+					if (is_object($this->loaderInstance)){
860
+						$this->loaderInstance->model($options['model'], $relationship . '_model');
861
+					}
862
+					else{
863
+						Loader::model($options['model'], $relationship . '_model');    
864
+					}
865
+					if (is_object($row))
866
+					{
867
+						$row->{$relationship} = $this->{$relationship . '_model'}->get($row->{$options['primary_key']});
868
+					}
869
+					else
870
+					{
871
+						$row[$relationship] = $this->{$relationship . '_model'}->get($row[$options['primary_key']]);
872
+					}
873
+				}
874
+			}
875 875
 			return $row;
876 876
 		}
877 877
 
878 878
 		/**
879
-		* relate for the relation "has_many"
880
-		* @return mixed
881
-		*/
879
+		 * relate for the relation "has_many"
880
+		 * @return mixed
881
+		 */
882 882
 		protected function relateHasMany($row){
883 883
 			foreach ($this->has_many as $key => $value)
884
-            {
885
-                if (is_string($value))
886
-                {
887
-                    $relationship = $value;
888
-                    $options = array( 'primary_key' => $this->_table . '_id', 'model' => $value . '_model' );
889
-                }
890
-                else
891
-                {
892
-                    $relationship = $key;
893
-                    $options = $value;
894
-                }
895
-
896
-                if (in_array($relationship, $this->_with))
897
-                {
898
-                    if (is_object($this->loaderInstance)){
899
-                        $this->loaderInstance->model($options['model'], $relationship . '_model');
900
-                    }
901
-                    else{
902
-                        Loader::model($options['model'], $relationship . '_model');    
903
-                    }
904
-                    if (is_object($row))
905
-                    {
906
-                        $row->{$relationship} = $this->{$relationship . '_model'}->get_many_by($options['primary_key'], $row->{$this->primary_key});
907
-                    }
908
-                    else
909
-                    {
910
-                        $row[$relationship] = $this->{$relationship . '_model'}->get_many_by($options['primary_key'], $row[$this->primary_key]);
911
-                    }
912
-                }
913
-            }
884
+			{
885
+				if (is_string($value))
886
+				{
887
+					$relationship = $value;
888
+					$options = array( 'primary_key' => $this->_table . '_id', 'model' => $value . '_model' );
889
+				}
890
+				else
891
+				{
892
+					$relationship = $key;
893
+					$options = $value;
894
+				}
895
+
896
+				if (in_array($relationship, $this->_with))
897
+				{
898
+					if (is_object($this->loaderInstance)){
899
+						$this->loaderInstance->model($options['model'], $relationship . '_model');
900
+					}
901
+					else{
902
+						Loader::model($options['model'], $relationship . '_model');    
903
+					}
904
+					if (is_object($row))
905
+					{
906
+						$row->{$relationship} = $this->{$relationship . '_model'}->get_many_by($options['primary_key'], $row->{$this->primary_key});
907
+					}
908
+					else
909
+					{
910
+						$row[$relationship] = $this->{$relationship . '_model'}->get_many_by($options['primary_key'], $row[$this->primary_key]);
911
+					}
912
+				}
913
+			}
914 914
 			return $row;
915 915
 		}
916 916
 		
917
-        /**
918
-         * Trigger an event and call its observers. Pass through the event name
919
-         * (which looks for an instance variable $this->event_name), an array of
920
-         * parameters to pass through and an optional 'last in interation' boolean
921
-         */
922
-        protected function trigger($event, $data = FALSE, $last = TRUE)
923
-        {
924
-            if (isset($this->$event) && is_array($this->$event))
925
-            {
926
-                foreach ($this->$event as $method)
927
-                {
928
-                    if (strpos($method, '('))
929
-                    {
930
-                        preg_match('/([a-zA-Z0-9\_\-]+)(\(([a-zA-Z0-9\_\-\., ]+)\))?/', $method, $matches);
931
-                        $method = $matches[1];
932
-                        $this->callback_parameters = explode(',', $matches[3]);
933
-                    }
934
-                    $data = call_user_func_array(array($this, $method), array($data, $last));
935
-                }
936
-            }
937
-            return $data;
938
-        }
939
-
940
-        /**
941
-         * Run validation on the passed data
942
-         */
943
-        protected function validate(array $data)
944
-        {
945
-            if ($this->skip_validation)
946
-            {
947
-                return $data;
948
-            }
949
-            if (!empty($this->validate))
950
-            {
951
-                $fv = null;
952
-                if (is_object($this->formValidationInstance)){
953
-                    $fv = $this->formValidationInstance;
954
-                }
955
-                else{
956
-                    Loader::library('FormValidation');
957
-                    $fv = $this->formvalidation;
958
-                    $this->setFormValidation($fv);
959
-                }
917
+		/**
918
+		 * Trigger an event and call its observers. Pass through the event name
919
+		 * (which looks for an instance variable $this->event_name), an array of
920
+		 * parameters to pass through and an optional 'last in interation' boolean
921
+		 */
922
+		protected function trigger($event, $data = FALSE, $last = TRUE)
923
+		{
924
+			if (isset($this->$event) && is_array($this->$event))
925
+			{
926
+				foreach ($this->$event as $method)
927
+				{
928
+					if (strpos($method, '('))
929
+					{
930
+						preg_match('/([a-zA-Z0-9\_\-]+)(\(([a-zA-Z0-9\_\-\., ]+)\))?/', $method, $matches);
931
+						$method = $matches[1];
932
+						$this->callback_parameters = explode(',', $matches[3]);
933
+					}
934
+					$data = call_user_func_array(array($this, $method), array($data, $last));
935
+				}
936
+			}
937
+			return $data;
938
+		}
939
+
940
+		/**
941
+		 * Run validation on the passed data
942
+		 */
943
+		protected function validate(array $data)
944
+		{
945
+			if ($this->skip_validation)
946
+			{
947
+				return $data;
948
+			}
949
+			if (!empty($this->validate))
950
+			{
951
+				$fv = null;
952
+				if (is_object($this->formValidationInstance)){
953
+					$fv = $this->formValidationInstance;
954
+				}
955
+				else{
956
+					Loader::library('FormValidation');
957
+					$fv = $this->formvalidation;
958
+					$this->setFormValidation($fv);
959
+				}
960 960
                
961
-                $fv->setData($data);
962
-                $fv->setRules($this->validate);
963
-
964
-                if ($fv->run())
965
-                {
966
-                    return $data;
967
-                }
968
-                else
969
-                {
970
-                    return FALSE;
971
-                }
972
-            }
973
-            else
974
-            {
975
-                return $data;
976
-            }
977
-        }
961
+				$fv->setData($data);
962
+				$fv->setRules($this->validate);
963
+
964
+				if ($fv->run())
965
+				{
966
+					return $data;
967
+				}
968
+				else
969
+				{
970
+					return FALSE;
971
+				}
972
+			}
973
+			else
974
+			{
975
+				return $data;
976
+			}
977
+		}
978 978
 		
979 979
 		
980 980
 		/**
981
-		* Set WHERE parameters, when is array
982
-		* @param array $params
983
-		*/
981
+		 * Set WHERE parameters, when is array
982
+		 * @param array $params
983
+		 */
984 984
 		protected function _set_where_array(array $params){
985 985
 			foreach ($params as $field => $filter)
986 986
 			{
@@ -1003,52 +1003,52 @@  discard block
 block discarded – undo
1003 1003
 		}
1004 1004
 
1005 1005
 
1006
-        /**
1007
-         * Set WHERE parameters, cleverly
1008
-         */
1009
-        protected function _set_where($params)
1010
-        {
1011
-            if (count($params) == 1 && is_array($params[0]))
1012
-            {
1013
-                $this->_set_where_array($params[0]);
1014
-            }
1015
-            else if (count($params) == 1)
1016
-            {
1017
-                $this->getQueryBuilder()->where($params[0]);
1018
-            }
1019
-        	else if (count($params) == 2)
1020
-    		{
1021
-                if (is_array($params[1]))
1022
-                {
1023
-                    $this->getQueryBuilder()->in($params[0], $params[1]);
1024
-                }
1025
-                else
1026
-                {
1027
-                    $this->getQueryBuilder()->where($params[0], $params[1]);
1028
-                }
1029
-    		}
1030
-    		else if (count($params) == 3)
1031
-    		{
1032
-    			$this->getQueryBuilder()->where($params[0], $params[1], $params[2]);
1033
-    		}
1034
-            else
1035
-            {
1036
-                if (is_array($params[1]))
1037
-                {
1038
-                    $this->getQueryBuilder()->in($params[0], $params[1]);
1039
-                }
1040
-                else
1041
-                {
1042
-                    $this->getQueryBuilder()->where($params[0], $params[1]);
1043
-                }
1044
-            }
1045
-        }
1046
-
1047
-        /**
1006
+		/**
1007
+		 * Set WHERE parameters, cleverly
1008
+		 */
1009
+		protected function _set_where($params)
1010
+		{
1011
+			if (count($params) == 1 && is_array($params[0]))
1012
+			{
1013
+				$this->_set_where_array($params[0]);
1014
+			}
1015
+			else if (count($params) == 1)
1016
+			{
1017
+				$this->getQueryBuilder()->where($params[0]);
1018
+			}
1019
+			else if (count($params) == 2)
1020
+			{
1021
+				if (is_array($params[1]))
1022
+				{
1023
+					$this->getQueryBuilder()->in($params[0], $params[1]);
1024
+				}
1025
+				else
1026
+				{
1027
+					$this->getQueryBuilder()->where($params[0], $params[1]);
1028
+				}
1029
+			}
1030
+			else if (count($params) == 3)
1031
+			{
1032
+				$this->getQueryBuilder()->where($params[0], $params[1], $params[2]);
1033
+			}
1034
+			else
1035
+			{
1036
+				if (is_array($params[1]))
1037
+				{
1038
+					$this->getQueryBuilder()->in($params[0], $params[1]);
1039
+				}
1040
+				else
1041
+				{
1042
+					$this->getQueryBuilder()->where($params[0], $params[1]);
1043
+				}
1044
+			}
1045
+		}
1046
+
1047
+		/**
1048 1048
             Shortcut to controller
1049
-        */
1050
-        public function __get($key){
1051
-            return get_instance()->{$key};
1052
-        }
1049
+		 */
1050
+		public function __get($key){
1051
+			return get_instance()->{$key};
1052
+		}
1053 1053
 
1054
-    }
1054
+	}
Please login to merge, or discard this patch.
core/classes/Router.php 1 patch
Indentation   +15 added lines, -15 removed lines patch added patch discarded remove patch
@@ -22,23 +22,23 @@  discard block
 block discarded – undo
22 22
 	 * You should have received a copy of the GNU General Public License
23 23
 	 * along with this program; if not, write to the Free Software
24 24
 	 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
25
-	*/
25
+	 */
26 26
 
27 27
 	class Router {
28 28
 		
29 29
 		/**
30
-		* @var array $pattern: The list of URIs to validate against
31
-		*/
30
+		 * @var array $pattern: The list of URIs to validate against
31
+		 */
32 32
 		private $pattern = array();
33 33
 
34 34
 		/**
35
-		* @var array $callback: The list of callback to call
36
-		*/
35
+		 * @var array $callback: The list of callback to call
36
+		 */
37 37
 		private $callback = array();
38 38
 
39 39
 		/**
40
-		* @var string $uriTrim: The char to remove from the URIs
41
-		*/
40
+		 * @var string $uriTrim: The char to remove from the URIs
41
+		 */
42 42
 		protected $uriTrim = '/\^$';
43 43
 
44 44
 		/**
@@ -94,9 +94,9 @@  discard block
 block discarded – undo
94 94
 		 */
95 95
 		public function __construct(){
96 96
 			$this->logger =& class_loader('Log', 'classes');
97
-	        $this->logger->setLogger('Library::Router');
98
-	        $routesPath = CONFIG_PATH . 'routes.php';
99
-	        $this->logger->debug('Loading of routes configuration file --> ' . $routesPath . ' ...');
97
+			$this->logger->setLogger('Library::Router');
98
+			$routesPath = CONFIG_PATH . 'routes.php';
99
+			$this->logger->debug('Loading of routes configuration file --> ' . $routesPath . ' ...');
100 100
 			if(file_exists($routesPath)){
101 101
 				$this->logger->info('Found routes configuration file --> ' . $routesPath. ' now load it');
102 102
 				$route = array();
@@ -145,11 +145,11 @@  discard block
 block discarded – undo
145 145
 		}
146 146
 
147 147
 		/**
148
-		* Add the URI and callback to the list of URIs to validate
149
-		*
150
-		* @param string $uri the request URI
151
-		* @param object $callback the callback function
152
-		*/
148
+		 * Add the URI and callback to the list of URIs to validate
149
+		 *
150
+		 * @param string $uri the request URI
151
+		 * @param object $callback the callback function
152
+		 */
153 153
 		public function add($uri, $callback) {
154 154
 			$uri = trim($uri, $this->uriTrim);
155 155
 			if(in_array($uri, $this->pattern)){
Please login to merge, or discard this patch.
core/classes/Database.php 1 patch
Indentation   +626 added lines, -626 removed lines patch added patch discarded remove patch
@@ -1,5 +1,5 @@  discard block
 block discarded – undo
1 1
 <?php
2
-    defined('ROOT_PATH') || exit('Access denied');
2
+	defined('ROOT_PATH') || exit('Access denied');
3 3
   /**
4 4
    * TNH Framework
5 5
    *
@@ -22,266 +22,266 @@  discard block
 block discarded – undo
22 22
    * You should have received a copy of the GNU General Public License
23 23
    * along with this program; if not, write to the Free Software
24 24
    * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
25
-  */
25
+   */
26 26
   class Database{
27 27
 	
28 28
 	/**
29 29
 	 * The PDO instance
30 30
 	 * @var object
31
-	*/
32
-    private $pdo                 = null;
31
+	 */
32
+	private $pdo                 = null;
33 33
     
34 34
 	/**
35 35
 	 * The database name used for the application
36 36
 	 * @var string
37
-	*/
37
+	 */
38 38
 	private $databaseName        = null;
39 39
 	
40 40
 	/**
41 41
 	 * The number of rows returned by the last query
42 42
 	 * @var int
43
-	*/
44
-    private $numRows             = 0;
43
+	 */
44
+	private $numRows             = 0;
45 45
 	
46 46
 	/**
47 47
 	 * The last insert id for the primary key column that have auto increment or sequence
48 48
 	 * @var mixed
49
-	*/
50
-    private $insertId            = null;
49
+	 */
50
+	private $insertId            = null;
51 51
 	
52 52
 	/**
53 53
 	 * The full SQL query statment after build for each command
54 54
 	 * @var string
55
-	*/
56
-    private $query               = null;
55
+	 */
56
+	private $query               = null;
57 57
 	
58 58
 	/**
59 59
 	 * The error returned for the last query
60 60
 	 * @var string
61
-	*/
62
-    private $error               = null;
61
+	 */
62
+	private $error               = null;
63 63
 	
64 64
 	/**
65 65
 	 * The result returned for the last query
66 66
 	 * @var mixed
67
-	*/
68
-    private $result              = array();
67
+	 */
68
+	private $result              = array();
69 69
 	
70 70
 	/**
71 71
 	 * The cache default time to live in second. 0 means no need to use the cache feature
72 72
 	 * @var int
73
-	*/
73
+	 */
74 74
 	private $cacheTtl              = 0;
75 75
 	
76 76
 	/**
77 77
 	 * The cache current time to live. 0 means no need to use the cache feature
78 78
 	 * @var int
79
-	*/
80
-    private $temporaryCacheTtl   = 0;
79
+	 */
80
+	private $temporaryCacheTtl   = 0;
81 81
 	
82 82
 	/**
83 83
 	 * The number of executed query for the current request
84 84
 	 * @var int
85
-	*/
86
-    private $queryCount          = 0;
85
+	 */
86
+	private $queryCount          = 0;
87 87
 	
88 88
 	/**
89 89
 	 * The default data to be used in the statments query INSERT, UPDATE
90 90
 	 * @var array
91
-	*/
92
-    private $data                = array();
91
+	 */
92
+	private $data                = array();
93 93
 	
94 94
 	/**
95 95
 	 * The database configuration
96 96
 	 * @var array
97
-	*/
98
-    private $config              = array();
97
+	 */
98
+	private $config              = array();
99 99
 	
100 100
 	/**
101 101
 	 * The logger instance
102 102
 	 * @var object
103 103
 	 */
104
-    private $logger              = null;
104
+	private $logger              = null;
105 105
 
106
-    /**
107
-    * The cache instance
108
-    * @var object
109
-    */
110
-    private $cacheInstance       = null;
106
+	/**
107
+	 * The cache instance
108
+	 * @var object
109
+	 */
110
+	private $cacheInstance       = null;
111 111
 
112
-    /**
113
-    * The benchmark instance
114
-    * @var object
115
-    */
116
-    private $benchmarkInstance   = null;
112
+	/**
113
+	 * The benchmark instance
114
+	 * @var object
115
+	 */
116
+	private $benchmarkInstance   = null;
117 117
 	
118 118
 	/**
119
-    * The DatabaseQueryBuilder instance
120
-    * @var object
121
-    */
122
-    private $queryBuilder        = null;
119
+	 * The DatabaseQueryBuilder instance
120
+	 * @var object
121
+	 */
122
+	private $queryBuilder        = null;
123 123
 
124 124
 
125
-    /**
126
-     * Construct new database
127
-     * @param array $overwriteConfig the config to overwrite with the config set in database.php
128
-     */
129
-    public function __construct($overwriteConfig = array()){
130
-        //Set Log instance to use
131
-        $this->setLoggerFromParamOrCreateNewInstance(null);
125
+	/**
126
+	 * Construct new database
127
+	 * @param array $overwriteConfig the config to overwrite with the config set in database.php
128
+	 */
129
+	public function __construct($overwriteConfig = array()){
130
+		//Set Log instance to use
131
+		$this->setLoggerFromParamOrCreateNewInstance(null);
132 132
 		
133
-		    //Set DatabaseQueryBuilder instance to use
134
-		    $this->setQueryBuilderFromParamOrCreateNewInstance(null);
133
+			//Set DatabaseQueryBuilder instance to use
134
+			$this->setQueryBuilderFromParamOrCreateNewInstance(null);
135 135
 
136
-        //Set database configuration
137
-        $this->setDatabaseConfiguration($overwriteConfig);
136
+		//Set database configuration
137
+		$this->setDatabaseConfiguration($overwriteConfig);
138 138
 	
139
-		    //cache time to live
140
-    	  $this->temporaryCacheTtl = $this->cacheTtl;
141
-    }
142
-
143
-    /**
144
-     * This is used to connect to database
145
-     * @return bool 
146
-     */
147
-    public function connect(){
148
-      $config = $this->getDatabaseConfiguration();
149
-      if (! empty($config)){
150
-        try{
151
-            $this->pdo = new PDO($this->getDsnFromDriver(), $config['username'], $config['password']);
152
-            $this->pdo->exec("SET NAMES '" . $config['charset'] . "' COLLATE '" . $config['collation'] . "'");
153
-            $this->pdo->exec("SET CHARACTER SET '" . $config['charset'] . "'");
154
-            $this->pdo->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_OBJ);
155
-            return true;
156
-          }
157
-          catch (PDOException $e){
158
-            $this->logger->fatal($e->getMessage());
159
-            show_error('Cannot connect to Database.');
160
-            return false;
161
-          }
162
-      }
163
-      else{
164
-        show_error('Database configuration is not set.');
165
-        return false;
166
-      }
167
-    }
168
-
169
-
170
-    /**
171
-     * Return the number of rows returned by the current query
172
-     * @return int
173
-     */
174
-    public function numRows(){
175
-      return $this->numRows;
176
-    }
177
-
178
-    /**
179
-     * Return the last insert id value
180
-     * @return mixed
181
-     */
182
-    public function insertId(){
183
-      return $this->insertId;
184
-    }
185
-
186
-    /**
187
-     * Show an error got from the current query (SQL command synthax error, database driver returned error, etc.)
188
-     */
189
-    public function error(){
139
+			//cache time to live
140
+		  $this->temporaryCacheTtl = $this->cacheTtl;
141
+	}
142
+
143
+	/**
144
+	 * This is used to connect to database
145
+	 * @return bool 
146
+	 */
147
+	public function connect(){
148
+	  $config = $this->getDatabaseConfiguration();
149
+	  if (! empty($config)){
150
+		try{
151
+			$this->pdo = new PDO($this->getDsnFromDriver(), $config['username'], $config['password']);
152
+			$this->pdo->exec("SET NAMES '" . $config['charset'] . "' COLLATE '" . $config['collation'] . "'");
153
+			$this->pdo->exec("SET CHARACTER SET '" . $config['charset'] . "'");
154
+			$this->pdo->setAttribute(PDO::ATTR_DEFAULT_FETCH_MODE, PDO::FETCH_OBJ);
155
+			return true;
156
+		  }
157
+		  catch (PDOException $e){
158
+			$this->logger->fatal($e->getMessage());
159
+			show_error('Cannot connect to Database.');
160
+			return false;
161
+		  }
162
+	  }
163
+	  else{
164
+		show_error('Database configuration is not set.');
165
+		return false;
166
+	  }
167
+	}
168
+
169
+
170
+	/**
171
+	 * Return the number of rows returned by the current query
172
+	 * @return int
173
+	 */
174
+	public function numRows(){
175
+	  return $this->numRows;
176
+	}
177
+
178
+	/**
179
+	 * Return the last insert id value
180
+	 * @return mixed
181
+	 */
182
+	public function insertId(){
183
+	  return $this->insertId;
184
+	}
185
+
186
+	/**
187
+	 * Show an error got from the current query (SQL command synthax error, database driver returned error, etc.)
188
+	 */
189
+	public function error(){
190 190
   		if ($this->error){
191 191
   			show_error('Query: "' . $this->query . '" Error: ' . $this->error, 'Database Error');
192 192
   		}
193
-    }
194
-
195
-    /**
196
-     * Get the result of one record rows returned by the current query
197
-     * @param  boolean $returnSQLQueryOrResultType if is boolean and true will return the SQL query string.
198
-     * If is string will determine the result type "array" or "object"
199
-     * @return mixed       the query SQL string or the record result
200
-     */
201
-    public function get($returnSQLQueryOrResultType = false){
202
-      $this->getQueryBuilder()->limit(1);
203
-      $query = $this->getAll(true);
204
-      if ($returnSQLQueryOrResultType === true){
205
-        return $query;
206
-      }
207
-      else{
208
-        return $this->query($query, false, $returnSQLQueryOrResultType == 'array');
209
-      }
210
-    }
211
-
212
-    /**
213
-     * Get the result of record rows list returned by the current query
214
-     * @param  boolean|string $returnSQLQueryOrResultType if is boolean and true will return the SQL query string.
215
-     * If is string will determine the result type "array" or "object"
216
-     * @return mixed       the query SQL string or the record result
217
-     */
218
-    public function getAll($returnSQLQueryOrResultType = false){
193
+	}
194
+
195
+	/**
196
+	 * Get the result of one record rows returned by the current query
197
+	 * @param  boolean $returnSQLQueryOrResultType if is boolean and true will return the SQL query string.
198
+	 * If is string will determine the result type "array" or "object"
199
+	 * @return mixed       the query SQL string or the record result
200
+	 */
201
+	public function get($returnSQLQueryOrResultType = false){
202
+	  $this->getQueryBuilder()->limit(1);
203
+	  $query = $this->getAll(true);
204
+	  if ($returnSQLQueryOrResultType === true){
205
+		return $query;
206
+	  }
207
+	  else{
208
+		return $this->query($query, false, $returnSQLQueryOrResultType == 'array');
209
+	  }
210
+	}
211
+
212
+	/**
213
+	 * Get the result of record rows list returned by the current query
214
+	 * @param  boolean|string $returnSQLQueryOrResultType if is boolean and true will return the SQL query string.
215
+	 * If is string will determine the result type "array" or "object"
216
+	 * @return mixed       the query SQL string or the record result
217
+	 */
218
+	public function getAll($returnSQLQueryOrResultType = false){
219 219
 	   $query = $this->getQueryBuilder()->getQuery();
220 220
 	   if ($returnSQLQueryOrResultType === true){
221
-      	return $query;
222
-      }
223
-      return $this->query($query, true, $returnSQLQueryOrResultType == 'array');
224
-    }
225
-
226
-    /**
227
-     * Insert new record in the database
228
-     * @param  array   $data   the record data if is empty will use the $this->data array.
229
-     * @param  boolean $escape  whether to escape or not the values
230
-     * @return mixed          the insert id of the new record or null
231
-     */
232
-    public function insert($data = array(), $escape = true){
233
-      if (empty($data) && $this->getData()){
234
-        //as when using $this->setData() may be the data already escaped
235
-        $escape = false;
236
-        $data = $this->getData();
237
-      }
238
-      $query = $this->getQueryBuilder()->insert($data, $escape)->getQuery();
239
-      $result = $this->query($query);
240
-      if ($result){
241
-        $this->insertId = $this->pdo->lastInsertId();
221
+	  	return $query;
222
+	  }
223
+	  return $this->query($query, true, $returnSQLQueryOrResultType == 'array');
224
+	}
225
+
226
+	/**
227
+	 * Insert new record in the database
228
+	 * @param  array   $data   the record data if is empty will use the $this->data array.
229
+	 * @param  boolean $escape  whether to escape or not the values
230
+	 * @return mixed          the insert id of the new record or null
231
+	 */
232
+	public function insert($data = array(), $escape = true){
233
+	  if (empty($data) && $this->getData()){
234
+		//as when using $this->setData() may be the data already escaped
235
+		$escape = false;
236
+		$data = $this->getData();
237
+	  }
238
+	  $query = $this->getQueryBuilder()->insert($data, $escape)->getQuery();
239
+	  $result = $this->query($query);
240
+	  if ($result){
241
+		$this->insertId = $this->pdo->lastInsertId();
242 242
 		//if the table doesn't have the auto increment field or sequence, the value of 0 will be returned 
243
-        return ! $this->insertId() ? true : $this->insertId();
244
-      }
245
-      return false;
246
-    }
247
-
248
-    /**
249
-     * Update record in the database
250
-     * @param  array   $data   the record data if is empty will use the $this->data array.
251
-     * @param  boolean $escape  whether to escape or not the values
252
-     * @return mixed          the update status
253
-     */
254
-    public function update($data = array(), $escape = true){
255
-      if (empty($data) && $this->getData()){
256
-        //as when using $this->setData() may be the data already escaped
257
-        $escape = false;
258
-        $data = $this->getData();
259
-      }
260
-      $query = $this->getQueryBuilder()->update($data, $escape)->getQuery();
261
-      return $this->query($query);
262
-    }
263
-
264
-    /**
265
-     * Delete the record in database
266
-     * @return mixed the delete status
267
-     */
268
-    public function delete(){
243
+		return ! $this->insertId() ? true : $this->insertId();
244
+	  }
245
+	  return false;
246
+	}
247
+
248
+	/**
249
+	 * Update record in the database
250
+	 * @param  array   $data   the record data if is empty will use the $this->data array.
251
+	 * @param  boolean $escape  whether to escape or not the values
252
+	 * @return mixed          the update status
253
+	 */
254
+	public function update($data = array(), $escape = true){
255
+	  if (empty($data) && $this->getData()){
256
+		//as when using $this->setData() may be the data already escaped
257
+		$escape = false;
258
+		$data = $this->getData();
259
+	  }
260
+	  $query = $this->getQueryBuilder()->update($data, $escape)->getQuery();
261
+	  return $this->query($query);
262
+	}
263
+
264
+	/**
265
+	 * Delete the record in database
266
+	 * @return mixed the delete status
267
+	 */
268
+	public function delete(){
269 269
 		$query = $this->getQueryBuilder()->delete()->getQuery();
270
-    	return $this->query($query);
271
-    }
272
-
273
-    /**
274
-     * Set database cache time to live
275
-     * @param integer $ttl the cache time to live in second
276
-     * @return object        the current Database instance
277
-     */
278
-    public function setCache($ttl = 0){
279
-      if ($ttl > 0){
280
-        $this->cacheTtl = $ttl;
281
-        $this->temporaryCacheTtl = $ttl;
282
-      }
283
-      return $this;
284
-    }
270
+		return $this->query($query);
271
+	}
272
+
273
+	/**
274
+	 * Set database cache time to live
275
+	 * @param integer $ttl the cache time to live in second
276
+	 * @return object        the current Database instance
277
+	 */
278
+	public function setCache($ttl = 0){
279
+	  if ($ttl > 0){
280
+		$this->cacheTtl = $ttl;
281
+		$this->temporaryCacheTtl = $ttl;
282
+	  }
283
+	  return $this;
284
+	}
285 285
 	
286 286
 	/**
287 287
 	 * Enabled cache temporary for the current query not globally	
@@ -289,272 +289,272 @@  discard block
 block discarded – undo
289 289
 	 * @return object        the current Database instance
290 290
 	 */
291 291
   	public function cached($ttl = 0){
292
-        if ($ttl > 0){
293
-          $this->temporaryCacheTtl = $ttl;
294
-        }
295
-        return $this;
296
-    }
297
-
298
-    /**
299
-     * Escape the data before execute query useful for security.
300
-     * @param  mixed $data the data to be escaped
301
-     * @param boolean $escaped whether we can do escape of not 
302
-     * @return mixed       the data after escaped or the same data if not
303
-     */
304
-    public function escape($data, $escaped = true){
305
-      return $escaped ? 
306
-                      $this->getPdo()->quote(trim($data)) 
307
-                      : $data; 
308
-    }
309
-
310
-    /**
311
-     * Return the number query executed count for the current request
312
-     * @return int
313
-     */
314
-    public function queryCount(){
315
-      return $this->queryCount;
316
-    }
317
-
318
-    /**
319
-     * Return the current query SQL string
320
-     * @return string
321
-     */
322
-    public function getQuery(){
323
-      return $this->query;
324
-    }
325
-
326
-    /**
327
-     * Return the application database name
328
-     * @return string
329
-     */
330
-    public function getDatabaseName(){
331
-      return $this->databaseName;
332
-    }
333
-
334
-    /**
335
-     * Return the PDO instance
336
-     * @return object
337
-     */
338
-    public function getPdo(){
339
-      return $this->pdo;
340
-    }
341
-
342
-    /**
343
-     * Set the PDO instance
344
-     * @param object $pdo the pdo object
292
+		if ($ttl > 0){
293
+		  $this->temporaryCacheTtl = $ttl;
294
+		}
295
+		return $this;
296
+	}
297
+
298
+	/**
299
+	 * Escape the data before execute query useful for security.
300
+	 * @param  mixed $data the data to be escaped
301
+	 * @param boolean $escaped whether we can do escape of not 
302
+	 * @return mixed       the data after escaped or the same data if not
303
+	 */
304
+	public function escape($data, $escaped = true){
305
+	  return $escaped ? 
306
+					  $this->getPdo()->quote(trim($data)) 
307
+					  : $data; 
308
+	}
309
+
310
+	/**
311
+	 * Return the number query executed count for the current request
312
+	 * @return int
313
+	 */
314
+	public function queryCount(){
315
+	  return $this->queryCount;
316
+	}
317
+
318
+	/**
319
+	 * Return the current query SQL string
320
+	 * @return string
321
+	 */
322
+	public function getQuery(){
323
+	  return $this->query;
324
+	}
325
+
326
+	/**
327
+	 * Return the application database name
328
+	 * @return string
329
+	 */
330
+	public function getDatabaseName(){
331
+	  return $this->databaseName;
332
+	}
333
+
334
+	/**
335
+	 * Return the PDO instance
336
+	 * @return object
337
+	 */
338
+	public function getPdo(){
339
+	  return $this->pdo;
340
+	}
341
+
342
+	/**
343
+	 * Set the PDO instance
344
+	 * @param object $pdo the pdo object
345 345
 	 * @return object Database
346
-     */
347
-    public function setPdo(PDO $pdo){
348
-      $this->pdo = $pdo;
349
-      return $this;
350
-    }
351
-
352
-
353
-    /**
354
-     * Return the Log instance
355
-     * @return Log
356
-     */
357
-    public function getLogger(){
358
-      return $this->logger;
359
-    }
360
-
361
-    /**
362
-     * Set the log instance
363
-     * @param Log $logger the log object
346
+	 */
347
+	public function setPdo(PDO $pdo){
348
+	  $this->pdo = $pdo;
349
+	  return $this;
350
+	}
351
+
352
+
353
+	/**
354
+	 * Return the Log instance
355
+	 * @return Log
356
+	 */
357
+	public function getLogger(){
358
+	  return $this->logger;
359
+	}
360
+
361
+	/**
362
+	 * Set the log instance
363
+	 * @param Log $logger the log object
364 364
 	 * @return object Database
365
-     */
366
-    public function setLogger($logger){
367
-      $this->logger = $logger;
368
-      return $this;
369
-    }
370
-
371
-     /**
372
-     * Return the cache instance
373
-     * @return CacheInterface
374
-     */
375
-    public function getCacheInstance(){
376
-      return $this->cacheInstance;
377
-    }
378
-
379
-    /**
380
-     * Set the cache instance
381
-     * @param CacheInterface $cache the cache object
365
+	 */
366
+	public function setLogger($logger){
367
+	  $this->logger = $logger;
368
+	  return $this;
369
+	}
370
+
371
+	 /**
372
+	  * Return the cache instance
373
+	  * @return CacheInterface
374
+	  */
375
+	public function getCacheInstance(){
376
+	  return $this->cacheInstance;
377
+	}
378
+
379
+	/**
380
+	 * Set the cache instance
381
+	 * @param CacheInterface $cache the cache object
382 382
 	 * @return object Database
383
-     */
384
-    public function setCacheInstance($cache){
385
-      $this->cacheInstance = $cache;
386
-      return $this;
387
-    }
388
-
389
-    /**
390
-     * Return the benchmark instance
391
-     * @return Benchmark
392
-     */
393
-    public function getBenchmark(){
394
-      return $this->benchmarkInstance;
395
-    }
396
-
397
-    /**
398
-     * Set the benchmark instance
399
-     * @param Benchmark $benchmark the benchmark object
383
+	 */
384
+	public function setCacheInstance($cache){
385
+	  $this->cacheInstance = $cache;
386
+	  return $this;
387
+	}
388
+
389
+	/**
390
+	 * Return the benchmark instance
391
+	 * @return Benchmark
392
+	 */
393
+	public function getBenchmark(){
394
+	  return $this->benchmarkInstance;
395
+	}
396
+
397
+	/**
398
+	 * Set the benchmark instance
399
+	 * @param Benchmark $benchmark the benchmark object
400 400
 	 * @return object Database
401
-     */
402
-    public function setBenchmark($benchmark){
403
-      $this->benchmarkInstance = $benchmark;
404
-      return $this;
405
-    }
401
+	 */
402
+	public function setBenchmark($benchmark){
403
+	  $this->benchmarkInstance = $benchmark;
404
+	  return $this;
405
+	}
406 406
 	
407 407
 	
408 408
 	/**
409
-     * Return the DatabaseQueryBuilder instance
410
-     * @return object DatabaseQueryBuilder
411
-     */
412
-    public function getQueryBuilder(){
413
-      return $this->queryBuilder;
414
-    }
415
-
416
-    /**
417
-     * Set the DatabaseQueryBuilder instance
418
-     * @param object DatabaseQueryBuilder $queryBuilder the DatabaseQueryBuilder object
419
-     */
420
-    public function setQueryBuilder(DatabaseQueryBuilder $queryBuilder){
421
-      $this->queryBuilder = $queryBuilder;
422
-      return $this;
423
-    }
424
-
425
-    /**
426
-     * Return the data to be used for insert, update, etc.
427
-     * @return array
428
-     */
429
-    public function getData(){
430
-      return $this->data;
431
-    }
432
-
433
-    /**
434
-     * Set the data to be used for insert, update, etc.
435
-     * @param string|array $key the data key identified
436
-     * @param mixed $value the data value
437
-     * @param boolean $escape whether to escape or not the $value
438
-     * @return object        the current Database instance
439
-     */
440
-    public function setData($key, $value = null, $escape = true){
409
+	 * Return the DatabaseQueryBuilder instance
410
+	 * @return object DatabaseQueryBuilder
411
+	 */
412
+	public function getQueryBuilder(){
413
+	  return $this->queryBuilder;
414
+	}
415
+
416
+	/**
417
+	 * Set the DatabaseQueryBuilder instance
418
+	 * @param object DatabaseQueryBuilder $queryBuilder the DatabaseQueryBuilder object
419
+	 */
420
+	public function setQueryBuilder(DatabaseQueryBuilder $queryBuilder){
421
+	  $this->queryBuilder = $queryBuilder;
422
+	  return $this;
423
+	}
424
+
425
+	/**
426
+	 * Return the data to be used for insert, update, etc.
427
+	 * @return array
428
+	 */
429
+	public function getData(){
430
+	  return $this->data;
431
+	}
432
+
433
+	/**
434
+	 * Set the data to be used for insert, update, etc.
435
+	 * @param string|array $key the data key identified
436
+	 * @param mixed $value the data value
437
+	 * @param boolean $escape whether to escape or not the $value
438
+	 * @return object        the current Database instance
439
+	 */
440
+	public function setData($key, $value = null, $escape = true){
441 441
   	  if(is_array($key)){
442
-    		foreach($key as $k => $v){
443
-    			$this->setData($k, $v, $escape);
444
-    		}	
442
+			foreach($key as $k => $v){
443
+				$this->setData($k, $v, $escape);
444
+			}	
445 445
   	  } else {
446
-        $this->data[$key] = $this->escape($value, $escape);
446
+		$this->data[$key] = $this->escape($value, $escape);
447 447
   	  }
448
-      return $this;
449
-    }
450
-
451
-     /**
452
-     * Execute an SQL query
453
-     * @param  string  $query the query SQL string
454
-     * @param  boolean|array $all  if boolean this indicate whether to return all record or not, if array 
455
-     * will 
456
-     * @param  boolean $array return the result as array
457
-     * @return mixed         the query result
458
-     */
459
-    public function query($query, $all = true, $array = false){
460
-      $this->reset();
461
-      $query = $this->getPreparedQuery($query, $all);
462
-      $this->query = preg_replace('/\s\s+|\t\t+/', ' ', trim($query));
448
+	  return $this;
449
+	}
450
+
451
+	 /**
452
+	  * Execute an SQL query
453
+	  * @param  string  $query the query SQL string
454
+	  * @param  boolean|array $all  if boolean this indicate whether to return all record or not, if array 
455
+	  * will 
456
+	  * @param  boolean $array return the result as array
457
+	  * @return mixed         the query result
458
+	  */
459
+	public function query($query, $all = true, $array = false){
460
+	  $this->reset();
461
+	  $query = $this->getPreparedQuery($query, $all);
462
+	  $this->query = preg_replace('/\s\s+|\t\t+/', ' ', trim($query));
463 463
       
464
-      $isSqlSELECTQuery = stristr($this->query, 'SELECT') !== false;
465
-
466
-      $this->logger->info(
467
-                          'Execute SQL query ['.$this->query.'], return type: ' 
468
-                          . ($array?'ARRAY':'OBJECT') .', return as list: ' 
469
-                          . (is_bool($all) && $all ? 'YES':'NO')
470
-                        );
471
-      //cache expire time
472
-      $cacheExpire = $this->temporaryCacheTtl;
464
+	  $isSqlSELECTQuery = stristr($this->query, 'SELECT') !== false;
465
+
466
+	  $this->logger->info(
467
+						  'Execute SQL query ['.$this->query.'], return type: ' 
468
+						  . ($array?'ARRAY':'OBJECT') .', return as list: ' 
469
+						  . (is_bool($all) && $all ? 'YES':'NO')
470
+						);
471
+	  //cache expire time
472
+	  $cacheExpire = $this->temporaryCacheTtl;
473 473
       
474
-      //return to the initial cache time
475
-      $this->temporaryCacheTtl = $this->cacheTtl;
474
+	  //return to the initial cache time
475
+	  $this->temporaryCacheTtl = $this->cacheTtl;
476 476
       
477
-      //config for cache
478
-      $cacheEnable = get_config('cache_enable');
477
+	  //config for cache
478
+	  $cacheEnable = get_config('cache_enable');
479 479
       
480
-      //the database cache content
481
-      $cacheContent = null;
480
+	  //the database cache content
481
+	  $cacheContent = null;
482 482
 
483
-      //if can use cache feature for this query
484
-      $dbCacheStatus = $cacheEnable && $cacheExpire > 0;
483
+	  //if can use cache feature for this query
484
+	  $dbCacheStatus = $cacheEnable && $cacheExpire > 0;
485 485
     
486
-      if ($dbCacheStatus && $isSqlSELECTQuery){
487
-          $this->logger->info('The cache is enabled for this query, try to get result from cache'); 
488
-          $cacheContent = $this->getCacheContentForQuery($query, $all, $array);  
489
-      }
486
+	  if ($dbCacheStatus && $isSqlSELECTQuery){
487
+		  $this->logger->info('The cache is enabled for this query, try to get result from cache'); 
488
+		  $cacheContent = $this->getCacheContentForQuery($query, $all, $array);  
489
+	  }
490 490
       
491
-      if ( !$cacheContent){
492
-        $sqlQuery = $this->runSqlQuery($query, $all, $array);
493
-        if (is_object($sqlQuery)){
494
-          if ($isSqlSELECTQuery){
495
-            $this->setQueryResultForSelect($sqlQuery, $all, $array);
496
-            $this->setCacheContentForQuery(
497
-                                            $this->query, 
498
-                                            $this->getCacheBenchmarkKeyForQuery($this->query, $all, $array), 
499
-                                            $this->result, 
500
-                                            $dbCacheStatus && $isSqlSELECTQuery, 
501
-                                            $cacheExpire
502
-                                          );
503
-            if (! $this->result){
504
-              $this->logger->info('No result where found for the query [' . $query . ']');
505
-            }
506
-          } else {
507
-              $this->setQueryResultForNonSelect($sqlQuery);
508
-          }
509
-        }
510
-      } else if ($isSqlSELECTQuery){
511
-          $this->logger->info('The result for query [' .$this->query. '] already cached use it');
512
-          $this->result = $cacheContent;
513
-          $this->numRows = count($this->result);
514
-      }
515
-      return $this->result;
516
-    }
491
+	  if ( !$cacheContent){
492
+		$sqlQuery = $this->runSqlQuery($query, $all, $array);
493
+		if (is_object($sqlQuery)){
494
+		  if ($isSqlSELECTQuery){
495
+			$this->setQueryResultForSelect($sqlQuery, $all, $array);
496
+			$this->setCacheContentForQuery(
497
+											$this->query, 
498
+											$this->getCacheBenchmarkKeyForQuery($this->query, $all, $array), 
499
+											$this->result, 
500
+											$dbCacheStatus && $isSqlSELECTQuery, 
501
+											$cacheExpire
502
+										  );
503
+			if (! $this->result){
504
+			  $this->logger->info('No result where found for the query [' . $query . ']');
505
+			}
506
+		  } else {
507
+			  $this->setQueryResultForNonSelect($sqlQuery);
508
+		  }
509
+		}
510
+	  } else if ($isSqlSELECTQuery){
511
+		  $this->logger->info('The result for query [' .$this->query. '] already cached use it');
512
+		  $this->result = $cacheContent;
513
+		  $this->numRows = count($this->result);
514
+	  }
515
+	  return $this->result;
516
+	}
517 517
 	
518 518
 	/**
519
-     * Run the database SQL query and return the PDOStatment object
520
-     * @see Database::query
521
-     * 
522
-     * @return object|void
523
-     */
524
-    public function runSqlQuery($query, $all, $array){
525
-       //for database query execution time
526
-        $benchmarkMarkerKey = $this->getCacheBenchmarkKeyForQuery($query, $all, $array);
527
-        $benchmarkInstance = $this->getBenchmark();
528
-        if (! is_object($benchmarkInstance)){
529
-          $obj = & get_instance();
530
-          $benchmarkInstance = $obj->benchmark; 
531
-          $this->setBenchmark($benchmarkInstance);
532
-        }
519
+	 * Run the database SQL query and return the PDOStatment object
520
+	 * @see Database::query
521
+	 * 
522
+	 * @return object|void
523
+	 */
524
+	public function runSqlQuery($query, $all, $array){
525
+	   //for database query execution time
526
+		$benchmarkMarkerKey = $this->getCacheBenchmarkKeyForQuery($query, $all, $array);
527
+		$benchmarkInstance = $this->getBenchmark();
528
+		if (! is_object($benchmarkInstance)){
529
+		  $obj = & get_instance();
530
+		  $benchmarkInstance = $obj->benchmark; 
531
+		  $this->setBenchmark($benchmarkInstance);
532
+		}
533 533
         
534
-        $benchmarkInstance->mark('DATABASE_QUERY_START(' . $benchmarkMarkerKey . ')');
535
-        //Now execute the query
536
-        $sqlQuery = $this->pdo->query($query);
534
+		$benchmarkInstance->mark('DATABASE_QUERY_START(' . $benchmarkMarkerKey . ')');
535
+		//Now execute the query
536
+		$sqlQuery = $this->pdo->query($query);
537 537
         
538
-        //get response time for this query
539
-        $responseTime = $benchmarkInstance->elapsedTime('DATABASE_QUERY_START(' . $benchmarkMarkerKey . ')', 'DATABASE_QUERY_END(' . $benchmarkMarkerKey . ')');
540
-		    //TODO use the configuration value for the high response time currently is 1 second
541
-        if ($responseTime >= 1 ){
542
-            $this->logger->warning('High response time while processing database query [' .$query. ']. The response time is [' .$responseTime. '] sec.');
543
-        }
544
-		    //count the number of query execution to server
545
-        $this->queryCount++;
538
+		//get response time for this query
539
+		$responseTime = $benchmarkInstance->elapsedTime('DATABASE_QUERY_START(' . $benchmarkMarkerKey . ')', 'DATABASE_QUERY_END(' . $benchmarkMarkerKey . ')');
540
+			//TODO use the configuration value for the high response time currently is 1 second
541
+		if ($responseTime >= 1 ){
542
+			$this->logger->warning('High response time while processing database query [' .$query. ']. The response time is [' .$responseTime. '] sec.');
543
+		}
544
+			//count the number of query execution to server
545
+		$this->queryCount++;
546 546
 		
547
-        if ($sqlQuery !== false){
548
-          return $sqlQuery;
549
-        }
550
-        $this->setQueryError();
551
-    }
547
+		if ($sqlQuery !== false){
548
+		  return $sqlQuery;
549
+		}
550
+		$this->setQueryError();
551
+	}
552 552
 	
553 553
 	
554 554
 	 /**
555
-	 * Return the database configuration
556
-	 * @return array
557
-	 */
555
+	  * Return the database configuration
556
+	  * @return array
557
+	  */
558 558
 	public  function getDatabaseConfiguration(){
559 559
 	  return $this->config;
560 560
 	}
@@ -563,39 +563,39 @@  discard block
 block discarded – undo
563 563
     * Setting the database configuration using the configuration file and additional configuration from param
564 564
     * @param array $overwriteConfig the additional configuration to overwrite with the existing one
565 565
     * @param boolean $useConfigFile whether to use database configuration file
566
-	  * @return object Database
566
+    * @return object Database
567 567
     */
568
-    public function setDatabaseConfiguration(array $overwriteConfig = array(), $useConfigFile = true){
569
-        $db = array();
570
-        if ($useConfigFile && file_exists(CONFIG_PATH . 'database.php')){
571
-            //here don't use require_once because somewhere user can create database instance directly
572
-            require CONFIG_PATH . 'database.php';
573
-        }
568
+	public function setDatabaseConfiguration(array $overwriteConfig = array(), $useConfigFile = true){
569
+		$db = array();
570
+		if ($useConfigFile && file_exists(CONFIG_PATH . 'database.php')){
571
+			//here don't use require_once because somewhere user can create database instance directly
572
+			require CONFIG_PATH . 'database.php';
573
+		}
574 574
         
575
-        //merge with the parameter  
576
-        $db = array_merge($db, $overwriteConfig);
575
+		//merge with the parameter  
576
+		$db = array_merge($db, $overwriteConfig);
577 577
         
578
-        //default configuration
579
-        $config = array(
580
-          'driver' => 'mysql',
581
-          'username' => 'root',
582
-          'password' => '',
583
-          'database' => '',
584
-          'hostname' => 'localhost',
585
-          'charset' => 'utf8',
586
-          'collation' => 'utf8_general_ci',
587
-          'prefix' => '',
588
-          'port' => ''
589
-        );
578
+		//default configuration
579
+		$config = array(
580
+		  'driver' => 'mysql',
581
+		  'username' => 'root',
582
+		  'password' => '',
583
+		  'database' => '',
584
+		  'hostname' => 'localhost',
585
+		  'charset' => 'utf8',
586
+		  'collation' => 'utf8_general_ci',
587
+		  'prefix' => '',
588
+		  'port' => ''
589
+		);
590 590
 		
591
-    		$config = array_merge($config, $db);
592
-    		//determine the port using the hostname like localhost:3307
593
-        //hostname will be "localhost", and port "3307"
594
-        $p = explode(':', $config['hostname']);
595
-    	  if (count($p) >= 2){
596
-    		  $config['hostname'] = $p[0];
597
-    		  $config['port'] = $p[1];
598
-    		}
591
+			$config = array_merge($config, $db);
592
+			//determine the port using the hostname like localhost:3307
593
+		//hostname will be "localhost", and port "3307"
594
+		$p = explode(':', $config['hostname']);
595
+		  if (count($p) >= 2){
596
+			  $config['hostname'] = $p[0];
597
+			  $config['port'] = $p[1];
598
+			}
599 599
 		
600 600
 		 $this->databaseName = $config['database'];
601 601
 		 $this->config = $config;
@@ -620,77 +620,77 @@  discard block
 block discarded – undo
620 620
   }
621 621
 	
622 622
    /**
623
-   * Set the result for SELECT query using PDOStatment
624
-   * @see Database::query
625
-   */
626
-    protected function setQueryResultForSelect($pdoStatment, $all, $array){
627
-      //if need return all result like list of record
628
-      if (is_bool($all) && $all){
629
-          $this->result = ($array === false) ? $pdoStatment->fetchAll(PDO::FETCH_OBJ) : $pdoStatment->fetchAll(PDO::FETCH_ASSOC);
630
-      }
631
-      else{
632
-          $this->result = ($array === false) ? $pdoStatment->fetch(PDO::FETCH_OBJ) : $pdoStatment->fetch(PDO::FETCH_ASSOC);
633
-      }
634
-      //Sqlite and pgsql always return 0 when using rowCount()
635
-      if (in_array($this->config['driver'], array('sqlite', 'pgsql'))){
636
-        $this->numRows = count($this->result);  
637
-      }
638
-      else{
639
-        $this->numRows = $pdoStatment->rowCount(); 
640
-      }
641
-    }
642
-
643
-    /**
644
-     * Set the result for other command than SELECT query using PDOStatment
645
-     * @see Database::query
646
-     */
647
-    protected function setQueryResultForNonSelect($pdoStatment){
648
-      //Sqlite and pgsql always return 0 when using rowCount()
649
-      if (in_array($this->config['driver'], array('sqlite', 'pgsql'))){
650
-        $this->result = true; //to test the result for the query like UPDATE, INSERT, DELETE
651
-        $this->numRows = 1; //TODO use the correct method to get the exact affected row
652
-      }
653
-      else{
654
-          $this->result = $pdoStatment->rowCount() >= 0; //to test the result for the query like UPDATE, INSERT, DELETE
655
-          $this->numRows = $pdoStatment->rowCount(); 
656
-      }
657
-    }
623
+    * Set the result for SELECT query using PDOStatment
624
+    * @see Database::query
625
+    */
626
+	protected function setQueryResultForSelect($pdoStatment, $all, $array){
627
+	  //if need return all result like list of record
628
+	  if (is_bool($all) && $all){
629
+		  $this->result = ($array === false) ? $pdoStatment->fetchAll(PDO::FETCH_OBJ) : $pdoStatment->fetchAll(PDO::FETCH_ASSOC);
630
+	  }
631
+	  else{
632
+		  $this->result = ($array === false) ? $pdoStatment->fetch(PDO::FETCH_OBJ) : $pdoStatment->fetch(PDO::FETCH_ASSOC);
633
+	  }
634
+	  //Sqlite and pgsql always return 0 when using rowCount()
635
+	  if (in_array($this->config['driver'], array('sqlite', 'pgsql'))){
636
+		$this->numRows = count($this->result);  
637
+	  }
638
+	  else{
639
+		$this->numRows = $pdoStatment->rowCount(); 
640
+	  }
641
+	}
642
+
643
+	/**
644
+	 * Set the result for other command than SELECT query using PDOStatment
645
+	 * @see Database::query
646
+	 */
647
+	protected function setQueryResultForNonSelect($pdoStatment){
648
+	  //Sqlite and pgsql always return 0 when using rowCount()
649
+	  if (in_array($this->config['driver'], array('sqlite', 'pgsql'))){
650
+		$this->result = true; //to test the result for the query like UPDATE, INSERT, DELETE
651
+		$this->numRows = 1; //TODO use the correct method to get the exact affected row
652
+	  }
653
+	  else{
654
+		  $this->result = $pdoStatment->rowCount() >= 0; //to test the result for the query like UPDATE, INSERT, DELETE
655
+		  $this->numRows = $pdoStatment->rowCount(); 
656
+	  }
657
+	}
658 658
 
659 659
 	
660 660
 
661
-    /**
662
-     * This method is used to get the PDO DSN string using the configured driver
663
-     * @return string the DSN string
664
-     */
665
-    protected function getDsnFromDriver(){
666
-      $config = $this->getDatabaseConfiguration();
667
-      if (! empty($config)){
668
-        $driver = $config['driver'];
669
-        $driverDsnMap = array(
670
-                                'mysql' => 'mysql:host=' . $config['hostname'] . ';' 
671
-                                            . (($config['port']) != '' ? 'port=' . $config['port'] . ';' : '') 
672
-                                            . 'dbname=' . $config['database'],
673
-                                'pgsql' => 'pgsql:host=' . $config['hostname'] . ';' 
674
-                                            . (($config['port']) != '' ? 'port=' . $config['port'] . ';' : '')
675
-                                            . 'dbname=' . $config['database'],
676
-                                'sqlite' => 'sqlite:' . $config['database'],
677
-                                'oracle' => 'oci:dbname=' . $config['hostname'] 
678
-                                            . (($config['port']) != '' ? ':' . $config['port'] : '')
679
-                                            . '/' . $config['database']
680
-                              );
681
-        return isset($driverDsnMap[$driver]) ? $driverDsnMap[$driver] : '';
682
-      }                   
683
-      return null;
684
-    }
685
-
686
-     /**
687
-     * Transform the prepared query like (?, ?, ?) into string format
688
-     * @see Database::query
689
-     *
690
-     * @return string
691
-     */
692
-    protected function getPreparedQuery($query, $data){
693
-      if (is_array($data)){
661
+	/**
662
+	 * This method is used to get the PDO DSN string using the configured driver
663
+	 * @return string the DSN string
664
+	 */
665
+	protected function getDsnFromDriver(){
666
+	  $config = $this->getDatabaseConfiguration();
667
+	  if (! empty($config)){
668
+		$driver = $config['driver'];
669
+		$driverDsnMap = array(
670
+								'mysql' => 'mysql:host=' . $config['hostname'] . ';' 
671
+											. (($config['port']) != '' ? 'port=' . $config['port'] . ';' : '') 
672
+											. 'dbname=' . $config['database'],
673
+								'pgsql' => 'pgsql:host=' . $config['hostname'] . ';' 
674
+											. (($config['port']) != '' ? 'port=' . $config['port'] . ';' : '')
675
+											. 'dbname=' . $config['database'],
676
+								'sqlite' => 'sqlite:' . $config['database'],
677
+								'oracle' => 'oci:dbname=' . $config['hostname'] 
678
+											. (($config['port']) != '' ? ':' . $config['port'] : '')
679
+											. '/' . $config['database']
680
+							  );
681
+		return isset($driverDsnMap[$driver]) ? $driverDsnMap[$driver] : '';
682
+	  }                   
683
+	  return null;
684
+	}
685
+
686
+	 /**
687
+	  * Transform the prepared query like (?, ?, ?) into string format
688
+	  * @see Database::query
689
+	  *
690
+	  * @return string
691
+	  */
692
+	protected function getPreparedQuery($query, $data){
693
+	  if (is_array($data)){
694 694
   			$x = explode('?', $query);
695 695
   			$q = '';
696 696
   			foreach($x as $k => $v){
@@ -699,121 +699,121 @@  discard block
 block discarded – undo
699 699
   			  }
700 700
   			}
701 701
   			return $q;
702
-      }
703
-      return $query;
704
-    }
705
-
706
-    /**
707
-     * Get the cache content for this query
708
-     * @see Database::query
709
-     *      
710
-     * @return mixed
711
-     */
712
-    protected function getCacheContentForQuery($query, $all, $array){
713
-        $cacheKey = $this->getCacheBenchmarkKeyForQuery($query, $all, $array);
714
-        if (! is_object($this->getCacheInstance())){
715
-    			//can not call method with reference in argument
716
-    			//like $this->setCacheInstance(& get_instance()->cache);
717
-    			//use temporary variable
718
-    			$instance = & get_instance()->cache;
719
-    			$this->setCacheInstance($instance);
720
-        }
721
-        return $this->getCacheInstance()->get($cacheKey);
722
-    }
723
-
724
-    /**
725
-     * Save the result of query into cache
726
-     * @param string $query  the SQL query
727
-     * @param string $key    the cache key
728
-     * @param mixed $result the query result to save
729
-     * @param boolean $status whether can save the query result into cache
730
-     * @param int $expire the cache TTL
731
-     */
732
-     protected function setCacheContentForQuery($query, $key, $result, $status, $expire){
733
-        if ($status){
734
-            $this->logger->info('Save the result for query [' .$query. '] into cache for future use');
735
-            if (! is_object($this->getCacheInstance())){
736
-      				//can not call method with reference in argument
737
-      				//like $this->setCacheInstance(& get_instance()->cache);
738
-      				//use temporary variable
739
-      				$instance = & get_instance()->cache;
740
-      				$this->setCacheInstance($instance);
741
-      			}
742
-            $this->getCacheInstance()->set($key, $result, $expire);
743
-        }
744
-     }
702
+	  }
703
+	  return $query;
704
+	}
705
+
706
+	/**
707
+	 * Get the cache content for this query
708
+	 * @see Database::query
709
+	 *      
710
+	 * @return mixed
711
+	 */
712
+	protected function getCacheContentForQuery($query, $all, $array){
713
+		$cacheKey = $this->getCacheBenchmarkKeyForQuery($query, $all, $array);
714
+		if (! is_object($this->getCacheInstance())){
715
+				//can not call method with reference in argument
716
+				//like $this->setCacheInstance(& get_instance()->cache);
717
+				//use temporary variable
718
+				$instance = & get_instance()->cache;
719
+				$this->setCacheInstance($instance);
720
+		}
721
+		return $this->getCacheInstance()->get($cacheKey);
722
+	}
723
+
724
+	/**
725
+	 * Save the result of query into cache
726
+	 * @param string $query  the SQL query
727
+	 * @param string $key    the cache key
728
+	 * @param mixed $result the query result to save
729
+	 * @param boolean $status whether can save the query result into cache
730
+	 * @param int $expire the cache TTL
731
+	 */
732
+	 protected function setCacheContentForQuery($query, $key, $result, $status, $expire){
733
+		if ($status){
734
+			$this->logger->info('Save the result for query [' .$query. '] into cache for future use');
735
+			if (! is_object($this->getCacheInstance())){
736
+	  				//can not call method with reference in argument
737
+	  				//like $this->setCacheInstance(& get_instance()->cache);
738
+	  				//use temporary variable
739
+	  				$instance = & get_instance()->cache;
740
+	  				$this->setCacheInstance($instance);
741
+	  			}
742
+			$this->getCacheInstance()->set($key, $result, $expire);
743
+		}
744
+	 }
745 745
 
746 746
     
747
-    /**
748
-     * Set error for database query execution
749
-     */
750
-    protected function setQueryError(){
751
-      $error = $this->pdo->errorInfo();
752
-      $this->error = isset($error[2]) ? $error[2] : '';
753
-      $this->logger->error('The database query execution got error: ' . stringfy_vars($error));
754
-	    //show error message
755
-      $this->error();
756
-    }
747
+	/**
748
+	 * Set error for database query execution
749
+	 */
750
+	protected function setQueryError(){
751
+	  $error = $this->pdo->errorInfo();
752
+	  $this->error = isset($error[2]) ? $error[2] : '';
753
+	  $this->logger->error('The database query execution got error: ' . stringfy_vars($error));
754
+		//show error message
755
+	  $this->error();
756
+	}
757 757
 
758 758
 	  /**
759
-     * Return the cache key for the given query
760
-     * @see Database::query
761
-     * 
762
-     *  @return string
763
-     */
764
-    protected function getCacheBenchmarkKeyForQuery($query, $all, $array){
765
-      if (is_array($all)){
766
-        $all = 'array';
767
-      }
768
-      return md5($query . $all . $array);
769
-    }
759
+	   * Return the cache key for the given query
760
+	   * @see Database::query
761
+	   * 
762
+	   *  @return string
763
+	   */
764
+	protected function getCacheBenchmarkKeyForQuery($query, $all, $array){
765
+	  if (is_array($all)){
766
+		$all = 'array';
767
+	  }
768
+	  return md5($query . $all . $array);
769
+	}
770 770
     
771 771
 	   /**
772
-     * Set the Log instance using argument or create new instance
773
-     * @param object $logger the Log instance if not null
774
-     */
775
-    protected function setLoggerFromParamOrCreateNewInstance(Log $logger = null){
776
-      if ($logger !== null){
777
-        $this->setLogger($logger);
778
-      }
779
-      else{
780
-          $this->logger =& class_loader('Log', 'classes');
781
-          $this->logger->setLogger('Library::Database');
782
-      }
783
-    }
772
+	    * Set the Log instance using argument or create new instance
773
+	    * @param object $logger the Log instance if not null
774
+	    */
775
+	protected function setLoggerFromParamOrCreateNewInstance(Log $logger = null){
776
+	  if ($logger !== null){
777
+		$this->setLogger($logger);
778
+	  }
779
+	  else{
780
+		  $this->logger =& class_loader('Log', 'classes');
781
+		  $this->logger->setLogger('Library::Database');
782
+	  }
783
+	}
784 784
 	
785 785
    /**
786
-   * Set the DatabaseQueryBuilder instance using argument or create new instance
787
-   * @param object $queryBuilder the DatabaseQueryBuilder instance if not null
788
-   */
786
+    * Set the DatabaseQueryBuilder instance using argument or create new instance
787
+    * @param object $queryBuilder the DatabaseQueryBuilder instance if not null
788
+    */
789 789
 	protected function setQueryBuilderFromParamOrCreateNewInstance(DatabaseQueryBuilder $queryBuilder = null){
790 790
 	  if ($queryBuilder !== null){
791
-      $this->setQueryBuilder($queryBuilder);
791
+	  $this->setQueryBuilder($queryBuilder);
792 792
 	  }
793 793
 	  else{
794 794
 		  $this->queryBuilder =& class_loader('DatabaseQueryBuilder', 'classes');
795 795
 	  }
796 796
 	}
797 797
 
798
-    /**
799
-     * Reset the database class attributs to the initail values before each query.
800
-     */
801
-    private function reset(){
798
+	/**
799
+	 * Reset the database class attributs to the initail values before each query.
800
+	 */
801
+	private function reset(){
802 802
 	   //query builder reset
803
-      $this->getQueryBuilder()->reset();
804
-      $this->numRows  = 0;
805
-      $this->insertId = null;
806
-      $this->query    = null;
807
-      $this->error    = null;
808
-      $this->result   = array();
809
-      $this->data     = array();
810
-    }
811
-
812
-    /**
813
-     * The class destructor
814
-     */
815
-    public function __destruct(){
816
-      $this->pdo = null;
817
-    }
803
+	  $this->getQueryBuilder()->reset();
804
+	  $this->numRows  = 0;
805
+	  $this->insertId = null;
806
+	  $this->query    = null;
807
+	  $this->error    = null;
808
+	  $this->result   = array();
809
+	  $this->data     = array();
810
+	}
811
+
812
+	/**
813
+	 * The class destructor
814
+	 */
815
+	public function __destruct(){
816
+	  $this->pdo = null;
817
+	}
818 818
 
819 819
 }
Please login to merge, or discard this patch.
core/classes/cache/FileCache.php 1 patch
Indentation   +86 added lines, -86 removed lines patch added patch discarded remove patch
@@ -22,7 +22,7 @@  discard block
 block discarded – undo
22 22
 	 * You should have received a copy of the GNU General Public License
23 23
 	 * along with this program; if not, write to the Free Software
24 24
 	 * Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
25
-	*/
25
+	 */
26 26
 
27 27
 	class FileCache implements CacheInterface{
28 28
 		
@@ -44,15 +44,15 @@  discard block
 block discarded – undo
44 44
 				show_error('The cache for file system is not available. Check the cache directory if is exists or is writable.');
45 45
 			}
46 46
 			/**
47
-	         * instance of the Log class
48
-	         */
49
-	        if(is_object($logger)){
50
-	          $this->logger = $logger;
51
-	        }
52
-	        else{
53
-	            $this->logger =& class_loader('Log', 'classes');
54
-	            $this->logger->setLogger('Library::FileCache');
55
-	        }
47
+			 * instance of the Log class
48
+			 */
49
+			if(is_object($logger)){
50
+			  $this->logger = $logger;
51
+			}
52
+			else{
53
+				$this->logger =& class_loader('Log', 'classes');
54
+				$this->logger->setLogger('Library::FileCache');
55
+			}
56 56
 			
57 57
 			//if Zlib extension is not loaded set compressCacheData to false
58 58
 			if(! extension_loaded('zlib')){
@@ -80,26 +80,26 @@  discard block
 block discarded – undo
80 80
 				return false;
81 81
 			}
82 82
 			// Getting a shared lock 
83
-		    flock($handle, LOCK_SH);
84
-		    $data = file_get_contents($filePath);
85
-      		fclose($handle);
86
-      		$data = @unserialize($this->compressCacheData ? gzinflate($data) : $data);
87
-      		if (! $data) {
88
-      			$this->logger->error('Can not unserialize the cache data for the key ['. $key .'], return false');
89
-		         // If unserializing somehow didn't work out, we'll delete the file
90
-		         unlink($filePath);
91
-		         return false;
92
-	      	}
93
-	      	if (time() > $data['expire']) {
94
-	      		$this->logger->info('The cache data for the key ['. $key .'] already expired delete the cache file [' .$filePath. ']');
95
-		        // Unlinking when the file was expired
96
-		        unlink($filePath);
97
-		        return false;
98
-		     }
99
-		     else{
100
-		     	$this->logger->info('The cache not yet expire, now return the cache data for key ['. $key .'], the cache will expire at [' . date('Y-m-d H:i:s', $data['expire']) . ']');
101
-		     	return $data['data'];
102
-		     }
83
+			flock($handle, LOCK_SH);
84
+			$data = file_get_contents($filePath);
85
+	  		fclose($handle);
86
+	  		$data = @unserialize($this->compressCacheData ? gzinflate($data) : $data);
87
+	  		if (! $data) {
88
+	  			$this->logger->error('Can not unserialize the cache data for the key ['. $key .'], return false');
89
+				 // If unserializing somehow didn't work out, we'll delete the file
90
+				 unlink($filePath);
91
+				 return false;
92
+		  	}
93
+		  	if (time() > $data['expire']) {
94
+		  		$this->logger->info('The cache data for the key ['. $key .'] already expired delete the cache file [' .$filePath. ']');
95
+				// Unlinking when the file was expired
96
+				unlink($filePath);
97
+				return false;
98
+			 }
99
+			 else{
100
+			 	$this->logger->info('The cache not yet expire, now return the cache data for key ['. $key .'], the cache will expire at [' . date('Y-m-d H:i:s', $data['expire']) . ']');
101
+			 	return $data['data'];
102
+			 }
103 103
 		}
104 104
 
105 105
 
@@ -121,25 +121,25 @@  discard block
 block discarded – undo
121 121
 			}
122 122
 			flock($handle, LOCK_EX); // exclusive lock, will get released when the file is closed
123 123
 			//Serializing along with the TTL
124
-		    $cacheData = serialize(array(
124
+			$cacheData = serialize(array(
125 125
 									'mtime' => time(),
126 126
 									'expire' => $expire,
127 127
 									'data' => $data,
128 128
 									'ttl' => $ttl
129 129
 									)
130 130
 								);		   
131
-		    $result = fwrite($handle, $this->compressCacheData ? gzdeflate($cacheData, 9) : $cacheData);
132
-		    if(! $result){
133
-		    	$this->logger->error('Can not write cache data into file [' .$filePath. '] for the key ['. $key .'], return false');
134
-		    	fclose($handle);
135
-		    	return false;
136
-		    }
137
-		    else{
138
-		    	$this->logger->info('Cache data saved into file [' .$filePath. '] for the key ['. $key .']');
139
-		    	fclose($handle);
131
+			$result = fwrite($handle, $this->compressCacheData ? gzdeflate($cacheData, 9) : $cacheData);
132
+			if(! $result){
133
+				$this->logger->error('Can not write cache data into file [' .$filePath. '] for the key ['. $key .'], return false');
134
+				fclose($handle);
135
+				return false;
136
+			}
137
+			else{
138
+				$this->logger->info('Cache data saved into file [' .$filePath. '] for the key ['. $key .']');
139
+				fclose($handle);
140 140
 				chmod($filePath, 0640);
141 141
 				return true;
142
-		    }
142
+			}
143 143
 		}	
144 144
 
145 145
 
@@ -159,7 +159,7 @@  discard block
 block discarded – undo
159 159
 			}
160 160
 			else{
161 161
 				$this->logger->info('Found cache file [' .$filePath. '] remove it');
162
-	      		unlink($filePath);
162
+		  		unlink($filePath);
163 163
 				return true;
164 164
 			}
165 165
 		}
@@ -182,7 +182,7 @@  discard block
 block discarded – undo
182 182
 			}
183 183
 			else{
184 184
 				$this->logger->info('Found cache file [' .$filePath. '] check the validity');
185
-	      		$data = file_get_contents($filePath);
185
+		  		$data = file_get_contents($filePath);
186 186
 				$data = @unserialize($this->compressCacheData ? gzinflate($data) : $data);
187 187
 				if(! $data){
188 188
 					$this->logger->warning('Can not unserialize the cache data for file [' . $filePath . ']');
@@ -222,17 +222,17 @@  discard block
 block discarded – undo
222 222
 				foreach ($list as $file) {
223 223
 					$this->logger->debug('Processing the cache file [' . $file . ']');
224 224
 					$data = file_get_contents($file);
225
-		      		$data = @unserialize($this->compressCacheData ? gzinflate($data) : $data);
226
-		      		if(! $data){
227
-		      			$this->logger->warning('Can not unserialize the cache data for file [' . $file . ']');
228
-		      		}
229
-		      		else if(time() > $data['expire']){
230
-		      			$this->logger->info('The cache data for file [' . $file . '] already expired remove it');
231
-		      			unlink($file);
232
-		      		}
233
-		      		else{
234
-		      			$this->logger->info('The cache data for file [' . $file . '] not yet expired skip it');
235
-		      		}
225
+			  		$data = @unserialize($this->compressCacheData ? gzinflate($data) : $data);
226
+			  		if(! $data){
227
+			  			$this->logger->warning('Can not unserialize the cache data for file [' . $file . ']');
228
+			  		}
229
+			  		else if(time() > $data['expire']){
230
+			  			$this->logger->info('The cache data for file [' . $file . '] already expired remove it');
231
+			  			unlink($file);
232
+			  		}
233
+			  		else{
234
+			  			$this->logger->info('The cache data for file [' . $file . '] not yet expired skip it');
235
+			  		}
236 236
 				}
237 237
 			}
238 238
 		}	
@@ -255,19 +255,19 @@  discard block
 block discarded – undo
255 255
 			}
256 256
 		}
257 257
 	
258
-	    /**
259
-	     * @return boolean
260
-	     */
261
-	    public function isCompressCacheData(){
262
-	        return $this->compressCacheData;
263
-	    }
258
+		/**
259
+		 * @return boolean
260
+		 */
261
+		public function isCompressCacheData(){
262
+			return $this->compressCacheData;
263
+		}
264 264
 
265
-	    /**
266
-	     * @param boolean $compressCacheData
267
-	     *
268
-	     * @return object
269
-	     */
270
-	    public function setCompressCacheData($status = true){
265
+		/**
266
+		 * @param boolean $compressCacheData
267
+		 *
268
+		 * @return object
269
+		 */
270
+		public function setCompressCacheData($status = true){
271 271
 			//if Zlib extension is not loaded set compressCacheData to false
272 272
 			if($status === true && ! extension_loaded('zlib')){
273 273
 				
@@ -278,7 +278,7 @@  discard block
 block discarded – undo
278 278
 				$this->compressCacheData = $status;
279 279
 			}
280 280
 			return $this;
281
-	    }
281
+		}
282 282
 		
283 283
 		/**
284 284
 		 * Check whether the cache feature for the handle is supported
@@ -290,28 +290,28 @@  discard block
 block discarded – undo
290 290
 		}
291 291
 
292 292
 		/**
293
-	     * Return the Log instance
294
-	     * @return object
295
-	     */
296
-	    public function getLogger(){
297
-	      return $this->logger;
298
-	    }
293
+		 * Return the Log instance
294
+		 * @return object
295
+		 */
296
+		public function getLogger(){
297
+		  return $this->logger;
298
+		}
299 299
 
300
-	    /**
301
-	     * Set the log instance
302
-	     * @param Log $logger the log object
303
-	     */
304
-	    public function setLogger(Log $logger){
305
-	      $this->logger = $logger;
306
-	      return $this;
307
-	    }
300
+		/**
301
+		 * Set the log instance
302
+		 * @param Log $logger the log object
303
+		 */
304
+		public function setLogger(Log $logger){
305
+		  $this->logger = $logger;
306
+		  return $this;
307
+		}
308 308
 		
309 309
 		/**
310
-		* Get the cache file full path for the given key
311
-		*
312
-		* @param $key the cache item key
313
-		* @return string
314
-		*/
310
+		 * Get the cache file full path for the given key
311
+		 *
312
+		 * @param $key the cache item key
313
+		 * @return string
314
+		 */
315 315
 		private function getFilePath($key){
316 316
 			return CACHE_PATH . md5($key) . '.cache';
317 317
 		}
Please login to merge, or discard this patch.