new version (from mysql git)

Author: leongrdic

composer.json

@@ -2,7 +2,7 @@
   "name": "leven-framework/dba-common",
   "type": "library",
   "suggest": {
-    "leven-framework/dba-mock": "Mock a database using e.g. a local file",
+    "leven-framework/dba-mock": "Mock a database using an array",
     "leven-framework/dba-mysql": "PDO MySQL adapter"
   },
   "autoload": {

composer.lock

@@ -0,0 +1,38 @@
+<?php
+
+namespace Leven\DBA\Common;
+
+use Leven\DBA\Common\Exception\DriverException;
+use Leven\DBA\Common\Exception\TxnNotActiveException;
+
+interface AdapterInterface
+{
+
+    public function select(string $table): SelectQueryInterface;
+
+    /**
+     * @throws \Leven\DBA\Common\Exception\DriverException
+     */
+    public function insert(string $table, ?array $data = null): InsertQueryInterface|AdapterResponse;
+
+    public function update(string $table): UpdateQueryInterface;
+
+    public function delete(string $table): DeleteQueryInterface;
+
+    /**
+     * @throws \Leven\DBA\Common\Exception\DriverException
+     */
+    public function txnBegin(): static;
+
+    /**
+     * @throws \Leven\DBA\Common\Exception\TxnNotActiveException
+     * @throws DriverException
+     */
+    public function txnCommit(): static;
+
+    /**
+     * @throws \Leven\DBA\Common\Exception\TxnNotActiveException
+     * @throws DriverException
+     */
+    public function txnRollback(): static;
+}

src/AdapterInterface.php

@@ -0,0 +1,21 @@
+<?php namespace Leven\DBA\Common;
+
+use ArrayIterator, ArrayObject, IteratorAggregate;
+
+class AdapterResponse implements IteratorAggregate {
+
+    public function __construct(
+        public readonly int $count,
+        public readonly array $rows = [],
+        public readonly int|string|null $lastId = null,
+    )
+    {
+    }
+
+    public function getIterator(): ArrayIterator
+    {
+        $o = new ArrayObject($this->rows);
+        return $o->getIterator();
+    }
+
+}

src/AdapterResponse.php

@@ -0,0 +1,22 @@
+<?php
+
+namespace Leven\DBA\Common\BuilderPart;
+
+trait ColumnTrait
+{
+
+    protected array|string $columns = [];
+
+    public function columns(string ...$columns): static
+    {
+        $this->columns = [...$this->columns, ...$columns];
+        return $this;
+    }
+
+    public function rawColumns(string $columns): static
+    {
+        $this->columns = $columns;
+        return $this;
+    }
+
+}

src/BuilderPart/ColumnTrait.php

@@ -0,0 +1,25 @@
+<?php
+
+namespace Leven\DBA\Common\BuilderPart;
+
+trait LimitTrait
+{
+
+    protected int $limit = 0;
+    protected int $offset = 0;
+
+    public function limit(int $limitOrOffset, int $limit = 0): static
+    {
+        if($limit !== 0) $this->offset = $limitOrOffset;
+        $this->limit = $limit === 0 ? $limitOrOffset : $limit;
+
+        return $this;
+    }
+
+    public function offset(int $offset): static
+    {
+        $this->offset = $offset;
+        return $this;
+    }
+
+}

src/BuilderPart/LimitTrait.php

@@ -0,0 +1,22 @@
+<?php
+
+namespace Leven\DBA\Common\BuilderPart;
+
+trait OrderTrait
+{
+
+    protected array $order = [];
+
+    public function orderAsc(string $column): static
+    {
+        $this->order[$column] = 'ASC';
+        return $this;
+    }
+
+    public function orderDesc(string $column): static
+    {
+        $this->order[$column] = 'DESC';
+        return $this;
+    }
+
+}

src/BuilderPart/OrderTrait.php

@@ -0,0 +1,22 @@
+<?php
+
+namespace Leven\DBA\Common\BuilderPart;
+
+trait SetTrait
+{
+
+    protected array $data = [];
+
+    public function set(array|string $dataOrColumn, null|string|bool|int|float $value = null): static
+    {
+        if(is_array($dataOrColumn)) {
+            $this->data = [...$this->data, ...$dataOrColumn];
+            return $this;
+        }
+
+        $this->data[$dataOrColumn] = $value;
+
+        return $this;
+    }
+
+}

src/BuilderPart/SetTrait.php

@@ -0,0 +1,17 @@
+<?php
+
+namespace Leven\DBA\Common\BuilderPart;
+
+class WhereCondition
+{
+
+    public function __construct(
+        public readonly bool $isOr,
+        public readonly string $column,
+        public readonly null|string|bool|int|float $value,
+        public readonly string $operand = '<=>',
+    )
+    {
+    }
+
+}

src/BuilderPart/WhereCondition.php

@@ -0,0 +1,21 @@
+<?php
+
+namespace Leven\DBA\Common\BuilderPart;
+
+class WhereGroup
+{
+
+    use WhereTrait;
+
+    public function __construct(
+        public readonly bool $isOr,
+    )
+    {
+    }
+
+    public function getConditions(): array
+    {
+        return $this->conditions;
+    }
+
+}