Transaction management.

dbBegin() starts a transaction. dbCommit() and dbRollback() end the transaction by either committing or rolling back the changes.

# S4 method for PqConnection
dbBegin(conn, ..., name = NULL)

# S4 method for PqConnection
dbCommit(conn, ..., name = NULL)

# S4 method for PqConnection
dbRollback(conn, ..., name = NULL)

Arguments

conn

a PqConnection object, produced by DBI::dbConnect()

...

Unused, for extensibility.

name

If provided, uses the SAVEPOINT SQL syntax to establish, remove (commit) or undo a ßsavepoint.

Value

A boolean, indicating success or failure.

Examples

library(DBI)
con <- dbConnect(RPostgres::Postgres())
dbWriteTable(con, "USarrests", datasets::USArrests, temporary = TRUE)
dbGetQuery(con, 'SELECT count(*) from "USarrests"')
#>   count
#> 1    50

dbBegin(con)
dbExecute(con, 'DELETE from "USarrests" WHERE "Murder" > 1')
#> [1] 49
dbGetQuery(con, 'SELECT count(*) from "USarrests"')
#>   count
#> 1     1
dbRollback(con)

# Rolling back changes leads to original count
dbGetQuery(con, 'SELECT count(*) from "USarrests"')
#>   count
#> 1    50

dbRemoveTable(con, "USarrests")
dbDisconnect(con)