如何在Java Spring Boot中从GCP导出SQL数据库

一、核心工具与API选择 #

1. GCP Cloud SQL Admin API（推荐） #

这是官方原生API，适合Spring Boot集成，支持程序化控制导出流程。需要在项目中引入Google Cloud Java客户端依赖：

<!-- Maven依赖 -->
<dependency>
    <groupId>com.google.cloud</groupId>
    <artifactId>google-cloud-sql</artifactId>
    <version>2.23.0</version>
</dependency>

认证方式：本地开发时设置GOOGLE_APPLICATION_CREDENTIALS环境变量指向服务账号密钥文件；部署到GCP（如App Engine、GKE）时自动使用默认服务账号，只需给账号配置Cloud SQL Editor和Storage Object Admin权限。

2. gcloud命令行工具（快速验证） #

如果后端环境已安装gcloud SDK，可以通过ProcessBuilder调用命令完成导出，适合快速原型开发：

gcloud sql export sql YOUR_INSTANCE_NAME gs://YOUR_BUCKET/export.sql --database=YOUR_DB_NAME

二、Spring Boot后端实现流程 #

1. 接收前端请求：创建Controller接口处理导出请求
2. 触发GCS导出：调用Admin API将数据库导出到GCS存储桶（Cloud SQL不支持直接导出到本地，必须中转GCS）
3. 下载到后端临时文件：从GCS拉取导出的SQL文件到后端临时目录
4. 返回文件流给前端：设置正确的响应头，以附件形式返回文件
5. 清理临时文件：使用deleteOnExit()或定时任务清理临时文件

核心代码示例：

@RestController
@RequestMapping("/api")
public class DbExportController {

    private final SqlAdminClient sqlAdminClient;
    private final Storage storage;

    // 构造函数注入客户端（Spring Boot自动配置）
    public DbExportController(SqlAdminClient sqlAdminClient, Storage storage) {
        this.sqlAdminClient = sqlAdminClient;
        this.storage = storage;
    }

    @PostMapping("/export-db")
    public ResponseEntity<Resource> exportDatabase() throws InterruptedException, IOException {
        // 配置导出参数
        String projectId = "your-gcp-project-id";
        String instanceName = "your-sql-instance";
        String bucketName = "your-gcs-bucket";
        String gcsFileName = "db-export-" + System.currentTimeMillis() + ".sql";
        String dbName = "your-target-db";

        // 构建导出请求
        ExportContext exportContext = ExportContext.newBuilder()
                .setSqlExportOptions(SqlExportOptions.newBuilder().setDatabase(dbName).build())
                .setUri(String.format("gs://%s/%s", bucketName, gcsFileName))
                .build();

        ExportInstanceRequest request = ExportInstanceRequest.newBuilder()
                .setProjectId(projectId)
                .setInstance(instanceName)
                .setExportContext(exportContext)
                .build();

        // 执行导出并等待完成
        Operation operation = sqlAdminClient.exportInstance(request);
        while (!operation.getStatus().getDone()) {
            Thread.sleep(1500);
            operation = sqlAdminClient.getOperation(operation.getName());
        }

        // 从GCS下载文件到本地临时目录
        Blob blob = storage.get(BlobId.of(bucketName, gcsFileName));
        File tempFile = File.createTempFile("db-export", ".sql");
        tempFile.deleteOnExit();
        blob.downloadTo(tempFile.toPath());

        // 构造响应返回给前端
        Resource resource = new FileSystemResource(tempFile);
        HttpHeaders headers = new HttpHeaders();
        headers.add(HttpHeaders.CONTENT_DISPOSITION, "attachment; filename=\"database-export.sql\"");

        return ResponseEntity.ok()
                .headers(headers)
                .contentType(MediaType.parseMediaType("application/sql"))
                .body(resource);
    }
}

三、Angular前端处理逻辑 #

发送POST请求接收Blob文件，触发浏览器下载：

import { HttpClient } from '@angular/common/http';
import { Injectable } from '@angular/core';

@Injectable({ providedIn: 'root' })
export class DbExportService {
  constructor(private http: HttpClient) {}

  exportDatabase() {
    this.http.post('/api/export-db', {}, { responseType: 'blob' })
      .subscribe(blob => {
        const downloadUrl = window.URL.createObjectURL(blob);
        const link = document.createElement('a');
        link.href = downloadUrl;
        link.download = 'database-export.sql';
        document.body.appendChild(link);
        link.click();
        window.URL.revokeObjectURL(downloadUrl);
        document.body.removeChild(link);
      });
  }
}

四、关键注意事项 #

• 权限配置：服务账号必须拥有Cloud SQL实例的导出权限，以及GCS存储桶的读写权限
• 异步优化：如果数据库较大，导出耗时久，建议改为异步流程：后端返回任务ID，前端轮询任务状态，完成后再触发下载
• 磁盘占用：临时文件要及时清理，避免后端磁盘溢出
• 其他数据库适配：如果是Firestore等NoSQL数据库，替换为对应的GCP Export API（如Firestore Export Service）

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