database

package

v0.22.6 Latest Latest Go to latest Published: Feb 2, 2026 License: Apache-2.0 Imports: 17 Imported by: 0

Details

This section is empty.

This section is empty.

func BuildParams(config *data.StreamConfig) []interface{}

type Batch = data.Batch

type Column = data.Column

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

type DataStream = data.DataStream

type MSDataReader struct {
	Conn             *sql.DB
	KeepOriginalUUID bool
}

func NewMSDataReader(connUrl *url.URL) (*MSDataReader, error)

func (reader *MSDataReader) Close() error

func (reader *MSDataReader) CreateDataStream(ctx context.Context, connUrl *url.URL, config *data.StreamConfig) (*DataStream, error)

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

type PGDataReader struct {
	Pool *pgxpool.Pool
}

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

func (pool *PGDataReader) Close() error

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

func (pool *PGDataReader) ExecuteCommand(ctx context.Context, sqlCommand string) (string, error)

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

type SnowflakeDataReader struct {
	Snowflake *sql.DB
}

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

func (sf *SnowflakeDataReader) Close() error

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

func (sf *SnowflakeDataReader) ExecuteCommand(ctx context.Context, sql_command string) (string, error)

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