// Path: src/main/java/com/elong/pb/newdda/client/exception/ShardingJdbcException.java
// public class ShardingJdbcException extends RuntimeException {
// 
//     private static final long serialVersionUID = -1343739516839252250L;
// 
//     public ShardingJdbcException(final String errorMessage, final Object... args) {
//         super(String.format(errorMessage, args));
//     }
// 
//     public ShardingJdbcException(final Exception cause) {
//         super(cause);
//     }
// 
// }


import com.elong.pb.newdda.client.exception.ShardingJdbcException;
package com.elong.pb.newdda.client.executor;


public final class ExecutorExceptionHandler {
    
    public static void handleException(final Exception ex ,boolean isExceptionThrown) {
        if (isExceptionThrown) {
// Path: src/main/java/com/elong/pb/newdda/client/exception/ShardingJdbcException.java
// public class ShardingJdbcException extends RuntimeException {
// 
//     private static final long serialVersionUID = -1343739516839252250L;
// 
//     public ShardingJdbcException(final String errorMessage, final Object... args) {
//         super(String.format(errorMessage, args));
//     }
// 
//     public ShardingJdbcException(final Exception cause) {
//         super(cause);
//     }
// 
// }


// Path: src/main/java/com/elong/pb/newdda/client/executor/ExecutorExceptionHandler.java
import com.elong.pb.newdda.client.exception.ShardingJdbcException;

package com.elong.pb.newdda.client.executor;


public final class ExecutorExceptionHandler {
    
    public static void handleException(final Exception ex ,boolean isExceptionThrown) {
        if (isExceptionThrown) {
            throw new ShardingJdbcException(ex);