67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
|
# File 'lib/event_source/postgres/put.rb', line 67
def execute_query(id, stream_name, type, serialized_data, serialized_metadata, expected_version)
logger.trace { "Executing insert (Stream Name: #{stream_name}, Type: #{type}, Expected Version: #{expected_version.inspect}, ID: #{id.inspect})" }
params = [
id,
stream_name,
type,
serialized_data,
serialized_metadata,
expected_version
]
begin
records = session.execute(self.class.statement, params)
rescue PG::RaiseException => e
raise_error e
end
logger.debug { "Executed insert (Stream Name: #{stream_name}, Type: #{type}, Expected Version: #{expected_version.inspect}, ID: #{id.inspect})" }
records
end
|