@@ -41,7 +41,11 @@ async fn execute_query_with_results(
4141 Ok ( stmt) => stmt,
4242 Err ( e) => {
4343 log:: error!( "Query preparation failed: {:?}" , e) ;
44- let error_msg = format ! ( "Query failed: {}" , e) ;
44+ let error_msg = if let Some ( db_error) = e. as_db_error ( ) {
45+ format ! ( "Database error: {}" , db_error. message( ) )
46+ } else {
47+ format ! ( "Query preparation failed: {}" , e)
48+ } ;
4549
4650 sender. send ( QueryExecEvent :: Finished {
4751 elapsed_ms : started_at. elapsed ( ) . as_millis ( ) as u64 ,
@@ -125,7 +129,11 @@ async fn execute_query_with_results(
125129 }
126130 Err ( e) => {
127131 log:: error!( "Query execution failed: {:?}" , e) ;
128- let error_msg = format ! ( "Query failed: {}" , e) ;
132+ let error_msg = if let Some ( db_error) = e. as_db_error ( ) {
133+ format ! ( "Database error: {}" , db_error. message( ) )
134+ } else {
135+ format ! ( "Query execution failed: {}" , e)
136+ } ;
129137
130138 sender. send ( QueryExecEvent :: Finished {
131139 elapsed_ms : started_at. elapsed ( ) . as_millis ( ) as u64 ,
@@ -158,7 +166,11 @@ async fn execute_modification_query(
158166 }
159167 Err ( e) => {
160168 log:: error!( "Modification query failed: {:?}" , e) ;
161- let error_msg = format ! ( "Query failed: {}" , e) ;
169+ let error_msg = if let Some ( db_error) = e. as_db_error ( ) {
170+ format ! ( "Database error: {}" , db_error. message( ) )
171+ } else {
172+ format ! ( "Modification query failed: {}" , e)
173+ } ;
162174
163175 sender. send ( QueryExecEvent :: Finished {
164176 elapsed_ms : started_at. elapsed ( ) . as_millis ( ) as u64 ,
0 commit comments