DB#Upsert(): workaround jmoiron/sqlx#694

Icinga · Apr 12, 2021 · 6ad6088 · 6ad6088
1 parent 9cefcb4
commit 6ad6088
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/icingadb/db.go b/icingadb/db.go
@@ -366,8 +366,11 @@ func (db DB) Upsert(ctx context.Context, entities <-chan contracts.Entity, succe
 		return err
 	}
 
-	stmt, placeholders := db.BuildUpsertStmt(first)
-	return db.NamedBulkExec(ctx, stmt, 1<<15/placeholders, 1<<3, forward, succeeded)
+	// TODO(ak): wait for https://github.com/jmoiron/sqlx/issues/694
+	//stmt, placeholders := db.BuildUpsertStmt(first)
+	//return db.NamedBulkExec(ctx, stmt, 1<<15/placeholders, 1<<3, forward, succeeded)
+	stmt, _ := db.BuildUpsertStmt(first)
+	return db.NamedBulkExec(ctx, stmt, 1, 1<<3, forward, succeeded)
 }
 
 func (db DB) Update(ctx context.Context, entities <-chan contracts.Entity) error {