// Using query builder directly
sql := NewQueryBuilder(db, subject).SetColumns(columns).Insert()
db.NamedBulkExec(ctx, sql, ch)

// Functional options
db.Upsert(ctx, ch, options.SetColumns(columns))

// Using query builder directly #2
upsert := qb.Upsert(subject).Columns(columns)
db.NamedBulkExec(ctx, upsert, ch)
// or
upsert.Stream(ctx, db, ch)

db.Upsert().Columns(columns).Exec() // .Stream()

qb.Upsert().Columns().Exec(ctx, db, setofData) // .Stream(ctx, db, ch)