如何在Rest Assured中连接经Kubectl端口转发的集群数据库？

你当前的两条命令已经完成了两个核心操作：

1. 配置GKE集群访问凭证，让本地kubectl能连接到目标集群
2. 将Kubernetes集群内growth-api-dev命名空间下growth-api部署的3306端口（数据库默认端口）转发到本地3306端口

端口转发生效后，本地Java程序连接数据库就和连接本地运行的数据库完全一致，不需要额外处理Kubernetes相关逻辑。下面是具体实现步骤：

1. 确保端口转发持续运行 #

你当前的第二条命令用> /dev/null &让端口转发后台运行，但关闭终端后进程会终止。要让它持续运行，可改用nohup：

nohup kubectl -n growth-api-dev port-forward deployment/growth-api 3306:3306 > /dev/null 2>&1 &

这样即使关闭终端，端口转发进程也会保持运行。

2. 添加数据库驱动依赖 #

假设你用的是MySQL（3306是MySQL默认端口），在项目依赖管理文件中添加驱动：

Maven（pom.xml） #

<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.33</version>
</dependency>

Gradle（build.gradle） #

implementation 'mysql:mysql-connector-java:8.0.33'

3. 在Rest Assured测试中实现数据库连接 #

Rest Assured本身用于REST接口测试，数据库操作需要通过JDBC实现。你可以在测试类的初始化/销毁阶段处理数据库连接，示例代码适配你提供的SubmitApp.java结构：

import org.testng.annotations.BeforeClass;
import org.testng.annotations.AfterClass;
import org.testng.annotations.Test;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

public class SubmitApp {
    private Connection dbConnection;

    @BeforeClass
    public void initDbConnection() {
        try {
            // MySQL 8.0+ 可省略驱动加载，会自动注册
            Class.forName("com.mysql.cj.jdbc.Driver");
            // 端口转发到本地3306，所以host填localhost
            String dbUrl = "jdbc:mysql://localhost:3306/你的数据库名?useSSL=false&serverTimezone=UTC";
            String dbUser = "你的数据库用户名";
            String dbPassword = "你的数据库密码";
            
            dbConnection = DriverManager.getConnection(dbUrl, dbUser, dbPassword);
            System.out.println("数据库连接成功");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    @Test
    public void testDbQuery() {
        try {
            Statement stmt = dbConnection.createStatement();
            String query = "SELECT * FROM 你的表名 LIMIT 1";
            ResultSet rs = stmt.executeQuery(query);
            
            while (rs.next()) {
                // 替换成你要查询的列名
                System.out.println("查询结果：" + rs.getString("column_name"));
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

    @AfterClass
    public void closeDbConnection() {
        try {
            if (dbConnection != null && !dbConnection.isClosed()) {
                dbConnection.close();
                System.out.println("数据库连接已关闭");
            }
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

关键注意事项 #

• 获取数据库凭证：数据库的用户名、密码需要从Kubernetes的Secret中获取。先查看命名空间下的Secret：

  kubectl get secrets -n growth-api-dev
  

  找到对应数据库凭证的Secret后，解码获取用户名和密码：

  # 获取用户名
  kubectl get secret <你的Secret名称> -n growth-api-dev -o jsonpath='{.data.username}' | base64 -d
  # 获取密码
  kubectl get secret <你的Secret名称> -n growth-api-dev -o jsonpath='{.data.password}' | base64 -d
  

• 端口冲突处理：如果本地3306端口被占用，修改端口转发命令的本地端口，比如：

  kubectl -n growth-api-dev port-forward deployment/growth-api 3307:3306
  

  同时修改代码中的dbUrl为jdbc:mysql://localhost:3307/你的数据库名...
• Rest Assured结合使用：你可以在接口测试前后执行数据库操作，比如调用接口后查询数据库，验证数据是否正确更新。

内容的提问来源于stack exchange，提问作者Pulkit Agrawal