替换实体

Testing Is Documentation

tests/Database/Ddd/Replace/ReplaceTest.php替换实体 - 图1

替换实体，将实体变更持久化到数据库。

Uses

  1. <?php
  3. use Leevel\Database\Ddd\Entity;
  4. use Tests\Database\DatabaseTestCase as TestCase;
  5. use Tests\Database\Ddd\Entity\CompositeId;
  6. use Tests\Database\Ddd\Entity\DemoEntity;

replace 替换实体

完整例子

  1. $entity = new DemoEntity(['id' => 1]);
  2. $entity->name = 'foo';
  3. $entity->replace()->flush();

调用 replace 方法并没有立刻真正持久化到数据库，这一个步骤计算好了待保存的数据。

完整模型

  1. namespace Tests\Database\Ddd\Entity;
  3. use Leevel\Database\Ddd\Entity;
  4. use Leevel\Database\Ddd\GetterSetter;
  6. class DemoEntity extends Entity
  7. {
  8.     use GetterSetter;
  10.     const TABLE = 'test';
  12.     const ID = 'id';
  14.     const AUTO = 'id';
  16.     const STRUCT = [
  17.         'id' => [
  18.             self::READONLY => true,
  19.         ],
  20.         'name' => [],
  21.     ];
  22. }
  1. public function testBaseUse(): void
  2. {
  3.     $entity = new DemoEntity(['id' => 1]);
  4.     $entity->name = 'foo';
  6.     $this->assertInstanceof(Entity::class, $entity);
  7.     $this->assertSame(1, $entity->id);
  8.     $this->assertSame('foo', $entity->name);
  9.     $this->assertSame(['id', 'name'], $entity->changed());
  10.     $this->assertNull($entity->flushData());
  11.     $entity->replace();
  13.     $data = <<<'eot'
  14.         [
  15.             {
  16.                 "id": 1,
  17.                 "name": "foo"
  18.             }
  19.         ]
  20.         eot;
  22.     $this->assertSame(
  23.         $data,
  24.         $this->varJson(
  25.             $entity->flushData()
  26.         )
  27.     );
  29.     $this->assertSame(1, $entity->flush());
  30.     $sql = 'SQL: [101] INSERT INTO `test` (`test`.`id`,`test`.`name`) VALUES (:pdonamedparameter_id,:pdonamedparameter_name) | Params:  2 | Key: Name: [21] :pdonamedparameter_id | paramno=0 | name=[21] ":pdonamedparameter_id" | is_param=1 | param_type=1 | Key: Name: [23] :pdonamedparameter_name | paramno=1 | name=[23] ":pdonamedparameter_name" | is_param=1 | param_type=2 (INSERT INTO `test` (`test`.`id`,`test`.`name`) VALUES (1,\'foo\'))';
  31.     $this->assertSame($sql, $entity->select()->getLastSql());
  32.     $entity->refresh();
  33.     $sql = 'SQL: [64] SELECT `test`.* FROM `test` WHERE `test`.`id` = :test_id LIMIT 1 | Params:  1 | Key: Name: [8] :test_id | paramno=0 | name=[8] ":test_id" | is_param=1 | param_type=1 (SELECT `test`.* FROM `test` WHERE `test`.`id` = 1 LIMIT 1)';
  34.     $this->assertSame($sql, $entity->select()->getLastSql());
  35.     $this->assertSame(1, $entity->id);
  36.     $this->assertSame('foo', $entity->name);
  37. }

TIP

通过 replace 方法替换一个实体，并通过 flush 将实体持久化到数据库。

replace 替换实体新增例子

  1. public function testReplaceBaseUseCreate(): void
  2. {
  3.     $entity = new DemoEntity(['id' => 1]);
  4.     $entity->name = 'foo';
  6.     $this->assertInstanceof(Entity::class, $entity);
  7.     $this->assertSame(1, $entity->id);
  8.     $this->assertSame('foo', $entity->name);
  9.     $this->assertSame(['id', 'name'], $entity->changed());
  10.     $this->assertNull($entity->flushData());
  11.     $entity->replace();
  13.     $data = <<<'eot'
  14.         [
  15.             {
  16.                 "id": 1,
  17.                 "name": "foo"
  18.             }
  19.         ]
  20.         eot;
  22.     $this->assertSame(
  23.         $data,
  24.         $this->varJson(
  25.             $entity->flushData()
  26.         )
  27.     );
  29.     $this->assertSame(1, $entity->flush());
  30.     $sql = 'SQL: [101] INSERT INTO `test` (`test`.`id`,`test`.`name`) VALUES (:pdonamedparameter_id,:pdonamedparameter_name) | Params:  2 | Key: Name: [21] :pdonamedparameter_id | paramno=0 | name=[21] ":pdonamedparameter_id" | is_param=1 | param_type=1 | Key: Name: [23] :pdonamedparameter_name | paramno=1 | name=[23] ":pdonamedparameter_name" | is_param=1 | param_type=2 (INSERT INTO `test` (`test`.`id`,`test`.`name`) VALUES (1,\'foo\'))';
  31.     $this->assertSame($sql, $entity->select()->getLastSql());
  32.     $entity->refresh();
  33.     $sql = 'SQL: [64] SELECT `test`.* FROM `test` WHERE `test`.`id` = :test_id LIMIT 1 | Params:  1 | Key: Name: [8] :test_id | paramno=0 | name=[8] ":test_id" | is_param=1 | param_type=1 (SELECT `test`.* FROM `test` WHERE `test`.`id` = 1 LIMIT 1)';
  34.     $this->assertSame($sql, $entity->select()->getLastSql());
  35.     $this->assertSame(1, $entity->id);
  36.     $this->assertSame('foo', $entity->name);
  37. }

replace.condition 替换实体配合设置扩展查询条件新增例子

replace 新增例子，设置扩展查询条件没有任何作用。

  1. public function testReplaceBaseUseCreateWithCondition(): void
  2. {
  3.     $entity = new DemoEntity(['id' => 1]);
  4.     $entity->name = 'foo';
  6.     $this->assertInstanceof(Entity::class, $entity);
  7.     $this->assertSame(1, $entity->id);
  8.     $this->assertSame('foo', $entity->name);
  9.     $this->assertSame(['id', 'name'], $entity->changed());
  10.     $this->assertNull($entity->flushData());
  11.     $entity->condition(['name' => 'hello'])->replace();
  13.     $data = <<<'eot'
  14.         [
  15.             {
  16.                 "id": 1,
  17.                 "name": "foo"
  18.             }
  19.         ]
  20.         eot;
  22.     $this->assertSame(
  23.         $data,
  24.         $this->varJson(
  25.             $entity->flushData()
  26.         )
  27.     );
  29.     $this->assertSame(1, $entity->flush());
  30.     $sql = 'SQL: [101] INSERT INTO `test` (`test`.`id`,`test`.`name`) VALUES (:pdonamedparameter_id,:pdonamedparameter_name) | Params:  2 | Key: Name: [21] :pdonamedparameter_id | paramno=0 | name=[21] ":pdonamedparameter_id" | is_param=1 | param_type=1 | Key: Name: [23] :pdonamedparameter_name | paramno=1 | name=[23] ":pdonamedparameter_name" | is_param=1 | param_type=2 (INSERT INTO `test` (`test`.`id`,`test`.`name`) VALUES (1,\'foo\'))';
  31.     $this->assertSame($sql, $entity->select()->getLastSql());
  32.     $entity->refresh();
  33.     $sql = 'SQL: [64] SELECT `test`.* FROM `test` WHERE `test`.`id` = :test_id LIMIT 1 | Params:  1 | Key: Name: [8] :test_id | paramno=0 | name=[8] ":test_id" | is_param=1 | param_type=1 (SELECT `test`.* FROM `test` WHERE `test`.`id` = 1 LIMIT 1)';
  34.     $this->assertSame($sql, $entity->select()->getLastSql());
  35.     $this->assertSame(1, $entity->id);
  36.     $this->assertSame('foo', $entity->name);
  37. }

replace 替换实体更新例子

  1. public function testReplaceBaseUseUpdate(): void
  2. {
  3.     $connect = $this->createDatabaseConnect();
  4.     $this->assertSame(
  5.         1,
  6.         $connect
  7.             ->table('test')
  8.             ->insert([
  9.                 'id'       => 1,
  10.                 'name'     => 'old',
  11.             ])
  12.     );
  14.     $entity = new DemoEntity(['id' => 1]);
  15.     $entity->name = 'foo';
  17.     $this->assertInstanceof(Entity::class, $entity);
  18.     $this->assertSame(1, $entity->id);
  19.     $this->assertSame('foo', $entity->name);
  20.     $this->assertSame(['id', 'name'], $entity->changed());
  21.     $this->assertNull($entity->flushData());
  22.     $entity->replace();
  24.     $data = <<<'eot'
  25.         [
  26.             {
  27.                 "id": 1,
  28.                 "name": "foo"
  29.             }
  30.         ]
  31.         eot;
  33.     $this->assertSame(
  34.         $data,
  35.         $this->varJson(
  36.             $entity->flushData()
  37.         )
  38.     );
  40.     $this->assertSame(1, $entity->flush());
  41.     $sql = 'SQL: [94] UPDATE `test` SET `test`.`name` = :pdonamedparameter_name WHERE `test`.`id` = :test_id LIMIT 1 | Params:  2 | Key: Name: [23] :pdonamedparameter_name | paramno=0 | name=[23] ":pdonamedparameter_name" | is_param=1 | param_type=2 | Key: Name: [8] :test_id | paramno=1 | name=[8] ":test_id" | is_param=1 | param_type=1 (UPDATE `test` SET `test`.`name` = \'foo\' WHERE `test`.`id` = 1 LIMIT 1)';
  42.     $this->assertSame($sql, $entity->select()->getLastSql());
  43.     $entity->refresh();
  44.     $sql = 'SQL: [64] SELECT `test`.* FROM `test` WHERE `test`.`id` = :test_id LIMIT 1 | Params:  1 | Key: Name: [8] :test_id | paramno=0 | name=[8] ":test_id" | is_param=1 | param_type=1 (SELECT `test`.* FROM `test` WHERE `test`.`id` = 1 LIMIT 1)';
  45.     $this->assertSame($sql, $entity->select()->getLastSql());
  46.     $this->assertSame(1, $entity->id);
  47.     $this->assertSame('foo', $entity->name);
  48. }

replace.condition 替换实体配合设置扩展查询条件更新例子

replace 更新例子，设置扩展查询条件影响更新查询条件。

  1. public function testReplaceBaseUseUpdateWithCondition(): void
  2. {
  3.     $connect = $this->createDatabaseConnect();
  4.     $this->assertSame(
  5.         1,
  6.         $connect
  7.             ->table('test')
  8.             ->insert([
  9.                 'id'       => 1,
  10.                 'name'     => 'old',
  11.             ])
  12.     );
  14.     $entity = new DemoEntity(['id' => 1]);
  15.     $entity->name = 'foo';
  17.     $this->assertInstanceof(Entity::class, $entity);
  18.     $this->assertSame(1, $entity->id);
  19.     $this->assertSame('foo', $entity->name);
  20.     $this->assertSame(['id', 'name'], $entity->changed());
  21.     $this->assertNull($entity->flushData());
  22.     $entity->condition(['name' => 'hello'])->replace();
  24.     $data = <<<'eot'
  25.         [
  26.             {
  27.                 "id": 1,
  28.                 "name": "foo"
  29.             }
  30.         ]
  31.         eot;
  33.     $this->assertSame(
  34.         $data,
  35.         $this->varJson(
  36.             $entity->flushData()
  37.         )
  38.     );
  40.     $this->assertSame(0, $entity->flush());
  41.     $sql = 'SQL: [125] UPDATE `test` SET `test`.`name` = :pdonamedparameter_name WHERE `test`.`name` = :test_name AND `test`.`id` = :test_id LIMIT 1 | Params:  3 | Key: Name: [23] :pdonamedparameter_name | paramno=0 | name=[23] ":pdonamedparameter_name" | is_param=1 | param_type=2 | Key: Name: [10] :test_name | paramno=1 | name=[10] ":test_name" | is_param=1 | param_type=2 | Key: Name: [8] :test_id | paramno=2 | name=[8] ":test_id" | is_param=1 | param_type=1 (UPDATE `test` SET `test`.`name` = \'foo\' WHERE `test`.`name` = \'hello\' AND `test`.`id` = 1 LIMIT 1)';
  42.     $this->assertSame($sql, $entity->select()->getLastSql());
  43.     $entity->refresh();
  44.     $sql = 'SQL: [64] SELECT `test`.* FROM `test` WHERE `test`.`id` = :test_id LIMIT 1 | Params:  1 | Key: Name: [8] :test_id | paramno=0 | name=[8] ":test_id" | is_param=1 | param_type=1 (SELECT `test`.* FROM `test` WHERE `test`.`id` = 1 LIMIT 1)';
  45.     $this->assertSame($sql, $entity->select()->getLastSql());
  46.     $this->assertSame(1, $entity->id);
  47.     $this->assertSame('old', $entity->name);
  48. }

replace 替换快捷方式，记录存在但是不存在更新数据不作任何处理

这里和单纯的更新不一样，单纯的更新不存在更新数据，则会抛出异常。

  1. public function testReplaceWithCompositeIdButNoDataToBeUpdate(): void
  2. {
  3.     $connect = $this->createDatabaseConnect();
  4.     $this->assertSame(
  5.         1,
  6.         $connect
  7.             ->table('composite_id')
  8.             ->insert([
  9.                 'id1'     => 2,
  10.                 'id2'     => 3,
  11.             ])
  12.     );
  14.     $entity = new CompositeId();
  15.     $entity->replace(['id1' => 2, 'id2' => 3]);
  17.     $data = <<<'eot'
  18.         [
  19.             {
  20.                 "id1": 2,
  21.                 "id2": 3
  22.             }
  23.         ]
  24.         eot;
  26.     $this->assertSame(
  27.         $data,
  28.         $this->varJson(
  29.             $entity->flushData()
  30.         )
  31.     );
  33.     $entity->flush();
  35.     $sql = '[FAILED] SQL: [125] INSERT INTO `composite_id` (`composite_id`.`id1`,`composite_id`.`id2`) VALUES (:pdonamedparameter_id1,:pdonamedparameter_id2) | Params:  2 | Key: Name: [22] :pdonamedparameter_id1 | paramno=0 | name=[22] ":pdonamedparameter_id1" | is_param=1 | param_type=1 | Key: Name: [22] :pdonamedparameter_id2 | paramno=1 | name=[22] ":pdonamedparameter_id2" | is_param=1 | param_type=1 (INSERT INTO `composite_id` (`composite_id`.`id1`,`composite_id`.`id2`) VALUES (2,3))';
  36.     $this->assertSame($sql, $entity->select()->getLastSql());
  37. }