sqlquery

README

sql-query

golang sql query utils

Documentation

Index

• func NormalizeField(fieldname string) (string, error)
• type Database
• type Field
  • func GetFieldsFromStruct(tablename string, i interface{}) []Field
  • func NormalCriteriaAlias(s Searchable, fieldname string) (Field, error)
• type Queryable
• type Searchable
• type SqlQueryHandler
  • func (o *SqlQueryHandler) AndEqual(s Searchable, fieldName string, _ interface{}) string
  • func (o *SqlQueryHandler) AndEqualString(fieldName string, field sql.NullString) string
  • func (o *SqlQueryHandler) AndEqualStringT(tableName string, fieldName string, field sql.NullString) string
  • func (o *SqlQueryHandler) AndGreaterThan(s Searchable, fieldName string, _ interface{}) string
  • func (o *SqlQueryHandler) AndGreaterThanEqual(s Searchable, fieldName string, _ interface{}) string
  • func (o *SqlQueryHandler) AndIsIn(s Searchable, fieldName string, rhs interface{}) string
  • func (o *SqlQueryHandler) AndLessThan(s Searchable, fieldName string, _ interface{}) string
  • func (o *SqlQueryHandler) AndLessThanEqual(s Searchable, fieldName string, _ interface{}) string
  • func (o *SqlQueryHandler) AndLike(s Searchable, fieldName string, _ interface{}) string
  • func (o *SqlQueryHandler) AndLikeString(fieldName string, field sql.NullString) string
  • func (o *SqlQueryHandler) AndLikeStringT(tableName string, fieldName string, field sql.NullString) string
  • func (o *SqlQueryHandler) Begin(db *Database) *sqlx.Tx
  • func (o *SqlQueryHandler) Commit(tx *sqlx.Tx)
  • func (o *SqlQueryHandler) CommitOrRollback(tx *sqlx.Tx)
  • func (o *SqlQueryHandler) Connect(db *Database, driverName string, dataSourceName string)
  • func (o *SqlQueryHandler) DefaultContext() (context.Context, context.CancelFunc)
  • func (o *SqlQueryHandler) Error() bool
  • func (o *SqlQueryHandler) Init(errp *error)
  • func (o *SqlQueryHandler) Rollback(tx *sqlx.Tx)
  • func (o *SqlQueryHandler) Set(err error)

Functions

func NormalizeField

func NormalizeField(fieldname string) (string, error)

Types

type Database

type Database struct {
	Conn *sqlx.DB
}

type Field

type Field struct {
	Table string
	Name  string
}

func GetFieldsFromStruct

func GetFieldsFromStruct(tablename string, i interface{}) []Field

func NormalCriteriaAlias

func NormalCriteriaAlias(s Searchable, fieldname string) (Field, error)

type Queryable

type Queryable interface {
	QueryContext(ctx context.Context, query string, args ...interface{}) (*sql.Rows, error)
	QueryxContext(ctx context.Context, query string, args ...interface{}) (*sqlx.Rows, error)
	ExecContext(ctx context.Context, query string, args ...interface{}) (sql.Result, error)
	NamedExecContext(ctx context.Context, query string, arg interface{}) (sql.Result, error)
	SelectContext(ctx context.Context, dest interface{}, query string, args ...interface{}) error
	Rebind(query string) string
}

type Searchable

type Searchable interface {
	Fields() []Field
	SelectFrom() string
	CriteriaAlias(string) (Field, error)
}

type SqlQueryHandler

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

func (*SqlQueryHandler) AndEqual

func (o *SqlQueryHandler) AndEqual(s Searchable, fieldName string, _ interface{}) string

func (*SqlQueryHandler) AndEqualString

func (o *SqlQueryHandler) AndEqualString(fieldName string, field sql.NullString) string

func (*SqlQueryHandler) AndEqualStringT

func (o *SqlQueryHandler) AndEqualStringT(tableName string, fieldName string, field sql.NullString) string

func (*SqlQueryHandler) AndGreaterThan

func (o *SqlQueryHandler) AndGreaterThan(s Searchable, fieldName string, _ interface{}) string

func (*SqlQueryHandler) AndGreaterThanEqual

func (o *SqlQueryHandler) AndGreaterThanEqual(s Searchable, fieldName string, _ interface{}) string

func (*SqlQueryHandler) AndIsIn

func (o *SqlQueryHandler) AndIsIn(s Searchable, fieldName string, rhs interface{}) string

func (*SqlQueryHandler) AndLessThan

func (o *SqlQueryHandler) AndLessThan(s Searchable, fieldName string, _ interface{}) string

func (*SqlQueryHandler) AndLessThanEqual

func (o *SqlQueryHandler) AndLessThanEqual(s Searchable, fieldName string, _ interface{}) string

func (*SqlQueryHandler) AndLike

func (o *SqlQueryHandler) AndLike(s Searchable, fieldName string, _ interface{}) string

func (*SqlQueryHandler) AndLikeString

func (o *SqlQueryHandler) AndLikeString(fieldName string, field sql.NullString) string

func (*SqlQueryHandler) AndLikeStringT

func (o *SqlQueryHandler) AndLikeStringT(tableName string, fieldName string, field sql.NullString) string

func (*SqlQueryHandler) Begin

func (o *SqlQueryHandler) Begin(db *Database) *sqlx.Tx

func (*SqlQueryHandler) Commit

func (o *SqlQueryHandler) Commit(tx *sqlx.Tx)

func (*SqlQueryHandler) CommitOrRollback

func (o *SqlQueryHandler) CommitOrRollback(tx *sqlx.Tx)

func (*SqlQueryHandler) Connect

func (o *SqlQueryHandler) Connect(db *Database, driverName string, dataSourceName string)

func (*SqlQueryHandler) DefaultContext

func (o *SqlQueryHandler) DefaultContext() (context.Context, context.CancelFunc)

func (*SqlQueryHandler) Error

func (o *SqlQueryHandler) Error() bool

func (*SqlQueryHandler) Init

func (o *SqlQueryHandler) Init(errp *error)

func (*SqlQueryHandler) Rollback

func (o *SqlQueryHandler) Rollback(tx *sqlx.Tx)

func (*SqlQueryHandler) Set

func (o *SqlQueryHandler) Set(err error)