diff --git a/composer.json b/composer.json
index e415bf2..af00d84 100644
--- a/composer.json
+++ b/composer.json
@@ -17,7 +17,7 @@
     },
     "autoload": {
         "psr-4": {
-            "ProVM\\": "src/"
+            "Database\\": "src/"
         }
     }
 }
diff --git a/src/Concept/Database/Connection.php b/src/Concept/Database/Connection.php
deleted file mode 100644
index 705400d..0000000
--- a/src/Concept/Database/Connection.php
+++ /dev/null
@@ -1,15 +0,0 @@
-<?php
-namespace ProVM\Concept\Database;
-
-use ProVM\Concept\Database;
-
-interface Connection
-{
-    public function connect(): \PDO;
-
-    public function transaction(): Transaction;
-
-    public function query(string $query): ResultSet;
-    public function prepare(string $query): ResultSet;
-    public function execute(string $query, ?array $data = null): ResultSet;
-}
diff --git a/src/Database/Connection.php b/src/Database/Connection.php
deleted file mode 100644
index ab67de3..0000000
--- a/src/Database/Connection.php
+++ /dev/null
@@ -1,86 +0,0 @@
-<?php
-namespace ProVM\Database;
-
-use PDO;
-use ProVM\Concept\Database;
-use ProVM\Exception\Database\InvalidQuery;
-
-class Connection implements Database\Connection
-{
-    public function __construct(Database $database)
-    {
-        $this->setDatabase($database);
-    }
-
-    protected Database $database;
-
-    protected function getDatabase(): Database
-    {
-        return $this->database;
-    }
-
-    protected function setDatabase(Database $database): Database\Connection
-    {
-        $this->database = $database;
-        return $this;
-    }
-
-    protected PDO $pdo;
-    public function connect(): PDO
-    {
-        if (!isset($this->pdo)) {
-            $dsn = $this->getDatabase()->getDsn();
-            if ($this->getDatabase()->needsUser()) {
-                $this->pdo = new PDO($dsn, $this->getDatabase()->getUser(), $this->getDatabase()->getPassword());
-            } else {
-                $this->pdo = new PDO($dsn);
-            }
-        }
-        return $this->pdo;
-    }
-
-    protected Database\Transaction $transaction;
-
-    public function transaction(): Database\Transaction
-    {
-        if (!isset($this->transaction)) {
-            $this->transaction = new Transaction($this);
-        }
-        return $this->transaction;
-    }
-
-    public function query(string $query): Database\ResultSet
-    {
-        $statement = $this->connect()->query($query);
-        if ($statement === false) {
-            throw new InvalidQuery($query);
-        }
-        return new ResultSet($statement);
-    }
-    public function prepare(string $query): Database\ResultSet
-    {
-        $statement = $this->connect()->prepare($query);
-        if ($statement === false) {
-            throw new InvalidQuery($query);
-        }
-        return new ResultSet($statement);
-    }
-    public function execute(string $query, ?array $data = null): Database\ResultSet
-    {
-        if ($data !== null) {
-            $rs = $this->prepare($query);
-            $rs->execute($data);
-            return $rs;
-        }
-        return $this->query($query);
-    }
-
-    public function fetchOne(string $query, ?array $data = null): array
-    {
-        return $this->execute($query, $data)->fetchFirst();
-    }
-    public function fetchMany(string $query, ?array $data = null): array
-    {
-        return $this->execute($query, $data)->fetchAll();
-    }
-}
diff --git a/src/Database/Transaction.php b/src/Database/Transaction.php
deleted file mode 100644
index 3181903..0000000
--- a/src/Database/Transaction.php
+++ /dev/null
@@ -1,40 +0,0 @@
-<?php
-namespace ProVM\Database;
-
-use PDO;
-use ProVM\Concept;
-
-class Transaction implements Concept\Database\Transaction
-{
-    public function __construct(Concept\Database\Connection $connection)
-    {
-        $this->setConnection($connection);
-    }
-
-    protected Concept\Database\Connection $connection;
-
-    public function getConnection(): Concept\Database\Connection
-    {
-        return $this->connection;
-    }
-
-    public function setConnection(Concept\Database\Connection $connection): Concept\Database\Transaction
-    {
-        $this->connection = $connection;
-        return $this;
-    }
-
-    public function begin(): Concept\Database\Transaction
-    {
-        $this->getConnection()->connect()->beginTransaction();
-        return $this;
-    }
-    public function commit(): void
-    {
-        $this->getConnection()->connect()->commit();
-    }
-    public function rollBack(): void
-    {
-        $this->getConnection()->connect()->rollBack();
-    }
-}
diff --git a/src/Concept/Database.php b/src/Define/Database.php
similarity index 50%
rename from src/Concept/Database.php
rename to src/Define/Database.php
index bc9f2a9..75f9804 100644
--- a/src/Concept/Database.php
+++ b/src/Define/Database.php
@@ -1,5 +1,5 @@
 <?php
-namespace ProVM\Concept;
+namespace Database\Define;
 
 interface Database
 {
@@ -9,10 +9,10 @@ interface Database
     public function getUser(): string;
     public function getPassword(): string;
     public function needsUser(): bool;
-    public function setHost(string $host): Database;
-    public function setPort(int $port): Database;
-    public function setName(string $name): Database;
-    public function setUser(string $username): Database;
-    public function setPassword(string $password): Database;
+    public function setHost(string $host): self;
+    public function setPort(int $port): self;
+    public function setName(string $name): self;
+    public function setUser(string $username): self;
+    public function setPassword(string $password): self;
     public function getDsn(): string;
 }
diff --git a/src/Define/Database/Connection.php b/src/Define/Database/Connection.php
new file mode 100644
index 0000000..8896788
--- /dev/null
+++ b/src/Define/Database/Connection.php
@@ -0,0 +1,40 @@
+<?php
+namespace Database\Define\Database;
+
+use Database\Exception\Database\InvalidQuery;
+use PDO;
+use PDOException;
+
+interface Connection
+{
+    /**
+     * @return self
+     * @throws PDOException
+     */
+    public function connect(): self;
+    public function getPDO(): PDO;
+
+    public function transaction(): Transaction;
+
+    /**
+     * @param string $query
+     * @return ResultSet
+     * @throws InvalidQuery
+     */
+    public function query(string $query): ResultSet;
+
+    /**
+     * @param string $query
+     * @return ResultSet
+     * @throws InvalidQuery
+     */
+    public function prepare(string $query): ResultSet;
+
+    /**
+     * @param string $query
+     * @param array|null $data
+     * @return ResultSet
+     * @throws InvalidQuery
+     */
+    public function execute(string $query, ?array $data = null): ResultSet;
+}
diff --git a/src/Concept/Database/ResultSet.php b/src/Define/Database/ResultSet.php
similarity index 57%
rename from src/Concept/Database/ResultSet.php
rename to src/Define/Database/ResultSet.php
index 4c744b2..d223897 100644
--- a/src/Concept/Database/ResultSet.php
+++ b/src/Define/Database/ResultSet.php
@@ -1,9 +1,12 @@
 <?php
-namespace ProVM\Concept\Database;
+namespace Database\Define\Database;
+
+use PDOStatement;
 
 interface ResultSet
 {
-    public function execute(array $data): ResultSet;
+    public function getStatement(): PDOStatement;
+    public function execute(array $data): self;
 
     public function fetchFirst(): array;
     public function fetchAll(): array;
diff --git a/src/Concept/Database/Transaction.php b/src/Define/Database/Transaction.php
similarity index 80%
rename from src/Concept/Database/Transaction.php
rename to src/Define/Database/Transaction.php
index bd76772..a7f50ad 100644
--- a/src/Concept/Database/Transaction.php
+++ b/src/Define/Database/Transaction.php
@@ -1,5 +1,5 @@
 <?php
-namespace ProVM\Concept\Database;
+namespace Database\Define\Database;
 
 interface Transaction
 {
diff --git a/src/Exception/Database.php b/src/Exception/Database.php
index d1a2759..1d463a0 100644
--- a/src/Exception/Database.php
+++ b/src/Exception/Database.php
@@ -1,12 +1,12 @@
 <?php
-namespace ProVM\Exception;
+namespace Database\Exception;
 
 use Exception;
 use Throwable;
 
 abstract class Database extends Exception
 {
-    const BASE_CODE = 600;
+    const BASE_CODE = 1000;
 
     public function __construct(string $message = "", int $code = 0, ?Throwable $previous = null)
     {
diff --git a/src/Exception/Database/BlankResult.php b/src/Exception/Database/BlankResult.php
index 9a2294d..0119442 100644
--- a/src/Exception/Database/BlankResult.php
+++ b/src/Exception/Database/BlankResult.php
@@ -1,8 +1,8 @@
 <?php
-namespace ProVM\Exception\Database;
+namespace Database\Exception\Database;
 
 use Throwable;
-use ProVM\Exception\Database;
+use Database\Exception\Database;
 
 class BlankResult extends Database
 {
diff --git a/src/Exception/Database/InvalidQuery.php b/src/Exception/Database/InvalidQuery.php
index 4f9b48c..4094631 100644
--- a/src/Exception/Database/InvalidQuery.php
+++ b/src/Exception/Database/InvalidQuery.php
@@ -1,8 +1,8 @@
 <?php
-namespace ProVM\Exception\Database;
+namespace Database\Exception\Database;
 
 use Throwable;
-use ProVM\Exception;
+use Database\Exception;
 
 class InvalidQuery extends Exception\Database
 {
diff --git a/src/Implement/Database.php b/src/Ideal/Database.php
similarity index 70%
rename from src/Implement/Database.php
rename to src/Ideal/Database.php
index 4093c19..344e8c6 100644
--- a/src/Implement/Database.php
+++ b/src/Ideal/Database.php
@@ -1,9 +1,9 @@
 <?php
-namespace ProVM\Implement;
+namespace Database\Ideal;
 
-use ProVM\Concept;
+use Database\Define;
 
-abstract class Database implements Concept\Database
+abstract class Database implements Define\Database
 {
     protected string $host;
     protected int $port;
@@ -32,27 +32,27 @@ abstract class Database implements Concept\Database
         return $this->password;
     }
 
-    public function setHost(string $host): Concept\Database
+    public function setHost(string $host): Define\Database
     {
         $this->host = $host;
         return $this;
     }
-    public function setPort(int $port): Concept\Database
+    public function setPort(int $port): Define\Database
     {
         $this->port = $port;
         return $this;
     }
-    public function setName(string $name): Concept\Database
+    public function setName(string $name): Define\Database
     {
         $this->name = $name;
         return $this;
     }
-    public function setUser(string $username): Concept\Database
+    public function setUser(string $username): Define\Database
     {
         $this->user = $username;
         return $this;
     }
-    public function setPassword(string $password): Concept\Database
+    public function setPassword(string $password): Define\Database
     {
         $this->password = $password;
         return $this;
diff --git a/src/Implement/Connection.php b/src/Implement/Connection.php
new file mode 100644
index 0000000..b599d7a
--- /dev/null
+++ b/src/Implement/Connection.php
@@ -0,0 +1,111 @@
+<?php
+namespace Database\Implement;
+
+use PDO;
+use PDOException;
+use Database\Define;
+use Database\Exception\Database\InvalidQuery;
+
+class Connection implements Define\Database\Connection
+{
+    public function __construct(Define\Database $database)
+    {
+        $this->setDatabase($database);
+    }
+
+    protected Define\Database $database;
+
+    protected function getDatabase(): Define\Database
+    {
+        return $this->database;
+    }
+
+    protected function setDatabase(Define\Database $database): self
+    {
+        $this->database = $database;
+        return $this;
+    }
+
+    protected PDO $pdo;
+    public function connect(): self
+    {
+        if (!isset($this->pdo)) {
+            $dsn = $this->getDatabase()->getDsn();
+            if ($this->getDatabase()->needsUser()) {
+                $this->pdo = new PDO($dsn, $this->getDatabase()->getUser(), $this->getDatabase()->getPassword());
+            } else {
+                $this->pdo = new PDO($dsn);
+            }
+        }
+        return $this;
+    }
+    public function getPDO(): PDO
+    {
+        return $this->connect()->pdo;
+    }
+
+    protected Define\Database\Transaction $transaction;
+
+    public function transaction(): Define\Database\Transaction
+    {
+        if (!isset($this->transaction)) {
+            $this->transaction = new Transaction($this);
+        }
+        return $this->transaction;
+    }
+
+    public function query(string $query): Define\Database\ResultSet
+    {
+        try {
+            $statement = $this->getPDO()->query($query);
+        } catch (PDOException $exception) {
+            throw new InvalidQuery($query, $exception);
+        }
+        if ($statement === false) {
+            throw new InvalidQuery($query);
+        }
+        return new ResultSet($statement);
+    }
+    public function prepare(string $query): Define\Database\ResultSet
+    {
+        try {
+            $statement = $this->getPDO()->prepare($query);
+        } catch (PDOException $exception) {
+            throw new InvalidQuery($query, $exception);
+        }
+        if ($statement === false) {
+            throw new InvalidQuery($query);
+        }
+        return new ResultSet($statement);
+    }
+    public function execute(string $query, ?array $data = null): Define\Database\ResultSet
+    {
+        if ($data !== null) {
+            return $this->prepare($query)
+                ->execute($data);
+        }
+        return $this->query($query);
+    }
+
+    /**
+     * @param string $query
+     * @param array|null $data
+     * @return array
+     * @throws InvalidQuery
+     */
+    public function fetchOne(string $query, ?array $data = null): array
+    {
+        return $this->execute($query, $data)->fetchFirst();
+    }
+
+    /**
+     * @param string $query
+     * @param array|null $data
+     * @return array
+     * @throws InvalidQuery
+     */
+    public function fetchMany(string $query, ?array $data = null): array
+    {
+        return $this->execute($query, $data)->fetchAll();
+    }
+}
diff --git a/src/Database/MySQL.php b/src/Implement/MySQL.php
similarity index 86%
rename from src/Database/MySQL.php
rename to src/Implement/MySQL.php
index a4e009f..546366c 100644
--- a/src/Database/MySQL.php
+++ b/src/Implement/MySQL.php
@@ -1,7 +1,7 @@
 <?php
-namespace ProVM\Database;
+namespace Database\Implement;
 
-use ProVM\Implement\Database;
+use Database\Ideal\Database;
 
 class MySQL extends Database
 {
diff --git a/src/Database/PostgreSQL.php b/src/Implement/PostgreSQL.php
similarity index 87%
rename from src/Database/PostgreSQL.php
rename to src/Implement/PostgreSQL.php
index fc83fe6..6fb4a8d 100644
--- a/src/Database/PostgreSQL.php
+++ b/src/Implement/PostgreSQL.php
@@ -1,7 +1,7 @@
 <?php
-namespace ProVM\Database;
+namespace Database\Implement;
 
-use ProVM\Implement\Database;
+use Database\Ideal\Database;
 
 class PostgreSQL extends Database
 {
diff --git a/src/Database/ResultSet.php b/src/Implement/ResultSet.php
similarity index 63%
rename from src/Database/ResultSet.php
rename to src/Implement/ResultSet.php
index d357ffc..b951cf1 100644
--- a/src/Database/ResultSet.php
+++ b/src/Implement/ResultSet.php
@@ -1,12 +1,12 @@
 <?php
-namespace ProVM\Database;
+namespace Database\Implement;
 
 use PDO;
 use PDOStatement;
-use ProVM\Concept\Database;
-use ProVM\Exception\Database\BlankResult;
+use Database\Define;
+use Database\Exception\Database\BlankResult;
 
-class ResultSet implements Database\ResultSet
+class ResultSet implements Define\Database\ResultSet
 {
     public function __construct(PDOStatement $statement)
     {
@@ -15,22 +15,26 @@ class ResultSet implements Database\ResultSet
 
     protected PDOStatement $statement;
 
-    protected function getStatement(): PDOStatement
+    public function getStatement(): PDOStatement
     {
         return $this->statement;
     }
-    protected function setStatement(PDOStatement $statement): ResultSet
+    protected function setStatement(PDOStatement $statement): self
     {
         $this->statement = $statement;
         return $this;
     }
 
-    public function execute(array $data): Database\ResultSet
+    public function execute(array $data): self
     {
         $this->statement->execute($data);
         return $this;
     }
 
+    /**
+     * @return PDOStatement
+     * @throws BlankResult
+     */
     protected function checkResults(): PDOStatement
     {
         if ($this->getStatement()->rowCount() === 0) {
@@ -38,18 +42,38 @@ class ResultSet implements Database\ResultSet
         }
         return $this->getStatement();
     }
+
+    /**
+     * @return array
+     * @throws BlankResult
+     */
     public function fetchFirst(): array
     {
         return $this->checkResults()->fetch(PDO::FETCH_ASSOC);
     }
+
+    /**
+     * @return array
+     * @throws BlankResult
+     */
     public function fetchAll(): array
     {
         return $this->checkResults()->fetchAll(PDO::FETCH_ASSOC);
     }
+
+    /**
+     * @return object
+     * @throws BlankResult
+     */
     public function fetchFirstAsObject(): object
     {
         return $this->checkResults()->fetch(PDO::FETCH_OBJ);
     }
+
+    /**
+     * @return array
+     * @throws BlankResult
+     */
     public function fetchAllAsObjects(): array
     {
         return $this->checkResults()->fetchAll(PDO::FETCH_OBJ);
diff --git a/src/Database/SQLite.php b/src/Implement/SQLite.php
similarity index 69%
rename from src/Database/SQLite.php
rename to src/Implement/SQLite.php
index f8ab299..e43481c 100644
--- a/src/Database/SQLite.php
+++ b/src/Implement/SQLite.php
@@ -1,7 +1,7 @@
 <?php
-namespace ProVM\Database;
+namespace Database\Implement;
 
-use ProVM\Implement\Database;
+use Database\Ideal\Database;
 
 class SQLite extends Database
 {
diff --git a/src/Implement/Transaction.php b/src/Implement/Transaction.php
new file mode 100644
index 0000000..a51621e
--- /dev/null
+++ b/src/Implement/Transaction.php
@@ -0,0 +1,39 @@
+<?php
+namespace Database\Implement;
+
+use Database\Define;
+
+class Transaction implements Define\Database\Transaction
+{
+    public function __construct(Define\Database\Connection $connection)
+    {
+        $this->setConnection($connection);
+    }
+
+    protected Define\Database\Connection $connection;
+
+    public function getConnection(): Define\Database\Connection
+    {
+        return $this->connection;
+    }
+
+    public function setConnection(Define\Database\Connection $connection): self
+    {
+        $this->connection = $connection;
+        return $this;
+    }
+
+    public function begin(): self
+    {
+        $this->getConnection()->getPDO()->beginTransaction();
+        return $this;
+    }
+    public function commit(): void
+    {
+        $this->getConnection()->getPDO()->commit();
+    }
+    public function rollBack(): void
+    {
+        $this->getConnection()->getPDO()->rollBack();
+    }
+}
diff --git a/tests/ConnectionTest.php b/tests/ConnectionTest.php
index fe4919f..9286f22 100644
--- a/tests/ConnectionTest.php
+++ b/tests/ConnectionTest.php
@@ -1,65 +1,61 @@
 <?php
 use PHPUnit\Framework\TestCase;
 
-use ProVM\Database\Connection;
-use ProVM\Concept;
+use Database\Implement\Connection;
+use Database\Define;
 
 class ConnectionTest extends TestCase
 {
+    protected string $host = '/tmp/test.db3';
+    protected string $tableName = 'test_table';
     protected PDO $pdo;
     protected function setUp(): void
     {
-        $this->pdo = new PDO('sqlite::memory:');
-        $query = "CREATE TABLE IF NOT EXISTS test_table (id INTEGER PRIMARY KEY, test TEXT)";
+        $this->pdo = new PDO("sqlite:{$this->host}");
+        $query = "CREATE TABLE IF NOT EXISTS {$this->tableName} (id INTEGER PRIMARY KEY, test TEXT)";
+        $this->pdo->query($query);
+        $query = "INSERT INTO {$this->tableName} (test) VALUES ('test')";
         $this->pdo->query($query);
     }
     protected function tearDown(): void
     {
         unset($this->pdo);
+        unlink($this->host);
+    }
+
+    protected function getConnection(): Connection
+    {
+        $host = $this->host;
+
+        $database = $this->getMockBuilder(Define\Database::class)->getMock();
+        $database->method('getHost')->willReturn($host);
+        $database->method('getDsn')->willReturn("sqlite:{$host}");
+        $database->method('needsUser')->willReturn(false);
+
+        return new Connection($database);
     }
 
     public function testConnection()
     {
-        $host = "memory";
-
-        $database = $this->getMockBuilder(Concept\Database::class)->getMock();
-        $database->method('getHost')->willReturn($host);
-        $database->method('getDsn')->willReturn("sqlite::{$host}");
-        $database->method('needsUser')->willReturn(false);
-
-        $connection = new Connection($database);
-        $this->assertEquals($this->pdo, $connection->connect());
+        $connection = $this->getConnection();
+        $this->assertEquals($this->pdo, $connection->getPDO());
     }
     public function testQuery()
     {
-        $host = "memory";
-
-        $database = $this->getMockBuilder(Concept\Database::class)->getMock();
-        $database->method('getHost')->willReturn($host);
-        $database->method('getDsn')->willReturn("sqlite::{$host}");
-        $database->method('needsUser')->willReturn(false);
-
-        $connection = new Connection($database);
+        $connection = $this->getConnection();
         $query = "CREATE TABLE IF NOT EXISTS test_table (id INTEGER PRIMARY KEY, test TEXT)";
         $connection->query($query);
         $query = "SELECT * FROM test_table";
-        $result = $connection->query($query);
-        $this->assertInstanceOf(Concept\Database\ResultSet::class, $result);
+        $connection->query($query);
+        $this->assertTrue(true);
     }
     public function testPrepare()
     {
-        $host = "memory";
-
-        $database = $this->getMockBuilder(Concept\Database::class)->getMock();
-        $database->method('getHost')->willReturn($host);
-        $database->method('getDsn')->willReturn("sqlite::{$host}");
-        $database->method('needsUser')->willReturn(false);
-
-        $connection = new Connection($database);
+        $connection = $this->getConnection();
         $query = "CREATE TABLE IF NOT EXISTS test_table (id INTEGER PRIMARY KEY, test TEXT)";
         $connection->query($query);
         $query = "SELECT * FROM test_table";
-        $result = $connection->prepare($query);
-        $this->assertInstanceOf(Concept\Database\ResultSet::class, $result);
+        $connection->prepare($query);
+        $this->assertTrue(true);
     }
 }
diff --git a/tests/MySQLTest.php b/tests/MySQLTest.php
index c02ede0..cce4c82 100644
--- a/tests/MySQLTest.php
+++ b/tests/MySQLTest.php
@@ -1,6 +1,6 @@
 <?php
 use PHPUnit\Framework\TestCase;
-use ProVM\Database\MySQL;
+use Database\Implement\MySQL;
 
 class MySQLTest extends TestCase
 {
diff --git a/tests/PostgreSQLTest.php b/tests/PostgreSQLTest.php
index 993005c..21b26c3 100644
--- a/tests/PostgreSQLTest.php
+++ b/tests/PostgreSQLTest.php
@@ -1,6 +1,6 @@
 <?php
 use PHPUnit\Framework\TestCase;
-use ProVM\Database\PostgreSQL;
+use Database\Implement\PostgreSQL;
 
 class PostgreSQLTest extends TestCase
 {
diff --git a/tests/ResultSetTest.php b/tests/ResultSetTest.php
index b64b4bf..a01c98a 100644
--- a/tests/ResultSetTest.php
+++ b/tests/ResultSetTest.php
@@ -1,7 +1,7 @@
 <?php
 use PHPUnit\Framework\TestCase;
 
-use ProVM\Database\ResultSet;
+use Database\Implement\ResultSet;
 
 class ResultSetTest extends TestCase
 {
diff --git a/tests/SQLiteTest.php b/tests/SQLiteTest.php
index b1d5820..f4f5cb6 100644
--- a/tests/SQLiteTest.php
+++ b/tests/SQLiteTest.php
@@ -1,6 +1,6 @@
 <?php
 use PHPUnit\Framework\TestCase;
-use ProVM\Database\SQLite;
+use Database\Implement\SQLite;
 
 class SQLiteTest extends TestCase
 {
diff --git a/tests/TransactionTest.php b/tests/TransactionTest.php
index ec2ff0c..e5265bd 100644
--- a/tests/TransactionTest.php
+++ b/tests/TransactionTest.php
@@ -1,12 +1,12 @@
 <?php
 use PHPUnit\Framework\TestCase;
-use ProVM\Database\Transaction;
+use Database\Implement\Transaction;
 
 class TransactionTest extends TestCase
 {
     public function testTransaction()
     {
-        $connection = $this->createMock(ProVM\Concept\Database\Connection::class);
+        $connection = $this->createMock(Database\Define\Database\Connection::class);
         $transaction = new Transaction($connection);
         $transaction->begin();
         $this->assertTrue(true);