* @copyright 2019 Akeneo SAS (http://www.akeneo.com) * @license http://opensource.org/licenses/osl-3.0.php Open Software License (OSL 3.0) */ class DbalConnectionRepository implements ConnectionRepositoryInterface { public function __construct(private DbalConnection $dbalConnection) { } public function create(Connection $connection): void { $insertQuery = <<dbalConnection->executeQuery( $insertQuery, [ 'client_id' => $connection->clientId()->id(), 'user_id' => $connection->userId()->id(), 'code' => (string) $connection->code(), 'label' => (string) $connection->label(), 'flow_type' => (string) $connection->flowType(), 'auditable' => $connection->auditable(), 'type' => (string) $connection->type(), ], [ 'auditable' => Types::BOOLEAN, ] ); } public function findOneByCode(string $code): ?Connection { $selectQuery = <<dbalConnection->executeQuery($selectQuery, ['code' => $code])->fetchAssociative(); return $dataRow ? new Connection( $dataRow['code'], $dataRow['label'], $dataRow['flow_type'], (int) $dataRow['client_id'], (int) $dataRow['user_id'], $dataRow['image'], (bool) $dataRow['auditable'], $dataRow['type'] ) : null; } public function update(Connection $connection): void { $updateQuery = <<dbalConnection->executeQuery( $updateQuery, [ 'code' => (string) $connection->code(), 'label' => (string) $connection->label(), 'flow_type' => (string) $connection->flowType(), 'image' => null !== $connection->image() ? (string) $connection->image() : null, 'auditable' => (bool) $connection->auditable(), ], [ 'auditable' => Types::BOOLEAN, ] ); } public function delete(Connection $connection): void { $deleteQuery = <<dbalConnection->executeQuery( $deleteQuery, [ 'code' => (string) $connection->code(), ] ); } }