Skip to content

Model

Jump to bottom Edit New page
Eachcan edited this page Oct 21, 2015 · 7 revisions

这是框架最复杂的部分。

从一个简单的例子开始：

<?php

class UserModel extends Model {
	public $id, $password, $mobile, $nickname, $reg_time, $login_times, $last_login_time, $reg_ip, $last_login_ip, $retry_times, $last_retry_time, $exp = 0, $auto_login_times = 0, $syncd = 0;
	
	protected $_primary = 'id';

	protected $_database = 'default';
	
	public function findByMobile($mobile) {
		$this->where("mobile", $mobile);
		
		return $this->findOne(true);
	}
}

每个数据表会对应一个模型。

先解释一下结构：

类名

UserModel 对应 user 表，LoginFailLogModel 则对应 login_fail_log 表。如果有前缀，则表名会加个前缀，类名不用变。也就是 UserModel 可能对应 ac_uesr 表。

字段声明

要列出所有的数据库字段，并建议声明为 public，主要是：

  1. 便于编辑器给出提示
  2. 插入的时候，如果字段不在此列表中，则不会被插入到数据库，但在条件语句中的字段名则不受此限制。

$_primary 表示主键，会在不指定主键的某些情况下以此为主键，默认为 id

$_database 对应数据库，数据库配置即为： $config['db'][$_database] 项所指的内容。默认为 default

$_table 表示表名，如果配置文件中指定了前缀，则在使用的时候会自动加上前缀。

如果要直接指定表名，则需要重写方法：

	public function getUsingTable() {
		return "my_table_name";
	}

执行 SQL 语句

框架使用的是 PDO，所以要用SQL语句，请先了解 PDO 如何工作 PDO

$sql = "SELECT * FROM user WHERE id=:id";
$model = new UserModel(); // 无论什么Model都行，反正你写了 SQL 了
$result = $model->query($sql, array('id' => 1));
$rows = $result->fetchAll(PDO::FETCH_ASSOC);

执行完 query ，返回值就是一个 PDOStatement，执行失败返回 false

一些前置知识

绑定参数

// 一般绑定方法
$this->where("id=:id");
$this->bind("id", 1); // 同下面一个
$this->bind(array("id" => 1));

// 绑定 like '%xx%' 类型的值
$this->where("name like '::prefix%'");
$this->bind("prefix", "赵");

// 绑定 in (1, 2, 3) 类型的值
$this->where("id in (::ids)");
$this->bind("ids", array(1, 2, 3));

为值加引号

$quote = $this->quote("str'ing"); // "'str\\\'ing'"

给一些值加上 `

$this->quoteKey(array('user')); // array('`user`');

清除之前设置的值

注意： 执行查询、更新、插入、删除等任何查询语句后，都会自动执行此方法

$this->reset();

模型包含的值

$data = $this->value(); // array('id' => 1, 'name' => 'eachcan', ...)

对当前模型进行批量赋值

$this->flat(array('id' => 2));
// 类似于以下：
$this->id = 2;

查看一下上次执行的SQL

$this->getLastQuery(); // select * from xyz;

看一下之前执行的失败消息

$this->getMessages();

当前模型使用的表

$this->getUsingTable(); // prefix_user

查询影响的行数或者记录集数

$this->affectRows(); // 1

清理设置过的值

$this->clean();

上次插入行的ID

$this->lastInsertId();

查询(SELECT)操作

在任何操作中，都和 PDO 保持一致，你在任何时间可以使用 PDO 相同的 SQL 语法。

$rows = $this->find();

foreach ($rows as $row) {
	echo $row['id'];
}

$this->where('expired_time > :time');
$rows = $this->find(array('time' => time()));

条件语句

// where 之间，是使用 AND 进行连接的。如果使用了多个where，则会导致每次where时都会用括号包围起来。

$this->where('id', 1);
// where id=1

// 传入占位符写法
$this->where("id=:id"); // 直接传入一个占位符

$this->where("id > :id OR create_time < :time"); // 直接加入条件

$this->where("id = :id", array('id' => 1)); // 直接传入绑定的值

// 如果直接使用上面语句，相当于生成以下语句： WHERE (id=:id) AND (id > :id OR create_time < :time) AND (id = :id)

// 对于 where in 的支持：
$this->where("id in (::id)", array("id" => array(1, 2, 3)));
// 相当于： WHERE id in (1, 2, 3)

// 对于原生语句的支持：
$this->where("name like '%::keyword%'", array('keyword' => 'a'));

指定字段

$this->select(); // 不写就相当于执行了这个，SELECT *
$this->select('id'); // select id
$this->select('id, name');
$this->select('MAX(id) as id'); // SELECT MAX(id) as id

from, 选择其他表

$this->from('xyz'); // FROM xyz，其实from如果不调用，就相当于 from 了当前表，一般不需要调用
$this->from('xyz a'); // FROM xyz a

join, 连接表

$this->leftJoin('xyz a', 'a.id=tbl.id');
// 还有 rightJoin、outerJoin、innerJoin

groupby

$this->groupBy('cid');
$this->groupBy('cid DESC');

having

// 使用完全同于 where
$this->having("cnt > :cnt");
$this->having("cnt > :cnt", array('cnt' => 1));

orderby

$this->orderBy("id DESC"); // ORDER BY id DESC

limit

$this->limit(10); // limit 10
$this->limit(10, 9990); // limit 9990, 10

我们一般在分页的时候会使用 limit 但如果想知道全部行数，又要去掉 limit 再 count 一次。现在不需要了，只需要：

$this->prepareFoundRows();
$this->limit(10, 20);
$rows = $this->find();
$total = $this->getFoundRows(); # foundRows() also.

插入数据

$this->insert(array('id' => 1, 'name' => 'Eachcan')); // INSERT table (id, name) VALUES (1, 'Eachcan');

$this->id = 1;
$this->name = 'Eachcan';
$this->insert(null, true); // INSERT IGNORE table (id, name) VALUES (1, 'Eachcan');

更新数据

$this->where('id=1');
$this->id = 1;
$this->name = 'Eachcan';
$this->update(); // UPDATE table SET id=1, name='Eachcan' WHERE id=1;

删除数据

$this->where('id=1');
$this->delete(); // DELETE FROM table WHERE id=1;

查询并插入到另一个表中

$this->insertSelect();

批量插入

// 暂未实现

插入时如果唯一键冲突则更新

// 请参考源代码

事务支持

启动一次事务

此时你可以指定一个错误的模式，请参考： [PDO 常量]http://php.net/manual/zh/pdo.constants.php#PDO::ERRMODE_SILENT

如果之前已经启动了一次事务，则不会有任何反应。启动一次事务的本质是关闭自动提交事务模式。

如果启动了事务但中途中断执行而没有调用提交事务，则会自动回滚。

请不要同时使用 mysql_query("begin transaction") 或 $model->query("begin transaction"); 或其他方式启动事务。否则将在每个链接单独启用事务。

$this->beginTransaction();

提交事务

提交事务，务必在启用事务后提交，否则没有任何作用

$this->commit();

回滚事务

$this->rollback();
Add a custom footer
Add a custom sidebar
Clone this wiki locally