postgres

package
v1.0.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 24, 2024 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	EqualOperator              = Operator{"="}
	GreaterThanOperator        = Operator{">"}
	LessThanOperator           = Operator{"<"}
	GreaterThanOrEqualOperator = Operator{">="}
	LessThanOrEqualOperator    = Operator{"<="}
	NotEqualOperator           = Operator{"!="}
	InOperator                 = Operator{"IN"}
	BetweenOperator            = Operator{"BETWEEN"}
	LikeOperator               = Operator{"LIKE"}
	ILikeOperator              = Operator{"ILIKE"}
	IsNullOperator             = Operator{"IS NULL"}
	IsNotNullOperator          = Operator{"IS NOT NULL"}
	NotOperator                = Operator{"NOT"}
)
View Source 
var (
	AndOperator = LogicalOperator{"AND"}
	OrOperator  = LogicalOperator{"OR"}
)

Functions

func CreateDatabase 

func CreateDatabase(cfg ConnectionConfig) error

CreateDatabase - Creates a new database with the given configuration

func DeleteDatabase 

func DeleteDatabase(cfg ConnectionConfig) error

DeleteDatabase - Deletes an existing database with the given configuration

Types

type Condition 

type Condition struct {
	Column     string
	Comparison Operator
	LogOp      LogicalOperator
	Value      interface{}
}

type ConditionGroup 

type ConditionGroup struct {
	Conditions []Condition
}

type ConnectionConfig 

type ConnectionConfig struct {
	Username string
	Password string
	Host     string
	Database string
	SSL      bool
	Verbose  bool
}

type DB 

type DB struct {
	*bun.DB
}

func ConnectToDatabase 

func ConnectToDatabase(cfg *ConnectionConfig) (*DB, error)

ConnectToDatabase - Creates a new connection to a PSQL database with the given configuration.

func (*DB) AddDateFilters 

func (db *DB) AddDateFilters(query *bun.SelectQuery, filters []DateFilter) *bun.SelectQuery

func (*DB) AddLimitAndOffset 

func (db *DB) AddLimitAndOffset(query *bun.SelectQuery, limit, offset int) *bun.SelectQuery

func (*DB) CreateExtensions added in v1.0.6 

func (db *DB) CreateExtensions(extensions []string) error

CreateExtensions - Creates a database extension if it doesn't already exist

func (*DB) CreateTables 

func (db *DB) CreateTables(models []interface{}) error

CreateTables - Creates the database schema if it doesn't already exist

func (*DB) QueryBuilder 

func (db *DB) QueryBuilder(groups []ConditionGroup) (query string, queryArgs []interface{}, err error)

func (*DB) QueryCount 

func (db *DB) QueryCount(ctx context.Context, model interface{}, query string, conditions ...interface{}) (int, error)

func (*DB) ResetTables 

func (db *DB) ResetTables(models []interface{}) error

ResetTables - Drops and recreates the database schema

type DateFilter 

type DateFilter struct {
	DateColumn   string `json:"date_column"`
	FromDate     string `json:"from_date"`
	ToDate       string `json:"to_date"`
	FromDateUnix int64  `json:"-"`
	ToDateUnix   int64  `json:"-"`
}

type LogicalOperator 

type LogicalOperator struct {
	Value string
}

func (LogicalOperator) String 

func (s LogicalOperator) String() string

type Operator 

type Operator struct {
	Value string
}

func (Operator) String 

func (s Operator) String() string

type Option added in v1.0.6 

type Option func(db *DB) error

func WithExtensions added in v1.0.6 

func WithExtensions(extensions []string) Option

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.