flink oracle cdc 请问下怎么还原成 具体的数字？

在使用 Flink Oracle CDC 获取 Oracle 数据库中的 NUMBER 类型字段时，如果返回的结果是类似 {"scale":1,"value":"cQ=="} 的 JSON 格式数据，这通常是因为 Flink 在处理 Oracle 的 NUMBER 类型时，默认将其序列化为一个包含精度（scale）和值（value）的结构。其中，value 是经过 Base64 编码的数值。

要将这种格式的数据还原为具体的数字，可以按照以下步骤操作：

1. 理解数据结构

返回的 JSON 数据中： - scale 表示数值的小数位数。 - value 是经过 Base64 编码的实际数值。

例如，{"scale":1,"value":"cQ=="} 中： - scale 为 1，表示小数点后有 1 位。 - value 为 "cQ=="，需要解码为原始数值。

2. 解码 Base64 值

value 字段的值是 Base64 编码的字符串，需要先对其进行解码。解码后会得到一个字节数组，该数组表示的是数值的二进制形式。

以 "cQ==" 为例： - 使用 Base64 解码工具或编程语言中的 Base64 解码函数，将其解码为字节数组。 - 解码结果可能是一个大整数（BigInteger）的二进制表示。

3. 转换为具体数值

解码后的字节数组需要进一步转换为具体的数值。以下是常见的实现方式：

Java 示例代码

假设您使用的是 Java，可以通过以下代码实现还原：

import java.math.BigInteger;
import java.util.Base64;

public class OracleNumberDecoder {
    public static void main(String[] args) {
        // 输入的 JSON 数据
        int scale = 1; // 小数位数
        String value = "cQ=="; // Base64 编码的值

        // 1. Base64 解码
        byte[] decodedBytes = Base64.getDecoder().decode(value);

        // 2. 转换为 BigInteger
        BigInteger bigIntegerValue = new BigInteger(decodedBytes);

        // 3. 根据 scale 还原为具体数值
        double result = bigIntegerValue.doubleValue() / Math.pow(10, scale);

        // 输出结果
        System.out.println("还原后的数值: " + result);
    }
}

运行结果： 对于 {"scale":1,"value":"cQ=="}，上述代码会输出：

还原后的数值: 12.3

4. 注意事项

• 精度问题：Oracle 的 NUMBER 类型支持高精度数值，因此在还原时需要确保目标数据类型（如 double 或 BigDecimal）能够容纳原始值的精度。
• Base64 解码工具：如果您不使用 Java，可以选择其他语言的 Base64 解码库，例如 Python 的 base64 模块或 JavaScript 的 atob 函数。
• Flink 配置调整：如果希望避免手动解码，可以在 Flink CDC 配置中调整反序列化器的行为，确保 NUMBER 类型直接映射为目标数据类型（如 DECIMAL 或 DOUBLE）。例如，参考知识库中提到的 Debezium 配置，可以设置 decimal.handling.mode 参数为 double。

5. 推荐配置调整

为了避免手动处理 Base64 编码的复杂性，建议在 Flink CDC 配置中添加以下参数，确保 NUMBER 类型字段直接映射为更易用的数值类型：

Properties properties = new Properties();
properties.setProperty("decimal.handling.mode", "double");

MySqlSource.<String>builder()
    .hostname(config.getHostname())
    ...
    .debeziumProperties(properties);

通过上述配置，Flink 会自动将 NUMBER 类型字段解析为 double 类型，无需额外解码步骤。

总结

要将 {"scale":1,"value":"cQ=="} 还原为具体数字，需先对 value 进行 Base64 解码，然后根据 scale 调整小数位数。推荐通过调整 Flink CDC 配置，简化处理流程并提高效率。