tongbanjie / baymax Goto Github PK

public void commit() throws SQLException {
    checkClosed();
    if(isAutoCommit){
        return;
    }
    SQLException sqlException = null;
    boolean first = true;
    for(Connection conn : openedConnection.values()){
        try{
            conn.commit();
        }catch(SQLException e){
            if(sqlException == null){
                sqlException = e;
            }
            if(first){
                // 第一次Commit就抛异常了,直接break
                break;
            }
        }
        first = false;
    }

    if(sqlException != null){
        throw sqlException;
    }
}

<dependency>
        <groupId>com.tbjfund.framework</groupId>
        <artifactId>tpa-core</artifactId>
        <version>1.0</version>
    </dependency>