Method: Sequel::JDBC::Database#execute

Defined in:

lib/sequel/adapters/jdbc.rb

#execute(sql, opts = OPTS, &block) ⇒ Object Also known as: execute_dui

# File 'lib/sequel/adapters/jdbc.rb', line 257

def execute(sql, opts=OPTS, &block)
  return call_sproc(sql, opts, &block) if opts[:sproc]
  return execute_prepared_statement(sql, opts, &block) if [Symbol, Dataset].any?{|c| sql.is_a?(c)}
  synchronize(opts[:server]) do |conn|
    statement(conn) do |stmt|
      if block
        if size = fetch_size
          stmt.setFetchSize(size)
        end
        yield log_connection_yield(sql, conn){stmt.executeQuery(sql)}
      else
        case opts[:type]
        when :ddl
          log_connection_yield(sql, conn){stmt.execute(sql)}
        when :insert
          log_connection_yield(sql, conn){execute_statement_insert(stmt, sql)}
          opts = Hash[opts]
          opts[:stmt] = stmt
          last_insert_id(conn, opts)
        else
          log_connection_yield(sql, conn){stmt.executeUpdate(sql)}
        end
      end
    end
  end
end