<?php
// +----------------------------------------------------------------------
// | ThinkPHP [ WE CAN DO IT JUST THINK IT ]
// +----------------------------------------------------------------------
// | Copyright (c) 2010 http://thinkphp.cn All rights reserved.
// +----------------------------------------------------------------------
// | Licensed ( http://www.apache.org/licenses/LICENSE-2.0 )
// +----------------------------------------------------------------------
// | Author: liu21st <liu21st@gmail.com>
// +----------------------------------------------------------------------
// $Id$
define('HAS_ONE', 1);
define('BELONGS_TO', 2);
define('HAS_MANY', 3);
define('MANY_TO_MANY', 4);
/**
+------------------------------------------------------------------------------
* ThinkPHP Model模型类
* 实现了ORM和ActiveRecords模式
+------------------------------------------------------------------------------
* @category Think
* @package Think
* @subpackage Core
* @author liu21st <liu21st@gmail.com>
* @version $Id$
+------------------------------------------------------------------------------
*/
class Model extends Think {
// 操作状态
const MODEL_INSERT = 1; // 插入模型数据
const MODEL_UPDATE = 2; // 更新模型数据
const MODEL_BOTH = 3; // 包含上面两种方式
const MUST_VALIDATE = 1; // 必须验证
const EXISTS_VAILIDATE = 0; // 表单存在字段则验证
const VALUE_VAILIDATE = 2; // 表单值不为空则验证
// 当前使用的扩展模型
private $_extModel = null;
// 当前数据库操作对象
protected $db = null;
// 主键名称
protected $pk = 'id';
// 数据表前缀
protected $tablePrefix = '';
// 数据表后缀
protected $tableSuffix = '';
// 模型名称
protected $name = '';
// 数据库名称
protected $dbName = '';
// 数据表名（不包含表前缀）
protected $tableName = '';
// 实际数据表名（包含表前缀）
protected $trueTableName = '';
// 最近错误信息
protected $error = '';
// 字段信息
protected $fields = array();
// 数据信息
protected $data = array();
// 查询表达式参数
protected $options = array();
protected $_validate = array(); // 自动验证定义
protected $_auto = array(); // 自动完成定义
protected $_map = array(); // 字段映射定义
// 是否自动检测数据表字段信息
protected $autoCheckFields = true;
/**
+----------------------------------------------------------
* 架构函数
* 取得DB类的实例对象 字段检查
+----------------------------------------------------------
* @param string $name 模型名称
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
*/
public function __construct($name='', $connection='') {
// 模型初始化
$this->_initialize();
// 获取模型名称
if (!empty($name)) {
$this->name = $name;
} elseif (empty($this->name)) {
$this->name = $this->getModelName();
}
// 数据库初始化操作
// 获取数据库操作对象
// 当前模型有独立的数据库连接信息
$this->db = Db::getInstance(empty($this->connection) ? $connection : $this->connection);
// 设置表前缀
$this->tablePrefix = $this->tablePrefix ? $this->tablePrefix : C('DB_PREFIX');
$this->tableSuffix = $this->tableSuffix ? $this->tableSuffix : C('DB_SUFFIX');
// 字段检测
if (!empty($this->name) && $this->autoCheckFields)
$this->_checkTableInfo();
}
/**
+----------------------------------------------------------
* 自动检测数据表信息
+----------------------------------------------------------
* @access protected
+----------------------------------------------------------
* @return void
+----------------------------------------------------------
*/
protected function _checkTableInfo() {
// 如果不是Model类 自动记录数据表信息
// 只在第一次执行记录
if (empty($this->fields)) {
// 如果数据表字段没有定义则自动获取
if (C('DB_FIELDS_CACHE')) {
$this->fields = F('_fields/' . $this->name);
if (!$this->fields)
$this->flush();
}else {
// 每次都会读取数据表信息
$this->flush();
}
}
}
/**
+----------------------------------------------------------
* 获取字段信息并缓存
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @return void
+----------------------------------------------------------
*/
public function flush() {
// 缓存不存在则查询数据表信息
$fields = $this->db->getFields($this->getTableName());
$this->fields = array_keys($fields);
$this->fields['_autoinc'] = false;
foreach ($fields as $key => $val) {
// 记录字段类型
$type[$key] = $val['type'];
if ($val['primary']) {
$this->fields['_pk'] = $key;
if ($val['autoinc'])
$this->fields['_autoinc'] = true;
}
}
// 记录字段类型信息
if (C('DB_FIELDTYPE_CHECK'))
$this->fields['_type'] = $type;
// 2008-3-7 增加缓存开关控制
if (C('DB_FIELDS_CACHE'))
// 永久缓存数据表信息
F('_fields/' . $this->name, $this->fields);
}
/**
+----------------------------------------------------------
* 动态切换扩展模型
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @param string $type 模型类型名称
* @param mixed $vars 要传入扩展模型的属性变量
+----------------------------------------------------------
* @return Model
+----------------------------------------------------------
*/
public function switchModel($type, $vars=array()) {
$class = ucwords(strtolower($type)) . 'Model';
if (!class_exists($class))
throw_exception($class . L('_MODEL_NOT_EXIST_'));
// 实例化扩展模型
$this->_extModel = new $class($this->name);
if (!empty($vars)) {
// 传入当前模型的属性到扩展模型
foreach ($vars as $var)
$this->_extModel->setProperty($var, $this->$var);
}
return $this->_extModel;
}
/**
+----------------------------------------------------------
* 设置数据对象的值
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @param string $name 名称
* @param mixed $value 值
+----------------------------------------------------------
* @return void
+----------------------------------------------------------
*/
public function __set($name, $value) {
// 设置数据对象属性
$this->data[$name] = $value;
}
/**
+----------------------------------------------------------
* 获取数据对象的值
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @param string $name 名称
+----------------------------------------------------------
* @return mixed
+----------------------------------------------------------
*/
public function __get($name) {
return isset($this->data[$name]) ? $this->data[$name] : null;
}
/**
+----------------------------------------------------------
* 检测数据对象的值
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @param string $name 名称
+----------------------------------------------------------
* @return boolean
+----------------------------------------------------------
*/
public function __isset($name) {
return isset($this->data[$name]);
}
/**
+----------------------------------------------------------
* 销毁数据对象的值
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @param string $name 名称
+----------------------------------------------------------
* @return void
+----------------------------------------------------------
*/
public function __unset($name) {
unset($this->data[$name]);
}
/**
+----------------------------------------------------------
* 利用__call方法实现一些特殊的Model方法
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @param string $method 方法名称
* @param array $args 调用参数
+----------------------------------------------------------
* @return mixed
+----------------------------------------------------------
*/
public function __call($method, $args) {
if (in_array(strtolower($method), array('field', 'table', 'where', 'order', 'limit', 'page', 'alias', 'having', 'group', 'lock', 'distinct'), true)) {
// 连贯操作的实现
$this->options[strtolower($method)] = $args[0];
return $this;
} elseif (in_array(strtolower($method), array('count', 'sum', 'min', 'max', 'avg'), true)) {
// 统计查询的实现
$field = isset($args[0]) ? $args[0] : '*';
return $this->getField(strtoupper($method) . '(' . $field . ') AS tp_' . $method);
} elseif (strtolower(substr($method, 0, 5)) == 'getby') {
// 根据某个字段获取记录
$field = parse_name(substr($method, 5));
$options['where'] = $field . '=\'' . $args[0] . '\'';
return $this->find($options);
} else {
throw_exception(__CLASS__ . ':' . $method . L('_METHOD_NOT_EXIST_'));
return;
}
}
// 回调方法 初始化模型
protected function _initialize() {
}
/**
+----------------------------------------------------------
* 对保存到数据库的数据进行处理
+----------------------------------------------------------
* @access protected
+----------------------------------------------------------
* @param mixed $data 要操作的数据
+----------------------------------------------------------
* @return boolean
+----------------------------------------------------------
*/
protected function _facade($data) {
// 检查非数据字段
if (!empty($this->fields)) {
foreach ($data as $key => $val) {
if (!in_array($key, $this->fields, true)) {
unset($data[$key]);
} elseif (C('DB_FIELDTYPE_CHECK') && is_scalar($val)) {
// 字段类型检查
$fieldType = strtolower($this->fields['_type'][$key]);
if (false !== strpos($fieldType, 'int')) {
$data[$key] = intval($val);
} elseif (false !== strpos($fieldType, 'float') || false !== strpos($fieldType, 'double')) {
$data[$key] = floatval($val);
}
}
}
}
$this->_before_write($data);
return $data;
}
// 写入数据前的回调方法 包括新增和更新
protected function _before_write(&$data) {
}
/**
+----------------------------------------------------------
* 新增数据
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @param mixed $data 数据
* @param array $options 表达式
* @param boolean $replace 是否replace
+----------------------------------------------------------
* @return mixed
+----------------------------------------------------------
*/
public function add($data='', $options=array(), $replace=false) {
if (empty($data)) {
// 没有传递数据，获取当前数据对象的值
if (!empty($this->data)) {
$data = $this->data;
} else {
$this->error = L('_DATA_TYPE_INVALID_');
return false;
}
}
// 分析表达式
$options = $this->_parseOptions($options);
// 数据处理
$data = $this->_facade($data);
if (false === $this->_before_insert($data, $options)) {
return false;
}
// 写入数据到数据库
$result = $this->db->insert($data, $options, $replace);
if (false !== $result) {
$insertId = $this->getLastInsID();
if ($insertId) {
// 自增主键返回插入ID
$data[$this->getPk()] = $insertId;
$this->_after_insert($data, $options);
return $insertId;
}
}
return $result;
}
// 插入数据前的回调方法
protected function _before_insert(&$data, $options) {
}
// 插入成功后的回调方法
protected function _after_insert($data, $options) {
}
public function addAll($dataList, $options=array(), $replace=false) {
if (empty($dataList)) {
$this->error = L('_DATA_TYPE_INVALID_');
return false;
}
// 分析表达式
$options = $this->_parseOptions($options);
// 数据处理
foreach ($dataList as $key => $data) {
$dataList[$key] = $this->_facade($data);
}
// 写入数据到数据库
$result = $this->db->insertAll($dataList, $options, $replace);
if (false !== $result) {
$insertId = $this->getLastInsID();
if ($insertId) {
return $insertId;
}
}
return $result;
}
/**
+----------------------------------------------------------
* 通过Select方式添加记录
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @param string $fields 要插入的数据表字段名
* @param string $table 要插入的数据表名
* @param array $options 表达式
+----------------------------------------------------------
* @return boolean
+----------------------------------------------------------
*/
public function selectAdd($fields='', $table='', $options=array()) {
// 分析表达式
$options = $this->_parseOptions($options);
// 写入数据到数据库
if (false === $result = $this->db->selectInsert($fields ? $fields : $options['field'], $table ? $table : $this->getTableName(), $options)) {
// 数据库插入操作失败
$this->error = L('_OPERATION_WRONG_');
return false;
} else {
// 插入成功
return $result;
}
}
/**
+----------------------------------------------------------
* 保存数据
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @param mixed $data 数据
* @param array $options 表达式
+----------------------------------------------------------
* @return boolean
+----------------------------------------------------------
*/
public function save($data='', $options=array()) {
if (empty($data)) {
// 没有传递数据，获取当前数据对象的值
if (!empty($this->data)) {
$data = $this->data;
} else {
$this->error = L('_DATA_TYPE_INVALID_');
return false;
}
}
// 数据处理
$data = $this->_facade($data);
// 分析表达式
$options = $this->_parseOptions($options);
if (false === $this->_before_update($data, $options)) {
return false;
}
if (!isset($options['where'])) {
// 如果存在主键数据 则自动作为更新条件
if (isset($data[$this->getPk()])) {
$pk = $this->getPk();
$options['where'] = $pk . '=\'' . $data[$pk] . '\'';
$pkValue = $data[$pk];
unset($data[$pk]);
} else {
// 如果没有任何更新条件则不执行
$this->error = L('_OPERATION_WRONG_');
return false;
}
}
$result = $this->db->update($data, $options);
if (false !== $result) {
if (isset($pkValue))
$data[$pk] = $pkValue;
$this->_after_update($data, $options);
}
return $result;
}
// 更新数据前的回调方法
protected function _before_update(&$data, $options) {
}
// 更新成功后的回调方法
protected function _after_update($data, $options) {
}
/**
+----------------------------------------------------------
* 删除数据
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @param mixed $options 表达式
+----------------------------------------------------------
* @return mixed
+----------------------------------------------------------
*/
public function delete($options=array()) {
if (empty($options) && empty($this->options)) {
// 如果删除条件为空 则删除当前数据对象所对应的记录
if (!empty($this->data) && isset($this->data[$this->getPk()]))
return $this->delete($this->data[$this->getPk()]);
else
return false;
}
if (is_numeric($options) || is_string($options)) {
// 根据主键删除记录
$pk = $this->getPk();
if (strpos($options, ',')) {
$where = $pk . ' IN (' . $options . ')';
} else {
$where = $pk . '=\'' . $options . '\'';
$pkValue = $options;
}
$options = array();
$options['where'] = $where;
}
// 分析表达式
$options = $this->_parseOptions($options);
$result = $this->db->delete($options);
if (false !== $result) {
$data = array();
if (isset($pkValue))
$data[$pk] = $pkValue;
$this->_after_delete($data, $options);
}
// 返回删除记录个数
return $result;
}
// 删除成功后的回调方法
protected function _after_delete($data, $options) {
}
/**
+----------------------------------------------------------
* 查询数据集
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @param array $options 表达式参数
+----------------------------------------------------------
* @return mixed
+----------------------------------------------------------
*/
public function select($options=array()) {
if (is_string($options) || is_numeric($options)) {
// 根据主键查询
$where = $this->getPk() . ' IN (' . $options . ')';
$options = array();
$options['where'] = $where;
}
// 分析表达式
$options = $this->_parseOptions($options);
$resultSet = $this->db->select($options);
if (false === $resultSet) {
return false;
}
if (empty($resultSet)) { // 查询结果为空
return null;
}
$this->_after_select($resultSet, $options);
if (is_array($resultSet) && !empty($resultSet)) {
foreach ($resultSet as $key => $val) {
if ($val['news_content']) {
$resultSet[$key]['news_content'] = stripcslashes($val['news_content']);
} elseif ($val['text_content']) {
$resultSet[$key]['text_content'] = stripcslashes($val['text_content']);
} elseif ($val['p_content']) {
$resultSet[$key]['p_content'] = stripcslashes($val['p_content']);
} else {
break;
}
}
}
return $resultSet;
}
// 查询成功后的回调方法
protected function _after_select(&$resultSet, $options) {
}
public function findAll($options=array()) {
return $this->select($options);
}
/**
+----------------------------------------------------------
* 分析表达式
+----------------------------------------------------------
* @access private
+----------------------------------------------------------
* @param array $options 表达式参数
+----------------------------------------------------------
* @return array
+----------------------------------------------------------
*/
private function _parseOptions($options) {
if (is_array($options))
$options = array_merge($this->options, $options);
// 查询过后清空sql表达式组装 避免影响下次查询
$this->options = array();
if (!isset($options['table']))
// 自动获取表名
$options['table'] = $this->getTableName();
if (!empty($options['alias'])) {
$options['table'] .= ' ' . $options['alias'];
}
// 字段类型验证
if (C('DB_FIELDTYPE_CHECK')) {
if (isset($options['where']) && is_array($options['where'])) {
// 对数组查询条件进行字段类型检查
foreach ($options['where'] as $key => $val) {
if (in_array($key, $this->fields, true) && is_scalar($val)) {
$fieldType = strtolower($this->fields['_type'][$key]);
if (false !== strpos($fieldType, 'int')) {
$options['where'][$key] = intval($val);
} elseif (false !== strpos($fieldType, 'float') || false !== strpos($fieldType, 'double')) {
$options['where'][$key] = floatval($val);
}
}
}
}
}
// 表达式过滤
$this->_options_filter($options);
return $options;
}
// 表达式过滤回调方法
protected function _options_filter(&$options) {
}
/**
+----------------------------------------------------------
* 查询数据
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @param mixed $options 表达式参数
+----------------------------------------------------------
* @return mixed
+----------------------------------------------------------
*/
public function find($options=array()) {
if (!empty($options) && ( is_numeric($options) || is_string($options))) {
$where = $this->getPk() . '=\'' . $options . '\'';
$options = array();
$options['where'] = $where;
}
// 总是查找一条记录
$options['limit'] = 1;
// 分析表达式
$options = $this->_parseOptions($options);
$resultSet = $this->db->select($options);
if (false === $resultSet) {
return false;
}
if (empty($resultSet)) {// 查询结果为空
return null;
}
$this->data = $resultSet[0];
$this->_after_find($this->data, $options);
if ($this->data['text_content']) {
$this->data['text_content'] = stripcslashes($this->data['text_content']);
} elseif ($this->data['news_content']) {
$this->data['news_content'] = stripcslashes($this->data['news_content']);
} elseif ($this->data['p_content']) {
$this->data['p_content'] = stripcslashes($this->data['p_content']);
}
return $this->data;
}
// 查询成功的回调方法
protected function _after_find(&$result, $options) {
}
/**
+----------------------------------------------------------
* 设置记录的某个字段值
* 支持使用数据库字段和方法
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @param string|array $field 字段名
* @param string|array $value 字段值
* @param mixed $condition 条件
+----------------------------------------------------------
* @return boolean
+----------------------------------------------------------
*/
public function setField($field, $value, $condition='') {
if (empty($condition) && isset($this->options['where']))
$condition = $this->options['where'];
$options['where'] = $condition;
if (is_array($field)) {
foreach ($field as $key => $val)
$data[$val] = $value[$key];
} else {
$data[$field] = $value;
}
return $this->save($data, $options);
}
/**
+----------------------------------------------------------
* 字段值增长
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @param string $field 字段名
* @param mixed $condition 条件
* @param integer $step 增长值
+----------------------------------------------------------
* @return boolean
+----------------------------------------------------------
*/
public function setInc($field, $condition='', $step=1) {
return $this->setField($field, array('exp', $field . '+' . $step), $condition);
}
/**
+----------------------------------------------------------
* 字段值减少
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @param string $field 字段名
* @param mixed $condition 条件
* @param integer $step 减少值
+----------------------------------------------------------
* @return boolean
+----------------------------------------------------------
*/
public function setDec($field, $condition='', $step=1) {
return $this->setField($field, array('exp', $field . '-' . $step), $condition);
}
/**
+----------------------------------------------------------
* 获取一条记录的某个字段值
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @param string $field 字段名
* @param mixed $condition 查询条件
* @param string $spea 字段数据间隔符号
+----------------------------------------------------------
* @return mixed
+----------------------------------------------------------
*/
public function getField($field, $condition='', $sepa=' ') {
if (empty($condition) && isset($this->options['where']))
$condition = $this->options['where'];
$options['where'] = $condition;
$options['field'] = $field;
$options = $this->_parseOptions($options);
if (strpos($field, ',')) { // 多字段
$resultSet = $this->db->select($options);
if (!empty($resultSet)) {
$field = explode(',', $field);
$key = array_shift($field);
$cols = array();
foreach ($resultSet as $result) {
$name = $result[$key];
$cols[$name] = '';
foreach ($field as $val)
$cols[$name] .= $result[$val] . $sepa;
$cols[$name] = substr($cols[$name], 0, -strlen($sepa));
}
return $cols;
}
} else { // 查找一条记录
$options['limit'] = 1;
$result = $this->db->select($options);
if (!empty($result)) {
return reset($result[0]);
}
}
return null;
}
/**
+----------------------------------------------------------
* 创建数据对象 但不保存到数据库
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @param mixed $data 创建数据
* @param string $type 状态
+----------------------------------------------------------
* @return mixed
+----------------------------------------------------------
*/
public function create($data='', $type='') {
// 如果没有传值默认取POST数据
if (empty($data)) {
$data = $_POST;
} elseif (is_object($data)) {
$data = get_object_vars($data);
} elseif (!is_array($data)) {
$this->error = L('_DATA_TYPE_INVALID_');
return false;
}
// 状态
$type = $type ? $type : (!empty($data[$this->getPk()]) ? self::MODEL_UPDATE : self::MODEL_INSERT);
// 表单令牌验证
if (C('TOKEN_ON') && !$this->autoCheckToken($data)) {
$this->error = L('_TOKEN_ERROR_');
return false;
}
// 检查字段映射
if (!empty($this->_map)) {
foreach ($this->_map as $key => $val) {
if (isset($data[$key])) {
$data[$val] = $data[$key];
unset($data[$key]);
}
}
}
// 数据自动验证
if (!$this->autoValidation($data, $type))
return false;
// 验证完成生成数据对象
$vo = array();
foreach ($this->fields as $key => $name) {
if (substr($key, 0, 1) == '_')
continue;
$val = isset($data[$name]) ? $data[$name] : null;
//保证赋值有效
if (!is_null($val)) {
$vo[$name] = (MAGIC_QUOTES_GPC && is_string($val)) ? stripslashes($val) : $val;
}
}
// 创建完成对数据进行自动处理
$this->autoOperation($vo, $type);
// 赋值当前数据对象
$this->data = $vo;
// 返回创建的数据以供其他调用
return $vo;
}
// 自动表单令牌验证
public function autoCheckToken($data) {
$name = C('TOKEN_NAME');
if (isset($_SESSION[$name])) {
// 当前需要令牌验证
if (empty($data[$name]) || $_SESSION[$name] != $data[$name]) {
// 非法提交
return false;
}
// 验证完成销毁session
unset($_SESSION[$name]);
}
return true;
}
/**
+----------------------------------------------------------
* 使用正则验证数据
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @param string $value 要验证的数据
* @param string $rule 验证规则
+----------------------------------------------------------
* @return boolean
+----------------------------------------------------------
*/
public function regex($value, $rule) {
$validate = array(
'require' => '/.+/',
'email' => '/^\w+([-+.]\w+)*@\w+([-.]\w+)*\.\w+([-.]\w+)*$/',
'url' => '/^http:\/\/[A-Za-z0-9]+\.[A-Za-z0-9]+[\/=\?%\-&_~`@[\]\':+!]*([^<>\"\"])*$/',
'currency' => '/^\d+(\.\d+)?$/',
'number' => '/^\d+$/',
'zip' => '/^[1-9]\d{5}$/',
'integer' => '/^[-\+]?\d+$/',
'double' => '/^[-\+]?\d+(\.\d+)?$/',
'english' => '/^[A-Za-z]+$/',
);
// 检查是否有内置的正则表达式
if (isset($validate[strtolower($rule)]))
$rule = $validate[strtolower($rule)];
return preg_match($rule, $value) === 1;
}
/**
+----------------------------------------------------------
* 自动表单处理
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @param array $data 创建数据
* @param string $type 创建类型
+----------------------------------------------------------
* @return mixed
+----------------------------------------------------------
*/
private function autoOperation(&$data, $type) {
// 自动填充
if (!empty($this->_auto)) {
foreach ($this->_auto as $auto) {
// 填充因子定义格式
// array('field','填充内容','填充条件','附加规则',[额外参数])
if (empty($auto[2]))
$auto[2] = self::MODEL_INSERT; // 默认为新增的时候自动填充
if ($type == $auto[2] || $auto[2] == self::MODEL_BOTH) {
switch ($auto[3]) {
case 'function': // 使用函数进行填充 字段的值作为参数
case 'callback': // 使用回调方法
$args = isset($auto[4]) ? $auto[4] : array();
if (isset($data[$auto[0]])) {
array_unshift($args, $data[$auto[0]]);
}
if ('function' == $auto[3]) {
$data[$auto[0]] = call_user_func_array($auto[1], $args);
} else {
$data[$auto[0]] = call_user_func_array(array(&$this, $auto[1]), $args);
}
break;
case 'field': // 用其它字段的值进行填充
$data[$auto[0]] = $data[$auto[1]];
break;
case 'string':
default: // 默认作为字符串填充
$data[$auto[0]] = $auto[1];
}
if (false === $data[$auto[0]])
unset($data[$auto[0]]);
}
}
}
return $data;
}
/**
+----------------------------------------------------------
* 自动表单验证
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @param array $data 创建数据
* @param string $type 创建类型
+----------------------------------------------------------
* @return boolean
+----------------------------------------------------------
*/
private function autoValidation($data, $type) {
// 属性验证
if (!empty($this->_validate)) {
// 如果设置了数据自动验证
// 则进行数据验证
// 重置验证错误信息
foreach ($this->_validate as $key => $val) {
// 验证因子定义格式
// array(field,rule,message,condition,type,when,params)
// 判断是否需要执行验证
if (empty($val[5]) || $val[5] == self::MODEL_BOTH || $val[5] == $type) {
if (0 == strpos($val[2], '{%') && strpos($val[2], '}'))
// 支持提示信息的多语言 使用 {%语言定义} 方式
$val[2] = L(substr($val[2], 2, -1));
$val[3] = isset($val[3]) ? $val[3] : self::EXISTS_VAILIDATE;
$val[4] = isset($val[4]) ? $val[4] : 'regex';
// 判断验证条件
switch ($val[3]) {
case self::MUST_VALIDATE: // 必须验证 不管表单是否有设置该字段
if (false === $this->_validationField($data, $val)) {
$this->error = $val[2];
return false;
}
break;
case self::VALUE_VAILIDATE: // 值不为空的时候才验证
if ('' != trim($data[$val[0]])) {
if (false === $this->_validationField($data, $val)) {
$this->error = $val[2];
return false;
}
}
break;
default: // 默认表单存在该字段就验证
if (isset($data[$val[0]])) {
if (false === $this->_validationField($data, $val)) {
$this->error = $val[2];
return false;
}
}
}
}
}
}
return true;
}
/**
+----------------------------------------------------------
* 根据验证因子验证字段
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @param array $data 创建数据
* @param string $val 验证规则
+----------------------------------------------------------
* @return boolean
+----------------------------------------------------------
*/
private function _validationField($data, $val) {
switch ($val[4]) {
case 'function':// 使用函数进行验证
case 'callback':// 调用方法进行验证
$args = isset($val[6]) ? $val[6] : array();
array_unshift($args, $data[$val[0]]);
if ('function' == $val[4]) {
return call_user_func_array($val[1], $args);
} else {
return call_user_func_array(array(&$this, $val[1]), $args);
}
case 'confirm': // 验证两个字段是否相同
return $data[$val[0]] == $data[$val[1]];
case 'in': // 验证是否在某个数组范围之内
return in_array($data[$val[0]], $val[1]);
case 'equal': // 验证是否等于某个值
return $data[$val[0]] == $val[1];
case 'unique': // 验证某个值是否唯一
if (is_string($val[0]) && strpos($val[0], ','))
$val[0] = explode(',', $val[0]);
$map = array();
if (is_array($val[0])) {
// 支持多个字段验证
foreach ($val[0] as $field)
$map[$field] = $data[$field];
} else {
$map[$val[0]] = $data[$val[0]];
}
if (!empty($data[$this->getPk()])) { // 完善编辑的时候验证唯一
$map[$this->getPk()] = array('neq', $data[$this->getPk()]);
}
if ($this->where($map)->find())
return false;
break;
case 'regex':
default: // 默认使用正则验证 可以使用验证类中定义的验证名称
// 检查附加规则
return $this->regex($data[$val[0]], $val[1]);
}
return true;
}
/**
+----------------------------------------------------------
* SQL查询
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @param mixed $sql SQL指令
+----------------------------------------------------------
* @return mixed
+----------------------------------------------------------
*/
public function query($sql) {
if (!empty($sql)) {
if (strpos($sql, '__TABLE__'))
$sql = str_replace('__TABLE__', $this->getTableName(), $sql);
return $this->db->query($sql);
}else {
return false;
}
}
/**
+----------------------------------------------------------
* 执行SQL语句
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @param string $sql SQL指令
+----------------------------------------------------------
* @return false | integer
+----------------------------------------------------------
*/
public function execute($sql) {
if (!empty($sql)) {
if (strpos($sql, '__TABLE__'))
$sql = str_replace('__TABLE__', $this->getTableName(), $sql);
return $this->db->execute($sql);
}else {
return false;
}
}
/**
+----------------------------------------------------------
* 切换当前的数据库连接
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @return string
+----------------------------------------------------------
*/
public function db($linkNum, $config='') {
static $_db = array();
if (!isset($_db[$linkNum]) && !empty($config)) {
// 创建一个新的实例
$_db[$linkNum] = Db::getInstance($config);
} elseif (NULL === $config) {
$_db[$linkNum]->close(); // 关闭数据库连接
unset($_db[$linkNum]);
return;
}
// 切换数据库连接
$this->db = $_db[$linkNum];
return $this;
}
/**
+----------------------------------------------------------
* 得到当前的数据对象名称
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @return string
+----------------------------------------------------------
*/
public function getModelName() {
if (empty($this->name))
$this->name = substr(get_class($this), 0, -5);
return $this->name;
}
/**
+----------------------------------------------------------
* 得到完整的数据表名
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @return string
+----------------------------------------------------------
*/
public function getTableName() {
if (empty($this->trueTableName)) {
$tableName = !empty($this->tablePrefix) ? $this->tablePrefix : '';
if (!empty($this->tableName)) {
$tableName .= $this->tableName;
} else {
$tableName .= parse_name($this->name);
}
$tableName .=!empty($this->tableSuffix) ? $this->tableSuffix : '';
if (!empty($this->dbName))
$tableName = $this->dbName . '.' . $tableName;
$this->trueTableName = strtolower($tableName);
}
return $this->trueTableName;
}
/**
+----------------------------------------------------------
* 启动事务
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @return void
+----------------------------------------------------------
*/
public function startTrans() {
$this->commit();
$this->db->startTrans();
return;
}
/**
+----------------------------------------------------------
* 提交事务
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @return boolean
+----------------------------------------------------------
*/
public function commit() {
return $this->db->commit();
}
/**
+----------------------------------------------------------
* 事务回滚
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @return boolean
+----------------------------------------------------------
*/
public function rollback() {
return $this->db->rollback();
}
/**
+----------------------------------------------------------
* 返回模型的错误信息
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @return string
+----------------------------------------------------------
*/
public function getError() {
return $this->error;
}
/**
+----------------------------------------------------------
* 返回数据库的错误信息
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @return string
+----------------------------------------------------------
*/
public function getDbError() {
return $this->db->getError();
}
/**
+----------------------------------------------------------
* 返回最后插入的ID
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @return string
+----------------------------------------------------------
*/
public function getLastInsID() {
return $this->db->lastInsID;
}
/**
+----------------------------------------------------------
* 返回最后执行的sql语句
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @return string
+----------------------------------------------------------
*/
public function getLastSql() {
return $this->db->getLastSql();
}
/**
+----------------------------------------------------------
* 获取主键名称
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @return string
+----------------------------------------------------------
*/
public function getPk() {
return isset($this->fields['_pk']) ? $this->fields['_pk'] : $this->pk;
}
/**
+----------------------------------------------------------
* 获取数据表字段信息
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @return array
+----------------------------------------------------------
*/
public function getDbFields() {
return $this->fields;
}
/**
+----------------------------------------------------------
* 设置数据对象值
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @param mixed $data 数据
+----------------------------------------------------------
* @return Model
+----------------------------------------------------------
*/
public function data($data) {
if (is_object($data)) {
$data = get_object_vars($data);
} elseif (is_string($data)) {
parse_str($data, $data);
} elseif (!is_array($data)) {
throw_exception(L('_DATA_TYPE_INVALID_'));
}
$this->data = $data;
return $this;
}
/**
+----------------------------------------------------------
* 查询SQL组装 join
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @param mixed $join
+----------------------------------------------------------
* @return Model
+----------------------------------------------------------
*/
public function join($join) {
if (is_array($join))
$this->options['join'] = $join;
else
$this->options['join'][] = $join;
return $this;
}
/**
+----------------------------------------------------------
* 设置模型的属性值
+----------------------------------------------------------
* @access public
+----------------------------------------------------------
* @param string $name 名称
* @param mixed $value 值
+----------------------------------------------------------
* @return Model
+----------------------------------------------------------
*/
public function setProperty($name, $value) {
if (property_exists($this, $name))
$this->$name = $value;
return $this;
}
}
;
?> |
