Package com.foundationdb.sql.parser

Examples of com.foundationdb.sql.parser.StatementNode

800
801
802
803
804
805
806
807
808
809
810
            }
        }
       
       
        if (pstmt == null) {
            StatementNode stmt;
            List<ParameterNode> params;
            try {
                sessionMonitor.enterStage(MonitorStage.PARSE);
                stmt = parser.parseStatement(sql);
                params = parser.getParameterList();
View Full Code Here
48
49
50
51
52
53
54
55
56
57
58
    public PostgresStatement generateStub(PostgresServerSession server,
                                          String sql, StatementNode stmt,
                                          List<ParameterNode> params, int[] paramTypes)  {
        if (stmt.getNodeType() != NodeTypes.EXPLAIN_STATEMENT_NODE)
            return null;
        StatementNode innerStmt = ((ExplainStatementNode)stmt).getStatement();
        if (compiler == null)
            throw new UnsupportedExplainException();
        if (!(innerStmt instanceof DMLStatementNode))
            throw new UnableToExplainException ();
        return new PostgresExplainStatement(compiler);
View Full Code Here
368
369
370
371
372
373
374
375
376
377
378
        LOG.debug("Creating Table As Select Online");

        txnService.beginTransaction(session);
        try {
            SQLParser parser = server.getParser();
            StatementNode stmt;
            String statement = "insert into " + tableName.toStringEscaped() + " " + queryExpression;
            try {
                stmt = parser.parseStatement(statement);
            } catch (StandardException e) {
                throw new SQLParserInternalException(e);//make specific runtime error unexpectedException
View Full Code Here
632
633
634
635
636
637
638
639
640
641
642
        Plannable deletePlan = null;
        Plannable insertPlan = null;
        for(ChangeSet cs : changeSets) {
            if(cs.hasSelectStatement()) {
                SQLParser parser = server.getParser();
                StatementNode insertStmt;
                try {
                    insertStmt = parser.parseStatement("insert into " + newAIS.getTable(cs.getToTableId()).getName().toStringEscaped() + " " + cs.getSelectStatement());
                } catch (StandardException e) {
                    throw new SQLParserInternalException(e);
                }
View Full Code Here
72
73
74
75
76
77
78
79
80
    @Test
    public void createNewTableWithIfNotExists() throws StandardException
    {
        String sql = "CREATE TABLE IF NOT EXISTS t1 (c1 INT)";
        createTableSimpleGenerateAIS();
        StatementNode createNode = parser.parseStatement(sql);
        assertTrue(createNode instanceof CreateTableNode);
        TableDDL.createTable(ddlFunctions, null, DEFAULT_SCHEMA, (CreateTableNode) createNode, null);
    }
View Full Code Here
82
83
84
85
86
87
88
89
90
    @Test
    public void createDuplicateTableWithIfNotExists() throws StandardException
    {
        String sql = "CREATE TABLE IF NOT EXISTS " + DEFAULT_TABLE + "(c1 INT)";
        createTableSimpleGenerateAIS(); // creates DEFAULT_SCHEMA.DEFAULT_TABLE
        StatementNode createNode = parser.parseStatement(sql);
        assertTrue(createNode instanceof CreateTableNode);
        TableDDL.createTable(ddlFunctions, null, DEFAULT_SCHEMA, (CreateTableNode) createNode, null);
    }
View Full Code Here
92
93
94
95
96
97
98
99
100
    @Test
    public void dropExistingTableWithIfExists() throws StandardException
    {
        String sql = "DROP TABLE IF EXISTS " + DEFAULT_TABLE;
        createTableSimpleGenerateAIS();
        StatementNode node = parser.parseStatement(sql);
        assertTrue(node instanceof DropTableNode);
        TableDDL.dropTable(ddlFunctions, null, DEFAULT_SCHEMA, (DropTableNode)node, null);
    }
View Full Code Here
102
103
104
105
106
107
108
109
110
    @Test
    public void dropNonExistingTableWithIfExists() throws StandardException
    {
        String sql = "DROP TABLE IF EXISTS chair";
        createTableSimpleGenerateAIS();
        StatementNode node = parser.parseStatement(sql);
        assertTrue(node instanceof DropTableNode);
        TableDDL.dropTable(ddlFunctions, null, DEFAULT_SCHEMA, (DropTableNode)node, null);
    }
View Full Code Here
112
113
114
115
116
117
118
119
120
121
    @Test
    public void dropTableSimple() throws Exception {
        String sql = "DROP TABLE t1";
        dropTable = TableName.create(DEFAULT_SCHEMA, DEFAULT_TABLE);
        createTableSimpleGenerateAIS ();
        StatementNode stmt = parser.parseStatement(sql);
        assertTrue (stmt instanceof DropTableNode);
       
        TableDDL.dropTable(ddlFunctions, null, DEFAULT_SCHEMA, (DropTableNode)stmt, null);
    }
View Full Code Here
123
124
125
126
127
128
129
130
131
132
    @Test
    public void dropTableSchemaTrue() throws Exception {
        String sql = "DROP TABLE test.t1";
        dropTable = TableName.create(DEFAULT_SCHEMA, DEFAULT_TABLE);
        createTableSimpleGenerateAIS ();
        StatementNode stmt = parser.parseStatement(sql);
        assertTrue (stmt instanceof DropTableNode);
       
        TableDDL.dropTable(ddlFunctions, null, DEFAULT_SCHEMA, (DropTableNode)stmt, null);
    }
View Full Code Here
TOP

Related Classes of com.foundationdb.sql.parser.StatementNode

  • com.foundationdb.server.service.dxl.BasicDDLFunctions
  • com.foundationdb.server.store.OnlineHelper
  • com.foundationdb.server.test.ApiTestBase
  • com.foundationdb.server.types.common.types.TypesTranslatorTest
  • com.foundationdb.sql.aisddl.AISDDLITBase
  • com.foundationdb.sql.aisddl.AlterTableDDLTest
  • com.foundationdb.sql.aisddl.SchemaDDLTest
  • com.foundationdb.sql.aisddl.TableDDLTest
  • com.foundationdb.sql.compiler.BooleanNormalizerTest
  • com.foundationdb.sql.embedded.JDBCConnection
    • Copyright © 2018 www.massapicom. 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.