From 6ad60881f4831a78d5591b6e3cd437225298bd1f Mon Sep 17 00:00:00 2001 From: "Alexander A. Klimov" Date: Thu, 25 Mar 2021 16:51:02 +0100 Subject: [PATCH] DB#Upsert(): workaround jmoiron/sqlx#694 --- icingadb/db.go | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/icingadb/db.go b/icingadb/db.go index b6a2ada..f83e368 100644 --- 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 {