Add Sql prefix to all classes

Author: trowski

src/Connection.php

@@ -0,0 +1,31 @@
+<?php declare(strict_types=1);
+
+namespace Amp\Sql;
+
+/**
+ * @template TConfig of SqlConfig
+ * @template TResult of SqlResult
+ * @template TStatement of SqlStatement<TResult>
+ * @template TTransaction of SqlTransaction
+ *
+ * @extends SqlLink<TResult, TStatement, TTransaction>
+ */
+interface SqlConnection extends SqlLink
+{
+    /**
+     * @return TConfig The configuration used to create this connection.
+     */
+    public function getConfig(): SqlConfig;
+
+    /**
+     * @return SqlTransactionIsolation Current transaction isolation used when beginning transactions on this connection.
+     */
+    public function getTransactionIsolation(): SqlTransactionIsolation;
+
+    /**
+     * Sets the transaction isolation level for transactions began on this link.
+     *
+     * @see SqlLink::beginTransaction()
+     */
+    public function setTransactionIsolation(SqlTransactionIsolation $isolation): void;
+}

src/Executor.php

@@ -2,6 +2,6 @@
 
 namespace Amp\Sql;
 
-class ConnectionException extends SqlException
+class SqlConnectionException extends SqlException
 {
 }

src/Link.php

@@ -4,21 +4,21 @@
 
 /**
  * @template TConfig of SqlConfig
- * @template TResult of Result
- * @template TStatement of Statement<TResult>
- * @template TTransaction of Transaction
+ * @template TResult of SqlResult
+ * @template TStatement of SqlStatement<TResult>
+ * @template TTransaction of SqlTransaction
  *
- * @extends Connection<TConfig, TResult, TStatement, TTransaction>
+ * @extends SqlConnection<TConfig, TResult, TStatement, TTransaction>
  */
-interface Pool extends Connection
+interface SqlConnectionPool extends SqlConnection
 {
     /**
      * Gets a single connection from the pool to run a set of queries against a single connection.
      * Generally a transaction should be used instead of this method.
      *
-     * @return Connection<TConfig, TResult, TStatement, TTransaction>
+     * @return SqlConnection<TConfig, TResult, TStatement, TTransaction>
      */
-    public function extractConnection(): Connection;
+    public function extractConnection(): SqlConnection;
 
     /**
      * @return int Total number of active connections in the pool.

src/SqlConnection.php

@@ -6,7 +6,7 @@
 
 /**
  * @template TConfig of SqlConfig
- * @template TConnection of Connection
+ * @template TConnection of SqlConnection
  */
 interface SqlConnector
 {
@@ -18,7 +18,7 @@ interface SqlConnector
      *
      * @return TConnection
      *
-     * @throws ConnectionException
+     * @throws SqlConnectionException
      */
-    public function connect(SqlConfig $config, ?Cancellation $cancellation = null): Connection;
+    public function connect(SqlConfig $config, ?Cancellation $cancellation = null): SqlConnection;
 }

src/ConnectionException.php src/SqlConnectionException.phpsrc/ConnectionException.php renamed to src/SqlConnectionException.php

@@ -0,0 +1,44 @@
+<?php declare(strict_types=1);
+
+namespace Amp\Sql;
+
+/**
+ * @template TResult of SqlResult
+ * @template TStatement of SqlStatement
+ */
+interface SqlExecutor extends SqlTransientResource
+{
+    /**
+     * @param string $sql SQL query to execute.
+     *
+     * @return TResult
+     *
+     * @throws SqlException If the operation fails due to unexpected condition.
+     * @throws SqlConnectionException If the connection to the database is lost.
+     * @throws SqlQueryError If the operation fails due to an error in the query (such as a syntax error).
+     */
+    public function query(string $sql): SqlResult;
+
+    /**
+     * @param string $sql SQL query to prepare.
+     *
+     * @return TStatement
+     *
+     * @throws SqlException If the operation fails due to unexpected condition.
+     * @throws SqlConnectionException If the connection to the database is lost.
+     * @throws SqlQueryError If the operation fails due to an error in the query (such as a syntax error).
+     */
+    public function prepare(string $sql): SqlStatement;
+
+    /**
+     * @param string $sql SQL query to prepare and execute.
+     * @param array<int, mixed>|array<string, mixed> $params Query parameters.
+     *
+     * @return TResult
+     *
+     * @throws SqlException If the operation fails due to unexpected condition.
+     * @throws SqlConnectionException If the connection to the database is lost.
+     * @throws SqlQueryError If the operation fails due to an error in the query (such as a syntax error).
+     */
+    public function execute(string $sql, array $params = []): SqlResult;
+}

src/Pool.php src/SqlConnectionPool.phpsrc/Pool.php renamed to src/SqlConnectionPool.php

@@ -0,0 +1,20 @@
+<?php declare(strict_types=1);
+
+namespace Amp\Sql;
+
+/**
+ * @template TResult of SqlResult
+ * @template TStatement of SqlStatement<TResult>
+ * @template TTransaction of SqlTransaction
+ *
+ * @extends SqlExecutor<TResult, TStatement>
+ */
+interface SqlLink extends SqlExecutor
+{
+    /**
+     * Starts a transaction, returning an object where all queries are executed on a single connection.
+     *
+     * @return TTransaction
+     */
+    public function beginTransaction(): SqlTransaction;
+}

src/SqlConnector.php

@@ -2,7 +2,7 @@
 
 namespace Amp\Sql;
 
-class QueryError extends \Error
+class SqlQueryError extends \Error
 {
     public function __construct(
         string $message,