Java - 在 MongoDB 中使用 Path 字段存储 Pojo

Question

我正在使用 mongo-java-driver 在 MongoDB 中存储 POJO，到目前为止，我这样做没有遇到任何问题：

CodecProvider pojoCodecProvider = PojoCodecProvider.builder().automatic(true).build();
CodecRegistry pojoCodecRegistry = fromRegistries(getDefaultCodecRegistry(), fromProviders(pojoCodecProvider));

但是，当我向 POJO 添加 Path 变量时，我开始出现以下异常：

线程“Thread-2”org.bson.codecs.configuration.CodecConfigurationException中出现异常：找不到类的编解码器...

我想我会为 Path 编写一个编解码器，如下所示：

public class PathCodec implements Codec<Path> {

    @Override
    public void encode(BsonWriter writer, Path path, EncoderContext encoderContext) {
        writer.writeString(path.toString());    
    }

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

    @Override
    public Path decode(BsonReader reader, DecoderContext decoderContext) {
        return Paths.get(reader.readString());
    }   
    
}

然后像这样注册它

CodecProvider pojoCodecProvider = PojoCodecProvider.builder().automatic(true).build();
PathCodec pathCodec = new PathCodec();      
CodecRegistry pojoCodecRegistry = fromRegistries(getDefaultCodecRegistry(), fromCodecs(pathCodec), fromProviders(pojoCodecProvider));

：尽管异常继续发生，但似乎并没有达到目的。

任何正确方向的观点将不胜感激！

Answer 1

这是我使用过的最复杂的系统之一。实现解决方案的方法有多种，每种解决方案都依赖于驱动程序版本。因此，有了这个警告，这里有一个选项供您使用类似的类：

@Document(collection = "example")
public class ExampleEntity implements Serializable {

    @Id
    private Long id;
    private DateTime date;

    public ExampleEntity() {
    }

    public ExampleEntity(Long id, DateTime date) {
        this.id = id;
        this.date = date;
    }

...
}

问题：MongoDB 不知道如何将 joda DateTime 转换为 MongoDB (BSON) 数据类型 DATE_TIME

解决方案：

public class DateTimeCodec implements Codec<DateTime> {
    @Override
    public void encode(BsonWriter writer, DateTime value, EncoderContext encoderContext) {
        writer.writeDateTime(value.getMillis()); // Take the joda DateTime field from the java class, convert to long, write to BSON
    }

    @Override
    public DateTime decode(BsonReader reader, DecoderContext decoderContext) {
        return new DateTime(reader.readDateTime());
    }

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

public class ExampleEntityCodec implements Codec<ExampleEntity> {
    private final CodecRegistry codecRegistry;

    public ExampleEntityCodec(CodecRegistry codecRegistry) {
        this.codecRegistry = codecRegistry;
    }

    @Override
    public void encode(BsonWriter writer, ExampleEntity value, EncoderContext encoderContext) {
        Codec<DateTime> dateTimeCodec = codecRegistry.get(DateTime.class);
        writer.writeStartDocument();
            writer.writeName("_id");
            writer.writeInt64(value.getId());
            writer.writeName("date");
            dateTimeCodec.encode(writer, value.getDate(), encoderContext); 
        writer.writeEndDocument();

    }

    @Override
    public ExampleEntity decode(BsonReader reader, DecoderContext decoderContext) {
        Codec<DateTime> dateTimeCodec = codecRegistry.get(DateTime.class);
        reader.readStartDocument();
            reader.readName();
            Long id = reader.readInt64();
            reader.readName();
            String className = reader.readString(); // ignoring this
            reader.readName();
            DateTime dateTimeFromDB = dateTimeCodec.decode(reader, decoderContext);
            ExampleEntity exampleEntity = new ExampleEntity(id, dateTimeFromDB);
        reader.readEndDocument();
        return exampleEntity;
    }

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

告诉 Java 何时需要使用您的编解码器：

public class ExampleEntityCodecProvider implements CodecProvider {
    @Override
    public <T> Codec<T> get(Class<T> clazz, CodecRegistry registry) {
        if(clazz == ExampleEntity.class) {
            return (Codec<T>) new ExampleEntityCodec(registry);
        }
        return null;
    }
}

构建编解码器：

...
    static CodecRegistry codecRegistry = CodecRegistries.fromRegistries(
            MongoClientSettings.getDefaultCodecRegistry(),  // Provides Codecs for Java's native datatypes
            CodecRegistries.fromCodecs(
                    new DateTimeCodec() // Required to convert BsonType DATE_TIME to joda.time.DateTime
            ),
            CodecRegistries.fromProviders(
                    new ExampleEntityCodecProvider(),
                    PojoCodecProvider.builder()
                            .automatic(true).build()
            )
    );
...

第一个编解码器 Codec 仅用于单个字段，而 Codec用于强制编写整个类的键/值对。请记住，当您编码时，您是在告诉 Mongo 您要使用哪种 BSON 数据类型。

在您的情况下，您似乎正在尝试对一个类进行字符串化，然后通过读取字符串再次构造它。您应该将 Java 类的键和值编码为要写入数据库的相应键和值，然后在解码时执行相反的转换。