feat: enhance ON DUPLICATE KEY UPDATE handling in Insert class and add related tests

Author: SonyPradana

src/System/Database/MyQuery/Insert.php

@@ -103,8 +103,15 @@ protected function builder(): string
 
     private function getDuplicateKeyUpdate(): string
     {
-        return null === $this->duplicate_key
-            ? ''
-            : 'ON DUPLICATE KEY UPDATE ' . implode(', ', $this->duplicate_key);
+        if (null === $this->duplicate_key) {
+            return '';
+        }
+
+        $keys = [];
+        foreach ($this->duplicate_key as $key => $value) {
+            $keys[] = "{$key} = {$value}";
+        }
+
+        return 'ON DUPLICATE KEY UPDATE ' . implode(', ', $keys);
     }
 }

tests/DataBase/Query/InsertTest.php

@@ -101,4 +101,24 @@ public function itCorrectInsertQueryMultyRaws(): void
             $insert->queryBind()
         );
     }
+
+    /** @test */
+    public function itCorrectInsertOnDuplicateKeyUpdate(): void
+    {
+        $insert = MyQuery::from('test', $this->PDO)
+            ->insert()
+            ->value('a', 1)
+            ->on('a')
+        ;
+
+        $this->assertEquals(
+            'INSERT INTO test (a) VALUES (:bind_a) ON DUPLICATE KEY UPDATE a = VALUES(a)',
+            $insert->__toString()
+        );
+
+        $this->assertEquals(
+            'INSERT INTO test (a) VALUES (1) ON DUPLICATE KEY UPDATE a = VALUES(a)',
+            $insert->queryBind()
+        );
+    }
 }

tests/DataBase/RealDatabase/InsertTest.php

@@ -52,4 +52,71 @@ public function itCanInsertMultyRaw()
         $this->assertUserExist('sony');
         $this->assertUserExist('pradana');
     }
+
+    /**
+     * @test
+     *
+     * @group database
+     */
+    public function itCanReplaceOnExistData()
+    {
+        MyQuery::from('users', $this->pdo)
+            ->insert()
+            ->values([
+                'user' => 'sony',
+                'pwd'  => 'secret',
+                'stat' => 99,
+            ])
+            ->execute();
+
+        MyQuery::from('users', $this->pdo)
+            ->insert()
+            ->values([
+                'user' => 'sony',
+                'pwd'  => 'secret',
+                'stat' => 66,
+            ])
+            ->on('stat')
+            ->execute();
+
+        $this->assertUserStat('sony', 66);
+    }
+
+    /**
+     * @test
+     *
+     * @group database
+     */
+    public function itCanUpdateInsertusingOneQuery()
+    {
+        MyQuery::from('users', $this->pdo)
+            ->insert()
+            ->values([
+                'user' => 'sony',
+                'pwd'  => 'secret',
+                'stat' => 99,
+            ])
+            ->execute();
+
+        MyQuery::from('users', $this->pdo)
+            ->insert()
+            ->rows([
+                [
+                    'user' => 'sony',
+                    'pwd'  => 'secret',
+                    'stat' => 66,
+                ],
+                [
+                    'user' => 'sony2',
+                    'pwd'  => 'secret',
+                    'stat' => 66,
+                ],
+            ])
+            ->on('user')
+            ->on('stat')
+            ->execute();
+
+        $this->assertUserStat('sony', 66);
+        $this->assertUserExist('sony2');
+    }
 }