postgres

package

v1.0.0 Latest Latest Go to latest Published: Apr 28, 2026 License: Apache-2.0 Imports: 8 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func Create(config config.DatabaseConnectionConfig) *Client

func (client *Client) Close()

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

func CreateDataLoader(client *Client) *DataLoader

func (l *DataLoader) LoadData(ctx context.Context, schema string, table string, columns []string, fetcher domain.ChunkIterator) error

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

func CreateTableRepository(client *Client) *TableRepository

func (r *TableRepository) CreateTable(ctx context.Context, schema string, table string, columns []domain.Field) error

func (r *TableRepository) IsTableExist(ctx context.Context, schema string, table string) (bool, error)

func (r *TableRepository) TruncateTable(ctx context.Context, schema string, table string) error