update

uinb · Dec 13, 2023 · 024c0ea · 024c0ea
1 parent 50e41e2
commit 024c0ea
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -1,4 +1,4 @@
-# v0.7.0-rc.7
+# v0.7.0-rc.8
 
 - online test of migration
 

diff --git a/engine/Cargo.toml b/engine/Cargo.toml
@@ -20,7 +20,7 @@ async-trait = "0.1.63"
 serde_json = "1.0"
 rocksdb = "0.21"
 flate2 = { version = "1.0", features = ["zlib"], default-features = false }
-sqlx = { version = "0.6.2", features = ["mysql", "decimal", "chrono", "runtime-tokio-rustls"], optional = true }
+sqlx = { version = "0.6.2", features = ["mysql", "decimal", "chrono", "runtime-tokio-rustls", "time"], optional = true }
 tokio = { version = "1", features = ["full"], optional = true }
 toml = "0.5"
 lazy_static = "1.4"

diff --git a/engine/src/migration.rs b/engine/src/migration.rs
@@ -98,8 +98,8 @@ mod v1_to_v2 {
                     .map(|row: sqlx::mysql::MySqlRow| -> (u64, Command, u8) {
                         let mut cmd: Command = serde_json::from_str(row.get("f_cmd")).unwrap();
                         cmd.timestamp = Some(
-                            row.get::<sqlx::types::chrono::NaiveDateTime, &str>("f_timestamp")
-                                .timestamp_millis() as u64,
+                            row.get::<sqlx::types::time::OffsetDateTime, &str>("f_timestamp")
+                                .unix_timestamp() as u64,
                         );
                         (row.get("f_id"), cmd, row.get("f_status"))
                     })