sqlite

Documentation

Index

• func Close() error
• func DeleteOldFromNow() error
• func Init(ctx ...context.Context)
• func Select(fileName, args string) (*store.StoreUnit, error)
• func Upsert(fileName, args string, unit *store.StoreUnit) error
• type Pull
  • func New(ctx ...context.Context) *Pull
  • func (p *Pull) Add(fileName string) (*SQL, error)
  • func (p *Pull) Close() error
  • func (p *Pull) DeleteOld() (int64, error)
  • func (p *Pull) DeleteOldFromNow() error
  • func (p *Pull) Get(fileName string) (*SQL, error)
  • func (p *Pull) Select(fileName, args string) (*store.StoreUnit, error)
  • func (p *Pull) Upsert(fileName, args string, unit *store.StoreUnit) error
• type SQL
  • func Add(fileName string) (*SQL, error)
  • func Conn(fileName string) (*SQL, error)
  • func Get(fileName string) (*SQL, error)
  • func (s *SQL) Close() error
  • func (s *SQL) CreateTable() error
  • func (s *SQL) DeleteOld() (int64, error)
  • func (s *SQL) DeleteOldByTime(timeForCut int) (int64, error)
  • func (s *SQL) Open() error
  • func (s *SQL) Select(args string) (*store.StoreUnit, error)
  • func (s *SQL) UpdateTimeRead(updateTimeRead bool)
  • func (s *SQL) Upsert(args string, unit *store.StoreUnit) error

Functions

func Close

func Close() error

--------------------------------

func DeleteOldFromNow

func DeleteOldFromNow() error

func Init

func Init(ctx ...context.Context)

func Select

func Select(fileName, args string) (*store.StoreUnit, error)

func Upsert

func Upsert(fileName, args string, unit *store.StoreUnit) error

Types

type Pull

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

func New

func New(ctx ...context.Context) *Pull

func (*Pull) Add

func (p *Pull) Add(fileName string) (*SQL, error)

Add creates new connection and adds to pull

func (*Pull) Close

func (p *Pull) Close() error

func (*Pull) DeleteOld

func (p *Pull) DeleteOld() (int64, error)

func (*Pull) DeleteOldFromNow

func (p *Pull) DeleteOldFromNow() error

func (*Pull) Get

func (p *Pull) Get(fileName string) (*SQL, error)

Add creates new connection and adds to pull

func (*Pull) Select

func (p *Pull) Select(fileName, args string) (*store.StoreUnit, error)

func (*Pull) Upsert

func (p *Pull) Upsert(fileName, args string, unit *store.StoreUnit) error

Upsert just inserts or update one record

type SQL

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

func Add

func Add(fileName string) (*SQL, error)

func Conn

func Conn(fileName string) (*SQL, error)

func Get

func Get(fileName string) (*SQL, error)

func (*SQL) Close

func (s *SQL) Close() error

func (*SQL) CreateTable

func (s *SQL) CreateTable() error

func (*SQL) DeleteOld

func (s *SQL) DeleteOld() (int64, error)

func (*SQL) DeleteOldByTime

func (s *SQL) DeleteOldByTime(timeForCut int) (int64, error)

func (*SQL) Open

func (s *SQL) Open() error

func (*SQL) Select

func (s *SQL) Select(args string) (*store.StoreUnit, error)

func (*SQL) UpdateTimeRead

func (s *SQL) UpdateTimeRead(updateTimeRead bool)

func (*SQL) Upsert

func (s *SQL) Upsert(args string, unit *store.StoreUnit) error

We are passing db reference connection from main to our method with other parameters