Documentation
¶
Index ¶
- Variables
- func ApplyCollectionOperators(db *gorm.DB, obj interface{}, f *query.Filtering, s *query.Sorting, ...) (*gorm.DB, error)
- func ApplyFieldSelection(db *gorm.DB, fs *query.FieldSelection, obj interface{}) (*gorm.DB, error)
- func ApplyFiltering(db *gorm.DB, f *query.Filtering, obj interface{}) (*gorm.DB, map[string]struct{}, error)
- func ApplyPagination(db *gorm.DB, p *query.Pagination) *gorm.DB
- func ApplySorting(db *gorm.DB, s *query.Sorting, obj interface{}) (*gorm.DB, map[string]struct{}, error)
- func BeginFromContext(ctx context.Context) (*gorm.DB, error)
- func FieldSelectionStringToGorm(fs string, obj interface{}) ([]string, error)
- func FieldSelectionToGorm(fs *query.FieldSelection, obj interface{}) ([]string, error)
- func FilterStringToGorm(filter string, obj interface{}) (string, []interface{}, map[string]struct{}, error)
- func FilteringToGorm(m *query.Filtering, obj interface{}) (string, []interface{}, map[string]struct{}, error)
- func HandleFieldPath(fieldPath []string, obj interface{}) (string, string, error)
- func JoinAssociations(db *gorm.DB, assoc map[string]struct{}, obj interface{}) (*gorm.DB, error)
- func JoinInfo(obj interface{}, assoc string) (string, []string, []string, error)
- func LogicalOperatorToGorm(lop *query.LogicalOperator, obj interface{}) (string, []interface{}, map[string]struct{}, error)
- func MergeWithMask(source, dest interface{}, mask *fieldmask.FieldMask) error
- func NewContext(parent context.Context, txn *Transaction) context.Context
- func NullConditionToGorm(c *query.NullCondition, obj interface{}) (string, []interface{}, map[string]struct{}, error)
- func NumberConditionToGorm(c *query.NumberCondition, obj interface{}) (string, []interface{}, map[string]struct{}, error)
- func StringConditionToGorm(c *query.StringCondition, obj interface{}) (string, []interface{}, map[string]struct{}, error)
- func UnaryServerInterceptor(db *gorm.DB) grpc.UnaryServerInterceptor
- type EmptyFieldPathError
- type Transaction
Constants ¶
This section is empty.
Variables ¶
var ( ErrCtxTxnMissing = errors.New("Database transaction for request missing in context") ErrCtxTxnNoDB = errors.New("Transaction in context, but DB is nil") )
Functions ¶
func ApplyCollectionOperators ¶
func ApplyCollectionOperators(db *gorm.DB, obj interface{}, f *query.Filtering, s *query.Sorting, p *query.Pagination, fs *query.FieldSelection) (*gorm.DB, error)
ApplyCollectionOperators applies collection operators to gorm instance db.
func ApplyFieldSelection ¶
ApplyFieldSelection applies field selection operator fs to gorm instance db.
func ApplyFiltering ¶
func ApplyFiltering(db *gorm.DB, f *query.Filtering, obj interface{}) (*gorm.DB, map[string]struct{}, error)
ApplyFiltering applies filtering operator f to gorm instance db.
func ApplyPagination ¶
ApplyPagination applies pagination operator p to gorm instance db.
func ApplySorting ¶
func ApplySorting(db *gorm.DB, s *query.Sorting, obj interface{}) (*gorm.DB, map[string]struct{}, error)
ApplySorting applies sorting operator s to gorm instance db.
func BeginFromContext ¶ added in v0.6.0
func FieldSelectionStringToGorm ¶ added in v0.7.0
FieldSelectionStringToGorm is a shortcut to parse a string into FieldSelection struct and receive a list of associations to preload.
func FieldSelectionToGorm ¶ added in v0.7.0
func FieldSelectionToGorm(fs *query.FieldSelection, obj interface{}) ([]string, error)
FieldSelectionToGorm receives FieldSelection struct and returns a list of associations to preload.
func FilterStringToGorm ¶
func FilterStringToGorm(filter string, obj interface{}) (string, []interface{}, map[string]struct{}, error)
FilterStringToGorm is a shortcut to parse a filter string using default FilteringParser implementation and call FilteringToGorm on the returned filtering expression.
func FilteringToGorm ¶
func FilteringToGorm(m *query.Filtering, obj interface{}) (string, []interface{}, map[string]struct{}, error)
FilteringToGorm returns GORM Plain SQL representation of the filtering expression.
func HandleFieldPath ¶ added in v0.7.0
HandleFieldPath converts fieldPath to appropriate db string for use in where/order by clauses according to obj GORM model. If fieldPath cannot be found in obj then original fieldPath is returned to allow tables joined by a third party. If association join is required to resolve the field path then it's name is returned as a second return value.
func JoinAssociations ¶ added in v0.7.0
JoinAssociations joins obj's associations from assoc to the current gorm query.
func JoinInfo ¶ added in v0.7.0
JoinInfo extracts the following information for assoc association of obj: - association table name - source join keys - target join keys
func LogicalOperatorToGorm ¶
func LogicalOperatorToGorm(lop *query.LogicalOperator, obj interface{}) (string, []interface{}, map[string]struct{}, error)
LogicalOperatorToGorm returns GORM Plain SQL representation of the logical operator.
func MergeWithMask ¶ added in v0.8.0
MergeWithMask will take the fields of `source` that are included as paths in `mask` and write them to the corresponding fields of `dest`
func NewContext ¶ added in v0.5.0
func NewContext(parent context.Context, txn *Transaction) context.Context
NewContext returns a new Context that carries value txn.
func NullConditionToGorm ¶
func NullConditionToGorm(c *query.NullCondition, obj interface{}) (string, []interface{}, map[string]struct{}, error)
NullConditionToGorm returns GORM Plain SQL representation of the null condition.
func NumberConditionToGorm ¶
func NumberConditionToGorm(c *query.NumberCondition, obj interface{}) (string, []interface{}, map[string]struct{}, error)
NumberConditionToGorm returns GORM Plain SQL representation of the number condition.
func StringConditionToGorm ¶
func StringConditionToGorm(c *query.StringCondition, obj interface{}) (string, []interface{}, map[string]struct{}, error)
StringConditionToGorm returns GORM Plain SQL representation of the string condition.
func UnaryServerInterceptor ¶ added in v0.5.0
func UnaryServerInterceptor(db *gorm.DB) grpc.UnaryServerInterceptor
UnaryServerInterceptor returns grpc.UnaryServerInterceptor that manages a `*Transaction` instance. New *Transaction instance is created before grpc.UnaryHandler call. Client is responsible to call `txn.Begin()` to open transaction. If call of grpc.UnaryHandler returns with an error the transaction is aborted, otherwise committed.
Types ¶
type EmptyFieldPathError ¶ added in v0.7.0
type EmptyFieldPathError struct {
}
func (*EmptyFieldPathError) Error ¶ added in v0.7.0
func (e *EmptyFieldPathError) Error() string
type Transaction ¶ added in v0.5.0
type Transaction struct {
// contains filtered or unexported fields
}
Transaction serves as a wrapper around `*gorm.DB` instance. It works as a singleton to prevent an application of creating more than one transaction instance per incoming request.
func FromContext ¶ added in v0.5.0
func FromContext(ctx context.Context) (txn *Transaction, ok bool)
FromContext returns the *Transaction value stored in ctx, if any.
func NewTransaction ¶ added in v0.9.0
func NewTransaction(db *gorm.DB) Transaction
func (*Transaction) AddAfterCommitHook ¶ added in v0.7.0
func (t *Transaction) AddAfterCommitHook(hooks ...func(context.Context))
func (*Transaction) Begin ¶ added in v0.5.0
func (t *Transaction) Begin() *gorm.DB
Begin starts new transaction by calling `*gorm.DB.Begin()` Returns new instance of `*gorm.DB` (error can be checked by `*gorm.DB.Error`)
func (*Transaction) Commit ¶ added in v0.5.0
func (t *Transaction) Commit(ctx context.Context) error
Commit finishes transaction by calling `*gorm.DB.Commit()` Reset current transaction and returns an error if any.
func (*Transaction) Rollback ¶ added in v0.5.0
func (t *Transaction) Rollback() error
Rollback terminates transaction by calling `*gorm.DB.Rollback()` Reset current transaction and returns an error if any.
Source Files
Directories