19

我试图将 postgres 与 dplyr 函数连接起来

my_db <- src_postgres(dbname = 'mdb1252', user = "diego", password = "pass")
my_db
src:  postgres 9.2.5 [postgres@localhost:5432/mdb1252]
tbls: alf, alturas, asociad, atenmed, base, bfa_boys_p_exp, bfa_boys_z_exp,
  bfa_girls_p_exp, bfa_girls_z_exp, bres, c21200012012, c212000392011, c212000532011,
  c21200062012, c212006222012, c212007352012, c212012112013, c212012242012,
  c212012452012, c2222012242012, calles, cap, cap0110, casos_tbc_tr09, casos_tbctr09,
  casosvadela, catpo, cbcvl, cie09, cie10, cie103d, cie103dantigua, cie10c, cie9a,
  cie9mc, clasiarc, coalc, coddepto, codedades, codest, codlocaerbio, codprov, coheb,
  cohec, cohep, cohiv, coho09_20110909_m, coign, combl, comet, comp, comport, conev,
  conymad, copri, corci3cod, corci910, cores, corin, cotab, cutoi, cutto, def0307,......

但是当我尝试连接 tbl

my_tbl <- tbl(my_db, 'def0307')

Error in postgresqlExecStatement(conn, statement, ...) : 
  RS-DBI driver: (could not Retrieve the result : ERROR:  no existe la relación «def0307»
LINE 1: SELECT * FROM "def0307" WHERE 0=1;
                      ^
)

我认为问题是架构问题，因为 sql 应该是：

 SELECT * FROM mortalidad.def0307

我做了my_tbl<-tbl(my_db, 'mortalidad.def0307');

my_tbl <- tbl(my_db, c('mortalidad','def0307'))没有解决办法。

我从 SQL 中与 dplyr 一起工作很有趣，但我希望解决这个问题并尝试 dplyr 技能。

提前致谢。

4

3 回答 3

14

多亏了 Hadley Wickham 最近发布的最新版本 0.7，dplyr 终于解决了这个问题。DBI 和 dbplyr 库极大地简化了 dplyr 和 PostgreSQL 之间的连接。

con <- DBI::dbConnect(RPostgreSQL::PostgreSQL(), 
host = "database.rstudio.com",
user = "hadley",
password = rstudioapi::askForPassword("Database password"))
tbl <- dplyr::tbl(con, dbplyr::in_schema('mortalidad','def0307'))
于 2017-06-27T19:34:05.150 回答
9

你可能想要这个，

db=src_postgres(dbname = 'mdb1252',  
               user = "diego", password = "pass", options="-c search_path=mortalidad")
于 2014-09-27T13:45:47.690 回答
4

如果有人在这里遇到同样的问题，这对我有用：（取自@Diego 2014 年 2 月 6 日的评论）

postgre_table <- function (src, schema, table) {
  paste('SELECT * FROM', paste(schema, table, sep = '.')) %>% 
    sql() %>% tbl(src = src)
}
于 2016-11-21T16:06:05.697 回答