From 4a659fd5c4ea50a805adefa22e1ef42a605c42b9 Mon Sep 17 00:00:00 2001
From: Eric Lippmann <eric.lippmann@icinga.com>
Date: Tue, 3 Aug 2021 08:45:25 +0200
Subject: [PATCH] Add db.BuildIgnoreStmt()

---
 pkg/icingadb/db.go | 14 ++++++++++++++
 1 file changed, 14 insertions(+)

diff --git a/pkg/icingadb/db.go b/pkg/icingadb/db.go
index 247be2a6..985990ff 100644
--- a/pkg/icingadb/db.go
+++ b/pkg/icingadb/db.go
@@ -111,6 +111,20 @@ func (db *DB) BuildInsertStmt(into interface{}) (string, int) {
 	), len(columns)
 }
 
+// BuildInsertIgnoreStmt returns an INSERT statement for the specified struct for
+// which the database ignores rows that have already been inserted.
+func (db *DB) BuildInsertIgnoreStmt(into interface{}) (string, int) {
+	columns := db.BuildColumns(into)
+
+	return fmt.Sprintf(
+		// MySQL treats UPDATE id = id as a no-op.
+		`INSERT INTO %s (%s) VALUES (%s) ON DUPLICATE KEY UPDATE id = id`,
+		utils.TableName(into),
+		strings.Join(columns, ", "),
+		fmt.Sprintf(":%s", strings.Join(columns, ", :")),
+	), len(columns)
+}
+
 // BuildSelectStmt returns a SELECT query that creates the FROM part from the given table struct
 // and the column list from the specified columns struct.
 func (db *DB) BuildSelectStmt(table interface{}, columns interface{}) string {