adb2client/src/main/java/com/alibaba/cloud/analyticdb/adbclient/AdbClient.java [377:389]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                        sqlQueue.put(entry.getValue().getLeft());
                    }
                }
            } else {
                for (Map.Entry<String, StringBuilder> entry : batchBuffer.entrySet()) {
                    sqlQueue.put(entry.getValue());
                }
            }
        } catch (Exception e) {
            logger("error", e.getMessage());
            throw new AdbClientException(AdbClientException.COMMIT_ERROR_OTHER, e.getMessage(), e);
        }
        sqlQueueExecute();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



adb2client/src/main/java/com/alibaba/cloud/analyticdb/adbclient/AdbClient.java [403:414]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                    sqlQueue.put(entry.getValue().getLeft());
                }
            } else {
                for (Map.Entry<String, StringBuilder> entry : batchBuffer.entrySet()) {
                    sqlQueue.put(entry.getValue());
                }
            }
        } catch (Exception e) {
            logger("error", e.getMessage());
            throw new AdbClientException(AdbClientException.COMMIT_ERROR_OTHER, e.getMessage(), e);
        }
        sqlQueueExecute();
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -