database

type DB struct {
	Master                *sqlx.DB
	Slave                 *sqlx.DB
	Logger                *logger.Logger
	Config                DatabaseConfig
	Debug                 bool
	IsStopCheckConnection chan bool
	Scope                 string
}

type DatabaseConfig struct {
	DriverName              string
	SourceMaster            string
	SourceSlave             string
	MaxOpenConns            int
	MaxIdleConns            int
	ConnMaxLifetime         int
	IntervalCheckConnection int
}

type IDatabase interface {
	GetMasterConnection() (*sqlx.DB, error)

	CreateDBTransaction(ctx context.Context) (tx *sqlx.Tx, err error)
	CommitDBTransaction(ctx context.Context, tx *sqlx.Tx) (err error)
	Write(ctx context.Context, tx *sqlx.Tx, query string, params map[string]interface{}) (err error)
	Read(ctx context.Context, query string, params map[string]interface{}) (rows *sqlx.Rows, err error)
}