Documentation
¶
Index ¶
- Constants
- func Callback(fn func(DBTX) error, tx ...*sqlx.Tx) error
- func CallbackByName(dbName string, fn func(DBTX) error, tx ...*sqlx.Tx) error
- func DB(name ...string) (*sqlx.DB, bool)
- func List() map[string]*sqlx.DB
- func MustDB(name ...string) *sqlx.DB
- func TransactCallback(fn func(*sqlx.Tx) error, tx ...*sqlx.Tx) (err error)
- func TransactCallbackByName(dbName string, fn func(*sqlx.Tx) error, tx ...*sqlx.Tx) (err error)
- type DBConfig
- type DBService
- type DBTX
Constants ¶
View Source
const ( DBCONFIG_FILE = faygo.CONFIG_DIR + "sqlx.ini" DATABASE_DIR = "database/" DEFAULTDB_NAME = "default" )
default constant
Variables ¶
This section is empty.
Functions ¶
func CallbackByName ¶
CallbackByName uses the specified database for non-transactional operations.
func TransactCallback ¶
TransactCallback uses the default database for transactional operations. note: if an error is returned, the rollback method should be invoked outside the function.
Types ¶
type DBConfig ¶
type DBConfig struct {
Name string `ini:"-"`
Enable bool `ini:"enable"`
Driver string `ini:"driver"` // driver: mssql | odbc(mssql) | mysql | mymysql | postgres | sqlite3 | oci8 | goracle
Connstring string `ini:"connstring"`
MaxOpenConns int `ini:"max_open_conns"`
MaxIdleConns int `ini:"max_idle_conns"`
ShowSql bool `ini:"show_sql"`
ColumnSnake bool `ini:"column_snake"` // the column name uses the snake style or remains unchanged
StructTag string `ini:"struct_tag"` // default is 'db'
}
DBConfig is database connection config
func MustConfig ¶
MustConfig gets the configuration information for the specified database, or returns the default if no name is specified.
type DBService ¶
type DBService struct {
Default *sqlx.DB // the default database engine
List map[string]*sqlx.DB // database engine list
}
DBService is a database engine object.
type DBTX ¶
type DBTX interface {
BindNamed(query string, arg interface{}) (string, []interface{}, error)
DriverName() string
Get(dest interface{}, query string, args ...interface{}) error
MustExec(query string, args ...interface{}) sql.Result
NamedExec(query string, arg interface{}) (sql.Result, error)
NamedQuery(query string, arg interface{}) (*sqlx.Rows, error)
PrepareNamed(query string) (*sqlx.NamedStmt, error)
Preparex(query string) (*sqlx.Stmt, error)
QueryRowx(query string, args ...interface{}) *sqlx.Row
Queryx(query string, args ...interface{}) (*sqlx.Rows, error)
Rebind(query string) string
Select(dest interface{}, query string, args ...interface{}) error
Exec(query string, args ...interface{}) (sql.Result, error)
Prepare(query string) (*sql.Stmt, error)
Query(query string, args ...interface{}) (*sql.Rows, error)
QueryRow(query string, args ...interface{}) *sql.Row
}
DBTX contains all the exportable methods of * sqlx.TX
Click to show internal directories.
Click to hide internal directories.