Ruby如何使用Mysql2連接操作MySQL

137次閱讀

共計 8324 個字符，預計需要花費 21 分鐘才能閱讀完成。

這篇文章主要介紹“Ruby 如何使用 Mysql2 連接操作 MySQL”，在日常操作中，相信很多人在 Ruby 如何使用 Mysql2 連接操作 MySQL 問題上存在疑惑，丸趣 TV 小編查閱了各式資料，整理出簡單好用的操作方法，希望對大家解答”Ruby 如何使用 Mysql2 連接操作 MySQL”的疑惑有所幫助！接下來，請跟著丸趣 TV 小編一起來學習吧！

Ruby 操作 MySQL

使用 mysql2 連接 mysql 并操作 mysql。

gem install mysql2

連接 mysql

建立連接：

require  mysql2 
conn = Mysql2::Client.new({ 
 host:  192.168.200.73 ,
 username:  root ,
 password:  P@ssword1! 
})

接受的連接選項包括：

Mysql2::Client.new(
 :host,
 :username,
 :password,
 :port,
 :database,
 :socket =  /path/to/mysql.sock ,
 :flags = REMEMBER_OPTIONS | LONG_PASSWORD | LONG_FLAG | TRANSACTIONS | PROTOCOL_41 | SECURE_CONNECTION | MULTI_STATEMENTS,
 :encoding =  utf8 ,
 :read_timeout = seconds,
 :write_timeout = seconds,
 :connect_timeout = seconds,
 :connect_attrs = {:program_name =  $PROGRAM_NAME, ...},
 :reconnect = true/false,
 :local_infile = true/false,
 :secure_auth = true/false,
 :ssl_mode = :disabled / :preferred / :required / :verify_ca / :verify_identity,
 :default_file =  $HOME/.my.cnf , #=   從文件讀取連接信息
 :default_group =  my.cfg section , #=   選擇.my.cnf 中的 section
 :default_auth =  authentication_windows_client ,
 :init_command =  SQL_Statement #= 主要用于設置本次連接時的某些變量
)

連接建立后就可以操作數據庫了，比如執行 SQL 語句：

conn. query(create databse mytest)
conn.select_ db(  mytest  )
# conn.query(use mytest  )
conn. query(create table tb(name varchar(1024),age int) )
conn. query  -SQL
 insert into tb values 
 (junmajinlong , 23), 
 (  woniu , 25),
 (fairy , 26)
SQL

如果測試和 mysql 的連接是否斷開，可執行 ping()：

conn.ping

如果連接未斷開，ping()返回 true，如果連接已斷開但已啟用 auto-reconnect，則 ping()會嘗試依次 reconnect，連接成功則返回 true，否則報錯。如果連接已斷開，且未啟用 auto-reconnect，則報錯。

query()查詢和結果處理

query()用于執行任何允許的 SQL 語句，比如執行查詢語句。

查詢結果可使用 each 進行迭代，迭代時傳遞查詢到的每一行記錄，可使用 hash 索引的方式 (默認以 hash 類型保存每一行) 查詢某個字段的內容：

conn.query(show databases).each do |row| pp row end
=begin
{Database = information_schema}
{Database = mysql}
{Database = mytest}
{Database = performance_schema}
{Database = sys}
conn.query(select * from mytest.tb).each do |row|
 pp row
 pp row[name]
=begin
{name = junmajinlong ,  age = 23}
 junmajinlong 
{name = woniu ,  age = 25}
 woniu 
{name = fairy ,  age = 26}
 fairy 
=end

可見，查詢結果中，每一行數據默認以 hash 格式保存。

實際上，對于增刪改的 SQL 語句，query()的返回值為 nil，對于查詢類的語句，其返回值以 Mysql2::Result 對象返回

conn.query(create table mytest.t1(id int) )
#=  nil
res = conn.query(select * from mytest.tb)
p res

結果：

# Mysql2::Result:0x00007fffe833a230
 @query_options=
 {:as= :hash,
 :async= false,
 :cast_booleans= false,
 :symbolize_keys= false,
 :database_timezone= :local,
 :application_timezone= nil,
 :cache_rows= true,
 :connect_flags= 2148540933,
 :cast= true,
 :default_file= nil,
 :default_group= nil,
 :host= 192.168.200.73 ,
 :username= root ,
 :password= P@ssword1! },
 @server_flags=
 {:no_good_index_used= false, 
 :no_index_used= true, 
 :query_was_slow= false}

query()各查詢選項的含義以及默認的查詢選項參見下文。先了解兩個：

:as 項表示以數組方式 (:as= :array) 還是 hash 方式 (:as= :hash) 存儲查詢結果

:symbolize_keys 表示返回 hash 結果時，其 key 是否設置為符號類型，默認為 false，即 key 是字符串類型

可在查詢時指定這些參數，也可在 each 迭代時指定這些參數，例如：

conn.query(select * from mytest.tb , symbolize_keys: true).each do |row|
 pp row
conn.query(select * from mytest.tb).each(symbolize_keys: true) do |row|
 pp row
end

結果：

{:name= junmajinlong , :age= 23}
{:name= woniu , :age= 25}
{:name= fairy , :age= 26}

雖然大多數時候使用 hash 保存每一行數據更方便，但有時候也會想要以數組方式操作每一行數據，例如連接每一個字段的值：

sql =  select * from mytest.tb 
res = conn.query(sql)
res.each(as: :array) do |row|
 p row.join(,)
end

結果：

junmajinlong,23 
 woniu,25 
 fairy,26

Mysql2::Result 自身具備的方法不多：

#count ? Object (also: #size)
#each(*args) ? Object
#fields ? Object
#free ? Object

外，Mysql2::Result 已經 mix-in 了 Enumerable 模塊，所以可直接使用該模塊中的方法，例如 first 表示取第一行記錄。

sql =  select * from mytest.tb 
res = conn.query(sql)
res.first
#= {name = junmajinlong ,  age = 23}

需注意，所有 SQL 語句中涉及到的值都是未經轉義的，有時候需要也建議在執行它們之前先對它們進行轉義。

escaped = conn.escape(gi thu\ bbe\0r s)
results = conn.query(SELECT * FROM users WHERE group= #{escaped} )

查詢選項含義以及默認查詢選項

query()默認的查詢選項可以通過 Mysql2::Client.default_query_options 獲取，它是一個 hash 結果：

Mysql2::Client.default_query_options
=begin
{:as= :hash,
 :async= false,
 :cast_booleans= false,
 :symbolize_keys= false,
 :database_timezone= :local,
 :application_timezone= nil,
 :cache_rows= true,
 :connect_flags= 2148540933,
 :cast= true,
 :default_file= nil,
 :default_group= nil}
=end

其中(重要)：

:as 項表示以數組方式 (:as= :array) 還是 hash 方式 (:as= :hash) 存儲查詢結果

:symbolize_keys 表示返回 hash 結果時，其 key 是否設置為符號類型，默認為 false，即 key 是字符串類型

:async 表示查詢是否異步模式，即是否非阻塞的查詢，參考 https://github.com/brianmario/mysql2#async

:cast 指示 MySQL 的查詢結果轉換為 Ruby 數據時是否進行類型轉換，如果確定本次查詢的字段類型和 Ruby 的類型完全對應，可禁用 casting 功能提升效率

:database_timezone 指示 Ruby 接收 MySQL 返回的日期時間數據時的時區，mysql2 將先以該時區創建日期時間對象來保存對應字段的值。僅支持:local 和:utc 兩個值

:application_timezone 指示最終 Mysql2::Result 中的日期時間的時區，即程序端的時區。因此，mysql2 先以”無損”的時區從 MySQL 獲取日期時間數據，并根據 application_timezone 將其轉換成程序端時區的日期時間對象

:cache_rows 指示是否緩存構建出來的 hash 行或 array 行

Mysql2 處理查詢結果的流程：

Mysql2 的 MySQL C api 從 MySQL 服務端查詢數據，并保存在 Ruby 的查詢結果集(結果集屬于 C)

Mysql2::Result 和 C 端結果集是關聯的，當釋放 Mysql2::Result，也會對 C 結果集進行 GC

Mysql2 在需要取得結果集中的數據時(比如 each 迭代)，才從結果集中根據查詢選項構建所需行并返回，比如構建 hash 結構的行，構建數組結構的行，構建 hash 結構時將 key 轉換為 Symbol 類型等

默認情況下，從結果集中查詢并構建出來的 hash 行或 array 行會緩存在 Ruby 中，使得下次再次請求這一行時(比如再次迭代)，可用直接從緩存中取得 hash 行或 array 行

比如從 MySQL 服務端查詢了 100 行數據保存在 C 的結果集中，第一次以 hash 方式請求其中 4 行，這 4 行 hash 數據會緩存起來，如果下次再從頭開始以 hash 方式請求 15 行，則前 4 行來自于緩存，后 11 行來自于結果集的臨時構建

如果:cache_rows 未禁用，當結果集中的所有行都被緩存，Mysql2::Result 將會去釋放 C 端的結果集

如果能確保查詢的結果集只使用一次，可禁用:cache_rows，這會提升效率

:stream: true 表示以 Stream 的方式處理查詢結果。有時候查詢結果數據量非常大，Ruby 端不方便存放所有結果，可采用 stream 的方式去處理本次查詢：一邊從 MySQL 服務端取數據放進結果集，一邊從結果集中取數據進行處理(比如迭代)。使用 stream 時，會自動關閉 cache_rows，因為它們是互相沖突的概念。此外，使用 stream 模式要求必須迭代完所有數據集才會執行下一條查詢，因為一個 mysql 連接在某一時刻只能執行一個操作，在迭代完之前，本次查詢操作還尚未完成。

修改 Mysql2::Client.default_query_options 可以設置默認 query()的查詢選項。如果想要設置其中某選項，可以通過 hash 合并的方式來設置該選項。

Mysql2::Client.default_query_options
#=  {:as= :hash, ...}
Mysql2::Client.default_query_options.merge!(:as =  :array)
#=  {:as= :array, ...}

prepare()+execute()

除了直接使用 query()執行 SQL 語句查詢數據庫，也可以使用 prepare()方法將字符串準備成一個待執行的 SQL 語句，其中可以使用? 充當占位符。

prepare 后的語句是一個 Mysql2::Statement 對象，該對象有一個 execute()方法，可以用來執行這個準備好的語句，它可指定查詢選項，且其返回值同 query()一樣：對于增刪改操作，返回值為 nil，對于查詢類操作，返回 Mysql2::Result 結果對象。

res_sql = conn.prepare(select * from mytest.tb where age  = ? and name like ?)
res = res_sql.execute(20,  %junma% , as: :array)
res.first

處理多結果集

有些存儲過程中可能包含多個查詢結果集，或者有時候會在一行 SQL 中包含多個 select 語句而同時返回多個結果集，Mysql2 能很好地處理多結果集問題。

要處理多結果集，連接 mysql 時必須指定一個 flag：

conn = Mysql2::Client.new({
 host:  192.168.200.73 ,
 username:  root ,
 password:  P@ssword1! ,
 flags: Mysql2::Client::MULTI_STATEMENTS
})

然后執行多結果集的多個查詢語句：

res = conn.query(select 1;select 2;select 3)

雖然本次 query()涉及了多個 select 語句，Mysql2 也已經保存了這三個 select 的查詢結果集 (保存在結果集隊列中)，但本次 query() 方法的返回值僅是第一個結果集，所以 res 中保存的是第一個結果集的內容。

res.first #=  {1 = 1}

要獲取剩余的結果集，可通過 conn.next_result 將結果集偏移指針移到下一個結果集，然后通過 conn.store_result 獲取下一個結果集，依次類推，直到沒有剩余結果集后，conn.next_result 返回 false。可通過 more_results?()方法判斷是否還有剩余的結果集。

conn.next_result
res = conn.store_result
res.first #=  {2 = 2}
conn.next_result
res = conn.store_result
res.first #=  {3 = 3}
conn.next_result #=  false

所以，可遍歷多個結果集：

res = conn.query(select 1;select 2;select 3)
loop do
 p res.first
 break unless conn.next_result
 res = conn.store_result
#  或者
p res.first
while conn.next_result
 res = conn.store_result
 p res.first
end

輸出結果：

{1 = 1}
{2 = 2}
{3 = 3}

需注意，開啟多行語句 (即多結果集) 功能后，所查詢得到的所有結果集必須已經處理完成 (嚴格來說，是存放結果集的隊列已經為空)，才能繼續執行后續的 SQL 語句(事實上，經測試，結果集隊列未空的情況下執行其它 SQL 語句會導致直接斷開 mysql 連接)?？墒褂?abandon_results!() 方法強行丟棄所有剩余結果集，使得 Mysql2 馬上回歸正常狀態：可向 MySQL 服務端發送 SQL 語句。

# res 和 res1 都只保存第一個結果集
#  但結果集隊列中保留的是 select 5 和 select 6 的結果集
res = conn.query(select 1;select 2;select 3)
conn.abandon_results! #  丟棄所有剩余結果集
res1 = conn.query(select 4;select 5;select 6)

另外，如果多個查詢語句中間的某個查詢語句報錯，它將影響其后面的語句不會執行，所以無法獲取后面的結果集。

res = conn.query(select 1;select 2;select A;select 3)
loop do
 p res.first
 break unless conn.next_result
 res = conn.store_result
end

結果：

{1 = 1}
{2 = 2}
Mysql2::Error: Unknown column  A  in  field list

Mysql2 的 EventMachine

Mysql2 支持 EM，可以執行異步的 query()，此外，可以指定當 query()查詢成功或失敗時的回調語句塊：

require  mysql2/em 
EM.run do
 client1 = Mysql2::EM::Client.new
 defer1 = client1.query  SELECT sleep(3) as first_query 
 defer1.callback do |result|
 puts  Result: #{result.to_a.inspect} 
 end
 client2 = Mysql2::EM::Client.new
 defer2 = client2.query  SELECT sleep(1) second_query 
 defer2.callback do |result|
 puts  Result: #{result.to_a.inspect} 
 end
end

ORM 之：Sequel

Active:Record 應該是最為人熟知的 orm，其功能極其豐富。

另一個輕量級的 ORM 是 Sequel，它支持 ADO, JDBC, MySQL, Mysql2, ODBC, Oracle, PostgreSQL, SQLite3 等等。

例如：

require  sequel 
#  創建數據庫實例
DB = Sequel.connect(
 adapter: :mysql2,
 user:  root ,
 password:  P@ssword1! ,
 host:  192.168.200.73 ,
 port: 3306,
 database:  mytest 
#  創建數據集，數據集表示的是一張表或表部分數據
#  此時不會去查詢數據，會推遲到需要數據時才查詢
dataset = DB[:tb]
#  迭代表數據
dataset.each do |row|
 pp row
#  條件查詢
pp dataset.where(name:  junmajinlong , age: 23).first
pp dataset.where { name =~  junmajinlong  and age =~ 23 }.first

到此，關于“Ruby 如何使用 Mysql2 連接操作 MySQL”的學習就結束了，希望能夠解決大家的疑惑。理論與實踐的搭配能更好的幫助大家學習，快去試試吧！若想繼續學習更多相關知識，請繼續關注丸趣 TV 網站，丸趣 TV 小編會繼續努力為大家帶來更多實用的文章！

向 AI 問一下細節

丸趣 TV 網 – 提供最優質的資源集合！

正文完