database

Documentation

Overview

Package database is an abstraction layer for database systems

Index

• Constants
• type Collection
  • func (c *Collection) DataFromDatabaseUsingResolveParams(objArr interface{}, modelType reflect.Type, p graphql.ResolveParams) error
  • func (c *Collection) Delete(obj interface{}) error
  • func (c *Collection) EnsureInTx() error
  • func (c *Collection) Insert(obj interface{}) error
  • func (c *Collection) IsInTx() bool
  • func (c *Collection) RunInTransaction(fn TransactionFunc) error
  • func (c *Collection) Select(arguments interface{}) (interface{}, error)
  • func (c *Collection) SelectAdvanced(model interface{}, query *dbdefs.SelectQuery) error
  • func (c *Collection) SelectInto(arguments interface{}, model interface{}) error
  • func (c *Collection) Update(obj interface{}) error
  • func (c *Collection) UpdateSpecifiedFields(obj interface{}, fields []reflect.StructField) error
  • func (c *Collection) WithoutTx() *Collection
• type Database
  • func Plug(system dbsystem.DBSystem, config *dbsystem.DBAdapterConfig, ...) *Database
  • func (db *Database) Close() error
  • func (db *Database) Collection(model interface{}) *Collection
  • func (db *Database) CustomCollection(name string) *Collection
  • func (db *Database) IsRelation(model interface{}, field reflect.StructField) bool
  • func (db *Database) IsTypeRelation(modelType reflect.Type, field reflect.StructField) bool
  • func (db *Database) Prepare() error
• type Relation
• type RelationSolveContext
• type StructFieldName
• type StructFieldRelationMap
• type TransactionFunc
• type TypeName
• type TypeRelationsMap

Constants

const (
	TagPrefix       = "goqlorm.relation."
	TagRelationType = TagPrefix + "type"
	TagLinkTo       = TagPrefix + "linkTo"
	TagLinkFrom     = TagPrefix + "linkFrom"
	TagInversedBy   = TagPrefix + "inversedBy"
)

Tags

const (
	AssocFieldPrefix = "Assoc"
)

const (
	ErrorMustBeInTx = "can't do %s, mutations must be run in a transaction"
)

Types

type Collection

type Collection struct {
	Name string
	// contains filtered or unexported fields
}

func (*Collection) DataFromDatabaseUsingResolveParams

func (c *Collection) DataFromDatabaseUsingResolveParams(
	objArr interface{}, modelType reflect.Type, p graphql.ResolveParams) error

func (*Collection) Delete

func (c *Collection) Delete(obj interface{}) error

func (*Collection) EnsureInTx

func (c *Collection) EnsureInTx() error

func (*Collection) Insert

func (c *Collection) Insert(obj interface{}) error

func (*Collection) IsInTx

func (c *Collection) IsInTx() bool

func (*Collection) RunInTransaction

func (c *Collection) RunInTransaction(fn TransactionFunc) error

func (*Collection) Select

func (c *Collection) Select(arguments interface{}) (interface{}, error)

func (*Collection) SelectAdvanced

func (c *Collection) SelectAdvanced(model interface{}, query *dbdefs.SelectQuery) error

func (*Collection) SelectInto

func (c *Collection) SelectInto(arguments interface{}, model interface{}) error

func (*Collection) Update

func (c *Collection) Update(obj interface{}) error

func (*Collection) UpdateSpecifiedFields

func (c *Collection) UpdateSpecifiedFields(obj interface{}, fields []reflect.StructField) error

func (*Collection) WithoutTx

func (c *Collection) WithoutTx() *Collection

type Database

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

func Plug

func Plug(
	system dbsystem.DBSystem, config *dbsystem.DBAdapterConfig,
	schemaSyncOptions dbdefs.SchemaSyncOptions, models ...interface{}) *Database

func (*Database) Close

func (db *Database) Close() error

func (*Database) Collection

func (db *Database) Collection(model interface{}) *Collection

func (*Database) CustomCollection

func (db *Database) CustomCollection(name string) *Collection

func (*Database) IsRelation

func (db *Database) IsRelation(model interface{}, field reflect.StructField) bool

func (*Database) IsTypeRelation

func (db *Database) IsTypeRelation(modelType reflect.Type, field reflect.StructField) bool

func (*Database) Prepare

func (db *Database) Prepare() error

type Relation

type Relation struct {
	ModelType               reflect.Type
	Field                   reflect.StructField
	LinkedType              reflect.Type
	LinkedTo                reflect.StructField
	LinkedFrom              reflect.StructField
	Associations            *Collection
	AssociateFrom           reflect.StructField
	AssociateTo             reflect.StructField
	AssociationType         reflect.Type
	Type                    relationtype.RelationType
	InversedBy              *reflect.StructField
	AssociationEntryIdField reflect.StructField
	LinkedPrimaryKeyField   reflect.StructField
}

type RelationSolveContext

type RelationSolveContext struct {
	Relation        *Relation
	ModelCollection *Collection
	FieldValue      *reflect.Value
	ModelValue      *reflect.Value
	ForInsert       bool
	OnFinishRunners []onFinishRunner

	LinkedToFieldInsideFieldValue *reflect.Value
	LinkedResult                  interface{}
}

type StructFieldName

type StructFieldName = string

type StructFieldRelationMap

type StructFieldRelationMap map[StructFieldName]*Relation

type TransactionFunc

type TransactionFunc func(txDb *Collection) error

type TypeName

type TypeName = string

type TypeRelationsMap

type TypeRelationsMap map[TypeName]StructFieldRelationMap