From 4d8b8ee5cc41f968ebd4026aca7534207b828131 Mon Sep 17 00:00:00 2001
From: YeJinrong <yejr@qq.com>
Date: Fri, 5 Sep 2025 17:53:43 +0800
Subject: [PATCH] =?UTF-8?q?PFS=E5=8F=8A=E5=85=B6=E4=B8=8B=E6=95=B0?=
 =?UTF-8?q?=E6=8D=AE=E5=AF=B9=E8=B1=A1=E5=90=8D=E5=A4=A7=E5=86=99=E6=94=B9?=
 =?UTF-8?q?=E5=B0=8F=E5=86=99?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../greatsqlmcp/service/DatabaseService.java  | 22 +++++++++----------
 1 file changed, 11 insertions(+), 11 deletions(-)

diff --git a/src/main/java/org/greatsql/greatsqlmcp/service/DatabaseService.java b/src/main/java/org/greatsql/greatsqlmcp/service/DatabaseService.java
index 7f80522..bda6a63 100644
--- a/src/main/java/org/greatsql/greatsqlmcp/service/DatabaseService.java
+++ b/src/main/java/org/greatsql/greatsqlmcp/service/DatabaseService.java
@@ -448,7 +448,7 @@ public class DatabaseService {
         // 检查线程危险状态
         try (Connection connection = connectionService.getConnection();
              Statement statement = connection.createStatement();
-             ResultSet rs = statement.executeQuery("SELECT * FROM PERFORMANCE_SCHEMA.PROCESSLIST")) {
+             ResultSet rs = statement.executeQuery("SELECT * FROM performance_schema.processlist")) {
             while (rs.next()) {
                 String state = rs.getString("State");
                 if (state != null && (state.contains("converting HEAP to ondisk")
@@ -470,9 +470,9 @@ public class DatabaseService {
         }
         
         // 检查全局状态指标
-        final String GLOBAL_STATUS_QUERY = "SELECT * FROM PERFORMANCE_SCHEMA.GLOBAL_STATUS";
+        final String global_status_QUERY = "SELECT * FROM performance_schema.global_status";
         try (Connection connection = connectionService.getConnection();
-             PreparedStatement statement = connection.prepareStatement(GLOBAL_STATUS_QUERY)) {
+             PreparedStatement statement = connection.prepareStatement(global_status_QUERY)) {
             // 第一次查询
             ResultSet rs = statement.executeQuery();
             Map<String, Long> firstGlobalStatus = new HashMap<>();
@@ -622,7 +622,7 @@ public class DatabaseService {
     }
     
     private void checkMGREnabled(Connection conn, Map<String, String> results) throws SQLException {
-        String sql = "SELECT * FROM PERFORMANCE_SCHEMA.REPLICATION_GROUP_MEMBERS";
+        String sql = "SELECT * FROM performance_schema.replication_group_members";
         try (PreparedStatement stmt = conn.prepareStatement(sql);
              ResultSet rs = stmt.executeQuery()) {
             if (!rs.next()) {
@@ -654,8 +654,8 @@ public class DatabaseService {
         String sql = "SELECT s.MEMBER_ID as id, s.COUNT_TRANSACTIONS_IN_QUEUE as trx_tobe_certified, " +
                      "s.COUNT_TRANSACTIONS_REMOTE_IN_APPLIER_QUEUE as relaylog_tobe_applied, " +
                      "m.MEMBER_HOST as host, m.MEMBER_PORT as port " +
-                     "FROM PERFORMANCE_SCHEMA.REPLICATION_GROUP_MEMBER_STATS s " +
-                     "JOIN PERFORMANCE_SCHEMA.REPLICATION_GROUP_MEMBERS m ON s.MEMBER_ID = m.MEMBER_ID";
+                     "FROM performance_schema.replication_group_member_stats s " +
+                     "JOIN performance_schema.replication_group_members m ON s.MEMBER_ID = m.MEMBER_ID";
         try (PreparedStatement stmt = conn.prepareStatement(sql);
              ResultSet rs = stmt.executeQuery()) {
             while (rs.next()) {
@@ -700,7 +700,7 @@ public class DatabaseService {
     
     private void checkGlobalMemoryEvents(Connection conn, Map<String, String> results) throws SQLException {
         String sql = "SELECT EVENT_NAME, SUM_NUMBER_OF_BYTES_ALLOC FROM " +
-                     "PERFORMANCE_SCHEMA.MEMORY_SUMMARY_GLOBAL_BY_EVENT_NAME " +
+                     "performance_schema.memory_summary_global_by_event_name " +
                      "WHERE SUM_NUMBER_OF_BYTES_ALLOC >= 1073741824 " +
                      "ORDER BY SUM_NUMBER_OF_BYTES_ALLOC DESC";
         
@@ -725,7 +725,7 @@ public class DatabaseService {
     }
     
     private long getInnoDBBufferPoolSize(Connection conn) throws SQLException {
-        String sql = "SELECT * FROM PERFORMANCE_SCHEMA.GLOBAL_VARIABLES WHERE VARIABLE_NAME='innodb_buffer_pool_size'";
+        String sql = "SELECT * FROM performance_schema.global_variables WHERE VARIABLE_NAME='innodb_buffer_pool_size'";
         try (PreparedStatement stmt = conn.prepareStatement(sql);
              ResultSet rs = stmt.executeQuery()) {
             if (rs.next()) {
@@ -737,7 +737,7 @@ public class DatabaseService {
     
     private void checkThreadMemoryEvents(Connection conn, Map<String, String> results) throws SQLException {
         String sql = "SELECT THREAD_ID, EVENT_NAME, SUM_NUMBER_OF_BYTES_ALLOC FROM " +
-                     "PERFORMANCE_SCHEMA.MEMORY_SUMMARY_BY_THREAD_BY_EVENT_NAME " +
+                     "performance_schema.memory_summary_by_thread_by_event_name " +
                      "WHERE SUM_NUMBER_OF_BYTES_ALLOC >= 1073741824 " +
                      "ORDER BY SUM_NUMBER_OF_BYTES_ALLOC DESC";
         
@@ -826,7 +826,7 @@ public class DatabaseService {
     
     private Map<String, String> getGlobalVariables(Connection conn) throws SQLException {
         Map<String, String> vars = new HashMap<>();
-        String sql = "SELECT * FROM PERFORMANCE_SCHEMA.GLOBAL_VARIABLES";
+        String sql = "SELECT * FROM performance_schema.global_variables";
         
         try (PreparedStatement stmt = conn.prepareStatement(sql);
              ResultSet rs = stmt.executeQuery()) {
@@ -839,7 +839,7 @@ public class DatabaseService {
     
     private Map<String, String> getGlobalStatus(Connection conn) throws SQLException {
         Map<String, String> stats = new HashMap<>();
-        String sql = "SELECT * FROM PERFORMANCE_SCHEMA.GLOBAL_STATUS";
+        String sql = "SELECT * FROM performance_schema.global_status";
         
         try (PreparedStatement stmt = conn.prepareStatement(sql);
              ResultSet rs = stmt.executeQuery()) {
-- 
Gitee