Package index • RTrino

Connect

Open a connection to a Trino coordinator, choose how to authenticate and how to verify its certificate.

Trino(): Instantiate the Trino driver
dbConnect(<TrinoDriver>): Connect to a Trino cluster
trino_auth_basic() trino_auth_jwt() trino_auth_oauth2(): Authentication methods for Trino
trino_ssl(): TLS options for a Trino connection
dbDisconnect(<TrinoConnection>): Disconnect from Trino
dbIsValid(<TrinoConnection>) dbIsValid(<TrinoResult>): Is this connection or result still usable?
dbGetInfo(<TrinoConnection>): Metadata about a Trino connection

Submit SQL and pull the rows back, in one go or in chunks.

dbGetQuery(<TrinoConnection>,<character>): Run a query and return all of its rows
dbSendQuery(<TrinoConnection>,<character>): Submit a statement to Trino
dbSendStatement(<TrinoConnection>,<character>): Submit a statement that changes something
dbExecute(<TrinoConnection>,<character>): Execute a statement that returns no rows
dbFetch(<TrinoResult>): Fetch rows from a Trino result
dbHasCompleted(<TrinoResult>): Have all rows of a result been consumed?
dbClearResult(<TrinoResult>): Release a Trino result
dbBind(<TrinoResult>): Parameters are not supported

Inspect, create, fill and drop tables.

dbListTables(<TrinoConnection>): List the tables in the connection's schema
dbListFields(<TrinoConnection>,<character>) dbListFields(<TrinoConnection>,<Id>) dbListFields(<TrinoConnection>,<ANY>): List a table's columns
dbExistsTable(<TrinoConnection>,<character>) dbExistsTable(<TrinoConnection>,<Id>) dbExistsTable(<TrinoConnection>,<ANY>): Does a table exist?
dbCreateTable(<TrinoConnection>): Create a table
dbAppendTable(<TrinoConnection>): Insert rows into an existing table
dbWriteTable(<TrinoConnection>,<ANY>) dbWriteTable(<TrinoConnection>,<Id>): Write a table
dbRenameTable(): Rename a table
dbRemoveTable(<TrinoConnection>,<character>) dbRemoveTable(<TrinoConnection>,<Id>) dbRemoveTable(<TrinoConnection>,<ANY>): Drop a table

dbBegin(<TrinoConnection>) dbCommit(<TrinoConnection>) dbRollback(<TrinoConnection>): Start, commit and roll back a transaction

Turn R values into Trino SQL, and Trino types into R types.

dbQuoteIdentifier(<TrinoConnection>,<character>) dbQuoteIdentifier(<TrinoConnection>,<SQL>) dbQuoteString(<TrinoConnection>,<character>) dbQuoteString(<TrinoConnection>,<SQL>): Quote identifiers and strings for Trino
dbQuoteLiteral(<TrinoConnection>): Quote R values as Trino literals
dbDataType(<TrinoConnection>): Map an R type to a Trino type
trino_type_to_r(): Map a Trino type to the name of an R type

The SQL dialect that lets dplyr pipelines run in Trino.

simulate_trino(): A Trino connection that never talks to a server
sql_dialect.TrinoConnection(): SQL dialect for Trino
sql_translation.sql_dialect_trino(): Function translations for Trino
sql_escape_date.sql_dialect_trino() sql_escape_datetime.sql_dialect_trino(): Literal dates and date-times in dplyr pipelines
sql_query_explain.sql_dialect_trino(): Explain a Trino query
sql_query_save.sql_dialect_trino() sql_table_analyze.sql_dialect_trino(): Saving a query as a table
db_copy_to.TrinoConnection(): copy_to() for Trino
dbplyr_edition.TrinoConnection(): dbplyr edition used by Trino connections

show(<TrinoDriver>) dbIsValid(<TrinoDriver>) dbGetInfo(<TrinoDriver>) dbUnloadDriver(<TrinoDriver>): Trino driver class
show(<TrinoConnection>): Trino connection class
show(<TrinoResult>) dbGetStatement(<TrinoResult>) dbGetRowCount(<TrinoResult>) dbGetRowsAffected(<TrinoResult>) dbColumnInfo(<TrinoResult>): Trino result class
RTrino RTrino-package: RTrino: 'DBI' Backend for 'Trino'