private void commitSingleTable()

in adb2client/src/main/java/com/alibaba/cloud/analyticdb/adbclient/AdbClient.java [392:415]

• 24 lines of code
• 9 McCabe index (conditional complexity)

    private void commitSingleTable(String table) {
        if (partitionBatch.get(table) == null || partitionBatch.get(table).size() == 0) {
            return;
        }
        try {
            if (commitExceptionDataList.size() > 0 || commitException != null) {
                commitExceptionDataList.clear();
                commitException = null;
            }
            if (databaseConfig.isPartitionBatch()) {
                for (Map.Entry<Integer, MutablePair<StringBuilder, Integer>> entry : partitionBatch.get(table).entrySet()) {
                    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();
    }