ydb

Documentation

Overview

Package ydb contains code specific for YDB database.

Index

• func ErrorCheckerQuery(err error) bool
• func NewConnectionManager(cfg *config.TYdbConfig, base rdbms_utils.ConnectionManagerBase) rdbms_utils.ConnectionManager
• func NewSQLFormatter(mode config.TYdbConfig_Mode) rdbms_utils.SQLFormatter
• func NewSchemaProvider(typeMapper datasource.TypeMapper, preffixGetter PrefixGetter) rdbms_utils.SchemaProvider
• func NewTypeMapper() datasource.TypeMapper
• type PrefixGetter
  • func NewPrefixGetter() PrefixGetter

Functions

func ErrorCheckerQuery

func ErrorCheckerQuery(err error) bool

func NewConnectionManager

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

func NewSQLFormatter

func NewSQLFormatter(mode config.TYdbConfig_Mode) rdbms_utils.SQLFormatter

func NewSchemaProvider

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

func NewTypeMapper

func NewTypeMapper() datasource.TypeMapper

Types

type PrefixGetter

type PrefixGetter interface {
	GetPrefix(
		ctx context.Context,
		logger *zap.Logger,
		driver *ydb.Driver,
		request *api_service_protos.TDescribeTableRequest) (string, error)
}

func NewPrefixGetter

func NewPrefixGetter() PrefixGetter