ExecutableQueryObject.php

<?php declare(strict_types = 1);

namespace Contributte\Nextras\Orm\QueryObject;

use Nextras\Dbal\Connection;
use Nextras\Dbal\Result\Result;

abstract class ExecutableQueryObject extends QueryObject
{

	protected Connection $connection;

	public function __construct(Connection $connection)
	{
		$this->connection = $connection;
	}

	/**
	 * @param Result<mixed> $result
	 * @return Result<mixed>
	 */
	public function postResult(Result $result): Result
	{
		return $result;
	}

	/**
	 * @return Result<mixed>
	 */
	public function execute(): Result
	{
		$qb = $this->fetch($this->connection->createQueryBuilder());

		// Execute query
		$result = $this->connection->queryArgs(
			$qb->getQuerySql(),
			$qb->getQueryParameters()
		);

		// Decorate result
		$result = $this->postResult($result);

		return $result;
	}

}