fix file open policy

agnesoft · Mar 25, 2024 · 19967be · 19967be
1 parent e2666b9
commit 19967be
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 2 deletions.
diff --git a/agdb/src/storage/file_storage.rs b/agdb/src/storage/file_storage.rs
@@ -90,7 +90,8 @@ impl StorageData for FileStorage {
     fn new(name: &str) -> Result<Self, DbError> {
         let mut file = OpenOptions::new()
             .read(true)
-            .append(true)
+            .write(true)
+            .truncate(false)
             .create(true)
             .open(name)?;
         let mut wal: WriteAheadLog = WriteAheadLog::new(name)?;

diff --git a/agdb/src/storage/write_ahead_log.rs b/agdb/src/storage/write_ahead_log.rs
@@ -35,7 +35,8 @@ impl WriteAheadLog {
         let mut wal = Self {
             file: OpenOptions::new()
                 .read(true)
-                .append(true)
+                .write(true)
+                .truncate(false)
                 .create(true)
                 .open(WriteAheadLog::wal_filename(filename))?,
         };