EmptyResult WIP

src/Dibi/Connection.php

@@ -189,7 +189,7 @@ final public function getDriver(): Driver
 	 * @param  mixed  ...$args
 	 * @throws Exception
 	 */
-	final public function query(...$args): ?Result
+	final public function query(...$args): Result
 	{
 		return $this->nativeQuery($this->translateArgs($args));
 	}
@@ -258,7 +258,7 @@ protected function translateArgs(array $args): string
 	 * Executes the SQL query.
 	 * @throws Exception
 	 */
-	final public function nativeQuery(string $sql): ?Result
+	final public function nativeQuery(string $sql): Result
 	{
 		if (!$this->driver) {
 			$this->connect();
@@ -276,7 +276,7 @@ final public function nativeQuery(string $sql): ?Result
 			throw $e;
 		}
 
-		$res = $res ? $this->createResultSet($res) : null;
+		$res = $this->createResultSet($res ?: new Drivers\EmptyResult(max(0, $this->driver->getAffectedRows())));
 		if ($event) {
 			$this->onEvent($event->done($res));
 		}

src/Dibi/Drivers/EmptyResult.php

@@ -0,0 +1,74 @@
+<?php
+
+/**
+ * This file is part of the "dibi" - smart database abstraction layer.
+ * Copyright (c) 2005 David Grudl (https://davidgrudl.com)
+ */
+
+declare(strict_types=1);
+
+namespace Dibi\Drivers;
+
+use Dibi;
+
+
+/**
+ * The dibi driver for empty result set.
+ */
+class EmptyResult implements Dibi\ResultDriver
+{
+	use Dibi\Strict;
+
+	/** @var int */
+	private $rows;
+
+
+	public function __construct(int $rows)
+	{
+		$this->rows = $rows;
+	}
+
+
+	/**
+	 * Returns the number of affected rows.
+	 */
+	public function getRowCount(): int
+	{
+		return $this->rows;
+	}
+
+
+	public function fetch(bool $assoc): ?array
+	{
+		return null;
+	}
+
+
+	public function seek(int $row): bool
+	{
+		return false;
+	}
+
+
+	public function free(): void
+	{
+	}
+
+
+	public function getResultColumns(): array
+	{
+		return [];
+	}
+
+
+	public function getResultResource()
+	{
+		return null;
+	}
+
+
+	public function unescapeBinary(string $value): string
+	{
+		return $value;
+	}
+}

src/Dibi/Fluent.php

@@ -380,7 +380,7 @@ public function count(): int
 	}
 
 
-	private function query($args): ?Result
+	private function query($args): Result
 	{
 		$res = $this->connection->query($args);
 		foreach ($this->setups as $setup) {

src/Dibi/dibi.php

@@ -13,8 +13,8 @@
  * store connections info.
  *
  * @method void disconnect()
- * @method Dibi\Result|null query(...$args)
- * @method Dibi\Result|null nativeQuery(...$args)
+ * @method Dibi\Result query(...$args)
+ * @method Dibi\Result nativeQuery(...$args)
  * @method bool test(...$args)
  * @method Dibi\DataSource dataSource(...$args)
  * @method Dibi\Row|null fetch(...$args)

src/Dibi/interfaces.php

@@ -216,7 +216,7 @@ function getDriver(): Driver;
 	 * Generates (translates) and executes SQL query.
 	 * @throws Exception
 	 */
-	function query(...$args): ?Result;
+	function query(...$args): Result;
 
 	/**
 	 * Gets the number of affected rows by the last INSERT, UPDATE or DELETE query.

tests/dibi/Fluent.fetch.phpt

@@ -54,5 +54,6 @@ if (!in_array($config['system'], ['odbc', 'sqlsrv'], true)) {
 
 // affected rows
 $res = $conn->update('products', ['title' => 'new'])->execute();
-Assert::null($res);
+Assert::same(3, $res->getRowCount());
+Assert::same(0, $res->getColumnCount());
 Assert::same(3, $conn->getAffectedRows());