Java 类com.mysql.jdbc.MysqlErrorNumbers 实例源码

项目:the-vigilantes    文件:ConnectionWrapper.java   
/**
 * @see Connection#setSavepoint()
 */
public java.sql.Savepoint setSavepoint() throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError.createSQLException("Can't set autocommit to 'true' on an XAConnection", SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        return this.mc.setSavepoint();
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }

    return null; // we don't reach this code, compiler can't tell
}
项目:the-vigilantes    文件:ConnectionWrapper.java   
/**
 * @see Connection#setSavepoint(String)
 */
public java.sql.Savepoint setSavepoint(String arg0) throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError.createSQLException("Can't set autocommit to 'true' on an XAConnection", SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        return this.mc.setSavepoint(arg0);
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }

    return null; // we don't reach this code, compiler can't tell
}
项目:OpenVertretung    文件:ConnectionWrapper.java   
/**
 * @see Connection#setSavepoint()
 */
public java.sql.Savepoint setSavepoint() throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError.createSQLException("Can't set autocommit to 'true' on an XAConnection", SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        return this.mc.setSavepoint();
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }

    return null; // we don't reach this code, compiler can't tell
}
项目:OpenVertretung    文件:ConnectionWrapper.java   
/**
 * @see Connection#setSavepoint(String)
 */
public java.sql.Savepoint setSavepoint(String arg0) throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError.createSQLException("Can't set autocommit to 'true' on an XAConnection", SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        return this.mc.setSavepoint(arg0);
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }

    return null; // we don't reach this code, compiler can't tell
}
项目:lams    文件:ConnectionWrapper.java   
/**
 * @see Connection#setSavepoint()
 */
public java.sql.Savepoint setSavepoint() throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError.createSQLException("Can't set autocommit to 'true' on an XAConnection", SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        return this.mc.setSavepoint();
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }

    return null; // we don't reach this code, compiler can't tell
}
项目:lams    文件:ConnectionWrapper.java   
/**
 * @see Connection#setSavepoint(String)
 */
public java.sql.Savepoint setSavepoint(String arg0) throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError.createSQLException("Can't set autocommit to 'true' on an XAConnection", SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        return this.mc.setSavepoint(arg0);
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }

    return null; // we don't reach this code, compiler can't tell
}
项目:ProyectoPacientes    文件:ConnectionWrapper.java   
/**
 * @see Connection#setSavepoint()
 */
public java.sql.Savepoint setSavepoint() throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError.createSQLException("Can't set autocommit to 'true' on an XAConnection", SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        return this.mc.setSavepoint();
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }

    return null; // we don't reach this code, compiler can't tell
}
项目:ProyectoPacientes    文件:ConnectionWrapper.java   
/**
 * @see Connection#setSavepoint(String)
 */
public java.sql.Savepoint setSavepoint(String arg0) throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError.createSQLException("Can't set autocommit to 'true' on an XAConnection", SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        return this.mc.setSavepoint(arg0);
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }

    return null; // we don't reach this code, compiler can't tell
}
项目:BibliotecaPS    文件:ConnectionWrapper.java   
/**
 * @see Connection#setSavepoint()
 */
public java.sql.Savepoint setSavepoint() throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError.createSQLException("Can't set autocommit to 'true' on an XAConnection", SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        return this.mc.setSavepoint();
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }

    return null; // we don't reach this code, compiler can't tell
}
项目:BibliotecaPS    文件:ConnectionWrapper.java   
/**
 * @see Connection#setSavepoint(String)
 */
public java.sql.Savepoint setSavepoint(String arg0) throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError.createSQLException("Can't set autocommit to 'true' on an XAConnection", SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        return this.mc.setSavepoint(arg0);
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }

    return null; // we don't reach this code, compiler can't tell
}
项目:Geometry-wars    文件:ConnectionWrapper.java   
/**
 * @see Connection#setSavepoint()
 */
public java.sql.Savepoint setSavepoint() throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError.createSQLException("Can't set autocommit to 'true' on an XAConnection", SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        return this.mc.setSavepoint();
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }

    return null; // we don't reach this code, compiler can't tell
}
项目:Geometry-wars    文件:ConnectionWrapper.java   
/**
 * @see Connection#setSavepoint(String)
 */
public java.sql.Savepoint setSavepoint(String arg0) throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError.createSQLException("Can't set autocommit to 'true' on an XAConnection", SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        return this.mc.setSavepoint(arg0);
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }

    return null; // we don't reach this code, compiler can't tell
}
项目:TPKB    文件:ConnectionWrapper.java   
/**
 * @see Connection#setSavepoint()
 */
public java.sql.Savepoint setSavepoint() throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError.createSQLException("Can't set autocommit to 'true' on an XAConnection", SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        return this.mc.setSavepoint();
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }

    return null; // we don't reach this code, compiler can't tell
}
项目:TPKB    文件:ConnectionWrapper.java   
/**
 * @see Connection#setSavepoint(String)
 */
public java.sql.Savepoint setSavepoint(String arg0) throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError.createSQLException("Can't set autocommit to 'true' on an XAConnection", SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        return this.mc.setSavepoint(arg0);
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }

    return null; // we don't reach this code, compiler can't tell
}
项目:cloudera-cli-scripts    文件:ConnectionWrapper.java   
/**
 * @see Connection#setSavepoint()
 */
public java.sql.Savepoint setSavepoint() throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError.createSQLException("Can't set autocommit to 'true' on an XAConnection", SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        return this.mc.setSavepoint();
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }

    return null; // we don't reach this code, compiler can't tell
}
项目:cloudera-cli-scripts    文件:ConnectionWrapper.java   
/**
 * @see Connection#setSavepoint(String)
 */
public java.sql.Savepoint setSavepoint(String arg0) throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError.createSQLException("Can't set autocommit to 'true' on an XAConnection", SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        return this.mc.setSavepoint(arg0);
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }

    return null; // we don't reach this code, compiler can't tell
}
项目:fil_project_mgmt_app_v2    文件:ConnectionWrapper.java   
/**
 * Passes call to method on physical connection instance. Notifies listeners
 * of any caught exceptions before re-throwing to client.
 * 
 * @see java.sql.Connection#setAutoCommit
 */
public void setAutoCommit(boolean autoCommit) throws SQLException {
    checkClosed();

    if (autoCommit && isInGlobalTx()) {
        throw SQLError.createSQLException(
                "Can't set autocommit to 'true' on an XAConnection",
                SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        this.mc.setAutoCommit(autoCommit);
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }
}
项目:fil_project_mgmt_app_v2    文件:ConnectionWrapper.java   
/**
 * @see Connection#setSavepoint()
 */
public java.sql.Savepoint setSavepoint() throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError.createSQLException(
                "Can't set autocommit to 'true' on an XAConnection",
                SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        return this.mc.setSavepoint();
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }

    return null; // we don't reach this code, compiler can't tell
}
项目:fil_project_mgmt_app_v2    文件:ConnectionWrapper.java   
/**
 * @see Connection#setSavepoint(String)
 */
public java.sql.Savepoint setSavepoint(String arg0) throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError.createSQLException(
                "Can't set autocommit to 'true' on an XAConnection",
                SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        return this.mc.setSavepoint(arg0);
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }

    return null; // we don't reach this code, compiler can't tell
}
项目:fil_project_mgmt_app_v2    文件:ConnectionWrapper.java   
/**
 * Passes call to method on physical connection instance. Notifies listeners
 * of any caught exceptions before re-throwing to client.
 * 
 * @throws SQLException
 *             if an error occurs
 */
public void commit() throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError
                .createSQLException(
                        "Can't call commit() on an XAConnection associated with a global transaction",
                        SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                        MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        this.mc.commit();
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }
}
项目:fil_project_mgmt_app_v2    文件:ConnectionWrapper.java   
/**
 * Passes call to method on physical connection instance. Notifies listeners
 * of any caught exceptions before re-throwing to client.
 * 
 * @see java.sql.Connection#rollback()
 */
public void rollback() throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError
                .createSQLException(
                        "Can't call rollback() on an XAConnection associated with a global transaction",
                        SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                        MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        this.mc.rollback();
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }
}
项目:fil_project_mgmt_app_v2    文件:ConnectionWrapper.java   
/**
 * @see Connection#rollback(Savepoint)
 */
public void rollback(Savepoint arg0) throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError
                .createSQLException(
                        "Can't call rollback() on an XAConnection associated with a global transaction",
                        SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                        MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        this.mc.rollback(arg0);
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }
}
项目:indoor-tracking    文件:ConnectionWrapper.java   
/**
 * Passes call to method on physical connection instance. Notifies listeners
 * of any caught exceptions before re-throwing to client.
 * 
 * @see java.sql.Connection#setAutoCommit
 */
public void setAutoCommit(boolean autoCommit) throws SQLException {
    checkClosed();

    if (autoCommit && isInGlobalTx()) {
        throw SQLError.createSQLException(
                "Can't set autocommit to 'true' on an XAConnection",
                SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        this.mc.setAutoCommit(autoCommit);
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }
}
项目:indoor-tracking    文件:ConnectionWrapper.java   
/**
 * @see Connection#setSavepoint()
 */
public java.sql.Savepoint setSavepoint() throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError.createSQLException(
                "Can't set autocommit to 'true' on an XAConnection",
                SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        return this.mc.setSavepoint();
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }

    return null; // we don't reach this code, compiler can't tell
}
项目:indoor-tracking    文件:ConnectionWrapper.java   
/**
 * @see Connection#setSavepoint(String)
 */
public java.sql.Savepoint setSavepoint(String arg0) throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError.createSQLException(
                "Can't set autocommit to 'true' on an XAConnection",
                SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        return this.mc.setSavepoint(arg0);
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }

    return null; // we don't reach this code, compiler can't tell
}
项目:indoor-tracking    文件:ConnectionWrapper.java   
/**
 * Passes call to method on physical connection instance. Notifies listeners
 * of any caught exceptions before re-throwing to client.
 * 
 * @throws SQLException
 *             if an error occurs
 */
public void commit() throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError
                .createSQLException(
                        "Can't call commit() on an XAConnection associated with a global transaction",
                        SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                        MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        this.mc.commit();
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }
}
项目:indoor-tracking    文件:ConnectionWrapper.java   
/**
 * Passes call to method on physical connection instance. Notifies listeners
 * of any caught exceptions before re-throwing to client.
 * 
 * @see java.sql.Connection#rollback()
 */
public void rollback() throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError
                .createSQLException(
                        "Can't call rollback() on an XAConnection associated with a global transaction",
                        SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                        MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        this.mc.rollback();
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }
}
项目:indoor-tracking    文件:ConnectionWrapper.java   
/**
 * @see Connection#rollback(Savepoint)
 */
public void rollback(Savepoint arg0) throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError
                .createSQLException(
                        "Can't call rollback() on an XAConnection associated with a global transaction",
                        SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                        MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        this.mc.rollback(arg0);
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }
}
项目:SMPT42    文件:ConnectionWrapper.java   
/**
 * @see Connection#setSavepoint()
 */
public java.sql.Savepoint setSavepoint() throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError.createSQLException("Can't set autocommit to 'true' on an XAConnection", SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        return this.mc.setSavepoint();
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }

    return null; // we don't reach this code, compiler can't tell
}
项目:SMPT42    文件:ConnectionWrapper.java   
/**
 * @see Connection#setSavepoint(String)
 */
public java.sql.Savepoint setSavepoint(String arg0) throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError.createSQLException("Can't set autocommit to 'true' on an XAConnection", SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        return this.mc.setSavepoint(arg0);
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }

    return null; // we don't reach this code, compiler can't tell
}
项目:ForYou    文件:ConnectionWrapper.java   
/**
 * Passes call to method on physical connection instance. Notifies listeners
 * of any caught exceptions before re-throwing to client.
 * 
 * @see java.sql.Connection#setAutoCommit
 */
public void setAutoCommit(boolean autoCommit) throws SQLException {
    checkClosed();

    if (autoCommit && isInGlobalTx()) {
        throw SQLError.createSQLException(
                "Can't set autocommit to 'true' on an XAConnection",
                SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        this.mc.setAutoCommit(autoCommit);
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }
}
项目:ForYou    文件:ConnectionWrapper.java   
/**
 * @see Connection#setSavepoint()
 */
public java.sql.Savepoint setSavepoint() throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError.createSQLException(
                "Can't set autocommit to 'true' on an XAConnection",
                SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        return this.mc.setSavepoint();
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }

    return null; // we don't reach this code, compiler can't tell
}
项目:ForYou    文件:ConnectionWrapper.java   
/**
 * @see Connection#setSavepoint(String)
 */
public java.sql.Savepoint setSavepoint(String arg0) throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError.createSQLException(
                "Can't set autocommit to 'true' on an XAConnection",
                SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        return this.mc.setSavepoint(arg0);
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }

    return null; // we don't reach this code, compiler can't tell
}
项目:ForYou    文件:ConnectionWrapper.java   
/**
 * Passes call to method on physical connection instance. Notifies listeners
 * of any caught exceptions before re-throwing to client.
 * 
 * @throws SQLException
 *             if an error occurs
 */
public void commit() throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError
                .createSQLException(
                        "Can't call commit() on an XAConnection associated with a global transaction",
                        SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                        MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        this.mc.commit();
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }
}
项目:ForYou    文件:ConnectionWrapper.java   
/**
 * Passes call to method on physical connection instance. Notifies listeners
 * of any caught exceptions before re-throwing to client.
 * 
 * @see java.sql.Connection#rollback()
 */
public void rollback() throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError
                .createSQLException(
                        "Can't call rollback() on an XAConnection associated with a global transaction",
                        SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                        MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        this.mc.rollback();
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }
}
项目:ForYou    文件:ConnectionWrapper.java   
/**
 * @see Connection#rollback(Savepoint)
 */
public void rollback(Savepoint arg0) throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError
                .createSQLException(
                        "Can't call rollback() on an XAConnection associated with a global transaction",
                        SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                        MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        this.mc.rollback(arg0);
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }
}
项目:group-five    文件:ConnectionWrapper.java   
/**
 * @see Connection#setSavepoint()
 */
public java.sql.Savepoint setSavepoint() throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError.createSQLException("Can't set autocommit to 'true' on an XAConnection", SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        return this.mc.setSavepoint();
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }

    return null; // we don't reach this code, compiler can't tell
}
项目:group-five    文件:ConnectionWrapper.java   
/**
 * @see Connection#setSavepoint(String)
 */
public java.sql.Savepoint setSavepoint(String arg0) throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError.createSQLException("Can't set autocommit to 'true' on an XAConnection", SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        return this.mc.setSavepoint(arg0);
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }

    return null; // we don't reach this code, compiler can't tell
}
项目:locaviewer    文件:ConnectionWrapper.java   
/**
 * @see Connection#setSavepoint()
 */
public java.sql.Savepoint setSavepoint() throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError.createSQLException("Can't set autocommit to 'true' on an XAConnection", SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        return this.mc.setSavepoint();
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }

    return null; // we don't reach this code, compiler can't tell
}
项目:locaviewer    文件:ConnectionWrapper.java   
/**
 * @see Connection#setSavepoint(String)
 */
public java.sql.Savepoint setSavepoint(String arg0) throws SQLException {
    checkClosed();

    if (isInGlobalTx()) {
        throw SQLError.createSQLException("Can't set autocommit to 'true' on an XAConnection", SQLError.SQL_STATE_INVALID_TRANSACTION_TERMINATION,
                MysqlErrorNumbers.ER_XA_RMERR, this.exceptionInterceptor);
    }

    try {
        return this.mc.setSavepoint(arg0);
    } catch (SQLException sqlException) {
        checkAndFireConnectionError(sqlException);
    }

    return null; // we don't reach this code, compiler can't tell
}