448 lines
14 KiB
PHP
448 lines
14 KiB
PHP
<?php
|
||
|
||
/************************************************
|
||
*
|
||
* Amysql PHPMVC - AMP 1.5
|
||
* Amysql.com
|
||
* @param Object $AmysqlProcess 网站进程
|
||
*
|
||
*/
|
||
class Amysql {
|
||
public $AmysqlProcess;
|
||
public function Amysql() {
|
||
global $Config;
|
||
ini_set ( "magic_quotes_runtime", false );
|
||
($Config ['DebugPhp'] && error_reporting ( E_ALL )) || error_reporting ( 0 ); // 是否报错
|
||
($Config ['SessionStart'] && session_start ()); // SESSION
|
||
(! empty ( $Config ['CharSet'] ) && header ( 'Content-type: text/html;charset=' . $Config ['CharSet'] ));
|
||
}
|
||
static public function AmysqlNotice($notice) {
|
||
$AmysqlController = new AmysqlController ();
|
||
$AmysqlController->notice = $notice;
|
||
$AmysqlController->_view ( 'AmysqlNotice' );
|
||
exit ();
|
||
}
|
||
static public function filter(&$array, $function) {
|
||
if (! is_array ( $array ))
|
||
return $array = $function ( $array );
|
||
foreach ( $array as $key => $value )
|
||
(is_array ( $value ) && $array [$key] = Amysql::filter ( $value, $function )) || $array [$key] = $function ( $value );
|
||
return $array;
|
||
}
|
||
}
|
||
|
||
/**
|
||
* **********************************************
|
||
*
|
||
* 总进程对象
|
||
*
|
||
* @param Object $ControllerName
|
||
* @param string $ControllerName
|
||
* @param string $ActionName
|
||
* @param string $ControllerFile
|
||
*
|
||
*/
|
||
class AmysqlProcess {
|
||
public $AmysqlController;
|
||
public $ControllerName;
|
||
public $ActionName;
|
||
public $ControllerFile;
|
||
function ProcessStart() {
|
||
global $Config;
|
||
if ($Config ['HttpPath']) {
|
||
$GETParam = (strlen ( $_SERVER ['REQUEST_URI'] ) > strlen ( $_SERVER ['SCRIPT_NAME'] )) ? explode ( '/', trim ( str_ireplace ( $_SERVER ['SCRIPT_NAME'], '', $_SERVER ['REQUEST_URI'] ), '/' ) ) : '';
|
||
$GETCount = count ( $GETParam );
|
||
if ($GETCount > 1)
|
||
for($i = 2; $i < $GETCount; ++ $i)
|
||
$_GET [$GETParam [$i]] = isset ( $GETParam [++ $i] ) ? $GETParam [$i] : '';
|
||
}
|
||
|
||
$magic_quotes = function_exists ( 'get_magic_quotes_gpc' ) ? get_magic_quotes_gpc () : false; // 环境是否有过滤
|
||
if ($Config ['Filter']) // 开启过滤
|
||
{
|
||
(! $magic_quotes && (Amysql::filter ( $_GET, 'addslashes' ) && Amysql::filter ( $_REQUEST, 'addslashes' ) && Amysql::filter ( $_COOKIE, 'addslashes' ) && Amysql::filter ( $_FILES, 'addslashes' )));
|
||
} else {
|
||
($magic_quotes && (Amysql::filter ( $_GET, 'stripslashes' ) && Amysql::filter ( $_REQUEST, 'stripslashes' ) && Amysql::filter ( $_COOKIE, 'stripslashes' ) && Amysql::filter ( $_FILES, 'stripslashes' )));
|
||
}
|
||
|
||
$this->ControllerName = ! empty ( $GETParam [0] ) ? $GETParam [0] : ((isset ( $_GET [$Config ['UrlControllerName']] ) && ! empty ( $_GET [$Config ['UrlControllerName']] )) ? $_GET [$Config ['UrlControllerName']] : 'index');
|
||
$this->ControllerName = str_replace ( _PathTag, DIRECTORY_SEPARATOR, $this->ControllerName );
|
||
$this->ActionName = ! empty ( $GETParam [1] ) ? $GETParam [1] : ((isset ( $_GET [$Config ['UrlActionName']] ) && ! empty ( $_GET [$Config ['UrlActionName']] )) ? $_GET [$Config ['UrlActionName']] : 'IndexAction');
|
||
$this->ControllerFile = _Controller . $this->ControllerName . '.php';
|
||
}
|
||
function ControllerStart() {
|
||
((is_file ( $this->ControllerFile ) && include_once ($this->ControllerFile)) || (is_file ( _Controller . 'index.php' ) && include_once (_Controller . 'index.php')) || Amysql::AmysqlNotice ( $this->ControllerFile . ' 控制器文件不存在' ));
|
||
|
||
(class_exists ( $this->ControllerName ) || (($this->ControllerName = 'index') && class_exists ( 'index' )) || Amysql::AmysqlNotice ( $this->ControllerName . ' 控制器不存在' ));
|
||
|
||
$methods = get_class_methods ( $this->ControllerName ); // 获取类中的方法名
|
||
|
||
(in_array ( $this->ActionName, $methods, true ) || (($this->ActionName = 'IndexAction') && in_array ( $this->ActionName, $methods, true )) || Amysql::AmysqlNotice ( $this->ActionName . ' 方法不存在' ));
|
||
|
||
$this->AmysqlController = new $this->ControllerName ( $_GET ); // 实例控制器
|
||
method_exists ( $this->AmysqlController, 'StartAction' ) ? $this->AmysqlController->StartAction () : '';
|
||
$this->AmysqlController->{$this->ActionName} (); // 执行方法
|
||
}
|
||
}
|
||
|
||
/**
|
||
* **********************************************
|
||
*
|
||
* 控制器逻辑层 (C)
|
||
*
|
||
* @param Object $DB
|
||
* @param Array $DBConfig
|
||
* @param Array $AmysqlModel
|
||
* @param Object $AmysqlTemplates
|
||
* @param Array $EchoData
|
||
*
|
||
*/
|
||
class AmysqlController {
|
||
public $DB;
|
||
public $DBConfig; // 控制器调用Mysql的链接配置
|
||
public $AmysqlModel; // 控制器关联的数据模型对象集
|
||
public $AmysqlClass; // 控制器关联的类对象集
|
||
public $AmysqlTemplates; // 控制器关联的模板对象
|
||
public $EchoData = array (); // 调试数据
|
||
function AmysqlController() {
|
||
global $Config;
|
||
$this->DBConfig = $Config;
|
||
|
||
$this->DB = new DB ();
|
||
$this->AmysqlTemplates = new AmysqlTemplates ();
|
||
}
|
||
|
||
/**
|
||
* 设置数据库配置
|
||
*
|
||
* @param Array $Config
|
||
*/
|
||
function _DBSet($_Config = NULL) {
|
||
global $Config;
|
||
$_Config = ($_Config == NULL) ? $Config : $_Config;
|
||
foreach ( $Config as $key => $val )
|
||
(empty ( $_Config [$key] ) && $_Config [$key] = $val);
|
||
$this->DBConfig = $_Config;
|
||
}
|
||
|
||
/**
|
||
* 模板赋值
|
||
*
|
||
* @param string $name
|
||
* @param string $value
|
||
*/
|
||
public function __set($name, $value = NULL) {
|
||
$this->AmysqlTemplates->TemplateValue [$name] = $value;
|
||
}
|
||
|
||
/**
|
||
* 数组模板赋值
|
||
*
|
||
* @param Array $array
|
||
*/
|
||
public function _array($array) {
|
||
if (is_array ( $array )) {
|
||
foreach ( $array as $key => $val )
|
||
$this->AmysqlTemplates->TemplateValue [$key] = $val;
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 加载自定义类文件
|
||
*
|
||
* @param string $file
|
||
* @param string $ClassName
|
||
* @return Object $ClassName() 类对象
|
||
*/
|
||
public function _class($file, $ClassName = NULL) {
|
||
$file = str_replace ( _PathTag, DIRECTORY_SEPARATOR, $file );
|
||
$ClassName = ($ClassName == NULL) ? $file : $ClassName;
|
||
$file = _Class . $file . '.php';
|
||
if (is_file ( $file )) {
|
||
include_once ($file);
|
||
if (! class_exists ( $ClassName ))
|
||
Amysql::AmysqlNotice ( $ClassName . ' 类对象不存在' );
|
||
|
||
if (! isset ( $this->AmysqlClass [$ClassName] )) // 不存在类对象
|
||
$this->AmysqlClass [$ClassName] = new $ClassName ();
|
||
return $this->AmysqlClass [$ClassName];
|
||
}
|
||
|
||
Amysql::AmysqlNotice ( $file . ' 类文件不存在' );
|
||
}
|
||
|
||
/**
|
||
* 加载模型文件
|
||
*
|
||
* @param string $file
|
||
* @param string $ClassName
|
||
* @return Object $ClassName() 模型对象
|
||
*/
|
||
public function _model($file, $ClassName = NULL) {
|
||
$file = str_replace ( _PathTag, DIRECTORY_SEPARATOR, $file );
|
||
$ClassName = ($ClassName == NULL) ? $file : $ClassName;
|
||
$file = _Model . $file . '.php';
|
||
if (is_file ( $file )) {
|
||
include_once ($file);
|
||
if (! class_exists ( $ClassName ))
|
||
Amysql::AmysqlNotice ( $ClassName . ' 模型对象不存在' );
|
||
$this->DBConfig ['ModelTag'] = $ModelTag = $ClassName . '_' . $this->DBConfig ['ConnectTag']; // 模型标识
|
||
// 不存在模型
|
||
if (! isset ( $this->AmysqlModel [$ModelTag] )) {
|
||
$this->AmysqlModel [$ModelTag] = new $ClassName ();
|
||
if (! isset ( $this->DB->DBS [$ModelTag] ))
|
||
$this->DB->DBConnect ( $this->DBConfig ); // 没连接就进行数据库连接
|
||
$this->AmysqlModel [$ModelTag]->MysqlConnect = $this->DB->DBS [$ModelTag]; // 模型使用的数据库连接
|
||
}
|
||
return $this->AmysqlModel [$ModelTag];
|
||
}
|
||
|
||
Amysql::AmysqlNotice ( $file . ' 模型文件不存在' );
|
||
}
|
||
|
||
/**
|
||
* 获得相关文件数据(模板目录)
|
||
*
|
||
* @param string $file
|
||
* @return string 数据
|
||
*/
|
||
public function _file($file) {
|
||
$file = str_replace ( _PathTag, DIRECTORY_SEPARATOR, $file );
|
||
$file = _View . $file . '.php';
|
||
if (is_file ( $file ))
|
||
return file_get_contents ( $file );
|
||
|
||
Amysql::AmysqlNotice ( $file . ' 数据文件不存在' );
|
||
}
|
||
|
||
/**
|
||
* 数据调试
|
||
*
|
||
* @param $data 数据
|
||
*/
|
||
public function _echo($data) {
|
||
$this->EchoData [] = $data;
|
||
}
|
||
|
||
/**
|
||
* 模板显示
|
||
*/
|
||
public function _view($file = null) {
|
||
// 控制器属性共享于模板 2012-4-20
|
||
$AmysqlSelfPropertyKey = array_keys ( get_class_vars ( 'AmysqlController' ) );
|
||
$ControllerPropertyParam = get_object_vars ( $this );
|
||
foreach ( $ControllerPropertyParam as $key => $val ) {
|
||
if (! in_array ( $key, $AmysqlSelfPropertyKey )) // 非Amysql控制器属性
|
||
$this->AmysqlTemplates->TemplateValue [$key] = $val;
|
||
}
|
||
|
||
$this->AmysqlTemplates->_view ( $file );
|
||
|
||
// 信息调试输出
|
||
if (is_array ( $this->AmysqlModel )) {
|
||
foreach ( $this->AmysqlModel as $key => $val ) // Sql调试
|
||
echo $this->AmysqlModel [$key]->SqlBug;
|
||
}
|
||
foreach ( $this->EchoData as $val )
|
||
echo "<!--<pre>\n", print_r ( $val, true ), "\n</pre>-->";
|
||
}
|
||
}
|
||
|
||
/**
|
||
* **********************************************
|
||
*
|
||
* 视图表现层 (V)
|
||
*
|
||
* @param Array $TemplateValue
|
||
*
|
||
*/
|
||
class AmysqlTemplates {
|
||
public $TemplateValue; // 模板数据
|
||
function AmysqlTemplates() {
|
||
// 自定义模板常用参数数据
|
||
$this->TemplateValue ['_date'] = date ( 'Y-m-d H:i:s', time () );
|
||
}
|
||
public function _view($file = null) {
|
||
global $Config;
|
||
// 2012-10-8
|
||
($Config ['XSS'] && Amysql::filter ( $this->TemplateValue, 'htmlspecialchars' ) && Amysql::filter ( $_GET, 'htmlspecialchars' ) && Amysql::filter ( $_REQUEST, 'htmlspecialchars' ) && Amysql::filter ( $_COOKIE, 'htmlspecialchars' ));
|
||
|
||
@extract ( $this->TemplateValue );
|
||
$file = str_replace ( _PathTag, DIRECTORY_SEPARATOR, $file );
|
||
$file = _View . $file . '.php';
|
||
if (is_file ( $file ))
|
||
return include ($file);
|
||
|
||
Amysql::AmysqlNotice ( $file . ' 模板文件不存在' );
|
||
}
|
||
}
|
||
|
||
/**
|
||
* **********************************************
|
||
*
|
||
* 模型数据层 (M)
|
||
*
|
||
* @param Object $MysqlConnect
|
||
* @param String $Affected
|
||
* @param String $InsertId
|
||
* @param String $ResultSum
|
||
* @param String $QueryStatus
|
||
*/
|
||
class AmysqlModel {
|
||
public $MysqlConnect;
|
||
public $Affected;
|
||
public $InsertId;
|
||
public $ResultSum;
|
||
public $QueryStatus;
|
||
public $SqlBug = '';
|
||
|
||
/**
|
||
* 基本查询
|
||
*
|
||
* @param string $sql
|
||
* @return Object 结果集
|
||
*/
|
||
public function _query($sql) {
|
||
global $Config;
|
||
if (! $this->MysqlConnect)
|
||
return false;
|
||
$this->QueryStatus = '(0)';
|
||
$this->Affected = 0;
|
||
if ($Config ['DebugSql'])
|
||
$this->SqlBug .= "\n" . '<!--DebugSql: ' . $sql . '-->' . "\n";
|
||
$result = mysql_query ( $sql, $this->MysqlConnect );
|
||
if (! $result)
|
||
return false;
|
||
$this->Affected = mysql_affected_rows ();
|
||
$this->QueryStatus = '(ok)';
|
||
return $result;
|
||
}
|
||
|
||
/**
|
||
* 插入数据
|
||
*
|
||
* @param string $table
|
||
* @param Array $data
|
||
* @return int InsertId 新增ID
|
||
*/
|
||
public function _insert($table, $data) {
|
||
$this->InsertId = 0;
|
||
if (! is_array ( $data ) || count ( $data ) == 0)
|
||
return 0;
|
||
|
||
$field_arr = array ();
|
||
foreach ( $data as $key => $val )
|
||
$field_arr [] = " `$key` = '$val' ";
|
||
|
||
$sql = "INSERT INTO `$table` SET " . implode ( ',', $field_arr );
|
||
$this->_query ( $sql );
|
||
$this->InsertId = mysql_insert_id ();
|
||
return $this->InsertId;
|
||
}
|
||
|
||
/**
|
||
* 更新数据
|
||
*
|
||
* @param string $table
|
||
* 表名
|
||
* @param Array $data
|
||
* 数据
|
||
* @param string $where
|
||
* 更新数据依据
|
||
* @return int Affected 影响数
|
||
*
|
||
*/
|
||
public function _update($table, $data, $where = '') {
|
||
$this->Affected = 0;
|
||
if (! is_array ( $data ) || count ( $data ) == 0)
|
||
return 0;
|
||
|
||
$field_arr = array ();
|
||
foreach ( $data as $key => $val )
|
||
$field_arr [] = " `$key` = '$val' ";
|
||
|
||
$sql = "UPDATE `$table` SET " . implode ( ',', $field_arr ) . $where;
|
||
$this->_query ( $sql );
|
||
return $this->Affected;
|
||
}
|
||
|
||
/**
|
||
* 取得一排数据
|
||
*
|
||
* @param string $sql
|
||
* @param string $result_type
|
||
* @return Array $row 数据
|
||
*/
|
||
public function _row($sql, $result_type = MYSQL_ASSOC) {
|
||
$result = $this->_query ( $sql );
|
||
if (! $result)
|
||
return false;
|
||
$row = mysql_fetch_array ( $result, $result_type );
|
||
$this->ResultSum = 1;
|
||
$this->_free ( $result );
|
||
return $row;
|
||
}
|
||
|
||
/**
|
||
* 取得所有数据
|
||
*
|
||
* @param string $sql
|
||
* @param string $result_type
|
||
* @return Array $row 数据
|
||
*/
|
||
public function _all($sql, $result_type = MYSQL_ASSOC) {
|
||
$result = $this->_query ( $sql );
|
||
if (! $result)
|
||
return false;
|
||
$data = array ();
|
||
$this->ResultSum = 0;
|
||
while ( $row = mysql_fetch_array ( $result, $result_type ) ) {
|
||
$data [] = $row;
|
||
++ $this->ResultSum;
|
||
}
|
||
$this->_free ( $result );
|
||
return $data;
|
||
}
|
||
|
||
/**
|
||
* 取得数据总数
|
||
*
|
||
* @param string $sql
|
||
* @return int 数量
|
||
*/
|
||
public function _sum($sql) {
|
||
$result = $this->_query ( $sql );
|
||
if (! $result)
|
||
return false;
|
||
return mysql_num_rows ( $result );
|
||
}
|
||
|
||
/**
|
||
* 释放结果集
|
||
*
|
||
* @param Object $rs
|
||
*/
|
||
public function _free($rs) {
|
||
return mysql_free_result ( $rs );
|
||
}
|
||
}
|
||
|
||
/**
|
||
* **********************************************
|
||
*
|
||
* 数据库对象
|
||
*
|
||
* @param Object $DBS
|
||
*/
|
||
class DB {
|
||
public $DBS;
|
||
public function DBConnect($Config) {
|
||
$this->DBS [$Config ['ModelTag']] = @mysql_connect ( $Config ['Host'], $Config ['User'], $Config ['Password'] );
|
||
(! $this->DBS [$Config ['ModelTag']] && Amysql::AmysqlNotice ( mysql_error () . ' Mysql链接出错，请配置/Amysql/config.php文件。' ));
|
||
|
||
(! empty ( $Config ['DBname'] ) && mysql_select_db ( $Config ['DBname'], $this->DBS [$Config ['ModelTag']] ));
|
||
$CharSet = str_replace ( '-', '', $Config ['CharSet'] );
|
||
mysql_query ( "SET NAMES '$CharSet'", $this->DBS [$Config ['ModelTag']] );
|
||
}
|
||
}
|