From 992d10abfea35c3f69c461bd353fab5faa16178f Mon Sep 17 00:00:00 2001 From: Marcus Goldschmidt Date: Sat, 25 Apr 2026 12:44:57 -0400 Subject: [PATCH 1/2] add rows affected and query idx for ErrQueryAffectedMoreThanOneRow --- pkg/bsql/query.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/bsql/query.go b/pkg/bsql/query.go index 4c05568c..dc5a1695 100644 --- a/pkg/bsql/query.go +++ b/pkg/bsql/query.go @@ -375,7 +375,7 @@ func (s *SQLSyncer) RunProvisioningQueries(ctx context.Context, queries, validat zeroRowCount := 0 - for _, q := range queries { + for idx, q := range queries { q, qArgs, err := s.prepareProvisioningQuery(q, vars) if err != nil { return fmt.Errorf("failed to prepare query: %w", err) @@ -392,7 +392,7 @@ func (s *SQLSyncer) RunProvisioningQueries(ctx context.Context, queries, validat } if rowsAffected > 1 { - return ErrQueryAffectedMoreThanOneRow + return fmt.Errorf("provisioning query affected rows %d > 1, query idx: %d error: %w", rowsAffected, idx, ErrQueryAffectedMoreThanOneRow) } if rowsAffected == 0 { From c02d76a380d1e4bf2a6635f146f23a9d9d7e2dd8 Mon Sep 17 00:00:00 2001 From: Marcus Goldschmidt Date: Sat, 25 Apr 2026 12:51:03 -0400 Subject: [PATCH 2/2] fix msg error --- pkg/bsql/query.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/bsql/query.go b/pkg/bsql/query.go index dc5a1695..3782df79 100644 --- a/pkg/bsql/query.go +++ b/pkg/bsql/query.go @@ -392,7 +392,7 @@ func (s *SQLSyncer) RunProvisioningQueries(ctx context.Context, queries, validat } if rowsAffected > 1 { - return fmt.Errorf("provisioning query affected rows %d > 1, query idx: %d error: %w", rowsAffected, idx, ErrQueryAffectedMoreThanOneRow) + return fmt.Errorf("provisioning query at index %d affected %d rows: %w", idx, rowsAffected, ErrQueryAffectedMoreThanOneRow) } if rowsAffected == 0 {