Method NewQuery

core/db_builder.go:151–160

NewQuery implements the [dbx.Builder.NewQuery] interface method by routing the SELECT queries to the concurrent builder instance.

(str string)

// NewQuery implements the [dbx.Builder.NewQuery] interface method by
// routing the SELECT queries to the concurrent builder instance.
func (b *dualDBBuilder) NewQuery(str string) *dbx.Query {
	// note: technically INSERT/UPDATE/DELETE could also have CTE but since
	// it is rare for now this scase is ignored to avoid unnecessary complicating the checks
	trimmed := trimLeftSpaces(str)
	if hasPrefixFold(trimmed, "SELECT") || hasPrefixFold(trimmed, "WITH") {
		return b.concurrentDB.NewQuery(str)
	}

	return b.nonconcurrentDB.NewQuery(str)
}

var asciiSpace = [256]uint8{'\t': 1, '\n': 1, '\v': 1, '\f': 1, '\r': 1, ' ': 1}