mbt

Apr 6, 2022

Changes in this version

type Session

+ func (it *Session) MasterDB() *sql.DB

+ func (it *Session) SlaveDB() *sql.DB

Jul 13, 2021

Changes in this version

type Database

+ Slave *Database

Jul 13, 2021

Changes in this version

+ type Logger struct

+ Count int

+ Interval int

+ LinkName string

+ MaxAge int

+ Path string

+ PrintSql bool

+ PrintXml bool

Jun 26, 2021

Changes in this version

+ type Convert interface

+ Convert func() string

+ Get func() int

+ Inc func()

type Session

+ func (it *Session) Driver(driverType Convert) *Session

+ func (it *Session) ID(node int64) Id

+ func (it *Session) Register(h H) *Session

+ func (it *Session) Run()

+ func (it *Session) SetOutPut(w io.Writer) *Session

+ func (it *Session) Tx(mapperPtr interface{})

Jun 26, 2021

Changes in this version

type Database

+ Namespace string

Jun 19, 2021

Changes in this version

type Database

+ Logger *logger

type Engine

+ func (it *Engine) SetOutPut(w io.Writer) *Engine

Jun 18, 2021

Changes in this version

+ type Database struct

+ ConnMaxIdleTime time.Duration

+ ConnMaxLifetime time.Duration

+ DSN string

+ DriverName string

+ LogFile string

+ MaxIdleConn int

+ MaxOpenConn int

+ Pkg string

+ PrintSql bool

+ PrintXml bool

Jun 12, 2021

Changes in this version

type Config

+ Pkg string

+ PrintSql bool

+ PrintWarn bool

+ PrintXml bool

+ TxEnable bool

type Engine

+ func (it *Engine) Tx(mapperPtr interface{})

May 9, 2021

Changes in this version

type Engine

+ func (it *Engine) Open(driverName, dataSourceName string) (*sql.DB, error)

type IEngine

+ Open func(driverName, dataSourceName string) (*sql.DB, error)

May 6, 2021

Changes in this version

+ const AdapterFormatDate

+ const DefaultOneArg

+ const ElementMapper

+ const ID

+ const MSession

+ const MSessionPtr

+ const MTime

+ const MTimePtr

+ const SessionFunc

+ var BoolType = reflect.TypeOf(boolDefault)

+ var ByteType = reflect.TypeOf(byteDefault)

+ var BytesType = reflect.SliceOf(ByteType)

+ var Complex128Type = reflect.TypeOf(complex128Default)

+ var Complex64Type = reflect.TypeOf(complex64Default)

+ var Epoch int64 = 1288834974657

+ var ErrInvalidBase32 = errors.New("invalid base32")

+ var ErrInvalidBase58 = errors.New("invalid base58")

+ var Float32Type = reflect.TypeOf(float32Default)

+ var Float64Type = reflect.TypeOf(float64Default)

+ var Int16Type = reflect.TypeOf(int16Default)

+ var Int32Type = reflect.TypeOf(int32Default)

+ var Int64Type = reflect.TypeOf(int64Default)

+ var Int8Type = reflect.TypeOf(int8Default)

+ var IntType = reflect.TypeOf(intDefault)

+ var NodeBits uint8 = 10

+ var PtrBoolType = reflect.PtrTo(BoolType)

+ var PtrByteType = reflect.PtrTo(ByteType)

+ var PtrComplex128Type = reflect.PtrTo(Complex128Type)

+ var PtrComplex64Type = reflect.PtrTo(Complex64Type)

+ var PtrFloat32Type = reflect.PtrTo(Float32Type)

+ var PtrFloat64Type = reflect.PtrTo(Float64Type)

+ var PtrInt16Type = reflect.PtrTo(Int16Type)

+ var PtrInt32Type = reflect.PtrTo(Int32Type)

+ var PtrInt64Type = reflect.PtrTo(Int64Type)

+ var PtrInt8Type = reflect.PtrTo(Int8Type)

+ var PtrIntType = reflect.PtrTo(IntType)

+ var PtrStringType = reflect.PtrTo(StringType)

+ var PtrTimeType = reflect.PtrTo(TimeType)

+ var PtrUint16Type = reflect.PtrTo(Uint16Type)

+ var PtrUint32Type = reflect.PtrTo(Uint32Type)

+ var PtrUint64Type = reflect.PtrTo(Uint64Type)

+ var PtrUint8Type = reflect.PtrTo(Uint8Type)

+ var PtrUintType = reflect.PtrTo(UintType)

+ var ResultItem = `<result column="#{column}" langType="#{langType}" #{version} #{logic}/>`

+ var StepBits uint8 = 12

+ var StringType = reflect.TypeOf(emptyString)

+ var TimeType = reflect.TypeOf(timeDefault)

+ var Uint16Type = reflect.TypeOf(uint16Default)

+ var Uint32Type = reflect.TypeOf(uint32Default)

+ var Uint64Type = reflect.TypeOf(uint64Default)

+ var Uint8Type = reflect.TypeOf(uint8Default)

+ var UintType = reflect.TypeOf(uintDefault)

+ var XmlData = ...

+ var XmlLogicEnable = `logic_enable="true" logic_undelete="1" logic_deleted="0"`

+ var XmlVersionEnable = `version_enable="true"`

+ func AopProxyService(service interface{}, engine IEngine)

+ func AopProxyServiceValue(service reflect.Value, engine IEngine)

+ func ByteConvertXml(bytes []byte) (items map[string]etree.Token)

+ func IsNotExist(abs string) bool

+ func PrintStr(str string) string

+ func Proxy(proxyPtr interface{}, ...)

+ func ProxyValue(mapperValue reflect.Value, ...)

+ func Snake(s string) string

+ func ToString(propagation Propagation) string

+ type Config struct

+ ConnMaxIdleTime time.Duration

+ ConnMaxLifetime time.Duration

+ DSN string

+ DriverName string

+ MaxIdleConn int

+ MaxOpenConn int

+ type DataSource struct

+ func NewRouter(routerFunc func(mapperName string) *string) DataSource

+ func (it *DataSource) Router(mapperName string, engine IEngine) (ISession, error)

+ func (it *DataSource) SetDB(driverType string, dsn string, db *sql.DB)

+ type ElementType = string

+ const ElementBind

+ const ElementChoose

+ const ElementDelete

+ const ElementDeleteTemplate

+ const ElementForeach

+ const ElementIf

+ const ElementInclude

+ const ElementInsert

+ const ElementInsertTemplate

+ const ElementOtherwise

+ const ElementResultMap

+ const ElementSelect

+ const ElementSelectTemplate

+ const ElementSet

+ const ElementSql

+ const ElementString

+ const ElementTrim

+ const ElementUpdate

+ const ElementUpdateTemplate

+ const ElementWhen

+ const ElementWhere

+ type Engine struct

+ func New(cfg *Config) (*Engine, error)

+ func (it *Engine) Driver(driverType string) string

+ func (it *Engine) GetDBRouter() IDataSource

+ func (it *Engine) GetExpression() ast.IExpression

+ func (it *Engine) GetGoroutine() *SessionMap

+ func (it *Engine) GetLog() ILog

+ func (it *Engine) GetSessionFactory() *SessionFactory

+ func (it *Engine) GetSqlBuilder() ISqlBuilder

+ func (it *Engine) GetSqlResultDecoder() ISqlResultDecoder

+ func (it *Engine) GetTpl() ITplDecoder

+ func (it *Engine) ID(node int64) Id

+ func (it *Engine) IsGoroutine() bool

+ func (it *Engine) IsLog() bool

+ func (it *Engine) IsPrintWarn() bool

+ func (it *Engine) LogSystem() *LogSystem

+ func (it *Engine) NewSession(mapperName string) (ISession, error)

+ func (it *Engine) One(mapperPtr interface{}) IEngine

+ func (it *Engine) Register(pkg string, h H) IEngine

+ func (it *Engine) Run()

+ func (it *Engine) SetExpression(engine ast.IExpression)

+ func (it *Engine) SetGoroutine(enable bool)

+ func (it *Engine) SetLog(log ILog)

+ func (it *Engine) SetLogEnable(enable bool)

+ func (it *Engine) SetPrintWarn(print bool)

+ func (it *Engine) SetSessionFactory(factory *SessionFactory)

+ func (it *Engine) SetSqlArgTypeConvert(convert ast.SqlArgTypeConvert)

+ func (it *Engine) SetSqlBuilder(builder ISqlBuilder)

+ func (it *Engine) SetSqlResultDecoder(decoder ISqlResultDecoder)

+ func (it *Engine) SetTpl(decoder ITplDecoder)

+ func (it *Engine) Use(router IDataSource)

+ type ExpressionCache struct

+ func (it *ExpressionCache) Get(expression string) (interface{}, error)

+ func (it *ExpressionCache) Name() string

+ func (it *ExpressionCache) Set(expression string, lexer interface{}) error

+ func (it ExpressionCache) New() ExpressionCache

+ type ExpressionProxy struct

+ func NewExpressionProxy(engine ast.IExpression, useLexerCache bool) ExpressionProxy

+ func (it *ExpressionProxy) Eval(lexerResult interface{}, arg interface{}, operation int) (interface{}, error)

+ func (it *ExpressionProxy) Lexer(expression string) (interface{}, error)

+ func (it *ExpressionProxy) LexerAndEval(expression string, arg interface{}) (interface{}, error)

+ func (it *ExpressionProxy) LexerCache() IExpressionLexerCache

+ func (it *ExpressionProxy) LexerCacheable() bool

+ func (it *ExpressionProxy) SetExpression(engine ast.IExpression)

+ func (it *ExpressionProxy) SetLexerCache(cache IExpressionLexerCache)

+ func (it *ExpressionProxy) SetUseLexerCache(isUseCache bool) error

+ func (it ExpressionProxy) Name() string

+ type H map[interface{}]interface

+ type IDataSource interface

+ Router func(mapperName string, engine IEngine) (ISession, error)

+ SetDB func(driverName string, dsn string, db *sql.DB)

+ type IEngine interface

+ GetDBRouter func() IDataSource

+ GetExpression func() ast.IExpression

+ GetGoroutine func() *SessionMap

+ GetLog func() ILog

+ GetSessionFactory func() *SessionFactory

+ GetSqlBuilder func() ISqlBuilder

+ GetSqlResultDecoder func() ISqlResultDecoder

+ GetTpl func() ITplDecoder

+ IsGoroutine func() bool

+ IsLog func() bool

+ IsPrintWarn func() bool

+ LogSystem func() *LogSystem

+ NewSession func(mapperName string) (ISession, error)

+ One func(mapperPtr interface{}) IEngine

+ Register func(filePath string, h H) IEngine

+ Run func()

+ SetExpression func(engine ast.IExpression)

+ SetGoroutine func(enable bool)

+ SetLog func(log ILog)

+ SetLogEnable func(enable bool)

+ SetSessionFactory func(factory *SessionFactory)

+ SetSqlArgTypeConvert func(convert ast.SqlArgTypeConvert)

+ SetSqlBuilder func(builder ISqlBuilder)

+ SetSqlResultDecoder func(decoder ISqlResultDecoder)

+ SetTpl func(decoder ITplDecoder)

+ Use func(router IDataSource)

+ type IExpressionLexerCache interface

+ Get func(expression string) (interface{}, error)

+ Name func() string

+ Set func(expression string, lexer interface{}) error

+ type IExpressionLexerCacheable interface

+ LexerCacheable func() bool

+ SetUseLexerCache func(use bool) error

+ type ILog interface

+ Println func(messages []byte)

+ QueueLen func() int

+ type ISession interface

+ Begin func(p *Propagation) error

+ Close func()

+ Commit func() error

+ Exec func(sqlOrArgs string) (*Result, error)

+ ExecPrepare func(sqlPrepare string, args ...interface{}) (*Result, error)

+ Id func() string

+ LastPropagation func() *Propagation

+ Query func(sqlOrArgs string) ([]map[string][]byte, error)

+ QueryPrepare func(sqlPrepare string, args ...interface{}) ([]map[string][]byte, error)

+ Rollback func() error

+ StmtConvert func() (ast.IConvert, error)

+ type ISqlBuilder interface

+ BuildSql func(paramMap map[string]interface{}, nodes []ast.Node, array *[]interface{}, ...) (string, error)

+ EnableLog func() bool

+ ExpressionProxy func() *ExpressionProxy

+ NodeParser func() ast.NodeParser

+ SetSqlLog func(enable bool)

+ type ISqlResultDecoder interface

+ Decode func(resultMap map[string]*ResultProperty, SqlResult []map[string][]byte, ...) error

+ type ITplDecoder interface

+ DecodeTree func(tree map[string]etree.Token, beanType reflect.Type) error

+ PrintElement func(print bool)

+ type Id int64

+ func ParseBase2(id string) (Id, error)

+ func ParseBase32(b []byte) (Id, error)

+ func ParseBase36(id string) (Id, error)

+ func ParseBase58(b []byte) (Id, error)

+ func ParseBase64(id string) (Id, error)

+ func ParseBytes(id []byte) (Id, error)

+ func ParseInt64(id int64) Id

+ func ParseIntBytes(id [8]byte) Id

+ func ParseString(id string) (Id, error)

+ func (f *Id) UnmarshalJSON(b []byte) error

+ func (f Id) Base2() string

+ func (f Id) Base32() string

+ func (f Id) Base36() string

+ func (f Id) Base58() string

+ func (f Id) Base64() string

+ func (f Id) Bytes() []byte

+ func (f Id) Int64() int64

+ func (f Id) IntBytes() [8]byte

+ func (f Id) MarshalJSON() ([]byte, error)

+ func (f Id) Node() int64

+ func (f Id) Step() int64

+ func (f Id) String() string

+ func (f Id) Time() int64

+ type JSONSyntaxError struct

+ func (j JSONSyntaxError) Error() string

+ type LogStandard struct

+ PrintlnFunc func(messages []byte)

+ func (it *LogStandard) Println(v []byte)

+ func (it *LogStandard) QueueLen() int

+ type LogSystem struct

+ func NewLog(log ILog, queueLen int) (LogSystem, error)

+ func (it *LogSystem) Close() error

+ func (it *LogSystem) SendLog(logs ...string) error

+ type LogicDeleteData struct

+ Column string

+ DeletedValue string

+ Enable bool

+ LangType string

+ Property string

+ UndeleteValue string

+ type Mapper struct

+ type Node struct

+ func NewNode(node int64) (*Node, error)

+ func (n *Node) Generate() Id

+ type Propagation int

+ const Mandatory

+ const Nested

+ const Never

+ const News

+ const NotRequired

+ const NotSupport

+ const Required

+ const Support

+ func NewPropagation(arg string) Propagation

+ type ProxyArg struct

+ Args []reflect.Value

+ ArgsLen int

+ TagArgs []TagArg

+ TagArgsLen int

+ func (it ProxyArg) New(tagArgs []TagArg, args []reflect.Value) ProxyArg

+ type Result struct

+ LastInsertId int64

+ RowsAffected int64

+ type ResultProperty struct

+ Column string

+ LangType string

+ XMLName string

+ type ReturnType struct

+ ErrorType *reflect.Type

+ NumOut int

+ ReturnIndex int

+ ReturnOutType *reflect.Type

+ type SavePoint struct

+ func (s *SavePoint) Len() int

+ func (s *SavePoint) Pop() *string

+ func (s *SavePoint) Push(k string)

+ func (s SavePoint) New() SavePoint

+ type Session struct

+ SessionId string

+ func (it *Session) Begin(p *Propagation) error

+ func (it *Session) Close()

+ func (it *Session) Commit() error

+ func (it *Session) Exec(args string) (*Result, error)

+ func (it *Session) ExecPrepare(sqlPrepare string, args ...interface{}) (*Result, error)

+ func (it *Session) Id() string

+ func (it *Session) LastPropagation() *Propagation

+ func (it *Session) Query(args string) ([]map[string][]byte, error)

+ func (it *Session) QueryPrepare(sqlPrepare string, args ...interface{}) ([]map[string][]byte, error)

+ func (it *Session) Rollback() error

+ func (it *Session) StmtConvert() (ast.IConvert, error)

+ func (it Session) New(driverType string, driverLink string, db *sql.DB, logSystem ILog) Session

+ type SessionFactory struct

+ Engine IEngine

+ SessionMap sync.Map

+ func NewSessionFactory(Engine IEngine) SessionFactory

+ func (it *SessionFactory) Close(id string)

+ func (it *SessionFactory) CloseAll(id string)

+ func (it *SessionFactory) GetSession(id string) ISession

+ func (it *SessionFactory) NewSession(mapperName string, sessionType SessionType) ISession

+ func (it *SessionFactory) SetSession(id string, session ISession)

+ type SessionFactorySession struct

+ Factory *SessionFactory

+ Session ISession

+ func (it *SessionFactorySession) Begin(p *Propagation) error

+ func (it *SessionFactorySession) Close()

+ func (it *SessionFactorySession) Commit() error

+ func (it *SessionFactorySession) Exec(sqlOrArg string) (*Result, error)

+ func (it *SessionFactorySession) ExecPrepare(sqlOrArg string, args ...interface{}) (*Result, error)

+ func (it *SessionFactorySession) Id() string

+ func (it *SessionFactorySession) LastPropagation() *Propagation

+ func (it *SessionFactorySession) Query(sqlOrArg string) ([]map[string][]byte, error)

+ func (it *SessionFactorySession) QueryPrepare(sqlOrArg string, args ...interface{}) ([]map[string][]byte, error)

+ func (it *SessionFactorySession) Rollback() error

+ func (it *SessionFactorySession) StmtConvert() (ast.IConvert, error)

+ type SessionMap struct

+ func (it *SessionMap) Delete(k int64)

+ func (it *SessionMap) Get(k int64) ISession

+ func (it *SessionMap) Put(k int64, session ISession)

+ func (it SessionMap) New() SessionMap

+ type SessionType = int

+ const SessionTypeDefault

+ const SessionTypeLocal

+ type SqlArgTypeConvert struct

+ func (it SqlArgTypeConvert) Convert(argValue interface{}) string

+ type SqlBuilder struct

+ func NewSqlBuilder(expressionEngine ExpressionProxy, log ILog, enableLog bool) SqlBuilder

+ func (it *SqlBuilder) BuildSql(args map[string]interface{}, node []ast.Node, array *[]interface{}, ...) (string, error)

+ func (it *SqlBuilder) EnableLog() bool

+ func (it *SqlBuilder) ExpressionProxy() *ExpressionProxy

+ func (it *SqlBuilder) NodeParser() ast.NodeParser

+ func (it *SqlBuilder) SetSqlLog(enable bool)

+ type SqlResultDecoder struct

+ func (it SqlResultDecoder) Decode(resultMap map[string]*ResultProperty, sqlResult []map[string][]byte, ...) error

+ type TagArg struct

+ Index int

+ Name string

+ type TplDecoder struct

+ func (it *TplDecoder) Decode(method *reflect.StructField, mapper *etree.Element, ...) (bool, error)

+ func (it *TplDecoder) DecodeCollectionName(method *reflect.StructField) string

+ func (it *TplDecoder) DecodeSets(arg string, mapper *etree.Element, logic LogicDeleteData, ...)

+ func (it *TplDecoder) DecodeTree(tree map[string]etree.Token, beanType reflect.Type) error

+ func (it *TplDecoder) DecodeWheres(arg string, mapper *etree.Element, logic LogicDeleteData, ...)

+ func (it *TplDecoder) PrintElement(print bool)

+ type Tx struct

+ Session func() (ISession, error)

+ type TxStack struct

+ func (s *TxStack) First() (*sql.Tx, *Propagation)

+ func (s *TxStack) HaveTx() bool

+ func (s *TxStack) Last() (*sql.Tx, *Propagation)

+ func (s *TxStack) Len() int

+ func (s *TxStack) Pop() (*sql.Tx, *Propagation)

+ func (s *TxStack) Push(k *sql.Tx, p *Propagation)

+ func (s TxStack) New() TxStack

+ type VersionData struct

+ Column string

+ LangType string

+ Property string