metadata: Rename indexes table into index_files

tontinton · May 31, 2024 · 21c0cf9 · 21c0cf9
1 parent 4ac33f9
commit 21c0cf9
Show file tree

Hide file tree

Showing 5 changed files with 7 additions and 7 deletions.
diff --git a/...429fa08f1f2d988f5df839783df0b4321d2c.json → ...127308d92f38f6851b20468b9a2adc77b535.json b/...429fa08f1f2d988f5df839783df0b4321d2c.json → ...127308d92f38f6851b20468b9a2adc77b535.json
diff --git a/migrations/0001_index_files.down.sql b/migrations/0001_index_files.down.sql
@@ -0,0 +1 @@
+DROP TABLE index_files;
diff --git a/migrations/0001_indexes.up.sql → migrations/0001_index_files.up.sql b/migrations/0001_indexes.up.sql → migrations/0001_index_files.up.sql
@@ -1,4 +1,4 @@
-CREATE TABLE IF NOT EXISTS indexes(
+CREATE TABLE IF NOT EXISTS index_files(
     id VARCHAR(36) PRIMARY KEY,
     file_name TEXT NOT NULL,
     footer_len BIGINT NOT NULL

diff --git a/migrations/0001_indexes.down.sql b/migrations/0001_indexes.down.sql
diff --git a/src/main.rs b/src/main.rs
@@ -58,7 +58,7 @@ async fn open_unified_directories(
     index_dir: &str,
     pool: &PgPool,
 ) -> Result<Vec<(String, UnifiedDirectory)>> {
-    let items = query!("SELECT id, file_name, footer_len FROM indexes")
+    let items = query!("SELECT id, file_name, footer_len FROM index_files")
         .fetch_all(pool)
         .await?;
 
@@ -135,7 +135,7 @@ async fn write_unified_index(
     let (total_len, footer_len) = unified_index_writer.write(&mut writer, file_cache).await?;
     writer.shutdown().await?;
 
-    query("INSERT INTO indexes (id, file_name, footer_len) VALUES ($1, $2, $3)")
+    query("INSERT INTO index_files (id, file_name, footer_len) VALUES ($1, $2, $3)")
         .bind(&id.to_string())
         .bind(&file_name)
         .bind(footer_len as i64)
@@ -238,7 +238,7 @@ async fn merge(args: MergeArgs, pool: PgPool, index_dir: &str) -> Result<()> {
 
     write_unified_index(index, &args.merge_dir, index_dir, &pool).await?;
 
-    let delete_result = query("DELETE FROM indexes WHERE id = ANY($1)")
+    let delete_result = query("DELETE FROM index_files WHERE id = ANY($1)")
         .bind(&ids)
         .execute(&pool)
         .await;