package query

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

Index ¶

• Constants
• Variables
• type Client
• func New(ctx context.Context, balancer balancer, config *config.Config) (*Client, error)
• func (c Client) Close(ctx context.Context) error
• func (c Client) Do(ctx context.Context, op query.Operation, opts ...options.DoOption) error
• func (c Client) DoTx(ctx context.Context, op query.TxOperation, opts ...options.DoTxOption) error
• type Session
• func (s *Session) Begin(ctx context.Context, txSettings query.TransactionSettings) (query.Transaction, error)
• func (s *Session) Close(ctx context.Context) error
• func (s *Session) Execute( ctx context.Context, q string, opts ...options.ExecuteOption, ) (query.Transaction, query.Result, error)
• func (s *Session) ID() string
• func (s *Session) NodeID() int64
• func (s *Session) Status() string

Constants ¶

const (
	SessionStatusUnknown = sessionStatus(iota)
	SessionStatusReady
	SessionStatusInUse
	SessionStatusClosed
)

Variables ¶

var (
	ErrNotImplemented = errors.New("not implemented yet")
)

Types ¶

type Client ¶

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

func New ¶

func New(ctx context.Context, balancer balancer, config *config.Config) (*Client, error)

func (Client) Close ¶

func (c Client) Close(ctx context.Context) error

func (Client) Do ¶

func (c Client) Do(ctx context.Context, op query.Operation, opts ...options.DoOption) error

func (Client) DoTx ¶

func (c Client) DoTx(ctx context.Context, op query.TxOperation, opts ...options.DoTxOption) error

type Session ¶

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

func (*Session) Begin ¶

func (s *Session) Begin(ctx context.Context, txSettings query.TransactionSettings) (query.Transaction, error)

func (*Session) Close ¶

func (s *Session) Close(ctx context.Context) error

func (*Session) Execute ¶

func (s *Session) Execute(
	ctx context.Context, q string, opts ...options.ExecuteOption,
) (query.Transaction, query.Result, error)

func (*Session) ID ¶

func (s *Session) ID() string

func (*Session) NodeID ¶

func (s *Session) NodeID() int64

func (*Session) Status ¶

func (s *Session) Status() string

Source Files ¶

client.go errors.go execute_query.go result.go result_set.go row.go session.go session_status.go transaction.go

Directories ¶