datastore

Documentation

Index

• Constants
• type Collection
  • func NewCollection(db *sqlx.DB, tableName string) *Collection
  • func (c *Collection) AddCallback(key string, cb func(q *Query))
  • func (c *Collection) Find(Criteria M) *Query
  • func (c *Collection) FindOne(Criteria M) *Query
  • func (c *Collection) Insert(from M) *Query
  • func (c *Collection) Truncate() error
• type M
• type Query
  • func (q *Query) GetLastID() int
  • func (q *Query) Limit(n int) *Query
  • func (q *Query) Order(by []string) *Query
  • func (q *Query) Run(dest interface{}) error
• type Store
  • func NewConnection(uri string, seed func(db *sqlx.DB) error) (*Store, error)
  • func (s *Store) AddCollection(tableName string) *Collection

Constants

const AfterInsert = "aINSERT"

const AfterSelect = "aSELECT"

const BeforeInsert = "bINSERT"

const BeforeSelect = "bSELECT"

Types

type Collection

type Collection struct {
	DB        *sqlx.DB
	Table     string
	Callbacks map[string][]func(q *Query)
}

Collection holds a table scoped database connection

func NewCollection

func NewCollection(db *sqlx.DB, tableName string) *Collection

func (*Collection) AddCallback

func (c *Collection) AddCallback(key string, cb func(q *Query))

func (*Collection) Find

func (c *Collection) Find(Criteria M) *Query

func (*Collection) FindOne

func (c *Collection) FindOne(Criteria M) *Query

func (*Collection) Insert

func (c *Collection) Insert(from M) *Query

func (*Collection) Truncate

func (c *Collection) Truncate() error

type M

type M map[string]interface{}

M is a map

type Query

type Query struct {
	C *Collection

	Criteria M

	LastID int
	Err    error
	// contains filtered or unexported fields
}

func (*Query) GetLastID

func (q *Query) GetLastID() int

func (*Query) Limit

func (q *Query) Limit(n int) *Query

func (*Query) Order

func (q *Query) Order(by []string) *Query

func (*Query) Run

func (q *Query) Run(dest interface{}) error

type Store

type Store struct {
	DB          *sqlx.DB
	Collections map[string]*Collection
}

Store holds all database collections

func NewConnection

func NewConnection(uri string, seed func(db *sqlx.DB) error) (*Store, error)

NewConnection creates a sql database connection and contentful client

func (*Store) AddCollection

func (s *Store) AddCollection(tableName string) *Collection