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.