Package org.apache.phoenix.parse

Examples of org.apache.phoenix.parse.SQLParser.parseQuery()


public class SelectStatementRewriterTest extends BaseConnectionlessQueryTest {
    private static Expression compileStatement(String query) throws SQLException {
        Scan scan = new Scan();
        List<Object> binds = Collections.emptyList();
        SQLParser parser = new SQLParser(query);
        SelectStatement statement = parser.parseQuery();
        PhoenixConnection pconn = DriverManager.getConnection(getUrl(), TEST_PROPERTIES).unwrap(PhoenixConnection.class);
        ColumnResolver resolver = FromCompiler.getResolver(statement, pconn);
        statement = StatementNormalizer.normalize(statement, resolver);
        StatementContext context = new StatementContext(statement, pconn, resolver, binds, scan);
        Expression whereClause = WhereCompiler.compile(context, statement);
View Full Code Here


    }
   
    private static JoinSpec getJoinSpec(String query, PhoenixConnection connection) throws SQLException {
        Scan scan = new Scan();
        SQLParser parser = new SQLParser(query);
        SelectStatement select = parser.parseQuery();
        ColumnResolver resolver = FromCompiler.getResolverForQuery(select, connection);
        select = StatementNormalizer.normalize(select, resolver);
        StatementContext context = new StatementContext(new PhoenixStatement(connection), resolver, scan);
        return JoinCompiler.getJoinSpec(context, select);       
    }
View Full Code Here

TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.