database

package

v0.3.0 Latest Latest Go to latest Published: Nov 20, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Batch = data.Batch

type Column = data.Column

func MapToMvrColumns(columns []*sql.ColumnType) []Column

type DataStream = data.DataStream

type PGDataReader struct {
	Pool *pgxpool.Pool
}

func NewPGDataReader(connUrl *url.URL) (*PGDataReader, error)

func (pool *PGDataReader) Close() error

func (pool *PGDataReader) CreateDataStream(connUrl *url.URL, config *data.StreamConfig) (ds *DataStream, err error)

func (pool *PGDataReader) ExecuteDataStream(ctx context.Context, ds *DataStream, config *data.StreamConfig) error

type SnowflakeDataReader struct {
	Snowflake *sqlx.DB
}

func NewSnowflakeDataReader(connUrl *url.URL) (*SnowflakeDataReader, error)

func (sf *SnowflakeDataReader) Close() error

func (sf *SnowflakeDataReader) CreateDataStream(connUrl *url.URL, config *data.StreamConfig) (ds *DataStream, err error)

func (sf *SnowflakeDataReader) ExecuteDataStream(ctx context.Context, ds *DataStream, config *data.StreamConfig) error