PrestoConnection-class function

class

S4 implementation of DBIConnection for Presto.

## S4 method for signature 'PrestoConnection'
show(object)

## S4 method for signature 'PrestoConnection,ANY,data.frame'
dbAppendTable(conn, name, value, ..., chunk.fields = NULL, row.names = NULL)

## S4 method for signature 'PrestoConnection'
dbCreateTable(
  conn,
  name,
  fields,
  with = NULL,
  ...,
  row.names = NULL,
  temporary = FALSE
)

## S4 method for signature 'PrestoConnection'
dbCreateTableAs(conn, name, sql, overwrite = FALSE, with = NULL, ...)

## S4 method for signature 'PrestoConnection,ANY'
dbExistsTable(conn, name, ...)

## S4 method for signature 'PrestoConnection,character'
dbGetQuery(conn, statement, ..., quiet = getOption("rpresto.quiet"))

## S4 method for signature 'PrestoConnection,ANY'
dbListFields(conn, name, ...)

## S4 method for signature 'PrestoConnection,character'
dbListFields(conn, name, ...)

## S4 method for signature 'PrestoConnection,dbplyr_schema'
dbListFields(conn, name, ...)

## S4 method for signature 'PrestoConnection,Id'
dbListFields(conn, name, ...)

## S4 method for signature 'PrestoConnection,SQL'
dbListFields(conn, name, ...)

## S4 method for signature 'PrestoConnection'
dbListTables(conn, pattern, ...)

## S4 method for signature 'PrestoConnection,dbplyr_schema'
dbQuoteIdentifier(conn, x, ...)

## S4 method for signature 'PrestoConnection,dbplyr_table_path'
dbQuoteIdentifier(conn, x, ...)

## S4 method for signature 'PrestoConnection,AsIs'
dbQuoteIdentifier(conn, x, ...)

## S4 method for signature 'PrestoConnection'
dbQuoteLiteral(conn, x, ...)

## S4 method for signature 'PrestoConnection,ANY'
dbReadTable(conn, name, ...)

## S4 method for signature 'PrestoConnection,character'
dbReadTable(conn, name, ...)

## S4 method for signature 'PrestoConnection,dbplyr_schema'
dbReadTable(conn, name, ...)

## S4 method for signature 'PrestoConnection,Id'
dbReadTable(conn, name, ...)

## S4 method for signature 'PrestoConnection,SQL'
dbReadTable(conn, name, ...)

## S4 method for signature 'PrestoConnection,ANY'
dbRemoveTable(conn, name, ..., fail_if_missing = TRUE)

## S4 method for signature 'PrestoConnection'
dbRenameTable(conn, name, new_name, ...)

## S4 method for signature 'PrestoConnection,character'
dbSendQuery(conn, statement, ..., quiet = getOption("rpresto.quiet"))

## S4 method for signature 'PrestoConnection,ANY,data.frame'
dbWriteTable(
  conn,
  name,
  value,
  overwrite = FALSE,
  ...,
  append = FALSE,
  field.types = NULL,
  temporary = FALSE,
  row.names = FALSE,
  with = NULL,
  chunk.fields = NULL,
  use.one.query = FALSE
)

## S4 method for signature 'PrestoConnection'
sqlCreateTable(
  con,
  table,
  fields,
  row.names = NA,
  temporary = FALSE,
  with = NULL,
  ...
)

## S4 method for signature 'PrestoConnection'
sqlCreateTableAs(con, name, sql, with = NULL, ...)

Arguments

• conn: a PrestoConnection object, as returned by DBI::dbConnect().

• name: The table name, passed on to dbQuoteIdentifier(). Options are:

  • a character string with the unquoted DBMS table name, e.g. "table_name",
  • a call to Id() with components to the fully qualified table name, e.g. Id(schema = "my_schema", table = "table_name")
  • a call to SQL() with the quoted and fully qualified table name given verbatim, e.g. SQL('"my_schema"."table_name"')

• value: A data.frame (or coercible to data.frame).

• ...: Other parameters passed on to methods.

• chunk.fields: A character vector of names of the fields that should be used to slice the value data frame into chunks for batch append. This is necessary when the data frame is too big to be uploaded at once in one single INSERT INTO statement. Default to NULL which inserts the entire value data frame.

• row.names: Must be NULL.

• fields: Either a character vector or a data frame.

  A named character vector: Names are column names, values are types. Names are escaped with dbQuoteIdentifier(). Field types are unescaped.

  A data frame: field types are generated using dbDataType().

• with: An optional WITH clause for the CREATE TABLE statement.

• temporary: If TRUE, will generate a temporary table.

• quiet: If a progress bar should be shown for long queries (which run for more than 2 seconds. Default to getOption("rpresto.quiet") which if not set, defaults to NA which turns on the progress bar for interactive queries.

• pattern: optional SQL pattern for filtering table names, e.g. '%test%'

• x: A character vector, SQL or Id object to quote as identifier.

• fail_if_missing: If FALSE, dbRemoveTable() succeeds if the table doesn't exist.

• use.one.query: A boolean to indicate if to use a single CREATE TABLE AS statement rather than the default implementation of using separate CREATE TABLE and INSERT INTO statements. Some Presto backends might have different requirements between the two approaches. e.g. INSERT INTO might not be allowed to mutate an unpartitioned table created by CREATE TABLE. If set to TRUE, chunk.fields cannot be used.

• con: A database connection.

• table: The table name, passed on to dbQuoteIdentifier(). Options are:

  • a character string with the unquoted DBMS table name, e.g. "table_name",
  • a call to Id() with components to the fully qualified table name, e.g. Id(schema = "my_schema", table = "table_name")
  • a call to SQL() with the quoted and fully qualified table name given verbatim, e.g. SQL('"my_schema"."table_name"')