Package com.mysql.clusterj

Examples of com.mysql.clusterj.ClusterJDatastoreException


    public void cmpInt(BinaryCondition condition, Column storeColumn, int value) {
        try {
            scanFilter.cmp(convertCondition(condition), storeColumn.getName(), value);
        } catch (NdbApiException ndbApiException) {
            throw new ClusterJDatastoreException(local.message("ERR_Datastore"),
                    ndbApiException);
        }
    }
View Full Code Here


    public void cmpLong(BinaryCondition condition, Column storeColumn, long value) {
        try {
            scanFilter.cmp(convertCondition(condition), storeColumn.getName(), value);
        } catch (NdbApiException ndbApiException) {
            throw new ClusterJDatastoreException(local.message("ERR_Datastore"),
                    ndbApiException);
        }
    }
View Full Code Here

    public void cmpString(BinaryCondition condition, Column storeColumn, String value) {
        try {
            scanFilter.cmpString(convertCondition(condition), storeColumn.getName(), value);
        } catch (NdbApiException ndbApiException) {
            throw new ClusterJDatastoreException(local.message("ERR_Datastore"),
                    ndbApiException);
        }
    }
View Full Code Here

    public void cmpTimestamp(BinaryCondition condition, Column storeColumn, Timestamp value) {
        try {
            scanFilter.cmpTimestamp(convertCondition(condition), storeColumn.getName(), value);
        } catch (NdbApiException ndbApiException) {
            throw new ClusterJDatastoreException(local.message("ERR_Datastore"),
                    ndbApiException);
        }
    }
View Full Code Here

    public void cmpDatetime(BinaryCondition condition, Column storeColumn, Timestamp value) {
        try {
            scanFilter.cmp(convertCondition(condition), storeColumn.getName(), value);
        } catch (NdbApiException ndbApiException) {
            throw new ClusterJDatastoreException(local.message("ERR_Datastore"),
                    ndbApiException);
        }
    }
View Full Code Here

    public void cmpDate(BinaryCondition condition, Column storeColumn, Date value) {
        try {
            Timestamp timestamp = new Timestamp(value.getTime());
            scanFilter.cmp(convertCondition(condition), storeColumn.getName(), timestamp);
        } catch (NdbApiException ndbApiException) {
            throw new ClusterJDatastoreException(local.message("ERR_Datastore"),
                    ndbApiException);
        }
    }
View Full Code Here

    public void cmpTime(BinaryCondition condition, Column storeColumn, Time value) {
        try {
            Timestamp timestamp = new Timestamp(value.getTime());
            scanFilter.cmp(convertCondition(condition), storeColumn.getName(), timestamp);
        } catch (NdbApiException ndbApiException) {
            throw new ClusterJDatastoreException(local.message("ERR_Datastore"),
                    ndbApiException);
        }
    }
View Full Code Here

            try {
                return initializeState(sm, state, (JDBCFetchConfiguration)fetch, info);
            } catch (ClassNotFoundException e) {
                throw new ClusterJFatalInternalException(local.message("ERR_Implementation_Should_Not_Occur"), e);
            } catch (SQLException e) {
                throw new ClusterJDatastoreException(local.message("ERR_Datastore_Exception"), e);
            }
        }
        // otherwise, load from the datastore
        // TODO: support user-defined oid types
        OpenJPAId id = (OpenJPAId)sm.getId();
View Full Code Here

    public void end() {
        try {
            scanFilter.end();
        } catch (NdbApiException ndbApiException) {
            throw new ClusterJDatastoreException(local.message("ERR_Datastore"),
                    ndbApiException);
        }
    }
View Full Code Here

            }
            tx.begin();
        } catch (Exception e) {
            logger.detail("NdbOpenJPAStoreManager.beginOptimistic():" +
                    "caught exception in session.currentTransaction.begin().");
            throw new ClusterJDatastoreException(
                    local.message("ERR_Datastore_Exception"), e);
        }
    }
View Full Code Here

TOP

Related Classes of com.mysql.clusterj.ClusterJDatastoreException

Copyright © 2018 www.massapicom. All rights reserved.
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.