package query

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

Index

Variables 

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

Functions

func NewMaterializedResultSet 

func NewMaterializedResultSet(
	index int,
	columnNames []string,
	columnTypes []types.Type,
	rows []query.Row,
) *materializedResultSet

func NewRow 

func NewRow(ctx context.Context, columns []*Ydb.Column, v *Ydb.Value, t *trace.Query) (*row, error)

Types

type Client 

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

func New 

func New(ctx context.Context, balancer grpc.ClientConnInterface, cfg *config.Config) *Client

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) (finalErr error)

func (*Client) DoTx 

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

func (*Client) Execute 

func (c *Client) Execute(ctx context.Context, q string, opts ...options.ExecuteOption) (_ query.Result, err error)

func (*Client) ReadResultSet 

func (c *Client) ReadResultSet(
	ctx context.Context, q string, opts ...options.ExecuteOption,
) (rs query.ResultSet, err error)

ReadResultSet is a helper which read all rows from first result set in result

func (*Client) ReadRow 

func (c *Client) ReadRow(ctx context.Context, q string, opts ...options.ExecuteOption) (row query.Row, err error)

ReadRow is a helper which read only one row from first result set in result

func (*Client) Stats 

func (c *Client) Stats() *pool.Stats

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, err error,
)

func (*Session) Close 

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

func (*Session) Execute 

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

func (*Session) ID 

func (s *Session) ID() string

func (*Session) IsAlive 

func (s *Session) IsAlive() bool

func (*Session) NodeID 

func (s *Session) NodeID() int64

func (*Session) ReadResultSet 

func (s *Session) ReadResultSet(ctx context.Context, q string, opts ...options.ExecuteOption) (
	rs query.ResultSet, _ error,
)

func (*Session) ReadRow 

func (s *Session) ReadRow(ctx context.Context, q string, opts ...options.ExecuteOption) (row query.Row, _ error)

func (*Session) Status 

func (s *Session) Status() string

Source Files

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

Directories

PathSynopsis
internal/query/config
internal/query/options
internal/query/scanner
internal/query/tx
Version
v3.76.1
Published
Jul 29, 2024
Platform
js/wasm
Imports
29 packages
Last checked
3 minutes ago –

Tools for package owners.