Support adding nullable fields

1 files changed, 3 insertions, 0 deletions

diff --git a/log_db/src/engine.rs b/log_db/src/engine.rs
index 4391451..d028ee0 100644
--- a/log_db/src/engine.rs
+++ b/log_db/src/engine.rs
@@ -163,6 +163,9 @@ impl<R: Recordable> Engine<R> {
             for ForwardLogReaderItem { record, index } in
                 ForwardLogReader::new_with_index(metadata_file, data_file, from_index)
             {
+                // Validate that the values in the record are compatible with the schema
+                record.validate(&self.config.fields)?;
+
                 let log_key = LogKey::new(segnum, index);
 
                 if record.tombstone {