55 lines
2.1 KiB
PHP
55 lines
2.1 KiB
PHP
<?php // phpcs:ignore SlevomatCodingStandard.TypeHints.DeclareStrictTypes.DeclareStrictTypesMissing
|
|
|
|
namespace MailPoet\Settings;
|
|
|
|
if (!defined('ABSPATH')) exit;
|
|
|
|
|
|
use MailPoet\Doctrine\Repository;
|
|
use MailPoet\Entities\SettingEntity;
|
|
use MailPoet\WP\Functions as WPFunctions;
|
|
use MailPoetVendor\Carbon\Carbon;
|
|
use MailPoetVendor\Doctrine\ORM\Query;
|
|
|
|
/**
|
|
* @extends Repository<SettingEntity>
|
|
*/
|
|
class SettingsRepository extends Repository {
|
|
public function findOneByName(string $name): ?SettingEntity {
|
|
// Always fetch fresh entity data (= don't use "findOneBy()"). See also further below.
|
|
$result = (array)$this->doctrineRepository->createQueryBuilder('s')
|
|
->where('s.name = :name')
|
|
->setParameter('name', $name)
|
|
->getQuery()
|
|
->setHint(Query::HINT_REFRESH, true)
|
|
->getResult();
|
|
|
|
return isset($result[0]) && $result[0] instanceof SettingEntity ? $result[0] : null;
|
|
}
|
|
|
|
public function createOrUpdateByName($name, $value) {
|
|
// Temporarily use low-level INSERT ... ON DUPLICATE KEY UPDATE query to avoid race conditions
|
|
// between entity fetch and creation with multiple concurrent requests. This will be replaced
|
|
// by a code solving atomicity of create-or-update on entity (ORM) level in a follow-up ticket.
|
|
$now = Carbon::createFromTimestamp(WPFunctions::get()->currentTime('timestamp'));
|
|
$tableName = $this->entityManager->getClassMetadata(SettingEntity::class)->getTableName();
|
|
$this->entityManager->getConnection()->executeStatement("
|
|
INSERT INTO $tableName (name, value, created_at, updated_at)
|
|
VALUES (:name, :value, :now, :now)
|
|
ON DUPLICATE KEY UPDATE value = :value, updated_at = :now
|
|
", [
|
|
'name' => $name,
|
|
'value' => is_array($value) ? serialize($value) : $value,
|
|
'now' => $now,
|
|
]);
|
|
|
|
// Ensure entity data is up-to-date in memory.
|
|
// - We can't use "refresh()"; we don't have the entity instance, and it can be a new record.
|
|
// - We can't use "findOneBy()"; it could return a cached entity instance.
|
|
$this->findOneByName($name);
|
|
}
|
|
|
|
protected function getEntityClassName() {
|
|
return SettingEntity::class;
|
|
}
|
|
}
|