juice

May 16, 2024

Changes in this version

+ var ErrInvalidExecutor = errors.New("juice: invalid executor")

type Executor

+ func InValidExecutor() Executor

+ type MultiRowsResultMap struct

+ func (MultiRowsResultMap) MapTo(rv reflect.Value, rows *sql.Rows) error

type ResultMap

+ MapTo func(rv reflect.Value, row *sql.Rows) error

+ type SessionTransaction interface

+ type SingleRowResultMap struct

+ func (SingleRowResultMap) MapTo(rv reflect.Value, rows *sql.Rows) error

+ type Transaction interface

+ Commit func() error

+ Rollback func() error

May 12, 2024

Changes in this version

+ func ConnectFromEnv(env *Environment) (*sql.DB, error)

type Action

+ func (a Action) ForRead() bool

+ func (a Action) ForWrite() bool

type Engine

+ func (e *Engine) AddExecutorAdapter(executorAdapter ExecutorAdapter)

+ type EnvironmentProvider interface

+ Attribute func(key string) string

+ Use func(id string) (*Environment, error)

type ExecHandler

+ func CombineExecHandler(stmt Statement, middlewares ...Middleware) ExecHandler

type GenericExecutor

+ Driver func() driver.Driver

type QueryHandler

+ func CombineQueryHandler(stmt Statement, middlewares ...Middleware) QueryHandler

+ type SettingProvider interface

+ Get func(name string) StringValue

May 9, 2024

Changes in this version

type Configuration

+ func (c Configuration) GetStatement(v any) (*Statement, error)

type Engine

+ func Default(configuration IConfiguration) (*Engine, error)

+ func New(configuration IConfiguration) (*Engine, error)

type Executor

+ Driver func() driver.Driver

+ type IConfiguration interface

+ Environments func() *Environments

+ GetStatement func(v any) (*Statement, error)

+ Settings func() *Settings

Nov 17, 2023

Changes in this version

+ type BinderRouter map[string]any

+ type ResultBinder interface

+ BindTo func(v reflect.Value) (BinderRouter, error)

+ type ResultBinderGroup []ResultBinder

+ func (r ResultBinderGroup) BindTo(v reflect.Value) (BinderRouter, error)

Nov 14, 2023

Changes in this version

+ var ErrNilDestination = errors.New("destination can not be nil")

+ var ErrNilRows = errors.New("rows can not be nil")

+ var ErrPointerRequired = errors.New("destination must be a pointer")

Oct 11, 2023

Changes in this version

+ type AdapterExecutorFunc func(Executor) Executor

+ func (f AdapterExecutorFunc) AdapterExecutor(e Executor) Executor

+ type ExecutorAdapter interface

+ AdapterExecutor func(Executor) Executor

+ func NewParamCtxExecutorAdapter() ExecutorAdapter

+ func NewSessionCtxInjectorExecutorAdapter() ExecutorAdapter

+ type ExecutorAdapterGroup []ExecutorAdapter

+ func (eg ExecutorAdapterGroup) AdapterExecutor(e Executor) Executor

+ type ExprCompiler interface

+ Compile func(expr string) (Expression, error)

+ var DefaultExprCompiler ExprCompiler = &goExprCompiler{ ... }

type Expression

+ Execute func(params Parameter) (EvalValue, error)

+ type NodeGroup []Node

+ func (g NodeGroup) Accept(translator driver.Translator, p Parameter) (query string, args []any, err error)

Aug 17, 2023

Changes in this version

+ var ErrSqlNodeNotFound = errors.New("sql node not found")

type Mappers

+ func (m *Mappers) GetMapperByNamespace(namespace string) (*Mapper, bool)

Aug 11, 2023

Changes in this version

+ type ADDExprExecutor struct

+ func (ADDExprExecutor) Exec(right reflect.Value, next func() (reflect.Value, error)) (reflect.Value, error)

+ type ANDExprExecutor struct

+ func (ANDExprExecutor) Exec(right reflect.Value, next func() (reflect.Value, error)) (reflect.Value, error)

+ type BinaryExprExecutor interface

+ Exec func(right reflect.Value, next func() (reflect.Value, error)) (reflect.Value, error)

+ type COMMENTExprExecutor struct

+ func (COMMENTExprExecutor) Exec(_ reflect.Value, _ func() (reflect.Value, error)) (reflect.Value, error)

+ type EQLExprExecutor struct

+ func (EQLExprExecutor) Exec(right reflect.Value, next func() (reflect.Value, error)) (reflect.Value, error)

+ type GEQExprExecutor struct

+ func (GEQExprExecutor) Exec(right reflect.Value, next func() (reflect.Value, error)) (reflect.Value, error)

+ type GTRExprExecutor struct

+ func (GTRExprExecutor) Exec(right reflect.Value, next func() (reflect.Value, error)) (reflect.Value, error)

+ type LANDExprExecutor struct

+ func (LANDExprExecutor) Exec(right reflect.Value, next func() (reflect.Value, error)) (reflect.Value, error)

+ type LEQExprExecutor struct

+ func (LEQExprExecutor) Exec(right reflect.Value, next func() (reflect.Value, error)) (reflect.Value, error)

+ type LORExprExecutor struct

+ func (LORExprExecutor) Exec(right reflect.Value, next func() (reflect.Value, error)) (reflect.Value, error)

+ type LPARENExprExecutor struct

+ func (LPARENExprExecutor) Exec(_ reflect.Value, next func() (reflect.Value, error)) (reflect.Value, error)

+ type LSSExprExecutor struct

+ func (LSSExprExecutor) Exec(right reflect.Value, next func() (reflect.Value, error)) (reflect.Value, error)

+ type MULExprExecutor struct

+ func (MULExprExecutor) Exec(right reflect.Value, next func() (reflect.Value, error)) (reflect.Value, error)

+ type NEQExprExecutor struct

+ func (NEQExprExecutor) Exec(right reflect.Value, next func() (reflect.Value, error)) (reflect.Value, error)

+ type NOTExprExecutor struct

+ func (NOTExprExecutor) Exec(_ reflect.Value, next func() (reflect.Value, error)) (reflect.Value, error)

+ type ORExprExecutor struct

+ func (ORExprExecutor) Exec(right reflect.Value, next func() (reflect.Value, error)) (reflect.Value, error)

+ type QUOExprExecutor struct

+ func (QUOExprExecutor) Exec(right reflect.Value, next func() (reflect.Value, error)) (reflect.Value, error)

+ type REMExprExecutor struct

+ func (REMExprExecutor) Exec(right reflect.Value, next func() (reflect.Value, error)) (reflect.Value, error)

+ type RPARENExprExecutor struct

+ func (RPARENExprExecutor) Exec(right reflect.Value, _ func() (reflect.Value, error)) (reflect.Value, error)

+ type SUBExprExecutor struct

+ func (SUBExprExecutor) Exec(right reflect.Value, next func() (reflect.Value, error)) (reflect.Value, error)

Aug 10, 2023

Changes in this version

+ type ExprPretreatment interface

+ PretreatmentExpr func(expr string) (string, error)

+ type ExprPretreatmentChain []ExprPretreatment

+ func (e ExprPretreatmentChain) PretreatmentExpr(expr string) (string, error)

Jul 24, 2023

Changes in this version

+ type ExecutorWarpFunc func(Executor) Executor

+ func (f ExecutorWarpFunc) WarpExecutor(e Executor) Executor

+ type ExecutorWarpGroup []ExecutorWrapper

+ func (eg ExecutorWarpGroup) WarpExecutor(e Executor) Executor

+ type ExecutorWrapper interface

+ WarpExecutor func(Executor) Executor

+ func NewParamCtxExecutorWrapper() ExecutorWrapper

+ func NewSessionCtxExecutorWrapper() ExecutorWrapper

+ type ParamCtxInjectorExecutor struct

+ func (e *ParamCtxInjectorExecutor) ExecContext(ctx context.Context, param Param) (sql.Result, error)

+ func (e *ParamCtxInjectorExecutor) QueryContext(ctx context.Context, param Param) (*sql.Rows, error)

+ type SessionCtxInjectorExecutor struct

+ func (e *SessionCtxInjectorExecutor) ExecContext(ctx context.Context, param Param) (sql.Result, error)

+ func (e *SessionCtxInjectorExecutor) QueryContext(ctx context.Context, param Param) (*sql.Rows, error)

type StringValue

+ func (s StringValue) Uint64() uint64

+ func (s StringValue) Unmarshaler(marshaller encoding.TextUnmarshaler) error

Jun 30, 2023

Changes in this version

+ type EvalValue = reflect.Value

+ type Evaluator interface

+ Parse func(expr string) (Expression, error)

+ var DefaultEvaluator Evaluator = &goEvaluator{}

+ type Expression interface

+ Eval func(params Parameter) (EvalValue, error)

Jun 27, 2023

Changes in this version

type Environments

+ func (e *Environments) Attr(key string) string

+ func (e *Environments) SetAttr(key, value string)

Jun 26, 2023

Changes in this version

+ func CtxWithParam(ctx context.Context, param Param) context.Context

+ type CacheMiddleware struct

+ func (c *CacheMiddleware[T]) ExecContext(stmt *Statement, next ExecHandler) ExecHandler

+ func (c *CacheMiddleware[T]) QueryContext(stmt *Statement, next GenericQueryHandler[T]) GenericQueryHandler[T]

type GenericExecutor

+ Use func(middlewares ...GenericMiddleware[T])

+ type GenericMiddleware interface

+ ExecContext func(stmt *Statement, next ExecHandler) ExecHandler

+ QueryContext func(stmt *Statement, next GenericQueryHandler[T]) GenericQueryHandler[T]

+ type GenericMiddlewareGroup []GenericMiddleware[T]

+ func (m GenericMiddlewareGroup[T]) ExecContext(stmt *Statement, next ExecHandler) ExecHandler

+ func (m GenericMiddlewareGroup[T]) QueryContext(stmt *Statement, next GenericQueryHandler[T]) GenericQueryHandler[T]

+ type GenericQueryHandler func(ctx context.Context, query string, args ...any) (T, error)

type Param

+ func ParamFromContext(ctx context.Context) Param

Jun 14, 2023

Changes in this version

+ func HasTxManager(ctx context.Context) bool

+ func IsTxManager(manager Manager) bool

Jun 14, 2023

Changes in this version

type Mapper

+ func (m *Mapper) Engine() *Engine

Jun 6, 2023

Changes in this version

+ var ErrTooManyRows = errors.New("juice: too many rows in result set")

type Engine

+ func (e *Engine) SetLocker(locker RWLocker)

+ type RWLocker interface

+ Lock func()

+ RLock func()

+ RUnlock func()

+ Unlock func()

May 24, 2023

Changes in this version

+ var CacheKeyFunc cacheKeyFunc = func(query string, args []any) (string, error)

+ var ErrNoSession = errors.New("no session found in context")

+ func WithSession(ctx context.Context, sess Session) context.Context

type Engine

+ func (e *Engine) CacheTx() TxCacheManager

+ func (e *Engine) ContextCacheTx(ctx context.Context, opt *sql.TxOptions) TxCacheManager

+ func (e *Engine) SetCacheFactory(factory func() cache.Cache)

type Executor

+ Session func() Session

type GenericExecutor

+ Session func() Session

+ Statement func() *Statement

type Statement

+ func (s *Statement) Build(param Param) (query string, args []any, err error)

+ func (s *Statement) ExecHandler() ExecHandler

+ func (s *Statement) QueryHandler() QueryHandler

+ type TxCacheManager interface

+ Cache func() cache.Cache

+ func NewTxCacheManager(manager TxManager, cache cache.Cache) TxCacheManager

May 22, 2023

Changes in this version

type Engine

+ func (e *Engine) Close() error

type Mappers

+ func (m *Mappers) Init(engine *Engine)

May 19, 2023

Changes in this version

type Node

+ func NewTextNode(str string) (Node, error)

type Statement

+ func (s *Statement) IsInsert() bool

May 6, 2023

Changes in this version

type H

+ func (h H) AsParam() Parameter

+ type ParamGroup []Parameter

+ func (g ParamGroup) Get(name string) (reflect.Value, bool)

+ type Parameter interface

+ Get func(name string) (reflect.Value, bool)

+ func NewParameter(v Param) Parameter

type SyntaxError

+ func (s *SyntaxError) Unwrap() error

Apr 16, 2023

Changes in this version

type XMLParser

+ func (p XMLParser) IgnoreEnv(i bool)

Apr 7, 2023

Changes in this version

type Mapper

+ func (m *Mapper) Prefix() string

type Mappers

+ func (m *Mappers) Attribute(key string) string

+ func (m *Mappers) Prefix() string

type Statement

+ func (s *Statement) Name() string

Jan 19, 2023

Changes in this version

+ type SelectFieldAliasNode []*selectFieldAliasItem

+ func (s SelectFieldAliasNode) Accept(_ driver.Translator, _ Param) (query string, args []interface{}, err error)

+ type ValuesNode []*valueItem

+ func (v ValuesNode) Accept(translater driver.Translator, param Param) (query string, args []interface{}, err error)

Jan 15, 2023

Changes in this version

type Binder

+ Bind func(v any) error

+ type ColumnDestination interface

+ Destination func(rv reflect.Value, column []string) ([]interface{}, error)

Jan 10, 2023

Changes in this version

+ type RowsScanner interface

+ ScanRows func(rows *sql.Rows) error

Jan 9, 2023

Changes in this version

type ResultMap

+ ResultTo func(rv reflect.Value, row *sql.Rows) error

+ type RowResultMap struct

+ func (RowResultMap) ResultTo(rv reflect.Value, rows *sql.Rows) error

+ type RowsResultMap struct

+ func (RowsResultMap) ResultTo(rv reflect.Value, rows *sql.Rows) error

Dec 31, 2022

Changes in this version

+ var ErrEmptyQuery = errors.New("empty query")

+ var ErrResultMapNotSet = errors.New("resultMap not set")

+ func Bind(rows *sql.Rows, v any) error

+ func BindWithResultMap(rows *sql.Rows, v any, mapper ResultMap) error

+ func ContextWithManager(ctx context.Context, manager Manager) context.Context

+ func Eval(expr string, params map[string]reflect.Value) (reflect.Value, error)

+ func MustRegisterEvalFunc(name string, v interface{})

+ func RegisterEnvValueProvider(name string, provider EnvValueProvider)

+ func RegisterEvalFunc(name string, v interface{}) error

+ func SessionWithContext(ctx context.Context, session Session) context.Context

+ type Action string

+ const Delete

+ const Insert

+ const Select

+ const Update

+ func (a Action) String() string

+ type Binder interface

+ Scan func(v any) error

+ type BinderExecutor interface

+ Exec func(param any) (sql.Result, error)

+ ExecContext func(ctx context.Context, param any) (sql.Result, error)

+ Query func(param any) (Binder, error)

+ QueryContext func(ctx context.Context, param any) (Binder, error)

+ type BinderManager interface

+ Object func(v any) BinderExecutor

+ func NewBinderManager(manager Manager) BinderManager

+ type ChooseNode struct

+ OtherwiseNode Node

+ WhenNodes []Node

+ func (c ChooseNode) Accept(translator driver.Translator, p Param) (query string, args []interface{}, err error)

+ type ConditionNode struct

+ Nodes []Node

+ func (c *ConditionNode) Accept(translator driver.Translator, p Param) (query string, args []interface{}, err error)

+ func (c *ConditionNode) Match(p Param) (bool, error)

+ func (c *ConditionNode) Parse(test string) (err error)

+ type Configuration struct

+ Environments Environments

+ Mappers Mappers

+ Settings Settings

+ func NewXMLConfiguration(filename string) (*Configuration, error)

+ func NewXMLConfigurationWithFS(fs fs.FS, filename string) (*Configuration, error)

+ func NewXMLConfigurationWithReader(fs fs.FS, reader io.Reader) (*Configuration, error)

+ type ConfigurationParser interface

+ Parse func(reader io.Reader) (*Configuration, error)

+ type DebugMiddleware struct

+ func (m *DebugMiddleware) ExecContext(stmt *Statement, next ExecHandler) ExecHandler

+ func (m *DebugMiddleware) QueryContext(stmt *Statement, next QueryHandler) QueryHandler

+ type Engine struct

+ Driver driver.Driver

+ func DefaultEngine(configuration *Configuration) (*Engine, error)

+ func NewEngine(configuration *Configuration) (*Engine, error)

+ func (e *Engine) ContextTx(ctx context.Context, opt *sql.TxOptions) TxManager

+ func (e *Engine) DB() *sql.DB

+ func (e *Engine) GetConfiguration() *Configuration

+ func (e *Engine) Object(v interface{}) Executor

+ func (e *Engine) SetConfiguration(cfg *Configuration)

+ func (e *Engine) Tx() TxManager

+ func (e *Engine) Use(middleware Middleware)

+ type EnvValueProvider interface

+ Get func(key string) (string, error)

+ func GetEnvValueProvider(key string) EnvValueProvider

+ type EnvValueProviderFunc func(key string) (string, error)

+ func (f EnvValueProviderFunc) Get(key string) (string, error)

+ type Environment struct

+ DataSource string

+ Driver string

+ MaxConnLifetime int

+ MaxIdleConnLifetime int

+ MaxIdleConnNum int

+ MaxOpenConnNum int

+ func (e *Environment) Attr(key string) string

+ func (e *Environment) Connect() (*sql.DB, error)

+ func (e *Environment) ID() string

+ type Environments struct

+ Default string

+ func (e *Environments) DefaultEnv() (*Environment, error)

+ func (e *Environments) Use(id string) (*Environment, error)

+ type ExecHandler func(ctx context.Context, query string, args ...any) (sql.Result, error)

+ type Executor interface

+ Exec func(param interface{}) (sql.Result, error)

+ ExecContext func(ctx context.Context, param interface{}) (sql.Result, error)

+ Query func(param interface{}) (*sql.Rows, error)

+ QueryContext func(ctx context.Context, param interface{}) (*sql.Rows, error)

+ Statement func() *Statement

+ type ForeachNode struct

+ Close string

+ Collection string

+ Index string

+ Item string

+ Nodes []Node

+ Open string

+ Separator string

+ func (f ForeachNode) Accept(translator driver.Translator, p Param) (query string, args []interface{}, err error)

+ type GenericExecutor interface

+ Exec func(param any) (sql.Result, error)

+ ExecContext func(ctx context.Context, param any) (sql.Result, error)

+ Query func(param any) (result, error)

+ QueryContext func(ctx context.Context, param any) (result, error)

+ type GenericManager interface

+ Object func(v any) GenericExecutor[T]

+ func NewGenericManager(manager Manager) GenericManager[T]

+ type H map[string]interface

+ func (h H) ParamConvert() (Param, error)

+ type IfNode = ConditionNode

+ type IncludeNode struct

+ RefId string

+ func (i IncludeNode) Accept(translator driver.Translator, p Param) (query string, args []interface{}, err error)

+ type IndexResultMap map[string][]int

+ func (m IndexResultMap) ColumnValue(rv reflect.Value, column string) (reflect.Value, bool, error)

+ type KeyValueResultMap map[string]reflect.Value

+ func (m KeyValueResultMap) ColumnValue(rv reflect.Value, column string) (reflect.Value, bool, error)

+ type LocalFS struct

+ func (f LocalFS) Open(name string) (fs.File, error)

+ type Manager interface

+ Object func(v any) Executor

+ func ManagerFromContext(ctx context.Context) Manager

+ type Mapper struct

+ func (m *Mapper) Attribute(key string) string

+ func (m *Mapper) Configuration() *Configuration

+ func (m *Mapper) GetResultMapByID(id string) (ResultMap, error)

+ func (m *Mapper) GetSQLNodeByID(id string) (Node, error)

+ func (m *Mapper) Mappers() *Mappers

+ func (m *Mapper) Namespace() string

+ type Mappers struct

+ func (m *Mappers) Configuration() *Configuration

+ func (m *Mappers) GetStatement(v any) (*Statement, error)

+ func (m *Mappers) GetStatementByID(id string) (*Statement, error)

+ type Middleware interface

+ ExecContext func(stmt *Statement, next ExecHandler) ExecHandler

+ QueryContext func(stmt *Statement, next QueryHandler) QueryHandler

+ type MiddlewareGroup []Middleware

+ func (m MiddlewareGroup) ExecContext(stmt *Statement, next ExecHandler) ExecHandler

+ func (m MiddlewareGroup) QueryContext(stmt *Statement, next QueryHandler) QueryHandler

+ type Node interface

+ Accept func(translator driver.Translator, p Param) (query string, args []interface{}, err error)

+ type OsEnvValueProvider struct

+ func (p OsEnvValueProvider) Get(key string) (string, error)

+ type OtherwiseNode struct

+ Nodes []Node

+ func (o OtherwiseNode) Accept(translator driver.Translator, p Param) (query string, args []interface{}, err error)

+ type Param map[string]reflect.Value

+ func ParamConvert(v interface{}, defaultParamName string) (Param, error)

+ func (p Param) Get(name string) (reflect.Value, bool)

+ type ParamConverter interface

+ ParamConvert func() (Param, error)

+ type QueryHandler func(ctx context.Context, query string, args ...any) (*sql.Rows, error)

+ type ResultMap interface

+ ColumnValue func(rv reflect.Value, column string) (reflect.Value, bool, error)

+ type SQLNode struct

+ func (s SQLNode) Accept(translator driver.Translator, p Param) (query string, args []interface{}, err error)

+ func (s SQLNode) ID() string

+ type Session interface

+ Exec func(query string, args ...interface{}) (sql.Result, error)

+ ExecContext func(ctx context.Context, query string, args ...interface{}) (sql.Result, error)

+ Prepare func(query string) (*sql.Stmt, error)

+ PrepareContext func(ctx context.Context, query string) (*sql.Stmt, error)

+ Query func(query string, args ...interface{}) (*sql.Rows, error)

+ QueryContext func(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)

+ func SessionFromContext(ctx context.Context) Session

+ type SetNode struct

+ Nodes []Node

+ func (s SetNode) Accept(translator driver.Translator, p Param) (query string, args []interface{}, err error)

+ type Setting struct

+ Name string

+ Value StringValue

+ type Settings []*Setting

+ func (s Settings) Get(name string) StringValue

+ type Statement struct

+ Nodes []Node

+ func (s *Statement) Accept(translator driver.Translator, p Param) (query string, args []interface{}, err error)

+ func (s *Statement) Action() Action

+ func (s *Statement) Attribute(key string) string

+ func (s *Statement) Configuration() *Configuration

+ func (s *Statement) Engine() *Engine

+ func (s *Statement) ForRead() bool

+ func (s *Statement) ForWrite() bool

+ func (s *Statement) ID() string

+ func (s *Statement) Key() string

+ func (s *Statement) Mapper() *Mapper

+ func (s *Statement) Namespace() string

+ func (s *Statement) ResultMap() (ResultMap, error)

+ func (s *Statement) String() string

+ type StatementIDGetter interface

+ StatementID func() string

+ type StringValue string

+ func (s StringValue) Bool() bool

+ func (s StringValue) Float64() float64

+ func (s StringValue) Int64() int64

+ func (s StringValue) String() string

+ type SyntaxError struct

+ func (s *SyntaxError) Error() string

+ type TextNode string

+ func (c TextNode) Accept(translator driver.Translator, p Param) (query string, args []interface{}, err error)

+ type TimeoutMiddleware struct

+ func (t TimeoutMiddleware) ExecContext(stmt *Statement, next ExecHandler) ExecHandler

+ func (t TimeoutMiddleware) QueryContext(stmt *Statement, next QueryHandler) QueryHandler

+ type TrimNode struct

+ Nodes []Node

+ Prefix string

+ PrefixOverrides string

+ Suffix string

+ SuffixOverrides string

+ func (t TrimNode) Accept(translator driver.Translator, p Param) (query string, args []interface{}, err error)

+ type TxManager interface

+ Commit func() error

+ Rollback func() error

+ type WhenNode = ConditionNode

+ type WhereNode struct

+ Nodes []Node

+ func (w WhereNode) Accept(translator driver.Translator, p Param) (query string, args []interface{}, err error)

+ type XMLParser struct

+ FS fs.FS

+ func (p XMLParser) Parse(reader io.Reader) (*Configuration, error)