MongoDB BSON кодек не используется во время кодирования объекта

Ответ 1

После нескольких дней исследований я выяснил решение.

DutyBlockCodec зависит от LocalDateCodec (который я создал) для кодирования/декодирования. Эта зависимость не выполняется просто путем добавления двух кодеков в один и тот же реестр кодеков. Решение состоит в том, чтобы передать объект CodecRegistry, содержащий кодеки, которые DutyBlockCodec зависит от (например, a CodecRegistry, содержащего внутри него LocalDateCodec), к конструктору DutyBlockCodec, который сохраняется как переменная-член. Чтобы использовать LocalDateCodec для кодирования, я использую метод EncoderContext.encodeWithChildContext(), передавая кодировку, запись и элемент для кодирования. Кроме того, я пишу отдельные поля, а не пишу Document как String (как в моем исходном коде). Таким образом, кодек DutyBlock выглядит следующим образом:

public class DutyBlockCodec implements Codec<DutyBlock> {
    private final CodecRegistry codecRegistry;

    public DutyBlockCodec(final CodecRegistry codecRegistry) {
        this.codecRegistry = codecRegistry;
    }

    @Override
    public void encode(BsonWriter writer, DutyBlock t, EncoderContext ec) {
        writer.writeStartDocument();
            Codec dateCodec = codecRegistry.get(LocalDate.class);
            writer.writeName("startDate");
            ec.encodeWithChildContext(dateCodec, writer, t.getStartDate());
            writer.writeName("endDate");
            ec.encodeWithChildContext(dateCodec, writer, t.getEndDate());
            writer.writeName("blockLength");
            writer.writeInt32(t.getBlockLength());
            writer.writeName("pointValue");
            writer.writeDouble(t.getPointValue());

            //Writing ArrayList of RAs
            writer.writeName("assigned");
            writer.writeStartArray();
                for (Ra ra : t.getRasOnDuty()) {
                    Codec raCodec = codecRegistry.get(Ra.class);
                    ec.encodeWithChildContext(raCodec, writer, ra);
                }
            writer.writeEndArray();
        writer.writeEndDocument();
    }

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

    @Override
    public DutyBlock decode(BsonReader reader, DecoderContext dc) {
        reader.readStartDocument();
            Codec<LocalDate> dateCodec = codecRegistry.get(LocalDate.class);
            reader.readName();
            LocalDate startDate = dateCodec.decode(reader, dc);
            reader.readName();
            LocalDate endDate = dateCodec.decode(reader, dc);
            reader.readName();
            int blockLength = reader.readInt32();
            reader.readName();
            double pointValue = reader.readDouble();

            //Reading ArrayList of RAs
            reader.readName();
            Codec<Ra> raCodec = codecRegistry.get(Ra.class);
            ArrayList<Ra> rasOnDuty = new ArrayList<>();
            reader.readStartArray();
                while (reader.readBsonType() != BsonType.END_OF_DOCUMENT) {
                    rasOnDuty.add(raCodec.decode(reader, dc));
                }
            reader.readEndArray();
        reader.readEndDocument();

        return new DutyBlock(startDate, endDate, blockLength, pointValue, rasOnDuty);
    }

}

DutyBlockCodec зависит от другого кодека, поэтому для его конструктора требуется передать CodecRegistry. Хотя я считаю, что можно создать CodecRegistry с LocalDateCodec, затем передать это как аргумент конструктору DutyBlockCodec, а затем создать еще один CodecRegistry, содержащий как LocalDateCodec, так и DutyBlockCodec, это довольно запутывает, а MongoDB предоставляет функциональные возможности CodecProvider для облегчения этого процесса.

Используя интерфейс CodecProvider, я написал a DutyBlockCodecProvider

public class DutyBlockCodecProvider implements CodecProvider {
    @Override
    public <T> Codec<T> get(Class<T> type, CodecRegistry cr) {
        if (type == DutyBlock.class) {
            return (Codec<T>) new DutyBlockCodec(cr);
        }
        return null;
    }
}

Я добавил эти CodecProviders клиенту MongoDB с помощью метода CodecRegistries.fromProviders().

CodecRegistry codecRegistry = CodecRegistries.fromRegistries(
            CodecRegistries.fromCodecs(new LocalDateCodec()),
            CodecRegistries.fromProviders(
                    new RaCodecProvider(),
                    new DutyBlockCodecProvider(),
                    new ScheduledDutyCodecProvider()),
            MongoClient.getDefaultCodecRegistry());  
    MongoClientOptions options = MongoClientOptions.builder()
            .codecRegistry(codecRegistry).build();
    mongoClient = new MongoClient(new ServerAddress(), options);
    db = mongoClient.getDatabase("DutySchedulerDB");

Мой исходный код для этого проекта можно найти на https://github.com/desrepair/DutyScheduler Я открыт для ответа на любые вопросы, которые могут возникнуть у людей.