insertOrgnore support

Author: phpfui

src/PHPFUI/ORM/Migration.php

@@ -294,9 +294,17 @@ protected function dropViews(array $views) : void
 	/**
 	 * Add an index on the fields in the array.
 	 */
-	protected function addIndex(string $table, array $fields, string $indexType = '') : bool
+	protected function addIndex(string $table, string | array $fields, string $indexType = '') : bool
 		{
-		$indexName = \implode('', $fields) . $table . 'Index';
+		if (\is_string($fields))
+			{
+			$indexName = $fields;
+			$fields = [$fields];
+			}
+		else
+			{
+			$indexName = \implode('', $fields) . $table . 'Index';
+			}
 
 		if ($this->indexExists($table, $indexName))
 			{

src/PHPFUI/ORM/PDOInstance.php

@@ -303,7 +303,7 @@ public function executeStatement(\PDOStatement $statement, array $input = []) :
 			{
 			$returnValue = $statement->execute($input);
 			}
-		catch (\Throwable)
+		catch (\PDOException)
 			{
 			$returnValue = false;
 			}

src/PHPFUI/ORM/Record.php

@@ -407,6 +407,16 @@ public function insertOrUpdate() : int | bool
 		return $this->privateInsert(true);
 		}
 
+	/**
+	 * Inserts current data into table or ignores duplicate key if found
+	 *
+	 * @return int | bool inserted id if auto increment, true on insertion if not auto increment or false on error
+	 */
+	public function insertOrIgnore() : int | bool
+		{
+		return $this->privateInsert(false, 'ignore ');
+		}
+
 	/**
 	 * Load first from SQL query
 	 */
@@ -782,12 +792,12 @@ private function getChildTable(string $relationship) : ?\PHPFUI\ORM\Table
 	 *
 	 * @return int | bool inserted id if auto increment, true on insertion if not auto increment or false on error
 	 */
-	private function privateInsert(bool $updateOnDuplicate) : int | bool
+	private function privateInsert(bool $updateOnDuplicate, string $ignore = '') : int | bool
 		{
 		$this->clean();
 		$table = static::$table;
 
-		$sql = "insert into `{$table}` (";
+		$sql = "insert {$ignore}into `{$table}` (";
 		$values = [];
 		$whereInput = $input = [];
 		$comma = '';
@@ -817,8 +827,9 @@ private function privateInsert(bool $updateOnDuplicate) : int | bool
 
 		if ($updateOnDuplicate)
 			{
-			$sql .= ' on duplicate key update ';
+			$updateSql = ' on duplicate key update ';
 			$comma = '';
+			$inputCount = count($input);
 
 			foreach ($this->current as $key => $value)
 				{
@@ -833,12 +844,20 @@ private function privateInsert(bool $updateOnDuplicate) : int | bool
 
 					if (! isset(static::$primaryKeys[$key]))
 						{
-						$sql .= $comma . '`' . $key . '` = ?';
+						$updateSql .= $comma . '`' . $key . '` = ?';
 						$input[] = $value;
 						$comma = ',';
 						}
 					}
 				}
+			if (count($input) == $inputCount) // nothing to update but primary keys, ignore input
+				{
+				$sql = str_replace('insert into', 'insert ignore into', $sql);
+				}
+			else
+				{
+				$sql .= $updateSql;
+				}
 			}
 
 		$returnValue = \PHPFUI\ORM::execute($sql, $input);

src/PHPFUI/ORM/Record/Definition/Migration.php

@@ -15,9 +15,9 @@ abstract class Migration extends \PHPFUI\ORM\Record
 
 	/** @var array<string, array<mixed>> */
 	protected static array $fields = [
-		// MYSQL_TYPE, PHP_TYPE, LENGTH, NULL, DEFAULT, KEY
-		'migrationId' => ['int(11)', 'int', 11, false, null, true, ],
-		'ran' => ['timestamp', 'string', 20, true, '', false, ],
+		// MYSQL_TYPE, PHP_TYPE, LENGTH, KEY, ALLOWS_NULL, DEFAULT
+		'migrationId' => ['int(11)', 'int', 11, true, false, ],
+		'ran' => ['timestamp', 'string', 20, false, false, ],
 	];
 
 	/** @var array<string, true> */