memdb

Documentation

Overview

Package memdb provides an adapter for the database abstraction layer so that you can access in-memory databases

Index

• type Database
  • func NewDB(config *dbsystem.DBAdapterConfig) *Database
  • func (db Database) Close() error
  • func (db *Database) CreateCollectionFromModel(name string, _ interface{}, ifNotExists bool) error
  • func (db Database) DataFromDatabaseUsingResolveParams(objArr interface{}, modelType reflect.Type, p graphql.ResolveParams) error
  • func (db *Database) Delete(cn string, model interface{}) error
  • func (db *Database) Insert(cn string, model interface{}) error
  • func (db Database) IsConnected() bool
  • func (db *Database) RunInTransaction(fn dbdefs.InnerTransactionFunc) error
  • func (db *Database) Select(collectionName string, args interface{}) (interface{}, error)
  • func (db *Database) SelectAdvanced(collectionName string, model interface{}, query *dbdefs.SelectQuery) error
  • func (db *Database) SelectInto(collectionName string, args interface{}, model interface{}) error
  • func (db Database) SyncSchema(options dbdefs.SchemaSyncOptions, models ...interface{}) error
  • func (db *Database) Update(cn string, model interface{}) error

Types

type Database

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

func NewDB

func NewDB(config *dbsystem.DBAdapterConfig) *Database

func (Database) Close

func (db Database) Close() error

func (*Database) CreateCollectionFromModel

func (db *Database) CreateCollectionFromModel(name string, _ interface{}, ifNotExists bool) error

func (Database) DataFromDatabaseUsingResolveParams

func (db Database) DataFromDatabaseUsingResolveParams(
	objArr interface{},
	modelType reflect.Type,
	p graphql.ResolveParams) error

func (*Database) Delete

func (db *Database) Delete(cn string, model interface{}) error

func (*Database) Insert

func (db *Database) Insert(cn string, model interface{}) error

func (Database) IsConnected

func (db Database) IsConnected() bool

func (*Database) RunInTransaction

func (db *Database) RunInTransaction(fn dbdefs.InnerTransactionFunc) error

func (*Database) Select

func (db *Database) Select(collectionName string, args interface{}) (interface{}, error)

func (*Database) SelectAdvanced

func (db *Database) SelectAdvanced(collectionName string, model interface{}, query *dbdefs.SelectQuery) error

func (*Database) SelectInto

func (db *Database) SelectInto(collectionName string, args interface{}, model interface{}) error

func (Database) SyncSchema

func (db Database) SyncSchema(options dbdefs.SchemaSyncOptions, models ...interface{}) error

func (*Database) Update

func (db *Database) Update(cn string, model interface{}) error