sql_queries.each do |sql_query|
varchar = 1043 # from pg_type.h
params = [{:value => user.to_s(), :type => varchar}]
- connection.query(sql_query, params)
+ connection.sync_exec_params(sql_query, params)
end
ensure
# Make sure the connection gets closed even if a query explodes.
begin
sql_queries.each do |sql_query|
- connection.query(sql_query, [domain.to_s()])
+ connection.sync_exec_params(sql_query, [domain.to_s()])
end
ensure
# Make sure the connection gets closed even if a query explodes.