Examples of org.voltdb.compiler.VoltProjectBuilder.addStmtProcedure()

Class org.voltdb.compiler.VoltProjectBuilder

Examples of org.voltdb.compiler.VoltProjectBuilder.addStmtProcedure()

org.voltdb.compiler.VoltProjectBuilder.addStmtProcedure()
Create a single statement procedure that only has one query The input parameters to the SQL statement will be automatically passed from the input parameters to the procedure. @param procedureName @param sql

        MultiConfigSuiteBuilder builder = new MultiConfigSuiteBuilder(TestPlanOptimizerSuite.class);
        VoltProjectBuilder project = new BasePlanOptimizerTestCase.PlanOptimizerTestProjectBuilder(PREFIX);
        VoltServerConfig config = null;
 
        // Single Statement Procedures
        project.addStmtProcedure("SimpleAggregate",
                                 "SELECT C_B_A_ID, AVG(C_VALUE0) " +
                                 "FROM TABLEC GROUP BY C_B_A_ID");
        project.addStmtProcedure("MultiAggregate",
                                 "SELECT C_B_A_ID, SUM(C_VALUE0), SUM(C_VALUE1), " +
                                 "       AVG(C_VALUE0), AVG(C_VALUE1) " +

View Full Code Here

 
        // Single Statement Procedures
        project.addStmtProcedure("SimpleAggregate",
                                 "SELECT C_B_A_ID, AVG(C_VALUE0) " +
                                 "FROM TABLEC GROUP BY C_B_A_ID");
        project.addStmtProcedure("MultiAggregate",
                                 "SELECT C_B_A_ID, SUM(C_VALUE0), SUM(C_VALUE1), " +
                                 "       AVG(C_VALUE0), AVG(C_VALUE1) " +
                                 "FROM TABLEC GROUP BY C_B_A_ID");
 
        // CLUSTER CONFIG #1

View Full Code Here

        VoltProjectBuilder project = new VoltProjectBuilder();


        project.addSchema(TestPlansGroupBy.class
                .getResource("testplans-groupby-ddl.sql"));
        project.addProcedures(PROCEDURES);
        project.addStmtProcedure("T1Insert", "INSERT INTO T1 VALUES (?, ?);");
        project.addStmtProcedure("BInsert", "INSERT INTO B VALUES (?, ?);");


        // config = new LocalSingleProcessServer("plansgroupby-ipc.jar", 1, BackendTarget.NATIVE_EE_IPC);
        // config.compile(project);
        // builder.addServerConfig(config);

View Full Code Here


        project.addSchema(TestPlansGroupBy.class
                .getResource("testplans-groupby-ddl.sql"));
        project.addProcedures(PROCEDURES);
        project.addStmtProcedure("T1Insert", "INSERT INTO T1 VALUES (?, ?);");
        project.addStmtProcedure("BInsert", "INSERT INTO B VALUES (?, ?);");


        // config = new LocalSingleProcessServer("plansgroupby-ipc.jar", 1, BackendTarget.NATIVE_EE_IPC);
        // config.compile(project);
        // builder.addServerConfig(config);

View Full Code Here

        project.addStmtProcedure("TestDecodeNullTimestamp", "select DECODE(tm, NULL, 'null tm', tm) from R3 where id = ?");


        project.addStmtProcedure("CONCAT2", "select id, CONCAT(DESC,?) from P1 where id = ?");
        project.addStmtProcedure("CONCAT3", "select id, CONCAT(DESC,?,?) from P1 where id = ?");
        project.addStmtProcedure("CONCAT4", "select id, CONCAT(DESC,?,?,?) from P1 where id = ?");
        project.addStmtProcedure("CONCAT5", "select id, CONCAT(DESC,?,?,?,cast(ID as VARCHAR)) from P1 where id = ?");
        project.addStmtProcedure("ConcatOpt", "select id, DESC || ? from P1 where id = ?");


        project.addProcedures(GotBadParamCountsInJava.class);
        // CONFIG #1: Local Site/Partition running on JNI backend
        config = new LocalCluster("fixedsql-onesite.jar", 1, 1, 0, BackendTarget.NATIVE_EE_JNI);

View Full Code Here


        project.addStmtProcedure("CONCAT2", "select id, CONCAT(DESC,?) from P1 where id = ?");
        project.addStmtProcedure("CONCAT3", "select id, CONCAT(DESC,?,?) from P1 where id = ?");
        project.addStmtProcedure("CONCAT4", "select id, CONCAT(DESC,?,?,?) from P1 where id = ?");
        project.addStmtProcedure("CONCAT5", "select id, CONCAT(DESC,?,?,?,cast(ID as VARCHAR)) from P1 where id = ?");
        project.addStmtProcedure("ConcatOpt", "select id, DESC || ? from P1 where id = ?");


        project.addProcedures(GotBadParamCountsInJava.class);
        // CONFIG #1: Local Site/Partition running on JNI backend
        config = new LocalCluster("fixedsql-onesite.jar", 1, 1, 0, BackendTarget.NATIVE_EE_JNI);
        success = config.compile(project);

View Full Code Here

        // build up a project builder for the workload
        VoltProjectBuilder project = new VoltProjectBuilder();
        project.addSchema(BatchedMultiPartitionTest.class.getResource("sqlindex-ddl.sql"));
        project.addProcedures(PROCEDURES);


        project.addStmtProcedure("TU1_LT",       "SELECT COUNT(*) FROM TU1 WHERE POINTS < ?");
        project.addStmtProcedure("TU1_LET",       "SELECT COUNT(*) FROM TU1 WHERE POINTS <= ?");
        project.addStmtProcedure("TU1_GT",       "SELECT COUNT(*) FROM TU1 WHERE POINTS > ?");
        project.addStmtProcedure("TU1_GET",       "SELECT COUNT(*) FROM TU1 WHERE POINTS >= ?");


        project.addStmtProcedure("TU3_LT",       "SELECT COUNT(*) FROM TU3 WHERE TEL = ? AND POINTS < ?");

View Full Code Here

        VoltProjectBuilder project = new VoltProjectBuilder();
        project.addSchema(BatchedMultiPartitionTest.class.getResource("sqlindex-ddl.sql"));
        project.addProcedures(PROCEDURES);


        project.addStmtProcedure("TU1_LT",       "SELECT COUNT(*) FROM TU1 WHERE POINTS < ?");
        project.addStmtProcedure("TU1_LET",       "SELECT COUNT(*) FROM TU1 WHERE POINTS <= ?");
        project.addStmtProcedure("TU1_GT",       "SELECT COUNT(*) FROM TU1 WHERE POINTS > ?");
        project.addStmtProcedure("TU1_GET",       "SELECT COUNT(*) FROM TU1 WHERE POINTS >= ?");


        project.addStmtProcedure("TU3_LT",       "SELECT COUNT(*) FROM TU3 WHERE TEL = ? AND POINTS < ?");
        project.addStmtProcedure("TU3_LET",       "SELECT COUNT(*) FROM TU3 WHERE TEL = ? AND POINTS <= ?");

View Full Code Here

        project.addSchema(BatchedMultiPartitionTest.class.getResource("sqlindex-ddl.sql"));
        project.addProcedures(PROCEDURES);


        project.addStmtProcedure("TU1_LT",       "SELECT COUNT(*) FROM TU1 WHERE POINTS < ?");
        project.addStmtProcedure("TU1_LET",       "SELECT COUNT(*) FROM TU1 WHERE POINTS <= ?");
        project.addStmtProcedure("TU1_GT",       "SELECT COUNT(*) FROM TU1 WHERE POINTS > ?");
        project.addStmtProcedure("TU1_GET",       "SELECT COUNT(*) FROM TU1 WHERE POINTS >= ?");


        project.addStmtProcedure("TU3_LT",       "SELECT COUNT(*) FROM TU3 WHERE TEL = ? AND POINTS < ?");
        project.addStmtProcedure("TU3_LET",       "SELECT COUNT(*) FROM TU3 WHERE TEL = ? AND POINTS <= ?");
        project.addStmtProcedure("TU3_GT_LT",       "SELECT COUNT(*) FROM TU3 WHERE TEL = ? AND POINTS > ? AND POINTS < ?");

View Full Code Here

        project.addProcedures(PROCEDURES);


        project.addStmtProcedure("TU1_LT",       "SELECT COUNT(*) FROM TU1 WHERE POINTS < ?");
        project.addStmtProcedure("TU1_LET",       "SELECT COUNT(*) FROM TU1 WHERE POINTS <= ?");
        project.addStmtProcedure("TU1_GT",       "SELECT COUNT(*) FROM TU1 WHERE POINTS > ?");
        project.addStmtProcedure("TU1_GET",       "SELECT COUNT(*) FROM TU1 WHERE POINTS >= ?");


        project.addStmtProcedure("TU3_LT",       "SELECT COUNT(*) FROM TU3 WHERE TEL = ? AND POINTS < ?");
        project.addStmtProcedure("TU3_LET",       "SELECT COUNT(*) FROM TU3 WHERE TEL = ? AND POINTS <= ?");
        project.addStmtProcedure("TU3_GT_LT",       "SELECT COUNT(*) FROM TU3 WHERE TEL = ? AND POINTS > ? AND POINTS < ?");
        project.addStmtProcedure("TU3_GT_LET",       "SELECT COUNT(*) FROM TU3 WHERE TEL = ? AND POINTS > ? AND POINTS <= ?");

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

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.