# 仓储
Testing Is Documentation
仓储层可以看作是对实体的一种包装，通过构造器注入的实体。
Uses
<?php
use Leevel\Database\Ddd\Entity;
use Leevel\Database\Ddd\ISpecification;
use Leevel\Database\Ddd\Repository;
use Leevel\Database\Ddd\Select;
use Leevel\Database\Ddd\Specification;
use Leevel\Database\Page;
use Leevel\Page\Page as BasePage;
use Leevel\Support\Collection;
use Tests\Database\DatabaseTestCase as TestCase;
use Tests\Database\Ddd\Entity\DemoUnique;
use Tests\Database\Ddd\Entity\Relation\Post;
# 基本使用方法
public function testBase(): void
{
$connect = $this->createDatabaseConnect();
$this->assertSame(
1,
$connect
->table('post')
->insert([
'title' => 'hello world',
'user_id' => 1,
'summary' => 'post summary',
'delete_at' => 0,
])
);
$repository = new Repository(new Post());
$newPost = $repository->findEntity(1);
$this->assertInstanceof(Post::class, $newPost);
$this->assertSame(1, $newPost->id);
$this->assertSame(1, $newPost->userId);
$this->assertSame('hello world', $newPost->title);
$this->assertSame('post summary', $newPost->summary);
$this->assertInstanceof(Post::class, $repository->entity());
}
# findEntity 通过主键查找实体
public function testFindEntity(): void
{
$connect = $this->createDatabaseConnect();
$this->assertSame(
1,
$connect
->table('post')
->insert([
'title' => 'hello world',
'user_id' => 1,
'summary' => 'post summary',
'delete_at' => 0,
])
);
$repository = new Repository(new Post());
$newPost = $repository->findEntity(1);
$this->assertInstanceof(Post::class, $newPost);
$this->assertSame(1, $newPost->id);
$this->assertSame(1, $newPost->userId);
$this->assertSame('hello world', $newPost->title);
$this->assertSame('post summary', $newPost->summary);
}
# findOrFail 通过主键查找实体，未找到则抛出异常
public function testFindOrFail(): void
{
$connect = $this->createDatabaseConnect();
$this->assertSame(
1,
$connect
->table('post')
->insert([
'title' => 'hello world',
'user_id' => 1,
'summary' => 'post summary',
'delete_at' => 0,
])
);
$repository = new Repository(new Post());
$newPost = $repository->findOrFail(1);
$this->assertInstanceof(Post::class, $newPost);
$this->assertSame(1, $newPost->id);
$this->assertSame(1, $newPost->userId);
$this->assertSame('hello world', $newPost->title);
$this->assertSame('post summary', $newPost->summary);
}
# findOrFail 通过主键查找实体，未找到则抛出异常例子
public function testFindOrFailNotFound(): void
{
$this->expectException(\Leevel\Database\Ddd\EntityNotFoundException::class);
$this->expectExceptionMessage(
'Entity `Tests\\Database\\Ddd\\Entity\\Relation\\Post` was not found.'
);
$repository = new Repository(new Post());
$newPost = $repository->findOrFail(1);
}
# 规约闭包查询
public function testSpecWithClosure(): void
{
$connect = $this->createDatabaseConnect();
for ($i = 0; $i < 10; $i++) {
$connect
->table('post')
->insert([
'title' => 'hello world',
'user_id' => 1,
'summary' => 'post summary',
'delete_at' => 0,
]);
}
$request = ['foo' => 'bar', 'hello' => 'world'];
$repository = new Repository(new Post());
$spec = new Specification(function (Entity $entity) use ($request) {
return 'bar' === $request['foo'];
}, function (Select $select, Entity $entity) {
$select->where('id', '>', 3);
});
$andSpec = $spec->and(new Specification(function (Entity $entity) use ($request) {
return 'world' === $request['hello'];
}, function (Select $select, Entity $entity) {
$select->where('id', '<', 8);
}));
$this->assertInstanceof(ISpecification::class, $andSpec);
$this->assertInstanceof(Specification::class, $andSpec);
$select = $repository->condition($andSpec);
$result = $select->findAll();
$sql = <<<'eot'
SQL: [126] SELECT `post`.* FROM `post` WHERE `post`.`delete_at` = :post_delete_at AND `post`.`id` > :post_id AND `post`.`id` < :post_id_1 | Params: 3 | Key: Name: [15] :post_delete_at | paramno=0 | name=[15] ":post_delete_at" | is_param=1 | param_type=1 | Key: Name: [8] :post_id | paramno=1 | name=[8] ":post_id" | is_param=1 | param_type=1 | Key: Name: [10] :post_id_1 | paramno=2 | name=[10] ":post_id_1" | is_param=1 | param_type=1 (SELECT `post`.* FROM `post` WHERE `post`.`delete_at` = 0 AND `post`.`id` > 3 AND `post`.`id` < 8)
eot;
$this->assertSame(
$sql,
$select->getLastSql(),
);
$this->assertInstanceof(Select::class, $select);
$this->assertInstanceof(Collection::class, $result);
$this->assertCount(4, $result);
}
# from 转换为标准规约查询
fixture 定义
Tests\Database\Ddd\Demo1Specification
namespace Tests\Database\Ddd;
class Demo1Specification extends Specification
{
private $request;
public function __construct(array $request)
{
$this->request = $request;
}
public function isSatisfiedBy(Entity $entity): bool
{
return 'bar' === $this->request['foo'];
}
public function handle(Select $select, Entity $entity): void
{
$select->where('id', '>', 3);
}
}
Tests\Database\Ddd\Demo2Specification
namespace Tests\Database\Ddd;
class Demo2Specification extends Specification
{
private $request;
public function __construct(array $request)
{
$this->request = $request;
}
public function isSatisfiedBy(Entity $entity): bool
{
return 'world' === $this->request['hello'];
}
public function handle(Select $select, Entity $entity): void
{
$select->where('id', '<', 8);
}
}
public function testSpecWithClass(): void
{
$connect = $this->createDatabaseConnect();
for ($i = 0; $i < 10; $i++) {
$connect
->table('post')
->insert([
'title' => 'hello world',
'user_id' => 1,
'summary' => 'post summary',
'delete_at' => 0,
]);
}
$request = ['foo' => 'bar', 'hello' => 'world'];
$repository = new Repository(new Post());
$spec = Specification::from(new Demo1Specification($request));
$spec->and(new Demo2Specification($request));
$this->assertInstanceof(ISpecification::class, $spec);
$this->assertInstanceof(Specification::class, $spec);
$select = $repository->condition($spec);
$result = $select->findAll();
$sql = <<<'eot'
SQL: [126] SELECT `post`.* FROM `post` WHERE `post`.`delete_at` = :post_delete_at AND `post`.`id` > :post_id AND `post`.`id` < :post_id_1 | Params: 3 | Key: Name: [15] :post_delete_at | paramno=0 | name=[15] ":post_delete_at" | is_param=1 | param_type=1 | Key: Name: [8] :post_id | paramno=1 | name=[8] ":post_id" | is_param=1 | param_type=1 | Key: Name: [10] :post_id_1 | paramno=2 | name=[10] ":post_id_1" | is_param=1 | param_type=1 (SELECT `post`.* FROM `post` WHERE `post`.`delete_at` = 0 AND `post`.`id` > 3 AND `post`.`id` < 8)
eot;
$this->assertSame(
$sql,
$select->getLastSql(),
);
$this->assertInstanceof(Select::class, $select);
$this->assertInstanceof(Collection::class, $result);
$this->assertCount(4, $result);
}
# not 规约反操作
public function testFindAllBySpecWithClosureForNot(): void
{
$connect = $this->createDatabaseConnect();
for ($i = 0; $i < 10; $i++) {
$connect
->table('post')
->insert([
'title' => 'hello world',
'user_id' => 1,
'summary' => 'post summary',
'delete_at' => 0,
]);
}
$request = ['foo' => 'bar', 'hello' => 'world'];
$repository = new Repository(new Post());
$spec = new Specification(function (Entity $entity) use ($request) {
return 'bar' === $request['foo'];
}, function (Select $select, Entity $entity) {
$select->where('id', '>', 3);
});
$notSpec = $spec->not();
$this->assertInstanceof(ISpecification::class, $notSpec);
$this->assertInstanceof(Specification::class, $notSpec);
$result = $repository->findAll($notSpec);
$sql = <<<'eot'
SQL: [70] SELECT `post`.* FROM `post` WHERE `post`.`delete_at` = :post_delete_at | Params: 1 | Key: Name: [15] :post_delete_at | paramno=0 | name=[15] ":post_delete_at" | is_param=1 | param_type=1 (SELECT `post`.* FROM `post` WHERE `post`.`delete_at` = 0)
eot;
$this->assertSame(
$sql,
$repository->getLastSql(),
);
$this->assertInstanceof(Collection::class, $result);
$this->assertCount(10, $result);
}
# or 规约或操作
public function testSpecWithOrFirstIsNo(): void
{
$connect = $this->createDatabaseConnect();
for ($i = 0; $i < 10; $i++) {
$connect
->table('post')
->insert([
'title' => 'hello world',
'user_id' => 1,
'summary' => 'post summary',
'delete_at' => 0,
]);
}
$request = ['foo' => 'bar', 'hello' => 'world'];
$repository = new Repository(new Post());
$spec = new Specification(function (Entity $entity) use ($request) {
return 'bar_no' === $request['foo'];
}, function (Select $select, Entity $entity) {
$select->where('id', '>', 3);
});
$orSpec = $spec->or(new Specification(function (Entity $entity) use ($request) {
return 'world' === $request['hello'];
}, function (Select $select, Entity $entity) {
$select->where('id', '<', 8);
}));
$this->assertInstanceof(ISpecification::class, $orSpec);
$this->assertInstanceof(Specification::class, $orSpec);
$select = $repository->condition($orSpec);
$result = $select->findAll();
$sql = <<<'eot'
SQL: [97] SELECT `post`.* FROM `post` WHERE `post`.`delete_at` = :post_delete_at AND `post`.`id` < :post_id | Params: 2 | Key: Name: [15] :post_delete_at | paramno=0 | name=[15] ":post_delete_at" | is_param=1 | param_type=1 | Key: Name: [8] :post_id | paramno=1 | name=[8] ":post_id" | is_param=1 | param_type=1 (SELECT `post`.* FROM `post` WHERE `post`.`delete_at` = 0 AND `post`.`id` < 8)
eot;
$this->assertSame(
$sql,
$select->getLastSql(),
);
$this->assertInstanceof(Select::class, $select);
$this->assertInstanceof(Collection::class, $result);
$this->assertCount(7, $result);
}
# make 创建规约表达式
public function testSpecMake(): void
{
$connect = $this->createDatabaseConnect();
for ($i = 0; $i < 10; $i++) {
$connect
->table('post')
->insert([
'title' => 'hello world',
'user_id' => 1,
'summary' => 'post summary',
'delete_at' => 0,
]);
}
$request = ['foo' => 'bar', 'hello' => 'world'];
$repository = new Repository(new Post());
$spec = Specification::make(function (Entity $entity) use ($request) {
return 'bar' === $request['foo'];
}, function (Select $select, Entity $entity) {
$select->where('id', '>', 4);
});
$select = $repository->condition($spec);
$result = $select->findAll();
$this->assertInstanceof(Select::class, $select);
$this->assertInstanceof(Collection::class, $result);
$this->assertCount(6, $result);
}
# and 规约与操作
public function testFindCountWithAndFirstIsYes(): void
{
$connect = $this->createDatabaseConnect();
for ($i = 0; $i < 10; $i++) {
$connect
->table('post')
->insert([
'title' => 'hello world',
'user_id' => 1,
'summary' => 'post summary',
'delete_at' => 0,
]);
}
$request = ['foo' => 'bar', 'hello' => 'world'];
$repository = new Repository(new Post());
$specExpr = new Specification(function (Entity $entity) use ($request) {
return 'bar' === $request['foo'];
}, function (Select $select, Entity $entity) {
$select->where('id', '>', 3);
});
$specExpr->and(new Specification(function (Entity $entity) use ($request) {
return 'world' === $request['hello'];
}, function (Select $select, Entity $entity) {
$select->where('id', '<', 6);
}));
$this->assertInstanceof(ISpecification::class, $specExpr);
$this->assertInstanceof(Specification::class, $specExpr);
$result = $repository->findCount($specExpr);
$this->assertSame(2, $result);
}
# __call 魔术方法访问实体查询
public function testCall(): void
{
$connect = $this->createDatabaseConnect();
$this->assertSame(
1,
$connect
->table('post')
->insert([
'title' => 'hello world',
'user_id' => 1,
'summary' => 'post summary',
'delete_at' => 0,
])
);
$repository = new Repository(new Post());
$newPost = $repository
->where('id', 5)
->findEntity(1);
$this->assertInstanceof(Post::class, $newPost);
$this->assertNull($newPost->id);
$this->assertNull($newPost->userId);
$this->assertNull($newPost->title);
$this->assertNull($newPost->summary);
}
# createEntity 新增实体
public function testCreateTwice(): void
{
$repository = new Repository(new Post());
$repository->createEntity($post = new Post([
'id' => 5,
'title' => 'foo',
'user_id' => 0,
]));
$this->assertSame('SQL: [147] INSERT INTO `post` (`post`.`id`,`post`.`title`,`post`.`user_id`) VALUES (:pdonamedparameter_id,:pdonamedparameter_title,:pdonamedparameter_user_id) | Params: 3 | Key: Name: [21] :pdonamedparameter_id | paramno=0 | name=[21] ":pdonamedparameter_id" | is_param=1 | param_type=1 | Key: Name: [24] :pdonamedparameter_title | paramno=1 | name=[24] ":pdonamedparameter_title" | is_param=1 | param_type=2 | Key: Name: [26] :pdonamedparameter_user_id | paramno=2 | name=[26] ":pdonamedparameter_user_id" | is_param=1 | param_type=1 (INSERT INTO `post` (`post`.`id`,`post`.`title`,`post`.`user_id`) VALUES (5,\'foo\',0))', $repository->getLastSql());
$this->assertSame(5, $post->id);
$this->assertSame('foo', $post->title);
$this->assertSame(0, $post->userId);
$this->assertSame([], $post->changed());
$repository->createEntity($post);
$this->assertSame('SQL: [31] INSERT INTO `post` () VALUES () | Params: 0 (INSERT INTO `post` () VALUES ())', $repository->getLastSql());
$newPost = $repository->findEntity(5);
$this->assertInstanceof(Post::class, $newPost);
$this->assertSame(5, $newPost->id);
$this->assertSame('foo', $newPost->title);
$newPost = $repository->findEntity(6);
$this->assertInstanceof(Post::class, $newPost);
$this->assertSame(6, $newPost->id);
$this->assertSame('', $newPost->title);
}
# updateEntity 更新实体
public function testUpdateTwiceAndDoNothing(): void
{
$connect = $this->createDatabaseConnect();
$this->assertSame(
1,
$connect
->table('post')
->insert([
'title' => 'hello world',
'user_id' => 1,
'summary' => 'post summary',
'delete_at' => 0,
])
);
$repository = new Repository(new Post());
$this->assertSame(1, $repository->updateEntity($post = new Post(['id' => 1, 'title' => 'new title'])));
$this->assertSame('SQL: [96] UPDATE `post` SET `post`.`title` = :pdonamedparameter_title WHERE `post`.`id` = :post_id LIMIT 1 | Params: 2 | Key: Name: [24] :pdonamedparameter_title | paramno=0 | name=[24] ":pdonamedparameter_title" | is_param=1 | param_type=2 | Key: Name: [8] :post_id | paramno=1 | name=[8] ":post_id" | is_param=1 | param_type=1 (UPDATE `post` SET `post`.`title` = \'new title\' WHERE `post`.`id` = 1 LIMIT 1)', $repository->getLastSql());
$this->assertSame([], $post->changed());
$this->assertNull($repository->updateEntity($post));
}
# replaceEntity 替换实体
public function testReplaceTwiceAndFindExistData(): void
{
$connect = $this->createDatabaseConnect();
$this->assertSame(
1,
$connect
->table('post')
->insert([
'title' => 'hello world',
'user_id' => 1,
'summary' => 'post summary',
'delete_at' => 0,
])
);
$repository = new Repository(new Post());
$affectedRow = $repository->replaceEntity($post = new Post([
'id' => 1,
'title' => 'new title',
'user_id' => 1,
]));
$this->assertSame('SQL: [142] UPDATE `post` SET `post`.`title` = :pdonamedparameter_title,`post`.`user_id` = :pdonamedparameter_user_id WHERE `post`.`id` = :post_id LIMIT 1 | Params: 3 | Key: Name: [24] :pdonamedparameter_title | paramno=0 | name=[24] ":pdonamedparameter_title" | is_param=1 | param_type=2 | Key: Name: [26] :pdonamedparameter_user_id | paramno=1 | name=[26] ":pdonamedparameter_user_id" | is_param=1 | param_type=1 | Key: Name: [8] :post_id | paramno=2 | name=[8] ":post_id" | is_param=1 | param_type=1 (UPDATE `post` SET `post`.`title` = \'new title\',`post`.`user_id` = 1 WHERE `post`.`id` = 1 LIMIT 1)', $repository->getLastSql());
$this->assertSame(1, $affectedRow);
$this->assertSame([], $post->changed());
$repository->replaceEntity($post); // 新增一条数据.
$this->assertSame('SQL: [31] INSERT INTO `post` () VALUES () | Params: 0 (INSERT INTO `post` () VALUES ())', $repository->getLastSql());
$updatedPost = $repository->findEntity(1);
$this->assertSame(1, $updatedPost->id);
$this->assertSame('new title', $updatedPost->title);
$this->assertSame(1, $updatedPost->userId);
$this->assertSame('post summary', $updatedPost->summary);
$newPost2 = $repository->findEntity(2);
$this->assertInstanceof(Post::class, $newPost2);
$this->assertSame(2, $newPost2->id);
$this->assertSame('', $newPost2->title);
$this->assertSame('', $newPost2->summary);
}
# deleteEntity 响应删除
public function testSoftDeleteTwice(): void
{
$connect = $this->createDatabaseConnect();
$this->assertSame(
1,
$connect
->table('post')
->insert([
'title' => 'hello world',
'user_id' => 1,
'summary' => 'post summary',
'delete_at' => 0,
])
);
$repository = new Repository(new Post());
$repository->deleteEntity($post = new Post(['id' => 1, 'title' => 'new title']));
$sql = 'SQL: [104] UPDATE `post` SET `post`.`delete_at` = :pdonamedparameter_delete_at WHERE `post`.`id` = :post_id LIMIT 1 | Params: 2 | Key: Name: [28] :pdonamedparameter_delete_at | paramno=0 | name=[28] ":pdonamedparameter_delete_at" | is_param=1 | param_type=1 | Key: Name: [8] :post_id | paramno=1 | name=[8] ":post_id" | is_param=1 | param_type=1 (UPDATE `post` SET `post`.`delete_at` = %d WHERE `post`.`id` = 1 LIMIT 1)';
$this->assertTrue(in_array($repository->getLastSql(), [
sprintf($sql, time() - 1),
sprintf($sql, time()),
sprintf($sql, time() + 1),
], true));
$repository->deleteEntity($post); // 将会更新 `delete_at` 字段.
$sql = 'SQL: [104] UPDATE `post` SET `post`.`delete_at` = :pdonamedparameter_delete_at WHERE `post`.`id` = :post_id LIMIT 1 | Params: 2 | Key: Name: [28] :pdonamedparameter_delete_at | paramno=0 | name=[28] ":pdonamedparameter_delete_at" | is_param=1 | param_type=1 | Key: Name: [8] :post_id | paramno=1 | name=[8] ":post_id" | is_param=1 | param_type=1 (UPDATE `post` SET `post`.`delete_at` = %s WHERE `post`.`id` = 1 LIMIT 1)';
$this->assertTrue(in_array($repository->getLastSql(), [
sprintf($sql, time() - 1),
sprintf($sql, time()),
sprintf($sql, time() + 1),
], true));
$newPost = $repository->findEntity(1);
$this->assertInstanceof(Post::class, $newPost);
$this->assertNull($newPost->id);
$this->assertNull($newPost->userId);
$this->assertNull($newPost->title);
$this->assertNull($newPost->summary);
}
# forceDeleteEntity 强制删除实体
public function testForceDeleteTwice(): void
{
$connect = $this->createDatabaseConnect();
$this->assertSame(
1,
$connect
->table('post')
->insert([
'title' => 'hello world',
'user_id' => 1,
'summary' => 'post summary',
'delete_at' => 0,
])
);
$repository = new Repository(new Post());
$repository->forceDeleteEntity($post = new Post(['id' => 1, 'title' => 'new title']));
$this->assertSame('SQL: [55] DELETE FROM `post` WHERE `post`.`id` = :post_id LIMIT 1 | Params: 1 | Key: Name: [8] :post_id | paramno=0 | name=[8] ":post_id" | is_param=1 | param_type=1 (DELETE FROM `post` WHERE `post`.`id` = 1 LIMIT 1)', $repository->getLastSql());
$repository->forceDeleteEntity($post); // 会执行 SQL，因为已经删除，没有任何影响.
$this->assertSame('SQL: [55] DELETE FROM `post` WHERE `post`.`id` = :post_id LIMIT 1 | Params: 1 | Key: Name: [8] :post_id | paramno=0 | name=[8] ":post_id" | is_param=1 | param_type=1 (DELETE FROM `post` WHERE `post`.`id` = 1 LIMIT 1)', $repository->getLastSql());
$newPost = $repository->findEntity(1);
$this->assertInstanceof(Post::class, $newPost);
$this->assertNull($newPost->id);
$this->assertNull($newPost->userId);
$this->assertNull($newPost->title);
$this->assertNull($newPost->summary);
}
# condition 条件查询器支持闭包
public function testConditionIsClosure(): void
{
$connect = $this->createDatabaseConnect();
for ($i = 0; $i < 10; $i++) {
$connect
->table('post')
->insert([
'title' => 'hello world',
'user_id' => 1,
'summary' => 'post summary',
'delete_at' => 0,
]);
}
$request = ['foo' => 'no-bar', 'hello' => 'no-world'];
$repository = new Repository(new Post());
$condition = function (Select $select, Entity $entity) {
$select->where('id', '<', 8);
};
$select = $repository->condition($condition);
$result = $select->findAll();
$this->assertInstanceof(Select::class, $select);
$this->assertInstanceof(Collection::class, $result);
$this->assertCount(7, $result);
}
# findPage 分页查询
public function testFindPage(): void
{
$connect = $this->createDatabaseConnect();
for ($i = 0; $i < 10; $i++) {
$connect
->table('post')
->insert([
'title' => 'hello world',
'user_id' => 1,
'summary' => 'post summary',
'delete_at' => 0,
]);
}
$repository = new Repository(new Post());
$page = $repository->findPage(1, 10);
$result = $page->getData();
$this->assertInstanceof(BasePage::class, $page);
$this->assertInstanceof(Page::class, $page);
$this->assertInstanceof(Collection::class, $result);
$this->assertCount(10, $result);
}
# findPage 分页查询支持条件过滤
public function testFindPageWithCondition(): void
{
$connect = $this->createDatabaseConnect();
for ($i = 0; $i < 10; $i++) {
$connect
->table('post')
->insert([
'title' => 'hello world',
'user_id' => 1,
'summary' => 'post summary',
'delete_at' => 0,
]);
}
$request = ['foo' => 'no-bar', 'hello' => 'no-world'];
$repository = new Repository(new Post());
$condition = function (Select $select, Entity $entity) {
$select->where('id', '<', 8);
};
$page = $repository->findPage(1, 10, $condition);
$result = $page->getData();
$this->assertInstanceof(BasePage::class, $page);
$this->assertInstanceof(Page::class, $page);
$this->assertInstanceof(Collection::class, $result);
$this->assertCount(7, $result);
}
# findPageMacro 创建一个无限数据的分页查询
public function testFindPageMacro(): void
{
$connect = $this->createDatabaseConnect();
for ($i = 0; $i < 10; $i++) {
$connect
->table('post')
->insert([
'title' => 'hello world',
'user_id' => 1,
'summary' => 'post summary',
'delete_at' => 0,
]);
}
$repository = new Repository(new Post());
$page = $repository->findPageMacro(1, 10);
$result = $page->getData();
$this->assertInstanceof(BasePage::class, $page);
$this->assertInstanceof(Page::class, $page);
$this->assertInstanceof(Collection::class, $result);
$this->assertCount(10, $result);
}
# findPageMacro 创建一个无限数据的分页查询支持条件过滤
public function testFindPageMacroWithCondition(): void
{
$connect = $this->createDatabaseConnect();
for ($i = 0; $i < 10; $i++) {
$connect
->table('post')
->insert([
'title' => 'hello world',
'user_id' => 1,
'summary' => 'post summary',
'delete_at' => 0,
]);
}
$request = ['foo' => 'no-bar', 'hello' => 'no-world'];
$repository = new Repository(new Post());
$condition = function (Select $select, Entity $entity) {
$select->where('id', '<', 8);
};
$page = $repository->findPageMacro(1, 10, $condition);
$result = $page->getData();
$this->assertInstanceof(BasePage::class, $page);
$this->assertInstanceof(Page::class, $page);
$this->assertInstanceof(Collection::class, $result);
$this->assertCount(7, $result);
}
# findPagePrevNext 创建一个只有上下页的分页查询
public function testFindPagePrevNext(): void
{
$connect = $this->createDatabaseConnect();
for ($i = 0; $i < 10; $i++) {
$connect
->table('post')
->insert([
'title' => 'hello world',
'user_id' => 1,
'summary' => 'post summary',
'delete_at' => 0,
]);
}
$repository = new Repository(new Post());
$page = $repository->findPagePrevNext(1, 10);
$result = $page->getData();
$this->assertInstanceof(BasePage::class, $page);
$this->assertInstanceof(Page::class, $page);
$this->assertInstanceof(Collection::class, $result);
$this->assertCount(10, $result);
}
# findPagePrevNext 创建一个只有上下页的分页查询支持条件过滤
public function testFindPagePrevNextWithCondition(): void
{
$connect = $this->createDatabaseConnect();
for ($i = 0; $i < 10; $i++) {
$connect
->table('post')
->insert([
'title' => 'hello world',
'user_id' => 1,
'summary' => 'post summary',
'delete_at' => 0,
]);
}
$request = ['foo' => 'no-bar', 'hello' => 'no-world'];
$repository = new Repository(new Post());
$condition = function (Select $select, Entity $entity) {
$select->where('id', '<', 8);
};
$page = $repository->findPagePrevNext(1, 10, $condition);
$result = $page->getData();
$this->assertInstanceof(BasePage::class, $page);
$this->assertInstanceof(Page::class, $page);
$this->assertInstanceof(Collection::class, $result);
$this->assertCount(7, $result);
}
# findList 返回一列数据
public function testFindList(): void
{
$connect = $this->createDatabaseConnect();
for ($i = 0; $i < 10; $i++) {
$connect
->table('post')
->insert([
'title' => 'hello world'.$i,
'user_id' => 1,
'summary' => 'post summary',
'delete_at' => 0,
]);
}
$repository = new Repository(new Post());
$result = $repository->findList(null, 'summary', 'title');
$this->assertIsArray($result);
$data = <<<'eot'
{
"hello world0": "post summary",
"hello world1": "post summary",
"hello world2": "post summary",
"hello world3": "post summary",
"hello world4": "post summary",
"hello world5": "post summary",
"hello world6": "post summary",
"hello world7": "post summary",
"hello world8": "post summary",
"hello world9": "post summary"
}
eot;
$this->assertSame(
$data,
$this->varJson(
$result
)
);
}
# findList 返回一列数据支持条件过滤
public function testFindListWithCondition(): void
{
$connect = $this->createDatabaseConnect();
for ($i = 0; $i < 10; $i++) {
$connect
->table('post')
->insert([
'title' => 'hello world'.$i,
'user_id' => 1,
'summary' => 'post summary',
'delete_at' => 0,
]);
}
$repository = new Repository(new Post());
$result = $repository->findList(function (Select $select) {
$select->where('id', '>', 5);
}, ['summary', 'title']);
$this->assertIsArray($result);
$data = <<<'eot'
{
"hello world5": "post summary",
"hello world6": "post summary",
"hello world7": "post summary",
"hello world8": "post summary",
"hello world9": "post summary"
}
eot;
$this->assertSame(
$data,
$this->varJson(
$result
)
);
}
← 事务工作单元