feat(db): 支持 PostgreSQL 的 returning 子句插入操作

- 在文件、分组和标签模块中添加对 PostgreSQL 数据库的支持
- 使用 returning 子句获取插入记录的 ID，替代手动查询
- 为 MySQL 数据库保留事务方式插入并获取 LAST_INSERT_ID()
- 条件编译支持不同数据库特性（mysql 和 postgres）

Author: DataEraserC

file_classification_core/src/internal/files.rs

@@ -33,21 +33,24 @@ pub fn insert_file(
         #[cfg(feature = "mysql")]
         // 对于 MySQL 连接，使用事务方式
         AnyConnection::Mysql(mysql) => {
-                conn.transaction(|mysql| {
-                        // 执行插入操作
-                        diesel::insert_into(files::table)
-                                .values(new_file)
-                                .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(mysql)?;
-
-                        Ok(last_id)
-                })
+            conn.transaction(|mysql| {
+                // 执行插入操作
+                diesel::insert_into(files::table)
+                    .values(new_file)
+                    .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(mysql)?;
+
+                Ok(last_id)
+            })
         },
-        // 默认情况（如其他数据库类型）使用 returning 子句
-        other_database_type => diesel::insert_into(files::table).values(new_file).returning(files::id).get_result(other_database_type),
+        #[cfg(feature = "postgres")]
+        // 对于 PostgreSQL 连接，使用 returning 子句
+        AnyConnection::Postgresql(postgres) => {
+            diesel::insert_into(files::table).values(new_file).returning(files::id).get_result(postgres)
+        }
     }
 }
 

file_classification_core/src/internal/groups.rs

@@ -34,22 +34,23 @@ pub fn insert_group(
         #[cfg(feature = "mysql")]
         // 对于 MySQL 连接，使用事务方式
         AnyConnection::Mysql(mysql) => {
-                mysql.transaction(|mysql| {
-                        // 执行插入操作
-                        diesel::insert_into(groups::table)
-                                .values(new_group)
-                                .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(mysql)?;
-
-                        Ok(last_id)
-                })
+            mysql.transaction(|mysql| {
+                // 执行插入操作
+                diesel::insert_into(groups::table)
+                    .values(new_group)
+                    .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(mysql)?;
+
+                Ok(last_id)
+            })
         },
-        // 默认情况（如其他数据库类型）使用 returning 子句
-        other_database_type => {
-            diesel::insert_into(groups::table).values(new_group).returning(groups::id).get_result(other_database_type)
+        #[cfg(feature = "postgres")]
+        // 对于 PostgreSQL 连接，使用 returning 子句
+        AnyConnection::Postgresql(postgres) => {
+            diesel::insert_into(groups::table).values(new_group).returning(groups::id).get_result(postgres)
         }
     }
 }

file_classification_core/src/internal/tags.rs

@@ -31,23 +31,26 @@ pub fn insert_tag(
             diesel::insert_into(tags::table).values(new_tag).returning(tags::id).get_result(sqlite)
         }
         #[cfg(feature = "mysql")]
-        // 对于 MySQL 连接，使用事务方式（暂时注释掉，因为目前没有启用mysql，注意不要删除以下注释内容，将来会用到）
+        // 对于 MySQL 连接，使用事务方式
         AnyConnection::Mysql(mysql) => {
-                mysql.transaction(|mysql| {
-                        // 执行插入操作
-                        diesel::insert_into(tags::table)
-                                .values(new_tag)
-                                .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(mysql)?;
-
-                        Ok(last_id)
-                })
+            mysql.transaction(|mysql| {
+                // 执行插入操作
+                diesel::insert_into(tags::table)
+                    .values(new_tag)
+                    .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(mysql)?;
+
+                Ok(last_id)
+            })
         },
-        // 默认情况（如其他数据库类型）使用 returning 子句
-        other_database_type => diesel::insert_into(tags::table).values(new_tag).returning(tags::id).get_result(other_database_type),
+        #[cfg(feature = "postgres")]
+        // 对于 PostgreSQL 连接，使用 returning 子句
+        AnyConnection::Postgresql(postgres) => {
+            diesel::insert_into(tags::table).values(new_tag).returning(tags::id).get_result(postgres)
+        }
     }
 }