You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
106 lines
2.8 KiB
106 lines
2.8 KiB
8 years ago
|
<?php
|
||
|
|
||
|
namespace yiiunit\framework\caching;
|
||
|
|
||
|
use yii\caching\ArrayCache;
|
||
|
use yii\caching\DbQueryDependency;
|
||
|
use yii\db\Query;
|
||
|
use yiiunit\framework\db\DatabaseTestCase;
|
||
|
|
||
|
class DbQueryDependencyTest extends DatabaseTestCase
|
||
|
{
|
||
|
/**
|
||
|
* @inheritdoc
|
||
|
*/
|
||
|
protected $driverName = 'sqlite';
|
||
|
|
||
|
|
||
|
/**
|
||
|
* @inheritdoc
|
||
|
*/
|
||
|
protected function setUp()
|
||
|
{
|
||
|
parent::setUp();
|
||
|
|
||
|
$db = $this->getConnection(false);
|
||
|
|
||
|
$db->createCommand()->createTable('dependency_item', [
|
||
|
'id' => 'pk',
|
||
|
'value' => 'string',
|
||
|
])->execute();
|
||
|
|
||
|
$db->createCommand()->insert('dependency_item', ['value' => 'initial'])->execute();
|
||
|
}
|
||
|
|
||
|
public function testIsChanged()
|
||
|
{
|
||
|
$db = $this->getConnection(false);
|
||
|
$cache = new ArrayCache();
|
||
|
|
||
|
$dependency = new DbQueryDependency();
|
||
|
$dependency->db = $db;
|
||
|
$dependency->query = (new Query())
|
||
|
->select(['id'])
|
||
|
->from('dependency_item')
|
||
|
->orderBy(['id' => SORT_DESC])
|
||
|
->limit(1);
|
||
|
$dependency->reusable = false;
|
||
|
|
||
|
$dependency->evaluateDependency($cache);
|
||
|
$this->assertFalse($dependency->isChanged($cache));
|
||
|
|
||
|
$db->createCommand()->insert('dependency_item', ['value' => 'new'])->execute();
|
||
|
|
||
|
$this->assertTrue($dependency->isChanged($cache));
|
||
|
}
|
||
|
|
||
|
/**
|
||
|
* @depends testIsChanged
|
||
|
*/
|
||
|
public function testCustomMethod()
|
||
|
{
|
||
|
$db = $this->getConnection(false);
|
||
|
$cache = new ArrayCache();
|
||
|
|
||
|
$dependency = new DbQueryDependency();
|
||
|
$dependency->db = $db;
|
||
|
$dependency->query = (new Query())
|
||
|
->from('dependency_item')
|
||
|
->andWhere(['value' => 'active']);
|
||
|
$dependency->reusable = false;
|
||
|
$dependency->method = 'exists';
|
||
|
|
||
|
$dependency->evaluateDependency($cache);
|
||
|
$this->assertFalse($dependency->isChanged($cache));
|
||
|
|
||
|
$db->createCommand()->insert('dependency_item', ['value' => 'active'])->execute();
|
||
|
|
||
|
$this->assertTrue($dependency->isChanged($cache));
|
||
|
}
|
||
|
|
||
|
/**
|
||
|
* @depends testCustomMethod
|
||
|
*/
|
||
|
public function testCustomMethodCallback()
|
||
|
{
|
||
|
$db = $this->getConnection(false);
|
||
|
$cache = new ArrayCache();
|
||
|
|
||
|
$dependency = new DbQueryDependency();
|
||
|
$dependency->db = $db;
|
||
|
$dependency->query = (new Query())
|
||
|
->from('dependency_item')
|
||
|
->andWhere(['value' => 'not exist']);
|
||
|
$dependency->reusable = false;
|
||
|
$dependency->method = function (Query $query, $db) {
|
||
|
return $query->orWhere(['value' => 'initial'])->exists($db);
|
||
|
};
|
||
|
|
||
|
$dependency->evaluateDependency($cache);
|
||
|
$this->assertFalse($dependency->isChanged($cache));
|
||
|
|
||
|
$db->createCommand()->delete('dependency_item')->execute();
|
||
|
|
||
|
$this->assertTrue($dependency->isChanged($cache));
|
||
|
}
|
||
|
}
|