gosql

README

gosql

Documentation

Index

• type DB
  • func (this DB) Connect() *sql.DB
  • func (this DB) CreateTable(tableName string, columns []string)
  • func (this DB) DropTable(tableName string)
  • func (this DB) Exec(sqlQuery string)
  • func (this DB) GetAvgRowCountPerDay(tableName, dateColumn string, startDate, endDate time.Time, dayCount int) (avgRowCountPerDay int)
  • func (this DB) GetAvgRowParamsPerDay(tableName, dateColumn string, startDate, endDate time.Time, dayCount int, ...) []map[string]interface{}
  • func (this DB) GetRowCountOnDate(tableName, dateColumn string, date time.Time) (yesterdayRowCount int)
  • func (this DB) GetRowParamsOnDate(tableName, dateColumn string, date time.Time, quantityColumn string, ...) []map[string]interface{}
  • func (this DB) InsertMultiple(tableName string, rows [][]interface{}, columns []string)
  • func (this DB) QueryObjects(sqlQuery string, values ...interface{}) (objects []map[string]interface{})
  • func (this DB) Quote(statement string) string
  • func (this DB) QuoteMultiple(statements []string) (quotedStatements []string)

Types

type DB

type DB struct {
	Driver, Host, Port, User, Password, Database string
}

func (DB) Connect

func (this DB) Connect() *sql.DB

func (DB) CreateTable

func (this DB) CreateTable(tableName string, columns []string)

func (DB) DropTable

func (this DB) DropTable(tableName string)

func (DB) Exec

func (this DB) Exec(sqlQuery string)

func (DB) GetAvgRowCountPerDay

func (this DB) GetAvgRowCountPerDay(
	tableName, dateColumn string,
	startDate, endDate time.Time,
	dayCount int) (avgRowCountPerDay int)

func (DB) GetAvgRowParamsPerDay

func (this DB) GetAvgRowParamsPerDay(
	tableName, dateColumn string,
	startDate, endDate time.Time,
	dayCount int,
	quantityColumn string,
	numericColumns []string,
	groupColumn string,
	filteredGroups []interface{}) []map[string]interface{}

func (DB) GetRowCountOnDate

func (this DB) GetRowCountOnDate(tableName, dateColumn string, date time.Time) (yesterdayRowCount int)

func (DB) GetRowParamsOnDate

func (this DB) GetRowParamsOnDate(
	tableName, dateColumn string,
	date time.Time,
	quantityColumn string,
	numericColumns []string,
	groupColumn string,
	filteredGroups []interface{}) []map[string]interface{}

func (DB) InsertMultiple

func (this DB) InsertMultiple(tableName string, rows [][]interface{}, columns []string)

func (DB) QueryObjects

func (this DB) QueryObjects(sqlQuery string, values ...interface{}) (objects []map[string]interface{})

func (DB) Quote

func (this DB) Quote(statement string) string

func (DB) QuoteMultiple

func (this DB) QuoteMultiple(statements []string) (quotedStatements []string)