feat: added InsertOnDuplicate sql generator

Author: IvanChepurnyi

src/Sql/InsertOnDuplicate.php

@@ -0,0 +1,40 @@
+<?php
+
+namespace EcomDev\MySQL2JSONL\Sql;
+
+class InsertOnDuplicate
+{
+    public function generate(string $tableName, array $columns, int $rowCount, $onUpdate = []): string
+    {
+        $sqlOnUpdate = '';
+
+        if ($onUpdate) {
+            $sqlOnUpdate = sprintf(
+                ' ON DUPLICATE KEY UPDATE %s',
+                implode(
+                    ',',
+                    array_map(fn ($column) => "`$column` = VALUES(`$column`)", $onUpdate)
+                )
+            );
+        }
+
+        $rowLine = rtrim(str_repeat('?,', count($columns)), ',');
+        $rowLines = str_repeat(
+            "($rowLine),",
+            $rowCount
+        );
+
+        $sql = sprintf(
+            'INSERT INTO `%s` (%s) VALUES %s%s',
+            $tableName,
+            implode(',', array_map(fn ($column) => "`$column`", $columns)),
+            rtrim(
+                $rowLines,
+                ','
+            ),
+            $sqlOnUpdate
+        );
+
+        return $sql;
+    }
+}

tests/Sql/InsertOnDuplicateTest.php

@@ -0,0 +1,44 @@
+<?php
+
+namespace EcomDev\MySQL2JSONL\Sql;
+
+use PHPUnit\Framework\Attributes\Test;
+use PHPUnit\Framework\TestCase;
+
+class InsertOnDuplicateTest extends TestCase
+{
+    #[Test]
+    public function generatesSingleRow()
+    {
+        $this->assertEquals(
+            'INSERT INTO `table1` (`column_one`,`column_two`) VALUES (?,?)',
+            (new InsertOnDuplicate())
+                ->generate('table1', ['column_one', 'column_two'], 1)
+        );
+    }
+
+    #[Test]
+    public function generatesMultipleRows()
+    {
+        $this->assertEquals(
+            'INSERT INTO `table1` (`column_one`,`column_two`) VALUES (?,?),(?,?),(?,?)',
+            (new InsertOnDuplicate())
+                ->generate('table1', ['column_one', 'column_two'], 3)
+        );
+    }
+
+    #[Test]
+    public function generatesSingleRowWithOnDuplicate()
+    {
+        $this->assertEquals(
+            'INSERT INTO `table1` (`column_one`,`column_two`) VALUES (?,?) ON DUPLICATE KEY UPDATE `column_two` = VALUES(`column_two`)',
+            (new InsertOnDuplicate())
+                ->generate(
+                    'table1',
+                    ['column_one', 'column_two'],
+                    1,
+                    ['column_two']
+                )
+        );
+    }
+}