R Under development (unstable) (2024-09-21 r87186 ucrt) -- "Unsuffered Consequences" Copyright (C) 2024 The R Foundation for Statistical Computing Platform: x86_64-w64-mingw32/x64 R is free software and comes with ABSOLUTELY NO WARRANTY. You are welcome to redistribute it under certain conditions. Type 'license()' or 'licence()' for distribution details. R is a collaborative project with many contributors. Type 'contributors()' for more information and 'citation()' on how to cite R or R packages in publications. Type 'demo()' for some demos, 'help()' for on-line help, or 'help.start()' for an HTML browser interface to help. Type 'q()' to quit R. > > ## dbWriteTable test > ## > ## Assumes that > ## a) PostgreSQL is running, and > ## b) the current user can connect > ## both of which are not viable for release but suitable while we test > ## > ## Dirk Eddelbuettel, 10 Sep 2009 > > ## only run this if this env.var is set correctly > if (Sys.getenv("POSTGRES_USER") != "" & Sys.getenv("POSTGRES_HOST") != "" & Sys.getenv("POSTGRES_DATABASE") != "") { + + ## try to load our module and abort if this fails + stopifnot(require(RPostgreSQL)) + + ## load the PostgresSQL driver + drv <- dbDriver("PostgreSQL") + + ## connect to the default db + con <- dbConnect(drv, + user=Sys.getenv("POSTGRES_USER"), + password=Sys.getenv("POSTGRES_PASSWD"), + host=Sys.getenv("POSTGRES_HOST"), + dbname=Sys.getenv("POSTGRES_DATABASE"), + port=ifelse((p<-Sys.getenv("POSTGRES_PORT"))!="", p, 5432)) + + + # create a table + res <- dbGetQuery(con, "CREATE TABLE aa (pk integer, v1 float not null, v2 float)" ) + + ## run a simple query and show the query result + res <- dbGetQuery(con, "INSERT INTO aa VALUES(3, 2, NULL)" ) + res <- dbSendQuery(con, "select pk, v1, v2, v1+v2 from aa") + cat("dbColumnInfo\n") + print(dbColumnInfo(res)) + print(dbColumnInfo(res)) + cat("SELECT result\n") + df <- fetch(res, n=-1) + print(df) + + ## cleanup + cat("Removing \"AA\"\n") + dbRemoveTable(con, "aa") + ## and disconnect + dbDisconnect(con) + } > > proc.time() user system elapsed 0.26 0.03 0.21