diff --git a/src/storage/materializations.rs b/src/storage/materializations.rs index daec64a..84d8833 100644 --- a/src/storage/materializations.rs +++ b/src/storage/materializations.rs @@ -13,7 +13,7 @@ impl StateStore { resulting_manifest: &Manifest, ) -> anyhow::Result<()> { self.connection.execute( - "INSERT INTO pending_materializations (folder_id, entries, resulting_manifest) VALUES (?1, ?2, ?3) ON CONFLICT(folder_id) DO UPDATE SET entries = excluded.entries, resulting_manifest = excluded.resulting_manifest", + "INSERT INTO pending_materializations (folder_id, entry, resulting_manifest) VALUES (?1, ?2, ?3) ON CONFLICT(folder_id) DO UPDATE SET entry = excluded.entry, resulting_manifest = excluded.resulting_manifest", params![folder_id.to_string(), serde_json::to_string(entries)?, serde_json::to_string(resulting_manifest)?], )?; Ok(()) @@ -24,7 +24,7 @@ impl StateStore { folder_id: FolderId, ) -> anyhow::Result> { self.connection.query_row( - "SELECT entries, resulting_manifest FROM pending_materializations WHERE folder_id = ?1", + "SELECT entry, resulting_manifest FROM pending_materializations WHERE folder_id = ?1", params![folder_id.to_string()], |row| Ok((row.get::<_, String>(0)?, row.get::<_, String>(1)?)), ).optional()?.map(|(entries, manifest)| Ok(PendingMaterialization { diff --git a/src/storage/schema.rs b/src/storage/schema.rs index 6fda89b..60dd4dd 100644 --- a/src/storage/schema.rs +++ b/src/storage/schema.rs @@ -57,7 +57,7 @@ const TABLE_STATEMENTS: &[&str] = &[ );", "CREATE TABLE IF NOT EXISTS pending_materializations ( folder_id TEXT PRIMARY KEY NOT NULL, - entries TEXT NOT NULL, + entry TEXT NOT NULL, resulting_manifest TEXT NOT NULL );", ];