jdbc调试

Author: aogg

test/jdbc/README.md

@@ -0,0 +1,27 @@
+# JDBC 测试工具
+
+运行 PowerShell 脚本测试 JDBC 连接并显示所有表：
+
+```powershell
+./build_and_run.ps1 -HostName 127.0.0.1 -Port 3306 -Database testdb -User root -Password ""
+```
+
+脚本会自动下载 MySQL JDBC 驱动、编译源码并运行测试。
+
+## 手动下载 JDBC 驱动
+
+如果网络受限无法自动下载，请手动下载：
+
+1. 访问：https://repo1.maven.org/maven2/com/mysql/mysql-connector-j/8.0.33/mysql-connector-j-8.0.33.jar
+2. 将文件保存为 `mysql-connector-java.jar`
+3. 放入 `test/jdbc/lib/` 目录
+
+或者使用代理下载：
+```bash
+curl -x http://localhost_alpine:8899 -o mysql-connector-java.jar "https://repo1.maven.org/maven2/com/mysql/mysql-connector-j/8.0.33/mysql-connector-j-8.0.33.jar"
+```
+
+
+# powershell运行注意
+- 核心：用 -ExecutionPolicy Bypass 临时允许运行当前脚本
+powershell -ExecutionPolicy Bypass -File "D:\code\www\my\github\sqlLogProxy\test\jdbc\build_and_run.ps1"

test/jdbc/TestJdbc.java

@@ -0,0 +1,75 @@
+import java.sql.*;
+import java.util.HashMap;
+import java.util.Map;
+
+public class TestJdbc {
+    public static void main(String[] args) {
+        Map<String, String> params = parseArgs(args);
+
+        String host = params.get("host");
+        String port = params.get("port");
+        String database = params.get("database");
+        String user = params.get("user");
+        String password = params.get("password");
+
+        if (host == null || port == null || database == null || user == null || password == null) {
+            System.err.println("Usage: java TestJdbc --host <host> --port <port> --database <database> --user <user> --password <password>");
+            System.exit(1);
+        }
+
+        String url = String.format("jdbc:mysql://%s:%s/%s?useSSL=false&serverTimezone=UTC", host, port, database);
+
+        try {
+            Class.forName("com.mysql.cj.jdbc.Driver");
+            System.out.println("Attempting to connect to: " + url);
+            System.out.println("User: " + user);
+
+            // 简化连接参数
+            String testUrl = url + "?useSSL=false&serverTimezone=UTC&allowPublicKeyRetrieval=true&useServerPrepStmts=false";
+
+            try (Connection conn = DriverManager.getConnection(testUrl, user, password)) {
+                System.out.println("Connection established successfully!");
+                System.out.println("Connection info: " + conn.getMetaData().getDatabaseProductName() + " " + conn.getMetaData().getDatabaseProductVersion());
+
+                // 首先执行一个简单的查询测试代理是否工作
+                try (Statement stmt = conn.createStatement()) {
+                    System.out.println("Testing with a simple SELECT query...");
+                    try (ResultSet rs = stmt.executeQuery("SELECT 1 as test_column")) {
+                        System.out.println("Simple query executed successfully!");
+                        while (rs.next()) {
+                            System.out.println("Result: " + rs.getString(1));
+                        }
+                    }
+
+                    System.out.println("Now executing SHOW TABLES...");
+                    try (ResultSet rs = stmt.executeQuery("SHOW TABLES")) {
+                        while (rs.next()) {
+                            System.out.println(rs.getString(1));
+                        }
+                    }
+                }
+            }
+        } catch (ClassNotFoundException e) {
+            System.err.println("MySQL JDBC driver not found. Make sure mysql-connector-java.jar is in classpath.");
+            System.exit(1);
+        } catch (SQLException e) {
+            System.err.println("Database connection failed: " + e.getMessage());
+            System.err.println("SQL State: " + e.getSQLState());
+            System.err.println("Error Code: " + e.getErrorCode());
+            e.printStackTrace();
+            System.exit(1);
+        }
+    }
+
+    private static Map<String, String> parseArgs(String[] args) {
+        Map<String, String> params = new HashMap<>();
+        for (int i = 0; i < args.length; i += 2) {
+            if (i + 1 < args.length && args[i].startsWith("--")) {
+                String key = args[i].substring(2);
+                String value = args[i + 1];
+                params.put(key, value);
+            }
+        }
+        return params;
+    }
+}

test/jdbc/bin/TestJdbc.class

@@ -0,0 +1,52 @@
+param(
+    [string]$HostName = "",
+    [string]$Port = "",
+    [string]$Database = "",
+    [string]$User = "",
+    [string]$Password = ""
+)
+
+# 检查 JDK 是否可用
+if (-not (Get-Command javac -ErrorAction SilentlyContinue)) {
+    Write-Error "JDK not found. Please install JDK and ensure javac is in PATH."
+    exit 1
+}
+
+if (-not (Get-Command java -ErrorAction SilentlyContinue)) {
+    Write-Error "Java runtime not found. Please install JDK and ensure java is in PATH."
+    exit 1
+}
+
+# 创建必要目录
+$libDir = "lib"
+$binDir = "bin"
+New-Item -ItemType Directory -Force -Path $libDir | Out-Null
+New-Item -ItemType Directory -Force -Path $binDir | Out-Null
+
+# 下载 MySQL JDBC 驱动（如果不存在）
+$driverPath = "$libDir/mysql-connector-java.jar"
+if (-not (Test-Path $driverPath)) {
+    Write-Host "Downloading MySQL JDBC driver..."
+    try {
+        Invoke-WebRequest -Uri "https://repo1.maven.org/maven2/com/mysql/mysql-connector-j/8.0.33/mysql-connector-j-8.0.33.jar" -OutFile $driverPath
+        Write-Host "Driver downloaded successfully."
+    } catch {
+        Write-Error "Failed to download MySQL JDBC driver. Please manually place mysql-connector-java.jar in $libDir directory."
+        Write-Error "Download URL: https://repo1.maven.org/maven2/com/mysql/mysql-connector-j/8.0.33/mysql-connector-j-8.0.33.jar"
+        Write-Error "Or use proxy: curl -x http://localhost_alpine:8899 -o mysql-connector-java.jar <URL>"
+        exit 1
+    }
+}
+
+# 编译 Java 源码
+Write-Host "Compiling Java source..."
+javac -cp "$libDir/*" -d $binDir TestJdbc.java
+if ($LASTEXITCODE -ne 0) {
+    Write-Error "Compilation failed."
+    exit 1
+}
+
+# 运行程序
+Write-Host "Running JDBC test..."
+$classPath = "$binDir;$libDir/*"
+java -cp $classPath TestJdbc --host $HostName --port $Port --database $Database --user $User --password $Password