package xquery

import "github.com/ydb-platform/ydb-go-sdk/v3/internal/xsql/xquery"

Index ¶

• Variables
• type Conn
• func New(ctx context.Context, s *query.Session, opts ...Option) *Conn
• func (c *Conn) Begin() (driver.Tx, error)
• func (c *Conn) BeginTx(ctx context.Context, txOptions driver.TxOptions) (common.Tx, error)
• func (c *Conn) Close() (finalErr error)
• func (c *Conn) Exec(ctx context.Context, sql string, params *params.Params) ( result driver.Result, finalErr error, )
• func (c *Conn) Explain(ctx context.Context, sql string, _ *params.Params) (ast string, plan string, _ error)
• func (c *Conn) ID() string
• func (c *Conn) IsValid() bool
• func (c *Conn) NodeID() uint32
• func (c *Conn) Ping(ctx context.Context) (finalErr error)
• func (c *Conn) Query(ctx context.Context, sql string, params *params.Params) ( result driver.RowsNextResultSet, finalErr error, )
• type Option
• func WithFakeTx() Option
• func WithOnClose(onClose func()) Option
• type Parent

Variables ¶

var (
	ErrUnsupported = driver.ErrSkip
)

Types ¶

type Conn ¶

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

func New ¶

func New(ctx context.Context, s *query.Session, opts ...Option) *Conn

func (*Conn) Begin ¶

func (c *Conn) Begin() (driver.Tx, error)

func (*Conn) BeginTx ¶

func (c *Conn) BeginTx(ctx context.Context, txOptions driver.TxOptions) (common.Tx, error)

func (*Conn) Close ¶

func (c *Conn) Close() (finalErr error)

func (*Conn) Exec ¶

func (c *Conn) Exec(ctx context.Context, sql string, params *params.Params) (
	result driver.Result, finalErr error,
)

func (*Conn) Explain ¶

func (c *Conn) Explain(ctx context.Context, sql string, _ *params.Params) (ast string, plan string, _ error)

func (*Conn) ID ¶

func (c *Conn) ID() string

func (*Conn) IsValid ¶

func (c *Conn) IsValid() bool

func (*Conn) NodeID ¶

func (c *Conn) NodeID() uint32

func (*Conn) Ping ¶

func (c *Conn) Ping(ctx context.Context) (finalErr error)

func (*Conn) Query ¶

func (c *Conn) Query(ctx context.Context, sql string, params *params.Params) (
	result driver.RowsNextResultSet, finalErr error,
)

type Option ¶

type Option func(c *Conn)

func WithFakeTx ¶

func WithFakeTx() Option

func WithOnClose ¶

func WithOnClose(onClose func()) Option

type Parent ¶

type Parent interface {
	Query() *query.Client
}

Source Files ¶

conn.go errors.go isolation.go options.go rows.go tx.go tx_fake.go