1

编辑：我在下面的示例中发现了我的错误。stored_group我在过滤器中输入了一个错字。它按预期工作。

我想使用字符值来过滤数据库表。我dplyr直接在连接对象上使用函数。请参阅下面的步骤。

我连接到我的 MariaDB 数据库：

con <- dbConnect(RMariaDB::MariaDB(), 
                 dbname = mariadb.database,
                 user = mariadb.username,
                 password = mariadb.password,
                 host = mariadb.host,
                 port = mariadb.port)

然后我想在数据库中的表上使用过滤器，dplyr直接在上面的连接上使用代码：

stored_group <- "some_group"
con %>% 
  tbl("Table") %>% 
  select(id, group) %>%
  filter(group == stored_group) %>%
  collect()

我有一个错误说Unknown column 'stored_group' in 'where clause'。所以我这样使用show_query()：

stored_group <- "some_group"
con %>% 
  tbl("Table") %>% 
  select(id, group) %>%
  filter(group == stored_group) %>%
  show_query()

我得到了：

<SQL>
SELECT `id`, `group`
FROM `Table`
WHERE (`group` = `stored_group`)

在翻译中，stored_group被视为列名而不是 R 中的值。如何防止这种情况发生？

在 R 中的普通 data.frames 上，这是可行的。喜欢：

stored_group <- "some_group"
data %>% 
  select(id, group) %>%
  filter(group == stored_group)

我刚刚测试了下面的解决方案，它可以工作。但是我的数据库表会增长。我想在收集之前直接在数据库上过滤。

stored_group <- "some_group"
con %>% 
  tbl("Table") %>% 
  select(id, group) %>%
  collect() %>%
  filter(group == stored_group)

有什么建议么？

4

0 回答 0