1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
|
module DataObjects
module Postgres
class Transaction < DataObjects::Transaction
def begin
cmd = "BEGIN"
connection.create_command(cmd).execute_non_query
end
def begin_prepared
cmd = "BEGIN"
connection.create_command(cmd).execute_non_query
end
def commit
cmd = "COMMIT"
connection.create_command(cmd).execute_non_query
end
def commit_prepared
cmd = "COMMIT PREPARED '#{id}'"
connection.create_command(cmd).execute_non_query
end
def rollback
cmd = "ROLLBACK"
connection.create_command(cmd).execute_non_query
end
def rollback_prepared
cmd = "ROLLBACK PREPARED '#{id}'"
connection.create_command(cmd).execute_non_query
end
def prepare
cmd = "PREPARE TRANSACTION '#{id}'"
connection.create_command(cmd).execute_non_query
end
end
end
end
|
