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

        project.addStmtProcedure("SelectMultiPart", "SELECT * FROM P1");
        project.addStmtProcedure("UpdateMultiPart",
                                 "UPDATE P1 SET P1.NUM = ?");
        project.addStmtProcedure("InsertMultiPartRepl",
                                 "INSERT INTO R1 VALUES (?, ?, ?, ?);");
        project.addStmtProcedure("SelectMultiPartRepl", "SELECT * FROM R1");
        project.addStmtProcedure("UpdateMultiPartRepl",
                                 "UPDATE R1 SET R1.NUM = ?");
        project.addProcedures(PROCEDURES);


        /////////////////////////////////////////////////////////////

View Full Code Here

        project.addStmtProcedure("UpdateMultiPart",
                                 "UPDATE P1 SET P1.NUM = ?");
        project.addStmtProcedure("InsertMultiPartRepl",
                                 "INSERT INTO R1 VALUES (?, ?, ?, ?);");
        project.addStmtProcedure("SelectMultiPartRepl", "SELECT * FROM R1");
        project.addStmtProcedure("UpdateMultiPartRepl",
                                 "UPDATE R1 SET R1.NUM = ?");
        project.addProcedures(PROCEDURES);


        /////////////////////////////////////////////////////////////
        // CLUSTER, two hosts, each with two sites, replication of 1

View Full Code Here

        project.addProcedures(PROCEDURES);
        
        for (String tableName : ALL_TABLES) {
            String procName = "Eng397LimitIndex" + tableName;
            String sql = String.format("SELECT * FROM %s WHERE %s.ID > 2 LIMIT ?", tableName, tableName);
            project.addStmtProcedure(procName, sql);
        } // FOR
        project.addStmtProcedure("Eng506UpdateRange", "UPDATE P1IX SET NUM = ? WHERE (P1IX.ID>P1IX.NUM) AND (P1IX.NUM>?)");
        project.addStmtProcedure("InsertP1IX", "insert into P1IX values (?, ?, ?, ?);");


        boolean success;

View Full Code Here

        for (String tableName : ALL_TABLES) {
            String procName = "Eng397LimitIndex" + tableName;
            String sql = String.format("SELECT * FROM %s WHERE %s.ID > 2 LIMIT ?", tableName, tableName);
            project.addStmtProcedure(procName, sql);
        } // FOR
        project.addStmtProcedure("Eng506UpdateRange", "UPDATE P1IX SET NUM = ? WHERE (P1IX.ID>P1IX.NUM) AND (P1IX.NUM>?)");
        project.addStmtProcedure("InsertP1IX", "insert into P1IX values (?, ?, ?, ?);");


        boolean success;


        /////////////////////////////////////////////////////////////

View Full Code Here

            String procName = "Eng397LimitIndex" + tableName;
            String sql = String.format("SELECT * FROM %s WHERE %s.ID > 2 LIMIT ?", tableName, tableName);
            project.addStmtProcedure(procName, sql);
        } // FOR
        project.addStmtProcedure("Eng506UpdateRange", "UPDATE P1IX SET NUM = ? WHERE (P1IX.ID>P1IX.NUM) AND (P1IX.NUM>?)");
        project.addStmtProcedure("InsertP1IX", "insert into P1IX values (?, ?, ?, ?);");


        boolean success;


        /////////////////////////////////////////////////////////////
        // CONFIG #1: 1 Local Site/Partition

View Full Code Here

        project.addTablePartitionInfo("NEW_ORDER", "NO_W_ID");
        project.addTablePartitionInfo("FIVEK_STRING", "P");
        project.addTablePartitionInfo("FIVEK_STRING_WITH_INDEX", "ID");
        project.addTablePartitionInfo("WIDE", "P");
        project.addProcedures(PROCEDURES);
        project.addStmtProcedure("InsertNewOrder", "INSERT INTO NEW_ORDER VALUES (?, ?, ?);", "NEW_ORDER.NO_W_ID: 2");
        // build the jarfile
        if (!config.compile(project))
            fail();


        // add this config to the set of tests to run

View Full Code Here

        project.addTablePartitionInfo("P1", "ID");
        project.addTablePartitionInfo("P2", "ID");
        project.addTablePartitionInfo("ASSET", "ASSET_ID");
        project.addTablePartitionInfo("OBJECT_DETAIL", "OBJECT_DETAIL_ID");
        project.addProcedures(PROCEDURES);
        project.addStmtProcedure("Eng397Limit1", "Select P1.NUM from P1 order by P1.NUM limit ?;");
        
        // TODO: Hardcoded procedures for ad-hoc queries
        project.addStmtProcedure("Ticket309P1", "select count(*), P1.NUM from P1 group by P1.NUM");
        project.addStmtProcedure("Ticket309R1", "select count(*), R1.NUM from R1 group by R1.NUM");
        project.addStmtProcedure("Ticket309P2", "select count(*), P2.NUM from P2 group by P2.NUM");

View Full Code Here

        project.addTablePartitionInfo("OBJECT_DETAIL", "OBJECT_DETAIL_ID");
        project.addProcedures(PROCEDURES);
        project.addStmtProcedure("Eng397Limit1", "Select P1.NUM from P1 order by P1.NUM limit ?;");
        
        // TODO: Hardcoded procedures for ad-hoc queries
        project.addStmtProcedure("Ticket309P1", "select count(*), P1.NUM from P1 group by P1.NUM");
        project.addStmtProcedure("Ticket309R1", "select count(*), R1.NUM from R1 group by R1.NUM");
        project.addStmtProcedure("Ticket309P2", "select count(*), P2.NUM from P2 group by P2.NUM");
        project.addStmtProcedure("Ticket309R2", "select count(*), R2.NUM from R2 group by R2.NUM");


        VoltServerConfig config;

View Full Code Here

        project.addProcedures(PROCEDURES);
        project.addStmtProcedure("Eng397Limit1", "Select P1.NUM from P1 order by P1.NUM limit ?;");
        
        // TODO: Hardcoded procedures for ad-hoc queries
        project.addStmtProcedure("Ticket309P1", "select count(*), P1.NUM from P1 group by P1.NUM");
        project.addStmtProcedure("Ticket309R1", "select count(*), R1.NUM from R1 group by R1.NUM");
        project.addStmtProcedure("Ticket309P2", "select count(*), P2.NUM from P2 group by P2.NUM");
        project.addStmtProcedure("Ticket309R2", "select count(*), R2.NUM from R2 group by R2.NUM");


        VoltServerConfig config;
        boolean success;

View Full Code Here

        project.addStmtProcedure("Eng397Limit1", "Select P1.NUM from P1 order by P1.NUM limit ?;");
        
        // TODO: Hardcoded procedures for ad-hoc queries
        project.addStmtProcedure("Ticket309P1", "select count(*), P1.NUM from P1 group by P1.NUM");
        project.addStmtProcedure("Ticket309R1", "select count(*), R1.NUM from R1 group by R1.NUM");
        project.addStmtProcedure("Ticket309P2", "select count(*), P2.NUM from P2 group by P2.NUM");
        project.addStmtProcedure("Ticket309R2", "select count(*), R2.NUM from R2 group by R2.NUM");


        VoltServerConfig config;
        boolean success;

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.