Versions in this module Expand all Collapse all v3 v3.80.13 Sep 25, 2024 v3.80.12 Sep 24, 2024 Changes in this version + var ErrOptionNotForTxExecute = errors.New("option is not for execute on transaction") + var ErrTransactionRollingBack = xerrors.Wrap(errors.New("ydb: the transaction is rolling back")) + func MaterializedResultSet(index int, columnNames []string, columnTypes []types.Type, rows []query.Row) *materializedResultSet + type Client struct + func New(ctx context.Context, cc grpc.ClientConnInterface, cfg *config.Config) *Client + func (c *Client) Close(ctx context.Context) error + func (c *Client) Do(ctx context.Context, op query.Operation, opts ...options.DoOption) (finalErr error) + func (c *Client) DoTx(ctx context.Context, op query.TxOperation, opts ...options.DoTxOption) (finalErr error) + func (c *Client) Exec(ctx context.Context, q string, opts ...options.Execute) (finalErr error) + func (c *Client) ExecuteScript(ctx context.Context, q string, ttl time.Duration, opts ...options.Execute) (op *options.ExecuteScriptOperation, err error) + func (c *Client) FetchScriptResults(ctx context.Context, opID string, opts ...options.FetchScriptOption) (*options.FetchScriptResult, error) + func (c *Client) Query(ctx context.Context, q string, opts ...options.Execute) (r query.Result, err error) + func (c *Client) QueryResultSet(ctx context.Context, q string, opts ...options.Execute) (rs result.ClosableResultSet, finalErr error) + func (c *Client) QueryRow(ctx context.Context, q string, opts ...options.Execute) (_ query.Row, finalErr error) + type Row struct + func NewRow(columns []*Ydb.Column, v *Ydb.Value) *Row + func (r Row) Scan(dst ...interface{}) (err error) + func (r Row) ScanNamed(dst ...scanner.NamedDestination) (err error) + func (r Row) ScanStruct(dst interface{}, opts ...scanner.ScanStructOption) (err error) + type Session struct + func (s *Session) Begin(ctx context.Context, txSettings query.TransactionSettings) (tx query.Transaction, finalErr error) + func (s *Session) Exec(ctx context.Context, q string, opts ...options.Execute) (finalErr error) + func (s *Session) Query(ctx context.Context, q string, opts ...options.Execute) (_ query.Result, finalErr error) + func (s *Session) QueryResultSet(ctx context.Context, q string, opts ...options.Execute) (rs result.ClosableResultSet, finalErr error) + func (s *Session) QueryRow(ctx context.Context, q string, opts ...options.Execute) (_ query.Row, finalErr error) + type Transaction struct + func (tx *Transaction) CommitTx(ctx context.Context) (finalErr error) + func (tx *Transaction) Exec(ctx context.Context, q string, opts ...options.Execute) (finalErr error) + func (tx *Transaction) OnBeforeCommit(f baseTx.OnTransactionBeforeCommit) + func (tx *Transaction) OnCompleted(f baseTx.OnTransactionCompletedFunc) + func (tx *Transaction) Query(ctx context.Context, q string, opts ...options.Execute) (_ query.Result, finalErr error) + func (tx *Transaction) QueryResultSet(ctx context.Context, q string, opts ...options.Execute) (rs result.ClosableResultSet, finalErr error) + func (tx *Transaction) QueryRow(ctx context.Context, q string, opts ...options.Execute) (row query.Row, finalErr error) + func (tx *Transaction) Rollback(ctx context.Context) (finalErr error) + func (tx *Transaction) SessionID() string + func (tx *Transaction) UnLazy(ctx context.Context) error