xsql

package
v3.76.5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 14, 2024 License: Apache-2.0 Imports: 33 Imported by: 0

Documentation

Index

Constants

View Source
const (
	UnknownQueryMode = QueryMode(iota)
	DataQueryMode
	ExplainQueryMode
	ScanQueryMode
	SchemeQueryMode
	ScriptingQueryMode

	DefaultQueryMode = DataQueryMode
)

Variables

View Source
var (
	ErrUnsupported = driver.ErrSkip
)

Functions

func WithQueryMode

func WithQueryMode(ctx context.Context, m QueryMode) context.Context

WithQueryMode returns a copy of context with given QueryMode

func WithTxControl

func WithTxControl(ctx context.Context, txc *table.TransactionControl) context.Context

func WithTxControlHook added in v3.54.0

func WithTxControlHook(ctx context.Context, hook txControlHook) context.Context

Types

type ConnAlreadyHaveTxError added in v3.57.0

type ConnAlreadyHaveTxError struct {
	// contains filtered or unexported fields
}

func (*ConnAlreadyHaveTxError) As added in v3.57.0

func (err *ConnAlreadyHaveTxError) As(target interface{}) bool

func (*ConnAlreadyHaveTxError) Error added in v3.57.0

func (err *ConnAlreadyHaveTxError) Error() string

type Connector

type Connector struct {
	Bindings bind.Bindings
	// contains filtered or unexported fields
}

Connector is a producer of database/sql connections

func Open

func Open(parent ydbDriver, opts ...ConnectorOption) (_ *Connector, err error)

func Unwrap

func Unwrap[T *sql.DB | *sql.Conn](v T) (connector *Connector, err error)

func (*Connector) Close

func (c *Connector) Close() (err error)

func (*Connector) Connect

func (c *Connector) Connect(ctx context.Context) (_ driver.Conn, err error)

func (*Connector) Driver

func (c *Connector) Driver() driver.Driver

type ConnectorOption

type ConnectorOption interface {
	Apply(c *Connector) error
}

func WithDefaultDataQueryOptions

func WithDefaultDataQueryOptions(opts ...options.ExecuteDataQueryOption) ConnectorOption

func WithDefaultQueryMode

func WithDefaultQueryMode(mode QueryMode) ConnectorOption

func WithDefaultScanQueryOptions

func WithDefaultScanQueryOptions(opts ...options.ExecuteScanQueryOption) ConnectorOption

func WithDefaultTxControl

func WithDefaultTxControl(txControl *table.TransactionControl) ConnectorOption

func WithDisableServerBalancer added in v3.42.4

func WithDisableServerBalancer() ConnectorOption

func WithFakeTx added in v3.44.0

func WithFakeTx(m QueryMode) ConnectorOption

WithFakeTx returns a copy of context with given QueryMode

func WithIdleThreshold added in v3.42.5

func WithIdleThreshold(idleThreshold time.Duration) ConnectorOption

func WithOnClose added in v3.44.0

func WithOnClose(f func(connector *Connector)) ConnectorOption

func WithTrace added in v3.34.0

func WithTraceRetry added in v3.54.0

func WithTraceRetry(t *trace.Retry) ConnectorOption

func WithretryBudget added in v3.66.0

func WithretryBudget(b budget.Budget) ConnectorOption

type QueryBindConnectorOption added in v3.44.0

type QueryBindConnectorOption interface {
	ConnectorOption
	bind.Bind
}

func WithQueryBind added in v3.44.0

func WithQueryBind(bind bind.Bind) QueryBindConnectorOption

func WithTablePathPrefix added in v3.44.0

func WithTablePathPrefix(tablePathPrefix string) QueryBindConnectorOption

type QueryMode

type QueryMode int

func QueryModeFromString

func QueryModeFromString(s string) QueryMode

func (QueryMode) String

func (t QueryMode) String() string

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL