Skip to contents

A lazy dplyr::tbl() over sync_row_versions, which maps every synced row (table_name, row_id) to the server sequence number it was last seen at. The result is uncollected, so filtering, joining and aggregating happen in SQLite; call entropia_collect() (or dplyr::collect()) to bring rows into R.

Usage

entropia_sync_versions(con)

Arguments

con

A connection returned by entropia_connect().

Value

A tbl_sql on sync_row_versions.

Examples

con <- entropia_connect(system.file("extdata", "entropia-example.sqlite",
  package = "entropiaR"
))
entropia_collect(entropia_sync_versions(con))
#> # A tibble: 2 × 3
#>   table_name  row_id                               server_seq
#>   <chr>       <chr>                                     <int>
#> 1 items       22222222-2222-4222-8222-222222222221         10
#> 2 collections 11111111-1111-4111-8111-111111111111          5
entropia_disconnect(con)