Блог

в настоящее время я использую dplyr и dplyr.snowflakedb для обработки некоторых данных в Snowflake.

Хотя это решение оказалось полезным для запроса данных, я столкнулся с проблемой:

Можно ли использовать строковые инструкции sql с этим решением? А именно для создания таблиц ?

То есть могу ли я использовать символ "CREATE TABLE my_table AS select * from table 1" для создания новой таблицы в базе данных?

заранее спасибо

Вы можете преобразовать удаленный tibble в SQL-запрос с помощью dbplyr::sql_render() и склеить его glue::glue_sql() следующим образом:

 # Create an ephemeral in-memory RSQLite database
conn <- DBI::dbConnect(RSQLite::SQLite(), ":memory:")
dplyr::copy_to(conn, mtcars, overwrite = TRUE)


remote_tbl <- dplyr::tbl(conn, 'mtcars')
remote_tbl
#> # Source:   table<mtcars> [?? x 11]
#> # Database: sqlite 3.30.1 [:memory:]
#>      mpg   cyl  disp    hp  drat    wt  qsec    vs    am  gear  carb
#>    <dbl> <dbl> <dbl> <dbl> <dbl> <dbl> <dbl> <dbl> <dbl> <dbl> <dbl>
#>  1  21       6  160    110  3.9   2.62  16.5     0     1     4     4
#>  2  21       6  160    110  3.9   2.88  17.0     0     1     4     4
#>  3  22.8     4  108     93  3.85  2.32  18.6     1     1     4     1
#>  4  21.4     6  258    110  3.08  3.22  19.4     1     0     3     1
#>  5  18.7     8  360    175  3.15  3.44  17.0     0     0     3     2
#>  6  18.1     6  225    105  2.76  3.46  20.2     1     0     3     1
#>  7  14.3     8  360    245  3.21  3.57  15.8     0     0     3     4
#>  8  24.4     4  147.    62  3.69  3.19  20       1     0     4     2
#>  9  22.8     4  141.    95  3.92  3.15  22.9     1     0     4     2
#> 10  19.2     6  168.   123  3.92  3.44  18.3     1     0     4     4
#> # … with more rows

modified_tbl <- remote_tbl %>% 
  dplyr::select(cyl)



select_query <- dbplyr::sql_render(modified_tbl)
table <- 'mtcars2'

insert_statement <- glue::glue_sql(
    "create table {`table`} as {DBI::SQL(select_query)}",
    .con = conn
  )
DBI::dbExecute(conn, insert_statement)
#> [1] 0
DBI::dbListTables(conn)
#> [1] "mtcars"       "mtcars2"      "sqlite_stat1" "sqlite_stat4"
 

^{Создано 2020-11-25 пакетом reprex (версия 0.3.0)}

В общем, {dplyr} не был предназначен для обратной записи чего-либо или обновления таблиц. {dm} может занять это место. Рассмотрим последние разработки в пакете {dm}, в частности эту виньетку при вставке.