txorm

README

txorm

txorm is a tool to connect to mysql, base on github.com/go-xorm/xorm

database(mysql)

• go get -v github.com/go-trellis/txorm
• import github.com/go-xorm/xorm

Documentation

Index

• Constants
• Variables
• func AddErrorTypes(errType reflect.Type)
• func CallFunc(fn interface{}, funcs LogicFuncs, args []interface{}) ([]interface{}, errors.ErrorCode)
• func DeepFields(iface interface{}, vType reflect.Type, fields []reflect.Value) interface{}
• func Derive(origin interface{}) (interface{}, error)
• func GetMysqlDSNFromConfig(name string, conf config.Config) string
• func Inherit(new, origin interface{}) error
• func NewEnginesFromConfig(conf config.Config, name string) (map[string]*xorm.Engine, error)
• func NewEnginesFromFile(file string) (map[string]*xorm.Engine, error)
• type Committer
  • func New() Committer
  • func NewCommitter() Committer
• type Deriver
• type Inheritor
• type LogicFuncs
  • func GetLogicFuncs(fn interface{}) (funcs LogicFuncs)
• type TXFunc
• type TXorm
  • func (p *TXorm) NonTX(fn interface{}, repos ...interface{}) errors.ErrorCode
  • func (p *TXorm) NonTXWithName(fn interface{}, name string, repos ...interface{}) errors.ErrorCode
  • func (p *TXorm) Session() *xorm.Session
  • func (p *TXorm) SetEngines(engines map[string]*xorm.Engine)
  • func (p *TXorm) TX(fn interface{}, repos ...interface{}) errors.ErrorCode
  • func (p *TXorm) TXWithName(fn interface{}, name string, repos ...interface{}) errors.ErrorCode

Constants

const (
	Logic = iota
	BeforeLogic
	AfterLogic
	OnError
	AfterCommit
)

Function Flags

const (
	DefaultDatabase = "go-trellis::txorm::default"
)

defines

Variables

var (
	ErrFailToExecuteLogicFunction = errors.TN(_namespace, 10001, "{{.message}}")

	// define orm errors
	ErrNotFoundDefaultDatabase    = errors.TN(_namespace, 20000, "not found default database")
	ErrAtLeastOneRepo             = errors.TN(_namespace, 20001, "input one repo at least")
	ErrNotFoundTransationFunction = errors.TN(_namespace, 20002, "not found transation function")
	ErrStructCombineWithRepo      = errors.TN(_namespace, 20003, "your repository struct should combine with {{.name}} repo")
	ErrFailToCreateRepo           = errors.TN(_namespace, 20004, "fail to create an new repo")
	ErrFailToDerive               = errors.TN(_namespace, 20005, "fail to derive: {{.message}}")
	ErrFailToInherit              = errors.TN(_namespace, 20006, "fail to inherit: {{.message}}")
	ErrFailToConvetTXToNonTX      = errors.TN(_namespace, 20007, "could not convert TX to NON-TX")
	ErrFailToCreateTransaction    = errors.TN(_namespace, 20008, "fail to create transaction: {{.message}}")
	ErrTransactionIsAlreadyBegin  = errors.TN(_namespace, 20009, "transaction is already begin: {{.name}}")
	ErrNonTransactionCantCommit   = errors.TN(_namespace, 20010, "non-transaction can't commit")
	ErrTransactionSessionIsNil    = errors.TN(_namespace, 20011, "transaction session is nil")
	ErrFailToCommitTransaction    = errors.TN(_namespace, 20012, "fail to commit transaction")
	ErrNotFoundXormEngine         = errors.TN(_namespace, 20013, "not found xorm engine with {{.name}}")
)

define connector errors

Functions

func AddErrorTypes

func AddErrorTypes(errType reflect.Type)

AddErrorTypes 增加支持的错误类型

func CallFunc

func CallFunc(fn interface{}, funcs LogicFuncs, args []interface{}) ([]interface{}, errors.ErrorCode)

CallFunc execute transaction function with logic functions and args

func DeepFields

func DeepFields(iface interface{}, vType reflect.Type, fields []reflect.Value) interface{}

DeepFields relect interface deep fields

func Derive

func Derive(origin interface{}) (interface{}, error)

Derive derive from developer function

func GetMysqlDSNFromConfig

func GetMysqlDSNFromConfig(name string, conf config.Config) string

GetMysqlDSNFromConfig get mysql dsn from gogap config

func Inherit

func Inherit(new, origin interface{}) error

Inherit inherit a new repository from origin repository

func NewEnginesFromConfig

func NewEnginesFromConfig(conf config.Config, name string) (map[string]*xorm.Engine, error)

NewEnginesFromConfig initial xorm engine from config

func NewEnginesFromFile

func NewEnginesFromFile(file string) (map[string]*xorm.Engine, error)

NewEnginesFromFile initial xorm engine from file

Types

type Committer

type Committer interface {
	TX(fn interface{}, repos ...interface{}) errors.ErrorCode
	TXWithName(fn interface{}, name string, repos ...interface{}) errors.ErrorCode
	NonTX(fn interface{}, repos ...interface{}) errors.ErrorCode
	NonTXWithName(fn interface{}, name string, repos ...interface{}) errors.ErrorCode
}

Committer Defination

func New

func New() Committer

New get trellis xorm committer

func NewCommitter

func NewCommitter() Committer

NewCommitter get trellis gorm committer

type Deriver

type Deriver interface {
	Derive() (repo interface{}, err error)
}

Deriver derive function

type Inheritor

type Inheritor interface {
	Inherit(repo interface{}) error
}

Inheritor inherit function

type LogicFuncs

type LogicFuncs struct {
	BeforeLogic interface{}
	AfterLogic  interface{}
	OnError     interface{}
	Logic       interface{}
	AfterCommit interface{}
}

LogicFuncs logic functions

func GetLogicFuncs

func GetLogicFuncs(fn interface{}) (funcs LogicFuncs)

GetLogicFuncs reflect logic function

type TXFunc

type TXFunc func(repos []interface{}) errors.ErrorCode

TXFunc Transation function

type TXorm

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

TXorm trellis xorm

func (*TXorm) NonTX

func (p *TXorm) NonTX(fn interface{}, repos ...interface{}) errors.ErrorCode

NonTX do non transaction function by default database

func (*TXorm) NonTXWithName

func (p *TXorm) NonTXWithName(fn interface{}, name string, repos ...interface{}) errors.ErrorCode

NonTXWithName do non transaction function with name of database

func (*TXorm) Session

func (p *TXorm) Session() *xorm.Session

Session get session

func (*TXorm) SetEngines

func (p *TXorm) SetEngines(engines map[string]*xorm.Engine)

SetEngines set xorm engines

func (*TXorm) TX

func (p *TXorm) TX(fn interface{}, repos ...interface{}) errors.ErrorCode

TX do transaction function by default database

func (*TXorm) TXWithName

func (p *TXorm) TXWithName(fn interface{}, name string, repos ...interface{}) errors.ErrorCode

TXWithName do transaction function with name of database