database

README

What does this directory DO?

This package provides basic database handlers for a testing mock database (PLEASE don't use in prod!) and a MongoDB handler. The database.go file also defines DatabaseAccessor which can be extended upon for custom implementations.

Documentation

Index

• type DatabaseAccessor
• type DatabaseUpdateActions
• type MongoDatabase
  • func (db MongoDatabase) DeleteOne(table string, query map[string]interface{}) (bool, error)
  • func (db MongoDatabase) Drop(table string) error
  • func (db MongoDatabase) Find(table string, query map[string]interface{}) ([]interface{}, bool)
  • func (db MongoDatabase) FindOne(table string, query map[string]interface{}) (interface{}, bool)
  • func (db *MongoDatabase) Initialize(uri string, database string) error
  • func (db MongoDatabase) InsertOne(table string, body map[string]interface{}) (interface{}, error)
  • func (db MongoDatabase) UpdateOne(table string, query map[string]interface{}, ...) (interface{}, error)
• type TestDatabase
  • func (db TestDatabase) DeleteOne(table string, query map[string]interface{}) (bool, error)
  • func (db TestDatabase) Drop(table string) error
  • func (db TestDatabase) Find(table string, query map[string]interface{}) ([]interface{}, bool)
  • func (db TestDatabase) FindOne(table string, query map[string]interface{}) (interface{}, bool)
  • func (db TestDatabase) InsertOne(table string, body map[string]interface{}) (interface{}, error)
  • func (db TestDatabase) UpdateOne(table string, query map[string]interface{}, ...) (interface{}, error)

Types

type DatabaseAccessor

type DatabaseAccessor interface {
	InsertOne(table string, body map[string]interface{}) (interface{}, error)
	UpdateOne(table string, query map[string]interface{}, body map[DatabaseUpdateActions]map[string]interface{}) (interface{}, error)
	FindOne(table string, query map[string]interface{}) (interface{}, bool)
	Find(table string, query map[string]interface{}) ([]interface{}, bool)
	DeleteOne(table string, query map[string]interface{}) (bool, error)
	Drop(table string) error
}

type DatabaseUpdateActions

type DatabaseUpdateActions string

const (
	SET  DatabaseUpdateActions = "set"
	PUSH DatabaseUpdateActions = "push"
)

type MongoDatabase

type MongoDatabase struct {
	Ctx    context.Context
	Cancel context.CancelFunc
	// contains filtered or unexported fields
}

func (MongoDatabase) DeleteOne

func (db MongoDatabase) DeleteOne(table string, query map[string]interface{}) (bool, error)

func (MongoDatabase) Drop

func (db MongoDatabase) Drop(table string) error

func (MongoDatabase) Find

func (db MongoDatabase) Find(table string, query map[string]interface{}) ([]interface{}, bool)

func (MongoDatabase) FindOne

func (db MongoDatabase) FindOne(table string, query map[string]interface{}) (interface{}, bool)

func (*MongoDatabase) Initialize

func (db *MongoDatabase) Initialize(uri string, database string) error

func (MongoDatabase) InsertOne

func (db MongoDatabase) InsertOne(table string, body map[string]interface{}) (interface{}, error)

func (MongoDatabase) UpdateOne

func (db MongoDatabase) UpdateOne(table string, query map[string]interface{}, body map[DatabaseUpdateActions]map[string]interface{}) (interface{}, error)

type TestDatabase

type TestDatabase struct {
	Tables map[string]map[string]interface{}
}

func (TestDatabase) DeleteOne

func (db TestDatabase) DeleteOne(table string, query map[string]interface{}) (bool, error)

func (TestDatabase) Drop

func (db TestDatabase) Drop(table string) error

func (TestDatabase) Find

func (db TestDatabase) Find(table string, query map[string]interface{}) ([]interface{}, bool)

func (TestDatabase) FindOne

func (db TestDatabase) FindOne(table string, query map[string]interface{}) (interface{}, bool)

func (TestDatabase) InsertOne

func (db TestDatabase) InsertOne(table string, body map[string]interface{}) (interface{}, error)

func (TestDatabase) UpdateOne

func (db TestDatabase) UpdateOne(table string, query map[string]interface{}, body map[DatabaseUpdateActions]map[string]interface{}) (interface{}, error)