internal

type Client interface {
	SchemaOfDSN() (schema string)
	Reader() (v *sql.DB)
	Writer() (v *sql.DB)
	Close() (err error)
}

type Config struct {
	Driver                      string   `json:"driver"`
	MasterSlaverMode            bool     `json:"masterSlaverMode"`
	DSN                         []string `json:"dsn"`
	MaxIdles                    int      `json:"maxIdles"`
	MaxOpens                    int      `json:"maxOpens"`
	EnableDebugLog              bool     `json:"enableDebugLog"`
	TransactionMaxAliveDuration string   `json:"transactionMaxAliveDuration"`
	GTMCleanUpSecond            int      `json:"gtmCleanUpSecond"`
	Isolation                   int      `json:"isolation"`
	Dialect                     string   `json:"dialect"`
}

type Database interface {
	service.Component
	Dialect() (name string)
	BeginTransaction(ctx context.Context) (err errors.CodeError)
	CommitTransaction(ctx context.Context) (finished bool, err errors.CodeError)
	RollbackTransaction(ctx context.Context) (err errors.CodeError)
	Query(ctx context.Context, query string, args []interface{}) (rows *sql.Rows, err errors.CodeError)
	Execute(ctx context.Context, query string, args []interface{}) (result sql.Result, err errors.CodeError)
}

type Executor interface {
	ExecContext(ctx context.Context, query string, args ...interface{}) (result sql.Result, err error)
}

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

type Options struct {
	Log    logs.Logger
	Config *Config
}

type QueryAble interface {
	QueryContext(ctx context.Context, query string, args ...interface{}) (rows *sql.Rows, err error)
}