jet/sqlbuilder/select_statement.go

package sqlbuilder

import (
	"database/sql"
	"github.com/dropbox/godropbox/errors"
	"github.com/sub0zero/go-sqlbuilder/types"
)

type SelectStatement interface {
	Statement
	Expression

	DISTINCT() SelectStatement
	FROM(table ReadableTable) SelectStatement
	WHERE(expression BoolExpression) SelectStatement
	GROUP_BY(expressions ...Clause) SelectStatement
	HAVING(boolExpression BoolExpression) SelectStatement
	ORDER_BY(clauses ...OrderByClause) SelectStatement

	LIMIT(limit int64) SelectStatement
	OFFSET(offset int64) SelectStatement

	FOR_UPDATE() SelectStatement

	AsTable(alias string) ExpressionTable
}

var SELECT = func(projection ...Projection) SelectStatement {
	return newSelectStatement(nil, projection)
}

// NOTE: SelectStatement purposely does not implement the Table interface since
// mysql's subquery performance is horrible.
type selectStatementImpl struct {
	expressionInterfaceImpl

	table       ReadableTable
	distinct    bool
	projections []Projection
	where       BoolExpression
	groupBy     []Clause //can be ROLLUP, ... so clause for now
	having      BoolExpression
	orderBy     []OrderByClause

	limit, offset int64

	forUpdate bool
}

func defaultProjectionAliasing(projections []Projection) []Projection {
	aliasedProjections := []Projection{}

	for _, projection := range projections {
		if column, ok := projection.(Column); ok {
			aliasedProjections = append(aliasedProjections, column.DefaultAlias())
		} else if columnList, ok := projection.(ColumnList); ok {
			aliasedProjections = append(aliasedProjections, columnList.DefaultAlias()...)
		} else {
			aliasedProjections = append(aliasedProjections, projection)
		}
	}

	return aliasedProjections
}

func newSelectStatement(table ReadableTable, projections []Projection) SelectStatement {
	newSelect := &selectStatementImpl{
		table:       table,
		projections: defaultProjectionAliasing(projections),
		limit:       -1,
		offset:      -1,
		forUpdate:   false,
		distinct:    false,
	}

	newSelect.expressionInterfaceImpl.parent = newSelect

	return newSelect
}

func (s *selectStatementImpl) FROM(table ReadableTable) SelectStatement {
	s.table = table
	return s
}

func (s *selectStatementImpl) Serialize(out *queryData, options ...serializeOption) error {

	out.WriteString("(")

	err := s.serializeImpl(out, options...)

	if err != nil {
		return err
	}

	out.WriteString(")")

	return nil
}

func (s *selectStatementImpl) serializeImpl(out *queryData, options ...serializeOption) error {

	out.WriteString("SELECT ")
	out.statementType = select_statement

	if s.distinct {
		out.WriteString("DISTINCT ")
	}

	if s.projections == nil || len(s.projections) == 0 {
		return errors.New("No column selected for projection.")
	}

	err := out.WriteProjection(s.projections)

	if err != nil {
		return err
	}

	out.WriteString(" FROM ")

	if s.table == nil {
		return errors.Newf("nil tableName.")
	}

	if err := s.table.SerializeSql(out); err != nil {
		return err
	}

	if s.where != nil {
		err := out.WriteWhere(s.where)

		if err != nil {
			return nil
		}
	}

	if s.groupBy != nil && len(s.groupBy) > 0 {
		err := out.WriteGroupBy(s.groupBy)

		if err != nil {
			return err
		}
	}

	if s.having != nil {
		err := out.WriteHaving(s.having)

		if err != nil {
			return err
		}
	}

	if s.orderBy != nil {
		err := out.WriteOrderBy(s.orderBy)

		if err != nil {
			return err
		}
	}

	if s.limit >= 0 {
		out.WriteString(" LIMIT ")
		out.InsertArgument(s.limit)
	}

	if s.offset >= 0 {
		out.WriteString(" OFFSET ")
		out.InsertArgument(s.offset)
	}

	if s.forUpdate {
		out.WriteString(" FOR UPDATE")
	}

	return nil
}

// Return the properly escaped SQL statement, against the specified database
func (q *selectStatementImpl) Sql() (query string, args []interface{}, err error) {
	queryData := queryData{}

	err = q.serializeImpl(&queryData)

	if err != nil {
		return "", nil, err
	}

	return queryData.buff.String(), queryData.args, nil
}

func (s *selectStatementImpl) AsTable(alias string) ExpressionTable {
	return &expressionTableImpl{
		statement: s,
		alias:     alias,
	}
}

func (q *selectStatementImpl) WHERE(expression BoolExpression) SelectStatement {
	q.where = expression
	return q
}

func (s *selectStatementImpl) GROUP_BY(cluases ...Clause) SelectStatement {
	s.groupBy = cluases
	return s
}

func (q *selectStatementImpl) HAVING(expression BoolExpression) SelectStatement {
	q.having = expression
	return q
}

func (q *selectStatementImpl) ORDER_BY(clauses ...OrderByClause) SelectStatement {

	q.orderBy = clauses

	return q
}

func (q *selectStatementImpl) OFFSET(offset int64) SelectStatement {
	q.offset = offset
	return q
}

func (q *selectStatementImpl) LIMIT(limit int64) SelectStatement {
	q.limit = limit
	return q
}

func (q *selectStatementImpl) DISTINCT() SelectStatement {
	q.distinct = true
	return q
}

func (q *selectStatementImpl) FOR_UPDATE() SelectStatement {
	q.forUpdate = true
	return q
}

func (s *selectStatementImpl) Query(db types.Db, destination interface{}) error {
	return Query(s, db, destination)
}

func (u *selectStatementImpl) Execute(db types.Db) (res sql.Result, err error) {
	return Execute(u, db)
}

func NumExp(statement SelectStatement) NumericExpression {
	return newNumericExpressionWrap(statement)
}