Skip to contents

Engine Class

Source: R/Engine.R
Engine.Rd

The Engine class is a core component of the oRm framework, responsible for managing database connections and providing methods for interacting with the database. It supports both direct connections and connection pooling, offering flexibility in how database resources are managed.

Key features:

  • Manages database connections (single or pooled)

  • Provides methods for executing SQL queries and commands

  • Allows creation of TableModel objects for ORM operations

  • Supports persistent connections for improved performance

Public fields

conn_args

A list of arguments for establishing a connection

conn

Active database connection or pool

use_pool

Whether to use connection pooling

persist

Whether to keep connections open between operations

dialect

Database dialect in use

schema

Default schema applied to tables

Methods

Public methods

Method new()

Create an Engine object

Usage

Engine$new(
  ...,
  conn_args = list(),
  .schema = NULL,
  use_pool = FALSE,
  persist = FALSE
)

Arguments

...

Additional arguments to be passed to DBI::dbConnect

conn_args

A list of arguments to be passed to DBI::dbConnect

.schema

Character. The default schema to apply to child TableModel objects

use_pool

Logical. Whether or not to make use of the pool package for connections to this engine

persist

Logical. Whether to keep the connection open after operations (default: FALSE) Get a connection to the database

Reapplies the configured schema on every connection retrieval to ensure consistency after reconnects.

Method get_connection()

Usage

Engine$get_connection()

Returns

A DBIConnection object or a pool object

Method close()

Close the database connection or pool

Usage

Engine$close()

Returns

NULL

Method list_tables()

List tables in the database connection

Usage

Engine$list_tables()

Returns

A character vector of table names

Method get_query()

Execute a SQL query and return the result as a data.frame

Usage

Engine$get_query(sql)

Arguments

sql

SQL query

Returns

A data.frame

Method execute()

Execute a SQL query and return the number of rows affected

Usage

Engine$execute(sql)

Arguments

sql

SQL query

Returns

The number of rows affected

Method set_schema()

Set the default schema for the engine and active connection

Usage

Engine$set_schema(schema)

Arguments

schema

Character. Schema name to apply

Returns

The Engine object

Method model()

Create a new TableModel object for the specified table

Usage

Engine$model(tablename, ..., .data = list(), .schema = NULL)

Arguments

tablename

Name of the table

...

Additional arguments passed to the TableModel constructor

.data

A named list of the arguments for the TableModel constructor

.schema

Character. The default schema to apply to the TableModel object

Returns

A new TableModel object

Method set_transaction_state()

Set the internal transaction state

Usage

Engine$set_transaction_state(state)

Arguments

state

Logical. Indicates if a transaction is active

Returns

NULL

Method get_transaction_state()

Retrieve the current transaction state

Usage

Engine$get_transaction_state()

Returns

Logical indicating if a transaction is active

Method qualify()

Qualify a table name with a schema

Usage

Engine$qualify(tablename, .schema = self$schema)

Arguments

tablename

Character. Table name to qualify

.schema

Character. Schema name to prepend

Returns

A fully qualified table name

Method format_tablename()

Quote and format a schema-qualified table name

Usage

Engine$format_tablename(tablename)

Arguments

tablename

Character. Table name to format

Returns

A quoted table name

Method print()

Print a concise summary of the engine.

Usage

Engine$print(...)

Arguments

...

Unused, present for compatibility.

Returns

The Engine object, invisibly.

Method clone()

The objects of this class are cloneable with this method.

Usage

Engine$clone(deep = FALSE)

Arguments

deep

Whether to make a deep clone.