sql_query = 'SELECT username FROM users;'
begin
- connection.query(sql_query) do |result|
+ connection.sync_exec(sql_query) do |result|
usernames = result.field_values('username')
end
ensure
sql_query = 'SELECT user_id FROM users WHERE username = $1;'
begin
- connection.query(sql_query, [user.to_s()]) do |result|
+ connection.sync_exec_params(sql_query, [user.to_s()]) do |result|
if result.num_tuples > 0
user_id = result[0]['user_id']
end