tests/testthat/_snaps/df/build_copy_queries.md

In krlmlr/dm: Relational Data Models

build_copy_queries snapshot test for pixarfilms

Code
  pixar_dm %>% build_copy_queries(src_db, .) %>% as.list()
Output
  $name
  [1] "pixar_films"     "academy"         "box_office"      "genres"         
  [5] "public_response"

  $remote_name
        pixar_films           academy        box_office            genres 
      "pixar_films"         "academy"      "box_office"          "genres" 
    public_response 
  "public_response"

  $columns
  $columns[[1]]
  [1] "number"       "film"         "release_date" "run_time"     "film_rating"

  $columns[[2]]
  [1] "film"       "award_type" "status"

  $columns[[3]]
  [1] "film"                 "budget"               "box_office_us_canada"
  [4] "box_office_other"     "box_office_worldwide"

  $columns[[4]]
  [1] "film"  "genre"

  $columns[[5]]
  [1] "film"            "rotten_tomatoes" "metacritic"      "cinema_score"   
  [5] "critics_choice"


  $sql_table
  <SQL> CREATE TEMPORARY TABLE pixar_films (
    number STRING,
    film STRING,
    release_date DATE,
    run_time DOUBLE,
    film_rating STRING,
    PRIMARY KEY (film)
  )
  <SQL> CREATE TEMPORARY TABLE academy (
    film STRING,
    award_type STRING,
    status STRING,
    PRIMARY KEY (film, award_type),
    FOREIGN KEY (film) REFERENCES pixar_films (film)
  )
  <SQL> CREATE TEMPORARY TABLE box_office (
    film STRING,
    budget DOUBLE,
    box_office_us_canada DOUBLE,
    box_office_other DOUBLE,
    box_office_worldwide DOUBLE,
    PRIMARY KEY (film),
    FOREIGN KEY (film) REFERENCES pixar_films (film)
  )
  <SQL> CREATE TEMPORARY TABLE genres (
    film STRING,
    genre STRING,
    PRIMARY KEY (film, genre),
    FOREIGN KEY (film) REFERENCES pixar_films (film)
  )
  <SQL> CREATE TEMPORARY TABLE public_response (
    film STRING,
    rotten_tomatoes DOUBLE,
    metacritic DOUBLE,
    cinema_score STRING,
    critics_choice DOUBLE,
    PRIMARY KEY (film),
    FOREIGN KEY (film) REFERENCES pixar_films (film)
  )

  $sql_index
  $sql_index[[1]]
  NULL

  $sql_index[[2]]
  <SQL> CREATE INDEX academy__film ON academy (film)

  $sql_index[[3]]
  <SQL> CREATE INDEX box_office__film ON box_office (film)

  $sql_index[[4]]
  <SQL> CREATE INDEX genres__film ON genres (film)

  $sql_index[[5]]
  <SQL> CREATE INDEX public_response__film ON public_response (film)


  $index_name
  $index_name[[1]]
  NULL

  $index_name[[2]]
  [1] "academy__film"

  $index_name[[3]]
  [1] "box_office__film"

  $index_name[[4]]
  [1] "genres__film"

  $index_name[[5]]
  [1] "public_response__film"

build_copy_queries snapshot test for dm_for_filter()

Code
  dm_for_filter() %>% collect() %>% build_copy_queries(src_db, .) %>% as.list()
Message
  `on_delete = "cascade"` not supported for duckdb
Output
  $name
  [1] "tf_1" "tf_3" "tf_6" "tf_2" "tf_4" "tf_5"

  $remote_name
    tf_1   tf_3   tf_6   tf_2   tf_4   tf_5 
  "tf_1" "tf_3" "tf_6" "tf_2" "tf_4" "tf_5"

  $columns
  $columns[[1]]
  [1] "a" "b"

  $columns[[2]]
  [1] "f"  "f1" "g"

  $columns[[3]]
  [1] "zz" "n"  "o"

  $columns[[4]]
  [1] "c"  "d"  "e"  "e1"

  $columns[[5]]
  [1] "h"  "i"  "j"  "j1"

  $columns[[6]]
  [1] "ww" "k"  "l"  "m"


  $sql_table
  <SQL> CREATE TEMPORARY TABLE tf_1 (
    a INTEGER,
    b STRING,
    PRIMARY KEY (a)
  )
  <SQL> CREATE TEMPORARY TABLE tf_3 (
    f STRING,
    f1 INTEGER,
    g STRING,
    PRIMARY KEY (f, f1)
  )
  <SQL> CREATE TEMPORARY TABLE tf_6 (
    zz INTEGER,
    n STRING,
    o STRING,
    PRIMARY KEY (o),
    UNIQUE (n)
  )
  <SQL> CREATE TEMPORARY TABLE tf_2 (
    c STRING,
    d INTEGER,
    e STRING,
    e1 INTEGER,
    PRIMARY KEY (c),
    FOREIGN KEY (d) REFERENCES tf_1 (a),
    FOREIGN KEY (e, e1) REFERENCES tf_3 (f, f1)
  )
  <SQL> CREATE TEMPORARY TABLE tf_4 (
    h STRING,
    i STRING,
    j STRING,
    j1 INTEGER,
    PRIMARY KEY (h),
    FOREIGN KEY (j, j1) REFERENCES tf_3 (f, f1)
  )
  <SQL> CREATE TEMPORARY TABLE tf_5 (
    ww INTEGER,
    k INTEGER,
    l STRING,
    m STRING,
    PRIMARY KEY (k),
    FOREIGN KEY (m) REFERENCES tf_6 (n),
    FOREIGN KEY (l) REFERENCES tf_4 (h)
  )

  $sql_index
  $sql_index[[1]]
  NULL

  $sql_index[[2]]
  NULL

  $sql_index[[3]]
  NULL

  $sql_index[[4]]
  <SQL> CREATE INDEX tf_2__d ON tf_2 (d)
  <SQL> CREATE INDEX tf_2__e_e1 ON tf_2 (e, e1)

  $sql_index[[5]]
  <SQL> CREATE INDEX tf_4__j_j1 ON tf_4 (j, j1)

  $sql_index[[6]]
  <SQL> CREATE INDEX tf_5__m ON tf_5 (m)
  <SQL> CREATE INDEX tf_5__l ON tf_5 (l)


  $index_name
  $index_name[[1]]
  NULL

  $index_name[[2]]
  NULL

  $index_name[[3]]
  NULL

  $index_name[[4]]
  [1] "tf_2__d"    "tf_2__e_e1"

  $index_name[[5]]
  [1] "tf_4__j_j1"

  $index_name[[6]]
  [1] "tf_5__m" "tf_5__l"

build_copy_queries avoids duplicate indexes

Code
  as.list(queries)
Output
  $name
  [1] "parent1"  "parent2"  "child"    "child__a"

  $remote_name
  $remote_name$parent1
  <Id> "parent1"

  $remote_name$parent2
  <Id> "parent2"

  $remote_name$child
  <Id> "child"

  $remote_name$child__a
  <Id> "child__a"


  $columns
  $columns[[1]]
  [1] "key"

  $columns[[2]]
  [1] "a__key"

  $columns[[3]]
  [1] "a__key"

  $columns[[4]]
  [1] "key"


  $sql_table
  <SQL> CREATE TEMPORARY TABLE parent1 (
    "key" DOUBLE,
    PRIMARY KEY ("key")
  )
  <SQL> CREATE TEMPORARY TABLE parent2 (
    a__key DOUBLE,
    PRIMARY KEY (a__key)
  )
  <SQL> CREATE TEMPORARY TABLE child (
    a__key DOUBLE,
    FOREIGN KEY (a__key) REFERENCES parent2 (a__key)
  )
  <SQL> CREATE TEMPORARY TABLE child__a (
    "key" DOUBLE,
    FOREIGN KEY ("key") REFERENCES parent2 (a__key)
  )

  $sql_index
  $sql_index[[1]]
  NULL

  $sql_index[[2]]
  NULL

  $sql_index[[3]]
  <SQL> CREATE INDEX child__a__key ON child (a__key)

  $sql_index[[4]]
  <SQL> CREATE INDEX child__a__key__1 ON child__a ("key")


  $index_name
  $index_name[[1]]
  NULL

  $index_name[[2]]
  NULL

  $index_name[[3]]
  [1] "child__a__key"

  $index_name[[4]]
  [1] "child__a__key__1"

krlmlr/dm documentation built on April 19, 2024, 5:23 p.m.