ydb

Documentation

Overview

Package ydb contains code specific for YDB database.

Index

• func NewConnectionManager(cfg *config.TYdbConfig, base rdbms_utils.ConnectionManagerBase) rdbms_utils.ConnectionManager
• func NewSQLFormatter() rdbms_utils.SQLFormatter
• func NewSchemaProvider(typeMapper datasource.TypeMapper) rdbms_utils.SchemaProvider
• func NewTypeMapper() datasource.TypeMapper
• func RetriableErrorCheckerMakeConnection(_ error) bool
• func RetriableErrorCheckerQuery(err error) bool
• type Connection
  • func (c *Connection) Close() error
  • func (c *Connection) Query(ctx context.Context, query string, args ...any) (rdbms_utils.Rows, error)

Functions

func NewConnectionManager

func NewConnectionManager(
	cfg *config.TYdbConfig,
	base rdbms_utils.ConnectionManagerBase,
) rdbms_utils.ConnectionManager

func NewSQLFormatter

func NewSQLFormatter() rdbms_utils.SQLFormatter

func NewSchemaProvider

func NewSchemaProvider(
	typeMapper datasource.TypeMapper,
) rdbms_utils.SchemaProvider

func NewTypeMapper

func NewTypeMapper() datasource.TypeMapper

func RetriableErrorCheckerMakeConnection

func RetriableErrorCheckerMakeConnection(_ error) bool

func RetriableErrorCheckerQuery

func RetriableErrorCheckerQuery(err error) bool

Types

type Connection

type Connection struct {
	*sql.DB
	// contains filtered or unexported fields
}

func (*Connection) Close

func (c *Connection) Close() error

func (*Connection) Query

func (c *Connection) Query(ctx context.Context, query string, args ...any) (rdbms_utils.Rows, error)