Rails 3 executa consulta sql personalizada sem um modelo

105

Preciso escrever um script ruby ​​autônomo que deve lidar com banco de dados. Eu usei o código fornecido abaixo no rails 3

@connection = ActiveRecord::Base.establish_connection(
:adapter => "mysql2",
:host => "localhost",
:database => "siteconfig_development",
:username => "root",
:password => "root123"
)

results = @connection.execute("select * from users")
results.each do |row|
puts row[0]
end

mas obtendo erro: -

`<main>': undefined method `execute' for #<ActiveRecord::ConnectionAdapters::ConnectionPool:0x00000002867548> (NoMethodError)

o que estou perdendo aqui?

SOLUÇÃO

Depois de obter a solução de denis-bu eu usei da seguinte maneira e funcionou também.

@connection = ActiveRecord::Base.establish_connection(
            :adapter => "mysql2",
            :host => "localhost",
            :database => "siteconfig_development",
            :username => "root",
            :password => "root123"
)

sql = "SELECT * from users"
@result = @connection.connection.execute(sql);
@result.each(:as => :hash) do |row| 
   puts row["email"] 
end
Neeraj
fonte

Respostas:

168

Talvez tente isto:

ActiveRecord::Base.establish_connection(...)
ActiveRecord::Base.connection.execute(...)
denis-bu
fonte
14
FWIW, Usar parâmetros vazios não é rubi idiomático. Então faça connection.executeao invés deconnection().execute
radixhound
Funciona no Rails 4 também.
Leigh McCulloch
github.com/igorkasyanchuk/execute_sql menos código é necessário e você pode fazer isso diretamente no console do Rails
Igor Kasyanchuk
100
connection = ActiveRecord::Base.connection
connection.execute("SQL query") 
Sachin R
fonte
8
Neste caso, connection = ActiveRecord :: Base.connection; connection.execute ("consulta SQL") funcionaria. Menos digitação!
Watusimoto
16
Ou apenasActiveRecord::Base.connection.execute("SQL query")
Kasper Grubbe
3
Esta conexão pode ter que ser retornada ao pool de conexão posteriormente para evitar problemas de threading: ActiveRecord::Base.connection_pool.checkin(connection) apidock.com/rails/ActiveRecord/ConnectionAdapters/…
lee
35

Eu recomendaria usar em ActiveRecord::Base.connection.exec_queryvez de ActiveRecord::Base.connection.executeque retorna um ActiveRecord::Result(disponível no rails 3.1+) que é um pouco mais fácil de trabalhar.

Em seguida, você pode acessá-lo em vários resultados de várias maneiras .rows, como .each, ou.to_hash

Dos documentos :

result = ActiveRecord::Base.connection.exec_query('SELECT id, title, body FROM posts')
result # => #<ActiveRecord::Result:0xdeadbeef>


# Get the column names of the result:
result.columns
# => ["id", "title", "body"]

# Get the record values of the result:
result.rows
# => [[1, "title_1", "body_1"],
      [2, "title_2", "body_2"],
      ...
     ]

# Get an array of hashes representing the result (column => value):
result.to_hash
# => [{"id" => 1, "title" => "title_1", "body" => "body_1"},
      {"id" => 2, "title" => "title_2", "body" => "body_2"},
      ...
     ]

# ActiveRecord::Result also includes Enumerable.
result.each do |row|
  puts row['title'] + " " + row['body']
end

nota: copiei minha resposta daqui

hajpoj
fonte
1
Conforme declarado, exec_query retorna os resultados reais - o que eu quero, enquanto execute apenas retorna informações de status.
Paul Chernoch
24

Você também pode usar find_by_sql

# A simple SQL query spanning multiple tables
Post.find_by_sql "SELECT p.title, c.author FROM posts p, comments c WHERE p.id = c.post_id"
> [#<Post:0x36bff9c @attributes={"title"=>"Ruby Meetup", "first_name"=>"Quentin"}>, ...]
montrealmike
fonte
meu script é um aplicativo fora do Rails, então não acho que find_by_sql funcionaria.
neeraj
4
você está certo, eu li sua pergunta muito rápido. Esta resposta pode ajudar outras pessoas que vêm a esta página com base no título da sua pergunta.
Montreal,
como obter não uma matriz, mas uma relação?
Малъ Скрылевъ
4

Que tal agora :

@client = TinyTds::Client.new(
      :adapter => 'mysql2',
      :host => 'host',
      :database => 'siteconfig_development',
      :username => 'username',
      :password => 'password'

sql = "SELECT * FROM users"

result = @client.execute(sql)

results.each do |row|
puts row[0]
end

Você precisa ter o TinyTds gem instalado, uma vez que você não especificou em sua pergunta Eu não usei o Active Record

formiga
fonte
1
Claro, TinyTds é uma joia totalmente diferente. Não é ActiveRecord. Para usá-lo, você deve instalá-lo separadamente.
denis-bu
1
Não quero usar nenhum GEM adicional, desde que mysql2 e active-record estejam disponíveis
neeraj
Bom, você deve mencionar isso em sua pergunta (tag / título)
formiga
2
TinyTDS funciona com MSSQL e Sybase, não funciona com MySQL. formiga: Você deve mencionar isso em sua resposta, e não presumir que o OP está usando o mesmo SGBD de nicho que você.
cliffordheath de