sqlexec

func AppendFloat64 ¶

func AppendFloat64(buf []byte, value float64, bitSize int) []byte

AppendFloat64 appends a float64 value, handling infinities.

func AppendHex ¶

func AppendHex(dst []byte, src []byte) []byte

AppendHex appends hex-encoded binary literal to buf.

func AppendInt64 ¶

func AppendInt64(buf []byte, value int64) []byte

AppendInt64 appends an int64 value as decimal text.

func AppendUint64 ¶

func AppendUint64(buf []byte, value uint64) []byte

AppendUint64 appends a uint64 value as decimal text.

func AppendVectorSQLLiteral ¶

func AppendVectorSQLLiteral(ctx context.Context, vec *vector.Vector, row int, buf []byte) ([]byte, error)

AppendVectorSQLLiteral appends the SQL literal representation of vec[row] to buf.

func BuildExactPkFilter ¶

func BuildExactPkFilter(ctx context.Context, vec *vector.Vector) (string, error)

BuildExactPkFilter converts a vector of primary key values into a comma-separated SQL literal string suitable for use in an IN (...) clause.

func GetTxn ¶

func GetTxn(
	ctx context.Context,
	cnEngine engine.Engine,
	cnTxnClient client.TxnClient,
	info string,
) (client.TxnOperator, error)

func RunSql ¶

func RunSql(sqlproc *SqlProcess, sql string) (executor.Result, error)

run SQL in batch mode. Result batches will stored in memory and return once all result batches received.

func RunStreamingSql ¶

func RunStreamingSql(
	ctx context.Context,
	sqlproc *SqlProcess,
	sql string,
	stream_chan chan executor.Result,
	error_chan chan error,
) (executor.Result, error)

run SQL in WithStreaming() and pass the channel to SQL executor

func RunTxn ¶

func RunTxn(sqlproc *SqlProcess, execFunc func(executor.TxnExecutor) error) error

run SQL in batch mode. Result batches will stored in memory and return once all result batches received.

func RunTxnWithSqlContext ¶

func RunTxnWithSqlContext(ctx context.Context,
	cnEngine engine.Engine,
	cnTxnClient client.TxnClient,
	cnUUID string,
	accountId uint32,
	duration time.Duration,
	resolveVariableFunc func(varName string, isSystemVar, isGlobalVar bool) (interface{}, error),
	cbdata any,
	f func(sqlproc *SqlProcess, data any) error) (err error)

run SQL with SqlContext

func WaitUniqueJoinKeys ¶

func WaitUniqueJoinKeys(sqlproc *SqlProcess) ([]byte, error)

WaitUniqueJoinKeys blocks until it receives a RuntimeFilter_UNIQUEJOINKEYS message that matches sqlproc.RuntimeFilterSpecs (if any). It returns the raw serialized unique join key bytes from the build side.

The caller is responsible for deserializing the bytes and deciding how to use them (e.g. exact pk IN filter vs a membership filter based on its own threshold).