Add FluentSQLKitExtras utilities for SQLInsertBuilder.ignoringConflicts(with:) and SQLInsertBuilder.onConflict(with:do:)

Author: gwynne

Sources/SQLKitExtras/FluentSQLKitExtras/Builders/SQLInsertBuilder+FluentKeypaths.swift

@@ -18,6 +18,29 @@ extension SQLInsertBuilder {
         }
         return self
     }
+
+    /// Allow specifying a column or columns for ignoring insert conflicts using Fluent model keypaths.
+    @discardableResult
+    public func ignoringConflicts<each F: Fields, each P: QueryAddressableProperty>(with keypaths: repeat KeyPath<each F, each P>) -> Self {
+        var identifiers: [SQLIdentifier] = []
+        for keypath in repeat each keypaths {
+            identifiers.append(.identifier(keypath))
+        }
+        return self.ignoringConflicts(with: identifiers)
+    }
+
+    /// Allow specifying a column or columns for resolving insert conflicts using Fluent model keypaths.
+    @discardableResult
+    public func onConflict<each F: Fields, each P: QueryAddressableProperty>(
+        with keypaths: repeat KeyPath<each F, each P>,
+        `do` updatePredicate: (SQLConflictUpdateBuilder) throws -> SQLConflictUpdateBuilder
+    ) rethrows -> Self {
+        var identifiers: [SQLIdentifier] = []
+        for keypath in repeat each keypaths {
+            identifiers.append(.identifier(keypath))
+        }
+        return try self.onConflict(with: identifiers, do: updatePredicate)
+    }
 }
 
 extension SQLDatabase {

Tests/SQLKitExtrasTests/FluentSQLKitExtrasTests.swift

@@ -164,6 +164,8 @@ struct FluentSQLKitExtrasTests {
         @Test
         func insertBuilderExtensions() {
             #expect(serialize(MockSQLDatabase().insert(into: FooModel.self).columns(\FooModel.$field, \FooModel.$parent)) == #"INSERT INTO "foos" ("field", "parent_id")"#)
+            #expect(serialize(MockSQLDatabase().insert(into: FooModel.self).ignoringConflicts(with: \FooModel.$field)) == #"INSERT INTO "foos" () ON CONFLICT ("field") DO NOTHING"#)
+            #expect(serialize(MockSQLDatabase().insert(into: FooModel.self).onConflict(with: \FooModel.$field, do: { $0 })) == #"INSERT INTO "foos" () ON CONFLICT ("field") DO UPDATE SET"#)
         }
 
         @Test