1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
|
R version 3.3.1 (2016-06-21) -- "Bug in Your Hair"
Copyright (C) 2016 The R Foundation for Statistical Computing
Platform: x86_64-pc-linux-gnu (64-bit)
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.
Natural language support but running in an English locale
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.
> ## Test of bytea conversion with insert and retrieve to the db.
> ##
>
> 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))
+
+ if (dbExistsTable(con, "texttable"))
+ dbRemoveTable(con, "texttable")
+
+ x_df <- data.frame(x = c("a", "ö", "漢字"), stringsAsFactors = FALSE)
+
+ dbGetQuery(con, "SHOW server_encoding")
+ dbGetQuery(con, "SET client_encoding = 'UTF8'")
+ dbGetQuery(con, "SHOW client_encoding")
+ # write with client_encoding = 'UTF8' and read back what was wrote
+ dbWriteTable(con, "texttable", x_df, overwrite = TRUE)
+ (x_db <- dbReadTable(con, "texttable"))
+ (e <- Encoding(x_db$x))
+ stopifnot( e[1] == "unknown" )
+ stopifnot( e[2] == "UTF-8" )
+ stopifnot( e[3] == "UTF-8" )
+ cat("GOOD -- all encoding are as expected\n")
+
+ x_df <- data.frame(x = c("a", "ö"), stringsAsFactors = FALSE)
+ dbWriteTable(con, "texttable", x_df, overwrite = TRUE)
+ dbGetQuery(con, "SET client_encoding = 'LATIN1'")
+ dbGetQuery(con, "SHOW client_encoding")
+ # read with client_encoding = 'LATIN1' what was already in the database
+ (x_db <- dbReadTable(con, "texttable"))
+ (e <- Encoding(x_db$x))
+ stopifnot( e[1] == "unknown" )
+ stopifnot( e[2] == "latin1" )
+ cat("GOOD -- all encoding are as expected\n")
+
+ # write with client_encoding = 'LATIN1' and read back what was wrote
+ dbWriteTable(con, "texttable", x_df, overwrite = TRUE)
+ (x_db <- dbReadTable(con, "texttable"))
+ (e <- Encoding(x_db$x))
+ stopifnot( e[1] == "unknown" )
+ stopifnot( e[2] == "latin1" )
+ cat("GOOD -- all encoding are as expected\n")
+
+ dbRemoveTable(con, "texttable")
+ dbDisconnect(con)
+ dbUnloadDriver(drv)
+ cat("DONE\n")
+ }else{
+ cat("Skip because envirinmental variables are not set to tell the connection params.\n")
+ }
GOOD -- all encoding are as expected
GOOD -- all encoding are as expected
GOOD -- all encoding are as expected
DONE
>
|
