xsql

package
v3.66.3 Latest Latest
Warning

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

 Go to latest Published: May 3, 2024 License: Apache-2.0 Imports: 37 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 Parse 

func Parse(dataSourceName string) (opts []config.Option, connectorOpts []ConnectorOption, _ 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 WithTrace(t *trace.DatabaseSQL, opts ...trace.DatabaseSQLComposeOption) ConnectorOption

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.