postgres

package

v0.0.0-...-b5cca38 Latest Latest Go to latest Published: Oct 17, 2019 License: MIT Imports: 9 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Postgres struct {
	Conn *sql.DB
}

Postgres abstraction for Postgresql database

func NewInstance(connectionString string) (*Postgres, error)

NewInstance create new connection to Postgres DB this initialization also attempts to migrate the DB to latest version

func (p *Postgres) DefaultWasSet(chatID int64) (bool, error)

DefaultWasSet check if a default bucket set for a chat

func (p *Postgres) DeleteBucket(chatID int64, bucketName string) error

DeleteBucket remove a bucket from database

func (p *Postgres) DeleteOption(chatID int64, bucketName string, optionIdx int64) ([]domain.Option, error)

DeleteOption remove an option from a bucket

func (p *Postgres) Exists(chatID int64, bucketName string) (bool, error)

Exists check if a bucket exists in database

func (p *Postgres) GetAllBuckets(chatID int64) ([]domain.Bucket, error)

GetAllBuckets get all buckets in a chat

func (p *Postgres) GetDefaultBucket(chatID int64) (string, error)

GetDefaultBucket get the default bucket of current chat

func (p *Postgres) InsertBucket(chatID int64, name string) error

InsertBucket create a new options bucket

func (p *Postgres) InsertOption(chatID int64, bucketName string, option domain.Option) error

InsertOption put an option inside a bucket

func (p *Postgres) ReadAllOptions(chatID int64, bucketName string) ([]domain.Option, error)

ReadAllOptions query all options inside a bucket

func (p *Postgres) UpdateDefaultBucket(chatID int64, bucketName string) error

UpdateDefaultBucket change the default bucket for chat to draw from