Documentation ¶
Index ¶
- Constants
- type DB
- func (db *DB) CheckConnection()
- func (db *DB) Close() error
- func (s *DB) CommitDBTransaction(ctx context.Context, tx *sqlx.Tx) (err error)
- func (s *DB) CreateDBTransaction(ctx context.Context) (tx *sqlx.Tx, err error)
- func (db *DB) GetMasterConnection() (*sqlx.DB, error)
- func (s *DB) Read(ctx context.Context, query string, params map[string]interface{}) (rows *sqlx.Rows, err error)
- func (s *DB) Write(ctx context.Context, tx *sqlx.Tx, query string, params map[string]interface{}) (err error)
- type DatabaseConfig
- type IDatabase
Constants ¶
View Source
const ( Postgres = "postgres" Mysql = "mysql" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DB ¶
type DB struct { Master *sqlx.DB Slave *sqlx.DB Logger *logger.Logger Config DatabaseConfig Debug bool IsStopCheckConnection chan bool Scope string }
func NewDatabase ¶
func (*DB) CheckConnection ¶
func (db *DB) CheckConnection()
func (*DB) CommitDBTransaction ¶
CommitDBTransaction commits database transaction
func (*DB) CreateDBTransaction ¶
CreateDBTransaction creates new database transaction
type DatabaseConfig ¶
type IDatabase ¶
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) }
Click to show internal directories.
Click to hide internal directories.