仓储

Testing Is Documentation

tests/Database/Ddd/RepositoryTest.php仓储 - 图1

仓储层可以看作是对实体的一种包装，通过构造器注入的实体。

Uses

  1. <?php
  3. use Leevel\Collection\Collection;
  4. use Leevel\Database\Ddd\Entity;
  5. use Leevel\Database\Ddd\ISpecification;
  6. use Leevel\Database\Ddd\Repository;
  7. use Leevel\Database\Ddd\Select;
  8. use Leevel\Database\Ddd\Specification;
  9. use Leevel\Database\Page;
  10. use Leevel\Page\Page as BasePage;
  11. use Tests\Database\DatabaseTestCase as TestCase;
  12. use Tests\Database\Ddd\Entity\DemoUnique;
  13. use Tests\Database\Ddd\Entity\Relation\Post;

基本使用方法

  1. public function testBase(): void
  2. {
  3.     $connect = $this->createDatabaseConnect();
  5.     $this->assertSame(
  6.         1,
  7.         $connect
  8.             ->table('post')
  9.             ->insert([
  10.                 'title'     => 'hello world',
  11.                 'user_id'   => 1,
  12.                 'summary'   => 'post summary',
  13.                 'delete_at' => 0,
  14.             ])
  15.     );
  17.     $repository = new Repository(new Post());
  19.     $newPost = $repository->findEntity(1);
  21.     $this->assertInstanceof(Post::class, $newPost);
  22.     $this->assertSame(1, $newPost->id);
  23.     $this->assertSame(1, $newPost->userId);
  24.     $this->assertSame('hello world', $newPost->title);
  25.     $this->assertSame('post summary', $newPost->summary);
  26.     $this->assertInstanceof(Post::class, $repository->entity());
  27. }

findEntity 通过主键查找实体

  1. public function testFindEntity(): void
  2. {
  3.     $connect = $this->createDatabaseConnect();
  5.     $this->assertSame(
  6.         1,
  7.         $connect
  8.             ->table('post')
  9.             ->insert([
  10.                 'title'     => 'hello world',
  11.                 'user_id'   => 1,
  12.                 'summary'   => 'post summary',
  13.                 'delete_at' => 0,
  14.             ])
  15.     );
  17.     $repository = new Repository(new Post());
  19.     $newPost = $repository->findEntity(1);
  21.     $this->assertInstanceof(Post::class, $newPost);
  22.     $this->assertSame(1, $newPost->id);
  23.     $this->assertSame(1, $newPost->userId);
  24.     $this->assertSame('hello world', $newPost->title);
  25.     $this->assertSame('post summary', $newPost->summary);
  26. }

findOrFail 通过主键查找实体，未找到则抛出异常

  1. public function testFindOrFail(): void
  2. {
  3.     $connect = $this->createDatabaseConnect();
  5.     $this->assertSame(
  6.         1,
  7.         $connect
  8.             ->table('post')
  9.             ->insert([
  10.                 'title'     => 'hello world',
  11.                 'user_id'   => 1,
  12.                 'summary'   => 'post summary',
  13.                 'delete_at' => 0,
  14.             ])
  15.     );
  17.     $repository = new Repository(new Post());
  19.     $newPost = $repository->findOrFail(1);
  21.     $this->assertInstanceof(Post::class, $newPost);
  22.     $this->assertSame(1, $newPost->id);
  23.     $this->assertSame(1, $newPost->userId);
  24.     $this->assertSame('hello world', $newPost->title);
  25.     $this->assertSame('post summary', $newPost->summary);
  26. }

findOrFail 通过主键查找实体，未找到则抛出异常例子

  1. public function testFindOrFailNotFound(): void
  2. {
  3.     $this->expectException(\Leevel\Database\Ddd\EntityNotFoundException::class);
  4.     $this->expectExceptionMessage(
  5.         'Entity `Tests\\Database\\Ddd\\Entity\\Relation\\Post` was not found.'
  6.     );
  8.     $repository = new Repository(new Post());
  10.     $newPost = $repository->findOrFail(1);
  11. }

规约闭包查询

  1. public function testSpecWithClosure(): void
  2. {
  3.     $connect = $this->createDatabaseConnect();
  5.     for ($i = 0; $i < 10; $i++) {
  6.         $connect
  7.             ->table('post')
  8.             ->insert([
  9.                 'title'     => 'hello world',
  10.                 'user_id'   => 1,
  11.                 'summary'   => 'post summary',
  12.                 'delete_at' => 0,
  13.             ]);
  14.     }
  16.     $request = ['foo' => 'bar', 'hello' => 'world'];
  18.     $repository = new Repository(new Post());
  20.     $spec = new Specification(function (Entity $entity) use ($request) {
  21.         return 'bar' === $request['foo'];
  22.     }, function (Select $select, Entity $entity) {
  23.         $select->where('id', '>', 3);
  24.     });
  26.     $andSpec = $spec->and(new Specification(function (Entity $entity) use ($request) {
  27.         return 'world' === $request['hello'];
  28.     }, function (Select $select, Entity $entity) {
  29.         $select->where('id', '<', 8);
  30.     }));
  32.     $this->assertInstanceof(ISpecification::class, $andSpec);
  33.     $this->assertInstanceof(Specification::class, $andSpec);
  35.     $select = $repository->condition($andSpec);
  36.     $result = $select->findAll();
  38.     $sql = <<<'eot'
  39.         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)
  40.         eot;
  41.     $this->assertSame(
  42.         $sql,
  43.         $select->getLastSql(),
  44.     );
  46.     $this->assertInstanceof(Select::class, $select);
  47.     $this->assertInstanceof(Collection::class, $result);
  48.     $this->assertCount(4, $result);
  49. }

from 转换为标准规约查询

fixture 定义

Tests\Database\Ddd\Demo1Specification

  1. namespace Tests\Database\Ddd;
  3. class Demo1Specification extends Specification
  4. {
  5.     private $request;
  7.     public function __construct(array $request)
  8.     {
  9.         $this->request = $request;
  10.     }
  12.     public function isSatisfiedBy(Entity $entity): bool
  13.     {
  14.         return 'bar' === $this->request['foo'];
  15.     }
  17.     public function handle(Select $select, Entity $entity): void
  18.     {
  19.         $select->where('id', '>', 3);
  20.     }
  21. }

Tests\Database\Ddd\Demo2Specification

  1. namespace Tests\Database\Ddd;
  3. class Demo2Specification extends Specification
  4. {
  5.     private $request;
  7.     public function __construct(array $request)
  8.     {
  9.         $this->request = $request;
  10.     }
  12.     public function isSatisfiedBy(Entity $entity): bool
  13.     {
  14.         return 'world' === $this->request['hello'];
  15.     }
  17.     public function handle(Select $select, Entity $entity): void
  18.     {
  19.         $select->where('id', '<', 8);
  20.     }
  21. }
  1. public function testSpecWithClass(): void
  2. {
  3.     $connect = $this->createDatabaseConnect();
  5.     for ($i = 0; $i < 10; $i++) {
  6.         $connect
  7.             ->table('post')
  8.             ->insert([
  9.                 'title'     => 'hello world',
  10.                 'user_id'   => 1,
  11.                 'summary'   => 'post summary',
  12.                 'delete_at' => 0,
  13.             ]);
  14.     }
  16.     $request = ['foo' => 'bar', 'hello' => 'world'];
  18.     $repository = new Repository(new Post());
  19.     $spec = Specification::from(new Demo1Specification($request));
  20.     $spec->and(new Demo2Specification($request));
  22.     $this->assertInstanceof(ISpecification::class, $spec);
  23.     $this->assertInstanceof(Specification::class, $spec);
  25.     $select = $repository->condition($spec);
  26.     $result = $select->findAll();
  28.     $sql = <<<'eot'
  29.         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)
  30.         eot;
  31.     $this->assertSame(
  32.         $sql,
  33.         $select->getLastSql(),
  34.     );
  36.     $this->assertInstanceof(Select::class, $select);
  37.     $this->assertInstanceof(Collection::class, $result);
  38.     $this->assertCount(4, $result);
  39. }

not 规约反操作

  1. public function testFindAllBySpecWithClosureForNot(): void
  2. {
  3.     $connect = $this->createDatabaseConnect();
  5.     for ($i = 0; $i < 10; $i++) {
  6.         $connect
  7.             ->table('post')
  8.             ->insert([
  9.                 'title'     => 'hello world',
  10.                 'user_id'   => 1,
  11.                 'summary'   => 'post summary',
  12.                 'delete_at' => 0,
  13.             ]);
  14.     }
  16.     $request = ['foo' => 'bar', 'hello' => 'world'];
  18.     $repository = new Repository(new Post());
  20.     $spec = new Specification(function (Entity $entity) use ($request) {
  21.         return 'bar' === $request['foo'];
  22.     }, function (Select $select, Entity $entity) {
  23.         $select->where('id', '>', 3);
  24.     });
  26.     $notSpec = $spec->not();
  28.     $this->assertInstanceof(ISpecification::class, $notSpec);
  29.     $this->assertInstanceof(Specification::class, $notSpec);
  31.     $result = $repository->findAll($notSpec);
  33.     $sql = <<<'eot'
  34.         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)
  35.         eot;
  36.     $this->assertSame(
  37.         $sql,
  38.         $repository->getLastSql(),
  39.     );
  41.     $this->assertInstanceof(Collection::class, $result);
  42.     $this->assertCount(10, $result);
  43. }

or 规约或操作

  1. public function testSpecWithOrFirstIsNo(): void
  2. {
  3.     $connect = $this->createDatabaseConnect();
  5.     for ($i = 0; $i < 10; $i++) {
  6.         $connect
  7.             ->table('post')
  8.             ->insert([
  9.                 'title'     => 'hello world',
  10.                 'user_id'   => 1,
  11.                 'summary'   => 'post summary',
  12.                 'delete_at' => 0,
  13.             ]);
  14.     }
  16.     $request = ['foo' => 'bar', 'hello' => 'world'];
  18.     $repository = new Repository(new Post());
  20.     $spec = new Specification(function (Entity $entity) use ($request) {
  21.         return 'bar_no' === $request['foo'];
  22.     }, function (Select $select, Entity $entity) {
  23.         $select->where('id', '>', 3);
  24.     });
  26.     $orSpec = $spec->or(new Specification(function (Entity $entity) use ($request) {
  27.         return 'world' === $request['hello'];
  28.     }, function (Select $select, Entity $entity) {
  29.         $select->where('id', '<', 8);
  30.     }));
  32.     $this->assertInstanceof(ISpecification::class, $orSpec);
  33.     $this->assertInstanceof(Specification::class, $orSpec);
  35.     $select = $repository->condition($orSpec);
  36.     $result = $select->findAll();
  38.     $sql = <<<'eot'
  39.         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)
  40.         eot;
  41.     $this->assertSame(
  42.         $sql,
  43.         $select->getLastSql(),
  44.     );
  46.     $this->assertInstanceof(Select::class, $select);
  47.     $this->assertInstanceof(Collection::class, $result);
  48.     $this->assertCount(7, $result);
  49. }

make 创建规约表达式

  1. public function testSpecMake(): void
  2. {
  3.     $connect = $this->createDatabaseConnect();
  5.     for ($i = 0; $i < 10; $i++) {
  6.         $connect
  7.             ->table('post')
  8.             ->insert([
  9.                 'title'     => 'hello world',
  10.                 'user_id'   => 1,
  11.                 'summary'   => 'post summary',
  12.                 'delete_at' => 0,
  13.             ]);
  14.     }
  16.     $request = ['foo' => 'bar', 'hello' => 'world'];
  18.     $repository = new Repository(new Post());
  20.     $spec = Specification::make(function (Entity $entity) use ($request) {
  21.         return 'bar' === $request['foo'];
  22.     }, function (Select $select, Entity $entity) {
  23.         $select->where('id', '>', 4);
  24.     });
  26.     $select = $repository->condition($spec);
  27.     $result = $select->findAll();
  29.     $this->assertInstanceof(Select::class, $select);
  30.     $this->assertInstanceof(Collection::class, $result);
  31.     $this->assertCount(6, $result);
  32. }

and 规约与操作

  1. public function testFindCountWithAndFirstIsYes(): void
  2. {
  3.     $connect = $this->createDatabaseConnect();
  5.     for ($i = 0; $i < 10; $i++) {
  6.         $connect
  7.             ->table('post')
  8.             ->insert([
  9.                 'title'     => 'hello world',
  10.                 'user_id'   => 1,
  11.                 'summary'   => 'post summary',
  12.                 'delete_at' => 0,
  13.             ]);
  14.     }
  16.     $request = ['foo' => 'bar', 'hello' => 'world'];
  18.     $repository = new Repository(new Post());
  20.     $specExpr = new Specification(function (Entity $entity) use ($request) {
  21.         return 'bar' === $request['foo'];
  22.     }, function (Select $select, Entity $entity) {
  23.         $select->where('id', '>', 3);
  24.     });
  26.     $specExpr->and(new Specification(function (Entity $entity) use ($request) {
  27.         return 'world' === $request['hello'];
  28.     }, function (Select $select, Entity $entity) {
  29.         $select->where('id', '<', 6);
  30.     }));
  32.     $this->assertInstanceof(ISpecification::class, $specExpr);
  33.     $this->assertInstanceof(Specification::class, $specExpr);
  35.     $result = $repository->findCount($specExpr);
  37.     $this->assertSame(2, $result);
  38. }

__call 魔术方法访问实体查询

  1. public function testCall(): void
  2. {
  3.     $connect = $this->createDatabaseConnect();
  5.     $this->assertSame(
  6.         1,
  7.         $connect
  8.             ->table('post')
  9.             ->insert([
  10.                 'title'     => 'hello world',
  11.                 'user_id'   => 1,
  12.                 'summary'   => 'post summary',
  13.                 'delete_at' => 0,
  14.             ])
  15.     );
  17.     $repository = new Repository(new Post());
  19.     $newPost = $repository
  20.         ->where('id', 5)
  21.         ->findEntity(1);
  23.     $this->assertInstanceof(Post::class, $newPost);
  24.     $this->assertNull($newPost->id);
  25.     $this->assertNull($newPost->userId);
  26.     $this->assertNull($newPost->title);
  27.     $this->assertNull($newPost->summary);
  28. }

createEntity 新增实体

  1. public function testCreateTwice(): void
  2. {
  3.     $repository = new Repository(new Post());
  5.     $repository->createEntity($post = new Post([
  6.         'id'      => 5,
  7.         'title'   => 'foo',
  8.         'user_id' => 0,
  9.     ]));
  11.     $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());
  13.     $this->assertSame(5, $post->id);
  14.     $this->assertSame('foo', $post->title);
  15.     $this->assertSame(0, $post->userId);
  16.     $this->assertSame([], $post->changed());
  17.     $repository->createEntity($post);
  18.     $this->assertSame('SQL: [31] INSERT INTO `post` () VALUES () | Params:  0 (INSERT INTO `post` () VALUES ())', $repository->getLastSql());
  20.     $newPost = $repository->findEntity(5);
  22.     $this->assertInstanceof(Post::class, $newPost);
  23.     $this->assertSame(5, $newPost->id);
  24.     $this->assertSame('foo', $newPost->title);
  26.     $newPost = $repository->findEntity(6);
  28.     $this->assertInstanceof(Post::class, $newPost);
  29.     $this->assertSame(6, $newPost->id);
  30.     $this->assertSame('', $newPost->title);
  31. }

updateEntity 更新实体

  1. public function testUpdateTwiceAndDoNothing(): void
  2. {
  3.     $connect = $this->createDatabaseConnect();
  5.     $this->assertSame(
  6.         1,
  7.         $connect
  8.             ->table('post')
  9.             ->insert([
  10.                 'title'     => 'hello world',
  11.                 'user_id'   => 1,
  12.                 'summary'   => 'post summary',
  13.                 'delete_at' => 0,
  14.             ])
  15.     );
  17.     $repository = new Repository(new Post());
  18.     $this->assertSame(1, $repository->updateEntity($post = new Post(['id' => 1, 'title' => 'new title'])));
  20.     $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());
  21.     $this->assertSame([], $post->changed());
  22.     $this->assertNull($repository->updateEntity($post));
  23. }

replaceEntity 替换实体

  1. public function testReplaceTwiceAndFindExistData(): void
  2. {
  3.     $connect = $this->createDatabaseConnect();
  5.     $this->assertSame(
  6.         1,
  7.         $connect
  8.             ->table('post')
  9.             ->insert([
  10.                 'title'     => 'hello world',
  11.                 'user_id'   => 1,
  12.                 'summary'   => 'post summary',
  13.                 'delete_at' => 0,
  14.             ])
  15.     );
  17.     $repository = new Repository(new Post());
  18.     $affectedRow = $repository->replaceEntity($post = new Post([
  19.         'id'      => 1,
  20.         'title'   => 'new title',
  21.         'user_id' => 1,
  22.     ]));
  23.     $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());
  25.     $this->assertSame(1, $affectedRow);
  26.     $this->assertSame([], $post->changed());
  28.     $repository->replaceEntity($post); // 新增一条数据.
  29.     $this->assertSame('SQL: [31] INSERT INTO `post` () VALUES () | Params:  0 (INSERT INTO `post` () VALUES ())', $repository->getLastSql());
  31.     $updatedPost = $repository->findEntity(1);
  32.     $this->assertSame(1, $updatedPost->id);
  33.     $this->assertSame('new title', $updatedPost->title);
  34.     $this->assertSame(1, $updatedPost->userId);
  35.     $this->assertSame('post summary', $updatedPost->summary);
  37.     $newPost2 = $repository->findEntity(2);
  39.     $this->assertInstanceof(Post::class, $newPost2);
  40.     $this->assertSame(2, $newPost2->id);
  41.     $this->assertSame('', $newPost2->title);
  42.     $this->assertSame('', $newPost2->summary);
  43. }

deleteEntity 响应删除

  1. public function testSoftDeleteTwice(): void
  2. {
  3.     $connect = $this->createDatabaseConnect();
  5.     $this->assertSame(
  6.         1,
  7.         $connect
  8.             ->table('post')
  9.             ->insert([
  10.                 'title'     => 'hello world',
  11.                 'user_id'   => 1,
  12.                 'summary'   => 'post summary',
  13.                 'delete_at' => 0,
  14.             ])
  15.     );
  17.     $repository = new Repository(new Post());
  19.     $repository->deleteEntity($post = new Post(['id' => 1, 'title' => 'new title']));
  20.     $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)';
  21.     $this->assertTrue(in_array($repository->getLastSql(), [
  22.         sprintf($sql, time() - 1),
  23.         sprintf($sql, time()),
  24.         sprintf($sql, time() + 1),
  25.     ], true));
  27.     $repository->deleteEntity($post); // 将会更新 `delete_at` 字段.
  28.     $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)';
  29.     $this->assertTrue(in_array($repository->getLastSql(), [
  30.         sprintf($sql, time() - 1),
  31.         sprintf($sql, time()),
  32.         sprintf($sql, time() + 1),
  33.     ], true));
  35.     $newPost = $repository->findEntity(1);
  37.     $this->assertInstanceof(Post::class, $newPost);
  38.     $this->assertNull($newPost->id);
  39.     $this->assertNull($newPost->userId);
  40.     $this->assertNull($newPost->title);
  41.     $this->assertNull($newPost->summary);
  42. }

forceDeleteEntity 强制删除实体

  1. public function testForceDeleteTwice(): void
  2. {
  3.     $connect = $this->createDatabaseConnect();
  5.     $this->assertSame(
  6.         1,
  7.         $connect
  8.             ->table('post')
  9.             ->insert([
  10.                 'title'     => 'hello world',
  11.                 'user_id'   => 1,
  12.                 'summary'   => 'post summary',
  13.                 'delete_at' => 0,
  14.             ])
  15.     );
  17.     $repository = new Repository(new Post());
  19.     $repository->forceDeleteEntity($post = new Post(['id' => 1, 'title' => 'new title']));
  20.     $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());
  21.     $repository->forceDeleteEntity($post); // 会执行 SQL，因为已经删除，没有任何影响.
  22.     $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());
  23.     $newPost = $repository->findEntity(1);
  25.     $this->assertInstanceof(Post::class, $newPost);
  26.     $this->assertNull($newPost->id);
  27.     $this->assertNull($newPost->userId);
  28.     $this->assertNull($newPost->title);
  29.     $this->assertNull($newPost->summary);
  30. }

condition 条件查询器支持闭包

  1. public function testConditionIsClosure(): void
  2. {
  3.     $connect = $this->createDatabaseConnect();
  5.     for ($i = 0; $i < 10; $i++) {
  6.         $connect
  7.             ->table('post')
  8.             ->insert([
  9.                 'title'     => 'hello world',
  10.                 'user_id'   => 1,
  11.                 'summary'   => 'post summary',
  12.                 'delete_at' => 0,
  13.             ]);
  14.     }
  16.     $request = ['foo' => 'no-bar', 'hello' => 'no-world'];
  18.     $repository = new Repository(new Post());
  20.     $condition = function (Select $select, Entity $entity) use ($request) {
  21.         $select->where('id', '<', 8);
  22.     };
  24.     $select = $repository->condition($condition);
  25.     $result = $select->findAll();
  27.     $this->assertInstanceof(Select::class, $select);
  28.     $this->assertInstanceof(Collection::class, $result);
  29.     $this->assertCount(7, $result);
  30. }

findPage 分页查询

  1. public function testFindPage(): void
  2. {
  3.     $connect = $this->createDatabaseConnect();
  5.     for ($i = 0; $i < 10; $i++) {
  6.         $connect
  7.             ->table('post')
  8.             ->insert([
  9.                 'title'     => 'hello world',
  10.                 'user_id'   => 1,
  11.                 'summary'   => 'post summary',
  12.                 'delete_at' => 0,
  13.             ]);
  14.     }
  16.     $repository = new Repository(new Post());
  18.     $page = $repository->findPage(1, 10);
  19.     $result = $page->getData();
  21.     $this->assertInstanceof(BasePage::class, $page);
  22.     $this->assertInstanceof(Page::class, $page);
  23.     $this->assertInstanceof(Collection::class, $result);
  24.     $this->assertCount(10, $result);
  25. }

findPage 分页查询支持条件过滤

  1. public function testFindPageWithCondition(): void
  2. {
  3.     $connect = $this->createDatabaseConnect();
  5.     for ($i = 0; $i < 10; $i++) {
  6.         $connect
  7.             ->table('post')
  8.             ->insert([
  9.                 'title'     => 'hello world',
  10.                 'user_id'   => 1,
  11.                 'summary'   => 'post summary',
  12.                 'delete_at' => 0,
  13.             ]);
  14.     }
  16.     $request = ['foo' => 'no-bar', 'hello' => 'no-world'];
  18.     $repository = new Repository(new Post());
  20.     $condition = function (Select $select, Entity $entity) use ($request) {
  21.         $select->where('id', '<', 8);
  22.     };
  24.     $page = $repository->findPage(1, 10, $condition);
  25.     $result = $page->getData();
  27.     $this->assertInstanceof(BasePage::class, $page);
  28.     $this->assertInstanceof(Page::class, $page);
  29.     $this->assertInstanceof(Collection::class, $result);
  30.     $this->assertCount(7, $result);
  31. }

findPageMacro 创建一个无限数据的分页查询

  1. public function testFindPageMacro(): void
  2. {
  3.     $connect = $this->createDatabaseConnect();
  5.     for ($i = 0; $i < 10; $i++) {
  6.         $connect
  7.             ->table('post')
  8.             ->insert([
  9.                 'title'     => 'hello world',
  10.                 'user_id'   => 1,
  11.                 'summary'   => 'post summary',
  12.                 'delete_at' => 0,
  13.             ]);
  14.     }
  16.     $repository = new Repository(new Post());
  18.     $page = $repository->findPageMacro(1, 10);
  19.     $result = $page->getData();
  21.     $this->assertInstanceof(BasePage::class, $page);
  22.     $this->assertInstanceof(Page::class, $page);
  23.     $this->assertInstanceof(Collection::class, $result);
  24.     $this->assertCount(10, $result);
  25. }

findPageMacro 创建一个无限数据的分页查询支持条件过滤

  1. public function testFindPageMacroWithCondition(): void
  2. {
  3.     $connect = $this->createDatabaseConnect();
  5.     for ($i = 0; $i < 10; $i++) {
  6.         $connect
  7.             ->table('post')
  8.             ->insert([
  9.                 'title'     => 'hello world',
  10.                 'user_id'   => 1,
  11.                 'summary'   => 'post summary',
  12.                 'delete_at' => 0,
  13.             ]);
  14.     }
  16.     $request = ['foo' => 'no-bar', 'hello' => 'no-world'];
  18.     $repository = new Repository(new Post());
  20.     $condition = function (Select $select, Entity $entity) use ($request) {
  21.         $select->where('id', '<', 8);
  22.     };
  24.     $page = $repository->findPageMacro(1, 10, $condition);
  25.     $result = $page->getData();
  27.     $this->assertInstanceof(BasePage::class, $page);
  28.     $this->assertInstanceof(Page::class, $page);
  29.     $this->assertInstanceof(Collection::class, $result);
  30.     $this->assertCount(7, $result);
  31. }

findPagePrevNext 创建一个只有上下页的分页查询

  1. public function testFindPagePrevNext(): void
  2. {
  3.     $connect = $this->createDatabaseConnect();
  5.     for ($i = 0; $i < 10; $i++) {
  6.         $connect
  7.             ->table('post')
  8.             ->insert([
  9.                 'title'     => 'hello world',
  10.                 'user_id'   => 1,
  11.                 'summary'   => 'post summary',
  12.                 'delete_at' => 0,
  13.             ]);
  14.     }
  16.     $repository = new Repository(new Post());
  18.     $page = $repository->findPagePrevNext(1, 10);
  19.     $result = $page->getData();
  21.     $this->assertInstanceof(BasePage::class, $page);
  22.     $this->assertInstanceof(Page::class, $page);
  23.     $this->assertInstanceof(Collection::class, $result);
  24.     $this->assertCount(10, $result);
  25. }

findPagePrevNext 创建一个只有上下页的分页查询支持条件过滤

  1. public function testFindPagePrevNextWithCondition(): void
  2. {
  3.     $connect = $this->createDatabaseConnect();
  5.     for ($i = 0; $i < 10; $i++) {
  6.         $connect
  7.             ->table('post')
  8.             ->insert([
  9.                 'title'     => 'hello world',
  10.                 'user_id'   => 1,
  11.                 'summary'   => 'post summary',
  12.                 'delete_at' => 0,
  13.             ]);
  14.     }
  16.     $request = ['foo' => 'no-bar', 'hello' => 'no-world'];
  18.     $repository = new Repository(new Post());
  20.     $condition = function (Select $select, Entity $entity) use ($request) {
  21.         $select->where('id', '<', 8);
  22.     };
  24.     $page = $repository->findPagePrevNext(1, 10, $condition);
  25.     $result = $page->getData();
  27.     $this->assertInstanceof(BasePage::class, $page);
  28.     $this->assertInstanceof(Page::class, $page);
  29.     $this->assertInstanceof(Collection::class, $result);
  30.     $this->assertCount(7, $result);
  31. }

findList 返回一列数据

  1. public function testFindList(): void
  2. {
  3.     $connect = $this->createDatabaseConnect();
  5.     for ($i = 0; $i < 10; $i++) {
  6.         $connect
  7.             ->table('post')
  8.             ->insert([
  9.                 'title'     => 'hello world'.$i,
  10.                 'user_id'   => 1,
  11.                 'summary'   => 'post summary',
  12.                 'delete_at' => 0,
  13.             ]);
  14.     }
  16.     $repository = new Repository(new Post());
  18.     $result = $repository->findList(null, 'summary', 'title');
  20.     $this->assertIsArray($result);
  22.     $data = <<<'eot'
  23.         {
  24.             "hello world0": "post summary",
  25.             "hello world1": "post summary",
  26.             "hello world2": "post summary",
  27.             "hello world3": "post summary",
  28.             "hello world4": "post summary",
  29.             "hello world5": "post summary",
  30.             "hello world6": "post summary",
  31.             "hello world7": "post summary",
  32.             "hello world8": "post summary",
  33.             "hello world9": "post summary"
  34.         }
  35.         eot;
  37.     $this->assertSame(
  38.         $data,
  39.         $this->varJson(
  40.             $result
  41.         )
  42.     );
  43. }

findList 返回一列数据支持条件过滤

  1. public function testFindListWithCondition(): void
  2. {
  3.     $connect = $this->createDatabaseConnect();
  5.     for ($i = 0; $i < 10; $i++) {
  6.         $connect
  7.             ->table('post')
  8.             ->insert([
  9.                 'title'     => 'hello world'.$i,
  10.                 'user_id'   => 1,
  11.                 'summary'   => 'post summary',
  12.                 'delete_at' => 0,
  13.             ]);
  14.     }
  16.     $repository = new Repository(new Post());
  18.     $result = $repository->findList(function (Select $select) {
  19.         $select->where('id', '>', 5);
  20.     }, ['summary', 'title']);
  22.     $this->assertIsArray($result);
  24.     $data = <<<'eot'
  25.         {
  26.             "hello world5": "post summary",
  27.             "hello world6": "post summary",
  28.             "hello world7": "post summary",
  29.             "hello world8": "post summary",
  30.             "hello world9": "post summary"
  31.         }
  32.         eot;
  34.     $this->assertSame(
  35.         $data,
  36.         $this->varJson(
  37.             $result
  38.         )
  39.     );
  40. }