From 3fbc9fa25fad2f492ebac370738cee4e0a7683a4 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 --- pkg/icingadb/db.go | 7 +++++-- 1 file changed, 5 insertions(+), 2 deletions(-) diff --git a/pkg/icingadb/db.go b/pkg/icingadb/db.go index b6a2ada6..f83e368f 100644 --- a/pkg/icingadb/db.go +++ b/pkg/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 {