dbExecuteForkExec: A function that uses the parallel package to execute a SQL...

In nathan-palmer/SqlTools: Provides convenience functions for interacting with a RDBMS.

Description

A function that uses the parallel package to execute a SQL statement in a subprocess. If async=FALSE, it returns the number of rows affected if the statement was successfully executed, or errors if not. If async=TRUE, it asyncronously returns an object of the class parallelJob that can be used to determine job status via parallel::mccollect.

Usage

dbExecuteForkExec(dbConnectionFun, dbConnectionArgs, statement,
  async = FALSE)

Arguments

dbConnectionFun	The function to be called to instantiate a database connection
dbConnectionArgs	The values of the parameters (in a named list) to be passed to dbConnectionFun to instantiate a connection
statement	The SQL statement to be executed
async	If FALSE, the function blocks, waiting for the subprocess to complete. If TRUE, the function asyncronously returns an object of the class parallelJob that can be used to determine job status via parallel::mccollect

nathan-palmer/SqlTools documentation built on July 22, 2020, 10:53 a.m.