PHP框架实现数据库连贯查询的思路解析

$result = $mysqlDb->limit(’0,10′)->order(‘id desc’)->findall();

$mysql

limit

order

return $this

<?php

/*
*类功能：实现数据库的连贯查询操作
*/
class mysql_query{
var $tbl=’user’;//要操作的表名
var $limit=”;//存储limit语句的变量
var $order=”;//存储order语句的变量
var $sql=”;//存储完整sql语句的变量

function limit($str) {
$this->limit=’limit ‘.$str;//设置limit语句
//返回对类自身的引用，这里不能使用return new mysql_qery()，
//因为这样相当于又创建了类的一个新实例，那么上一步设置的limit语句，在新实例中是不存在的
//大家可以自己实验
//因此要返回$this，即当前类的实例
return $this;
}

function order($str) {
$this->order=’order by ‘.$str;//设置order语句
return $this;//返回对类自身的引用
}

function findall() {
$this->sql=’select * from ‘.$this->tbl.’ ‘.$this->order.’ ‘.$this->limit;//拼接sql语句
echo $this->sql;//输出，由于是示例，所以没有写查询数据库的代码
}

}

//Example
$mysqlDb=new mysql_query();
$result = $mysqlDb->limit(’0,10′)->order(‘id desc’)->findall();
print_r($result);
?>

<?php
class Test {

protected $options = array();

//这里就是了, 通过判断调用的函数名, 如果存在, 那么设置参数, 返回自己
public function __call($func, $args) {
if (in_array($func, array('form', 'field', 'join', 'order', 'where', 'limit', '更多....'))) {
$this->options[$func] = $args;
return $this; //这里返回了本对象
}
}

}

//Example
$test = new Test();
$test->form('test'); // 这样调用就相当于设置 $test->options['form'] = 'test';

//在ThinkPHP中这种连贯操作都是以find或者findAll结尾的.
//所以前面这些方法的调用只是在设置查询的参数而已
//在find或者findAll方法中, 是根据$this->options参数的不同执行不同的SQL
//比如这样
Php代码  收藏代码
public function find() {
$sql = "SELECT {$this->options['field']} FROM {$this->options['form']}";
$sql .= isset($this->options['where']) ? " WHERE {$this->options['where']}" : '';
//.........更多处理
echo $sql;
}

<?php
class Users
{
protected $options = array();

public function select()
{
$fields = $this->options['field'] ? $this->options['field'] : "*";
$query = "select ".$fields." from ";
$query .= $this->options['table']." where ";
$query .= $this->options['where']." limit 0,";
$query .= $this->options['limit']." order by ";
$query .= $this->options['order'].";";;
echo $query;
//do something for select data from database;
}
public function __call($methods,$vars)
{
$this->options[$methods] = $vars[0];
return $this;           //关键在这里是返回对象
}
}
$p = new Users();
$p->table('users')->field('username,passwd')->where("uid = 12")->limit('10')->order("uid asc")->select();

/**
+----------------------------------------------------------
* 利用__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));
$where[$field] =  $args[0];
return $this->where($where)->find();
}else{
throw_exception(__CLASS__.':'.$method.L('_METHOD_NOT_EXIST_'));
return;
}
}

$this->dao= M(‘table’);          //快速高性能实例化一个 table 表的模型
$this->dao->field($field)->where($where)->limit($offset . ‘,’ . $limit)->select();
//设置查询字段，查询条件，设置查询数量，最后执行查询操作。当然返回的就是数据库记录了

<?php
// 使用__call()方法来实现数据库连贯操作
// 申明一个Db类（数据库操作类）的简单操作模型

class Db{
private $sql = array(
"field" => "",
"where" => "",
"order" => "",
"limit" => "",
"group" => "",
"having" => "",
);

// 连贯操作调用field() where() order() limit() group() having()方法，组合sql语句
function __call($methodName,$args){
// 将第一个参数(代表不存在方法的方法名称),全部转成小写方式，获取方法名称
$methodName = strtolower($methodName);

// 如果调用的方法名和成员属性数组$sql下标对应上，则将第二个参数给数组中下标对应的元素
if(array_key_exists($methodName,$this->sql)){
$this->sql[$methodName] = $args[0];
}else{
echo '调用类'.get_class($this).'中的方法'.$methodName.'()不存在';
}
// 返回自己对象，则可以继续调用本对象中的方法，形成连贯操作
return $this;
}
// 输出连贯操作后组合的一个sql语句，是连贯操作最后的一个方法
function select(){
echo "SELECT {$this->sql['field']} FROM  user {$this->sql['where']} {$this->sql['order']} {$this->sql['limit']} {$this->sql['group']}
{$this->sql['having']}";
}
}

$db = new Db();

// 连贯操作
$db->field('sex, count(sex)')
->where('where sex in ("男","女")')
->group('group by sex')
->having('having avg(age) > 25')
->select();
?>