fix: downcrate rbatis

Author: Randoooom

Cargo.lock

@@ -39,10 +39,10 @@ opentelemetry-semantic-conventions = { version = "0.16.0", optional = true }
 opentelemetry-http = { version = "0.13.0", optional = true }
 paste = "1.0.14"
 prost-types = "0.13.0"
-rbatis = "4.5.21"
-rbdc-pg = { version = "4.5.6", optional = true }
-rbdc-mysql = { version = "4.5.7", optional = true }
-rbdc-mssql = { version = "4.5.4", optional = true }
+rbatis = "=4.5.33"
+rbdc-pg = { version = "4.5.17", optional = true }
+rbdc-mysql = { version = "4.5.17", optional = true }
+rbdc-mssql = { version = "4.5.7", optional = true }
 rbs = "4.5.13"
 serde = { version = "1.0.197", features = ["derive"] }
 serde_json = "1.0.115"

Cargo.toml

@@ -279,8 +279,8 @@ pub fn read_permission_matrix(
 pub async fn sync_preset(connection: &DatabaseConnection) -> Result<()> {
     if let Some(preset) = CONFIG.preset() {
         let transaction = connection.acquire_begin().await?;
-        let transaction = transaction.defer_async(|tx| async move {
-            if !tx.done() {
+        let mut transaction = transaction.defer_async(|mut tx| async move {
+            if !tx.done {
                 let _ = tx.rollback().await;
             }
         });

src/config.rs

@@ -375,7 +375,7 @@ impl From<feedback_fusion_common::proto::PromptResponse> for PromptResponse {
 }
 
 crud!(PromptResponse {});
-impl_select_page_wrapper!(PromptResponse {select_page_by_prompt(prompt: &str) => "WHERE prompt = #{prompt}"});
+impl_select_page_wrapper!(PromptResponse {select_page_by_prompt(prompt: &str) => "`WHERE prompt = #{prompt}`"});
 
 save_as_json!(FieldData, data);
 

src/database/schema/feedback/field.rs

@@ -39,8 +39,8 @@ pub async fn create_responses(
     let data = request.into_inner();
     // start transaction
     let transaction = context.connection().acquire_begin().await?;
-    let transaction = transaction.defer_async(|tx| async move {
-        if !tx.done() {
+    let mut transaction = transaction.defer_async(|mut tx| async move {
+        if !tx.done {
             let _ = tx.rollback().await;
         }
     });
@@ -118,6 +118,9 @@ pub async fn get_responses(
     let page_request = data.page_request();
     let connection = context.connection();
 
+
+    error!("{:?}", page_request);
+
     // select a page of responses
     let responses = database_request!(
         PromptResponse::select_page_by_prompt_wrapper(
@@ -129,6 +132,8 @@ pub async fn get_responses(
         "Select responses by prompt"
     )?;
 
+    error!("{:?}", responses);
+
     let records = if responses.total > 0 {
         database_request!(
             field_responses(