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
|
#' @rdname hidden_aliases
#' @usage NULL
dbReadTable_DBIConnection_character <- function(
conn,
name,
...,
row.names = FALSE,
check.names = TRUE
) {
sql_name <- dbReadTable_toSqlName(conn, name, ...)
if (!is.null(row.names)) {
stopifnot(length(row.names) == 1L)
stopifnot(is.logical(row.names) || is.character(row.names))
}
stopifnot(length(check.names) == 1L)
stopifnot(is.logical(check.names))
stopifnot(!is.na(check.names))
out <- dbGetQuery(conn, paste0("SELECT * FROM ", sql_name))
out <- sqlColumnToRownames(out, row.names)
if (check.names) {
names(out) <- make.names(names(out), unique = TRUE)
}
out
}
dbReadTable_toSqlName <- function(conn, name, ...) {
sql_name <- dbQuoteIdentifier(conn, x = name, ...)
if (length(sql_name) != 1L) {
stop("Invalid name: ", format(name), call. = FALSE)
}
sql_name
}
#' @rdname hidden_aliases
#' @export
setMethod(
"dbReadTable",
signature("DBIConnection", "character"),
dbReadTable_DBIConnection_character
)
|
