Explorer: added autoCommit()

Author: dg

src/Database/Explorer.php

@@ -44,6 +44,7 @@ class Explorer
 	private TypeConverter $typeConverter;
 	private ?SqlLiteral $lastQuery = null;
 	private int $transactionDepth = 0;
+	private bool $autoCommit = true;
 	private ?Cache $cache = null;
 	private ?Conventions $conventions = null;
 	private ?Structure $structure = null;
@@ -77,6 +78,7 @@ public static function createFromParameters(
 		$args = array_diff_key($params, array_flip(self::TypeConverterOptions));
 		$explorer = new self(new $class(...$args));
 		array_map(fn($opt) => isset($params[$opt]) && ($explorer->typeConverter->$opt = (bool) $params[$opt]), self::TypeConverterOptions);
+		$this->autoCommit = (bool) ($params['autoCommit'] ?? true);
 		return $explorer;
 	}
 
@@ -129,6 +131,9 @@ public function connect(): void
 			throw ConnectionException::from($e);
 		}
 
+		if (!$this->autoCommit) {
+			$this->beginTransaction();
+		}
 		Arrays::invoke($this->onConnect, $this);
 	}
 
@@ -259,7 +264,9 @@ public function commit(): void
 
 		} elseif (--$this->transactionDepth === 0) {
 			$this->logOperation($this->getConnection()->commit(...), new SqlLiteral('COMMIT'));
-
+			if (!$this->autoCommit) {
+				$this->beginTransaction();
+			}
 		} else {
 			$this->releaseSavepoint($this->transactionDepth);
 		}
@@ -277,7 +284,9 @@ public function rollBack(): void
 
 		} elseif (--$this->transactionDepth === 0) {
 			$this->logOperation($this->getConnection()->rollBack(...), new SqlLiteral('ROLLBACK'));
-
+			if (!$this->autoCommit) {
+				$this->beginTransaction();
+			}
 		} else {
 			$this->rollbackToSavepoint($this->transactionDepth);
 		}
@@ -301,6 +310,27 @@ public function transaction(callable $callback): mixed
 	}
 
 
+	public function setAutoCommit(bool $state): void
+	{
+		if ($this->autoCommit === $state) {
+			return;
+		}
+
+		while ($this->transactionDepth > 0) {
+			if (--$this->transactionDepth === 0) {
+				$this->query('::commit');
+			} else {
+				$this->releaseSavepoint($this->transactionDepth);
+			}
+		}
+
+		$this->autoCommit = $state;
+		if (!$state && $this->connection) {
+			$$this->beginTransaction();
+		}
+	}
+
+
 	public function createSavepoint(int $level): void
 	{
 		$this->query('SAVEPOINT LEVEL' . $level); // TODO: to driver, logOperation