plugin_dbname = cfg.send("#{plugin}_dbname")
next if plugin_dbname.nil? # Skip the dovecot plugin
query = "CREATE DATABASE #{plugin_dbname};"
- connection.query(query)
+ connection.sync_exec(query)
plugin_dbhost = cfg.send("#{plugin}_dbhost")
plugin_dbport = cfg.send("#{plugin}_dbport")
plugin_dbpass)
sql = File.open("test/sql/#{plugin}.sql").read()
- plugin_conn.query(sql)
+ plugin_conn.sync_exec(sql)
sql = File.open("test/sql/#{plugin}-fixtures.sql").read()
- plugin_conn.query(sql)
+ plugin_conn.sync_exec(sql)
plugin_conn.close()
end
plugin_dbname = cfg.send("#{plugin}_dbname")
next if plugin_dbname.nil? # Skip the dovecot plugin
query = "DROP DATABASE IF EXISTS #{plugin_dbname};"
- connection.query(query)
+ connection.sync_exec(query)
end
connection.close()