Examples of org.hsqldb.navigator.RangeIterator

org.hsqldb.navigator.RangeIterator
@author Fred Toussi (fredt@users dot sourceforge.net) @version 1.9.0 @since 1.9.0


    void insertRowSet(Session session, RowSetNavigator generatedNavigator,
                      RowSetNavigator newData) {


        PersistentStore store         = baseTable.getRowStore(session);
        RangeIterator   checkIterator = null;


        if (updatableTableCheck != null) {
            checkIterator = checkRangeVariable.getIterator(session);
        }


        newData.beforeFirst();


        if (baseTable.triggerLists[Trigger.INSERT_BEFORE_ROW].length > 0) {
            while (newData.hasNext()) {
                Object[] data = (Object[]) newData.getNext();


                baseTable.fireTriggers(session, Trigger.INSERT_BEFORE_ROW,
                                       null, data, null);
            }


            newData.beforeFirst();
        }


        while (newData.hasNext()) {
            Object[] data = (Object[]) newData.getNext();


            // for identity using global sequence
            session.sessionData.startRowProcessing();
            baseTable.insertSingleRow(session, store, data, null);


            if (checkIterator != null) {
                checkIterator.setCurrent(data);


                boolean check = updatableTableCheck.testCondition(session);


                if (!check) {
                    throw Error.error(ErrorCode.X_44000);

View Full Code Here

     * @return the result of executing the statement
     */
    Result executeDeleteStatement(Session session) {


        int count = 0;
        RangeIterator it = RangeVariable.getIterator(session,
            targetRangeVariables);
        RowSetNavigatorDataChange rowset =
            session.sessionContext.getRowSetDataChange();


        session.sessionContext.rownum = 1;


        while (it.next()) {
            Row currentRow = it.getCurrentRow();


            rowset.addRow(currentRow);


            session.sessionContext.rownum++;
        }


        it.release();
        rowset.endMainDataSet();


        if (rowset.getSize() > 0) {
            count = delete(session, baseTable, rowset);
        } else {

View Full Code Here

        }
    }


    public RangeIteratorBase getCheckIterator(RangeVariable rangeVariable) {


        RangeIterator it = rangeIterators[0];


        if (it == null) {
            it                = rangeVariable.getIterator(session);
            rangeIterators[0] = it;
        }

View Full Code Here

                if (end) {
                    break;
                }
            }


            RangeIterator it = rangeIterators[currentIndex];


            if (it.next()) {
                if (currentIndex < rangeVariables.length - 1) {
                    currentIndex++;


                    continue;
                }
            } else {
                it.reset();


                currentIndex--;


                continue;
            }


            session.sessionData.startRowProcessing();


            Object[] data = new Object[indexLimitData];


            for (int i = 0; i < indexStartAggregates; i++) {
                if (isAggregated && aggregateCheck[i]) {
                    continue;
                } else {
                    data[i] = exprColumns[i].getValue(session);
                }
            }


            for (int i = indexLimitVisible; i < indexLimitRowId; i++) {
                if (i == indexLimitVisible) {
                    data[i] = it.getRowidObject();
                } else {
                    data[i] = it.getCurrentRow();
                }
            }


            session.sessionContext.rownum++;

View Full Code Here

        Expression[] colExpressions = updateExpressions;
        RowSetNavigatorDataChange rowset =
            new RowSetNavigatorDataChange(session.database.sqlEnforceTDCD,
                                          session.database.sqlEnforceTDCU);
        Type[] colTypes = baseTable.getColumnTypes();
        RangeIterator it = RangeVariable.getIterator(session,
            targetRangeVariables);
        Result          resultOut          = null;
        RowSetNavigator generatedNavigator = null;


        if (generatedIndexes != null) {
            resultOut = Result.newUpdateCountResult(generatedResultMetaData,
                    0);
            generatedNavigator = resultOut.getChainedResult().getNavigator();
        }


        while (it.next()) {
            session.sessionData.startRowProcessing();


            Row      row  = it.getCurrentRow();
            Object[] data = row.getData();
            Object[] newData = getUpdatedData(session, targets, baseTable,
                                              updateColumnMap, colExpressions,
                                              colTypes, data);


            if (updatableTableCheck != null) {
                it.setCurrent(newData);


                boolean check = updatableTableCheck.testCondition(session);


                if (!check) {
                    it.release();


                    throw Error.error(ErrorCode.X_44000);
                }
            }


            rowset.addRow(session, row, newData, colTypes, updateColumnMap);
        }


        it.release();
/* debug 190
        if (rowset.size() == 0) {
            System.out.println(targetTable.getName().name + " zero update: session "
                               + session.getId());
        } else if (rowset.size() >1) {

View Full Code Here

        for (int i = 0; i < joinRangeIterators.length; i++) {
            rangeIterators[i] = joinRangeIterators[i].getIterator(session);
        }


        for (int currentIndex = 0; currentIndex >= 0; ) {
            RangeIterator it          = rangeIterators[currentIndex];
            boolean       beforeFirst = it.isBeforeFirst();


            if (it.next()) {
                if (currentIndex < joinRangeIterators.length - 1) {
                    currentIndex++;


                    continue;
                }
            } else {
                if (currentIndex == 1 && beforeFirst
                        && insertExpression != null) {
                    Object[] data =
                        getInsertData(session, colTypes,
                                      insertExpression.nodes[0].nodes);


                    if (data != null) {
                        newData.add(data);
                    }
                }


                it.reset();


                currentIndex--;


                continue;
            }


            // row matches!
            if (updateExpressions.length != 0) {
                Row row = it.getCurrentRow();    // this is always the second iterator


                session.sessionData.startRowProcessing();


                Object[] data = getUpdatedData(session, targets, baseTable,
                                               updateColumnMap,

View Full Code Here


    void insertRowSet(Session session, RowSetNavigator generatedNavigator,
                      RowSetNavigator newData) {


        PersistentStore store         = baseTable.getRowStore(session);
        RangeIterator   checkIterator = null;


        if (updatableTableCheck != null) {
            checkIterator = checkRangeVariable.getIterator(session);
        }


        newData.beforeFirst();


        if (baseTable.triggerLists[Trigger.INSERT_BEFORE_ROW].length > 0) {
            while (newData.hasNext()) {
                Object[] data = (Object[]) newData.getNext();


                baseTable.fireTriggers(session, Trigger.INSERT_BEFORE_ROW,
                                       null, data, null);
            }


            newData.beforeFirst();
        }


        while (newData.hasNext()) {
            Object[] data = (Object[]) newData.getNext();


            baseTable.insertSingleRow(session, store, data, null);


            if (checkIterator != null) {
                checkIterator.setCurrent(data);


                boolean check = updatableTableCheck.testCondition(session);


                if (!check) {
                    throw Error.error(ErrorCode.X_44000);

View Full Code Here

     * @return the result of executing the statement
     */
    Result executeDeleteStatement(Session session) {


        int count = 0;
        RangeIterator it = RangeVariable.getIterator(session,
            targetRangeVariables);
        RowSetNavigatorDataChange navigator =
            new RowSetNavigatorDataChange(session.database.sqlEnforceTDCD,
                                          session.database.sqlEnforceTDCU);


        while (it.next()) {
            Row currentRow = it.getCurrentRow();


            navigator.addRow(currentRow);
        }


        it.release();


        if (navigator.getSize() > 0) {
            count = delete(session, baseTable, navigator);
        } else {
            return Result.updateZeroResult;

View Full Code Here

        for (int i = 0; i < joinRangeIterators.length; i++) {
            rangeIterators[i] = joinRangeIterators[i].getIterator(session);
        }


        for (int currentIndex = 0; 0 <= currentIndex; ) {
            RangeIterator it          = rangeIterators[currentIndex];
            boolean       beforeFirst = it.isBeforeFirst();


            if (it.next()) {
                if (currentIndex < joinRangeIterators.length - 1) {
                    currentIndex++;


                    continue;
                }
            } else {
                if (currentIndex == 1 && beforeFirst) {
                    Object[] data = getMergeInsertData(session);


                    if (data != null) {
                        newData.add(data);
                    }
                }


                it.reset();


                currentIndex--;


                continue;
            }


            // row matches!
            if (updateExpressions != null) {
                Row row = it.getCurrentRow();    // this is always the second iterator
                Object[] data = getUpdatedData(session, baseTable,
                                               updateColumnMap,
                                               updateExpressions,
                                               baseTable.getColumnTypes(),
                                               row.getData());

View Full Code Here

     */
    Result executeDeleteStatement(Session session) {


        int                       count   = 0;
        RowSetNavigatorLinkedList oldRows = new RowSetNavigatorLinkedList();
        RangeIterator it = RangeVariable.getIterator(session,
            targetRangeVariables);


        while (it.next()) {
            Row currentRow = it.getCurrentRow();


            oldRows.add(currentRow);
        }


        count = delete(session, baseTable, oldRows);

View Full Code Here

0 1 2

TOP

Related Classes of org.hsqldb.navigator.RangeIterator

org.hsqldb.QuerySpecification

org.hsqldb.SessionContext

org.hsqldb.StatementDML

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.