如何批量修改Cosmos DB SQL表中myCol1列所有值的数据类型为Integer

你之前修改POJO类型后重存失效，核心是Cosmos Java SDK的默认Jackson序列化配置没有强制Integer字段输出为数字类型，部分全局配置会自动把数字转成字符串存储，导致类型没有变更。

方案1：使用Cosmos DB存储过程批量转换（推荐，适用于存量数据量大的场景） #

直接在Cosmos DB侧执行转换，完全规避SDK序列化干扰，执行效率更高，操作步骤如下：

• 进入Azure门户的Cosmos DB账户，打开对应容器的「数据资源管理器」
• 新建存储过程，粘贴以下代码：

function convertMyCol1ToInt() {
    var collection = getContext().getCollection();
    var response = getContext().getResponse();
    var docsProcessed = 0;

    // 仅过滤myCol1为字符串类型的待转换文档
    var filterQuery = "SELECT * FROM c WHERE IS_STRING(c.myCol1)";

    var isAccepted = collection.queryDocuments(
        collection.getSelfLink(),
        filterQuery,
        { pageSize: 100 },
        function (err, feed, options) {
            if (err) throw err;
            if (!feed || feed.length === 0) {
                response.setBody("转换完成，共处理" + docsProcessed + "条文档");
                return;
            }

            processDocBatch(feed, 0, function () {
                if (options.continuation) {
                    // 存在续传标记时继续处理下一页
                    collection.queryDocuments(collection.getSelfLink(), filterQuery, { continuation: options.continuation }, arguments.callee);
                } else {
                    response.setBody("转换完成，共处理" + docsProcessed + "条文档");
                }
            });
        }
    );

    if (!isAccepted) throw new Error("查询请求被拒绝，请重试");

    function processDocBatch(docs, index, callback) {
        if (index >= docs.length) {
            callback();
            return;
        }
        var doc = docs[index];
        // 字符串转整数逻辑
        doc.myCol1 = parseInt(doc.myCol1);
        var isAccepted = collection.replaceDocument(doc._self, doc, function (err, replaced) {
            if (err) throw err;
            docsProcessed++;
            processDocBatch(docs, index + 1, callback);
        });
        if (!isAccepted) throw new Error("替换请求被拒绝，请重试");
    }
}

• 执行存储过程，如果容器配置了分区键需要指定对应分区键值，数据量过大时可分批执行或调整pageSize参数。

方案2：Java代码批量处理（适配原有实现思路） #

修复序列化配置即可解决之前重存无效的问题，操作步骤如下：

• 在POJO的myCol1字段上添加Jackson注解，强制序列化时输出为数字类型：

import com.fasterxml.jackson.annotation.JsonFormat;

public class MyTablePojo {
    @JsonFormat(shape = JsonFormat.Shape.NUMBER)
    private Integer myCol1;
    private String myCol2;
    // 省略其余属性、getter、setter方法
}

• 用以下SQL过滤待转换文档，避免全表扫描：SELECT * FROM c WHERE IS_STRING(c.myCol1)
• 逐篇加载文档、调用save方法重写即可完成转换。

执行如下SQL查询，如果返回结果为空说明所有myCol1都已转换为整数类型：

SELECT c.id, c.myCol1 FROM c WHERE IS_STRING(c.myCol1)

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