Method parseResTarget

database/postgres/parser.go:489–533

(stmt *pgquery.ResTarget)

}

func (p PostgresParser) parseResTarget(stmt *pgquery.ResTarget) (parser.SelectExpr, error) {
	if node, ok := stmt.Val.Node.(*pgquery.Node_ColumnRef); ok {
		fields := node.ColumnRef.Fields
		fieldsLen := len(fields)
		column := fields[fieldsLen-1]
		if _, ok := column.Node.(*pgquery.Node_AStar); ok {
			var tableName string
			var schemaName string
			if fieldsLen >= 2 {
				tableField := fields[fieldsLen-2]
				tableNode, ok := tableField.Node.(*pgquery.Node_String_)
				if !ok {
					return nil, fmt.Errorf("Invalid table field node type: %#v", tableField)
				}
				tableName = tableNode.String_.Sval

				if fieldsLen >= 3 {
					schemaField := fields[fieldsLen-3]
					schemaNode, ok := schemaField.Node.(*pgquery.Node_String_)
					if !ok {
						return nil, fmt.Errorf("Invalid schema field node type: %#v", schemaField)
					}
					schemaName = schemaNode.String_.Sval
				}
			}

			return &parser.StarExpr{
				TableName: parser.TableName{
					Name:   parser.NewIdent(tableName, false),
					Schema: parser.NewIdent(schemaName, false),
				},
			}, nil
		}
	}

	expr, err := p.parseExpr(stmt.Val)
	if err != nil {
		return nil, err
	}

	return &parser.AliasedExpr{
		Expr: expr,
		As:   parser.NewIdent(stmt.Name, false),
	}, nil
}

func (p PostgresParser) parseExpr(stmt *pgquery.Node) (parser.Expr, error) {
	switch node := stmt.Node.(type) {