public void commit()

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

• 23 lines of code
• 8 McCabe index (conditional complexity)

    public void commit() {
        try {
            if (commitExceptionDataList.size() > 0 || commitException != null) {
                commitExceptionDataList.clear();
                commitException = null;
            }
            if (databaseConfig.isPartitionBatch()) {
                for (Map<Integer, MutablePair<StringBuilder, Integer>> partitionString : partitionBatch.values()) {
                    for (Map.Entry<Integer, MutablePair<StringBuilder, Integer>> entry : partitionString.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();
    }