Examples of com.mysql.clusterj.ClusterJException

com.mysql.clusterj.ClusterJException
ClusterJException is the base for all ClusterJ exceptions. Applications can catch ClusterJException to be notified of all ClusterJ reported issues.
Exceptions are in three general categories: User exceptions, Datastore exceptions, and Internal exceptions.
- User exceptions are caused by user error, for example providing a connect string that refers to an unavailable host or port.
  - If a user exception is detected during bootstrapping (acquiring a SessionFactory), it is thrown as a fatal exception. {@link ClusterJFatalUserException}
  - If an exception is detected during initialization of a persistent interface, for example annotating a column that doesn't exist in the mapped table, it is reported as a user exception. {@link ClusterJUserException}
- Datastore exceptions report conditions that result from datastore operations after bootstrapping. For example, duplicate keys on insert, or record does not exist on delete. {@link ClusterJDatastoreException}
- Internal exceptions report conditions that are caused by errors in implementation. These exceptions should be reported as bugs. {@link ClusterJFatalInternalException}

     */
    protected void internalRollback() {
        try {
                clusterTransaction.executeRollback();
        } catch (ClusterJException ex) {
            throw new ClusterJException(
                    local.message("ERR_Transaction_Execute", "rollback"), ex);
        } finally {
            if (clusterTransaction != null) {
                clusterTransaction.close();
            }

View Full Code Here


    protected void handleTransactionException() {
        if (transactionException == null) {
            return;
        } else {
            ClusterJException ex = transactionException;
            transactionException = null;
            throw ex;
        }
    }

View Full Code Here

        assertActive();
        try {
            IndexScanOperation result = clusterTransaction.getIndexScanOperation(storeIndex, storeTable);
            return result;
        } catch (ClusterJException ex) {
            throw new ClusterJException(
                    local.message("ERR_Index_Scan", storeTable.getName(), storeIndex.getName()), ex);
        }
    }

View Full Code Here

        assertActive();
        try {
            IndexScanOperation result = clusterTransaction.getIndexScanOperationMultiRange(storeIndex, storeTable);
            return result;
        } catch (ClusterJException ex) {
            throw new ClusterJException(
                    local.message("ERR_Index_Scan", storeTable.getName(), storeIndex.getName()), ex);
        }
    }

View Full Code Here

        assertActive();
        try {
            IndexScanOperation result = clusterTransaction.getIndexScanOperationLockModeExclusiveScanFlagKeyInfo(storeIndex, storeTable);
            return result;
        } catch (ClusterJException ex) {
            throw new ClusterJException(
                    local.message("ERR_Index_Scan", storeTable.getName(), storeIndex.getName()), ex);
        }
    }

View Full Code Here

        assertActive();
        try {
            ScanOperation result = clusterTransaction.getTableScanOperation(storeTable);
            return result;
        } catch (ClusterJException ex) {
            throw new ClusterJException(
                    local.message("ERR_Table_Scan", storeTable.getName()), ex);
        }
    }

View Full Code Here

       assertActive();
       try {
           ScanOperation result = clusterTransaction.getTableScanOperationLockModeExclusiveScanFlagKeyInfo(storeTable);
           return result;
       } catch (ClusterJException ex) {
           throw new ClusterJException(
                   local.message("ERR_Table_Scan", storeTable.getName()), ex);
       }
   }

View Full Code Here

        assertActive();
        try {
            IndexOperation result = clusterTransaction.getUniqueIndexOperation(storeIndex, storeTable);
            return result;
        } catch (ClusterJException ex) {
            throw new ClusterJException(
                    local.message("ERR_Unique_Index", storeTable.getName(), storeIndex.getName()), ex);
        }
    }

View Full Code Here

        assertActive();
        try {
            Operation result = clusterTransaction.getSelectOperation(storeTable);
            return result;
        } catch (ClusterJException ex) {
            throw new ClusterJException(
                    local.message("ERR_Select", storeTable), ex);
        }
    }

View Full Code Here

        assertActive();
        try {
            Operation result = clusterTransaction.getDeleteOperation(storeTable);
            return result;
        } catch (ClusterJException ex) {
            throw new ClusterJException(
                    local.message("ERR_Delete", storeTable), ex);
        }
    }

View Full Code Here

0 1 2 3 4

TOP

Related Classes of com.mysql.clusterj.ClusterJException

com.mysql.clusterj.core.metadata.AbstractDomainTypeHandlerImpl

com.mysql.clusterj.core.metadata.DomainTypeHandlerImpl

com.mysql.clusterj.core.query.AndPredicateImpl

com.mysql.clusterj.core.query.BetweenPredicateImpl

com.mysql.clusterj.core.query.InPredicateImpl

com.mysql.clusterj.core.query.NotPredicateImpl

com.mysql.clusterj.core.query.OrPredicateImpl

com.mysql.clusterj.core.query.PredicateImpl

com.mysql.clusterj.core.query.QueryDomainTypeImpl

com.mysql.clusterj.core.SessionImpl

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.