@@ -7,44 +7,50 @@ db_name <- Sys.getenv("DB_NAME")
77db_user <- Sys.getenv(" DB_USER" )
88db_password <- Sys.getenv(" DB_PASSWORD" )
99
10- tryCatch({
11- conn <- dbConnect(
12- RPostgres :: Postgres(),
10+
11+ tryCatch(
12+ {
13+ conn <- dbConnect(
14+ RPostgres :: Postgres(),
1315 dbname = Sys.getenv(" DB_NAME" , " shiny_db" ),
1416 host = Sys.getenv(" DB_HOST" , " 127.0.0.1" ),
1517 port = Sys.getenv(" DB_PORT" , 5432 ),
1618 user = Sys.getenv(" DB_USER" , " visualisation" ),
1719 password = Sys.getenv(" DB_PASSWORD" , " visualisation" )
18- )
19- message(" Connected successfully" )
20-
21-
22-
23- is_empty <- function (con , table ) {
24- tryCatch({
25- query <- sprintf(" SELECT COUNT(*) AS n FROM %s;" , table )
26- n <- dbGetQuery(con , query )$ n
27- return (n == 0 )},
28- error = function (e ){return (TRUE )})
29-
30- }
20+ )
21+ message(" Connected successfully" )
22+
23+
24+ is_empty <- function (con , table ) {
25+ tryCatch(
26+ {
27+ query <- sprintf(" SELECT COUNT(*) AS n FROM %s;" , table )
28+ n <- dbGetQuery(con , query )$ n
29+ return (n == 0 )
30+ },
31+ error = function (e ) {
32+ return (TRUE )
33+ }
34+ )
35+ }
36+
37+ if (is_empty(conn , " equipment_access" )) {
38+ message(" Reading Parquet file..." )
39+ df <- read_parquet(" data/donnees-2024-reg94.parquet" )
40+ df_data_frame <- as.data.frame(df )
41+ message(" Writing to Database..." )
42+ dbWriteTable(conn , " equipment_access" , df_data_frame , overwrite = TRUE , row.names = FALSE )
43+ message(" Success! Data loaded." )
44+ } else {
45+ message(" Database already loaded, skipping data load" )
46+ }
47+
48+ legend <- read.csv(file = " data/BPE24_table_passage.csv" , sep = " ;" , header = T )
49+ # print(legend)
3150
32- if (is_empty(conn , " equipment_access" )){
33- message(" Reading Parquet file..." )
34- df <- read_parquet(" data/donnees-2024-reg94.parquet" )
35- df_data_frame <- as.data.frame(df )
36- message(" Writing to Database..." )
37- dbWriteTable(conn , " equipment_access" , df_data_frame , overwrite = TRUE , row.names = FALSE )
38- message(" Success! Data loaded." )
39- }else {
40- message(" Database already loaded, skipping data load" )
51+ # dbDisconnect(conn)
52+ },
53+ error = function (e ) {
54+ message(" DB ERROR: " , e $ message )
4155 }
42-
43- legend <- read.csv(file = " data/BPE24_table_passage.csv" , sep = " ;" , header = T )
44- print(legend )
45-
46- # dbDisconnect(conn)
47-
48- }, error = function (e ) {
49- message(" DB ERROR: " , e $ message )
50- })
56+ )
0 commit comments