当前位置:Gxlcms > PHP教程 > b2Core:300行的phpMVC架构

b2Core:300行的phpMVC架构

时间:2021-07-01 10:21:17 帮助过:35人阅读

b2Core 是一个轻量 php MVC 框架, 300 行代码封装了常用 CRUD 等实用功能。
最新版代码请见 http://b2core.b24.cn ,欢迎批评和建议。

本页中对对于代码的各个部分做了详尽的注释.
前台请求的格式为

http://domain/index.php/controller/method/param1/param2/

http://domain/controller/method/param1/param2/
  1. /**
  2. * B2Core 是由 Brant (brantx@gmail.com)发起的基于PHP的MVC架构
  3. * 核心思想是在采用MVC框架的基础上最大限度的保留php的灵活性
  4. * Vison 2.0 (20120515)
  5. * */
  6. define('VERSION','2.0');
  7. // 载入配置文件:数据库、url路由等等
  8. require(APP.'config.php');
  9. // 如果配置了数据库则载入
  10. if(isset($db_config)) $db = new db($db_config);
  11. // 获取请求的地址兼容 SAE
  12. $uri = '';
  13. if(isset($_SERVER['PATH_INFO'])) $uri = $_SERVER['PATH_INFO'];
  14. if(isset($_SERVER['ORIG_PATH_INFO'])) $uri = $_SERVER['ORIG_PATH_INFO'];
  15. if(isset($_SERVER['SCRIPT_URL'])) $uri = $_SERVER['SCRIPT_URL'];
  16. // 去除Magic_Quotes
  17. if(get_magic_quotes_gpc()) // Maybe would be removed in php6
  18. {
  19. function stripslashes_deep($value)
  20. {
  21. $value = is_array($value) ? array_map('stripslashes_deep', $value) : (isset($value) ? stripslashes($value) : null);
  22. return $value;
  23. }
  24. $_POST = stripslashes_deep($_POST);
  25. $_GET = stripslashes_deep($_GET);
  26. $_COOKIE = stripslashes_deep($_COOKIE);
  27. }
  28. // 执行 config.php 中配置的url路由
  29. foreach ($route_config as $key => $val)
  30. {
  31. $key = str_replace(':any', '([^\/.]+)', str_replace(':num', '([0-9]+)', $key));
  32. if (preg_match('#^'.$key.'#', $uri))$uri = preg_replace('#^'.$key.'#', $val, $uri);
  33. }
  34. // 获取URL中每一段的参数
  35. $uri = rtrim($uri,'/');
  36. $seg = explode('/',$uri);
  37. $des_dir = $dir = '';
  38. /* 依次载入控制器上级所有目录的架构文件 __construct.php
  39. * 架构文件可以包含当前目录下的所有控制器的父类,和需要调用的函数
  40. */
  41. foreach($seg as $cur_dir)
  42. {
  43. $des_dir.=$cur_dir."/";
  44. if(is_file(APP.'c'.$des_dir.'__construct.php')) {
  45. require(APP.'c'.$des_dir.'__construct.php');
  46. $dir .=array_shift($seg).'/';
  47. }
  48. else {
  49. break;
  50. }
  51. }
  52. /* 根据 url 调用控制器中的方法,如果不存在返回 404 错误
  53. * 默认请求 class home->index()
  54. */
  55. $dir = $dir ? $dir:'/';
  56. array_unshift($seg,NULL);
  57. $class = isset($seg[1])?$seg[1]:'home';
  58. $method = isset($seg[2])?$seg[2]:'index';
  59. if(!is_file(APP.'c'.$dir.$class.'.php'))show_404();
  60. require(APP.'c'.$dir.$class.'.php');
  61. if(!class_exists($class))show_404();
  62. if(!method_exists($class,$method))show_404();
  63. $B2 = new $class();
  64. call_user_func_array(array(&$B2, $method), array_slice($seg, 3));
  65. /* B2 系统函数
  66. * load($path,$instantiate) 可以动态载入对象,如:控制器、Model、库类等
  67. * $path 是类文件相对 app 的地址
  68. * $instantiate 为 False 时,仅引用文件,不实例化对象
  69. * $instantiate 为数组时,数组内容会作为参数传递给对象
  70. */
  71. function &load($path, $instantiate = TRUE )
  72. {
  73. $param = FALSE;
  74. if(is_array($instantiate)) {
  75. $param = $instantiate;
  76. $instantiate = TRUE;
  77. }
  78. $file = explode('/',$path);
  79. $class_name = array_pop($file);
  80. $object_name = md5($path);
  81. static $objects = array();
  82. if (isset($objects[$object_name])) return $objects[$object_name];
  83. require(APP.$path.'.php');
  84. if ($instantiate == FALSE) $objects[$object_name] = TRUE;
  85. if($param)$objects[$object_name] = new $class_name($param);
  86. else $objects[$object_name] = new $class_name();
  87. return $objects[$object_name];
  88. }
  89. /* 调用 view 文件
  90. * function view($view,$param = array(),$cache = FALSE)
  91. * $view 是模板文件相对 app/v/ 目录的地址,地址应去除 .php 文件后缀
  92. * $param 数组中的变量会传递给模板文件
  93. * $cache = TRUE 时,不像浏览器输出结果,而是以 string 的形式 return
  94. */
  95. function view($view,$param = array(),$cache = FALSE)
  96. {
  97. if(!empty($param))extract($param);
  98. ob_start();
  99. if(is_file(APP.$view.'.php')) {
  100. require APP.$view.'.php';
  101. }
  102. else {
  103. echo 'view '.$view.' desn\'t exsit';
  104. return false;
  105. }
  106. // Return the file data if requested
  107. if ($cache === TRUE)
  108. {
  109. $buffer = ob_get_contents();
  110. @ob_end_clean();
  111. return $buffer;
  112. }
  113. }
  114. // 取得 url 的片段,如 url 是 /abc/def/g/ seg(1) = abc
  115. function seg($i)
  116. {
  117. global $seg;
  118. return isset($seg[$i])?$seg[$i]:false;
  119. }
  120. // 写入日志
  121. function write_log($level = 0 ,$content = 'none')
  122. {
  123. file_put_contents(APP.'log/'.$level.'-'.date('Y-m-d').'.log', $content , FILE_APPEND );
  124. }
  125. // 显示404错误
  126. function show_404() //显示 404 错误
  127. {
  128. header("HTTP/1.1 404 Not Found");
  129. // 调用 模板 v/404.php
  130. view('v/404');
  131. exit(1);
  132. }
  133. /* B2Core 系统类 */
  134. // 抽象的控制器类,建议所有的控制器均基层此类或者此类的子类
  135. class c {
  136. function index()
  137. {
  138. echo "基于 B2 v".VERSION." 创建";
  139. }
  140. }
  141. // 数据库操作类
  142. class db {
  143. var $link;
  144. var $last_query;
  145. function __construct($conf)
  146. {
  147. $this->link = mysql_connect($conf['host'],$conf['user'], $conf['password']);
  148. if (!$this->link) {
  149. die('无法连接: ' . mysql_error());
  150. return FALSE;
  151. }
  152. $db_selected = mysql_select_db($conf['default_db']);
  153. if (!$db_selected) {
  154. die('无法使用 : ' . mysql_error());
  155. }
  156. mysql_query('set names utf8',$this->link);
  157. }
  158. //执行 query 查询,如果结果为数组,则返回数组数据
  159. function query($query)
  160. {
  161. $ret = array();
  162. $this->last_query = $query;
  163. $result = mysql_query($query,$this->link);
  164. if (!$result) {
  165. echo "DB Error, could not query the database\n";
  166. echo 'MySQL Error: ' . mysql_error();
  167. echo 'Error Query: ' . $query;
  168. exit;
  169. }
  170. if($result == 1 )return TRUE;
  171. while($record = mysql_fetch_assoc($result))
  172. {
  173. $ret[] = $record;
  174. }
  175. return $ret;
  176. }
  177. function insert_id() {return mysql_insert_id();}
  178. // 执行多条 SQL 语句
  179. function muti_query($query)
  180. {
  181. $sq = explode(";\n",$query);
  182. foreach($sq as $s){
  183. if(trim($s)!= '')$this->query($s);
  184. }
  185. }
  186. }
  187. // 模块类,封装了通用CURD模块操作,建议所有模块都继承此类。
  188. class m {
  189. var $db;
  190. var $table;
  191. var $fields;
  192. var $key;
  193. function __construct()
  194. {
  195. global $db;
  196. $this->db = $db;
  197. $this->key = 'id';
  198. }
  199. public function __call($name, $arg) {
  200. return call_user_func_array(array($this, $name), $arg);
  201. }
  202. // 向数据库插入数组格式数据
  203. function add($elem = FALSE)
  204. {
  205. $query_list = array();
  206. if(!$elem)$elem = $_POST;
  207. foreach($this->fields as $f) {
  208. if(isset($elem[$f])){
  209. $elem[$f] = addslashes($elem[$f]);
  210. $query_list[] = "`$f` = '$elem[$f]'";
  211. }
  212. }
  213. $this->db->query("insert into `$this->table` set ".implode(',',$query_list));
  214. return $this->db->insert_id();
  215. }
  216. // 删除某一条数据
  217. function del($id)
  218. {
  219. $this->db->query("delete from `$this->table` where ".$this->key."='$id'");
  220. }
  221. // 更新数据
  222. function update($id , $elem = FALSE)
  223. {
  224. $query_list = array();
  225. if(!$elem)$elem = $_POST;
  226. foreach($this->fields as $f) {
  227. if(isset($elem[$f])){
  228. $elem[$f] = addslashes($elem[$f]);
  229. $query_list[] = "`$f` = '$elem[$f]'";
  230. }
  231. }
  232. $this->db->query("update `$this->table` set ".implode(',',$query_list)." where ".$this->key." ='$id'" );
  233. }
  234. // 统计数量
  235. function count($where='')
  236. {
  237. $res = $this->db->query("select count(*) as a from `$this->table` where 1 $where");
  238. return $res[0]['a'];
  239. }
  240. /* get($id) 取得一条数据 或
  241. * get($postquery = '',$cur = 1,$psize = 30) 取得多条数据
  242. */
  243. function get()
  244. {
  245. $args = func_get_args();
  246. if(is_numeric($args[0])) return $this->__call('get_one', $args);
  247. return $this->__call('get_many', $args);
  248. }
  249. function get_one($id)
  250. {
  251. $id = is_numeric($id)?$id:0;
  252. $res = $this->db->query("select * from `$this->table` where ".$this->key."='$id'");
  253. if(isset($res[0]))return $res[0];
  254. return false;
  255. }
  256. function get_many($postquery = '',$cur = 1,$psize = 30)
  257. {
  258. $cur = $cur > 0 ?$cur:1;
  259. $start = ($cur - 1) * $psize;
  260. $query = "select * from `$this->table` where 1 $postquery limit $start , $psize";
  261. return $this->db->query($query);
  262. }
  263. }
  1. // 所有配置内容都可以在这个文件维护
  2. error_reporting(E_ERROR);
  3. if(file_exists(APP.'config_user.php')) require(APP.'config_user.php');
  4. // 配置url路由
  5. $route_config = array(
  6. '/reg/'=>'/user/reg/',
  7. '/logout/'=>'/user/logout/',
  8. );
  9. define('BASE','/');
  10. /* 数据库默认按照 SAE 进行配置 */
  11. $db_config = array(
  12. 'host'=>SAE_MYSQL_HOST_M.':'.SAE_MYSQL_PORT,
  13. 'user'=>SAE_MYSQL_USER,
  14. 'password'=>SAE_MYSQL_PASS,
  15. 'default_db'=>SAE_MYSQL_DB
  16. );

人气教程排行