refactor(db):优化数据库连接参数传递

- 将 files.rs 中的数据库连接参数从 `_` 改为具体变量名
- 将 groups.rs 中的数据库连接参数从 `_` 改为具体变量名
- 将 tags.rs 中的数据库连接参数从 `_` 改为具体变量名
- 统一 SQLite 和 MySQL 数据库连接调用方式
- 提高代码可读性和维护性

Author: DataEraserC

file_classification_core/src/internal/files.rs

@@ -27,27 +27,27 @@ pub fn insert_file(
     match conn {
         #[cfg(feature = "sqlite")]
         // 对于 SQLite 连接，使用 returning 子句
-        AnyConnection::Sqlite(_) => {
-            diesel::insert_into(files::table).values(new_file).returning(files::id).get_result(conn)
+        AnyConnection::Sqlite(sqlite) => {
+            diesel::insert_into(files::table).values(new_file).returning(files::id).get_result(sqlite)
         }
         #[cfg(feature = "mysql")]
         // 对于 MySQL 连接，使用事务方式
-        AnyConnection::Mysql(_) => {
-                conn.transaction(|conn| {
+        AnyConnection::Mysql(mysql) => {
+                conn.transaction(|mysql| {
                         // 执行插入操作
                         diesel::insert_into(files::table)
                                 .values(new_file)
-                                .execute(conn)?;
+                                .execute(mysql)?;
 
                         // MySQL使用LAST_INSERT_ID()获取最后插入的ID
                         let last_id: i32 = diesel::select(diesel::dsl::sql::<diesel::sql_types::Integer>("LAST_INSERT_ID()"))
-                                .get_result(conn)?;
+                                .get_result(mysql)?;
 
                         Ok(last_id)
                 })
         },
         // 默认情况（如其他数据库类型）使用 returning 子句
-        _ => diesel::insert_into(files::table).values(new_file).returning(files::id).get_result(conn),
+        other_database_type => diesel::insert_into(files::table).values(new_file).returning(files::id).get_result(other_database_type),
     }
 }
 

file_classification_core/src/internal/groups.rs

@@ -28,28 +28,28 @@ pub fn insert_group(
     match conn {
         #[cfg(feature = "sqlite")]
         // 对于 SQLite 连接，使用 returning 子句
-        AnyConnection::Sqlite(_) => {
-            diesel::insert_into(groups::table).values(new_group).returning(groups::id).get_result(conn)
+        AnyConnection::Sqlite(sqlite) => {
+            diesel::insert_into(groups::table).values(new_group).returning(groups::id).get_result(sqlite)
         }
         #[cfg(feature = "mysql")]
         // 对于 MySQL 连接，使用事务方式
-        AnyConnection::Mysql(_) => {
-                conn.transaction(|conn| {
+        AnyConnection::Mysql(mysql) => {
+                mysql.transaction(|mysql| {
                         // 执行插入操作
                         diesel::insert_into(groups::table)
                                 .values(new_group)
-                                .execute(conn)?;
+                                .execute(mysql)?;
 
                         // MySQL使用LAST_INSERT_ID()获取最后插入的ID
                         let last_id: i32 = diesel::select(diesel::dsl::sql::<diesel::sql_types::Integer>("LAST_INSERT_ID()"))
-                                .get_result(conn)?;
+                                .get_result(mysql)?;
 
                         Ok(last_id)
                 })
         },
         // 默认情况（如其他数据库类型）使用 returning 子句
-        _ => {
-            diesel::insert_into(groups::table).values(new_group).returning(groups::id).get_result(conn)
+        other_database_type => {
+            diesel::insert_into(groups::table).values(new_group).returning(groups::id).get_result(other_database_type)
         }
     }
 }

file_classification_core/src/internal/tags.rs

@@ -27,27 +27,27 @@ pub fn insert_tag(
     match conn {
         #[cfg(feature = "sqlite")]
         // 对于 SQLite 连接，使用 returning 子句
-        AnyConnection::Sqlite(_) => {
-            diesel::insert_into(tags::table).values(new_tag).returning(tags::id).get_result(conn)
+        AnyConnection::Sqlite(sqlite) => {
+            diesel::insert_into(tags::table).values(new_tag).returning(tags::id).get_result(sqlite)
         }
         #[cfg(feature = "mysql")]
         // 对于 MySQL 连接，使用事务方式（暂时注释掉，因为目前没有启用mysql，注意不要删除以下注释内容，将来会用到）
-        AnyConnection::Mysql(_) => {
-                conn.transaction(|conn| {
+        AnyConnection::Mysql(mysql) => {
+                mysql.transaction(|mysql| {
                         // 执行插入操作
                         diesel::insert_into(tags::table)
                                 .values(new_tag)
-                                .execute(conn)?;
+                                .execute(mysql)?;
 
                         // MySQL使用LAST_INSERT_ID()获取最后插入的ID
                         let last_id: i32 = diesel::select(diesel::dsl::sql::<diesel::sql_types::Integer>("LAST_INSERT_ID()"))
-                                .get_result(conn)?;
+                                .get_result(mysql)?;
 
                         Ok(last_id)
                 })
         },
         // 默认情况（如其他数据库类型）使用 returning 子句
-        _ => diesel::insert_into(tags::table).values(new_tag).returning(tags::id).get_result(conn),
+        other_database_type => diesel::insert_into(tags::table).values(new_tag).returning(tags::id).get_result(other_database_type),
     }
 }