Method parseSelectStmt

database/postgres/parser.go:370–487

(stmt *pgquery.SelectStmt)

}

func (p PostgresParser) parseSelectStmt(stmt *pgquery.SelectStmt) (parser.SelectStatement, error) {
	unhandled := stmt.IntoClause != nil ||
		stmt.WindowClause != nil ||
		stmt.SortClause != nil ||
		stmt.ValuesLists != nil ||
		stmt.LimitOffset != nil ||
		stmt.LimitCount != nil ||
		stmt.LimitOption != 1 ||
		stmt.LockingClause != nil ||
		stmt.WithClause != nil ||
		stmt.Op != 1 ||
		stmt.All ||
		stmt.Larg != nil ||
		stmt.Rarg != nil
	if unhandled {
		return nil, fmt.Errorf("unhandled node in parseSelectStmt: %#v", stmt)
	}

	var selectExprs parser.SelectExprs
	for _, target := range stmt.TargetList {
		switch node := target.Node.(type) {
		case *pgquery.Node_ResTarget:
			selectExpr, err := p.parseResTarget(node.ResTarget)
			if err != nil {
				return nil, err
			}
			selectExprs = append(selectExprs, selectExpr)
		default:
			return nil, fmt.Errorf("unknown node in parseSelectStmt: %#v", node)
		}
	}

	var fromTable parser.TableName
	var aliasName string
	if len(stmt.FromClause) == 0 {
		fromTable = parser.TableName{
			Name:   parser.NewIdent("", false),
			Schema: parser.NewIdent("", false),
		}
	} else {
		var err error
		switch node := stmt.FromClause[0].Node.(type) {
		case *pgquery.Node_RangeVar:
			fromTable, err = p.parseTableName(node.RangeVar)
			if err != nil {
				return nil, err
			}
			if node.RangeVar.Alias != nil {
				aliasName = node.RangeVar.Alias.Aliasname
			}
		default:
			return nil, fmt.Errorf("unknown node in parseSelectStmt: %#v", node)
		}
	}

	var distinct *parser.DistinctClause
	if stmt.DistinctClause != nil {
		distinct = &parser.DistinctClause{}