SQLite support has been added

CHANGELOG.md

@@ -0,0 +1,5 @@
+# Release Notes
+
+## [v2.2.0](https://github.com/lapaliv/laravel-bulk-upsert/compare/2.1.1...2.2.0) - 2023-12-10
+
+* SQLite support has been added. in https://github.com/lapaliv/laravel-bulk-upsert/pull/41

README.md

@@ -56,6 +56,7 @@ The documentation for version 1.x you can see [here](https://github.com/lapaliv/
 - Database:
   - MySQL: __5.7+__
   - PostgreSQL __9.6+__
+  - SQLite __3.32+__
 - PHP: __8.0+__
 - Laravel: __8.0+__
 
@@ -768,8 +769,8 @@ class BulkRow {
 * Bulk touching
 * Bulk updating without updating timestamps
 * Supporting `DB::raw()` as a value
-* Supporting `SQLite`
 * Support a custom database driver
+* Update rows and return the number of updated ones
 
 ### Tests
 

src/Drivers/MySql/MySqlDriverDelete.php → src/Drivers/MySql/MySqlDriverDeleteFeature.php

@@ -10,7 +10,7 @@
 /**
  * @internal
  */
-class MySqlDriverDelete
+class MySqlDriverDeleteFeature
 {
     public function __construct(private MixedValueToSqlConverter $mixedValueToSqlConverter)
     {

src/Drivers/MySql/MySqlDriverInsertWithResult.php → src/Drivers/MySql/MySqlDriverInsertWithResultFeature.php

@@ -16,7 +16,7 @@
 /**
  * @internal
  */
-class MySqlDriverInsertWithResult
+class MySqlDriverInsertWithResultFeature
 {
     public function __construct(
         private MixedValueToSqlConverter $mixedValueToSqlConverter,

src/Drivers/MySql/MySqlDriverQuietInsert.php → src/Drivers/MySql/MySqlDriverQuietInsertFeature.php

@@ -14,7 +14,7 @@
 /**
  * @internal
  */
-class MySqlDriverQuietInsert
+class MySqlDriverQuietInsertFeature
 {
     public function __construct(
         private MixedValueToSqlConverter $mixedValueToSqlConverter,

src/Drivers/MySql/MySqlDriverUpdate.php → src/Drivers/MySql/MySqlDriverUpdateFeature.php

@@ -10,7 +10,7 @@
 /**
  * @internal
  */
-class MySqlDriverUpdate
+class MySqlDriverUpdateFeature
 {
     public function __construct(private MixedValueToSqlConverter $mixedValueToSqlConverter)
     {

src/Drivers/MySqlBulkDriver.php

@@ -8,10 +8,10 @@
 use Lapaliv\BulkUpsert\Builders\UpdateBulkBuilder;
 use Lapaliv\BulkUpsert\Contracts\BulkDriver;
 use Lapaliv\BulkUpsert\Contracts\BulkInsertResult;
-use Lapaliv\BulkUpsert\Drivers\MySql\MySqlDriverDelete;
-use Lapaliv\BulkUpsert\Drivers\MySql\MySqlDriverInsertWithResult;
-use Lapaliv\BulkUpsert\Drivers\MySql\MySqlDriverQuietInsert;
-use Lapaliv\BulkUpsert\Drivers\MySql\MySqlDriverUpdate;
+use Lapaliv\BulkUpsert\Drivers\MySql\MySqlDriverDeleteFeature;
+use Lapaliv\BulkUpsert\Drivers\MySql\MySqlDriverInsertWithResultFeature;
+use Lapaliv\BulkUpsert\Drivers\MySql\MySqlDriverQuietInsertFeature;
+use Lapaliv\BulkUpsert\Drivers\MySql\MySqlDriverUpdateFeature;
 use Throwable;
 
 /**
@@ -20,10 +20,10 @@
 class MySqlBulkDriver implements BulkDriver
 {
     public function __construct(
-        private MySqlDriverInsertWithResult $insertWithResult,
-        private MySqlDriverQuietInsert $quietInsert,
-        private MySqlDriverUpdate $update,
-        private MySqlDriverDelete $delete,
+        private MySqlDriverInsertWithResultFeature $insertWithResultFeature,
+        private MySqlDriverQuietInsertFeature $quietInsertFeature,
+        private MySqlDriverUpdateFeature $updateFeature,
+        private MySqlDriverDeleteFeature $deleteFeature,
     ) {
         //
     }
@@ -36,27 +36,27 @@ public function insertWithResult(
         InsertBuilder $builder,
         ?string $primaryKeyName,
     ): BulkInsertResult {
-        return $this->insertWithResult->handle($connection, $builder, $primaryKeyName);
+        return $this->insertWithResultFeature->handle($connection, $builder, $primaryKeyName);
     }
 
     /**
      * @throws Throwable
      */
     public function quietInsert(ConnectionInterface $connection, InsertBuilder $builder): void
     {
-        $this->quietInsert->handle($connection, $builder);
+        $this->quietInsertFeature->handle($connection, $builder);
     }
 
     /**
      * @throws Throwable
      */
     public function update(ConnectionInterface $connection, UpdateBulkBuilder $builder): int
     {
-        return $this->update->handle($connection, $builder);
+        return $this->updateFeature->handle($connection, $builder);
     }
 
     public function forceDelete(ConnectionInterface $connection, DeleteBulkBuilder $builder): int
     {
-        return $this->delete->handle($connection, $builder);
+        return $this->deleteFeature->handle($connection, $builder);
     }
 }

src/Drivers/PostgreSql/PostgreSqlDriverDelete.php → src/Drivers/PostgreSql/PostgreSqlDriverDeleteFeature.php

@@ -10,7 +10,7 @@
 /**
  * @internal
  */
-class PostgreSqlDriverDelete
+class PostgreSqlDriverDeleteFeature
 {
     public function __construct(private MixedValueToSqlConverter $mixedValueToSqlConverter)
     {

src/Drivers/PostgreSql/PostgreSqlDriverInsertWithResult.php → src/Drivers/PostgreSql/PostgreSqlDriverInsertWithResultFeature.php

@@ -9,7 +9,10 @@
 use Lapaliv\BulkUpsert\Entities\BulkPostgreSqlInsertResult;
 use Lapaliv\BulkUpsert\Grammars\PostgreSqlGrammar;
 
-class PostgreSqlDriverInsertWithResult
+/**
+ * @internal
+ */
+class PostgreSqlDriverInsertWithResultFeature
 {
     public function __construct(
         private MixedValueToSqlConverter $mixedValueToSqlConverter,

src/Drivers/PostgreSql/PostgreSqlDriverQuietInsert.php → src/Drivers/PostgreSql/PostgreSqlDriverQuietInsertFeature.php

@@ -7,7 +7,10 @@
 use Lapaliv\BulkUpsert\Converters\MixedValueToSqlConverter;
 use Lapaliv\BulkUpsert\Grammars\PostgreSqlGrammar;
 
-class PostgreSqlDriverQuietInsert
+/**
+ * @internal
+ */
+class PostgreSqlDriverQuietInsertFeature
 {
     public function __construct(
         private MixedValueToSqlConverter $mixedValueToSqlConverter,

src/Drivers/PostgreSql/PostgreSqlDriverUpdate.php → src/Drivers/PostgreSql/PostgreSqlDriverUpdateFeature.php

@@ -10,7 +10,7 @@
 /**
  * @internal
  */
-class PostgreSqlDriverUpdate
+class PostgreSqlDriverUpdateFeature
 {
     public function __construct(private MixedValueToSqlConverter $mixedValueToSqlConverter)
     {

src/Drivers/PostgreSqlBulkDriver.php

@@ -8,18 +8,18 @@
 use Lapaliv\BulkUpsert\Builders\UpdateBulkBuilder;
 use Lapaliv\BulkUpsert\Contracts\BulkDriver;
 use Lapaliv\BulkUpsert\Contracts\BulkInsertResult;
-use Lapaliv\BulkUpsert\Drivers\PostgreSql\PostgreSqlDriverDelete;
-use Lapaliv\BulkUpsert\Drivers\PostgreSql\PostgreSqlDriverInsertWithResult;
-use Lapaliv\BulkUpsert\Drivers\PostgreSql\PostgreSqlDriverQuietInsert;
-use Lapaliv\BulkUpsert\Drivers\PostgreSql\PostgreSqlDriverUpdate;
+use Lapaliv\BulkUpsert\Drivers\PostgreSql\PostgreSqlDriverDeleteFeature;
+use Lapaliv\BulkUpsert\Drivers\PostgreSql\PostgreSqlDriverInsertWithResultFeature;
+use Lapaliv\BulkUpsert\Drivers\PostgreSql\PostgreSqlDriverQuietInsertFeature;
+use Lapaliv\BulkUpsert\Drivers\PostgreSql\PostgreSqlDriverUpdateFeature;
 
 class PostgreSqlBulkDriver implements BulkDriver
 {
     public function __construct(
-        private PostgreSqlDriverInsertWithResult $insertWithResult,
-        private PostgreSqlDriverQuietInsert $quietInsert,
-        private PostgreSqlDriverUpdate $update,
-        private PostgreSqlDriverDelete $delete,
+        private PostgreSqlDriverInsertWithResultFeature $insertWithResultFeature,
+        private PostgreSqlDriverQuietInsertFeature $quietInsertFeature,
+        private PostgreSqlDriverUpdateFeature $updateFeature,
+        private PostgreSqlDriverDeleteFeature $deleteFeature,
     ) {
         //
     }
@@ -29,21 +29,21 @@ public function insertWithResult(
         InsertBuilder $builder,
         ?string $primaryKeyName,
     ): BulkInsertResult {
-        return $this->insertWithResult->handle($connection, $builder);
+        return $this->insertWithResultFeature->handle($connection, $builder);
     }
 
     public function quietInsert(ConnectionInterface $connection, InsertBuilder $builder): void
     {
-        $this->quietInsert->handle($connection, $builder);
+        $this->quietInsertFeature->handle($connection, $builder);
     }
 
     public function update(ConnectionInterface $connection, UpdateBulkBuilder $builder): int
     {
-        return $this->update->handle($connection, $builder);
+        return $this->updateFeature->handle($connection, $builder);
     }
 
     public function forceDelete(ConnectionInterface $connection, DeleteBulkBuilder $builder): int
     {
-        return $this->delete->handle($connection, $builder);
+        return $this->deleteFeature->handle($connection, $builder);
     }
 }

src/Drivers/SqLite/SqLiteDriverForceDeleteFeature.php

@@ -0,0 +1,33 @@
+<?php
+
+namespace Lapaliv\BulkUpsert\Drivers\SqLite;
+
+use Illuminate\Database\ConnectionInterface;
+use Lapaliv\BulkUpsert\Builders\DeleteBulkBuilder;
+use Lapaliv\BulkUpsert\Converters\MixedValueToSqlConverter;
+use Lapaliv\BulkUpsert\Grammars\SqLiteGrammar;
+
+/**
+ * @internal
+ */
+class SqLiteDriverForceDeleteFeature
+{
+    public function __construct(
+        private MixedValueToSqlConverter $mixedValueToSqlConverter,
+    ) {
+        //
+    }
+
+    public function handle(
+        ConnectionInterface $connection,
+        DeleteBulkBuilder $builder,
+    ): int {
+        $grammar = new SqLiteGrammar($this->mixedValueToSqlConverter);
+
+        $result = $connection->delete($grammar->delete($builder), $grammar->getBindings());
+
+        unset($grammar);
+
+        return $result;
+    }
+}

src/Drivers/SqLite/SqLiteDriverInsertWithResultFeature.php

@@ -0,0 +1,51 @@
+<?php
+
+namespace Lapaliv\BulkUpsert\Drivers\SqLite;
+
+use Illuminate\Database\ConnectionInterface;
+use Lapaliv\BulkUpsert\Builders\InsertBuilder;
+use Lapaliv\BulkUpsert\Converters\MixedValueToSqlConverter;
+use Lapaliv\BulkUpsert\Entities\BulkSqLiteInsertResult;
+use Lapaliv\BulkUpsert\Grammars\SqLiteGrammar;
+
+class SqLiteDriverInsertWithResultFeature
+{
+    public function __construct(
+        private MixedValueToSqlConverter $mixedValueToSqlConverter,
+    ) {
+        //
+    }
+
+    public function handle(
+        ConnectionInterface $connection,
+        InsertBuilder $builder,
+        ?string $primaryKeyName,
+    ): BulkSqLiteInsertResult {
+        $lastPrimaryBeforeInserting = null;
+
+        if ($primaryKeyName !== null) {
+            $lastRow = $connection->selectOne(
+                sprintf(
+                    'select max(%s) as id from %s',
+                    $primaryKeyName,
+                    $builder->getInto()
+                )
+            );
+
+            $lastPrimaryBeforeInserting = $lastRow->id ?? 0;
+        }
+
+        $grammar = new SqLiteGrammar($this->mixedValueToSqlConverter);
+        $sql = $grammar->insert($builder);
+        $bindings = $grammar->getBindings();
+        $connection->insert($sql, $bindings);
+
+        unset($grammar);
+
+        return new BulkSqLiteInsertResult(
+            is_numeric($lastPrimaryBeforeInserting)
+                ? (int) $lastPrimaryBeforeInserting
+                : null
+        );
+    }
+}

src/Drivers/SqLite/SqLiteDriverQuietInsertFeature.php

@@ -0,0 +1,33 @@
+<?php
+
+/** @noinspection PhpPluralMixedCanBeReplacedWithArrayInspection */
+
+/** @noinspection PhpArrayShapeAttributeCanBeAddedInspection */
+
+namespace Lapaliv\BulkUpsert\Drivers\SqLite;
+
+use Illuminate\Database\ConnectionInterface;
+use Lapaliv\BulkUpsert\Builders\InsertBuilder;
+use Lapaliv\BulkUpsert\Converters\MixedValueToSqlConverter;
+use Lapaliv\BulkUpsert\Grammars\SqLiteGrammar;
+
+/**
+ * @internal
+ */
+class SqLiteDriverQuietInsertFeature
+{
+    public function __construct(
+        private MixedValueToSqlConverter $mixedValueToSqlConverter,
+    ) {
+        //
+    }
+
+    public function handle(ConnectionInterface $connection, InsertBuilder $builder): void
+    {
+        $grammar = new SqLiteGrammar($this->mixedValueToSqlConverter);
+
+        $connection->insert($grammar->insert($builder), $grammar->getBindings());
+
+        unset($grammar);
+    }
+}

src/Drivers/SqLite/SqLiteDriverUpdateFeature.php

@@ -0,0 +1,33 @@
+<?php
+
+namespace Lapaliv\BulkUpsert\Drivers\SqLite;
+
+use Illuminate\Database\ConnectionInterface;
+use Lapaliv\BulkUpsert\Builders\UpdateBulkBuilder;
+use Lapaliv\BulkUpsert\Converters\MixedValueToSqlConverter;
+use Lapaliv\BulkUpsert\Grammars\SqLiteGrammar;
+
+/**
+ * @internal
+ */
+class SqLiteDriverUpdateFeature
+{
+    public function __construct(
+        private MixedValueToSqlConverter $mixedValueToSqlConverter
+    ) {
+        //
+    }
+
+    public function handle(
+        ConnectionInterface $connection,
+        UpdateBulkBuilder $builder,
+    ): int {
+        $grammar = new SqLiteGrammar($this->mixedValueToSqlConverter);
+
+        $result = $connection->update($grammar->update($builder), $grammar->getBindings());
+
+        unset($grammar);
+
+        return $result;
+    }
+}