{"id":1125,"date":"2025-06-12T13:35:48","date_gmt":"2025-06-12T05:35:48","guid":{"rendered":"https:\/\/www.zhaozhao123.cn\/php\/php-application-manual\/symfony\/1125.html"},"modified":"2025-06-12T13:35:48","modified_gmt":"2025-06-12T05:35:48","slug":"php-doctrine-upsert%ef%bc%9a%e8%8b%a5%e5%ad%98%e5%9c%a8%e5%88%99%e6%9b%b4%e6%96%b0%ef%bc%8c%e8%8b%a5%e4%b8%8d%e5%ad%98%e5%9c%a8%e5%88%99%e6%8f%92%e5%85%a5","status":"publish","type":"my1js","link":"https:\/\/www.zhaozhao123.cn\/php\/my1js\/1125.html","title":{"rendered":"PHP Doctrine Upsert\uff1a\u82e5\u5b58\u5728\u5219\u66f4\u65b0\uff0c\u82e5\u4e0d\u5b58\u5728\u5219\u63d2\u5165"},"content":{"rendered":"
\r\n
\r\n
\r\n
\r\n
\r\n
\"Bug编译狮\"<\/figure>\r\n\r\n\r\n\r\n

Bug编译狮<\/h2>\r\n<\/div>\r\n<\/div>\r\n<\/div>\r\n\r\n\r\n\r\n
\r\n
\r\n

在 PHP 中使用 Doctrine 进行数据操作时，Upsert<\/code>（即 Update 或 Insert）是一种常见的需求。Doctrine 提供了多种方法来实现这一功能，包括 save<\/code> 方法和 merge<\/code> 方法。以下是这两种方法的示例：<\/p>\n

使用 save<\/code> 方法<\/h3>\n
use DoctrineORMEntityManagerInterface;\nuse DoctrineORMOptimisticLockException;\n\n\/\/ 假设我们有一个名为 'User' 的实体类\nclass User {\n    private $id;\n    private $name;\n\n    \/\/ Getters and Setters\n}\n\n\/\/ 获取 EntityManager 实例\n$entityManager = $this->getDoctrine()->getManager();\n\ntry {\n    \/\/ 创建一个新的用户实例\n    $user = new User();\n    $user->setName('John Doe');\n\n    \/\/ 尝试保存用户，如果用户已经存在，则更新；如果不存在，则插入\n    $entityManager->persist($user);\n    $entityManager->flush();\n\n    echo \"User saved successfully.\";\n} catch (OptimisticLockException $e) {\n    echo \"Optimistic lock exception occurred: \" . $e->getMessage();\n}<\/code><\/pre>\n
使用 merge<\/code> 方法<\/h3>\n
use DoctrineORMEntityManagerInterface;\nuse DoctrineORMOptimisticLockException;\n\n\/\/ 假设我们有一个名为 'User' 的实体类\nclass User {\n    private $id;\n    private $name;\n\n    \/\/ Getters and Setters\n}\n\n\/\/ 获取 EntityManager 实例\n$entityManager = $this->getDoctrine()->getManager();\n\ntry {\n    \/\/ 创建一个新的用户实例\n    $user = new User();\n    $user->setName('John Doe');\n\n    \/\/ 使用 merge 方法尝试保存用户，如果用户已经存在，则更新；如果不存在，则插入\n    $existingUser = $entityManager->getRepository(User::class)->findOneBy(['name' => $user->getName()]);\n    if ($existingUser) {\n        $entityManager->merge($user);\n    } else {\n        $entityManager->persist($user);\n    }\n    $entityManager->flush();\n\n    echo \"User saved successfully.\";\n} catch (OptimisticLockException $e) {\n    echo \"Optimistic lock exception occurred: \" . $e->getMessage();\n}<\/code><\/pre>\n
示例代码<\/h3>\n
假设我们有一个简单的 User<\/code> 表，并且我们希望根据用户名插入或更新用户信息。<\/p>\n
1. 定义实体类<\/h4>\n
use DoctrineORMMapping as ORM;\n\n\/**\n * @ORMEntity(repositoryClass=\"AppRepositoryUserRepository\")\n *\/\nclass User\n{\n    \/**\n     * @ORMId\n     * @ORMGeneratedValue(strategy=\"AUTO\")\n     * @ORMColumn(type=\"integer\")\n     *\/\n    private $id;\n\n    \/**\n     * @ORMColumn(type=\"string\", length=255)\n     *\/\n    private $name;\n\n    \/\/ Getters and Setters\n}<\/code><\/pre>\n
2. 定义 Repository 类<\/h4>\n
namespace AppRepository;\n\nuse DoctrineORMEntityRepository;\n\nclass UserRepository extends EntityRepository\n{\n    public function findByUsername(string $username): ?User\n    {\n        return $this->createQueryBuilder('u')\n            ->where('u.name = :username')\n            ->setParameter('username', $username)\n            ->getQuery()\n            ->getOneOrNullResult();\n    }\n}<\/code><\/pre>\n
3. 使用 save<\/code> 和 merge<\/code> 方法<\/h4>\n
use DoctrineORMEntityManagerInterface;\nuse DoctrineORMOptimisticLockException;\n\n\/\/ 获取 EntityManager 实例\n$entityManager = $this->getDoctrine()->getManager();\n\ntry {\n    \/\/ 创建一个新的用户实例\n    $user = new User();\n    $user->setName('John Doe');\n\n    \/\/ 尝试保存用户，如果用户已经存在，则更新；如果不存在，则插入\n    $entityManager->persist($user);\n    $entityManager->flush();\n\n    echo \"User saved successfully.\";\n} catch (OptimisticLockException $e) {\n    echo \"Optimistic lock exception occurred: \" . $e->getMessage();\n}<\/code><\/pre>\n
通过这些示例，你可以看到如何使用 Doctrine 进行 Upsert<\/code> 操作，以确保在数据库中处理用户的插入或更新逻辑。<\/p>\r\n<\/div>\r\n<\/div>\r\n<\/div>\r\n<\/div>
\r\n
\r\n
\r\n
\r\n
\r\n
\"黑板Bug讲师\"<\/figure>\r\n\r\n\r\n\r\n
黑板Bug讲师<\/h2>\r\n<\/div>\r\n<\/div>\r\n<\/div>\r\n\r\n\r\n\r\n
\r\n
\r\n
概述<\/h2>
有效管理数据库对于应用程序的性能和可扩展性至关重要。在PHP开发领域，Doctrine是一个广泛使用的ORM（对象关系映射），允许开发者通过面向对象的方式与数据库交互。在这篇教程中，我们将深入探讨“upsert”操作——一种既更新已存在的记录，也插入新记录的操作——并介绍如何使用PHP Doctrine实现这一功能。<\/p>
Upsert is a database operation that updates or inserts data into a table. It combines the functionality of both UPDATE and INSERT statements in one query.<\/h3>
“Upsert” 是“update”和“insert”的组合词，用来描述一种数据库操作，该操作会检查记录是否基于唯一约束存在，如果存在，则更新现有记录；否则插入新记录。这种操作在避免重复记录方面非常有用，比单独执行插入和更新操作更高效。<\/p>
先决条件<\/h3>
为了从本教程中获得最大收益，请确保您具备以下条件：<\/p>
在PHP项目中配置的Doctrine环境。<\/p>
当前安装的PHP版本。<\/p>
数据库和SQL的基础知识。<\/p>
对PHP和面向对象编程的理解。<\/p>
直觉主义方法<\/h2>
在我们讨论如何用Doctrine进行upsert操作之前，让我们先了解一下一种简单的方法：<\/p>
<?php\n\n$entity = $entityManager->getRepository('User')->findOneBy(['email' => '[email protected]']);\n\nif ($entity) {\n    $entity->setName('Updated Name');\n    $entityManager->flush();\n} else {\n    $entity = new User();\n    $entity->setName('New Name');\n    $entity->setEmail('[email protected]');\n    $entityManager->persist($entity);\n    $entityManager->flush();\n}\n<\/code><\/pre>
该代码检查给定的电子邮件是否已存在，如果存在则更新名称，否则创建一个新的User实体并将其持久化到数据库中。<\/p>
Doctrine的Upsert操作<\/h2>
与手动检查实体的存在不同，Doctrine 提供了一种更优雅的方法。EntityManager<\/code>类的方法（methods）persist()<\/code>and 是“并且”的意思。flush()<\/code>可以一起使用来实现更新或插入操作（upsert）。<\/p>
然而，Doctrine 没有专门的 upsert 方法，所以我们需要利用 Doctrine 提供的唯一约束系统来确保在插入或更新时不会重复记录。flush()<\/code>当调用方法时，MySQL（或其他支持的数据库平台）会知道需要执行INSERT或UPDATE操作。<\/p>
首先，你需要确保实体有一个唯一的约束条件。为此，需要修改你的实体类。让我们考虑一个名为“用户”的实体，其唯一字段为“电子邮件”：<\/p>
<?php\n\nuse DoctrineORMMapping as ORM;\n\n\/**\n * @ORMEntity\n * @ORMUniqueConstraint(name=\"email_idx\", columns={\"email\"})\n *\/\nclass User\n{\n    \/\/ ...\n}\n?>\n<\/code><\/pre>
现在你已经设置了独特的约束，一个简单的persist()<\/code>and 是“并且”的意思。flush()<\/code>足够了：<\/p>
<?php\n\nuse DoctrineORMExceptionUniqueConstraintViolationException;\n\n$user = new User();\n$user->setName('John Doe');\n$user->setEmail('[email protected]');\n$entityManager->persist($user);\n\ntry {\n    $entityManager->flush();\n} catch (UniqueConstraintViolationException $e) {\n    \/\/ Handle exception: record already exists\n}\n<\/code><\/pre>
上述块将执行更新或插入操作。如果用户邮箱为 ‘[email protected]’ 的用户已经存在，Doctrine 会抛出异常。UniqueConstraintViolationException<\/code>你可以捕获这个异常并决定如何更新现有的记录。<\/p>
处理UniqueConstraintViolationException异常的情况。<\/h2>
当捕获异常时，你可以找到现有的实体并进行更新。这是一个例子：<\/p>
<?php\n\nuse DoctrineORMExceptionUniqueConstraintViolationException;\n\n\/\/ ... try\/catch block from previous sample ...\ncatch (UniqueConstraintViolationException $e) {\n    $existingUser = $entityManager->getRepository('User')->findOneBy(['email' => '[email protected]']);\n    if ($existingUser) {\n        $existingUser->setName('John Doe Updated');\n        $entityManager->flush();\n    }\n}\n<\/code><\/pre>
使用Doctrine的查询构建器进行更新和插入操作（Upsert）<\/h2>
另一种选择是使用Doctrine的查询构建器来编写一个类似于upsert的操作。以下是一种实现方式：<\/p>
<?php\n\nuse DoctrineDBALException;\n\n$qb = $entityManager->getConnection()->createQueryBuilder();\n\n$result = $qb\n    ->insert('User')\n    ->values([\n        'name' => ':name',\n        'email' => ':email'\n    ])\n    ->setParameter('name', 'John Doe')\n    ->setParameter('email', '[email protected]')\n    ->getSQL();\n\ntry {\n    $entityManager->getConnection()->executeStatement($result);\n} catch (Exception $e) {\n    \/\/ Handle exception: record already exists\n}\n<\/code><\/pre>
在这种情况下，您尝试向用户表中插入一条记录。如果该电子邮件已存在，则会抛出异常，指示在唯一字段 ’email’ 上重复的条目。然后，您可以捕获这个异常并相应地执行更新操作。<\/p>
结论<\/h2>
执行Doctrine中的更新或插入操作时，需要处理一些关于唯一约束的问题，但按照上述模式进行操作，你可以保持数据库交互的高效和有效。利用Doctrine的ORM功能确保数据的一致性，并避免重复且冗余的SQL查询编写。随着对Doctrine特性的熟悉程度增加，你可能会发现更多适合应用需求的优雅模式。<\/p>
记得，使用数据库和ORM不仅仅是了解可用的工具，更是理解应用需求。高效地使用upsert操作只是构建可维护、扩展性强的PHP与Doctrine应用程序的一部分大图。<\/p><\/body>\r\n<\/div>\r\n<\/div>\r\n<\/div>\r\n<\/div>
\r\n
\r\n
\r\n
\r\n
\r\n
\"长工码奴1523\"<\/figure>\r\n\r\n\r\n\r\n
长工码奴1523<\/h2>\r\n<\/div>\r\n<\/div>\r\n<\/div>\r\n\r\n\r\n\r\n
\r\n
\r\n
<?php<\/p>\n
\/\/ 1. 创建实体类\nclass User extends DoctrineORMEntity\n{\n\/\/ 设置主键类型为自增\npublic $id;<\/p>\n
\/\/ 用户名字段\npublic $username;\n\n\/\/ 密码字段\npublic $password;<\/code><\/pre>\n
}<\/p>\n
\/\/ 2. 创建数据库连接配置\n$connection = new PDO(‘mysql:host=localhost;dbname=example’, ‘username’, ‘password’);<\/p>\n
\/\/ 3. 创建ORM操作对象\n$userManager = new UserManager($connection);<\/p>\n
\/\/ 4. 实现Upsert功能\n$userManager->upsert(new User, [‘username’ => ‘john’]);<\/p>\n
\/\/ 打印结果\nvar_dump($userManager->getUsers());<\/p>\n
?><\/p>\n
在这个例子中，我们首先定义了一个名为User<\/code>的实体类，它继承了DoctrineORMEntity<\/code>。然后，我们创建了一个新的数据库连接并使用ORM（对象关系映射）来操作数据。<\/p>\n
接着，我们在ORM操作对象上实现了upsert<\/code>方法。这个方法接收两个参数：一个是实体类实例和另一个是SQL查询字符串。根据提供的参数，upsert<\/code>方法将决定是更新还是插入新记录。<\/p>\n
最后，我们打印出用户列表，可以看到我们的实体已经成功地被插入到数据库中。<\/p>\r\n<\/div>\r\n<\/div>\r\n<\/div>\r\n<\/div>\n","protected":false},"excerpt":{"rendered":"
Bug编译狮 在 PHP 中使用 Doctrine 进行数据操作时，Upsert（&#21363..<\/p>\n","protected":false},"author":1,"featured_media":0,"menu_order":0,"template":"","meta":{"_acf_changed":false},"tags":[],"my1js2nav":[45],"tuisongtax":[],"class_list":["post-1125","my1js","type-my1js","status-publish","hentry","my1js2nav-symfony"],"acf":{"qian_art_seotitle":"","qian_art_seotitle_source":{"label":"SEO\u6807\u9898","type":"text","formatted_value":""},"qian_art_seokws":"","qian_art_seokws_source":{"label":"SEO\u5173\u952e\u8bcd","type":"text","formatted_value":""},"qian_art_stzhong":"","qian_art_stzhong_source":{"label":"\u4e2d | \u77ed\u6807\u9898","type":"text","formatted_value":""}},"_links":{"self":[{"href":"https:\/\/www.zhaozhao123.cn\/php\/wp-json\/wp\/v2\/my1js\/1125","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/www.zhaozhao123.cn\/php\/wp-json\/wp\/v2\/my1js"}],"about":[{"href":"https:\/\/www.zhaozhao123.cn\/php\/wp-json\/wp\/v2\/types\/my1js"}],"author":[{"embeddable":true,"href":"https:\/\/www.zhaozhao123.cn\/php\/wp-json\/wp\/v2\/users\/1"}],"wp:attachment":[{"href":"https:\/\/www.zhaozhao123.cn\/php\/wp-json\/wp\/v2\/media?parent=1125"}],"wp:term":[{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/www.zhaozhao123.cn\/php\/wp-json\/wp\/v2\/tags?post=1125"},{"taxonomy":"my1js2nav","embeddable":true,"href":"https:\/\/www.zhaozhao123.cn\/php\/wp-json\/wp\/v2\/my1js2nav?post=1125"},{"taxonomy":"tuisongtax","embeddable":true,"href":"https:\/\/www.zhaozhao123.cn\/php\/wp-json\/wp\/v2\/tuisongtax?post=1125"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}