sqlite

Documentation

Index

• Constants
• type Adapter
  • func (a *Adapter) Connect() error
  • func (a *Adapter) Count(param moleculer.Payload) moleculer.Payload
  • func (a *Adapter) Disconnect() error
  • func (a *Adapter) Find(param moleculer.Payload) moleculer.Payload
  • func (a *Adapter) FindAndUpdate(param moleculer.Payload) moleculer.Payload
  • func (a *Adapter) FindById(id moleculer.Payload) moleculer.Payload
  • func (a *Adapter) FindByIds(ids moleculer.Payload) moleculer.Payload
  • func (a *Adapter) FindOne(params moleculer.Payload) moleculer.Payload
  • func (a *Adapter) Init(log *log.Entry, settings map[string]interface{})
  • func (a *Adapter) Insert(param moleculer.Payload) moleculer.Payload
  • func (a *Adapter) RemoveAll() moleculer.Payload
  • func (a *Adapter) RemoveById(id moleculer.Payload) moleculer.Payload
  • func (a *Adapter) Update(params moleculer.Payload) moleculer.Payload
  • func (a *Adapter) UpdateById(id, update moleculer.Payload) moleculer.Payload
• type Column

Constants

const (
	//YYYY-MM-DD HH:MM:SS.SSS -> SQLIte format
	ISO8601 = "2006-01-02 15:04:05.000"
)

Types

type Adapter

type Adapter struct {
	URI      string
	Flags    sqlite.OpenFlags
	PoolSize int
	Timeout  time.Duration
	Table    string
	Columns  []Column
	// ColName can be used to modify/translate column names
	// from what is passed in the params
	ColName func(string) string
	// contains filtered or unexported fields
}

func (*Adapter) Connect

func (a *Adapter) Connect() error

func (*Adapter) Count

func (a *Adapter) Count(param moleculer.Payload) moleculer.Payload

func (*Adapter) Disconnect

func (a *Adapter) Disconnect() error

func (*Adapter) Find

func (a *Adapter) Find(param moleculer.Payload) moleculer.Payload

func (*Adapter) FindAndUpdate

func (a *Adapter) FindAndUpdate(param moleculer.Payload) moleculer.Payload

func (*Adapter) FindById

func (a *Adapter) FindById(id moleculer.Payload) moleculer.Payload

func (*Adapter) FindByIds

func (a *Adapter) FindByIds(ids moleculer.Payload) moleculer.Payload

FindByIds

func (*Adapter) FindOne

func (a *Adapter) FindOne(params moleculer.Payload) moleculer.Payload

func (*Adapter) Init

func (a *Adapter) Init(log *log.Entry, settings map[string]interface{})

func (*Adapter) Insert

func (a *Adapter) Insert(param moleculer.Payload) moleculer.Payload

func (*Adapter) RemoveAll

func (a *Adapter) RemoveAll() moleculer.Payload

func (*Adapter) RemoveById

func (a *Adapter) RemoveById(id moleculer.Payload) moleculer.Payload

func (*Adapter) Update

func (a *Adapter) Update(params moleculer.Payload) moleculer.Payload

func (*Adapter) UpdateById

func (a *Adapter) UpdateById(id, update moleculer.Payload) moleculer.Payload

type Column

type Column struct {
	Name string
	Type string
}