本文共 16022 字，大约阅读时间需要 53 分钟。

<?php /**  * 获取和设置配置参数 支持批量定义  * 如果$key是关联型数组，则会按K-V的形式写入配置  * 如果$key是数字索引数组，则返回对应的配置数组  * @param string|array $key 配置变量  * @param array|null $value 配置值  * @return array|null  */ function C($key,$value=null){     static $_config = array();     $args = func_num_args();     if($args == 1){         if(is_string($key)){  //如果传入的key是字符串             return isset($_config[$key])?$_config[$key]:null;         }         if(is_array($key)){             if(array_keys($key) !== range(0, count($key) - 1)){  //如果传入的key是关联数组                 $_config = array_merge($_config, $key);             }else{                 $ret = array();                 foreach ($key as $k) {                     $ret[$k] = isset($_config[$k])?$_config[$k]:null;                 }                 return $ret;             }         }     }else{         if(is_string($key)){             $_config[$key] = $value;         }else{             halt('传入参数不正确');         }     }     return null; } /**  * 调用Widget  * @param string $name widget名  * @param array $data 传递给widget的变量列表，key为变量名，value为变量值  * @return void  */ function W($name, $data = array()){     $fullName = $name.'Widget';     if(!class_exists($fullName)){         halt('Widget '.$name.'不存在');     }     $widget = new $fullName();     $widget->invoke($data); } /**  * 终止程序运行  * @param string $str 终止原因  * @param bool $display 是否显示调用栈，默认不显示  * @return void  */ function halt($str, $display=false){     Log::fatal($str.' debug_backtrace:'.var_export(debug_backtrace(), true));     header("Content-Type:text/html; charset=utf-8");     if($display){         echo "<pre>";         debug_print_backtrace();         echo "</pre>";     }     echo $str;     exit; } /* <?php // Default connection ORM::configure('sqlite:./example.db'); // A named connection, where 'remote' is an arbitrary key name ORM::configure('mysql:host=localhost;dbname=my_database', null, 'remote'); ORM::configure('username', 'database_user', 'remote'); ORM::configure('password', 'top_secret', 'remote'); // Using default connection $person = ORM::for_table('person')->find_one(5); // Using default connection, explicitly $person = ORM::for_table('person', ORM::DEFAULT_CONNECTION)->find_one(5); // Using named connection $person = ORM::for_table('different_person', 'remote')->find_one(5); */ //增加idiorm支持 function Model($dbConf=null){ require_once(__DIR__."/lib/idiorm.php"); //缓存配置，可配成REDIS等 $my_cache = array(); ORM::configure('cache_query_result', function ($cache_key, $value, $table_name, $connection_name) use (&$my_cache) {     $my_cache[$cache_key] = $value; }); ORM::configure('check_query_cache', function ($cache_key, $table_name, $connection_name) use (&$my_cache) {     if(isset($my_cache[$cache_key])){        return $my_cache[$cache_key];     } else {     return false;     } }); ORM::configure('clear_cache', function ($table_name, $connection_name) use (&$my_cache) {      $my_cache = array(); }); ORM::configure('caching', false); ORM::configure('caching_auto_clear', true); //ORM::clear_cache() ORM::configure('create_cache_key', function ($query, $parameters, $table_name, $connection_name) {     $parameter_string = join(',', $parameters);     $key = $query . ':' . $parameter_string;     $my_key = 'my-prefix'.crc32($key);     return $my_key; }); if($dbConf==null) { $dbConf = C(array('DB_HOST','DB_PORT','DB_USER','DB_PWD','DB_NAME','DB_CHARSET','DB_DEBUG')); ORM::configure('mysql:host='. $dbConf['DB_HOST'].':'.$dbConf['DB_PORT'].';dbname='.$dbConf['DB_NAME']); ORM::configure('username', $dbConf['DB_USER']); ORM::configure('password', $dbConf['DB_PWD']); ORM::configure('driver_options', array(PDO::MYSQL_ATTR_INIT_COMMAND => "set names ".$dbConf['DB_CHARSET'])); ORM::configure('return_result_sets',false); // returns result sets ORM::configure('logging', $dbConf['DB_DEBUG']); ORM::configure('logger', function($log_string, $query_time) {     echo $log_string . ' in ' . $query_time.'<br/>'; }); return 'default'; } else { $conn=md5(implode('',$dbConf)); ORM::configure('mysql:host='. $dbConf['DB_HOST'].':'.$dbConf['DB_PORT'].';dbname='.$dbConf['DB_NAME'],null,$conn);   ORM::configure('username', $dbConf['DB_USER'],$conn); ORM::configure('password', $dbConf['DB_PWD'],$conn); ORM::configure('driver_options', array(PDO::MYSQL_ATTR_INIT_COMMAND => "set names ".$dbConf['DB_CHARSET']),$conn); ORM::configure('return_result_sets',false,$conn); // returns result sets ORM::configure('logging', $dbConf['DB_DEBUG'],$conn); ORM::configure('logger', function($log_string, $query_time) {     echo $log_string . ' in ' . $query_time.'<br/>'; },$conn);   return $conn; } $instance = ORM::get_db(); return $instance; } /**  * 获取数据库实例  * @return DB  */ function M(){     $dbConf = C(array('DB_HOST','DB_PORT','DB_USER','DB_PWD','DB_NAME','DB_CHARSET'));     return DB::getInstance($dbConf); } /**  * 如果文件存在就include进来  * @param string $path 文件路径  * @return void  */ function includeIfExist($path){     if(file_exists($path)){         include $path;     } } /**  * 总控类  */ class SinglePHP {     /**      * 控制器      * @var string      */     private $c;     /**      * Action      * @var string      */     private $a;     /**      * 单例      * @var SinglePHP      */     private static $_instance;     /**      * 构造函数，初始化配置      * @param array $conf      */     private function __construct($conf){         C($conf);     }     private function __clone(){}  function parseUrl(){ if (isset($_SERVER['PATH_INFO'])){       //获取 pathinfo               $pathinfo = explode('/', trim($_SERVER['PATH_INFO'], "/"));         // 获取 control         $_GET['C'] = (!empty($pathinfo[0]) ? $pathinfo[0] : 'Index');                     $this->c =$_GET['C'];         array_shift($pathinfo); //将数组开头的单元移出数组              // 获取 action         $_GET['A'] = (!empty($pathinfo[0]) ? $pathinfo[0] : 'Index');         $this->a =$_GET['A'];            array_shift($pathinfo); //再将将数组开头的单元移出数组                                                   for($i=0; $i<count($pathinfo); $i+=2){    if(isset($pathinfo[$i+1])){ $_GET[$pathinfo[$i]]=$pathinfo[$i+1]; $_REQUEST[$pathinfo[$i]]=$pathinfo[$i+1];    } } }else{ $_GET["C"]= (!empty($_GET['C']) ? $_GET['C']: 'Index');    //默认是index模块 $_GET["A"]= (!empty($_GET['A']) ? $_GET['A'] : 'Index');   //默认是index动作 if($_SERVER["QUERY_STRING"]){ $m=$_GET["C"]; unset($_GET["C"]);  //去除数组中的m $a=$_GET["A"]; unset($_GET["A"]);  //去除数组中的a $query=http_build_query($_GET);   //形成0=foo&1=bar&2=baz&3=boom&cow=milk格式 //组成新的URL $url=$_SERVER["SCRIPT_NAME"]."/{$m}/{$a}/".str_replace(array("&","="), "/", $query); header("Location:".$url); } } }     /**      * 获取单例      * @param array $conf      * @return SinglePHP      */     public static function getInstance($conf){         if(!(self::$_instance instanceof self)){             self::$_instance = new self($conf);         }         return self::$_instance;     }     /**      * 运行应用实例      * @access public      * @return void      */     public function run(){         if(C('USE_SESSION') == true){             session_start();         }         C('APP_FULL_PATH', getcwd().'/'.C('APP_PATH').'/');         includeIfExist( C('APP_FULL_PATH').'/common.php');                $pathMod = C('PATH_MOD');         $pathMod = empty($pathMod)?'NORMAL':$pathMod;         spl_autoload_register(array('SinglePHP', 'autoload'));                           /*         if(strcmp(strtoupper($pathMod),'NORMAL') === 0 || !isset($_SERVER['PATH_INFO'])){ //             $this->c = isset($_GET['c'])?$_GET['c']:'Index';             $this->a = isset($_GET['a'])?$_GET['a']:'Index';         }else{                           $pathInfo = isset($_SERVER['PATH_INFO'])?$_SERVER['PATH_INFO']:'';             $pathInfoArr = explode('/',trim($pathInfo,'/'));             if(isset($pathInfoArr[0]) && $pathInfoArr[0] !== ''){                 $this->c = $pathInfoArr[0];             }else{                 $this->c = 'Index';             }             if(isset($pathInfoArr[1])){                 $this->a = $pathInfoArr[1];             }else{                 $this->a = 'Index';             }                          for($i=2; $i<count($pathInfoArr); $i+=2){ $_GET[$pathInfoArr[$i]]=$pathInfoArr[$i+1]; }         }         */         $this->parseUrl();                                    if(!class_exists($this->c.'Controller')){             header("Content-Type:text/html; charset=utf-8");               $tpl = $this->c . '/' . $this->a;               $view = new View();               $view->display($tpl);               return;         }                   $controllerClass = $this->c.'Controller';         $controller = new $controllerClass();         if(!method_exists($controller, $this->a.'Action')){             header("Content-Type:text/html; charset=utf-8");             $tpl = $this->c . '/' . $this->a;               $view = new View();                              $view->display($tpl);               return;             //halt('方法'.$this->a.'不存在');         }         call_user_func(array($controller,$this->a.'Action'));     }     /**      * 自动加载函数      * @param string $class 类名      */     public static function autoload($class){         if(substr($class,-10)=='Controller'){             includeIfExist(C('APP_FULL_PATH').'/Controller/'.$class.'.class.php');         }elseif(substr($class,-6)=='Widget'){             includeIfExist(C('APP_FULL_PATH').'/Widget/'.$class.'.class.php');         }else{             includeIfExist(C('APP_FULL_PATH').'/Lib/'.$class.'.class.php');         }     } } /**  * 控制器类  */ class Controller {     /**      * 视图实例      * @var View      */     private $_view;     /**      * 构造函数，初始化视图实例，调用hook      */     public function __construct(){         $this->_view = new View();         $this->_init();     }     /**      * 前置hook      */     protected function _init(){}     /**      * 渲染模板并输出      * @param null|string $tpl 模板文件路径      * 参数为相对于App/View/文件的相对路径，不包含后缀名，例如index/index      * 如果参数为空，则默认使用$controller/$action.php      * 如果参数不包含"/"，则默认使用$controller/$tpl      * @return void      */     protected function display($tpl=''){         if($tpl === ''){             $trace = debug_backtrace();             $controller = substr($trace[1]['class'], 0, -10);             $action = substr($trace[1]['function'], 0 , -6);             $tpl = $controller . '/' . $action;         }elseif(strpos($tpl, '/') === false){             $trace = debug_backtrace();             $controller = substr($trace[1]['class'], 0, -10);             $tpl = $controller . '/' . $tpl;         }         $this->_view->display($tpl);     }     /**      * 为视图引擎设置一个模板变量      * @param string $name 要在模板中使用的变量名      * @param mixed $value 模板中该变量名对应的值      * @return void      */     protected function assign($name,$value){         $this->_view->assign($name,$value);     }     /**      * 将数据用json格式输出至浏览器，并停止执行代码      * @param array $data 要输出的数据      */     protected function ajaxReturn($data){         echo json_encode($data);         exit;     }     /**      * 重定向至指定url      * @param string $url 要跳转的url      * @param void      */     protected function redirect($url){         header("Location: $url");         exit;     } } /**  * 视图类  */ class View {     /**      * 视图文件目录      * @var string      */     private $_tplDir;     /**      * 视图文件路径      * @var string      */     private $_viewPath;     /**      * 视图变量列表      * @var array      */     private $_data = array();     /**      * 给tplInclude用的变量列表      * @var array      */     private static $tmpData;     /**      * @param string $tplDir      */     public function __construct($tplDir=''){         if($tplDir == ''){             $this->_tplDir = './'.C('APP_PATH').'/View/';         }else{             $this->_tplDir = $tplDir;         }     }     /**      * 为视图引擎设置一个模板变量      * @param string $key 要在模板中使用的变量名      * @param mixed $value 模板中该变量名对应的值      * @return void      */     public function assign($key, $value) {         $this->_data[$key] = $value;     }     /**      * 渲染模板并输出      * @param null|string $tplFile 模板文件路径，相对于App/View/文件的相对路径，不包含后缀名，例如index/index      * @return void      */     public function display($tplFile) {                  $this->_viewPath = $this->_tplDir . $tplFile . '.php';         if(!file_exists($this->_viewPath))         {             halt("视图文件".$this->_viewPath."不存在！");         }         unset($tplFile);         extract($this->_data);         include $this->_viewPath;     }     /**      * 用于在模板文件中包含其他模板      * @param string $path 相对于View目录的路径      * @param array $data 传递给子模板的变量列表，key为变量名，value为变量值      * @return void      */     public static function tplInclude($path, $data=array()){         self::$tmpData = array(             'path' => C('APP_FULL_PATH') . '/View/' . $path . '.php',             'data' => $data,         );         unset($path);         unset($data);         if(self::$tmpData['data']!=null)         extract(self::$tmpData['data']);         include self::$tmpData['path'];     } } /**  * Widget类  * 使用时需继承此类，重写invoke方法，并在invoke方法中调用display  */ class Widget {     /**      * 视图实例      * @var View      */     protected $_view;     /**      * Widget名      * @var string      */     protected $_widgetName;     /**      * 构造函数，初始化视图实例      */     public function __construct(){         $this->_widgetName = get_class($this);         $dir = C('APP_FULL_PATH') . '/Widget/Tpl/';         $this->_view = new View($dir);     }     /**      * 处理逻辑      * @param mixed $data 参数      */     public function invoke($data){}     /**      * 渲染模板      * @param string $tpl 模板路径，如果为空则用类名作为模板名      */     protected function display($tpl=''){         if($tpl == ''){             $tpl = $this->_widgetName;         }         $this->_view->display($tpl);     }     /**      * 为视图引擎设置一个模板变量      * @param string $name 要在模板中使用的变量名      * @param mixed $value 模板中该变量名对应的值      * @return void      */     protected function assign($name,$value){         $this->_view->assign($name,$value);     } } /**  * 数据库操作类  * 使用方法：  * DB::getInstance($conf)->query('select * from table');  * 其中$conf是一个关联数组，需要包含以下key：  * DB_HOST DB_USER DB_PWD DB_NAME  * 可以用DB_PORT和DB_CHARSET来指定端口和编码，默认3306和utf8  */ class DB {     /**      * 数据库链接      * @var resource      */     private $_db;     /**      * 保存最后一条sql      * @var string      */     private $_lastSql;     /**      * 上次sql语句影响的行数      * @var int      */     private $_rows;     /**      * 上次sql执行的错误      * @var string      */     private $_error;     /**      * 实例数组      * @var array      */     private static $_instance = array();     /**      * 构造函数      * @param array $dbConf 配置数组      */     private function __construct($dbConf){         if(!isset($dbConf['DB_CHARSET'])){             $dbConf['DB_CHARSET'] = 'utf8';         }         $this->_db = mysql_connect($dbConf['DB_HOST'].':'.$dbConf['DB_PORT'],$dbConf['DB_USER'],$dbConf['DB_PWD']);         if($this->_db === false){             halt(mysql_error());         }         $selectDb = mysql_select_db($dbConf['DB_NAME'],$this->_db);         if($selectDb === false){             halt(mysql_error());         }         mysql_set_charset($dbConf['DB_CHARSET']);     }     private function __clone(){}     /**      * 获取DB类      * @param array $dbConf 配置数组      * @return DB      */     static public function getInstance($dbConf){         if(!isset($dbConf['DB_PORT'])){             $dbConf['DB_PORT'] = '3306';         }         $key = $dbConf['DB_HOST'].':'.$dbConf['DB_PORT'];         if(!isset(self::$_instance[$key]) || !(self::$_instance[$key] instanceof self)){             self::$_instance[$key] = new self($dbConf);         }         return self::$_instance[$key];     }     /**      * 转义字符串      * @param string $str 要转义的字符串      * @return string 转义后的字符串      */     public function escape($str){         return mysql_real_escape_string($str, $this->_db);     }     /**      * 查询，用于select语句      * @param string $sql 要查询的sql      * @return bool|array 查询成功返回对应数组，失败返回false      */     public function query($sql){         $this->_rows = 0;         $this->_error = '';         $this->_lastSql = $sql;         $this->logSql();         $res = mysql_query($sql,$this->_db);         if($res === false){             $this->_error = mysql_error($this->_db);             $this->logError();             return false;         }else{             $this->_rows = mysql_num_rows($res);             $result = array();             if($this->_rows >0) {                 while($row = mysql_fetch_array($res, MYSQL_ASSOC)){                     $result[]   =   $row;                 }                 mysql_data_seek($res,0);             }             return $result;         }     }     /**      * 查询，用于insert/update/delete语句      * @param string $sql 要查询的sql      * @return bool|int 查询成功返回影响的记录数量，失败返回false      */     public function execute($sql) {         $this->_rows = 0;         $this->_error = '';         $this->_lastSql = $sql;         $this->logSql();         $result =   mysql_query($sql, $this->_db) ;         if ( false === $result) {             $this->_error = mysql_error($this->_db);             $this->logError();             return false;         } else {             $this->_rows = mysql_affected_rows($this->_db);             return $this->_rows;         }     }     /**      * 获取上一次查询影响的记录数量      * @return int 影响的记录数量      */     public function getRows(){         return $this->_rows;     }     /**      * 获取上一次insert后生成的自增id      * @return int 自增ID      */     public function getInsertId() {         return mysql_insert_id($this->_db);     }     /**      * 获取上一次查询的sql      * @return string sql      */     public function getLastSql(){         return $this->_lastSql;     }     /**      * 获取上一次查询的错误信息      * @return string 错误信息      */     public function getError(){         return $this->_error;     }     /**      * 记录sql到文件      */     private function logSql(){         Log::sql($this->_lastSql);     }     /**      * 记录错误日志到文件      */     private function logError(){         $str = '[SQL ERR]'.$this->_error.' SQL:'.$this->_lastSql;         Log::warn($str);     } } /**  * 日志类  * 使用方法：Log::fatal('error msg');  * 保存路径为 App/Log，按天存放  * fatal和warning会记录在.log.wf文件中  */ class Log{     /**      * 打日志，支持SAE环境      * @param string $msg 日志内容      * @param string $level 日志等级      * @param bool $wf 是否为错误日志      */     public static function write($msg, $level='DEBUG', $wf=false){         if(function_exists('sae_debug')){ //如果是SAE，则使用sae_debug函数打日志             $msg = "[{$level}]".$msg;             sae_set_display_errors(false);             sae_debug(trim($msg));             sae_set_display_errors(true);         }else{             $msg = date('[ Y-m-d H:i:s ]')."[{$level}]".$msg."\r\n";             $logPath = C('APP_FULL_PATH').'/Log/'.date('Ymd').'.log';             if($wf){                 $logPath .= '.wf';             }             file_put_contents($logPath, $msg, FILE_APPEND);         }     }     /**      * 打印fatal日志      * @param string $msg 日志信息      */     public static function fatal($msg){         self::write($msg, 'FATAL', true);     }     /**      * 打印warning日志      * @param string $msg 日志信息      */     public static function warn($msg){         self::write($msg, 'WARN', true);     }     /**      * 打印notice日志      * @param string $msg 日志信息      */     public static function notice($msg){         self::write($msg, 'NOTICE');     }     /**      * 打印debug日志      * @param string $msg 日志信息      */     public static function debug($msg){         self::write($msg, 'DEBUG');     }     /**      * 打印sql日志      * @param string $msg 日志信息      */     public static function sql($msg){         self::write($msg, 'SQL');     } } /**  * ExtException类，记录额外的异常信息  */ class ExtException extends Exception{     /**      * @var array      */     protected $extra;     /**      * @param string $message      * @param array $extra      * @param int $code      * @param null $previous      */     public function __construct($message = "", $extra = array(), $code = 0, $previous = null){         $this->extra = $extra;         parent::__construct($message, $code, $previous);     }     /**      * 获取额外的异常信息      * @return array      */     public function getExtra(){         return $this->extra;     } }

转载地址：http://biuhf.baihongyu.com/