# 缓存对象关系映射（Caching in the ORM）
现实中的每个应用都不同，一些应用的模型数据经常改变而另一些模型的数据几乎不同。访问数据库在很多时候对我们应用的来说 是个瓶颈。这是由于我们每次访问应用时都会和数据库数据通信，和数据库进行通信的代价是很大的。因此在必要时我们可以通过增加 缓存层来获取更高的性能。 本章内容的重点即是探讨实施缓存来提高性能的可行性。Phalcon框架给我们提供了灵活的缓存技术来实现我们的应用缓存。
## 缓存结果集（Caching Resultsets）
一个非常可行的方案是我们可以为那些不经常改变且经常访问的数据库数据进行缓存，比如把他们放入内存，这样可以加快程序的执行速度。
当[Phalcon\\Mvc\\Model](http://docs.iphalcon.cn/api/Phalcon_Mvc_Model.html)需要使用缓存数据的服务时Model可以直接从DI中取得此缓存服务modelsCache(惯例名).
Phalcon提供了一个组件（服务）可以用来[缓存](http://docs.iphalcon.cn/reference/cache.html)任何种类的数据，下面我们会解释如何在model使用它。第一步我们要在启动文件注册 这个服务:
~~~
<?php
use Phalcon\Cache\Frontend\Data as FrontendData;
use Phalcon\Cache\Backend\Memcache as BackendMemcache;
// 设置模型缓存服务
$di->set(
"modelsCache",
function () {
// 默认缓存时间为一天
$frontCache = new FrontendData(
[
"lifetime" => 86400,
]
);
// Memcached连接配置 这里使用的是Memcache适配器
$cache = new BackendMemcache(
$frontCache,
[
"host" => "localhost",
"port" => "11211",
]
);
return $cache;
}
);
~~~
在注册缓存服务时我们可以按照我们的需要进行配置。一旦完成正确的缓存设置之后，我们可以按如下的方式缓存查询的结果了:
~~~
<?php
// 直接取Products模型里的数据（未缓存）
$products = Products::find();
// 缓存查询结果.缓存时间为默认1天。
$products = Products::find(
[
"cache" => [
"key" => "my-cache",
],
]
);
// 缓存查询结果时间为300秒
$products = Products::find(
[
"cache" => [
"key" => "my-cache",
"lifetime" => 300,
],
]
);
// Use the 'cache' service from the DI instead of 'modelsCache'
$products = Products::find(
[
"cache" => [
"key" => "my-cache",
"service" => "cache",
],
]
);
这里我们也可以缓存关联表的数据:
~~~
~~~
<?php
// Query some post
$post = Post::findFirst();
// Get comments related to a post, also cache it
$comments = $post->getComments(
[
"cache" => [
"key" => "my-key",
],
]
);
// Get comments related to a post, setting lifetime
$comments = $post->getComments(
[
"cache" => [
"key" => "my-key",
"lifetime" => 3600,
],
]
);
~~~
如果想删除已经缓存的结果，则只需要使用前面指定的缓存的键值进行删除即可。
注意并不是所有的结果都必须缓存下来。那些经常改变的数据就不应该被缓存，这样做只会影响应用的性能。另外对于那些特别大的 不易变的数据集，开发者应用根据实际情况进行选择是否进行缓存。
## 强制缓存（Forcing Cache）
前面的例子中我们在[Phalcon\\Mvc\\Model](http://docs.iphalcon.cn/api/Phalcon_Mvc_Model.html)中使用框架内建的缓存组件。为实现强制缓存我们传递了cache作为参数：
~~~
<?php
// 缓存查询结果5分钟
$products = Products::find(
[
"cache" => [
"key" => "my-cache",
"lifetime" => 300,
],
]
);
~~~
这给了我们自由选择需要缓存的查询结果，但是如果我们想对模型中的所有查询结果进行缓存，那么我们可以重写:code:find()/:code:[`](http://docs.iphalcon.cn/reference/models-cache.html#id1)findFirst()`方法：
~~~
<?php
use Phalcon\Mvc\Model;
class Robots extends Model
{
/**
* Implement a method that returns a string key based
* on the query parameters
*/
protected static function _createKey($parameters)
{
$uniqueKey = [];
foreach ($parameters as $key => $value) {
if (is_scalar($value)) {
$uniqueKey[] = $key . ":" . $value;
} elseif (is_array($value)) {
$uniqueKey[] = $key . ":[" . self::_createKey($value) . "]";
}
}
return join(",", $uniqueKey);
}
public static function find($parameters = null)
{
// Convert the parameters to an array
if (!is_array($parameters)) {
$parameters = [$parameters];
}
// Check if a cache key wasn't passed
// and create the cache parameters
if (!isset($parameters["cache"])) {
$parameters["cache"] = [
"key" => self::_createKey($parameters),
"lifetime" => 300,
];
}
return parent::find($parameters);
}
public static function findFirst($parameters = null)
{
// ...
}
}
~~~
访问数据要远比计算key值慢的多，我们在这里定义自己需要的key生成方式。注意好的键可以避免冲突，这样就可以依据不同的key值 取得不同的缓存结果。
这样我们可以对每个模型的缓存进行完全的控制，如果其他的模型也需要共用此缓存，可以建立一个模型缓存基类：
~~~
<?php
use Phalcon\Mvc\Model;
class CacheableModel extends Model
{
protected static function _createKey($parameters)
{
// ... Create a cache key based on the parameters
}
public static function find($parameters = null)
{
// ... Custom caching strategy
}
public static function findFirst($parameters = null)
{
// ... Custom caching strategy
}
}
~~~
然后把这个类作为其它缓存类的基类：
~~~
<?php
class Robots extends CacheableModel
{
}
~~~
## 缓存 PHQL 查询（Caching PHQL Queries）
ORM中的所有查询，不论多高级的查询方法，内部都是通过PHQL进行实现的。PHQL可以让我们非常自由的创建各种查询，当然这些查询也可以被缓存：
~~~
<?php
$phql = "SELECT * FROM Cars WHERE name = :name:";
$query = $this->modelsManager->createQuery($phql);
$query->cache(
[
"key" => "cars-by-name",
"lifetime" => 300,
]
);
$cars = $query->execute(
[
"name" => "Audi",
]
);
~~~
## 可重用的相关记录（Reusable Related Records）
一些模型可能与其他模型之间有关联关系。下面的例子可以让我们非常容易的在内存中检索相关联的数据：
~~~
<?php
// Get some invoice
$invoice = Invoices::findFirst();
// Get the customer related to the invoice
$customer = $invoice->customer;
// Print his/her name
echo $customer->name, "\n";
~~~
这个例子非常简单，依据查询到的订单信息取得用户信息之后再取得用户名。下面的例子也是如此：我们查询了一些订单的信息，然后取得这些订单相关联 用户的信息，之后取得用户名：
~~~
<?php
// Get a set of invoices
// SELECT * FROM invoices;
$invoices = Invoices::find();
foreach ($invoices as $invoice) {
// Get the customer related to the invoice
// SELECT * FROM customers WHERE id = ?;
$customer = $invoice->customer;
// Print his/her name
echo $customer->name, "\n";
}
~~~
每个客户可能会有一个或多个帐单，这就意味着客户对象没必须取多次。为了避免一次次的重复取客户信息，我们这里设置关系为reusable为true, 这样ORM就可以重复使用客户信息：
~~~
<?php
use Phalcon\Mvc\Model;
class Invoices extends Model
{
public function initialize()
{
$this->belongsTo(
"customers_id",
"Customer",
"id",
[
"reusable" => true,
]
);
}
}
~~~
此Cache存在于内存中，这意味着当请求结束时缓存数据即被释放。
## 缓存相关记录（Caching Related Records）
当使用:code:[`](http://docs.iphalcon.cn/reference/models-cache.html#id3)find()`或:code:[`](http://docs.iphalcon.cn/reference/models-cache.html#id5)findFirst()`查询关联数据时，ORM内部会自动的依据以下规则创建查询条件：
| 类型 | 描述 | 隐含方法 |
| --- | --- | --- |
| Belongs-To | 直接的返回模型相关的记录 | `findFirst()` |
| Has-One | 直接的返回模型相关的记录 | `findFirst()` |
| Has-Many | 返回模型相关的记录集合 | `find()` |
这意味着当我们取得关联记录时，我们需要解析如何取得数据的方法：
~~~
<?php
// Get some invoice
$invoice = Invoices::findFirst();
// Get the customer related to the invoice
$customer = $invoice->customer; // Invoices::findFirst("...");
// Same as above
$customer = $invoice->getCustomer(); // Invoices::findFirst("...");
~~~
因此，我们可以替换掉Invoices模型中的:code:[`](http://docs.iphalcon.cn/reference/models-cache.html#id7)findFirst()`方法然后实现我们使用适合的方法
~~~
<?php
use Phalcon\Mvc\Model;
class Invoices extends Model
{
public static function findFirst($parameters = null)
{
// ... Custom caching strategy
}
}
~~~
## 递归缓存相关记录（Caching Related Records Recursively）
在这种场景下我们假定我们每次取主记录时都会取模型的关联记录，如果我们此时保存这些记录可能会为我们的系统带来一些性能上的提升：
~~~
<?php
use Phalcon\Mvc\Model;
class Invoices extends Model
{
protected static function _createKey($parameters)
{
// ... Create a cache key based on the parameters
}
protected static function _getCache($key)
{
// Returns data from a cache
}
protected static function _setCache($key, $results)
{
// Stores data in the cache
}
public static function find($parameters = null)
{
// Create a unique key
$key = self::_createKey($parameters);
// Check if there are data in the cache
$results = self::_getCache($key);
// Valid data is an object
if (is_object($results)) {
return $results;
}
$results = [];
$invoices = parent::find($parameters);
foreach ($invoices as $invoice) {
// Query the related customer
$customer = $invoice->customer;
// Assign it to the record
$invoice->customer = $customer;
$results[] = $invoice;
}
// Store the invoices in the cache + their customers
self::_setCache($key, $results);
return $results;
}
public function initialize()
{
// Add relations and initialize other stuff
}
}
~~~
从已经缓存的订单中取得用户信息，可以减少系统的负载。注意我们也可以使用PHQL来实现这个，下面使用了PHQL来实现：
~~~
<?php
use Phalcon\Mvc\Model;
class Invoices extends Model
{
public function initialize()
{
// Add relations and initialize other stuff
}
protected static function _createKey($conditions, $params)
{
// ... Create a cache key based on the parameters
}
public function getInvoicesCustomers($conditions, $params = null)
{
$phql = "SELECT Invoices.*, Customers.* FROM Invoices JOIN Customers WHERE " . $conditions;
$query = $this->getModelsManager()->executeQuery($phql);
$query->cache(
[
"key" => self::_createKey($conditions, $params),
"lifetime" => 300,
]
);
return $query->execute($params);
}
}
~~~
## 基于条件的缓存（Caching based on Conditions）
此例中，根据不同的条件实施缓存. We might decide that the cache backend should be determined by the primary key:
| 类型 | 缓存 |
| --- | --- |
| 1 - 10000 | mongo1 |
| 10000 - 20000 | mongo2 |
| \> 20000 | mongo3 |
最简单的方式即是为模型类添加一个静态的方法，此方法中我们指定要使用的缓存：
~~~
<?php
use Phalcon\Mvc\Model;
class Robots extends Model
{
public static function queryCache($initial, $final)
{
if ($initial >= 1 && $final < 10000) {
$service = "mongo1";
} elseif ($initial >= 10000 && $final <= 20000) {
$service = "mongo2";
} elseif ($initial > 20000) {
$service = "mongo3";
}
return self::find(
[
"id >= " . $initial . " AND id <= " . $final,
"cache" => [
"service" => $service,
],
]
);
}
}
~~~
这个方法是可以解决问题，不过如果我们需要添加其它的参数比如排序或条件等等，我们还要创建更复杂的方法。另外当我们使用:code:find()/:code:[`](http://docs.iphalcon.cn/reference/models-cache.html#id9)findFirst()`来查询关联数据时此方法亦会失效：
~~~
<?php
$robots = Robots::find("id < 1000");
$robots = Robots::find("id > 100 AND type = 'A'");
$robots = Robots::find("(id > 100 AND type = 'A') AND id < 2000");
$robots = Robots::find(
[
"(id > ?0 AND type = 'A') AND id < ?1",
"bind" => [100, 2000],
"order" => "type",
]
);
~~~
为了实现这个，我们需要拦截中间语言解析，然后书写相关的代码以定制缓存： 首先我们需要创建自定义的创建器，然后我们可以使用它来创建自己定义的查询：
~~~
<?php
use Phalcon\Mvc\Model\Query\Builder as QueryBuilder;
class CustomQueryBuilder extends QueryBuilder
{
public function getQuery()
{
$query = new CustomQuery($this->getPhql());
$query->setDI($this->getDI());
return $query;
}
}
~~~
这里我们返回的是CustomQuery而不是不直接的返回[Phalcon\\Mvc\\Model\\Query](http://docs.iphalcon.cn/api/Phalcon_Mvc_Model_Query.html)， 类定义如下所示：
~~~
<?php
use Phalcon\Mvc\Model\Query as ModelQuery;
class CustomQuery extends ModelQuery
{
/**
* The execute method is overridden
*/
public function execute($params = null, $types = null)
{
// Parse the intermediate representation for the SELECT
$ir = $this->parse();
// Check if the query has conditions
if (isset($ir["where"])) {
// The fields in the conditions can have any order
// We need to recursively check the conditions tree
// to find the info we're looking for
$visitor = new CustomNodeVisitor();
// Recursively visits the nodes
$visitor->visit($ir["where"]);
$initial = $visitor->getInitial();
$final = $visitor->getFinal();
// Select the cache according to the range
// ...
// Check if the cache has data
// ...
}
// Execute the query
$result = $this->_executeSelect($ir, $params, $types);
// Cache the result
// ...
return $result;
}
}
~~~
这里我们实现了一个帮助类，用递归的方式来检查条件中的查询字段，方便我们了解需要使用缓存的范围（即检查条件以确认实施查询缓存的范围）：
~~~
<?php
class CustomNodeVisitor
{
protected $_initial = 0;
protected $_final = 25000;
public function visit($node)
{
switch ($node["type"]) {
case "binary-op":
$left = $this->visit($node["left"]);
$right = $this->visit($node["right"]);
if (!$left || !$right) {
return false;
}
if ($left === "id") {
if ($node["op"] === ">") {
$this->_initial = $right;
}
if ($node["op"] === "=") {
$this->_initial = $right;
}
if ($node["op"] === ">=") {
$this->_initial = $right;
}
if ($node["op"] === "<") {
$this->_final = $right;
}
if ($node["op"] === "<=") {
$this->_final = $right;
}
}
break;
case "qualified":
if ($node["name"] === "id") {
return "id";
}
break;
case "literal":
return $node["value"];
default:
return false;
}
}
public function getInitial()
{
return $this->_initial;
}
public function getFinal()
{
return $this->_final;
}
}
~~~
最后，我们替换Robots模型中的查询方法，以使用我们创建的自定义类：
~~~
<?php
use Phalcon\Mvc\Model;
class Robots extends Model
{
public static function find($parameters = null)
{
if (!is_array($parameters)) {
$parameters = [$parameters];
}
$builder = new CustomQueryBuilder($parameters);
$builder->from(get_called_class());
$query = $builder->getQuery();
if (isset($parameters["bind"])) {
return $query->execute($parameters["bind"]);
} else {
return $query->execute();
}
}
}
~~~
## 缓存 PHQL 查询计划（Caching of PHQL planning）
像大多数现代的操作系统一样PHQL内部会缓存执行计划，如果同样的语句多次执行，PHQL会使用之前生成的查询计划以提升系统的性能， 对开发者来说只采用绑定参数的形式传递参数即可实现：
~~~
<?php
for ($i = 1; $i <= 10; $i++) {
$phql = "SELECT * FROM Store\Robots WHERE id = " . $i;
$robots = $this->modelsManager->executeQuery($phql);
// ...
}
~~~
上面的例子中，Phalcon产生了10个查询计划，这导致了应用的内存使用量增加。重写以上代码，我们使用绑定参数的这个优点可以减少系统和数据库的过多操作：
~~~
<?php
$phql = "SELECT * FROM Store\Robots WHERE id = ?0";
for ($i = 1; $i <= 10; $i++) {
$robots = $this->modelsManager->executeQuery(
$phql,
[
$i,
]
);
// ...
}
~~~
使用PHQL查询亦可以提升查询性能：
~~~
<?php
$phql = "SELECT * FROM Store\Robots WHERE id = ?0";
$query = $this->modelsManager->createQuery($phql);
for ($i = 1; $i <= 10; $i++) {
$robots = $query->execute(
$phql,
[
$i,
]
);
// ...
}
~~~
[预先准备的查询语句](http://en.wikipedia.org/wiki/Prepared_statement)的查询计划亦可以被大多数的数据库所缓存，这样可以减少执行的时间，也可以使我们的系统免受[SQL注入](http://en.wikipedia.org/wiki/SQL_injection)的影响。
- 简介
- 安装
- 安装(installlation)
- XAMPP下的安装
- WAMP下安装
- Nginx安装说明
- Apache安装说明
- Cherokee 安装说明
- 使用 PHP 内置 web 服务器
- Phalcon 开发工具
- Linux 系统下使用 Phalcon 开发工具
- Mac OS X 系统下使用 Phalcon 开发工具
- Windows 系统下使用 Phalcon 开发工具
- 教程
- 教程 1：让我们通过例子来学习
- 教程 2：INVO简介
- 教程 3: 保护INVO
- 教程4: 使用CRUD
- 教程5: 定制INVO
- 教程 6: Vökuró
- 教程 7：创建简单的 REST API
- 组件
- 依赖注入与服务定位器
- MVC架构
- 使用控制器
- 使用模型
- 模型关系
- 事件与事件管理器
- Behaviors
- 模型元数据
- 事务管理
- 验证数据完整性
- Workingwith Models
- Phalcon查询语言
- 缓存对象关系映射
- 对象文档映射 ODM
- 使用视图
- 视图助手
- 资源文件管理
- Volt 模版引擎
- MVC 应用
- 路由
- 调度控制器
- Micro Applications
- 使用命名空间
- 事件管理器
- Request Environmen
- 返回响应
- Cookie 管理
- 生成 URL 和 路径
- 闪存消息
- 使用 Session 存储数据
- 过滤与清理
- 上下文编码
- 验证Validation
- 表单_Forms
- 读取配置
- 分页 Pagination
- 使用缓存提高性能
- 安全
- 加密与解密 Encryption/Decryption
- 访问控制列表
- 多语言支持
- 类加载器 Class Autoloader
- 日志记录_Logging
- 注释解析器 Annotations Parser
- 命令行应用 Command Line Applications
- Images
- 队列 Queueing
- 数据库抽象层
- 国际化
- 数据库迁移
- 调试应用程序
- 单元测试
- 进阶技巧与延伸阅读
- 提高性能：下一步该做什么？
- Dependency Injection Explained
- Understanding How Phalcon Applications Work
- Api
- Abstract class Phalcon\Acl