db

package

v1.0.0 Latest Latest Go to latest Published: Apr 19, 2023 License: Apache-2.0 Imports: 18 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

var ErrCursorNotFound = errors.New("cursor not found")

This section is empty.

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

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

type Loader struct {
	*sql.DB

	EntriesCount uint64
	// contains filtered or unexported fields
}

func NewLoader(psqlDsn string, logger *zap.Logger, tracer logging.Tracer) (*Loader, error)

func (l *Loader) Delete(tableName string, primaryKey string) error

Delete a row in the DB, it is assumed the table exists, you can do a check before with HasTable()

func (l *Loader) Flush(ctx context.Context, moduleHash string, cursor *sink.Cursor) (err error)

func (l *Loader) GetAvailableTablesInSchema() string

func (l *Loader) GetCursor(ctx context.Context, outputModuleHash string) (*sink.Cursor, error)

func (l *Loader) GetIdentifier() string

GetIdentifier returns <database>/<schema> suitable for user presentation

func (l *Loader) GetSchema() string

func (l *Loader) HasTable(tableName string) bool

func (l *Loader) Insert(tableName string, primaryKey string, data map[string]string) error

Insert a row in the DB, it is assumed the table exists, you can do a check before with HasTable()

func (l *Loader) LoadTables() error

func (l *Loader) MarshalLogObject(encoder zapcore.ObjectEncoder) error

func (l *Loader) Setup(ctx context.Context, schemaFile string) error

func (l *Loader) Update(tableName string, primaryKey string, data map[string]string) error

Update a row in the DB, it is assumed the table exists, you can do a check before with HasTable()

func (l *Loader) UpdateCursorQuery(moduleHash string, c *sink.Cursor) string

func (l *Loader) WriteCursor(ctx context.Context, moduleHash string, c *sink.Cursor) error

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

func (o *Operation) String() string

type OperationType string

const (
	OperationTypeInsert OperationType = "INSERT"
	OperationTypeUpdate OperationType = "UPDATE"
	OperationTypeDelete OperationType = "DELETE"
)

type Queryable interface {
	// contains filtered or unexported methods
}

type TypeGetter func(tableName string, columnName string) (reflect.Type, error)