db

Documentation

Index

• type MySQLRepository
  • func NewMySQLRepository(db *sql.DB) *MySQLRepository
  • func (repo *MySQLRepository) GetTableData(sourceTable string) (*sql.Rows, error)
• type PostgresRepository
  • func NewPostgresRepository(pool *pgxpool.Pool) *PostgresRepository
  • func (repo *PostgresRepository) InsertTableData(ctx context.Context, destinationTable string, columns []string, ...) error

Types

type MySQLRepository

type MySQLRepository struct {
	DB *sql.DB
}

func NewMySQLRepository

func NewMySQLRepository(db *sql.DB) *MySQLRepository

func (*MySQLRepository) GetTableData

func (repo *MySQLRepository) GetTableData(sourceTable string) (*sql.Rows, error)

type PostgresRepository

type PostgresRepository struct {
	Pool *pgxpool.Pool
}

func NewPostgresRepository

func NewPostgresRepository(pool *pgxpool.Pool) *PostgresRepository

func (*PostgresRepository) InsertTableData

func (repo *PostgresRepository) InsertTableData(ctx context.Context, destinationTable string, columns []string, values [][]interface{}) error