@@ -4,14 +4,14 @@ use tokio_postgres::{connect, NoTls};
4
4
use crate :: { utils:: reflective_get, AppState } ;
5
5
6
6
#[ tauri:: command( rename_all = "snake_case" ) ]
7
- pub async fn postgresql_connector ( project : & str , key : & str , app : AppHandle ) -> Result < Vec < String > > {
7
+ pub async fn postgresql_connector (
8
+ project_name : & str ,
9
+ key : & str ,
10
+ app : AppHandle ,
11
+ ) -> Result < Vec < String > > {
8
12
let app_state = app. state :: < AppState > ( ) ;
9
- let mut db = app_state. project_db . lock ( ) . await ;
10
- if let Some ( ref mut db_instance) = * db {
11
- db_instance. insert ( project, key) . unwrap ( ) ;
12
- }
13
-
14
13
let ( client, connection) = connect ( key, NoTls ) . await . expect ( "connection error" ) ;
14
+
15
15
tokio:: spawn ( async move {
16
16
if let Err ( e) = connection. await {
17
17
eprintln ! ( "connection error: {}" , e) ;
@@ -32,7 +32,7 @@ pub async fn postgresql_connector(project: &str, key: &str, app: AppHandle) -> R
32
32
let schemas = schemas. iter ( ) . map ( |r| r. get ( 0 ) ) . collect ( ) ;
33
33
let mut clients = app_state. client . lock ( ) . await ;
34
34
let clients = clients. as_mut ( ) . unwrap ( ) ;
35
- clients. insert ( project . to_string ( ) , client) ;
35
+ clients. insert ( project_name . to_string ( ) , client) ;
36
36
37
37
Ok ( schemas)
38
38
}
@@ -66,6 +66,7 @@ pub async fn select_schema_tables(
66
66
. iter ( )
67
67
. map ( |r| ( r. get ( 0 ) , r. get ( 1 ) ) )
68
68
. collect :: < Vec < ( String , String ) > > ( ) ;
69
+
69
70
Ok ( tables)
70
71
}
71
72
0 commit comments