如何在 Pojo 编解码器错误时为字段分配默认值？

Question

我使用 MongoDB java 同步驱动程序来处理我的数据库，PojoCodecProvider 用于反序列化 PlayerData 类，该类存储玩家统计信息。如果类的某些字段更改了其类（例如，从 String 更改为 int），或者 Enum 字段已被删除，则 Pojo 会抛出异常并中止反序列化。如何防止这种情况发生并在发生错误时使字段获取默认值？

我使用这个编解码器注册表：

CodecRegistries.fromRegistries(
        MongoClientSettings.getDefaultCodecRegistry(),
        CodecRegistries.fromProviders(PojoCodecProvider.builder()
                .automatic(true)
                .build()
);

我尝试配置编解码器注册表和提供程序，但没有找到所需的设置。

Answer 1

我将您的问题转交给 ChatGPT 以了解其内容。我查看了答案，看起来很合理：

“要处理反序列化错误并为无法反序列化的字段提供默认值，您可以为 PlayerData 类实现自定义编解码器。这使您可以更好地控制反序列化过程并处理发生的任何异常。

以下是如何为 PlayerData 类创建自定义编解码器：

import org.bson.BsonReader;
import org.bson.BsonType;
import org.bson.BsonWriter;
import org.bson.codecs.Codec;
import org.bson.codecs.DecoderContext;
import org.bson.codecs.EncoderContext;

public class PlayerDataCodec implements Codec<PlayerData> {

    private final Codec<Document> documentCodec;

    public PlayerDataCodec(final Codec<Document> documentCodec) {
        this.documentCodec = documentCodec;
    }

    @Override
    public PlayerData decode(final BsonReader reader, final DecoderContext decoderContext) {
        PlayerData playerData = new PlayerData(); // Instantiate your PlayerData object here
        reader.readStartDocument();
        while (reader.readBsonType() != BsonType.END_OF_DOCUMENT) {
            String fieldName = reader.readName();
            try {
                switch (fieldName) {
                    case "field1":
                        playerData.setField1(reader.readString());
                        break;
                    case "field2":
                        playerData.setField2(reader.readInt32());
                        break;
                    // Add cases for other fields
                    default:
                        reader.skipValue(); // Skip unrecognized fields
                        break;
                }
            } catch (Exception e) {
                // Handle deserialization errors
                // Set default values or handle the error as needed
                // For example:
                playerData.setField2(DEFAULT_INT_VALUE); // Set a default value for field2
            }
        }
        reader.readEndDocument();
        return playerData;
    }

    @Override
    public void encode(final BsonWriter writer, final PlayerData value, final EncoderContext encoderContext) {
        // Implement encoding if necessary
    }

    @Override
    public Class<PlayerData> getEncoderClass() {
        return PlayerData.class;
    }
}

在此编解码器中：

1. 实现decode()方法来读取BSON文档并填充PlayerData对象。在此方法中，您可以捕获反序列化过程中发生的任何异常并进行适当的处理。例如，您可以为反序列化失败的字段设置默认值。

2. 如果需要将PlayerData对象序列化为BSON，请实现encode()方法。

3. 在创建编解码器注册表时注册您的自定义编解码器：

           CodecRegistry codecRegistry = CodecRegistries.fromRegistries(
           MongoClientSettings.getDefaultCodecRegistry(),
           CodecRegistries.fromProviders(
                   PojoCodecProvider.builder()
                           .register(PlayerData.class)
                           .build(),
                   CodecRegistries.fromCodecs(new PlayerDataCodec(new DocumentCodec()))
           ));
   

将 PlayerData.class 替换为适当的类名并相应地调整编解码器。

通过使用自定义编解码器，您可以更好地控制反序列化过程，并可以通过提供默认值或采取其他适当的操作来优雅地处理错误。”

我希望这能正确回答您的问题。