diff options
Diffstat (limited to 'internal/database')
| -rw-r--r-- | internal/database/database.go | 5 |
1 files changed, 1 insertions, 4 deletions
diff --git a/internal/database/database.go b/internal/database/database.go index 5fd3af9e..917b6094 100644 --- a/internal/database/database.go +++ b/internal/database/database.go @@ -520,10 +520,7 @@ func (db *DB) BulkUpdate(ctx context.Context, table string, columns, types []str } query := buildBulkUpdateQuery(table, columns, types) for left := 0; left < nRows; left += maxBulkUpdateArrayLen { - right := left + maxBulkUpdateArrayLen - if right > nRows { - right = nRows - } + right := min(left+maxBulkUpdateArrayLen, nRows) var args []any for _, vs := range values { args = append(args, pq.Array(vs[left:right])) |