<?php
/*
 * Copyright 2014 pm.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

/**
 * MicroPHP
 *
 * An open source application development framework for PHP 5.2.0 or newer
 *
 * @package       MicroPHP
 * @author        狂奔的蜗牛
 * @email         672308444@163.com
 * @copyright     Copyright (c) 2013 - 2014, 狂奔的蜗牛, Inc.
 * @link          http://git.oschina.net/snail/microphp
 * @since         Version 2.3.0
 * @createdtime   2014-10-18 16:32:34
 */
 
 if (!function_exists('args')) { function args($key = null) { return MpInput::parameters($key); } } if (!function_exists('xss_clean')) { function xss_clean($val) { return MpInput::xss_clean($val); } } foreach (array('set_cookie'=>'setCookie', 'set_cookie_raw'=>'setCookieRaw') as $func=>$true) { if (!function_exists($func)) { eval('function ' . $func . '($key, $value, $life = null, $path = "/", $domian = null, $http_only = false) {
					 return MpLoader::' . $true . '($key, $value, $life, $path, $domian, $http_only);
		 }'); } } foreach (array('server', 'session') as $func) { if (!function_exists($func)) { eval('function ' . $func . '($key = null, $default = null) {
					 return MpInput::' . $func . '($key, $default);
		 }'); } } foreach (array('get_rule', 'post_rule', 'get_post_rule', 'post_get_rule') as $func) { if (!function_exists($func)) { eval('function ' . $func . '($rule, $key, $default = null) {
					 return MpInput::' . $func . '($rule, $key, $default);
		 }'); } } foreach (array('get', 'post', 'cookie', 'cookie_raw', 'get_post', 'post_get') as $func) { if (!function_exists($func)) { if ($func == 'cookie_raw') { $func = 'cookiRaw'; } eval('function ' . $func . '($key = null, $default = null, $xss_clean = false) {
					 return MpInput::' . $func . '($key, $default, $xss_clean);
		 }'); } } foreach (array('get_int', 'post_int', 'get_post_int', 'post_get_int', 'get_time', 'post_time', 'get_post_time', 'post_get_time', 'get_date', 'post_date', 'get_post_date', 'post_get_date', 'get_datetime', 'post_datetime', 'get_post_datetime', 'post_get_datetime') as $func) { if (!function_exists($func)) { eval('function ' . $func . '($key, $min = null, $max = null, $default = null) {
					 return MpInput::' . $func . '($key, $min, $max, $default);
		 }'); } } if (!function_exists('dump')) { function dump($arg, $_ = null) { $args = func_get_args(); if (MpInput::isCli()) { call_user_func_array('var_dump', $args); } else { echo '<pre>'; call_user_func_array('var_dump', $args); echo '</pre>'; } } } if (!function_exists('table')) { function table($table_name, $db = null) { return MpTableModel::M($table_name, $db); } } if (!function_exists('url')) { function url() { $action = null; $argc = func_num_args(); if ($argc > 0) { $action = func_get_arg(0); } $args = array(); $get_str_arr = array(); if ($argc > 1) { for ($i = 1; $i < $argc; $i++) { if (is_array($arg = func_get_arg($i))) { foreach ($arg as $k => $v) { $get_str_arr[] = $k . '=' . urlencode($v); } } else { $args[] = $arg; } } } if (!systemInfo('url_rewrite')) { $self_name = stripos($action, '#') === 0 || stripos($action, '#') === 1 ? pathinfo(MpInput::server('php_self'), PATHINFO_BASENAME) : ''; $app_start = '?'; $get_start = '&'; } else { $self_name = ''; $app_start = ''; $get_start = '?'; } $path = (stripos($action, '?') === 0 || stripos($action, '?') === 1 ? '' : urlPath() . '/' ); $action = ltrim($action, '#?'); $url_app = $path . $self_name . (empty($args) && empty($get_str_arr) && empty($action) ? '' : $app_start) . ($action . (empty($args) || empty($action) ? '' : '/' ) . implode('/', $args)) . (empty($get_str_arr) ? '' : $get_start . implode('&', $get_str_arr)); return str_replace('?&', '?', $url_app); } } if (!function_exists('urlPath')) { function urlPath($subpath = null) { if (MpInput::isCli()) { throw new Exception('function urlPath() can not be used in cli mode'); } else { $old_path = getcwd(); $root = str_replace(array("/", "\\"), '/', MpInput::server('DOCUMENT_ROOT')); chdir($root); $root = getcwd(); $root = str_replace(array("/", "\\"), '/', $root); chdir($old_path); $path = path($subpath); return str_replace($root, '', $path); } } } if (!function_exists('path')) { function path($subpath = null) { $path = str_replace(array("/", "\\"), '/', realpath('.') . ($subpath ? '/' . trim($subpath, '/\\') : '')); return truepath($path); } } if (!function_exists('systemInfo')) { function systemInfo($key = NULL) { if (is_null($key)) { return MpLoader::$system; } elseif (isset(MpLoader::$system[$key])) { return MpLoader::$system[$key]; } else { return null; } } } if (!function_exists('dbInfo')) { function dbInfo($group = NULL, $key = NULL) { if (is_null($group)) { $system= systemInfo(); $cfg = $system['db'][$system['db']['active_group']]; if (is_null($key)) { return $cfg; } else { return isset($cfg[$key]) ? $cfg[$key] : null; } } elseif (isset($system['db'][$group])) { $cfg = $system['db'][$group]; if (is_null($key)) { return $cfg; } else { return isset($cfg[$key]) ? $cfg[$key] : null; } } else { return null; } } } if (!function_exists('sessionStart')) { function sessionStart() { if (!isset($_SESSION)) { session_start(); } } } if (!function_exists('getInstance')) { function &getInstance() { return WoniuController::getInstance(); } } if (!function_exists('trigger404')) { function trigger404($msg = '<h1>Not Found</h1>') { $system = systemInfo(); if (!headers_sent()) { header('HTTP/1.1 404 NotFound'); } if (!empty($system['error_page_404']) && file_exists($system['error_page_404'])) { include $system['error_page_404']; } else { echo $msg; } exit(); } } if (!function_exists('truepath')) { function truepath($path) { $unipath = PATH_SEPARATOR == ':'; if (strpos($path, ':') === false && strlen($path) && $path{0} != '/') { $path = realpath('.') . DIRECTORY_SEPARATOR . $path; } $path = str_replace(array('/', '\\'), DIRECTORY_SEPARATOR, $path); $parts = array_filter(explode(DIRECTORY_SEPARATOR, $path), 'strlen'); $absolutes = array(); foreach ($parts as $part) { if ('.' == $part) continue; if ('..' == $part) { array_pop($absolutes); } else { $absolutes[] = $part; } } $path = implode(DIRECTORY_SEPARATOR, $absolutes); $path = $unipath ? (strlen($path) && $path{0} != '/' ? '/' . $path : $path) : $path; $path = str_replace(array('/', '\\'), '/', $path); return $path; } } if (!function_exists('convertPath')) { function convertPath($path) { return str_replace(array("\\", "/"), '/', $path); } } if (!function_exists('trigger500')) { function trigger500($msg = '<h1>Server Error</h1>') { $system = systemInfo(); if (!headers_sent()) { header('HTTP/1.1 500 Server Error'); } if (!empty($system['error_page_50x']) && file_exists($system['error_page_50x'])) { include $system['error_page_50x']; } else { echo $msg; } exit(); } } if (!function_exists('woniu_exception_handler')) { function woniu_exception_handler($exception) { $errno = $exception->getCode(); $errfile = pathinfo($exception->getFile(), PATHINFO_FILENAME); $errline = $exception->getLine(); $errstr = $exception->getMessage(); $system =systemInfo(); if ($system['log_error']) { $handle = $system['log_error_handle']['exception']; if (!empty($handle)) { if (is_array($handle)) { $class = key($handle); $method = $handle[$class]; $rclass_obj = new ReflectionClass($class); $rclass_obj = $rclass_obj->newInstanceArgs(); if (method_exists($rclass_obj, $method)) { $rclass_obj->{$method}($errno, $errstr, $errfile, $errline, get_strace()); } } else { if (function_exists($handle)) { $handle($errno, $errstr, $errfile, $errline, get_strace()); } } } } if ($system['debug']) { trigger500('<pre>' . format_error($errno, $errstr, $errfile, $errline) . '</pre>'); } exit; } } if (!function_exists('woniu_error_handler')) { function woniu_error_handler($errno, $errstr, $errfile, $errline) { if (!error_reporting()) { return; } $fatal_err = array(E_ERROR, E_USER_ERROR, E_COMPILE_ERROR, E_CORE_ERROR, E_PARSE, E_RECOVERABLE_ERROR); if (in_array($errno, $fatal_err)) { return true; } $system =systemInfo(); if ($system['log_error']) { $handle = $system['log_error_handle']['error']; if (!empty($handle)) { if (is_array($handle)) { $class = key($handle); $method = $handle[$class]; $rclass_obj = new ReflectionClass($class); $rclass_obj = $rclass_obj->newInstanceArgs(); if (method_exists($rclass_obj, $method)) { $rclass_obj->{$method}($errno, $errstr, $errfile, $errline, get_strace()); } } else { if (function_exists($handle)) { $handle($errno, $errstr, $errfile, $errline, get_strace()); } } } } if ($system['debug']) { echo '<pre>' . format_error($errno, $errstr, $errfile, $errline) . '</pre>'; } } } if (!function_exists('woniu_fatal_handler')) { function woniu_fatal_handler() { $system = systemInfo(); $errfile = "unknown file"; $errstr = "shutdown"; $errno = E_CORE_ERROR; $errline = 0; $error = error_get_last(); $fatal_err = array(E_ERROR, E_USER_ERROR, E_COMPILE_ERROR, E_CORE_ERROR, E_PARSE, E_RECOVERABLE_ERROR); if ($error !== NULL && isset($error["type"]) && in_array($error["type"], $fatal_err)) { $errno = $error["type"]; $errfile = $error["file"]; $errline = $error["line"]; $errstr = $error["message"]; if ($system['log_error']) { $handle = $system['log_error_handle']['error']; if (!empty($handle)) { if (is_array($handle)) { $class = key($handle); $method = $handle[$class]; $rclass_obj = new ReflectionClass($class); $rclass_obj = $rclass_obj->newInstanceArgs(); if (method_exists($rclass_obj, $method)) { $rclass_obj->{$method}($errno, $errstr, $errfile, $errline, get_strace()); } } else { if (function_exists($handle)) { $handle($errno, $errstr, $errfile, $errline, get_strace()); } } } } if ($system['debug']) { trigger500('<pre>' . format_error($errno, $errstr, $errfile, $errline) . '</pre>'); } exit; } } } if (!function_exists('woniu_db_error_handler')) { function woniu_db_error_handler($error) { $msg = ''; if (is_array($error)) { foreach ($error as $m) { $msg.=$m . "\n"; } } else { $msg = $error; } $system = systemInfo(); $woniu_db = systemInfo('db'); if ($system['log_error']) { $handle = $system['log_error_handle']['db_error']; if (!empty($handle)) { if (is_array($handle)) { $class = key($handle); $method = $handle[$class]; $rclass_obj = new ReflectionClass($class); $rclass_obj = $rclass_obj->newInstanceArgs(); if (method_exists($rclass_obj, $method)) { $rclass_obj->{$method}($msg, get_strace(TRUE)); } } else { if (function_exists($handle)) { $handle($msg, get_strace(TRUE)); } } } } if ($woniu_db[$woniu_db['active_group']]['db_debug'] && $system['debug']) { if (!empty($system['error_page_db']) && file_exists($system['error_page_db'])) { include $system['error_page_db']; } else { echo '<pre>' . $msg . get_strace(TRUE) . '</pre>'; } exit; } } } if (!function_exists('format_error')) { function format_error($errno, $errstr, $errfile, $errline) { $path = truepath(systemInfo('application_folder')); $path.=empty($path) ? '' : '/'; $array_map = array('0' => 'EXCEPTION', '1' => 'ERROR', '2' => 'WARNING', '4' => 'PARSE', '8' => 'NOTICE', '16' => 'CORE_ERROR', '32' => 'CORE_WARNING', '64' => 'COMPILE_ERROR', '128' => 'COMPILE_WARNING', '256' => 'USER_ERROR', '512' => 'USER_WARNING', '1024' => 'USER_NOTICE', '2048' => 'STRICT', '4096' => 'RECOVERABLE_ERROR', '8192' => 'DEPRECATED', '16384' => 'USER_DEPRECATED'); $trace = get_strace(); $content = ''; $content .= "错误信息:" . nl2br($errstr) . "\n"; $content .= "出错文件:" . str_replace($path, '', $errfile) . "\n"; $content .= "出错行数:{$errline}\n"; $content .= "错误代码:{$errno}\n"; $content .= "错误类型:{$array_map[$errno]}\n"; if (!empty($trace)) { $content .= "调用信息:{$trace}\n"; } return $content; } } if (!function_exists('get_strace')) { function get_strace($is_db = false) { $trace = debug_backtrace(false); foreach ($trace as $t) { if (!in_array($t['function'], array('display_error', 'woniu_db_error_handler', 'woniu_fatal_handler', 'woniu_error_handler', 'woniu_exception_handler'))) { array_shift($trace); } else { array_shift($trace); break; } } if ($is_db) { array_shift($trace); } array_pop($trace); array_pop($trace); $str = ''; $path = truepath(systemInfo('application_folder')); $path.=empty($path) ? '' : '/'; foreach ($trace as $k => $e) { $file = !empty($e['file']) ? "File:" . str_replace($path, '', $e['file']) . "\n" : ''; $line = !empty($e['line']) ? "   Line:{$e['line']}\n" : ''; $space = (empty($file) && empty($line) ? '' : '   '); $func = $space . (!empty($e['class']) ? "Function:{$e['class']}{$e['type']}{$e['function']}()\n" : "Function:{$e['function']}()\n"); $str.="\n#{$k} {$file}{$line}{$func}"; } return $str; } } if (!function_exists('stripslashes_all')) { function stripslashes_all() { if (!get_magic_quotes_gpc()) { return; } $strip_list = array('_GET', '_POST', '_COOKIE'); foreach ($strip_list as $val) { global $$val; $$val = stripslashes2($$val); } } } if (!function_exists('stripslashes2')) { function stripslashes2($var) { if (!get_magic_quotes_gpc()) { return $var; } if (is_array($var)) { foreach ($var as $key => $val) { if (is_array($val)) { $var[$key] = stripslashes2($val); } else { $var[$key] = stripslashes($val); } } } elseif (is_string($var)) { $var = stripslashes($var); } return $var; } } if (!function_exists('is_php')) { function is_php($version = '5.0.0') { static $_is_php; $version = (string) $version; if (!isset($_is_php[$version])) { $_is_php[$version] = (version_compare(PHP_VERSION, $version) < 0) ? FALSE : TRUE; } return $_is_php[$version]; } } if (!function_exists('forceDownload')) { function forceDownload($filename = '', $data = '') { if ($filename == '' OR $data == '') { return FALSE; } if (FALSE === strpos($filename, '.')) { return FALSE; } $x = explode('.', $filename); $extension = end($x); $mimes = array('hqx' => 'application/mac-binhex40', 'cpt' => 'application/mac-compactpro', 'csv' => array('text/x-comma-separated-values', 'text/comma-separated-values', 'application/octet-stream', 'application/vnd.ms-excel', 'application/x-csv', 'text/x-csv', 'text/csv', 'application/csv', 'application/excel', 'application/vnd.msexcel'), 'bin' => 'application/macbinary', 'dms' => 'application/octet-stream', 'lha' => 'application/octet-stream', 'lzh' => 'application/octet-stream', 'exe' => array('application/octet-stream', 'application/x-msdownload'), 'class' => 'application/octet-stream', 'psd' => 'application/x-photoshop', 'so' => 'application/octet-stream', 'sea' => 'application/octet-stream', 'dll' => 'application/octet-stream', 'oda' => 'application/oda', 'pdf' => array('application/pdf', 'application/x-download'), 'ai' => 'application/postscript', 'eps' => 'application/postscript', 'ps' => 'application/postscript', 'smi' => 'application/smil', 'smil' => 'application/smil', 'mif' => 'application/vnd.mif', 'xls' => array('application/excel', 'application/vnd.ms-excel', 'application/msexcel'), 'ppt' => array('application/powerpoint', 'application/vnd.ms-powerpoint'), 'wbxml' => 'application/wbxml', 'wmlc' => 'application/wmlc', 'dcr' => 'application/x-director', 'dir' => 'application/x-director', 'dxr' => 'application/x-director', 'dvi' => 'application/x-dvi', 'gtar' => 'application/x-gtar', 'gz' => 'application/x-gzip', 'php' => 'application/x-httpd-php', 'php4' => 'application/x-httpd-php', 'php3' => 'application/x-httpd-php', 'phtml' => 'application/x-httpd-php', 'phps' => 'application/x-httpd-php-source', 'js' => 'application/x-javascript', 'swf' => 'application/x-shockwave-flash', 'sit' => 'application/x-stuffit', 'tar' => 'application/x-tar', 'tgz' => array('application/x-tar', 'application/x-gzip-compressed'), 'xhtml' => 'application/xhtml+xml', 'xht' => 'application/xhtml+xml', 'zip' => array('application/x-zip', 'application/zip', 'application/x-zip-compressed'), 'mid' => 'audio/midi', 'midi' => 'audio/midi', 'mpga' => 'audio/mpeg', 'mp2' => 'audio/mpeg', 'mp3' => array('audio/mpeg', 'audio/mpg', 'audio/mpeg3', 'audio/mp3'), 'aif' => 'audio/x-aiff', 'aiff' => 'audio/x-aiff', 'aifc' => 'audio/x-aiff', 'ram' => 'audio/x-pn-realaudio', 'rm' => 'audio/x-pn-realaudio', 'rpm' => 'audio/x-pn-realaudio-plugin', 'ra' => 'audio/x-realaudio', 'rv' => 'video/vnd.rn-realvideo', 'wav' => 'audio/x-wav', 'bmp' => 'image/bmp', 'gif' => 'image/gif', 'jpeg' => array('image/jpeg', 'image/pjpeg'), 'jpg' => array('image/jpeg', 'image/pjpeg'), 'jpe' => array('image/jpeg', 'image/pjpeg'), 'png' => array('image/png', 'image/x-png'), 'tiff' => 'image/tiff', 'tif' => 'image/tiff', 'css' => 'text/css', 'html' => 'text/html', 'htm' => 'text/html', 'shtml' => 'text/html', 'txt' => 'text/plain', 'text' => 'text/plain', 'log' => array('text/plain', 'text/x-log'), 'rtx' => 'text/richtext', 'rtf' => 'text/rtf', 'xml' => 'text/xml', 'xsl' => 'text/xml', 'mpeg' => 'video/mpeg', 'mpg' => 'video/mpeg', 'mpe' => 'video/mpeg', 'qt' => 'video/quicktime', 'mov' => 'video/quicktime', 'avi' => 'video/x-msvideo', 'movie' => 'video/x-sgi-movie', 'doc' => 'application/msword', 'docx' => 'application/vnd.openxmlformats-officedocument.wordprocessingml.document', 'xlsx' => 'application/vnd.openxmlformats-officedocument.spreadsheetml.sheet', 'word' => array('application/msword', 'application/octet-stream'), 'xl' => 'application/excel', 'eml' => 'message/rfc822', 'json' => array('application/json', 'text/json')); if (!isset($mimes[$extension])) { $mime = 'application/octet-stream'; } else { $mime = (is_array($mimes[$extension])) ? $mimes[$extension][0] : $mimes[$extension]; } header('Content-Type: "' . $mime . '"'); $tmpName = $filename; $filename = '"' . urlencode($tmpName) . '"'; if (strstr(strtolower($_SERVER['HTTP_USER_AGENT']), 'firefox') != false) { $filename = '"' . $tmpName . '"'; } if (strstr(strtolower($_SERVER['HTTP_USER_AGENT']), 'chrome') != false) { $filename = urlencode($tmpName); } header('Content-Disposition: attachment; filename=' . $filename); header('Expires: 0'); header('Cache-Control: must-revalidate, post-check=0, pre-check=0'); header("Content-Transfer-Encoding: binary"); header('Pragma: no-cache'); header("Content-Length: " . strlen($data)); exit($data); } } if (!function_exists('getRsCol')) { function getRsCol($rows, $col_name) { $ret = array(); foreach ($rows as &$row) { $ret[] = $row[$col_name]; } return $ret; } } if (!function_exists('chRsKey')) { function chRsKey($rs, $col) { $_rs = array(); foreach ($rs as $v) { $_rs[$v[$col]] = $v; } return $_rs; } } if (!function_exists('sortRs')) { function sortRs($rows, $key, $order = 'asc') { $sort = array(); foreach ($rows as $k => $value) { $sort[$k] = $value[$key]; } $order == 'asc' ? asort($sort) : arsort($sort); $ret = array(); foreach ($sort as $k => $value) { $ret[] = $rows[$k]; } return $ret; } } if (!function_exists('mergeRs')) { function mergeRs() { $argv = func_get_args(); $argc = count($argv); $ret = array(); foreach ($argv[0][0] as $v) { $r = $v; for ($j = 1; $j < $argc; $j++) { foreach ($argv[$j][0] as $row) { if ($v[$argv[0][1]] == $row[$argv[$j][1]]) { $r = array_merge($r, $row); break; } } } $ret[] = $r; } $allkeys = array(); foreach ($argv as $rs) { foreach (array_keys($rs[0][0]) as $key) { $allkeys[] = $key; } } foreach ($ret as &$row) { foreach ($allkeys as $key) { if (!isset($row[$key])) { $row[$key] = null; } } } return $ret; } } if (!function_exists('enableSelectDefault')) { function enableSelectDefault($return = false) { $js = '<script>var func0797986876;if(typeof(window.onload)=="function"){func0797986876=window.onload};window.onload=function(){func0797986876?func0797986876():null;var b=document.getElementsByTagName("select");var c=function(){for(var k=0;k<b.length;k++){var s=b[k];var a=s.attributes["default"]?s.attributes["default"].value:null;if(a){for(var i=0;i<s.length;i++){if(s[i].value==a){s[i].selected=true;break;}}}}};c();window["select_default"]=c;};</script>'; if ($return) { return $js; } else { echo $js; } } } class WoniuInput { public static $router; public static function route_query() { return self::$router['query']; } public static function module_name() { return self::$router['module']; } public static function method_path() { return self::$router['mpath']; } public static function method_name() { return self::$router['m']; } public static function method_prefix() { return self::$router['prefix']; } public static function controller_path() { return self::$router['cpath']; } public static function controller_name() { return self::$router['c']; } public static function folder_name() { return self::$router['folder']; } public static function controller_file() { return self::$router['file']; } public static function class_name() { return self::$router['class']; } public static function class_method_name() { return self::$router['method']; } public static function parameters($key = null) { if (!is_null($key)) { if (isset(self::$router['parameters'][$key])) { return self::$router['parameters'][$key]; } else { return null; } } else { return self::$router['parameters']; } } private static function get_x_type($rule, $method, $key) { $val = null; switch ($method) { case 'get': $val = self::get($key); break; case 'post': $val = self::post($key); break; case 'get_post': $val = self::get_post($key); break; case 'post_get': $val = self::post_get($key); break; } if (is_null(MpLoader::checkData($rule, array('check' => $val)))) { return $val; } else { return null; } } private static function get_rule_type($rule, $method, $key, $default = null) { if (!is_array($rule)) { $_rule = array($rule => 'err'); } else { $_rule = array(); foreach ($rule as $r) { $_rule[$r] = 'err'; } } $rule = array('check' => $_rule); $val = self::get_x_type($rule, $method, $key); return is_null($val) ? $default : $val; } public static function get_rule($rule, $key, $default = null) { return self::get_rule_type($rule, 'get', $key, $default); } public static function post_rule($rule, $key, $default = null) { return self::get_rule_type($rule, 'post', $key, $default); } public static function get_post_rule($rule, $key, $default = null) { return self::get_rule_type($rule, 'get_post', $key, $default); } public static function post_get_rule($rule, $key, $default = null) { return self::get_rule_type($rule, 'post_get', $key, $default); } private static function get_int_type($method, $key, $min = null, $max = null, $default = null) { $val = self::get_rule_type('int', $method, $key); $min_okay = is_null($min) || (!is_null($min) && $val >= $min); $max_okay = is_null($max) || (!is_null($max) && $val <= $max); return $min_okay && $max_okay && !is_null($val) ? $val : $default; } public static function get_int($key, $min = null, $max = null, $default = null) { return self::get_int_type('get', $key, $min, $max, $default); } public static function post_int($key, $min = null, $max = null, $default = null) { return self::get_int_type('post', $key, $min, $max, $default); } public static function get_post_int($key, $min = null, $max = null, $default = null) { return self::get_int_type('get_post', $key, $min, $max, $default); } public static function post_get_int($key, $min = null, $max = null, $default = null) { return self::get_int_type('post_get', $key, $min, $max, $default); } private static function get_date_type($method, $key, $min = null, $max = null, $default = null) { $val = self::get_rule_type('date', $method, $key); $min_okay = is_null($min) || (!is_null($min) && strtotime($val) >= strtotime($min)); $max_okay = is_null($max) || (!is_null($max) && strtotime($val) <= strtotime($max)); return $min_okay && $max_okay && !is_null($val) ? $val : $default; } public static function get_date($key, $min = null, $max = null, $default = null) { return self::get_date_type('get', $key, $min, $max, $default); } public static function post_date($key, $min = null, $max = null, $default = null) { return self::get_date_type('post', $key, $min, $max, $default); } public static function get_post_date($key, $min = null, $max = null, $default = null) { return self::get_date_type('get_post', $key, $min, $max, $default); } public static function post_get_date($key, $min = null, $max = null, $default = null) { return self::get_date_type('post_get', $key, $min, $max, $default); } private static function get_time_type($method, $key, $min = null, $max = null, $default = null) { $val = self::get_rule_type('time', $method, $key); $pre_fix = '2014-01-01 '; $min_okay = is_null($min) || (!is_null($min) && strtotime($pre_fix . $val) >= strtotime($pre_fix . $min)); $max_okay = is_null($max) || (!is_null($max) && strtotime($pre_fix . $val) <= strtotime($pre_fix . $max)); return $min_okay && $max_okay && !is_null($val) ? $val : $default; } public static function get_time($key, $min = null, $max = null, $default = null) { return self::get_time_type('get', $key, $min, $max, $default); } public static function post_time($key, $min = null, $max = null, $default = null) { return self::get_time_type('post', $key, $min, $max, $default); } public static function get_post_time($key, $min = null, $max = null, $default = null) { return self::get_time_type('get_post', $key, $min, $max, $default); } public static function post_get_time($key, $min = null, $max = null, $default = null) { return self::get_time_type('post_get', $key, $min, $max, $default); } private static function get_datetime_type($method, $key, $min = null, $max = null, $default = null) { $val = self::get_rule_type('datetime', $method, $key); $min_okay = is_null($min) || (!is_null($min) && strtotime($val) >= strtotime($min)); $max_okay = is_null($max) || (!is_null($max) && strtotime($val) <= strtotime($max)); return $min_okay && $max_okay && !is_null($val) ? $val : $default; } public static function get_datetime($key, $min = null, $max = null, $default = null) { return self::get_datetime_type('get', $key, $min, $max, $default); } public static function post_datetime($key, $min = null, $max = null, $default = null) { return self::get_datetime_type('post', $key, $min, $max, $default); } public static function get_post_datetime($key, $min = null, $max = null, $default = null) { return self::get_datetime_type('get_post', $key, $min, $max, $default); } public static function post_get_datetime($key, $min = null, $max = null, $default = null) { return self::get_datetime_type('post_get', $key, $min, $max, $default); } public static function get_post($key = null, $default = null, $xss_clean = false) { $get = self::gpcs('_GET', $key, $default); $val = $get === null ? self::gpcs('_POST', $key, $default) : $get; return $xss_clean ? self::xss_clean($val) : $val; } public static function post_get($key = null, $default = null, $xss_clean = false) { $get = self::gpcs('_POST', $key, $default); $val = $get === null ? self::gpcs('_GET', $key, $default) : $get; return $xss_clean ? self::xss_clean($val) : $val; } public static function get($key = null, $default = null, $xss_clean = false) { $val = self::gpcs('_GET', $key, $default); return $xss_clean ? self::xss_clean($val) : $val; } public static function post($key = null, $default = null, $xss_clean = false) { $val = self::gpcs('_POST', $key, $default); return $xss_clean ? self::xss_clean($val) : $val; } public static function cookie($key = null, $default = null, $xss_clean = false) { $key = systemInfo('cookie_key_prefix') . $key; return self::cookieRaw($key, $default, $xss_clean); } public static function cookieRaw($key = null, $default = null, $xss_clean = false) { $val = self::gpcs('_COOKIE', $key, $default); return $xss_clean ? self::xss_clean($val) : $val; } public static function session($key = null, $default = null) { return self::gpcs('_SESSION', $key, $default); } public static function server($key = null, $default = null) { $key = !is_null($key) ? strtoupper($key) : null; return self::gpcs('_SERVER', $key, $default); } private static function gpcs($range, $key, $default) { global $$range; if ($key === null) { return $$range; } else { $range = $$range; return isset($range[$key]) ? $range[$key] : ( $default !== null ? $default : null); } } public static function isCli() { return php_sapi_name() == 'cli'; } public static function is_cli() { return self::isCli(); } public static function is_ajax() { return (self::server('HTTP_X_REQUESTED_WITH') === 'XMLHttpRequest'); } public static function xss_clean($var) { if (is_array($var)) { foreach ($var as $key => $val) { if (is_array($val)) { $var[$key] = self::xss_clean($val); } else { $var[$key] = self::xss_clean0($val); } } } elseif (is_string($var)) { $var = self::xss_clean0($var); } return $var; } private static function xss_clean0($data) { $data = str_replace(array('&amp;', '&lt;', '&gt;'), array('&amp;amp;', '&amp;lt;', '&amp;gt;'), $data); $data = preg_replace('/(&#*\w+)[\x00-\x20]+;/u', '$1;', $data); $data = preg_replace('/(&#x*[0-9A-F]+);*/iu', '$1;', $data); $data = html_entity_decode($data, ENT_COMPAT, 'UTF-8'); $data = preg_replace('#(<[^>]+?[\x00-\x20"\'])(?:on|xmlns)[^>]*+>#iu', '$1>', $data); $data = preg_replace('#([a-z]*)[\x00-\x20]*=[\x00-\x20]*([`\'"]*)[\x00-\x20]*j[\x00-\x20]*a[\x00-\x20]*v[\x00-\x20]*a[\x00-\x20]*s[\x00-\x20]*c[\x00-\x20]*r[\x00-\x20]*i[\x00-\x20]*p[\x00-\x20]*t[\x00-\x20]*:#iu', '$1=$2nojavascript...', $data); $data = preg_replace('#([a-z]*)[\x00-\x20]*=([\'"]*)[\x00-\x20]*v[\x00-\x20]*b[\x00-\x20]*s[\x00-\x20]*c[\x00-\x20]*r[\x00-\x20]*i[\x00-\x20]*p[\x00-\x20]*t[\x00-\x20]*:#iu', '$1=$2novbscript...', $data); $data = preg_replace('#([a-z]*)[\x00-\x20]*=([\'"]*)[\x00-\x20]*-moz-binding[\x00-\x20]*:#u', '$1=$2nomozbinding...', $data); $data = preg_replace('#(<[^>]+?)style[\x00-\x20]*=[\x00-\x20]*[`\'"]*.*?expression[\x00-\x20]*\([^>]*+>#i', '$1>', $data); $data = preg_replace('#(<[^>]+?)style[\x00-\x20]*=[\x00-\x20]*[`\'"]*.*?behaviour[\x00-\x20]*\([^>]*+>#i', '$1>', $data); $data = preg_replace('#(<[^>]+?)style[\x00-\x20]*=[\x00-\x20]*[`\'"]*.*?s[\x00-\x20]*c[\x00-\x20]*r[\x00-\x20]*i[\x00-\x20]*p[\x00-\x20]*t[\x00-\x20]*:*[^>]*+>#iu', '$1>', $data); $data = preg_replace('#</*\w+:\w[^>]*+>#i', '', $data); do { $old_data = $data; $data = preg_replace('#</*(?:applet|b(?:ase|gsound|link)|embed|iframe|frame(?:set)?|i(?:frame|layer)|l(?:ayer|ink)|meta|object|s(?:cript|tyle)|title|xml)[^>]*+>#i', '', $data); } while ($old_data !== $data); return $data; } } class MpInput extends WoniuInput{} class WoniuRouter { public static function loadClass() { $system = systemInfo(); $methodInfo = self::parseURI(); MpLoader::classAutoloadRegister(); if (file_exists($methodInfo['file'])) { include $methodInfo['file']; MpInput::$router = $methodInfo; if (!MpInput::isCli()) { self::checkSession(); } $class = new $methodInfo['class'](); if (method_exists($class, $methodInfo['method'])) { $methodInfo['parameters'] = is_array($methodInfo['parameters']) ? $methodInfo['parameters'] : array(); if (method_exists($class, '__output')) { ob_start(); call_user_func_array(array($class, $methodInfo['method']), $methodInfo['parameters']); $buffer = ob_get_contents(); @ob_end_clean(); call_user_func_array(array($class, '__output'), array($buffer)); } else { call_user_func_array(array($class, $methodInfo['method']), $methodInfo['parameters']); } } else { trigger404($methodInfo['class'] . ':' . $methodInfo['method'] . ' not found.'); } } else { if ($system['debug']) { trigger404('file:' . $methodInfo['file'] . ' not found.'); } else { trigger404(); } } } private static function parseURI() { $pathinfo_query = self::getQueryStr(); $router['module'] = self::getHmvcModuleName($pathinfo_query); $pathinfo_query = self::checkHmvc($pathinfo_query); $pathinfo_query = self::checkRouter($pathinfo_query); $router['query'] = $pathinfo_query; $system = systemInfo(); $class_method = $system['default_controller'] . '.' . $system['default_controller_method']; if (!empty($pathinfo_query)) { $pathinfo_query = ltrim($pathinfo_query, '/'); $requests = explode("/", $pathinfo_query); preg_match('/[^&]+(?:\.[^&]+)+=?/', $requests[0]) ? $class_method = $requests[0] : null; if (strstr($class_method, '&') !== false) { $cm = explode('&', $class_method); $class_method = trim($cm[0], "="); } } $class_method = trim($class_method, "="); $pathinfo_query = str_replace($class_method, '', $pathinfo_query); $pathinfo_query_parameters = explode("&", $pathinfo_query); $pathinfo_query_parameters_str = !empty($pathinfo_query_parameters[0]) ? $pathinfo_query_parameters[0] : ''; $pathinfo_query_parameters_str && $pathinfo_query_parameters_str{0} === '/' ? $pathinfo_query_parameters_str = substr($pathinfo_query_parameters_str, 1) : ''; $origin_class_method = $class_method; $class_method = explode(".", $class_method); $method = end($class_method); $method = $system['controller_method_prefix'] . ($system['controller_method_ucfirst'] ? ucfirst($method) : $method); unset($class_method[count($class_method) - 1]); $file = $system['controller_folder'] . DIRECTORY_SEPARATOR . implode(DIRECTORY_SEPARATOR, $class_method) . $system['controller_file_subfix']; $class = $class_method[count($class_method) - 1]; $parameters = explode("/", $pathinfo_query_parameters_str); if (count($parameters) === 1 && empty($parameters[0])) { $parameters = array(); } foreach ($parameters as $key => $value) { $parameters[$key] = urldecode($value); } $info = array('file' => $file, 'class' => ucfirst($class), 'method' => str_replace('.', '/', $method), 'parameters' => $parameters); $path = explode('.', $origin_class_method); $router['mpath'] = $origin_class_method; $router['m'] = $path[count($path) - 1]; $router['c'] = ''; if (count($path) > 1) { $router['c'] = $path[count($path) - 2]; } $router['prefix'] = $system['controller_method_prefix']; unset($path[count($path) - 1]); $router['cpath'] = empty($path) ? '' : implode('.', $path); $router['folder'] = ''; if (count($path) > 1) { unset($path[count($path) - 1]); $router['folder'] = implode('.', $path); } return $router + $info; } private static function getQueryStr() { $system = systemInfo(); if (MpInput::isCli()) { global $argv; $pathinfo_query = isset($argv[1]) ? $argv[1] : ''; } else { $pathinfo = @parse_url($_SERVER['REQUEST_URI']); if (empty($pathinfo)) { if ($system['debug']) { trigger404('request parse error:' . $_SERVER['REQUEST_URI']); } else { trigger404(); } } $query_str = empty($pathinfo['query']) ? '' : $pathinfo['query']; $pathinfo_query = empty($_SERVER['PATH_INFO']) ? $query_str : $_SERVER['PATH_INFO'] . '&' . $query_str; } if ($pathinfo_query) { $pathinfo_query = trim($pathinfo_query, '/&'); } $pq = $_pq = array(); $_pq = explode('&', $pathinfo_query); foreach ($_pq as $value) { $p = explode('=', $value); if (isset($p[0])) { $p[0] = urldecode($p[0]); } $pq[] = implode('=', $p); } $pathinfo_query = implode('&', $pq); return $pathinfo_query; } private static function checkSession() { $system = systemInfo(); $common_config = $system['session_handle']['common']; ini_set('session.auto_start', 0); ini_set('session.gc_probability', 1); ini_set('session.gc_divisor', 100); ini_set('session.gc_maxlifetime', $common_config['lifetime']); ini_set('session.referer_check', ''); ini_set('session.entropy_file', '/dev/urandom'); ini_set('session.entropy_length', 16); ini_set('session.use_cookies', 1); ini_set('session.use_only_cookies', 1); ini_set('session.use_trans_sid', 0); ini_set('session.hash_function', 1); ini_set('session.hash_bits_per_character', 5); session_cache_limiter('nocache'); session_set_cookie_params( $common_config['lifetime'], $common_config['cookie_path'], preg_match('/^[^\\.]+$/', MpInput::server('HTTP_HOST')) ? null : $common_config['cookie_domain'] ); session_name($common_config['session_name']); register_shutdown_function('session_write_close'); if (!empty($system['session_handle']['handle']) && isset($system['session_handle'][$system['session_handle']['handle']])) { $driver = $system['session_handle']['handle']; $config = $system['session_handle']; $handle = ucfirst($driver) . 'SessionHandle'; if (class_exists($handle, FALSE)) { $session = new $handle(); $session->start($config); } } if ($common_config['autostart']) { sessionStart(); } } private static function checkRouter($pathinfo_query) { $system = systemInfo(); if (is_array($system['route'])) { foreach ($system['route'] as $reg => $replace) { if (preg_match($reg, $pathinfo_query)) { $pathinfo_query = preg_replace($reg, $replace, $pathinfo_query); break; } } } return $pathinfo_query; } private static function checkHmvc($pathinfo_query) { if ($_module = self::getHmvcModuleName($pathinfo_query)) { $_system = systemInfo(); self::switchHmvcConfig($_system['hmvc_modules'][$_module]); return preg_replace('|^' . $_module . '[\./&]?|', '', $pathinfo_query); } return $pathinfo_query; } private static function getHmvcModuleName($pathinfo_query) { $_module = current(explode('&', $pathinfo_query)); $_module = current(explode('/', $_module)); $_system = systemInfo(); if (isset($_system['hmvc_modules'][$_module])) { return $_module; } else { return ''; } } public static function switchHmvcConfig($hmvc_folder) { $_system = $system = systemInfo(); $module = $_system['hmvc_folder'] . '/' . $hmvc_folder . '/hmvc.php'; include($module); foreach (array('model_folder', 'view_folder', 'library_folder', 'helper_folder', 'helper_file_autoload', 'library_file_autoload', 'models_file_autoload') as $folder) { if (!is_array($_system[$folder])) { $_system[$folder] = array($_system[$folder]); } if (!is_array($system[$folder])) { $system[$folder] = array($system[$folder]); } $system[$folder] = array_merge($system[$folder], $_system[$folder]); } self::setConfig($system); } public static function setConfig($system) { MpLoader::$system = $system; } } class MpRouter extends WoniuRouter{} class WoniuLoader { public $model, $lib, $router, $db, $input, $view_vars = array(), $cache, $rule; private static $helper_files = array(), $files = array(); private static $instance, $config = array(); public static $system; public function __construct() { $system = systemInfo(); date_default_timezone_set($system['default_timezone']); $this->registerErrorHandle(); $this->router = MpInput::$router; $this->input = new MpInput(); $this->model = new WoniuModelLoader(); $this->lib = new WoniuLibLoader(); if (class_exists('MpRule', FALSE)) { $this->rule = new MpRule(); } if (class_exists('phpFastCache', false)) { $this->cache = phpFastCache::getInstance($system['cache_config']['storage'], $system['cache_config']); } if ($system['autoload_db']) { $this->database(); } stripslashes_all(); } public function registerErrorHandle() { $system = systemInfo(); error_reporting(E_ALL); if ($system['debug']) { ini_set('display_errors', true); } else { ini_set('display_errors', FALSE); } if ($system['error_manage'] || $system['log_error']) { set_exception_handler('woniu_exception_handler'); set_error_handler('woniu_error_handler'); register_shutdown_function('woniu_fatal_handler'); } } public static function config($config_group, $key = null) { if (!is_null($key)) { return isset(self::$config[$config_group][$key]) ? self::$config[$config_group][$key] : null; } else { return isset(self::$config[$config_group]) ? self::$config[$config_group] : null; } } public function &database($config = NULL, $is_return = false, $force_new_conn = false) { $woniu_db = self::$system['db']; $db_cfg_key = $woniu_db['active_group']; if (is_string($config) && !empty($config)) { $db_cfg = $woniu_db[$config]; } elseif (is_array($config)) { $db_cfg = $config; } else { $db_cfg = $woniu_db[$db_cfg_key]; } if ($is_return) { return WoniuDB::getInstance($db_cfg, $force_new_conn); } else { if ($force_new_conn || !is_object($this->db) || !is_null($config)) { $this->db = WoniuDB::getInstance($db_cfg, $force_new_conn); } return $this->db; } } public function setConfig($key, $val) { self::$config[$key] = $val; } public static function helper($file_name, $is_config = true) { $system = systemInfo(); $helper_folders = $system['helper_folder']; if (!is_array($helper_folders)) { $helper_folders = array($helper_folders); } $count = count($helper_folders); foreach ($helper_folders as $k => $helper_folder) { $filename = $helper_folder . DIRECTORY_SEPARATOR . $file_name . $system['helper_file_subfix']; $filename = convertPath($filename); if (in_array($filename, self::$helper_files)) { return; } if (file_exists($filename)) { self::$helper_files[] = $filename; if ($is_config) { $before_vars = array_keys(get_defined_vars()); $before_vars[] = 'before_vars'; } include($filename); if ($is_config) { $vars = get_defined_vars(); $all_vars = array_keys($vars); foreach ($all_vars as $key) { if (!in_array($key, $before_vars) && isset($vars[$key])) { self::$config[$key] = $vars[$key]; } } } break; } else { if (($count - 1) == $k) { trigger404($filename . ' not found.'); } } } } public static function lib($file_name, $alias_name = null, $new = true) { $system = systemInfo(); $classname = $file_name; if (strstr($file_name, '/') !== false || strstr($file_name, "\\") !== false) { $classname = basename($file_name); } if (!$alias_name) { $alias_name = $classname; } $library_folders = $system['library_folder']; if (!is_array($library_folders)) { $library_folders = array($library_folders); } $count = count($library_folders); foreach ($library_folders as $key => $library_folder) { $filepath = $library_folder . DIRECTORY_SEPARATOR . $file_name . $system['library_file_subfix']; if (in_array($alias_name, array_keys(WoniuLibLoader::$lib_files))) { return WoniuLibLoader::$lib_files[$alias_name]; } else { foreach (WoniuLibLoader::$lib_files as $aname => $obj) { if (strtolower(get_class($obj)) === strtolower($classname)) { return WoniuLibLoader::$lib_files[$alias_name] = WoniuLibLoader::$lib_files[$aname]; } } } if (file_exists($filepath)) { self::includeOnce($filepath); if (class_exists($classname, FALSE)) { if ($new) { return WoniuLibLoader::$lib_files[$alias_name] = new $classname(); } else { return null; } } else { if ($key == $count - 1) { trigger404('Library Class:' . $classname . ' not found.'); } } } else { if ($key == $count - 1) { trigger404($filepath . ' not found.'); } } } } public static function model($file_name, $alias_name = null) { $system = systemInfo(); $classname = $file_name; if (strstr($file_name, '/') !== false || strstr($file_name, "\\") !== false) { $classname = basename($file_name); } if (!$alias_name) { $alias_name = $classname; } $model_folders = $system['model_folder']; if (!is_array($model_folders)) { $model_folders = array($model_folders); } $count = count($model_folders); foreach ($model_folders as $key => $model_folder) { $filepath = $model_folder . DIRECTORY_SEPARATOR . $file_name . $system['model_file_subfix']; if (in_array($alias_name, array_keys(WoniuModelLoader::$model_files))) { return WoniuModelLoader::$model_files[$alias_name]; } else { foreach (WoniuModelLoader::$model_files as &$obj) { if (strtolower(get_class($obj)) == strtolower($classname)) { return WoniuModelLoader::$model_files[$alias_name] = $obj; } } } if (file_exists($filepath)) { self::includeOnce($filepath); if (class_exists($classname, FALSE)) { return WoniuModelLoader::$model_files[$alias_name] = new $classname(); } else { if ($key == $count - 1) { trigger404('Model Class:' . $classname . ' not found.'); } } } else { if ($key == $count - 1) { trigger404($filepath . ' not  found.'); } } } } public function view($view_name, $data = null, $return = false) { if (is_array($data)) { $this->view_vars = array_merge($this->view_vars, $data); extract($this->view_vars); } elseif (is_array($this->view_vars) && !empty($this->view_vars)) { extract($this->view_vars); } $system = systemInfo(); $view_folders = $system['view_folder']; if (!is_array($view_folders)) { $view_folders = array($view_folders); } $count = count($view_folders); $i = 0; if (stripos($view_name, ':') !== false) { $info = explode(':', $view_name); $path_key = current($info); $view_name = next($info); if (!isset($system['view_folder'][$path_key])) { trigger404('error key[' . $path_key . '] of $system["view_folder"]'); } else { $dir = $system['view_folder'][$path_key]; $view_path = $dir . DIRECTORY_SEPARATOR . $view_name . $system['view_file_subfix']; if (file_exists($view_path)) { if ($return) { @ob_start(); include $view_path; $html = ob_get_contents(); @ob_end_clean(); return $html; } else { include $view_path; return; } } else { trigger404('View:' . $view_path . ' not found'); } } } else { $view_path = ''; foreach ($view_folders as $dir) { $view_path = $dir . DIRECTORY_SEPARATOR . $view_name . $system['view_file_subfix']; if (file_exists($view_path)) { if ($return) { @ob_start(); include $view_path; $html = ob_get_contents(); @ob_end_clean(); return $html; } else { include $view_path; return; } } elseif (($i++) == $count - 1) { trigger404('View:' . $view_path . ' not found'); } } } } public static function classAutoloadRegister() { $found = false; $__autoload_found = false; $auto_functions = spl_autoload_functions(); if (is_array($auto_functions)) { foreach ($auto_functions as $func) { if (is_array($func) && $func[0] == 'MpLoader' && $func[1] == 'classAutoloader') { $found = TRUE; break; } } foreach ($auto_functions as $func) { if (!is_array($func) && $func == '__autoload') { $__autoload_found = TRUE; break; } } } if (function_exists('__autoload') && !$__autoload_found) { spl_autoload_register('__autoload'); } if (!$found) { spl_autoload_register(array('MpLoader', 'classAutoloader')); } } public static function classAutoloader($clazzName) { $system = systemInfo(); $library_folders = $system['library_folder']; if (!is_array($library_folders)) { $library_folders = array($library_folders); } foreach ($library_folders as $library_folder) { $library = $library_folder . DIRECTORY_SEPARATOR . $clazzName . $system['library_file_subfix']; if (file_exists($library)) { self::includeOnce($library); } else { if (is_dir($library_folder)) { $dir = dir($library_folder); $found = false; while (($file = $dir->read()) !== false) { if ($file == '.' || $file == '..' || is_file($library_folder . DIRECTORY_SEPARATOR . $file)) { continue; } $path = truepath($library_folder) . DIRECTORY_SEPARATOR . $file . DIRECTORY_SEPARATOR . $clazzName . $system['library_file_subfix']; if (file_exists($path)) { self::includeOnce($path); $found = true; break; } } if ($found) { break; } } } } } public static function checkUserLoader() { global $system; if (!class_exists('MpLoaderPlus', FALSE)) { if (!empty($system['my_loader'])) { self::includeOnce($system['my_loader']); $clazz = basename($system['my_loader'], '.class.php'); if (class_exists($clazz, FALSE)) { eval('class MpLoaderPlus extends ' . $clazz . '{}'); } else { eval('class MpLoaderPlus extends MpLoader{}'); } } else { eval('class MpLoaderPlus extends MpLoader{}'); } } } public static function instance($renew = null, $hmvc_module_floder = null) { $default = systemInfo(); if (!empty($hmvc_module_floder)) { MpRouter::switchHmvcConfig($hmvc_module_floder); } self::classAutoloadRegister(); WoniuController::instance(); $renew = is_bool($renew) && $renew === true; $ret = empty(self::$instance) || $renew ? self::$instance = new self() : self::$instance; MpRouter::setConfig($default); return $ret; } public static function view_path($view_name, $path_key = 0) { if (stripos($view_name, ':') !== false) { $info = explode(':', $view_name); $path_key = current($info); $view_name = next($info); } $system = systemInfo(); if (!is_array($system['view_folder'])) { $system['view_folder'] = array($system['view_folder']); } if (!isset($system['view_folder'][$path_key])) { trigger404('error key[' . $path_key . '] of $system["view_folder"]'); } $dir = $system['view_folder'][$path_key]; $view_path = $dir . DIRECTORY_SEPARATOR . $view_name . $system['view_file_subfix']; return truepath($view_path); } public function ajax_echo($code, $tip = null, $data = null, $jsonp_callback = null, $is_exit = true) { $str = json_encode(array('code' => $code, 'tip' => is_null($tip) ? '' : $tip, 'data' => is_null($data) ? '' : $data)); if (!empty($jsonp_callback)) { echo $jsonp_callback . "($str)"; } else { echo $str; } if ($is_exit) { exit(); } } public static function xml_echo($xml, $is_exit = true) { header('Content-type:text/xml;charset=utf-8'); echo $xml; if ($is_exit) { exit(); } } public function redirect($url, $msg = null, $time = 3, $view = null) { $time = intval($time) ? intval($time) : 3; if (empty($msg)) { header('Location:' . $url); } else { header("refresh:{$time};url={$url}"); header("Content-type: text/html; charset=utf-8"); if (empty($view)) { echo $msg; } else { $this->view($view, array('msg' => $msg, 'url' => $url, 'time' => $time)); } } exit(); } public function message($msg, $url = null, $time = 3, $view = null) { $time = intval($time) ? intval($time) : 3; if (!empty($url)) { header("refresh:{$time};url={$url}"); } header("Content-type: text/html; charset=utf-8"); $view = is_null($view) ? systemInfo('message_page_view') : $view; if (!empty($view)) { $this->view($view, array('msg' => $msg, 'url' => $url, 'time' => $time)); } else { echo $msg; } exit(); } public static function setCookieRaw($key, $value, $life = null, $path = '/', $domian = null, $http_only = false) { header('P3P: CP="CURa ADMa DEVa PSAo PSDo OUR BUS UNI PUR INT DEM STA PRE COM NAV OTC NOI DSP COR"'); if (!is_null($domian)) { $auto_domain = $domian; } else { $host = MpInput::server('HTTP_HOST'); $is_ip = preg_match('/^((25[0-5]|2[0-4]\d|[01]?\d\d?)\.){3}(25[0-5]|2[0-4]\d|[01]?\d\d?)$/', $host); $not_regular_domain = preg_match('/^[^\\.]+$/', $host); if ($is_ip) { $auto_domain = $host; } elseif ($not_regular_domain) { $auto_domain = NULL; } else { $auto_domain = '.' . $host; } } setcookie($key, $value, ($life ? $life + time() : null), $path, $auto_domain, (MpInput::server('SERVER_PORT') == 443 ? 1 : 0), $http_only); $_COOKIE[$key] = $value; } public static function setCookie($key, $value, $life = null, $path = '/', $domian = null, $http_only = false) { $key = systemInfo('cookie_key_prefix') . $key; return self::setCookieRaw($key, $value, $life, $path, $domian, $http_only); } public static function page($total, $page, $pagesize, $url, $order = array(1, 2, 3, 4, 5, 6), $a_count = 10) { $a_num = $a_count; $first = '首页'; $last = '尾页'; $pre = '上页'; $next = '下页'; $a_num = $a_num % 2 == 0 ? $a_num + 1 : $a_num; $pages = ceil($total / $pagesize); $curpage = intval($page) ? intval($page) : 1; $curpage = $curpage > $pages || $curpage <= 0 ? 1 : $curpage; $body = '<span class="page_body">'; $prefix = ''; $subfix = ''; $start = $curpage - ($a_num - 1) / 2; $end = $curpage + ($a_num - 1) / 2; $start = $start <= 0 ? 1 : $start; $end = $end > $pages ? $pages : $end; if ($pages >= $a_num) { if ($curpage <= ($a_num - 1) / 2) { $end = $a_num; } if ($end - $curpage <= ($a_num - 1) / 2) { $start-=floor($a_num / 2) - ($end - $curpage); } } for ($i = $start; $i <= $end; $i++) { if ($i == $curpage) { $body.='<a class="page_cur_page" href="javascript:void(0);"><b>' . $i . '</b></a>'; } else { $body.='<a href="' . str_replace('{page}', $i, $url) . '">' . $i . '</a>'; } } $body.='</span>'; $prefix = ($curpage == 1 ? '' : '<span class="page_bar_prefix"><a href="' . str_replace('{page}', 1, $url) . '">' . $first . '</a><a href="' . str_replace('{page}', $curpage - 1, $url) . '">' . $pre . '</a></span>'); $subfix = ($curpage == $pages ? '' : '<span class="page_bar_subfix"><a href="' . str_replace('{page}', $curpage + 1, $url) . '">' . $next . '</a><a href="' . str_replace('{page}', $pages, $url) . '">' . $last . '</a></span>'); $info = "<span class=\"page_cur\">第{$curpage}/{$pages}页</span>"; $id="gsd09fhas9d".rand(100000, 1000000); $go = '<script>function ekup(){if(event.keyCode==13){clkyup();}}function clkyup(){var num=document.getElementById(\''.$id.'\').value;if(!/^\d+$/.test(num)||num<=0||num>' . $pages . '){alert(\'请输入正确页码!\');return;};location=\'' . addslashes($url) . '\'.replace(/\\{page\\}/,document.getElementById(\''.$id.'\').value);}</script><span class="page_input_num"><input onkeyup="ekup()" type="text" id="'.$id.'" style="width:40px;vertical-align:text-baseline;padding:0 2px;font-size:10px;border:1px solid gray;"/></span><span class="page_btn_go" onclick="clkyup();" style="cursor:pointer;text-decoration:underline;">转到</span>'; $total = "<span class=\"page_total\">共{$total}条</span>"; $pagination = array( $total, $info, $prefix, $body, $subfix, $go ); $output = array(); if (is_null($order)) { $order = array(1, 2, 3, 4, 5, 6); } foreach ($order as $key) { if (isset($pagination[$key - 1])) { $output[] = $pagination[$key - 1]; } } return $pages>1?implode("", $output):''; } public static function readData(Array $map, $source_data = null) { $data = array(); $formdata = is_null($source_data) ? MpInput::post() : $source_data; foreach ($formdata as $form_key => $val) { if (isset($map[$form_key])) { $data[$map[$form_key]] = $val; } } return $data; } public static function checkData(Array $rule, Array $data = NULL, &$return_data = NULL, $db = null) { if (is_null($data)) { $data = MpInput::post(); } $return_data = $data; foreach ($rule as $col => $val) { foreach ($val as $_rule => $msg) { if (stripos($_rule, 'default[') === 0) { unset($rule[$col][$_rule]); $matches = self::getCheckRuleInfo($_rule); $_r = $matches[1]; $args = $matches[2]; $return_data[$col] = isset($args[0]) ? $args[0] : ''; } } } $unset_keys = array(); foreach ($rule as $col => $val) { if (!isset($return_data[$col])) { $return_data[$col] = ''; $unset_keys[] = $col; } } self::checkSetData('set', $rule, $return_data); foreach ($rule as $col => $val) { foreach ($val as $_rule => $msg) { if (!empty($_rule)) { if (empty($return_data[$col]) && isset($val['optional'])) { break; } else { $matches = self::getCheckRuleInfo($_rule); $_r = $matches[1]; $args = $matches[2]; if ($_r == 'set' || $_r == 'set_post' || $_r == 'optional') { continue; } if (!self::checkRule($_rule, $return_data[$col], $return_data, $db)) { foreach ($unset_keys as $key) { unset($return_data[$key]); } return $msg; } } } } } self::checkSetData('set_post', $rule, $return_data); foreach ($unset_keys as $key) { unset($return_data[$key]); } return NULL; } private static function checkSetData($type, Array $rule, &$return_data = NULL) { foreach ($rule as $col => $val) { foreach (array_keys($val) as $_rule) { if (!empty($_rule)) { if (!isset($return_data[$col])) { if (isset($_rule['optional'])) { break; } else { $return_data[$col] = ''; } } $matches = self::getCheckRuleInfo($_rule); $_r = $matches[1]; $args = $matches[2]; if ($_r == $type) { $_v = $return_data[$col]; $_args = array($_v, $return_data); foreach ($args as $func) { if (function_exists($func)) { $reflection = new ReflectionFunction($func); if ($reflection->isInternal()) { $_args = array($_v); } } $_v = self::callFunc($func, $_args); } $return_data[$col] = $_v; } } } } } private static function getCheckRuleInfo($_rule) { $matches = array(); preg_match('|([^\[]+)(?:\[(.*)\](.?))?|', $_rule, $matches); $matches[1] = isset($matches[1]) ? $matches[1] : ''; $matches[3] = !empty($matches[3]) ? $matches[3] : ','; if ($matches[1] != 'reg') { $matches[2] = isset($matches[2]) ? explode($matches[3], $matches[2]) : array(); } else { $matches[2] = isset($matches[2]) ? array($matches[2]) : array(); } return $matches; } public static function callFunc($func, $args) { if (is_array($func)) { return self::callMethod($func, $args); } elseif (function_exists($func)) { return call_user_func_array($func, $args); } elseif (stripos($func, '::')) { $_func = explode('::', $func); return self::callMethod($_func, $args); } return null; } private static function callMethod($_func, $args) { $class = $_func[0]; $method = $_func[1]; if (is_object($class)) { $class = new ReflectionClass(get_class($class)); } else { $class = new ReflectionClass($class); } $obj = $class->newInstanceArgs(); $method = $class->getMethod($method); $method->setAccessible(true); return $method->invokeArgs($obj, $args); } private static function checkRule($_rule, $val, $data, $db = null) { if (!$db) { $db = MpLoader::instance()->database(); } $matches = self::getCheckRuleInfo($_rule); $_rule = $matches[1]; $args = $matches[2]; switch ($_rule) { case 'required': return !empty($val); case 'match': return isset($args[0]) && isset($data[$args[0]]) ? $val && ($val == $data[$args[0]]) : false; case 'equal': return isset($args[0]) ? $val && ($val == $args[0]) : false; case 'enum': return in_array($val, $args); case 'unique': if (!$val || !count($args)) { return false; } $_info = explode('.', $args[0]); if (count($_info) != 2) { return false; } $table = $_info[0]; $col = $_info[1]; if (isset($args[1])) { $_id_info = explode(':', $args[1]); if (count($_id_info) != 2) { return false; } $id_col = $_id_info[0]; $id = $_id_info[1]; $id = stripos($id, '#') === 0 ? MpInput::get_post(substr($id, 1)) : $id; $where = array($col => $val, "$id_col <>" => $id); } else { $where = array($col => $val); } return !$db->where($where)->from($table)->count_all_results(); case 'exists': if (!$val || !count($args)) { return false; } $_info = explode('.', $args[0]); if (count($_info) != 2) { return false; } $table = $_info[0]; $col = $_info[1]; $where = array($col => $val); if (count($args) > 1) { foreach (array_slice($args, 1) as $v) { $_id_info = explode(':', $v); if (count($_id_info) != 2) { continue; } $id_col = $_id_info[0]; $id = $_id_info[1]; $id = stripos($id, '#') === 0 ? MpInput::get_post(substr($id, 1)) : $id; $where[$id_col] = $id; } } return $db->where($where)->from($table)->count_all_results(); case 'min_len': return isset($args[0]) ? (mb_strlen($val, 'UTF-8') >= intval($args[0])) : false; case 'max_len': return isset($args[0]) ? (mb_strlen($val, 'UTF-8') <= intval($args[0])) : false; case 'range_len': return count($args) == 2 ? (mb_strlen($val, 'UTF-8') >= intval($args[0])) && (mb_strlen($val, 'UTF-8') <= intval($args[1])) : false; case 'len': return isset($args[0]) ? (mb_strlen($val, 'UTF-8') == intval($args[0])) : false; case 'min': return isset($args[0]) && is_numeric($val) ? $val >= $args[0] : false; case 'max': return isset($args[0]) && is_numeric($val) ? $val <= $args[0] : false; case 'range': return (count($args) == 2) && is_numeric($val) ? $val >= $args[0] && $val <= $args[1] : false; case 'alpha': return !preg_match('/[^A-Za-z]+/', $val); case 'alpha_num': return !preg_match('/[^A-Za-z0-9]+/', $val); case 'alpha_dash': return !preg_match('/[^A-Za-z0-9_-]+/', $val); case 'alpha_start': return preg_match('/^[A-Za-z]+/', $val); case 'num': return !preg_match('/[^0-9]+/', $val); case 'int': return preg_match('/^([-+]?[1-9]\d*|0)$/', $val); case 'float': return preg_match('/^([1-9]\d*|0)\.\d+$/', $val); case 'numeric': return is_numeric($val); case 'natural': return preg_match('/^([1-9]\d*|0)$/', $val); case 'natural_no_zero': return preg_match('/^[1-9]\d*$/', $val); case 'email': $args[0] = isset($args[0]) && $args[0] == 'true' ? TRUE : false; return !empty($val) ? preg_match('/^\w+([-+.]\w+)*@\w+([-.]\w+)*\.\w+([-.]\w+)*$/', $val) : $args[0]; case 'url': $args[0] = isset($args[0]) && $args[0] == 'true' ? TRUE : false; return !empty($val) ? preg_match('/^http[s]?:\/\/[A-Za-z0-9]+\.[A-Za-z0-9]+[\/=\?%\-&_~`@[\]\':+!]*([^<>\"])*$/', $val) : $args[0]; case 'qq': $args[0] = isset($args[0]) && $args[0] == 'true' ? TRUE : false; return !empty($val) ? preg_match('/^[1-9][0-9]{4,}$/', $val) : $args[0]; case 'phone': $args[0] = isset($args[0]) && $args[0] == 'true' ? TRUE : false; return !empty($val) ? preg_match('/^(?:\d{3}-?\d{8}|\d{4}-?\d{7})$/', $val) : $args[0]; case 'mobile': $args[0] = isset($args[0]) && $args[0] == 'true' ? TRUE : false; return !empty($val) ? preg_match('/^(((13[0-9]{1})|(15[0-9]{1})|(18[0-9]{1})|(14[0-9]{1}))+\d{8})$/', $val) : $args[0]; case 'zipcode': $args[0] = isset($args[0]) && $args[0] == 'true' ? TRUE : false; return !empty($val) ? preg_match('/^[1-9]\d{5}(?!\d)$/', $val) : $args[0]; case 'idcard': $args[0] = isset($args[0]) && $args[0] == 'true' ? TRUE : false; return !empty($val) ? preg_match('/^\d{14}(\d{4}|(\d{3}[xX])|\d{1})$/', $val) : $args[0]; case 'ip': $args[0] = isset($args[0]) && $args[0] == 'true' ? TRUE : false; return !empty($val) ? preg_match('/^((25[0-5]|2[0-4]\d|[01]?\d\d?)\.){3}(25[0-5]|2[0-4]\d|[01]?\d\d?)$/', $val) : $args[0]; case 'chs': $count = implode(',', array_slice($args, 1, 2)); $count = empty($count) ? '1,' : $count; $can_empty = isset($args[0]) && $args[0] == 'true'; return !empty($val) ? preg_match('/^[\x{4e00}-\x{9fa5}]{' . $count . '}$/u', $val) : $can_empty; case 'date': $args[0] = isset($args[0]) && $args[0] == 'true' ? TRUE : false; return !empty($val) ? preg_match('/^[0-9]{4}-(((0[13578]|(10|12))-(0[1-9]|[1-2][0-9]|3[0-1]))|(02-(0[1-9]|[1-2][0-9]))|((0[469]|11)-(0[1-9]|[1-2][0-9]|30)))$/', $val) : $args[0]; case 'time': $args[0] = isset($args[0]) && $args[0] == 'true' ? TRUE : false; return !empty($val) ? preg_match('/^(([0-1][0-9])|([2][0-3])):([0-5][0-9])(:([0-5][0-9]))$/', $val) : $args[0]; case 'datetime': $args[0] = isset($args[0]) && $args[0] == 'true' ? TRUE : false; return !empty($val) ? preg_match('/^[0-9]{4}-(((0[13578]|(10|12))-(0[1-9]|[1-2][0-9]|3[0-1]))|(02-(0[1-9]|[1-2][0-9]))|((0[469]|11)-(0[1-9]|[1-2][0-9]|30))) (([0-1][0-9])|([2][0-3])):([0-5][0-9])(:([0-5][0-9]))$/', $val) : $args[0]; case 'reg': return !empty($args[0]) ? preg_match($args[0], $val) : false; case 'set': case 'set_post': return true; default: $_args = array_merge(array($val, $data), $args); $matches = self::getCheckRuleInfo($_rule); $func = $matches[1]; $args = $matches[2]; if (function_exists($func)) { $reflection = new ReflectionFunction($func); if ($reflection->isInternal()) { $_args = isset($_args[0]) ? array($_args[0]) : array(); } } return self::callFunc($_rule, $_args); } return false; } public static function includeOnce($file_path) { $key = md5(truepath(convertPath($file_path))); if (!isset(self::$files[$key])) { include $file_path; self::$files[$key] = 1; } } } class MpLoader extends WoniuLoader{} MpLoader::checkUserLoader(); class WoniuModelLoader { public static $model_files = array(); function __get($classname) { if (isset(self::$model_files[$classname])) { return self::$model_files[$classname]; } else { return MpLoader::model($classname); } } } class WoniuLibLoader { public static $lib_files = array(); function __get($classname) { if (isset(self::$lib_files[$classname])) { return self::$lib_files[$classname]; } else { return MpLoader::lib($classname); } } } class WoniuController extends MpLoaderPlus { private static $instance; public function __construct() { self::$instance = &$this; $this->autoload(); parent::__construct(); } private function autoload() { $system = systemInfo(); $autoload_helper = $system['helper_file_autoload']; $autoload_library = $system['library_file_autoload']; $autoload_models = $system['models_file_autoload']; foreach ($autoload_helper as $val) { if (is_array($val)) { $key = key($val); $val = $val[$key]; $this->helper($key,$val); } else { $this->helper($val); } } foreach ($autoload_library as $key => $val) { if (is_array($val)) { $new = isset($val['new']) ? $val['new'] : true; $key = key($val); $val = $val[$key]; $this->lib($key, $val, $new); } else { $this->lib($val); } } foreach ($autoload_models as $key => $val) { if (is_array($val)) { $key = key($val); $val = $val[$key]; $this->model($key, $val); } else { $this->model($val); } } static $included = array(); foreach ($system['cache_drivers'] as $filepath) { $file = pathinfo($filepath, PATHINFO_BASENAME); $namex = str_replace(".php", "", $file); if ($namex == $system['cache_config']['storage']) { if (!isset($included[truepath($filepath)])) { MpLoader::includeOnce($filepath); } else { $included[truepath($filepath)] = 1; } } } } public static function &getInstance() { return self::$instance; } public static function instance($classname_path = null, $hmvc_module_floder = NULL) { if (!empty($hmvc_module_floder)) { MpRouter::switchHmvcConfig($hmvc_module_floder); } if (empty($classname_path)) { MpLoader::classAutoloadRegister(); return new self(); } $system = systemInfo(); $classname_path = str_replace('.', DIRECTORY_SEPARATOR, $classname_path); $classname = basename($classname_path); $filepath = $system['controller_folder'] . DIRECTORY_SEPARATOR . $classname_path . $system['controller_file_subfix']; $alias_name = strtolower($classname); static $loadedClasses = array(); if (in_array($alias_name, array_keys($loadedClasses))) { return $loadedClasses[$alias_name]; } if (file_exists($filepath)) { MpLoader::classAutoloadRegister(); MpLoader::includeOnce($filepath); if (class_exists($classname, FALSE)) { return $loadedClasses[$alias_name] = new $classname(); } else { trigger404('Ccontroller Class:' . $classname . ' not found.'); } } else { trigger404($filepath . ' not found.'); } } } class MpController extends WoniuController{} class WoniuModel extends MpLoaderPlus { private static $instance; public static function instance($classname_path = null, $hmvc_module_floder = NULL) { if (!empty($hmvc_module_floder)) { MpRouter::switchHmvcConfig($hmvc_module_floder); } WoniuController::instance(); if (empty($classname_path)) { $renew = is_bool($classname_path) && $classname_path === true; MpLoader::classAutoloadRegister(); return empty(self::$instance) || $renew ? self::$instance = new self() : self::$instance; } $system = systemInfo(); $classname_path = str_replace('.', DIRECTORY_SEPARATOR, $classname_path); $classname = basename($classname_path); $model_folders = $system['model_folder']; if (!is_array($model_folders)) { $model_folders = array($model_folders); } $count = count($model_folders); MpLoader::classAutoloadRegister(); foreach ($model_folders as $key => $model_folder) { $filepath = $model_folder . DIRECTORY_SEPARATOR . $classname_path . $system['model_file_subfix']; $alias_name = $classname; if (in_array($alias_name, array_keys(WoniuModelLoader::$model_files))) { return WoniuModelLoader::$model_files[$alias_name]; } if (file_exists($filepath)) { if (!class_exists($classname, FALSE)) { MpLoader::includeOnce($filepath); } if (class_exists($classname, FALSE)) { return WoniuModelLoader::$model_files[$alias_name] = new $classname(); } else { if ($key == $count - 1) { trigger404('Model Class:' . $classname . ' not found.'); } } } else { if ($key == $count - 1) { trigger404($filepath . ' not  found.'); } } } } } class MpModel extends WoniuModel{} class MpTableModel extends MpModel { public $pk; public $keys = array(); public $table; public $full_table; public $map = array(); public $prefix; public $fields = array(); private static $models = array(), $table_cache = array(); public function __construct() { parent::__construct(); $this->database(); } public function init($table, $db = null) { if (!is_null($db)) { $this->db = $db; } $this->prefix = $this->db->dbprefix; $this->table = $table; $this->full_table = $this->prefix . $table; $this->fields = $fields = $this->getTableFieldsInfo($table, $this->db); foreach ($fields as $col => $info) { if ($info['primary']) { $this->pk = $col; } $this->keys[] = $col; $this->map[$col] = $col; } return $this; } public static function M($table, $db = null) { if (!isset(self::$models[$table])) { self::$models[$table] = new MpTableModel(); self::$models[$table]->init($table, $db); } return self::$models[$table]; } public function columns() { return $this->keys; } public static function getTableFieldsInfo($tableName, $db) { if (!empty(self::$table_cache[$tableName])) { return self::$table_cache[$tableName]; } if (!file_exists($cache_file = systemInfo('table_cache_folder') . DIRECTORY_SEPARATOR . $tableName . '.php')) { $info = array(); $result = $db->query('SHOW FULL COLUMNS FROM ' . $db->dbprefix . $tableName)->result_array(); if ($result) { foreach ($result as $val) { $info[$val['Field']] = array( 'name' => $val['Field'], 'type' => $val['Type'], 'comment' => $val['Comment'] ? $val['Comment'] : $val['Field'], 'notnull' => $val['Null'] == 'NO' ? 1 : 0, 'default' => $val['Default'], 'primary' => (strtolower($val['Key']) == 'pri'), 'autoinc' => (strtolower($val['Extra']) == 'auto_increment'), ); } } $content = 'return ' . var_export($info, true) . ";\n"; $content = '<?' . 'php' . "\n" . $content; file_put_contents($cache_file, $content); $ret_info[$tableName] = $info; } else { $ret_info[$tableName] = include ($cache_file); } return $ret_info[$tableName]; } public function check($source_data, &$ret_data, $rule = null, $map = null) { $rule = !is_array($rule) ? array() : $rule; $map = is_null($map) ? $this->map : $map; $data = $this->readData($map, $source_data); return $this->checkData($rule, $data, $ret_data); } public function insert($ret_data) { return $this->db->insert($this->table, $ret_data); } public function update($ret_data, $where) { $where = is_array($where) ? $where : array($this->pk => $where); return $this->db->where($where)->update($this->table, $ret_data); } public function find($values, $is_rows = false, $order_by = null) { if (empty($values)) { return 0; } if (is_array($values)) { $is_asso = array_diff_assoc(array_keys($values), range(0, sizeof($values))) ? TRUE : FALSE; if ($is_asso) { $this->db->where($values); } else { $is_rows = true; $this->db->where_in($this->pk, array_values($values)); } } else { $this->db->where(array($this->pk => $values)); } if ($order_by) { $this->db->order_by($order_by); } if (!$is_rows) { $this->db->limit(1); } $rs = $this->db->get($this->table); if ($is_rows) { return $rs->result_array(); } else { return $rs->row_array(); } } public function findAll($where = null, $orderby = NULL, $limit = null, $fileds = null) { if (!is_null($fileds)) { $this->db->select($fileds); } if (!is_null($where)) { $this->db->where($where); } if (!is_null($orderby)) { $this->db->order_by($orderby); } if (!is_null($limit)) { $this->db->limit($limit); } return $this->db->get($this->table)->result_array(); } public function findCol($col, $where, $is_rows = false, $order_by = null) { $row = $this->find($where, $is_rows, $order_by); if (!$is_rows) { return isset($row[$col]) ? $row[$col] : null; } else { $vals = array(); foreach ($row as $v) { $vals[] = $v[$col]; } return $vals; } } public function delete($values, Array $cond = NULL) { return $this->deleteIn($this->pk, $values, $cond); } public function deleteIn($key, $values, Array $cond = NULL) { if (empty($values)) { return 0; } if (is_array($values)) { $this->db->where_in($key, array_values($values)); } else { $this->db->where(array($key => $values)); } if (!empty($cond)) { $this->db->where($cond); } if ($this->db->delete($this->table)) { return $this->db->affected_rows(); } else { return false; } } public function getPage($page, $pagesize, $url, $fields = '*', Array $where = null, Array $like = null, $orderby = null, $page_bar_order = array(1, 2, 3, 4, 5, 6), $page_bar_a_count = 10) { $data = array(); if (is_array($where)) { $this->db->where($where); } if (is_array($like)) { $this->db->like($like); } $total = $this->db->from($this->table)->count_all_results(); if (is_array($where)) { $this->db->where($where); } if (is_array($like)) { $this->db->like($like); } if (!is_null($orderby)) { $this->db->order_by($orderby); } $data['items'] = $this->db->select($fields)->limit($pagesize, ($page - 1) * $pagesize)->get($this->table)->result_array(); $data['page'] = $this->page($total, $page, $pagesize, $url, $page_bar_order, $page_bar_a_count); return $data; } public function search($page, $pagesize, $url, $fields, $cond, $page_bar_order = array(1, 2, 3, 4, 5, 6), $page_bar_a_count = 10) { $data = array(); $table = $this->full_table; $query = $this->db->query('select count(*) as total from ' . $table . (strpos(trim($cond), 'order') === 0 ? '' : ' where') . $cond)->row_array(); $total = $query['total']; $data['items'] = $this->db->query('select ' . $fields . ' from ' . $table . (strpos(trim($cond), 'order') === 0 ? '' : ' where') . $cond . ' limit ' . (($page - 1) * $pagesize) . ',' . $pagesize)->result_array(); $data['page'] = $this->page($total, $page, $pagesize, $url, $page_bar_order, $page_bar_a_count); return $data; } } class WoniuRule { public static function required() { return 'required'; } public static function defaultVal($val = '') { return 'default[' . $val . ']'; } public static function optional() { return 'optional'; } public static function match($field_name) { return 'match[' . $field_name . ']'; } public static function equal($val) { return 'equal[' . $val . ']'; } public static function enum($val, $delimiter = '') { return 'enum[' . $val . ']' . $delimiter; } public static function unique($val, $delimiter = '') { return 'unique[' . $val . ']' . $delimiter; } public static function exists($val, $delimiter = '') { return 'exists[' . $val . ']' . $delimiter; } public static function min_len($val) { return 'min_len[' . $val . ']'; } public static function max_len($val) { return 'min_len[' . $val . ']'; } public static function range_len($min_len, $max_len) { return 'range_len[' . $min_len . ',' . $max_len . ']'; } public static function len($val) { return 'len[' . $val . ']'; } public static function min($val) { return 'min[' . $val . ']'; } public static function max($val) { return 'max[' . $val . ']'; } public static function range($min, $max) { return 'range[' . $min . ',' . $max . ']'; } public static function alpha() { return 'alpha'; } public static function alpha_num() { return 'alpha_num'; } public static function alpha_dash() { return 'alpha_dash'; } public static function alpha_start() { return 'alpha_start'; } public static function num() { return 'num'; } public static function int() { return 'int'; } public static function float() { return 'float'; } public static function numeric() { return 'numeric'; } public static function natural() { return 'natural'; } public static function natural_no_zero() { return 'natural_no_zero'; } public static function url($can_empty = false) { return self::can_empty_rule('url', $can_empty); } public static function email($can_empty = false) { return self::can_empty_rule('email', $can_empty); } public static function qq($can_empty = false) { return self::can_empty_rule('qq', $can_empty); } public static function phone($can_empty = false) { return self::can_empty_rule('phone', $can_empty); } public static function mobile($can_empty = false) { return self::can_empty_rule('mobile', $can_empty); } public static function zipcode($can_empty = false) { return self::can_empty_rule('zipcode', $can_empty); } public static function idcard($can_empty = false) { return self::can_empty_rule('idcard', $can_empty); } public static function ip($can_empty = false) { return self::can_empty_rule('ip', $can_empty); } public static function chs($val = '', $delimiter = '') { return 'chs' . ($val ? '[' . $val . ']' . $delimiter : ''); } public static function date($can_empty = false) { return self::can_empty_rule('date', $can_empty); } public static function datetime($can_empty = false) { return self::can_empty_rule('datetime', $can_empty); } public static function time($can_empty = false) { return self::can_empty_rule('time', $can_empty); } public static function reg($val) { return 'reg[' . $val . ']'; } public static function set($val, $delimiter = '') { return 'set[' . $val . ']' . $delimiter; } public static function set_post($val, $delimiter = '') { return 'set_post[' . $val . ']' . $delimiter; } private static function can_empty_rule($rule_name, $can_empty) { return $rule_name . ($can_empty ? '[true]' : ''); } } class MpRule extends WoniuRule{} class WoniuDB { private static $conns = array(); public static function &getInstance($config, $force_new_conn = false) { $default['dbdriver'] = "mysql"; $default['hostname'] = '127.0.0.1'; $default['port'] = '3306'; $default['username'] = 'root'; $default['password'] = ''; $default['database'] = 'test'; $default['dbprefix'] = ''; $default['pconnect'] = TRUE; $default['db_debug'] = TRUE; $default['char_set'] = 'utf8'; $default['dbcollat'] = 'utf8_general_ci'; $default['swap_pre'] = ''; $default['autoinit'] = TRUE; $default['stricton'] = FALSE; $config= array_merge($default,$config); $class = 'CI_DB_' . $config['dbdriver'] . '_driver'; if(!class_exists($class, false)){ return null; } $config0=$config; asort($config0); $hash = md5(sha1(var_export($config0, TRUE))); if ($force_new_conn || !isset(self::$conns[$hash])) { self::$conns[$hash] = new $class($config); } if ($config['dbdriver'] == 'pdo' && strpos($config['hostname'], 'mysql') !== FALSE) { self::$conns[$hash]->simple_query('set names ' . $config['char_set']); } return self::$conns[$hash]; } } class CI_DB extends CI_DB_active_record { } class CI_DB_driver { var $username; var $password; var $hostname; var $database; var $dbdriver = 'mysql'; var $dbprefix = ''; var $char_set = 'utf8'; var $dbcollat = 'utf8_general_ci'; var $autoinit = TRUE; var $swap_pre = ''; var $port = ''; var $pconnect = FALSE; var $conn_id = FALSE; var $result_id = FALSE; var $db_debug = FALSE; var $benchmark = 0; var $query_count = 0; var $bind_marker = '?'; var $save_queries = TRUE; var $queries = array(); var $query_times = array(); var $data_cache = array(); var $trans_enabled = TRUE; var $trans_strict = TRUE; var $_trans_depth = 0; var $_trans_status = TRUE; var $_protect_identifiers = TRUE; var $_reserved_identifiers = array('*'); var $stmt_id; var $curs_id; var $limit_used; function __construct($params) { if (is_array($params)) { foreach ($params as $key => $val) { $this->$key = $val; } } log_message('debug', 'Database Driver Class Initialized'); } function initialize() { if (is_resource($this->conn_id) OR is_object($this->conn_id)) { return TRUE; } $this->conn_id = ($this->pconnect == FALSE) ? $this->db_connect() : $this->db_pconnect(); if (!$this->conn_id) { log_message('error', 'Unable to connect to the database'); if ($this->db_debug || systemInfo('error_manage')) { $this->display_error('db_unable_to_connect'); } return FALSE; } if ($this->database != '') { if (!$this->db_select()) { log_message('error', 'Unable to select database: ' . $this->database); if ($this->db_debug || systemInfo('error_manage')) { $this->display_error('db_unable_to_select', $this->database); } return FALSE; } else { if (!$this->db_set_charset($this->char_set, $this->dbcollat)) { return FALSE; } return TRUE; } } return TRUE; } function db_set_charset($charset, $collation) { if (!$this->_db_set_charset($this->char_set, $this->dbcollat)) { log_message('error', 'Unable to set database connection charset: ' . $this->char_set); if ($this->db_debug || systemInfo('error_manage')) { $this->display_error('db_unable_to_set_charset', $this->char_set); } return FALSE; } return TRUE; } function platform() { return $this->dbdriver; } function version() { if (FALSE === ($sql = $this->_version())) { if ($this->db_debug || systemInfo('error_manage')) { return $this->display_error('db_unsupported_function'); } return FALSE; } $driver_version_exceptions = array('oci8', 'sqlite', 'cubrid'); if (in_array($this->dbdriver, $driver_version_exceptions)) { return $sql; } else { $query = $this->query($sql); return $query->row('ver'); } } function query($sql, $binds = FALSE, $return_object = TRUE) { if ($sql == '') { if ($this->db_debug || systemInfo('error_manage')) { log_message('error', 'Invalid query: ' . $sql); return $this->display_error('db_invalid_query'); } return FALSE; } if (($this->dbprefix != '' AND $this->swap_pre != '') AND ( $this->dbprefix != $this->swap_pre)) { $sql = preg_replace("/(\W)" . $this->swap_pre . "(\S+?)/", "\\1" . $this->dbprefix . "\\2", $sql); } if ($binds !== FALSE) { $sql = $this->compile_binds($sql, $binds); } if ($this->save_queries == TRUE) { $this->queries[] = $sql; } $time_start = list($sm, $ss) = explode(' ', microtime()); if (FALSE === ($this->result_id = $this->simple_query($sql))) { if ($this->save_queries == TRUE) { $this->query_times[] = 0; } $this->_trans_status = FALSE; if ($this->db_debug || systemInfo('error_manage')) { $error_no = $this->_error_number(); $error_msg = $this->_error_message(); $this->trans_complete(); log_message('error', 'Query error: ' . $error_msg); return $this->display_error( array( 'Error Number: ' . $error_no, $error_msg, $sql ) ); } return FALSE; } $time_end = list($em, $es) = explode(' ', microtime()); $this->benchmark += ($em + $es) - ($sm + $ss); if ($this->save_queries == TRUE) { $this->query_times[] = ($em + $es) - ($sm + $ss); } $this->query_count++; if ($this->is_write_type($sql) === TRUE) { return TRUE; } if ($return_object !== TRUE) { return TRUE; } $driver = $this->load_rdriver(); $RES = new $driver(); $RES->conn_id = $this->conn_id; $RES->result_id = $this->result_id; if ($this->dbdriver == 'oci8') { $RES->stmt_id = $this->stmt_id; $RES->curs_id = NULL; $RES->limit_used = $this->limit_used; $this->stmt_id = FALSE; } $RES->num_rows = $RES->num_rows(); return $RES; } function load_rdriver() { $driver = 'CI_DB_' . $this->dbdriver . '_result'; if (!class_exists($driver, FALSE)) { include_once(BASEPATH . 'database/DB_result.php'); include_once(BASEPATH . 'database/drivers/' . $this->dbdriver . '/' . $this->dbdriver . '_result.php'); } return $driver; } function simple_query($sql) { if (!$this->conn_id) { $this->initialize(); } return $this->_execute($sql); } function trans_off() { $this->trans_enabled = FALSE; } function trans_strict($mode = TRUE) { $this->trans_strict = is_bool($mode) ? $mode : TRUE; } function trans_start($test_mode = FALSE) { if (!$this->trans_enabled) { return FALSE; } if ($this->_trans_depth > 0) { $this->_trans_depth += 1; return; } $this->trans_begin($test_mode); } function trans_complete() { if (!$this->trans_enabled) { return FALSE; } if ($this->_trans_depth > 1) { $this->_trans_depth -= 1; return TRUE; } if ($this->_trans_status === FALSE) { $this->trans_rollback(); if ($this->trans_strict === FALSE) { $this->_trans_status = TRUE; } log_message('debug', 'DB Transaction Failure'); return FALSE; } $this->trans_commit(); return TRUE; } function trans_status() { return $this->_trans_status; } function compile_binds($sql, $binds) { if (strpos($sql, $this->bind_marker) === FALSE) { return $sql; } if (!is_array($binds)) { $binds = array($binds); } $segments = explode($this->bind_marker, $sql); if (count($binds) >= count($segments)) { $binds = array_slice($binds, 0, count($segments) - 1); } $result = $segments[0]; $i = 0; foreach ($binds as $bind) { $result .= $this->escape($bind); $result .= $segments[++$i]; } return $result; } function is_write_type($sql) { if (!preg_match('/^\s*"?(SET|INSERT|UPDATE|DELETE|REPLACE|CREATE|DROP|TRUNCATE|LOAD DATA|COPY|ALTER|GRANT|REVOKE|LOCK|UNLOCK)\s+/i', $sql)) { return FALSE; } return TRUE; } function elapsed_time($decimals = 6) { return number_format($this->benchmark, $decimals); } function total_queries() { return $this->query_count; } function last_query() { return end($this->queries); } function escape($str) { if (is_string($str)) { $str = "'" . $this->escape_str($str) . "'"; } elseif (is_bool($str)) { $str = ($str === FALSE) ? 0 : 1; } elseif (is_null($str)) { $str = 'NULL'; } return $str; } function escape_like_str($str) { return $this->escape_str($str, TRUE); } function primary($table = '') { $fields = $this->list_fields($table); if (!is_array($fields)) { return FALSE; } return current($fields); } function list_tables($constrain_by_prefix = FALSE) { if (isset($this->data_cache['table_names'])) { return $this->data_cache['table_names']; } if (FALSE === ($sql = $this->_list_tables($constrain_by_prefix))) { if ($this->db_debug || systemInfo('error_manage')) { return $this->display_error('db_unsupported_function'); } return FALSE; } $retval = array(); $query = $this->query($sql); if ($query->num_rows() > 0) { foreach ($query->result_array() as $row) { if (isset($row['TABLE_NAME'])) { $retval[] = $row['TABLE_NAME']; } else { $retval[] = array_shift($row); } } } $this->data_cache['table_names'] = $retval; return $this->data_cache['table_names']; } function table_exists($table_name) { return (!in_array($this->_protect_identifiers($table_name, TRUE, FALSE, FALSE), $this->list_tables())) ? FALSE : TRUE; } function list_fields($table = '') { if (isset($this->data_cache['field_names'][$table])) { return $this->data_cache['field_names'][$table]; } if ($table == '') { if ($this->db_debug || systemInfo('error_manage')) { return $this->display_error('db_field_param_missing'); } return FALSE; } if (FALSE === ($sql = $this->_list_columns($table))) { if ($this->db_debug || systemInfo('error_manage')) { return $this->display_error('db_unsupported_function'); } return FALSE; } $query = $this->query($sql); $retval = array(); foreach ($query->result_array() as $row) { if (isset($row['COLUMN_NAME'])) { $retval[] = $row['COLUMN_NAME']; } else if ($this->dbdriver == 'sqlite3') { $retval[] = $row['name']; } else { $retval[] = current($row); } } $this->data_cache['field_names'][$table] = $retval; return $this->data_cache['field_names'][$table]; } function field_exists($field_name, $table_name) { return (!in_array($field_name, $this->list_fields($table_name))) ? FALSE : TRUE; } function field_data($table = '') { if ($table == '') { if ($this->db_debug || systemInfo('error_manage')) { return $this->display_error('db_field_param_missing'); } return FALSE; } $query = $this->query($this->_field_data($this->_protect_identifiers($table, TRUE, NULL, FALSE))); return $query->field_data(); } function insert_string($table, $data) { $fields = array(); $values = array(); foreach ($data as $key => $val) { $fields[] = $this->_escape_identifiers($key); $values[] = $this->escape($val); } return $this->_insert($this->_protect_identifiers($table, TRUE, NULL, FALSE), $fields, $values); } function update_string($table, $data, $where) { if ($where == '') { return false; } $fields = array(); foreach ($data as $key => $val) { $fields[$this->_protect_identifiers($key)] = $this->escape($val); } if (!is_array($where)) { $dest = array($where); } else { $dest = array(); foreach ($where as $key => $val) { $prefix = (count($dest) == 0) ? '' : ' AND '; if ($val !== '') { if (!$this->_has_operator($key)) { $key .= ' ='; } $val = ' ' . $this->escape($val); } $dest[] = $prefix . $key . $val; } } return $this->_update($this->_protect_identifiers($table, TRUE, NULL, FALSE), $fields, $dest); } function _has_operator($str) { $str = trim($str); if (!preg_match("/(\s|<|>|!|=|is null|is not null)/i", $str)) { return FALSE; } return TRUE; } function call_function($function) { $driver = ($this->dbdriver == 'postgre') ? 'pg_' : $this->dbdriver . '_'; if (FALSE === strpos($driver, $function)) { $function = $driver . $function; } if (!function_exists($function)) { if ($this->db_debug || systemInfo('error_manage')) { return $this->display_error('db_unsupported_function'); } return FALSE; } else { $args = (func_num_args() > 1) ? array_splice(func_get_args(), 1) : null; if (is_null($args)) { return call_user_func($function); } else { return call_user_func_array($function, $args); } } } function close() { if (is_resource($this->conn_id) OR is_object($this->conn_id)) { $this->_close($this->conn_id); } $this->conn_id = FALSE; } function display_error($error = '', $swap = '', $native = FALSE) { woniu_db_error_handler($error, $swap, $native); } function protect_identifiers($item, $prefix_single = FALSE) { return $this->_protect_identifiers($item, $prefix_single); } function _protect_identifiers($item, $prefix_single = FALSE, $protect_identifiers = NULL, $field_exists = TRUE) { if (!is_bool($protect_identifiers)) { $protect_identifiers = $this->_protect_identifiers; } if (is_array($item)) { $escaped_array = array(); foreach ($item as $k => $v) { $escaped_array[$this->_protect_identifiers($k)] = $this->_protect_identifiers($v); } return $escaped_array; } $item = preg_replace('/[\t ]+/', ' ', $item); if (strpos($item, ' ') !== FALSE) { $alias = strstr($item, ' '); $item = substr($item, 0, - strlen($alias)); } else { $alias = ''; } if (strpos($item, '(') !== FALSE) { return $item . $alias; } if (strpos($item, '.') !== FALSE) { $parts = explode('.', $item); if (in_array($parts[0], $this->ar_aliased_tables)) { if ($protect_identifiers === TRUE) { foreach ($parts as $key => $val) { if (!in_array($val, $this->_reserved_identifiers)) { $parts[$key] = $this->_escape_identifiers($val); } } $item = implode('.', $parts); } return $item . $alias; } if ($this->dbprefix != '') { if (isset($parts[3])) { $i = 2; } elseif (isset($parts[2])) { $i = 1; } else { $i = 0; } if ($field_exists == FALSE) { $i++; } if ($this->swap_pre != '' && strncmp($parts[$i], $this->swap_pre, strlen($this->swap_pre)) === 0) { $parts[$i] = preg_replace("/^" . $this->swap_pre . "(\S+?)/", $this->dbprefix . "\\1", $parts[$i]); } if (substr($parts[$i], 0, strlen($this->dbprefix)) != $this->dbprefix) { $parts[$i] = $this->dbprefix . $parts[$i]; } $item = implode('.', $parts); } if ($protect_identifiers === TRUE) { $item = $this->_escape_identifiers($item); } return $item . $alias; } if ($this->dbprefix != '') { if ($this->swap_pre != '' && strncmp($item, $this->swap_pre, strlen($this->swap_pre)) === 0) { $item = preg_replace("/^" . $this->swap_pre . "(\S+?)/", $this->dbprefix . "\\1", $item); } if ($prefix_single == TRUE AND substr($item, 0, strlen($this->dbprefix)) != $this->dbprefix) { $item = $this->dbprefix . $item; } } if ($protect_identifiers === TRUE AND ! in_array($item, $this->_reserved_identifiers)) { $item = $this->_escape_identifiers($item); } return $item . $alias; } protected function _reset_select() { } } class CI_DB_result { var $conn_id = NULL; var $result_id = NULL; var $result_array = array(); var $result_object = array(); var $custom_result_object = array(); var $current_row = 0; var $num_rows = 0; var $row_data = NULL; public function result($type = 'object') { if ($type == 'array') return $this->result_array(); else if ($type == 'object') return $this->result_object(); else return $this->custom_result_object($type); } public function custom_result_object($class_name) { if (array_key_exists($class_name, $this->custom_result_object)) { return $this->custom_result_object[$class_name]; } if ($this->result_id === FALSE OR $this->num_rows() == 0) { return array(); } $this->_data_seek(0); $result_object = array(); while ($row = $this->_fetch_object()) { $object = new $class_name(); foreach ($row as $key => $value) { if (method_exists($object, 'set_' . $key)) { $object->{'set_' . $key}($value); } else { $object->$key = $value; } } $result_object[] = $object; } return $this->custom_result_object[$class_name] = $result_object; } public function result_object() { if (count($this->result_object) > 0) { return $this->result_object; } if ($this->result_id === FALSE OR $this->num_rows() == 0) { return array(); } $this->_data_seek(0); while ($row = $this->_fetch_object()) { $this->result_object[] = $row; } return $this->result_object; } public function result_array() { if (count($this->result_array) > 0) { return $this->result_array; } if ($this->result_id === FALSE OR $this->num_rows() == 0) { return array(); } $this->_data_seek(0); while ($row = $this->_fetch_assoc()) { $this->result_array[] = $row; } return $this->result_array; } public function row($n = 0, $type = 'object') { if (!is_numeric($n)) { if (!is_array($this->row_data)) { $this->row_data = $this->row_array(0); } if (array_key_exists($n, $this->row_data)) { return $this->row_data[$n]; } $n = 0; } if ($type == 'object') return $this->row_object($n); else if ($type == 'array') return $this->row_array($n); else return $this->custom_row_object($n, $type); } public function set_row($key, $value = NULL) { if (!is_array($this->row_data)) { $this->row_data = $this->row_array(0); } if (is_array($key)) { foreach ($key as $k => $v) { $this->row_data[$k] = $v; } return; } if ($key != '' AND ! is_null($value)) { $this->row_data[$key] = $value; } } public function custom_row_object($n, $type) { $result = $this->custom_result_object($type); if (count($result) == 0) { return $result; } if ($n != $this->current_row AND isset($result[$n])) { $this->current_row = $n; } return $result[$this->current_row]; } public function row_object($n = 0) { $result = $this->result_object(); if (count($result) == 0) { return $result; } if ($n != $this->current_row AND isset($result[$n])) { $this->current_row = $n; } return $result[$this->current_row]; } public function row_array($n = 0) { $result = $this->result_array(); if (count($result) == 0) { return $result; } if ($n != $this->current_row AND isset($result[$n])) { $this->current_row = $n; } return $result[$this->current_row]; } public function first_row($type = 'object') { $result = $this->result($type); if (count($result) == 0) { return $result; } return $result[0]; } public function last_row($type = 'object') { $result = $this->result($type); if (count($result) == 0) { return $result; } return $result[count($result) - 1]; } public function next_row($type = 'object') { $result = $this->result($type); if (count($result) == 0) { return $result; } if (isset($result[$this->current_row + 1])) { ++$this->current_row; } return $result[$this->current_row]; } public function previous_row($type = 'object') { $result = $this->result($type); if (count($result) == 0) { return $result; } if (isset($result[$this->current_row - 1])) { --$this->current_row; } return $result[$this->current_row]; } public function num_rows() { return $this->num_rows; } public function num_fields() { return 0; } public function list_fields() { return array(); } public function field_data() { return array(); } public function free_result() { return TRUE; } protected function _data_seek() { return TRUE; } protected function _fetch_assoc() { return array(); } protected function _fetch_object() { return array(); } } class CI_DB_active_record extends CI_DB_driver { var $ar_select = array(); var $ar_distinct = FALSE; var $ar_from = array(); var $ar_join = array(); var $ar_where = array(); var $ar_like = array(); var $ar_groupby = array(); var $ar_having = array(); var $ar_keys = array(); var $ar_limit = FALSE; var $ar_offset = FALSE; var $ar_order = FALSE; var $ar_orderby = array(); var $ar_set = array(); var $ar_wherein = array(); var $ar_aliased_tables = array(); var $ar_store_array = array(); var $ar_no_escape = array(); public function select($select = '*', $escape = NULL) { if (is_string($select)) { $select = explode(',', $select); } foreach ($select as $val) { $val = trim($val); if ($val != '') { $this->ar_select[] = $val; $this->ar_no_escape[] = $escape; } } return $this; } public function select_max($select = '', $alias = '') { return $this->_max_min_avg_sum($select, $alias, 'MAX'); } public function select_min($select = '', $alias = '') { return $this->_max_min_avg_sum($select, $alias, 'MIN'); } public function select_avg($select = '', $alias = '') { return $this->_max_min_avg_sum($select, $alias, 'AVG'); } public function select_sum($select = '', $alias = '') { return $this->_max_min_avg_sum($select, $alias, 'SUM'); } protected function _max_min_avg_sum($select = '', $alias = '', $type = 'MAX') { if (!is_string($select) OR $select == '') { $this->display_error('db_invalid_query'); } $type = strtoupper($type); if (!in_array($type, array('MAX', 'MIN', 'AVG', 'SUM'))) { show_error('Invalid function type: ' . $type); } if ($alias == '') { $alias = $this->_create_alias_from_table(trim($select)); } $sql = $type . '(' . $this->_protect_identifiers(trim($select)) . ') AS ' . $alias; $this->ar_select[] = $sql; return $this; } protected function _create_alias_from_table($item) { if (strpos($item, '.') !== FALSE) { return end(explode('.', $item)); } return $item; } public function distinct($val = TRUE) { $this->ar_distinct = (is_bool($val)) ? $val : TRUE; return $this; } public function from($from) { foreach ((array) $from as $val) { if (strpos($val, ',') !== FALSE) { foreach (explode(',', $val) as $v) { $v = trim($v); $this->_track_aliases($v); $this->ar_from[] = $this->_protect_identifiers($v, TRUE, NULL, FALSE); } } else { $val = trim($val); $this->_track_aliases($val); $this->ar_from[] = $this->_protect_identifiers($val, TRUE, NULL, FALSE); } } return $this; } public function join($table, $cond, $type = '') { if ($type != '') { $type = strtoupper(trim($type)); if (!in_array($type, array('LEFT', 'RIGHT', 'OUTER', 'INNER', 'LEFT OUTER', 'RIGHT OUTER'))) { $type = ''; } else { $type .= ' '; } } $this->_track_aliases($table); if (preg_match('/([\w\.]+)([\W\s]+)(.+)/', $cond, $match)) { $match[1] = $this->_protect_identifiers($match[1]); $match[3] = $this->_protect_identifiers($match[3]); $cond = $match[1] . $match[2] . $match[3]; } $join = $type . 'JOIN ' . $this->_protect_identifiers($table, TRUE, NULL, FALSE) . ' ON ' . $cond; $this->ar_join[] = $join; return $this; } public function where($key, $value = NULL, $escape = TRUE) { return $this->_where($key, $value, 'AND ', $escape); } public function or_where($key, $value = NULL, $escape = TRUE) { return $this->_where($key, $value, 'OR ', $escape); } protected function _where($key, $value = NULL, $type = 'AND ', $escape = NULL) { if (!is_array($key)) { $key = array($key => $value); } if (!is_bool($escape)) { $escape = $this->_protect_identifiers; } foreach ($key as $k => $v) { $prefix = (count($this->ar_where) == 0) ? '' : $type; if (is_null($v) && !$this->_has_operator($k)) { $k .= ' IS NULL'; } if (!is_null($v)) { if ($escape === TRUE) { $k = $this->_protect_identifiers($k, FALSE, $escape); $v = ' ' . $this->escape($v); } if (!$this->_has_operator($k)) { $k .= ' = '; } } else { $k = $this->_protect_identifiers($k, FALSE, $escape); } $this->ar_where[] = $prefix . $k . $v; } return $this; } public function where_in($key = NULL, $values = NULL) { return $this->_where_in($key, $values); } public function or_where_in($key = NULL, $values = NULL) { return $this->_where_in($key, $values, FALSE, 'OR '); } public function where_not_in($key = NULL, $values = NULL) { return $this->_where_in($key, $values, TRUE); } public function or_where_not_in($key = NULL, $values = NULL) { return $this->_where_in($key, $values, TRUE, 'OR '); } protected function _where_in($key = NULL, $values = NULL, $not = FALSE, $type = 'AND ') { if ($key === NULL OR $values === NULL) { return; } if (!is_array($values)) { $values = array($values); } elseif (empty($values)) { $values = array(''); } $not = ($not) ? ' NOT' : ''; foreach ($values as $value) { $this->ar_wherein[] = $this->escape($value); } $prefix = (count($this->ar_where) == 0) ? '' : $type; $where_in = $prefix . $this->_protect_identifiers($key) . $not . " IN (" . implode(", ", $this->ar_wherein) . ") "; $this->ar_where[] = $where_in; $this->ar_wherein = array(); return $this; } public function like($field, $match = '', $side = 'both') { return $this->_like($field, $match, 'AND ', $side); } public function not_like($field, $match = '', $side = 'both') { return $this->_like($field, $match, 'AND ', $side, 'NOT'); } public function or_like($field, $match = '', $side = 'both') { return $this->_like($field, $match, 'OR ', $side); } public function or_not_like($field, $match = '', $side = 'both') { return $this->_like($field, $match, 'OR ', $side, 'NOT'); } protected function _like($field, $match = '', $type = 'AND ', $side = 'both', $not = '') { if (!is_array($field)) { $field = array($field => $match); } foreach ($field as $k => $v) { $k = $this->_protect_identifiers($k); $prefix = (count($this->ar_like) == 0) ? '' : $type; $v = $this->escape_like_str($v); if ($side == 'none') { $like_statement = $prefix . " $k $not LIKE '{$v}'"; } elseif ($side == 'before') { $like_statement = $prefix . " $k $not LIKE '%{$v}'"; } elseif ($side == 'after') { $like_statement = $prefix . " $k $not LIKE '{$v}%'"; } else { $like_statement = $prefix . " $k $not LIKE '%{$v}%'"; } if ($this->_like_escape_str != '') { $like_statement = $like_statement . sprintf($this->_like_escape_str, $this->_like_escape_chr); } $this->ar_like[] = $like_statement; } return $this; } public function group_by($by) { if (is_string($by)) { $by = explode(',', $by); } foreach ($by as $val) { $val = trim($val); if ($val != '') { $this->ar_groupby[] = $this->_protect_identifiers($val); } } return $this; } public function having($key, $value = '', $escape = TRUE) { return $this->_having($key, $value, 'AND ', $escape); } public function or_having($key, $value = '', $escape = TRUE) { return $this->_having($key, $value, 'OR ', $escape); } protected function _having($key, $value = '', $type = 'AND ', $escape = TRUE) { if (!is_array($key)) { $key = array($key => $value); } foreach ($key as $k => $v) { $prefix = (count($this->ar_having) == 0) ? '' : $type; if ($escape === TRUE) { $k = $this->_protect_identifiers($k); } if (!$this->_has_operator($k)) { $k .= ' = '; } if ($v != '') { $v = ' ' . $this->escape($v); } $this->ar_having[] = $prefix . $k . $v; } return $this; } public function order_by($orderby, $direction = '') { if (strtolower($direction) == 'random') { $orderby = ''; $direction = $this->_random_keyword; } elseif (trim($direction) != '') { $direction = (in_array(strtoupper(trim($direction)), array('ASC', 'DESC'), TRUE)) ? ' ' . $direction : ' ASC'; } if (strpos($orderby, ',') !== FALSE) { $temp = array(); foreach (explode(',', $orderby) as $part) { $part = trim($part); if (!in_array($part, $this->ar_aliased_tables)) { $part = $this->_protect_identifiers(trim($part)); } $temp[] = $part; } $orderby = implode(', ', $temp); } else if ($direction != $this->_random_keyword) { $orderby = $this->_protect_identifiers($orderby); } $orderby_statement = $orderby . $direction; $this->ar_orderby[] = $orderby_statement; return $this; } public function limit($value, $offset = '') { $this->ar_limit = (int) $value; if ($offset != '') { $this->ar_offset = (int) $offset; } return $this; } public function offset($offset) { $this->ar_offset = $offset; return $this; } public function set($key, $value = '', $escape = TRUE) { $key = $this->_object_to_array($key); if (!is_array($key)) { $key = array($key => $value); } foreach ($key as $k => $v) { if ($escape === FALSE) { $this->ar_set[$this->_protect_identifiers($k)] = $v; } else { $this->ar_set[$this->_protect_identifiers($k, FALSE, TRUE)] = $this->escape($v); } } return $this; } public function get($table = '', $limit = null, $offset = null) { if ($table != '') { $this->_track_aliases($table); $this->from($table); } if (!is_null($limit)) { $this->limit($limit, $offset); } $sql = $this->_compile_select(); $result = $this->query($sql); $this->_reset_select(); return $result; } public function count_all_results($table = '') { if ($table != '') { $this->_track_aliases($table); $this->from($table); } $sql = $this->_compile_select($this->_count_string . $this->_protect_identifiers('numrows')); $query = $this->query($sql); $this->_reset_select(); if ($query->num_rows() == 0) { return 0; } $row = $query->row(); return (int) $row->numrows; } public function get_where($table = '', $where = null, $limit = null, $offset = null) { if ($table != '') { $this->from($table); } if (!is_null($where)) { $this->where($where); } if (!is_null($limit)) { $this->limit($limit, $offset); } $sql = $this->_compile_select(); $result = $this->query($sql); $this->_reset_select(); return $result; } public function insert_batch($table = '', $set = NULL) { if (!is_null($set)) { $this->set_insert_batch($set); } if (count($this->ar_set) == 0) { if ($this->db_debug || systemInfo('error_manage')) { return $this->display_error('db_must_use_set'); } return FALSE; } if ($table == '') { if (!isset($this->ar_from[0])) { if ($this->db_debug || systemInfo('error_manage')) { return $this->display_error('db_must_set_table'); } return FALSE; } $table = $this->ar_from[0]; } for ($i = 0, $total = count($this->ar_set); $i < $total; $i = $i + 100) { $sql = $this->_insert_batch($this->_protect_identifiers($table, TRUE, NULL, FALSE), $this->ar_keys, array_slice($this->ar_set, $i, 100)); $this->query($sql); } $this->_reset_write(); return TRUE; } public function set_insert_batch($key, $value = '', $escape = TRUE) { $key = $this->_object_to_array_batch($key); if (!is_array($key)) { $key = array($key => $value); } $keys = array_keys(current($key)); sort($keys); foreach ($key as $row) { if (count(array_diff($keys, array_keys($row))) > 0 OR count(array_diff(array_keys($row), $keys)) > 0) { $this->ar_set[] = array(); return; } ksort($row); if ($escape === FALSE) { $this->ar_set[] = '(' . implode(',', $row) . ')'; } else { $clean = array(); foreach ($row as $value) { $clean[] = $this->escape($value); } $this->ar_set[] = '(' . implode(',', $clean) . ')'; } } foreach ($keys as $k) { $this->ar_keys[] = $this->_protect_identifiers($k); } return $this; } function insert($table = '', $set = NULL) { if (!is_null($set)) { $this->set($set); } if (count($this->ar_set) == 0) { if ($this->db_debug || systemInfo('error_manage')) { return $this->display_error('db_must_use_set'); } return FALSE; } if ($table == '') { if (!isset($this->ar_from[0])) { if ($this->db_debug || systemInfo('error_manage')) { return $this->display_error('db_must_set_table'); } return FALSE; } $table = $this->ar_from[0]; } $sql = $this->_insert($this->_protect_identifiers($table, TRUE, NULL, FALSE), array_keys($this->ar_set), array_values($this->ar_set)); $this->_reset_write(); return $this->query($sql); } public function replace($table = '', $set = NULL) { if (!is_null($set)) { $this->set($set); } if (count($this->ar_set) == 0) { if ($this->db_debug || systemInfo('error_manage')) { return $this->display_error('db_must_use_set'); } return FALSE; } if ($table == '') { if (!isset($this->ar_from[0])) { if ($this->db_debug || systemInfo('error_manage')) { return $this->display_error('db_must_set_table'); } return FALSE; } $table = $this->ar_from[0]; } $sql = $this->_replace($this->_protect_identifiers($table, TRUE, NULL, FALSE), array_keys($this->ar_set), array_values($this->ar_set)); $this->_reset_write(); return $this->query($sql); } public function update($table = '', $set = NULL, $where = NULL, $limit = NULL) { if (!is_null($set)) { $this->set($set); } if (count($this->ar_set) == 0) { if ($this->db_debug || systemInfo('error_manage')) { return $this->display_error('db_must_use_set'); } return FALSE; } if ($table == '') { if (!isset($this->ar_from[0])) { if ($this->db_debug || systemInfo('error_manage')) { return $this->display_error('db_must_set_table'); } return FALSE; } $table = $this->ar_from[0]; } if ($where != NULL) { $this->where($where); } if ($limit != NULL) { $this->limit($limit); } $sql = $this->_update($this->_protect_identifiers($table, TRUE, NULL, FALSE), $this->ar_set, $this->ar_where, $this->ar_orderby, $this->ar_limit); $this->_reset_write(); return $this->query($sql); } public function update_batch($table = '', $set = NULL, $index = NULL) { if (is_null($index)) { if ($this->db_debug || systemInfo('error_manage')) { return $this->display_error('db_must_use_index'); } return FALSE; } if (!is_null($set)) { $this->set_update_batch($set, $index); } if (count($this->ar_set) == 0) { if ($this->db_debug || systemInfo('error_manage')) { return $this->display_error('db_must_use_set'); } return FALSE; } if ($table == '') { if (!isset($this->ar_from[0])) { if ($this->db_debug || systemInfo('error_manage')) { return $this->display_error('db_must_set_table'); } return FALSE; } $table = $this->ar_from[0]; } for ($i = 0, $total = count($this->ar_set); $i < $total; $i = $i + 100) { $sql = $this->_update_batch($this->_protect_identifiers($table, TRUE, NULL, FALSE), array_slice($this->ar_set, $i, 100), $this->_protect_identifiers($index), $this->ar_where); $this->query($sql); } $this->_reset_write(); } public function set_update_batch($key, $index = '', $escape = TRUE) { $key = $this->_object_to_array_batch($key); if (!is_array($key)) { } foreach ($key as $k => $v) { $index_set = FALSE; $clean = array(); foreach ($v as $k2 => $v2) { if ($k2 == $index) { $index_set = TRUE; } else { $not[] = $k2 . '-' . $v2; } if ($escape === FALSE) { $clean[$this->_protect_identifiers($k2)] = $v2; } else { $clean[$this->_protect_identifiers($k2)] = $this->escape($v2); } } if ($index_set == FALSE) { return $this->display_error('db_batch_missing_index'); } $this->ar_set[] = $clean; } return $this; } public function empty_table($table = '') { if ($table == '') { if (!isset($this->ar_from[0])) { if ($this->db_debug || systemInfo('error_manage')) { return $this->display_error('db_must_set_table'); } return FALSE; } $table = $this->ar_from[0]; } else { $table = $this->_protect_identifiers($table, TRUE, NULL, FALSE); } $sql = $this->_delete($table); $this->_reset_write(); return $this->query($sql); } public function truncate($table = '') { if ($table == '') { if (!isset($this->ar_from[0])) { if ($this->db_debug || systemInfo('error_manage')) { return $this->display_error('db_must_set_table'); } return FALSE; } $table = $this->ar_from[0]; } else { $table = $this->_protect_identifiers($table, TRUE, NULL, FALSE); } $sql = $this->_truncate($table); $this->_reset_write(); return $this->query($sql); } public function delete($table = '', $where = '', $limit = NULL, $reset_data = TRUE) { if ($table == '') { if (!isset($this->ar_from[0])) { if ($this->db_debug || systemInfo('error_manage')) { return $this->display_error('db_must_set_table'); } return FALSE; } $table = $this->ar_from[0]; } elseif (is_array($table)) { foreach ($table as $single_table) { $this->delete($single_table, $where, $limit, FALSE); } $this->_reset_write(); return; } else { $table = $this->_protect_identifiers($table, TRUE, NULL, FALSE); } if ($where != '') { $this->where($where); } if ($limit != NULL) { $this->limit($limit); } if (count($this->ar_where) == 0 && count($this->ar_wherein) == 0 && count($this->ar_like) == 0) { if ($this->db_debug || systemInfo('error_manage')) { return $this->display_error('db_del_must_use_where'); } return FALSE; } $sql = $this->_delete($table, $this->ar_where, $this->ar_like, $this->ar_limit); if ($reset_data) { $this->_reset_write(); } return $this->query($sql); } public function dbprefix($table = '') { if ($table == '') { $this->display_error('db_table_name_required'); } return $this->dbprefix . $table; } public function set_dbprefix($prefix = '') { return $this->dbprefix = $prefix; } protected function _track_aliases($table) { if (is_array($table)) { foreach ($table as $t) { $this->_track_aliases($t); } return; } if (strpos($table, ',') !== FALSE) { return $this->_track_aliases(explode(',', $table)); } if (strpos($table, " ") !== FALSE) { $table = preg_replace('/\s+AS\s+/i', ' ', $table); $table = trim(strrchr($table, " ")); if (!in_array($table, $this->ar_aliased_tables)) { $this->ar_aliased_tables[] = $table; } } } protected function _compile_select($select_override = FALSE) { if ($select_override !== FALSE) { $sql = $select_override; } else { $sql = (!$this->ar_distinct) ? 'SELECT ' : 'SELECT DISTINCT '; if (count($this->ar_select) == 0) { $sql .= '*'; } else { foreach ($this->ar_select as $key => $val) { $no_escape = isset($this->ar_no_escape[$key]) ? $this->ar_no_escape[$key] : NULL; $this->ar_select[$key] = $this->_protect_identifiers($val, FALSE, $no_escape); } $sql .= implode(', ', $this->ar_select); } } if (count($this->ar_from) > 0) { $sql .= "\nFROM "; $sql .= $this->_from_tables($this->ar_from); } if (count($this->ar_join) > 0) { $sql .= "\n"; $sql .= implode("\n", $this->ar_join); } if (count($this->ar_where) > 0 OR count($this->ar_like) > 0) { $sql .= "\nWHERE "; } $sql .= implode("\n", $this->ar_where); if (count($this->ar_like) > 0) { if (count($this->ar_where) > 0) { $sql .= "\nAND "; } $sql .= implode("\n", $this->ar_like); } if (count($this->ar_groupby) > 0) { $sql .= "\nGROUP BY "; $sql .= implode(', ', $this->ar_groupby); } if (count($this->ar_having) > 0) { $sql .= "\nHAVING "; $sql .= implode("\n", $this->ar_having); } if (count($this->ar_orderby) > 0) { $sql .= "\nORDER BY "; $sql .= implode(', ', $this->ar_orderby); if ($this->ar_order !== FALSE) { $sql .= ($this->ar_order == 'desc') ? ' DESC' : ' ASC'; } } if (is_numeric($this->ar_limit)) { $sql .= "\n"; $sql = $this->_limit($sql, $this->ar_limit, $this->ar_offset); } return $sql; } public function _object_to_array($object) { if (!is_object($object)) { return $object; } $array = array(); foreach (get_object_vars($object) as $key => $val) { if (!is_object($val) && !is_array($val) && $key != '_parent_name') { $array[$key] = $val; } } return $array; } public function _object_to_array_batch($object) { if (!is_object($object)) { return $object; } $array = array(); $out = get_object_vars($object); $fields = array_keys($out); foreach ($fields as $val) { if ($val != '_parent_name') { $i = 0; foreach ($out[$val] as $data) { $array[$i][$val] = $data; $i++; } } } return $array; } protected function _reset_run($ar_reset_items) { foreach ($ar_reset_items as $item => $default_value) { if (!in_array($item, $this->ar_store_array)) { $this->$item = $default_value; } } } protected function _reset_select() { $ar_reset_items = array( 'ar_select' => array(), 'ar_from' => array(), 'ar_join' => array(), 'ar_where' => array(), 'ar_like' => array(), 'ar_groupby' => array(), 'ar_having' => array(), 'ar_orderby' => array(), 'ar_wherein' => array(), 'ar_aliased_tables' => array(), 'ar_no_escape' => array(), 'ar_distinct' => FALSE, 'ar_limit' => FALSE, 'ar_offset' => FALSE, 'ar_order' => FALSE, ); $this->_reset_run($ar_reset_items); } protected function _reset_write() { $ar_reset_items = array( 'ar_set' => array(), 'ar_from' => array(), 'ar_where' => array(), 'ar_like' => array(), 'ar_orderby' => array(), 'ar_keys' => array(), 'ar_limit' => FALSE, 'ar_order' => FALSE ); $this->_reset_run($ar_reset_items); } } function log_message($level, $msg) { } class CI_DB_mysql_driver extends CI_DB { var $dbdriver = 'mysql'; var $_escape_char = '`'; var $_like_escape_str = ''; var $_like_escape_chr = ''; var $delete_hack = TRUE; var $_count_string = 'SELECT COUNT(*) AS '; var $_random_keyword = ' RAND()'; var $use_set_names; function db_connect() { if ($this->port != '') { $this->hostname .= ':' . $this->port; } return @mysql_connect($this->hostname, $this->username, $this->password, TRUE); } function db_pconnect() { if ($this->port != '') { $this->hostname .= ':' . $this->port; } return @mysql_pconnect($this->hostname, $this->username, $this->password); } function reconnect() { if (mysql_ping($this->conn_id) === FALSE) { $this->conn_id = FALSE; } } function db_select() { return @mysql_select_db($this->database, $this->conn_id); } function _db_set_charset($charset, $collation) { if (!isset($this->use_set_names)) { $this->use_set_names = (version_compare(PHP_VERSION, '5.2.3', '>=') && version_compare(mysql_get_server_info(), '5.0.7', '>=')) ? FALSE : TRUE; } if ($this->use_set_names === TRUE) { return @mysql_query("SET NAMES '" . $this->escape_str($charset) . "' COLLATE '" . $this->escape_str($collation) . "'", $this->conn_id); } else { return @mysql_set_charset($charset, $this->conn_id); } } function _version() { return "SELECT version() AS ver"; } function _execute($sql) { $sql = $this->_prep_query($sql); return @mysql_query($sql, $this->conn_id); } function _prep_query($sql) { if ($this->delete_hack === TRUE) { if (preg_match('/^\s*DELETE\s+FROM\s+(\S+)\s*$/i', $sql)) { $sql = preg_replace("/^\s*DELETE\s+FROM\s+(\S+)\s*$/", "DELETE FROM \\1 WHERE 1=1", $sql); } } return $sql; } function trans_begin($test_mode = FALSE) { if (!$this->trans_enabled) { return TRUE; } if ($this->_trans_depth > 0) { return TRUE; } $this->_trans_failure = ($test_mode === TRUE) ? TRUE : FALSE; $this->simple_query('SET AUTOCOMMIT=0'); $this->simple_query('START TRANSACTION'); return TRUE; } function trans_commit() { if (!$this->trans_enabled) { return TRUE; } if ($this->_trans_depth > 0) { return TRUE; } $this->simple_query('COMMIT'); $this->simple_query('SET AUTOCOMMIT=1'); return TRUE; } function trans_rollback() { if (!$this->trans_enabled) { return TRUE; } if ($this->_trans_depth > 0) { return TRUE; } $this->simple_query('ROLLBACK'); $this->simple_query('SET AUTOCOMMIT=1'); return TRUE; } function escape_str($str, $like = FALSE) { if (is_array($str)) { foreach ($str as $key => $val) { $str[$key] = $this->escape_str($val, $like); } return $str; } if (function_exists('mysql_real_escape_string') AND is_resource($this->conn_id)) { $str = mysql_real_escape_string($str, $this->conn_id); } elseif (function_exists('mysql_escape_string') && (version_compare(PHP_VERSION, '5.3.0','<'))) { $str = mysql_escape_string($str); } else { $str = addslashes($str); } if ($like === TRUE) { $str = str_replace(array('%', '_'), array('\\%', '\\_'), $str); } return $str; } function affected_rows() { return @mysql_affected_rows($this->conn_id); } function insert_id() { return @mysql_insert_id($this->conn_id); } function count_all($table = '') { if ($table == '') { return 0; } $query = $this->query($this->_count_string . $this->_protect_identifiers('numrows') . " FROM " . $this->_protect_identifiers($table, TRUE, NULL, FALSE)); if ($query->num_rows() == 0) { return 0; } $row = $query->row(); $this->_reset_select(); return (int) $row->numrows; } function _list_tables($prefix_limit = FALSE) { $sql = "SHOW TABLES FROM " . $this->_escape_char . $this->database . $this->_escape_char; if ($prefix_limit !== FALSE AND $this->dbprefix != '') { $sql .= " LIKE '" . $this->escape_like_str($this->dbprefix) . "%'"; } return $sql; } function _list_columns($table = '') { return "SHOW COLUMNS FROM " . $this->_protect_identifiers($table, TRUE, NULL, FALSE); } function _field_data($table) { return "DESCRIBE " . $table; } function _error_message() { return mysql_error($this->conn_id); } function _error_number() { return mysql_errno($this->conn_id); } function _escape_identifiers($item) { if ($this->_escape_char == '') { return $item; } foreach ($this->_reserved_identifiers as $id) { if (strpos($item, '.' . $id) !== FALSE) { $str = $this->_escape_char . str_replace('.', $this->_escape_char . '.', $item); return preg_replace('/[' . $this->_escape_char . ']+/', $this->_escape_char, $str); } } if (strpos($item, '.') !== FALSE) { $str = $this->_escape_char . str_replace('.', $this->_escape_char . '.' . $this->_escape_char, $item) . $this->_escape_char; } else { $str = $this->_escape_char . $item . $this->_escape_char; } return preg_replace('/[' . $this->_escape_char . ']+/', $this->_escape_char, $str); } function _from_tables($tables) { if (!is_array($tables)) { $tables = array($tables); } return '(' . implode(', ', $tables) . ')'; } function _insert($table, $keys, $values) { return "INSERT INTO " . $table . " (" . implode(', ', $keys) . ") VALUES (" . implode(', ', $values) . ")"; } function _replace($table, $keys, $values) { return "REPLACE INTO " . $table . " (" . implode(', ', $keys) . ") VALUES (" . implode(', ', $values) . ")"; } function _insert_batch($table, $keys, $values) { return "INSERT INTO " . $table . " (" . implode(', ', $keys) . ") VALUES " . implode(', ', $values); } function _update($table, $values, $where, $orderby = array(), $limit = FALSE) { foreach ($values as $key => $val) { $valstr[] = $key . ' = ' . $val; } $limit = (!$limit) ? '' : ' LIMIT ' . $limit; $orderby = (count($orderby) >= 1) ? ' ORDER BY ' . implode(", ", $orderby) : ''; $sql = "UPDATE " . $table . " SET " . implode(', ', $valstr); $sql .= ($where != '' AND count($where) >= 1) ? " WHERE " . implode(" ", $where) : ''; $sql .= $orderby . $limit; return $sql; } function _update_batch($table, $values, $index, $where = NULL) { $ids = array(); $where = ($where != '' AND count($where) >= 1) ? implode(" ", $where) . ' AND ' : ''; foreach ($values as $key => $val) { $ids[] = $val[$index]; foreach (array_keys($val) as $field) { if ($field != $index) { $final[$field][] = 'WHEN ' . $index . ' = ' . $val[$index] . ' THEN ' . $val[$field]; } } } $sql = "UPDATE " . $table . " SET "; $cases = ''; foreach ($final as $k => $v) { $cases .= $k . ' = CASE ' . "\n"; foreach ($v as $row) { $cases .= $row . "\n"; } $cases .= 'ELSE ' . $k . ' END, '; } $sql .= substr($cases, 0, -2); $sql .= ' WHERE ' . $where . $index . ' IN (' . implode(',', $ids) . ')'; return $sql; } function _truncate($table) { return "TRUNCATE " . $table; } function _delete($table, $where = array(), $like = array(), $limit = FALSE) { $conditions = ''; if (count($where) > 0 OR count($like) > 0) { $conditions = "\nWHERE "; $conditions .= implode("\n", $this->ar_where); if (count($where) > 0 && count($like) > 0) { $conditions .= " AND "; } $conditions .= implode("\n", $like); } $limit = (!$limit) ? '' : ' LIMIT ' . $limit; return "DELETE FROM " . $table . $conditions . $limit; } function _limit($sql, $limit, $offset) { if ($offset == 0) { $offset = ''; } else { $offset .= ", "; } return $sql . "LIMIT " . $offset . $limit; } function _close($conn_id) { @mysql_close($conn_id); } } class CI_DB_mysql_result extends CI_DB_result { function num_rows() { return @mysql_num_rows($this->result_id); } function num_fields() { return @mysql_num_fields($this->result_id); } function list_fields() { $field_names = array(); while ($field = mysql_fetch_field($this->result_id)) { $field_names[] = $field->name; } return $field_names; } function field_data() { $retval = array(); while ($field = mysql_fetch_object($this->result_id)) { preg_match('/([a-zA-Z]+)(\(\d+\))?/', $field->Type, $matches); $type = (array_key_exists(1, $matches)) ? $matches[1] : NULL; $length = (array_key_exists(2, $matches)) ? preg_replace('/[^\d]/', '', $matches[2]) : NULL; $F = new stdClass(); $F->name = $field->Field; $F->type = $type; $F->default = $field->Default; $F->max_length = $length; $F->primary_key = ( $field->Key == 'PRI' ? 1 : 0 ); $retval[] = $F; } return $retval; } function free_result() { if (is_resource($this->result_id)) { mysql_free_result($this->result_id); $this->result_id = FALSE; } } function _data_seek($n = 0) { return mysql_data_seek($this->result_id, $n); } function _fetch_assoc() { return mysql_fetch_assoc($this->result_id); } function _fetch_object() { return mysql_fetch_object($this->result_id); } } class CI_DB_mysqli_driver extends CI_DB { var $dbdriver = 'mysqli'; var $_escape_char = '`'; var $_like_escape_str = ''; var $_like_escape_chr = ''; var $_count_string = "SELECT COUNT(*) AS "; var $_random_keyword = ' RAND()'; var $delete_hack = TRUE; var $use_set_names; function db_connect() { if ($this->port != '') { return @mysqli_connect($this->hostname, $this->username, $this->password, $this->database, $this->port); } else { return @mysqli_connect($this->hostname, $this->username, $this->password, $this->database); } } function db_pconnect() { return $this->db_connect(); } function reconnect() { if (mysqli_ping($this->conn_id) === FALSE) { $this->conn_id = FALSE; } } function db_select() { return @mysqli_select_db($this->conn_id, $this->database); } function _db_set_charset($charset, $collation) { if (!isset($this->use_set_names)) { $this->use_set_names = (version_compare(mysqli_get_server_info($this->conn_id), '5.0.7', '>=')) ? FALSE : TRUE; } if ($this->use_set_names === TRUE) { return @mysqli_query($this->conn_id, "SET NAMES '" . $this->escape_str($charset) . "' COLLATE '" . $this->escape_str($collation) . "'"); } else { return @mysqli_set_charset($this->conn_id, $charset); } } function _version() { return "SELECT version() AS ver"; } function _execute($sql) { $sql = $this->_prep_query($sql); $result = @mysqli_query($this->conn_id, $sql); return $result; } function _prep_query($sql) { if ($this->delete_hack === TRUE) { if (preg_match('/^\s*DELETE\s+FROM\s+(\S+)\s*$/i', $sql)) { $sql = preg_replace("/^\s*DELETE\s+FROM\s+(\S+)\s*$/", "DELETE FROM \\1 WHERE 1=1", $sql); } } return $sql; } function trans_begin($test_mode = FALSE) { if (!$this->trans_enabled) { return TRUE; } if ($this->_trans_depth > 0) { return TRUE; } $this->_trans_failure = ($test_mode === TRUE) ? TRUE : FALSE; $this->simple_query('SET AUTOCOMMIT=0'); $this->simple_query('START TRANSACTION'); return TRUE; } function trans_commit() { if (!$this->trans_enabled) { return TRUE; } if ($this->_trans_depth > 0) { return TRUE; } $this->simple_query('COMMIT'); $this->simple_query('SET AUTOCOMMIT=1'); return TRUE; } function trans_rollback() { if (!$this->trans_enabled) { return TRUE; } if ($this->_trans_depth > 0) { return TRUE; } $this->simple_query('ROLLBACK'); $this->simple_query('SET AUTOCOMMIT=1'); return TRUE; } function escape_str($str, $like = FALSE) { if (is_array($str)) { foreach ($str as $key => $val) { $str[$key] = $this->escape_str($val, $like); } return $str; } if (function_exists('mysqli_real_escape_string') AND is_object($this->conn_id)) { $str = mysqli_real_escape_string($this->conn_id, $str); } elseif (function_exists('mysql_escape_string') && version_compare(PHP_VERSION, '5.3.0', '<')) { $str = mysql_escape_string($str); } else { $str = addslashes($str); } if ($like === TRUE) { $str = str_replace(array('%', '_'), array('\\%', '\\_'), $str); } return $str; } function affected_rows() { return @mysqli_affected_rows($this->conn_id); } function insert_id() { return @mysqli_insert_id($this->conn_id); } function count_all($table = '') { if ($table == '') { return 0; } $query = $this->query($this->_count_string . $this->_protect_identifiers('numrows') . " FROM " . $this->_protect_identifiers($table, TRUE, NULL, FALSE)); if ($query->num_rows() == 0) { return 0; } $row = $query->row(); $this->_reset_select(); return (int) $row->numrows; } function _list_tables($prefix_limit = FALSE) { $sql = "SHOW TABLES FROM " . $this->_escape_char . $this->database . $this->_escape_char; if ($prefix_limit !== FALSE AND $this->dbprefix != '') { $sql .= " LIKE '" . $this->escape_like_str($this->dbprefix) . "%'"; } return $sql; } function _list_columns($table = '') { return "SHOW COLUMNS FROM " . $this->_protect_identifiers($table, TRUE, NULL, FALSE); } function _field_data($table) { return "DESCRIBE " . $table; } function _error_message() { return mysqli_error($this->conn_id); } function _error_number() { return mysqli_errno($this->conn_id); } function _escape_identifiers($item) { if ($this->_escape_char == '') { return $item; } foreach ($this->_reserved_identifiers as $id) { if (strpos($item, '.' . $id) !== FALSE) { $str = $this->_escape_char . str_replace('.', $this->_escape_char . '.', $item); return preg_replace('/[' . $this->_escape_char . ']+/', $this->_escape_char, $str); } } if (strpos($item, '.') !== FALSE) { $str = $this->_escape_char . str_replace('.', $this->_escape_char . '.' . $this->_escape_char, $item) . $this->_escape_char; } else { $str = $this->_escape_char . $item . $this->_escape_char; } return preg_replace('/[' . $this->_escape_char . ']+/', $this->_escape_char, $str); } function _from_tables($tables) { if (!is_array($tables)) { $tables = array($tables); } return '(' . implode(', ', $tables) . ')'; } function _insert($table, $keys, $values) { return "INSERT INTO " . $table . " (" . implode(', ', $keys) . ") VALUES (" . implode(', ', $values) . ")"; } function _insert_batch($table, $keys, $values) { return "INSERT INTO " . $table . " (" . implode(', ', $keys) . ") VALUES " . implode(', ', $values); } function _replace($table, $keys, $values) { return "REPLACE INTO " . $table . " (" . implode(', ', $keys) . ") VALUES (" . implode(', ', $values) . ")"; } function _update($table, $values, $where, $orderby = array(), $limit = FALSE) { foreach ($values as $key => $val) { $valstr[] = $key . " = " . $val; } $limit = (!$limit) ? '' : ' LIMIT ' . $limit; $orderby = (count($orderby) >= 1) ? ' ORDER BY ' . implode(", ", $orderby) : ''; $sql = "UPDATE " . $table . " SET " . implode(', ', $valstr); $sql .= ($where != '' AND count($where) >= 1) ? " WHERE " . implode(" ", $where) : ''; $sql .= $orderby . $limit; return $sql; } function _update_batch($table, $values, $index, $where = NULL) { $ids = array(); $where = ($where != '' AND count($where) >= 1) ? implode(" ", $where) . ' AND ' : ''; foreach ($values as $key => $val) { $ids[] = $val[$index]; foreach (array_keys($val) as $field) { if ($field != $index) { $final[$field][] = 'WHEN ' . $index . ' = ' . $val[$index] . ' THEN ' . $val[$field]; } } } $sql = "UPDATE " . $table . " SET "; $cases = ''; foreach ($final as $k => $v) { $cases .= $k . ' = CASE ' . "\n"; foreach ($v as $row) { $cases .= $row . "\n"; } $cases .= 'ELSE ' . $k . ' END, '; } $sql .= substr($cases, 0, -2); $sql .= ' WHERE ' . $where . $index . ' IN (' . implode(',', $ids) . ')'; return $sql; } function _truncate($table) { return "TRUNCATE " . $table; } function _delete($table, $where = array(), $like = array(), $limit = FALSE) { $conditions = ''; if (count($where) > 0 OR count($like) > 0) { $conditions = "\nWHERE "; $conditions .= implode("\n", $this->ar_where); if (count($where) > 0 && count($like) > 0) { $conditions .= " AND "; } $conditions .= implode("\n", $like); } $limit = (!$limit) ? '' : ' LIMIT ' . $limit; return "DELETE FROM " . $table . $conditions . $limit; } function _limit($sql, $limit, $offset) { $sql .= "LIMIT " . $limit; if ($offset > 0) { $sql .= " OFFSET " . $offset; } return $sql; } function _close($conn_id) { @mysqli_close($conn_id); } } class CI_DB_mysqli_result extends CI_DB_result { function num_rows() { return @mysqli_num_rows($this->result_id); } function num_fields() { return @mysqli_num_fields($this->result_id); } function list_fields() { $field_names = array(); while ($field = mysqli_fetch_field($this->result_id)) { $field_names[] = $field->name; } return $field_names; } function field_data() { $retval = array(); while ($field = mysqli_fetch_object($this->result_id)) { preg_match('/([a-zA-Z]+)(\(\d+\))?/', $field->Type, $matches); $type = (array_key_exists(1, $matches)) ? $matches[1] : NULL; $length = (array_key_exists(2, $matches)) ? preg_replace('/[^\d]/', '', $matches[2]) : NULL; $F = new stdClass(); $F->name = $field->Field; $F->type = $type; $F->default = $field->Default; $F->max_length = $length; $F->primary_key = ( $field->Key == 'PRI' ? 1 : 0 ); $retval[] = $F; } return $retval; } function free_result() { if (is_object($this->result_id)) { mysqli_free_result($this->result_id); $this->result_id = FALSE; } } function _data_seek($n = 0) { return mysqli_data_seek($this->result_id, $n); } function _fetch_assoc() { return mysqli_fetch_assoc($this->result_id); } function _fetch_object() { return mysqli_fetch_object($this->result_id); } } class CI_DB_pdo_driver extends CI_DB{ var $dbdriver = 'pdo'; var $_escape_char = ''; var $_like_escape_str; var $_like_escape_chr; var $_count_string = "SELECT COUNT(*) AS "; var $_random_keyword; var $options = array(); function __construct($params) { parent::__construct($params); if (strpos($this->hostname, 'mysql') !== FALSE) { $this->_like_escape_str = ''; $this->_like_escape_chr = ''; if(is_php('5.3.6')) { $this->hostname .= ";charset={$this->char_set}"; } $this->options['PDO::MYSQL_ATTR_INIT_COMMAND'] = "SET NAMES {$this->char_set}"; } elseif (strpos($this->hostname, 'odbc') !== FALSE) { $this->_like_escape_str = " {escape '%s'} "; $this->_like_escape_chr = '!'; } else { $this->_like_escape_str = " ESCAPE '%s' "; $this->_like_escape_chr = '!'; } empty($this->database) OR $this->hostname .= ';dbname='.$this->database; $this->trans_enabled = FALSE; $this->_random_keyword = ' RND('.time().')'; } function db_connect() { $this->options['PDO::ATTR_ERRMODE'] = PDO::ERRMODE_SILENT; return new PDO($this->hostname, $this->username, $this->password, $this->options); } function db_pconnect() { $this->options['PDO::ATTR_ERRMODE'] = PDO::ERRMODE_SILENT; $this->options['PDO::ATTR_PERSISTENT'] = TRUE; return new PDO($this->hostname, $this->username, $this->password, $this->options); } function reconnect() { if ($this->db->db_debug) { return $this->db->display_error('db_unsuported_feature'); } return FALSE; } function db_select() { return TRUE; } function _db_set_charset($charset, $collation) { return TRUE; } function _version() { return $this->conn_id->getAttribute(PDO::ATTR_CLIENT_VERSION); } function _execute($sql) { $sql = $this->_prep_query($sql); $result_id = $this->conn_id->prepare($sql); $result_id->execute(); if (is_object($result_id)) { if (is_numeric(stripos($sql, 'SELECT'))) { $this->affect_rows = count($result_id->fetchAll()); $result_id->execute(); } else { $this->affect_rows = $result_id->rowCount(); } } else { $this->affect_rows = 0; } return $result_id; } function _prep_query($sql) { return $sql; } function trans_begin($test_mode = FALSE) { if ( ! $this->trans_enabled) { return TRUE; } if ($this->_trans_depth > 0) { return TRUE; } $this->_trans_failure = (bool) ($test_mode === TRUE); return $this->conn_id->beginTransaction(); } function trans_commit() { if ( ! $this->trans_enabled) { return TRUE; } if ($this->_trans_depth > 0) { return TRUE; } $ret = $this->conn->commit(); return $ret; } function trans_rollback() { if ( ! $this->trans_enabled) { return TRUE; } if ($this->_trans_depth > 0) { return TRUE; } $ret = $this->conn_id->rollBack(); return $ret; } function escape_str($str, $like = FALSE) { if (is_array($str)) { foreach ($str as $key => $val) { $str[$key] = $this->escape_str($val, $like); } return $str; } $str = $this->conn_id->quote($str); if (strpos($str, "'") === 0) { $str = substr($str, 1, -1); } if ($like === TRUE) { $str = str_replace( array('%', '_', $this->_like_escape_chr), array($this->_like_escape_chr.'%', $this->_like_escape_chr.'_', $this->_like_escape_chr.$this->_like_escape_chr), $str); } return $str; } function affected_rows() { return $this->affect_rows; } function insert_id($name=NULL) { if (strpos($this->hostname, 'pgsql') !== FALSE) { $v = $this->_version(); $table = func_num_args() > 0 ? func_get_arg(0) : NULL; if ($table == NULL && $v >= '8.1') { $sql='SELECT LASTVAL() as ins_id'; } $query = $this->query($sql); $row = $query->row(); return $row->ins_id; } else { return $this->conn_id->lastInsertId($name); } } function count_all($table = '') { if ($table == '') { return 0; } $query = $this->query($this->_count_string . $this->_protect_identifiers('numrows') . " FROM " . $this->_protect_identifiers($table, TRUE, NULL, FALSE)); if ($query->num_rows() == 0) { return 0; } $row = $query->row(); $this->_reset_select(); return (int) $row->numrows; } function _list_tables($prefix_limit = FALSE) { $sql = "SHOW TABLES FROM `".$this->database."`"; if ($prefix_limit !== FALSE AND $this->dbprefix != '') { return FALSE; } return $sql; } function _list_columns($table = '') { return "SHOW COLUMNS FROM ".$table; } function _field_data($table) { return "SELECT TOP 1 FROM ".$table; } function _error_message() { $error_array = $this->conn_id->errorInfo(); return $error_array[2]; } function _error_number() { return $this->conn_id->errorCode(); } function _escape_identifiers($item) { if ($this->_escape_char == '') { return $item; } foreach ($this->_reserved_identifiers as $id) { if (strpos($item, '.'.$id) !== FALSE) { $str = $this->_escape_char. str_replace('.', $this->_escape_char.'.', $item); return preg_replace('/['.$this->_escape_char.']+/', $this->_escape_char, $str); } } if (strpos($item, '.') !== FALSE) { $str = $this->_escape_char.str_replace('.', $this->_escape_char.'.'.$this->_escape_char, $item).$this->_escape_char; } else { $str = $this->_escape_char.$item.$this->_escape_char; } return preg_replace('/['.$this->_escape_char.']+/', $this->_escape_char, $str); } function _from_tables($tables) { if ( ! is_array($tables)) { $tables = array($tables); } return (count($tables) == 1) ? $tables[0] : '('.implode(', ', $tables).')'; } function _insert($table, $keys, $values) { return "INSERT INTO ".$table." (".implode(', ', $keys).") VALUES (".implode(', ', $values).")"; } function _insert_batch($table, $keys, $values) { return "INSERT INTO ".$table." (".implode(', ', $keys).") VALUES ".implode(', ', $values); } function _update($table, $values, $where, $orderby = array(), $limit = FALSE) { foreach ($values as $key => $val) { $valstr[] = $key." = ".$val; } $limit = ( ! $limit) ? '' : ' LIMIT '.$limit; $orderby = (count($orderby) >= 1)?' ORDER BY '.implode(", ", $orderby):''; $sql = "UPDATE ".$table." SET ".implode(', ', $valstr); $sql .= ($where != '' AND count($where) >=1) ? " WHERE ".implode(" ", $where) : ''; $sql .= $orderby.$limit; return $sql; } function _update_batch($table, $values, $index, $where = NULL) { $ids = array(); $where = ($where != '' AND count($where) >=1) ? implode(" ", $where).' AND ' : ''; foreach ($values as $key => $val) { $ids[] = $val[$index]; foreach (array_keys($val) as $field) { if ($field != $index) { $final[$field][] = 'WHEN '.$index.' = '.$val[$index].' THEN '.$val[$field]; } } } $sql = "UPDATE ".$table." SET "; $cases = ''; foreach ($final as $k => $v) { $cases .= $k.' = CASE '."\n"; foreach ($v as $row) { $cases .= $row."\n"; } $cases .= 'ELSE '.$k.' END, '; } $sql .= substr($cases, 0, -2); $sql .= ' WHERE '.$where.$index.' IN ('.implode(',', $ids).')'; return $sql; } function _truncate($table) { return $this->_delete($table); } function _delete($table, $where = array(), $like = array(), $limit = FALSE) { $conditions = ''; if (count($where) > 0 OR count($like) > 0) { $conditions = "\nWHERE "; $conditions .= implode("\n", $this->ar_where); if (count($where) > 0 && count($like) > 0) { $conditions .= " AND "; } $conditions .= implode("\n", $like); } $limit = ( ! $limit) ? '' : ' LIMIT '.$limit; return "DELETE FROM ".$table.$conditions.$limit; } function _limit($sql, $limit, $offset) { if (strpos($this->hostname, 'cubrid') !== FALSE || strpos($this->hostname, 'sqlite') !== FALSE) { if ($offset == 0) { $offset = ''; } else { $offset .= ", "; } return $sql."LIMIT ".$offset.$limit; } else { $sql .= "LIMIT ".$limit; if ($offset > 0) { $sql .= " OFFSET ".$offset; } return $sql; } } function _close($conn_id) { $this->conn_id = null; } } class CI_DB_pdo_result extends CI_DB_result { public $num_rows; public function num_rows() { if (is_int($this->num_rows)) { return $this->num_rows; } elseif (($this->num_rows = $this->result_id->rowCount()) > 0) { return $this->num_rows; } $this->num_rows = count($this->result_id->fetchAll()); $this->result_id->execute(); return $this->num_rows; } function num_fields() { return $this->result_id->columnCount(); } function list_fields() { if ($this->db->db_debug) { return $this->db->display_error('db_unsuported_feature'); } return FALSE; } function field_data() { $data = array(); try { for($i = 0; $i < $this->num_fields(); $i++) { $data[] = $this->result_id->getColumnMeta($i); } return $data; } catch (Exception $e) { if ($this->db->db_debug) { return $this->db->display_error('db_unsuported_feature'); } return FALSE; } } function free_result() { if (is_object($this->result_id)) { $this->result_id = FALSE; } } function _data_seek($n = 0) { return FALSE; } function _fetch_assoc() { return $this->result_id->fetch(PDO::FETCH_ASSOC); } function _fetch_object() { return $this->result_id->fetchObject(); } } class CI_DB_sqlite3_driver extends CI_DB { var $dbdriver = 'pdo'; var $_escape_char = ''; var $conn_id; var $_random_keyword = ' Random()'; var $_like_escape_str = ''; var $_like_escape_chr = ''; var $delete_hack = TRUE; var $_count_string = 'SELECT COUNT(*) AS '; var $use_set_names; function db_connect() { $conn_id = false; try { $conn_id = new PDO($this->database, $this->username, $this->password); log_message('debug', "PDO driver connecting " . $this->database); } catch (PDOException $e) { log_message('debug', 'merde'); log_message('error', $e->getMessage()); if ($this->db_debug) { $this->display_error($e->getMessage(), '', TRUE); } } log_message('debug', print_r($conn_id, true)); if ($conn_id) { log_message('debug', 'PDO driver connection ok'); } $this->conn_id = $conn_id; return $conn_id; } function _list_columns($table = '') { return "PRAGMA table_info('" . $this->_protect_identifiers($table, TRUE, NULL, FALSE) . "') "; } function db_pconnect() { return $this->db_connect(); } function db_select() { return TRUE; } function _execute($sql) { $sql = $this->_prep_query($sql); log_message('debug', 'SQL : ' . $sql); return @$this->conn_id->query($sql); } function &_prep_query($sql) { return $sql; } function escape($str) { switch (gettype($str)) { case 'string' : $str = "'" . $this->escape_str($str) . "'"; break; case 'boolean' : $str = ($str === FALSE) ? 0 : 1; break; default : $str = ($str === NULL) ? 'NULL' : $str; break; } return $str; } function escape_str($str) { if (function_exists('sqlite_escape_string')) { return sqlite_escape_string($str); } else { return SQLite3::escapeString($str); } } function _escape_identifiers($item) { if ($this->_escape_char == '') { return $item; } foreach ($this->_reserved_identifiers as $id) { if (strpos($item, '.' . $id) !== FALSE) { $str = $this->_escape_char . str_replace('.', $this->_escape_char . '.', $item); return preg_replace('/[' . $this->_escape_char . ']+/', $this->_escape_char, $str); } } if (strpos($item, '.') !== FALSE) { $str = $this->_escape_char . str_replace('.', $this->_escape_char . '.' . $this->_escape_char, $item) . $this->_escape_char; } else { $str = $this->_escape_char . $item . $this->_escape_char; } return preg_replace('/[' . $this->_escape_char . ']+/', $this->_escape_char, $str); } function trans_begin($test_mode = FALSE) { if (!$this->trans_enabled) { return TRUE; } if ($this->_trans_depth > 0) { return TRUE; } $this->_trans_failure = ($test_mode === TRUE) ? TRUE : FALSE; $this->simple_query('BEGIN TRANSACTION'); return TRUE; } function trans_commit() { if (!$this->trans_enabled) { return TRUE; } if ($this->_trans_depth > 0) { return TRUE; } $this->simple_query('COMMIT'); return TRUE; } function trans_rollback() { if (!$this->trans_enabled) { return TRUE; } if ($this->_trans_depth > 0) { return TRUE; } $this->simple_query('ROLLBACK'); return TRUE; } function destroy($conn_id) { $conn_id = null; } function insert_id() { return @$this->conn_id->lastInsertId(); } function count_all($table = '') { if ($table == '') return '0'; $query = $this->query("SELECT COUNT(*) AS numrows FROM `" . $table . "`"); if ($query->num_rows() == 0) return '0'; $row = $query->row(); return $row->numrows; } function _error_message() { $infos = $this->conn_id->errorInfo(); return $infos[2]; } function _error_number() { $infos = $this->conn_id->errorInfo(); return $infos[1]; } function version() { return $this->conn_id->getAttribute(constant("PDO::ATTR_SERVER_VERSION")); } function escape_table($table) { if (stristr($table, '.')) { $table = preg_replace("/\./", "`.`", $table); } return $table; } function _field_data($table) { $sql = "SELECT * FROM " . $this->escape_table($table) . " LIMIT 1"; $query = $this->query($sql); return $query->field_data(); } function _insert($table, $keys, $values) { return "INSERT INTO " . $this->escape_table($table) . " (" . implode(', ', $keys) . ") VALUES (" . implode(', ', $values) . ")"; } function _update($table, $values, $where) { foreach ($values as $key => $val) { $valstr[] = $key . " = " . $val; } return "UPDATE " . $this->escape_table($table) . " SET " . implode(', ', $valstr) . " WHERE " . implode(" ", $where); } function _delete($table, $where) { return "DELETE FROM " . $this->escape_table($table) . " WHERE " . implode(" ", $where); } function _show_tables() { return "SELECT name from sqlite_master WHERE type='table'"; } function _show_columns($table = '') { return FALSE; } function _limit($sql, $limit, $offset) { if ($offset == 0) { $offset = ''; } else { $offset .= ", "; } return $sql . "LIMIT " . $offset . $limit; } function _from_tables($tables) { if (!is_array($tables)) { $tables = array($tables); } return implode(', ', $tables); } function db_set_charset($charset, $collation) { return TRUE; } function _close($conn_id) { } function _list_tables($prefix_limit = FALSE) { $sql = "SELECT name from sqlite_master WHERE type='table'"; if ($prefix_limit !== FALSE AND $this->dbprefix != '') { $sql .= " AND 'name' LIKE '" . $this->dbprefix . "%'"; } return $sql; } } class CI_DB_sqlite3_result extends CI_DB_result { var $pdo_results = ''; var $pdo_index = 0; function num_rows() { if (!$this->pdo_results) { $this->pdo_results = $this->result_id->fetchAll(PDO::FETCH_ASSOC); } return sizeof($this->pdo_results); } function num_fields() { if (is_array($this->pdo_results)) { return sizeof($this->pdo_results[$this->pdo_index]); } else { return $this->result_id->columnCount(); } } function _fetch_assoc() { if (is_array($this->pdo_results)) { $i = $this->pdo_index; $this->pdo_index++; if (isset($this->pdo_results[$i])) return $this->pdo_results[$i]; return null; } return $this->result_id->fetch(PDO::FETCH_ASSOC); } function _fetch_object() { if (is_array($this->pdo_results)) { $i = $this->pdo_index; $this->pdo_index++; if (isset($this->pdo_results[$i])) { $back = new stdClass(); foreach ($this->pdo_results[$i] as $key => $val) { $back->$key = $val; } return $back; } return null; } return $this->result_id->fetch(PDO::FETCH_OBJ); } } interface phpfastcache_driver { function __construct($option = array()); function checkdriver(); function driver_set($keyword, $value = "", $time = 300, $option = array() ); function driver_get($keyword, $option = array()); function driver_delete($keyword, $option = array()); function driver_clean($option = array()); } class phpfastcache_apc extends phpFastCache implements phpfastcache_driver { function checkdriver() { if (extension_loaded('apc') && ini_get('apc.enabled')) { return true; } else { return false; } } function __construct($option = array()) { $this->setOption($option); if (!$this->checkdriver() && !isset($option['skipError'])) { throw new Exception("Can't use this driver for your website!"); } } function driver_set($keyword, $value = "", $time = 300, $option = array()) { if (isset($option['skipExisting']) && $option['skipExisting'] == true) { return apc_add($keyword, $value, $time); } else { return apc_store($keyword, $value, $time); } } function driver_get($keyword, $option = array()) { $data = apc_fetch($keyword, $bo); if ($bo === false) { return null; } return $data; } function driver_delete($keyword, $option = array()) { return apc_delete($keyword); } function driver_clean($option = array()) { @apc_clear_cache(); @apc_clear_cache("user"); } function driver_isExisting($keyword) { if (apc_exists($keyword)) { return true; } else { return false; } } } class phpfastcache_files extends phpFastCache implements phpfastcache_driver { function checkdriver() { if (is_writable($this->getPath())) { return true; } else { } return false; } function __construct($option = array()) { $this->setOption($option); $this->getPath(); if (!$this->checkdriver() && !isset($option['skipError'])) { throw new Exception("Can't use this driver for your website!"); } } private function getFilePath($keyword, $skip = false) { $path = $this->getPath(); $code = md5($keyword); $folder = substr($code, 0, 2); $path = $path . "/" . $folder; if ($skip == false) { if (!file_exists($path)) { if (!@mkdir($path, 0777)) { throw new Exception("PLEASE CHMOD " . $this->getPath() . " - 0777 OR ANY WRITABLE PERMISSION!", 92); } } elseif (!is_writeable($path)) { @chmod($path, 0777); } } $file_path = $path . "/" . $code . ".txt"; return $file_path; } function driver_set($keyword, $value = "", $time = 300, $option = array()) { $file_path = $this->getFilePath($keyword); $data = $this->encode($value); $toWrite = true; if (isset($option['skipExisting']) && $option['skipExisting'] == true && file_exists($file_path)) { $content = $this->readfile($file_path); $old = $this->decode($content); $toWrite = false; if ($this->isExpired($old)) { $toWrite = true; } } if ($toWrite == true) { $f = fopen($file_path, "w+"); fwrite($f, $data); fclose($f); } } function driver_get($keyword, $option = array()) { $file_path = $this->getFilePath($keyword); if (!file_exists($file_path)) { return null; } $content = $this->readfile($file_path); $object = $this->decode($content); if ($this->isExpired($object)) { @unlink($file_path); $this->auto_clean_expired(); return null; } return $object; } function driver_delete($keyword, $option = array()) { $file_path = $this->getFilePath($keyword, true); if (@unlink($file_path)) { return true; } else { return false; } } function auto_clean_expired() { $autoclean = $this->get("keyword_clean_up_driver_files"); if ($autoclean == null) { $this->set("keyword_clean_up_driver_files", 3600 * 24); } } function driver_clean($option = array()) { $path = $this->getPath(); $dir = @opendir($path); if (!$dir) { throw new Exception("Can't read PATH:" . $path, 94); } while ($file = readdir($dir)) { if ($file != "." && $file != ".." && is_dir($path . "/" . $file)) { $subdir = @opendir($path . "/" . $file); if (!$subdir) { throw new Exception("Can't read path:" . $path . "/" . $file, 93); } while ($f = readdir($subdir)) { if ($f != "." && $f != "..") { $file_path = $path . "/" . $file . "/" . $f; unlink($file_path); } } } } } function driver_isExisting($keyword) { $file_path = $this->getFilePath($keyword, true); if (!file_exists($file_path)) { return false; } else { $value = $this->get($keyword); if ($value == null) { return false; } else { return true; } } } function isExpired($object) { if (!empty($object['expired_in']) && isset($object['expired_time']) && @date("U") >= $object['expired_time']) { return true; } else { return false; } } } class phpfastcache_memcache extends phpFastCache implements phpfastcache_driver { var $instant; function checkdriver() { if(function_exists("memcache_connect")) { return true; } return false; } function __construct($option = array()) { $this->setOption($option); if(!$this->checkdriver() && !isset($option['skipError'])) { throw new Exception("Can't use this driver for your website!"); } if ($this->checkdriver() && !is_object($this->instant)) { $this->instant = new Memcache(); } } function connectServer() { $server = $this->option['server']; if(count($server) < 1) { $server = array( array("127.0.0.1",11211), ); } foreach($server as $s) { $name = $s[0]."_".$s[1]; if(!isset($this->checked[$name])) { $this->instant->addserver($s[0],$s[1]); $this->checked[$name] = 1; } } } function driver_set($keyword, $value = "", $time = 300, $option = array() ) { $this->connectServer(); if(isset($option['skipExisting']) && $option['skipExisting'] == true) { return $this->instant->add($keyword, $value, false, $time ); } else { return $this->instant->set($keyword, $value, false, $time ); } } function driver_get($keyword, $option = array()) { $this->connectServer(); $x = $this->instant->get($keyword); if($x == false) { return null; } else { return $x; } } function driver_delete($keyword, $option = array()) { $this->connectServer(); $this->instant->delete($keyword); } function driver_clean($option = array()) { $this->connectServer(); $this->instant->flush(); } function driver_isExisting($keyword) { $this->connectServer(); $x = $this->get($keyword); if($x == null) { return false; } else { return true; } } } class phpfastcache_memcached extends phpFastCache implements phpfastcache_driver { var $instant; function checkdriver() { if (class_exists("Memcached",FALSE)) { return true; } return false; } function __construct($option = array()) { $this->setOption($option); if (!$this->checkdriver() && !isset($option['skipError'])) { throw new Exception("Can't use this driver for your website!"); } if ($this->checkdriver() && !is_object($this->instant)) { $this->instant = new Memcached(); } } function connectServer() { $s = $this->option['server']; if (count($s) < 1) { $s = array( array("127.0.0.1", 11211, 100), ); } foreach ($s as $server) { $name = isset($server[0]) ? $server[0] : "127.0.0.1"; $port = isset($server[1]) ? $server[1] : 11211; $sharing = isset($server[2]) ? $server[2] : 0; $checked = $name . "_" . $port; if (!isset($this->checked[$checked])) { if ($sharing > 0) { $this->instant->addServer($name, $port, $sharing); } else { $this->instant->addServer($name, $port); } $this->checked[$checked] = 1; } } } function driver_set($keyword, $value = "", $time = 300, $option = array()) { $this->connectServer(); if (isset($option['isExisting']) && $option['isExisting'] == true) { return $this->instant->add($keyword, $value, time() + $time); } else { return $this->instant->set($keyword, $value, time() + $time); } } function driver_get($keyword, $option = array()) { $this->connectServer(); $x = $this->instant->get($keyword); if ($x == false) { return null; } else { return $x; } } function driver_delete($keyword, $option = array()) { $this->connectServer(); $this->instant->delete($keyword); } function driver_clean($option = array()) { $this->connectServer(); $this->instant->flush(); } function driver_isExisting($keyword) { $this->connectServer(); $x = $this->get($keyword); if ($x == null) { return false; } else { return true; } } } class phpfastcache_sqlite extends phpFastCache implements phpfastcache_driver { var $max_size = 10; var $instant = array(); var $indexing = NULL; var $path = ""; var $currentDB = 1; function initDB(PDO $db) { $db->exec('drop table if exists "caching"'); $db->exec('CREATE TABLE "caching" ("id" INTEGER PRIMARY KEY AUTOINCREMENT, "keyword" VARCHAR UNIQUE, "object" BLOB, "exp" INTEGER)'); $db->exec('CREATE UNIQUE INDEX "cleaup" ON "caching" ("keyword","exp")'); $db->exec('CREATE INDEX "exp" ON "caching" ("exp")'); $db->exec('CREATE UNIQUE INDEX "keyword" ON "caching" ("keyword")'); } function initIndexing(PDO $db) { $dir = opendir($this->path); while ($file = readdir($dir)) { if ($file != "." && $file != ".." && $file != "indexing" && $file != "dbfastcache") { unlink($this->path . "/" . $file); } } $db->exec('drop table if exists "balancing"'); $db->exec('CREATE TABLE "balancing" ("keyword" VARCHAR PRIMARY KEY NOT NULL UNIQUE, "db" INTEGER)'); $db->exec('CREATE INDEX "db" ON "balancing" ("db")'); $db->exec('CREATE UNIQUE INDEX "lookup" ON "balacing" ("keyword")'); } function indexing($keyword) { if ($this->indexing == NULL) { $createTable = false; if (!file_exists($this->path . "/indexing")) { $createTable = true; } $PDO = new PDO("sqlite:" . $this->path . "/indexing"); $PDO->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); if ($createTable == true) { $this->initIndexing($PDO); } $this->indexing = $PDO; unset($PDO); $stm = $this->indexing->prepare("SELECT MAX(`db`) as `db` FROM `balancing`"); $stm->execute(); $row = $stm->fetch(PDO::FETCH_ASSOC); if (!isset($row['db'])) { $db = 1; } elseif ($row['db'] <= 1) { $db = 1; } else { $db = $row['db']; } $size = file_exists($this->path . "/db" . $db) ? filesize($this->path . "/db" . $db) : 1; $size = round($size / 1024 / 1024, 1); if ($size > $this->max_size) { $db = $db + 1; } $this->currentDB = $db; } $stm = $this->indexing->prepare("SELECT * FROM `balancing` WHERE `keyword`=:keyword LIMIT 1"); $stm->execute(array( ":keyword" => $keyword )); $row = $stm->fetch(PDO::FETCH_ASSOC); if (isset($row['db']) && $row['db'] != "") { $db = $row['db']; } else { $db = $this->currentDB; $stm = $this->indexing->prepare("INSERT INTO `balancing` (`keyword`,`db`) VALUES(:keyword, :db)"); $stm->execute(array( ":keyword" => $keyword, ":db" => $db, )); } return $db; } function db($keyword, $reset = false) { $instant = $this->indexing($keyword); if (!isset($this->instant[$instant])) { $createTable = false; if (!file_exists($this->path . "/db" . $instant) || $reset == true) { $createTable = true; } $PDO = new PDO("sqlite:" . $this->path . "/db" . $instant); $PDO->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION); if ($createTable == true) { $this->initDB($PDO); } $this->instant[$instant] = $PDO; unset($PDO); } return $this->instant[$instant]; } function checkdriver() { if (extension_loaded('pdo_sqlite') && is_writeable($this->getPath())) { return true; } return false; } function __construct($option = array()) { $this->setOption($option); if (!$this->checkdriver() && !isset($option['skipError'])) { throw new Exception("Can't use this driver for your website!"); } if ($option['storage'] == 'sqlite' && !file_exists($this->getPath() . "/sqlite")) { if (!@mkdir($this->getPath() . "/sqlite", 0777)) { die("Sorry, Please CHMOD 0777 for this path: " . $this->getPath()); } } $this->path = $this->getPath() . "/sqlite"; } function driver_set($keyword, $value = "", $time = 300, $option = array()) { $skipExisting = isset($option['skipExisting']) ? $option['skipExisting'] : false; $toWrite = true; $in_cache = $this->get($keyword, $option); if ($skipExisting == true) { if ($in_cache == null) { $toWrite = true; } else { $toWrite = false; } } if ($toWrite == true) { try { $stm = $this->db($keyword)->prepare("INSERT OR REPLACE INTO `caching` (`keyword`,`object`,`exp`) values(:keyword,:object,:exp)"); $stm->execute(array( ":keyword" => $keyword, ":object" => $this->encode($value), ":exp" => @date("U") + (Int) $time, )); return true; } catch (PDOException $e) { $stm = $this->db($keyword, true)->prepare("INSERT OR REPLACE INTO `caching` (`keyword`,`object`,`exp`) values(:keyword,:object,:exp)"); $stm->execute(array( ":keyword" => $keyword, ":object" => $this->encode($value), ":exp" => @date("U") + (Int) $time, )); } } return false; } function driver_get($keyword, $option = array()) { try { $stm = $this->db($keyword)->prepare("SELECT * FROM `caching` WHERE `keyword`=:keyword LIMIT 1"); $stm->execute(array( ":keyword" => $keyword )); $row = $stm->fetch(PDO::FETCH_ASSOC); } catch (PDOException $e) { $stm = $this->db($keyword, true)->prepare("SELECT * FROM `caching` WHERE `keyword`=:keyword LIMIT 1"); $stm->execute(array( ":keyword" => $keyword )); $row = $stm->fetch(PDO::FETCH_ASSOC); } if ($this->isExpired($row)) { $this->deleteRow($row); return null; } if (isset($row['id'])) { $data = $this->decode($row['object']); return $data; } return null; } function isExpired($row) { $object= $this->decode($row['object']); if (!empty($object['expired_in'])&&isset($row['exp']) && @date("U") >= $row['exp']) { return true; } return false; } function deleteRow($row) { $stm = $this->db($row['keyword'])->prepare("DELETE FROM `caching` WHERE (`id`=:id) OR (`exp` <= :U) "); $stm->execute(array( ":id" => $row['id'], ":U" => @date("U"), )); } function driver_delete($keyword, $option = array()) { $stm = $this->db($keyword)->prepare("DELETE FROM `caching` WHERE (`keyword`=:keyword) OR (`exp` <= :U)"); $stm->execute(array( ":keyword" => $keyword, ":U" => @date("U"), )); } function driver_clean($option = array()) { $dir = opendir($this->path); while ($file = readdir($dir)) { if ($file != "." && $file != "..") { unlink($this->path . "/" . $file); } } } function driver_isExisting($keyword) { $stm = $this->db($keyword)->prepare("SELECT COUNT(`id`) as `total` FROM `caching` WHERE `keyword`=:keyword"); $stm->execute(array( ":keyword" => $keyword )); $data = $stm->fetch(PDO::FETCH_ASSOC); if ($data['total'] >= 1) { return true; } else { return false; } } } class phpfastcache_wincache extends phpFastCache implements phpfastcache_driver { function checkdriver() { if(extension_loaded('wincache') && function_exists("wincache_ucache_set")) { return true; } return false; } function __construct($option = array()) { $this->setOption($option); if(!$this->checkdriver() && !isset($option['skipError'])) { throw new Exception("Can't use this driver for your website!"); } } function driver_set($keyword, $value = "", $time = 300, $option = array() ) { if(isset($option['skipExisting']) && $option['skipExisting'] == true) { return wincache_ucache_add($keyword, $value, $time); } else { return wincache_ucache_set($keyword, $value, $time); } } function driver_get($keyword, $option = array()) { $x = wincache_ucache_get($keyword,$suc); if($suc == false) { return null; } else { return $x; } } function driver_delete($keyword, $option = array()) { return wincache_ucache_delete($keyword); } function driver_clean($option = array()) { wincache_ucache_clear(); return true; } function driver_isExisting($keyword) { if(wincache_ucache_exists($keyword)) { return true; } else { return false; } } } class phpfastcache_xcache extends phpFastCache implements phpfastcache_driver { function checkdriver() { if(extension_loaded('xcache') && function_exists("xcache_get")) { return true; } return false; } function __construct($option = array()) { $this->setOption($option); if(!$this->checkdriver() && !isset($option['skipError'])) { throw new Exception("Can't use this driver for your website!"); } } function driver_set($keyword, $value = "", $time = 300, $option = array() ) { if(isset($option['skipExisting']) && $option['skipExisting'] == true) { if(!$this->isExisting($keyword)) { return xcache_set($keyword,$value,$time); } } else { return xcache_set($keyword,$value,$time); } return false; } function driver_get($keyword, $option = array()) { $data = xcache_get($keyword); if($data === false || $data == "") { return null; } return $data; } function driver_delete($keyword, $option = array()) { return xcache_unset($keyword); } function driver_clean($option = array()) { $cnt = xcache_count(XC_TYPE_VAR); for ($i=0; $i < $cnt; $i++) { xcache_clear_cache(XC_TYPE_VAR, $i); } return true; } function driver_isExisting($keyword) { if(xcache_isset($keyword)) { return true; } else { return false; } } } class phpfastcache_redis extends phpFastCache implements phpfastcache_driver { var $instant; function checkdriver() { if (class_exists("redis",FALSE)) { return true; } return false; } function __construct($option = array()) { $this->setOption($option); if (!$this->checkdriver() && !isset($option['skipError'])) { throw new Exception("Can't use this driver for your website!"); } if ($this->checkdriver() && !is_object($this->instant)) { $this->instant = new Redis(); } } function connectServer() { $config = $this->option['redis']; $this->instant = new Redis(); if ($config['type'] == 'sock') { $this->instant->connect($config['sock']); } else { $this->instant->connect($config['host'], $config['port'], $config['timeout'], NULL, $config['retry']); } if (!is_null($config['password'])) { $this->instant->auth($config['password']); } if (!is_null($config['prefix'])) { if ($config['prefix']{strlen($config['prefix']) - 1} != ':') { $config['prefix'].=':'; } $this->instant->setOption(Redis::OPT_PREFIX, $config['prefix']); } } function driver_set($keyword, $value = "", $time = 300, $option = array()) { $this->connectServer(); $value = serialize($value); return ($time) ? $this->instant->setex($keyword, $time, $value) : $this->instant->set($keyword, $value); } function driver_get($keyword, $option = array()) { $this->connectServer(); if (($data = $this->instant->get($keyword))) { return @unserialize($data); } else { return null; } } function driver_delete($keyword, $option = array()) { $this->connectServer(); $this->instant->delete($keyword); } function driver_clean($option = array()) { $this->connectServer(); $this->instant->flushDB(); } function driver_isExisting($keyword) { $this->connectServer(); return $this->instant->exists($keyword); } } class phpFastCache { var $drivers = array('apc', 'files', 'sqlite', 'memcached', 'redis', 'wincache', 'xcache', 'memcache'); private static $intances = array(); public static $storage = "auto"; public static $config = array( "storage" => "auto", "fallback" => array( ), "securityKey" => "", "htaccess" => false, "path" => "", "server" => array( array("127.0.0.1", 11211, 1), ), "extensions" => array(), ); var $tmp = array(); var $checked = array( "path" => false, "fallback" => false, "hook" => false, ); var $is_driver = false; var $driver = NULL; var $option = array( "path" => "", "htaccess" => null, "securityKey" => '', "system" => array(), "storage" => "", "cachePath" => "", ); function __construct($storage = "", $option = array()) { self::setup($option); if (!$this->isExistingDriver($storage) && isset(self::$config['fallback'][$storage])) { $storage = self::$config['fallback'][$storage]; } if ($storage == "") { $storage = self::$storage; self::option("storage", $storage); } else { self::$storage = $storage; } $this->tmp['storage'] = $storage; if ($storage != "auto" && $storage != "" && $this->isExistingDriver($storage)) { $driver = "phpfastcache_" . $storage; } else { $storage = $this->autoDriver(); self::$storage = $storage; $driver = "phpfastcache_" . $storage; } $this->option("storage", $storage); if (class_exists($driver, false)) { $this->driver = new $driver($this->option); $this->driver->is_driver = true; } } public static function getInstance($type, $config) { if (!isset(self::$intances[$type])) { self::$intances[$type] = new phpFastCache($type, $config); } return self::$intances[$type]; } function set($keyword, $value = "", $time = 300, $option = array()) { $object = array( "value" => $value, "write_time" => @date("U"), "expired_in" => $time, "expired_time" => @date("U") + (Int) $time, ); if ($this->is_driver == true) { return $this->driver_set($keyword, $object, $time, $option); } else { return $this->driver->driver_set($keyword, $object, $time, $option); } } function get($keyword, $option = array()) { if ($this->is_driver == true) { $object = $this->driver_get($keyword, $option); } else { $object = $this->driver->driver_get($keyword, $option); } if ($object == null) { return null; } return $object['value']; } function delete($keyword, $option = array()) { if ($this->is_driver == true) { return $this->driver_delete($keyword, $option); } else { return $this->driver->driver_delete($keyword, $option); } } function clean($option = array()) { if ($this->is_driver == true) { return $this->driver_clean($option); } else { return $this->driver->driver_clean($option); } } public static function setup($name, $value = "") { if (!is_array($name)) { if ($name == "storage") { self::$storage = $value; } self::$config[$name] = $value; } else { foreach ($name as $n => $value) { self::setup($n, $value); } } } function autoDriver() { foreach ($this->drivers as $namex) { $class = "phpfastcache_" . $namex; $option = $this->option; $option['skipError'] = true; $_driver = new $class($option); $_driver->option = $option; if ($_driver->checkdriver()) { return $namex; } } $system = systemInfo(); foreach ($system['cache_drivers'] as $filepath) { $file = pathinfo($filepath, PATHINFO_BASENAME); $namex = str_replace(".php", "", $file); $clazz = "phpfastcache_" . $namex; $option = $this->option; $option['skipError'] = true; $_driver = new $clazz($option); $_driver->option = $option; if ($_driver->checkdriver()) { return $namex; } } return ""; } function option($name, $value = null) { if ($value == null) { if (isset($this->option[$name])) { return $this->option[$name]; } else { return null; } } else { if ($name == "path") { $this->checked['path'] = false; $this->driver->checked['path'] = false; } self::$config[$name] = $value; $this->option[$name] = $value; $this->driver->option[$name] = $this->option[$name]; return $this; } } public function setOption($option = array()) { $this->option = array_merge($this->option, self::$config, $option); $this->checked['path'] = false; } function __get($name) { $this->driver->option = $this->option; return $this->driver->get($name); } function __set($name, $v) { $this->driver->option = $this->option; if (isset($v[1]) && is_numeric($v[1])) { return $this->driver->set($name, $v[0], $v[1], isset($v[2]) ? $v[2] : array() ); } else { throw new Exception("Example ->$name = array('VALUE', 300);", 98); } } private function isExistingDriver($class) { $class = strtolower($class); if (!class_exists("phpfastcache_" . $class, false)) { return false; } foreach ($this->drivers as $namex) { $clazz = "phpfastcache_" . $namex; if (class_exists($clazz, false)) { $option = $this->option; $option['skipError'] = true; $_driver = new $clazz($option); $_driver->option = $option; if ($_driver->checkdriver() && $class == $namex) { return true; } } } $system = systemInfo(); foreach ($system['cache_drivers'] as $filepath) { $file = pathinfo($filepath, PATHINFO_BASENAME); $namex = str_replace(".php", "", $file); $clazz = "phpfastcache_" . $namex; if (class_exists($clazz, false)) { $option = $this->option; $option['skipError'] = true; $_driver = new $clazz($option); $_driver->option = $option; if ($_driver->checkdriver() && $class == $namex) { return true; } } } return false; } public function encode($data) { return serialize($data); } public function decode($value) { $x = @unserialize($value); if ($x == false) { return $value; } else { return $x; } } public function isPHPModule() { if (PHP_SAPI == "apache2handler") { return true; } else { if (strpos(PHP_SAPI, "handler") !== false) { return true; } } return false; } public function getPath($create_path = false) { if ($this->option['path'] == "" && self::$config['path'] != "") { $this->option("path", self::$config['path']); } if ($this->option['path'] == '') { if ($this->isPHPModule()) { $tmp_dir = ini_get('upload_tmp_dir') ? ini_get('upload_tmp_dir') : sys_get_temp_dir(); $this->option("path", $tmp_dir); } else { $this->option("path", dirname(__FILE__)); } if (self::$config['path'] == "") { self::$config['path'] = $this->option("path"); } } $full_path = $this->option("path") . "/"; if ($create_path == false && $this->checked['path'] == false) { if (!file_exists($full_path) || !is_writable($full_path)) { if (!file_exists($full_path)) { @mkdir($full_path, 0777); } if (!is_writable($full_path)) { @chmod($full_path, 0777); } } $this->checked['path'] = true; } $this->option['cachePath'] = $full_path; return $this->option['cachePath']; } function readfile($file) { if (function_exists("file_get_contents")) { return file_get_contents($file); } else { $string = ""; $file_handle = @fopen($file, "r"); if (!$file_handle) { throw new Exception("Can't Read File", 96); } while (!feof($file_handle)) { $line = fgets($file_handle); $string .= $line; } fclose($file_handle); return $string; } } } interface WoniuSessionHandle { public function start($config=array()); public function open($save_path, $session_name); public function close(); public function read($id); public function write($id, $data); public function destroy($id); public function gc($max=0); } class MysqlSessionHandle implements WoniuSessionHandle { private $_config; protected $dbConnection; protected $dbTable; public function connect() { $config = $this->_config; $dbHost = $config['host']; $dbPort = $config['port']; $dbUser = $config['user']; $dbPassword = $config['password']; $dbDatabase = $config['database']; $dbTable = $config['table']; $this->dbConnection = new mysqli($dbHost, $dbUser, $dbPassword, $dbDatabase, $dbPort); $this->dbTable = $dbTable; if (mysqli_connect_error()) { throw new Exception('Connect Error (' . mysqli_connect_errno() . ') ' . mysqli_connect_error()); } } public function start($config = array()) { $this->_config = $config = array_merge($config['common'], $config['mysql']); session_set_save_handler(array($this, 'open'), array($this, 'close'), array($this, 'read'), array($this, 'write'), array($this, 'destroy'), array($this, 'gc')); } public function open($save_path, $session_name) { if (!is_object($this->dbConnection)) { $this->connect(); } return TRUE; } public function close() { return $this->dbConnection->close(); } public function read($id) { $sql = sprintf("SELECT data FROM %s WHERE id = '%s'", $this->dbTable, $this->dbConnection->escape_string($id)); if ($result = $this->dbConnection->query($sql)) { if ($result->num_rows && $result->num_rows > 0) { $record = $result->fetch_assoc(); $sql = sprintf("update  %s set `timestamp` =%s where id='%s' ", $this->dbTable, time() + intval($this->_config['lifetime']), $this->dbConnection->escape_string($id)); $this->dbConnection->query($sql); return $record['data']; } else { return false; } } else { return false; } return true; } public function write($id, $data) { $sql = sprintf("REPLACE INTO %s VALUES('%s', '%s', %s)", $this->dbTable, $this->dbConnection->escape_string($id), $this->dbConnection->escape_string($data), time() + intval($this->_config['lifetime'])); return $this->dbConnection->query($sql); } public function destroy($id) { unset($_SESSION); $sql = sprintf("DELETE FROM %s WHERE `id` = '%s'", $this->dbTable, $this->dbConnection->escape_string($id)); return $this->dbConnection->query($sql); } public function gc($max = 0) { $sql = sprintf("DELETE FROM %s WHERE `timestamp` < %s ", $this->dbTable, time()); return $this->dbConnection->query($sql); } } class MongodbSessionHandle implements WoniuSessionHandle { protected $_config; private $__mongo_collection = NULL; private $__current_session = NULL; private $__mongo_conn = NULL; public function connect() { $connection_string = sprintf('mongodb://%s:%s', $this->_config['host'], $this->_config['port']); if ($this->_config['user'] != null && $this->_config['password'] != null) { $connection_string = sprintf('mongodb://%s:%s@%s:%s/%s', $this->_config['user'], $this->_config['password'], $this->_config['host'], $this->_config['port'], $this->_config['database']); } $opts = array('connect' => true); if ($this->_config['persistent'] && !empty($this->_config['persistentId'])) { $opts['persist'] = $this->_config['persistentId']; } if ($this->_config['replicaSet']) { $opts['replicaSet'] = $this->_config['replicaSet']; } $class = 'MongoClient'; if (!class_exists($class)) { $class = 'Mongo'; } $this->__mongo_conn=$object_conn = new $class($connection_string, $opts); $object_mongo = $object_conn->{$this->_config['database']}; $this->__mongo_collection = $object_mongo->{$this->_config['collection']}; } public function start($config = array()) { $config = array_merge($config['common'], $config['mongodb']); $this->_config = $config; session_set_save_handler(array(&$this, 'open'), array(&$this, 'close'), array(&$this, 'read'), array(&$this, 'write'), array(&$this, 'destroy'), array(&$this, 'gc')); } public function open($session_path, $session_name) { if (!is_object($this->__mongo_collection)) { $this->connect(); } $result = true; if ($this->__mongo_collection == NULL) { $result = false; } return $result; } public function close() { $this->__mongo_conn->close(); return true; } public function read($session_id) { $result = NULL; $ret = ''; $expiry = time(); $query['_id'] = $session_id; $query['expiry'] = array('$gte' => $expiry); $result = $this->__mongo_collection->findone($query); if ($result) { $this->__current_session = $result; $result['expiry'] = time() + $this->_config['lifetime']; $this->__mongo_collection->update(array("_id" => $session_id), $result); $ret = $result['data']; } return $ret; } public function write($session_id, $data) { $result = true; $expiry = time() + $this->_config['lifetime']; $session_data = array(); if (empty($this->__current_session)) { $session_id = $session_id; $session_data['_id'] = $session_id; $session_data['data'] = $data; $session_data['expiry'] = $expiry; } else { $session_data = (array) $this->__current_session; $session_data['data'] = $data; $session_data['expiry'] = $expiry; } $query['_id'] = $session_id; $record = $this->__mongo_collection->findOne($query); if ($record == null) { $this->__mongo_collection->insert($session_data); } else { $record['data'] = $data; $record['expiry'] = $expiry; $this->__mongo_collection->save($record); } return true; } public function destroy($session_id) { unset($_SESSION); $query['_id'] = $session_id; $this->__mongo_collection->remove($query); return true; } public function gc($max = 0) { $query = array(); $query['expiry'] = array(':lt' => time()); $this->__mongo_collection->remove($query, array('justOne' => false)); return true; } } class MemcacheSessionHandle { public function start($config = array()) { ini_set('session.save_handler', 'memcache'); ini_set('session.save_path', $config['memcache']); } } class RedisSessionHandle { public function start($config = array()) { ini_set('session.save_handler', 'redis'); ini_set('session.save_path', $config['redis']); } }