如何关闭Spanner查询结果的JSON反序列化？

Java SDK 优化方案 #

• 直接读取原始数据，跳过对象反序列化
  Spanner Java SDK的ResultSet提供了底层数据访问能力，无需将结果映射为POJO。你可以用getXXX系列方法（如getLong()、getString()、getBytes()）直接读取原生类型，或者通过getCurrentRowAsBytes()获取整行的原始字节数据，直接传递给下游应用。
  示例代码：

  try (ResultSet resultSet = databaseClient.singleUse().executeQuery(Statement.of("SELECT * FROM your_table"))) {
    while (resultSet.next()) {
      // 获取整行原始字节数据，直接传递给下游
      byte[] rowBytes = resultSet.getCurrentRowAsBytes();
      // 执行下游传递逻辑
    }
  }
  

• 自定义RowReader逻辑
  若需要更灵活的处理，可实现RowReader接口，完全绕过默认的对象映射逻辑，自定义数据读取流程，适合轻量处理后再传递的场景。

JavaScript SDK 优化方案 #

• 启用原始结果模式
  Spanner JS SDK的查询方法支持配置raw: true，此时返回的结果不会被反序列化为常规JS对象，而是保留Spanner原始类型标记的键值对结构，大幅减少序列化开销。
  示例代码：

  const { Spanner } = require('@google-cloud/spanner');
  const spanner = new Spanner();
  const instance = spanner.instance('your-instance');
  const database = instance.database('your-database');
  
  async function queryRawData() {
    const [rows] = await database.run({
      sql: 'SELECT * FROM your_table',
      raw: true // 跳过自动反序列化，返回原始数据
    });
    // 直接将rows传递给下游应用
  }
  queryRawData();
  

• 流式查询配合原始模式
  针对大规模数据集，使用streamingRun进行流式查询，结合raw: true逐行处理原始数据，避免一次性加载全量数据到内存：

  async function streamRawData() {
    const stream = database.streamingRun({
      sql: 'SELECT * FROM your_table',
      raw: true
    });
    for await (const row of stream) {
      // 逐行将原始数据传递给下游
      sendToDownstream(row);
    }
  }
  

通用建议 #

• 确认下游应用可直接处理Spanner的原始数据格式（字节或带类型标记的原始值），如需格式转换，尽量放在下游应用完成，避免当前服务做额外序列化操作。
• 超大规模数据场景优先使用流式查询（Java的StreamingResultSet、JS的streamingRun），配合原始数据读取，兼顾性能与内存占用。

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