12

假设我连接到一个名为con.

我想dplyr用来重现这个查询

SELECT var1, var2, var3 from myTable LIMIT 10

我努力了

qry <- tbl(con, "myTable") %>%
    select(var1) %>%
    filter(between(row_number(), 1, 10)

但它并没有给出想要的结果，而且它产生的查询比我所追求的要慢得多。

它产生的查询是

SELECT "var1",
FROM SELECT "var1", row_number() OVER () AS "zzz25"
FROM SELECT "var1" AS "var1"
FROM myTable "yhydrqlhho") "zsdfunxidf"
WHERE zzz25 BETWEEN 1.0 AND 10.0)

当我将此查询发送到数据库时，它会运行很长时间。当我发送

SELECT var1 from myTable limit 10

结果立即返回。

4

2 回答 2

17

您可以尝试head(10)，它会在以下位置生成正确的 sql 查询Postgres：

tbl(con, 'my_table') %>% select(var1, var2) %>% head(6) %>% explain()
# here con is a PostgreSQL connection

#<SQL>
#SELECT "var1" AS "var1", "var2" AS "var2"
#FROM "my_table"
#LIMIT 6
于 2017-10-27T03:05:42.650 回答
5

如果您从查询中获取实际数据，而不是仅仅重新创建 SQL 查询，那么指定collect(n=10)将给出与@Psidom 的答案相同的输出。

tbl(con, 'my_table') %>% select(var1, var2) %>% collect(n=10)

# A tibble: 10 x 2
   var1  var2 
   <chr>       <dbl>   
 1 text1            87.8     
 2 text2            99.6    
 3 text3           100       
 4 text4            91.9     
 5 text5            76.8    
 6 text6            77.8    
 7 text7            77.2    
 8 text8            97.2  
 9 text9            97.5
10 text10            80.4

请注意，默认collect()值为n = 1e+05，因此如果您的数据（过滤后）包含更多行，则需要指定collect(n=Inf)检索它。

于 2018-07-06T02:05:41.170 回答