Examples of javax.sql.rowset.spi.SyncProviderException

javax.sql.rowset.spi.SyncProviderException
Indicates an error with the SyncProvider mechanism. This exception is created by a SyncProvider abstract class extension if it encounters violations in reading from or writing to the originating data source.
If it is implemented to do so, the SyncProvider object may also create a SyncResolver object and either initialize the SyncProviderException object with it at construction time or set it with the SyncProvider object at a later time.
The method acceptChanges will throw this exception after the writer has finished checking for conflicts and has found one or more conflicts. An application may catch a SyncProviderException object and call its getSyncResolver method to get its SyncResolver object. See the code fragment in the interface comment for SyncResolver for an example. This SyncResolver object will mirror the RowSet object that generated the exception, except that it will contain only the values from the data source that are in conflict. All other values in the SyncResolver object will be null.
The SyncResolver object may be used to examine and resolve each conflict in a row and then go to the next row with a conflict to repeat the procedure.
A SyncProviderException object may or may not contain a description of the condition causing the exception. The inherited method getMessage may be called to retrieve the description if there is one. @author Jonathan Bruce @see javax.sql.rowset.spi.SyncFactory @see javax.sql.rowset.spi.SyncResolver @see javax.sql.rowset.spi.SyncFactoryException

            RowSetWriter rowSetWriter = syncProvider.getRowSetWriter();
            rowSetWriter.writeData(this);
            // acceptChanges(this.getConnection());
        } catch (SQLException e) {
            e.printStackTrace();
            throw new SyncProviderException();
        }
    }

View Full Code Here

        }
    }


    public void acceptChanges(Connection con) throws SyncProviderException {
        if (currentRow == insertRow)
            throw new SyncProviderException();
        throw new NotImplementedException();
    }

View Full Code Here

    assertFalse(this.dialect.indicatesFailure(new SQLTransactionRollbackException()));
    assertFalse(this.dialect.indicatesFailure(new SQLWarning()));
    assertFalse(this.dialect.indicatesFailure(new DataTruncation(1, false, false, 1, 1)));
    assertFalse(this.dialect.indicatesFailure(new SQLDataException()));
    assertFalse(this.dialect.indicatesFailure(new SyncFactoryException()));
    assertFalse(this.dialect.indicatesFailure(new SyncProviderException()));
  }

View Full Code Here

    assertFalse(this.dialect.indicatesFailure(new SQLTransactionRollbackException()));
    assertFalse(this.dialect.indicatesFailure(new SQLWarning()));
    assertFalse(this.dialect.indicatesFailure(new DataTruncation(1, false, false, 1, 1)));
    assertFalse(this.dialect.indicatesFailure(new SQLDataException()));
    assertFalse(this.dialect.indicatesFailure(new SyncFactoryException()));
    assertFalse(this.dialect.indicatesFailure(new SyncProviderException()));
  }

View Full Code Here

        this.columnCount = cloumnCount;
    }


    public void acceptChanges() throws SyncProviderException {
        if (currentRow == insertRow && currentRow != null) {
            throw new SyncProviderException();
        }


        try {
            acceptChanges(getConnection());
        } catch (SQLException e) {

View Full Code Here

    }


    public void acceptChanges(Connection con) throws SyncProviderException {
        if (currentRow == insertRow && currentRow != null) {
            // TODO add error messages
            throw new SyncProviderException();
        }


        try {
            CachedRowSetWriter rowSetWriter = (CachedRowSetWriter) syncProvider
                    .getRowSetWriter();
            rowSetWriter.setConnection(con);
            int beforeWriteIndex = currentRowIndex;
            rowSetWriter.writeData(this);
            absolute(beforeWriteIndex);
            /*
             * FIXME: if no conflicts happen when writeData, then call
             * setOriginalRow()
             */
            notifyRowSetChanged();


        } catch (SyncProviderException e) {
            throw e;
        } catch (SQLException e) {
            throw new SyncProviderException(e.getMessage());
        }
    }

View Full Code Here

    }


    public void acceptChanges() throws SyncProviderException {
        if (isCursorOnInsert) {
            // rowset.11=Illegal operation on an insert row
            throw new SyncProviderException(Messages.getString("rowset.11")); //$NON-NLS-1$
        }


        Connection currentConn = null;
        Connection preConn = conn;
        try {
            currentConn = retrieveConnection();
            currentConn.setTypeMap(getTypeMap());
            acceptChanges(currentConn);
            currentConn.commit();
        } catch (SQLException e) {
            try {
                if (currentConn != null) {
                    currentConn.rollback();
                }
            } catch (SQLException ex) {
                // ignore
            }
            SyncProviderException ex = new SyncProviderException();
            ex.initCause(e);
            throw ex;
        } finally {
            conn = preConn;
            if (currentConn != null) {
                try {
                    currentConn.close();
                } catch (SQLException ex) {
                    SyncProviderException spe = new SyncProviderException();
                    spe.initCause(ex);
                    throw spe;
                }
            }
        }
    }

View Full Code Here


    public void acceptChanges(Connection connection)
            throws SyncProviderException {
        if (isCursorOnInsert) {
            // rowset.11=Illegal operation on an insert row
            throw new SyncProviderException(Messages.getString("rowset.11")); //$NON-NLS-1$
        }


        // Follow RI to assign conn before checking whether conn is null
        conn = connection;


        if (conn == null) {
            throw new SyncProviderException();
        }


        boolean isShowDeleted = false;
        try {
            isShowDeleted = getShowDeleted();
        } catch (SQLException e) {
            // ignore
        }


        try {
            conn.setAutoCommit(false);
            CachedRowSetWriter rowSetWriter = (CachedRowSetWriter) syncProvider
                    .getRowSetWriter();
            rowSetWriter.setConnection(conn);
            int beforeWriteIndex = currentRowIndex;
            // writer use next navigate rowset, so must make all rows visible
            setShowDeleted(true);


            if (!rowSetWriter.writeData(this)) {
                throw rowSetWriter.getSyncException();
            }


            // must reset curosr before reset showDeleted
            absolute(beforeWriteIndex);
            setShowDeleted(isShowDeleted);


            // record to the next visible row index
            int index = getRow();
            if (index == 0) {
                next();
                index = getRow();
                if (index == 0) {
                    index = rows.size() + 1;
                }
            }


            boolean isChanged = false;
            for (int i = rows.size() - 1; i >= 0; i--) {
                currentRow = rows.get(i);
                if (rowDeleted()) {
                    isChanged = true;
                    setOriginalRow();
                } else if (rowInserted() || rowUpdated()) {
                    isChanged = true;
                    setOriginalRow();
                }
            }
            // Set originalResultSet
            if (isChanged) {
                try {
                    ArrayList<CachedRow> nowRows = new ArrayList<CachedRow>();
                    for (int i = 0; i < rows.size(); i++) {
                        nowRows.add(rows.get(i).createClone());
                        nowRows.get(i).restoreOriginal();
                    }
                    originalResultSet.setRows(nowRows, columnCount);
                } catch (CloneNotSupportedException cloneE) {
                    throw new SyncProviderException(cloneE.getMessage());
                }
            }


            deletedRowCount = 0;


            // move cursor
            if (index > rows.size()) {
                afterLast();
            } else if (index <= 0) {
                beforeFirst();
            } else {
                absolute(index);
            }


            if (isNotifyListener) {
                notifyRowSetChanged();
            }


        } catch (SyncProviderException e) {
            throw e;
        } catch (SQLException e) {
            SyncProviderException ex = new SyncProviderException();
            ex.initCause(e);
            throw ex;
        } finally {
            try {
                setShowDeleted(isShowDeleted);
            } catch (SQLException e) {

View Full Code Here

        }
        try {
            preSt.executeUpdate();
        } catch (SQLException e) {
            // TODO generate SyncProviderException
            throw new SyncProviderException();
        } finally {
            preSt.close();
        }
    }

View Full Code Here

        fillParamInPreStatement(preSt, updateCount + 1);
        try {
            preSt.executeUpdate();
        } catch (SQLException e) {
            // TODO generate SyncProviderException
            throw new SyncProviderException();
        } finally {
            preSt.close();
        }
    }

View Full Code Here

0 1 2

TOP

Related Classes of javax.sql.rowset.spi.SyncProviderException

net.sf.hajdbc.dialect.StandardDialectTest

org.apache.harmony.sql.internal.rowset.CachedRowSetImpl

org.apache.harmony.sql.internal.rowset.CachedRowSetWriter

org.apache.harmony.sql.internal.rowset.HYOptimisticProvider

org.apache.harmony.sql.tests.internal.rowset.SyncResolverTest

org.apache.harmony.sql.tests.javax.sql.rowset.spi.SyncProviderExceptionTest

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.