Method: SQLRunner::Adapters::MySQL#execute

Defined in:
lib/sql_runner/adapters/mysql.rb

#execute(query, **bind_vars) ⇒ Object 



46
47
48
49
50
51
52
53
54
55
 
# File 'lib/sql_runner/adapters/mysql.rb', line 46

def execute(query, **bind_vars)
  bound_query, bindings, names = parse(query, bind_vars)
  validate_bindings(query, bind_vars, names)

  statement = @connection.prepare(bound_query)
  statement.execute(*bindings, cast: true)
rescue Mysql2::Error
  reconnect
  execute(query, **bind_vars)
end