Summarize this content to 400 words in Persian Lang <\/p>\n
import java.io.*;
\nimport java.util.*;
\nimport java.util.regex.*;
\nimport java.util.stream.Collectors;<\/p>\n
public class SQLLogAnalyzer {
\n private static final Pattern LOG_PATTERN = Pattern.compile(“.*?\\\\[((?:ACTIVE|STUCK|Async-Pool-\\\\d+-thread-\\\\d+|.*?))\\\\].*?(?:ExecuteThread:\\\\s+'(\\\\d+)’|).*?((?i)SELECT\\\\s+.*)”);
\n private final Map<String, QueryStats> queryDistribution;
\n private final Set<String> knownStates;<\/p>\n
public SQLLogAnalyzer() {
\n this.queryDistribution = new HashMap<>();
\n this.knownStates = new HashSet<>();
\n }<\/p>\n
private static String repeatString(String str, int count) {
\n StringBuilder sb = new StringBuilder();
\n for (int i = 0; i < count; i++) {
\n sb.append(str);
\n }
\n return sb.toString();
\n }<\/p>\n
public static class ThreadInfo {
\n private final String threadId;
\n private int occurrences;
\n private final Set<Integer> lineNumbers;<\/p>\n
public ThreadInfo(String threadId) {
\n this.threadId = threadId;
\n this.occurrences = 0;
\n this.lineNumbers = new HashSet<>();
\n }<\/p>\n
public void addOccurrence(int lineNumber) {
\n occurrences++;
\n lineNumbers.add(lineNumber);
\n }<\/p>\n
@Override
\n public String toString() {
\n return String.format(“%d occurrences, Lines: %s”,
\n occurrences,
\n lineNumbers.stream()
\n .sorted()
\n .map(String::valueOf)
\n .collect(Collectors.joining(“, “))
\n );
\n }
\n }<\/p>\n
public static class StateInfo {
\n private final Map<String, ThreadInfo> threadStats;
\n private int totalOccurrences;<\/p>\n
public StateInfo() {
\n this.threadStats = new HashMap<>();
\n this.totalOccurrences = 0;
\n }<\/p>\n
public void addOccurrence(String threadId, int lineNumber) {
\n threadStats.computeIfAbsent(threadId, ThreadInfo::new)
\n .addOccurrence(lineNumber);
\n totalOccurrences++;
\n }<\/p>\n
public int getTotalOccurrences() {
\n return totalOccurrences;
\n }<\/p>\n
public Collection<ThreadInfo> getThreadStats() {
\n return threadStats.values();
\n }
\n }<\/p>\n
public static class QueryStats {
\n private final String originalQuery;
\n private final String normalizedQuery;
\n private int occurrences;
\n private final Map<String, StateInfo> stateStats;<\/p>\n
public QueryStats(String query) {
\n this.originalQuery = query.trim();
\n this.normalizedQuery = normalizeQuery(query);
\n this.occurrences = 0;
\n this.stateStats = new HashMap<>();
\n }<\/p>\n
private static String normalizeQuery(String query) {
\n return query.replaceAll(“\\\\s+”, ” “).trim();
\n }<\/p>\n
public void addOccurrence(String threadId, String state, int lineNumber) {
\n occurrences++;
\n \/\/ Normalize state names
\n if (state.startsWith(“Async-Pool”)) {
\n state = state; \/\/ Keep the full async pool thread name
\n } else {
\n state = state.equals(“STUCK”) ? “[STUCK]” : “[ACTIVE]”;
\n }
\n stateStats.computeIfAbsent(state, k -> new StateInfo())
\n .addOccurrence(threadId, lineNumber);
\n }<\/p>\n
public String toFormattedString() {
\n StringBuilder sb = new StringBuilder();
\n \/\/ Format query to avoid line breaks
\n String formattedQuery = “Query: ” + originalQuery.replaceAll(“\\\\s+”, ” “);
\n sb.append(formattedQuery).append(“\\n”);
\n sb.append(String.format(“Total Occurrences: %d%n”, occurrences));<\/p>\n
\/\/ State-wise breakdown
\n sb.append(“State Distribution:\\n”);
\n stateStats.entrySet().stream()
\n .sorted(Map.Entry.<String, StateInfo>comparingByKey())
\n .forEach(entry -> {
\n String state = entry.getKey();
\n StateInfo stateInfo = entry.getValue();
\n sb.append(String.format(” %s (Total: %d): %s%n”,
\n state,
\n stateInfo.getTotalOccurrences(),
\n stateInfo.getThreadStats().iterator().next().toString()
\n ));
\n });<\/p>\n
return sb.toString();
\n }<\/p>\n
public String getNormalizedQuery() {
\n return normalizedQuery;
\n }
\n }<\/p>\n
public void analyzeLogs(String filePath) throws IOException {
\n try (BufferedReader reader = new BufferedReader(new FileReader(filePath))) {
\n String line;
\n int lineNumber = 0;<\/p>\n
while ((line = reader.readLine()) != null) {
\n lineNumber++;
\n processLine(line, lineNumber);
\n }
\n }
\n }<\/p>\n
private void processLine(String line, int lineNumber) {
\n Matcher matcher = LOG_PATTERN.matcher(line);
\n if (matcher.find()) {
\n String state = matcher.group(1);
\n knownStates.add(state);
\n String threadId = matcher.group(2) != null ? matcher.group(2) : “N\/A”;
\n String sqlStatement = matcher.group(3).trim();<\/p>\n
String normalizedSQL = sqlStatement.replaceAll(“\\\\s+”, ” “).trim();
\n queryDistribution
\n .computeIfAbsent(normalizedSQL, query -> new QueryStats(sqlStatement))
\n .addOccurrence(threadId, state, lineNumber);
\n }
\n }<\/p>\n
public void writeAnalysisToFile(String outputPath) throws IOException {
\n try (PrintWriter writer = new PrintWriter(new FileWriter(outputPath))) {
\n writer.println(“=== SQL Query Analysis ===\\n”);<\/p>\n
queryDistribution.values().stream()
\n .sorted((a, b) -> Integer.compare(b.occurrences, a.occurrences))
\n .forEach(stats -> {
\n writer.println(stats.toFormattedString());
\n writer.println(repeatString(“-“, 80) + “\\n”);
\n });<\/p>\n
\/\/ Write summary statistics
\n writer.println(“=== Summary Statistics ===”);
\n writer.println(“Total unique queries: ” + queryDistribution.size());<\/p>\n
writer.println(“\\nThread states found: ” +
\n knownStates.stream()
\n .sorted()
\n .collect(Collectors.joining(“, “)));<\/p>\n
Map<String, Integer> totalStateDistribution = new HashMap<>();
\n queryDistribution.values().forEach(stats ->
\n stats.stateStats.forEach((state, stateInfo) ->
\n totalStateDistribution.merge(state, stateInfo.getTotalOccurrences(), Integer::sum))
\n );<\/p>\n
writer.println(“\\nOverall state distribution:”);
\n totalStateDistribution.entrySet().stream()
\n .sorted(Map.Entry.<String, Integer>comparingByValue().reversed())
\n .forEach(entry ->
\n writer.printf(” %s: %d occurrences%n”, entry.getKey(), entry.getValue())
\n );
\n }
\n }<\/p>\n
public static void main(String[] args) {
\n if (args.length != 2) {
\n System.out.println(“Usage: java SQLLogAnalyzer <log-file-path> <output-file-path>”);
\n return;
\n }<\/p>\n
SQLLogAnalyzer analyzer = new SQLLogAnalyzer();
\n try {
\n analyzer.analyzeLogs(args[0]);
\n analyzer.writeAnalysisToFile(args[1]);
\n System.out.println(“Analysis has been written to: ” + args[1]);
\n } catch (IOException e) {
\n System.err.println(“Error processing files: ” + e.getMessage());
\n e.printStackTrace();
\n }
\n }
\n}<\/p>\n
\nimport java.io.*;\nimport java.util.*;\nimport java.util.regex.*;\nimport java.util.stream.Collectors;\n\npublic class SQLLogAnalyzer {\n private static final Pattern LOG_PATTERN = Pattern.compile(\".*?\\\\[((?:ACTIVE|STUCK|Async-Pool-\\\\d+-thread-\\\\d+|.*?))\\\\].*?(?:ExecuteThread:\\\\s+'(\\\\d+)'|).*?((?i)SELECT\\\\s+.*)\");\n private final Map<String, QueryStats> queryDistribution;\n private final Set<String> knownStates;\n\n public SQLLogAnalyzer() {\n this.queryDistribution = new HashMap<>();\n this.knownStates = new HashSet<>();\n }\n\n private static String repeatString(String str, int count) {\n StringBuilder sb = new StringBuilder();\n for (int i = 0; i < count; i++) {\n sb.append(str);\n }\n return sb.toString();\n }\n\n public static class ThreadInfo {\n private final String threadId;\n private int occurrences;\n private final Set<Integer> lineNumbers;\n\n public ThreadInfo(String threadId) {\n this.threadId = threadId;\n this.occurrences = 0;\n this.lineNumbers = new HashSet<>();\n }\n\n public void addOccurrence(int lineNumber) {\n occurrences++;\n lineNumbers.add(lineNumber);\n }\n\n @Override\n public String toString() {\n return String.format(\"%d occurrences, Lines: %s\", \n occurrences,\n lineNumbers.stream()\n .sorted()\n .map(String::valueOf)\n .collect(Collectors.joining(\", \"))\n );\n }\n }\n\n public static class StateInfo {\n private final Map<String, ThreadInfo> threadStats;\n private int totalOccurrences;\n\n public StateInfo() {\n this.threadStats = new HashMap<>();\n this.totalOccurrences = 0;\n }\n\n public void addOccurrence(String threadId, int lineNumber) {\n threadStats.computeIfAbsent(threadId, ThreadInfo::new)\n .addOccurrence(lineNumber);\n totalOccurrences++;\n }\n\n public int getTotalOccurrences() {\n return totalOccurrences;\n }\n\n public Collection<ThreadInfo> getThreadStats() {\n return threadStats.values();\n }\n }\n\n public static class QueryStats {\n private final String originalQuery;\n private final String normalizedQuery;\n private int occurrences;\n private final Map<String, StateInfo> stateStats;\n\n public QueryStats(String query) {\n this.originalQuery = query.trim();\n this.normalizedQuery = normalizeQuery(query);\n this.occurrences = 0;\n this.stateStats = new HashMap<>();\n }\n\n private static String normalizeQuery(String query) {\n return query.replaceAll(\"\\\\s+\", \" \").trim();\n }\n\n public void addOccurrence(String threadId, String state, int lineNumber) {\n occurrences++;\n \/\/ Normalize state names\n if (state.startsWith(\"Async-Pool\")) {\n state = state; \/\/ Keep the full async pool thread name\n } else {\n state = state.equals(\"STUCK\") ? \"[STUCK]\" : \"[ACTIVE]\";\n }\n stateStats.computeIfAbsent(state, k -> new StateInfo())\n .addOccurrence(threadId, lineNumber);\n }\n\n public String toFormattedString() {\n StringBuilder sb = new StringBuilder();\n \/\/ Format query to avoid line breaks\n String formattedQuery = \"Query: \" + originalQuery.replaceAll(\"\\\\s+\", \" \");\n sb.append(formattedQuery).append(\"\\n\");\n sb.append(String.format(\"Total Occurrences: %d%n\", occurrences));\n\n \/\/ State-wise breakdown\n sb.append(\"State Distribution:\\n\");\n stateStats.entrySet().stream()\n .sorted(Map.Entry.<String, StateInfo>comparingByKey())\n .forEach(entry -> {\n String state = entry.getKey();\n StateInfo stateInfo = entry.getValue();\n sb.append(String.format(\" %s (Total: %d): %s%n\", \n state,\n stateInfo.getTotalOccurrences(),\n stateInfo.getThreadStats().iterator().next().toString()\n ));\n });\n\n return sb.toString();\n }\n\n public String getNormalizedQuery() {\n return normalizedQuery;\n }\n }\n\n public void analyzeLogs(String filePath) throws IOException {\n try (BufferedReader reader = new BufferedReader(new FileReader(filePath))) {\n String line;\n int lineNumber = 0;\n\n while ((line = reader.readLine()) != null) {\n lineNumber++;\n processLine(line, lineNumber);\n }\n }\n }\n\n private void processLine(String line, int lineNumber) {\n Matcher matcher = LOG_PATTERN.matcher(line);\n if (matcher.find()) {\n String state = matcher.group(1);\n knownStates.add(state);\n String threadId = matcher.group(2) != null ? matcher.group(2) : \"N\/A\";\n String sqlStatement = matcher.group(3).trim();\n\n String normalizedSQL = sqlStatement.replaceAll(\"\\\\s+\", \" \").trim();\n queryDistribution\n .computeIfAbsent(normalizedSQL, query -> new QueryStats(sqlStatement))\n .addOccurrence(threadId, state, lineNumber);\n }\n }\n\n public void writeAnalysisToFile(String outputPath) throws IOException {\n try (PrintWriter writer = new PrintWriter(new FileWriter(outputPath))) {\n writer.println(\"=== SQL Query Analysis ===\\n\");\n\n queryDistribution.values().stream()\n .sorted((a, b) -> Integer.compare(b.occurrences, a.occurrences))\n .forEach(stats -> {\n writer.println(stats.toFormattedString());\n writer.println(repeatString(\"-\", 80) + \"\\n\");\n });\n\n \/\/ Write summary statistics\n writer.println(\"=== Summary Statistics ===\");\n writer.println(\"Total unique queries: \" + queryDistribution.size());\n\n writer.println(\"\\nThread states found: \" + \n knownStates.stream()\n .sorted()\n .collect(Collectors.joining(\", \")));\n\n Map<String, Integer> totalStateDistribution = new HashMap<>();\n queryDistribution.values().forEach(stats -> \n stats.stateStats.forEach((state, stateInfo) -> \n totalStateDistribution.merge(state, stateInfo.getTotalOccurrences(), Integer::sum))\n );\n\n writer.println(\"\\nOverall state distribution:\");\n totalStateDistribution.entrySet().stream()\n .sorted(Map.Entry.<String, Integer>comparingByValue().reversed())\n .forEach(entry -> \n writer.printf(\" %s: %d occurrences%n\", entry.getKey(), entry.getValue())\n );\n }\n }\n\n public static void main(String[] args) {\n if (args.length != 2) {\n System.out.println(\"Usage: java SQLLogAnalyzer <log-file-path> <output-file-path>\");\n return;\n }\n\n SQLLogAnalyzer analyzer = new SQLLogAnalyzer();\n try {\n analyzer.analyzeLogs(args[0]);\n analyzer.writeAnalysisToFile(args[1]);\n System.out.println(\"Analysis has been written to: \" + args[1]);\n } catch (IOException e) {\n System.err.println(\"Error processing files: \" + e.getMessage());\n e.printStackTrace();\n }\n }\n}\n\n<\/code><\/pre>\n<\/div>\n","protected":false},"excerpt":{"rendered":"Summarize this content to 400 words in Persian Lang import java.io.*; import java.util.*; import java.util.regex.*; import java.util.stream.Collectors; public class SQLLogAnalyzer { private static final Pattern LOG_PATTERN = Pattern.compile(“.*?\\\\[((?:ACTIVE|STUCK|Async-Pool-\\\\d+-thread-\\\\d+|.*?))\\\\].*?(?:ExecuteThread:\\\\s+'(\\\\d+)’|).*?((?i)SELECT\\\\s+.*)”); private final Map<String, QueryStats> queryDistribution; private final Set<String> knownStates; public SQLLogAnalyzer() { this.queryDistribution = new HashMap<>(); this.knownStates = new HashSet<>(); } private static String repeatString(String str, int …<\/p>\n","protected":false},"author":2,"featured_media":88276,"comment_status":"open","ping_status":"closed","sticky":false,"template":"","format":"standard","meta":{"fifu_image_url":"","fifu_image_alt":"","footnotes":""},"categories":[339],"tags":[],"class_list":["post-88275","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-dev"],"_links":{"self":[{"href":"https:\/\/nabfollower.com\/blog\/wp-json\/wp\/v2\/posts\/88275","targetHints":{"allow":["GET"]}}],"collection":[{"href":"https:\/\/nabfollower.com\/blog\/wp-json\/wp\/v2\/posts"}],"about":[{"href":"https:\/\/nabfollower.com\/blog\/wp-json\/wp\/v2\/types\/post"}],"author":[{"embeddable":true,"href":"https:\/\/nabfollower.com\/blog\/wp-json\/wp\/v2\/users\/2"}],"replies":[{"embeddable":true,"href":"https:\/\/nabfollower.com\/blog\/wp-json\/wp\/v2\/comments?post=88275"}],"version-history":[{"count":0,"href":"https:\/\/nabfollower.com\/blog\/wp-json\/wp\/v2\/posts\/88275\/revisions"}],"wp:featuredmedia":[{"embeddable":true,"href":"https:\/\/nabfollower.com\/blog\/wp-json\/wp\/v2\/media\/88276"}],"wp:attachment":[{"href":"https:\/\/nabfollower.com\/blog\/wp-json\/wp\/v2\/media?parent=88275"}],"wp:term":[{"taxonomy":"category","embeddable":true,"href":"https:\/\/nabfollower.com\/blog\/wp-json\/wp\/v2\/categories?post=88275"},{"taxonomy":"post_tag","embeddable":true,"href":"https:\/\/nabfollower.com\/blog\/wp-json\/wp\/v2\/tags?post=88275"}],"curies":[{"name":"wp","href":"https:\/\/api.w.org\/{rel}","templated":true}]}}