db

Documentation

Index

• func ConnectSQL(c context.Context, dsn string, pool *config.MyPool) (*sql.DB, error)
• func ExecuteSQLWorker(sql string, app *config.AppConfig, errChan chan error, wg *sync.WaitGroup)
• func InitialiseDatabase(app *config.AppConfig) error
• func NewConn() (*config.Conn, error)

Functions

func ConnectSQL

func ConnectSQL(c context.Context, dsn string, pool *config.MyPool) (*sql.DB, error)

ConnectSQL creates database pool for MySql

func ExecuteSQLWorker

func ExecuteSQLWorker(sql string, app *config.AppConfig, errChan chan error, wg *sync.WaitGroup)

ExecuteSQLWorker this function executes against DB and passing errors through error channel this is not really needed but, I am demonstrating the sql can be run parallel

func InitialiseDatabase

func InitialiseDatabase(app *config.AppConfig) error

func NewConn

func NewConn() (*config.Conn, error)

NewConn connects to the database and generates a connection pool Connection pooling parameters can be accessed using env variables if wanted to