postgres

Documentation

Overview

Package postgres provides an adapter for the database abstraction layer so that you can access PostgreSQL databases

Index

• func ToPgString(str string) string
• func ToPgTableName(str string) string
• type Database
  • func (db Database) Close() error
  • func (db Database) CreateCollectionFromModel(name string, model 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
• type TxMutationAdapter
  • func (TxMA TxMutationAdapter) CreateCollectionFromModel(name string, model interface{}, ifNotExists bool) error
  • func (TxMA TxMutationAdapter) Delete(cn string, obj interface{}) error
  • func (TxMA TxMutationAdapter) Insert(cn string, obj interface{}) error
  • func (TxMA TxMutationAdapter) Update(cn string, obj interface{}) error

Functions

func ToPgString

func ToPgString(str string) string

func ToPgTableName

func ToPgTableName(str string) string

Types

type Database

type Database struct {
	PgDB *pg.DB
}

func (Database) Close

func (db Database) Close() error

func (Database) CreateCollectionFromModel

func (db Database) CreateCollectionFromModel(name string, model 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

type TxMutationAdapter

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

func (TxMutationAdapter) CreateCollectionFromModel

func (TxMA TxMutationAdapter) CreateCollectionFromModel(name string, model interface{}, ifNotExists bool) error

func (TxMutationAdapter) Delete

func (TxMA TxMutationAdapter) Delete(cn string, obj interface{}) error

func (TxMutationAdapter) Insert

func (TxMA TxMutationAdapter) Insert(cn string, obj interface{}) error

func (TxMutationAdapter) Update

func (TxMA TxMutationAdapter) Update(cn string, obj interface{}) error