From dbc6b36610e253742fa05d8e448bf80d8ea36f42 Mon Sep 17 00:00:00 2001
From: Kyle Belanger <kyleb44@hotmail.com>
Date: Wed, 4 Jan 2023 11:15:36 -0500
Subject: [PATCH] Update 0-greeter-dbcreation.R

---
 ML/0-greeter-dbcreation.R | 24 +++++++++++++++++++++---
 1 file changed, 21 insertions(+), 3 deletions(-)

diff --git a/ML/0-greeter-dbcreation.R b/ML/0-greeter-dbcreation.R
index 8d4fcca..2dc9eb7 100644
--- a/ML/0-greeter-dbcreation.R
+++ b/ML/0-greeter-dbcreation.R
@@ -12,8 +12,9 @@ cat("\014") # Clear the console
 box::use(
   magrittr[`%>%`]
   ,RSQLite
-  ,DBI
+  ,DBI[dbConnect,dbDisconnect,dbWriteTable]
   ,here[here]
+  ,readr
 )
 
 
@@ -25,17 +26,34 @@ box::use(
 
 # create database ---------------------------------------------------------
 
-mimicDB <- DBI$dbConnect(
+mimicDB <- dbConnect(
   RSQLite$SQLite()
   ,here("ML","data-unshared","mimicDB.sqlite")
   )
 
 
+# create labevents table
+readr$read_csv_chunked(
+  here("ML","data-unshared", "labevents.csv")
+  ,callback = function(chunk,dummy){
+    dbWriteTable(mimicDB, "labevents", chunk, append = TRUE)
+    }
+  ,chunk_size = 10000
+  ,col_types = "_d_ddTT_d______"
+  )
+
+
+# create patient table
+
+readr$read_csv(
+  here("ML","data-unshared","patients.csv")
+) %>%
+  dbWriteTable(mimicDB,"patients", .)
 
 
 
 
 # close database ----------------------------------------------------------
 
-DBI$dbDisconnect(mimicDB)
+dbDisconnect(mimicDB)