通过纯Ruby，数据库连接将哈希插入MySQL

Question

我使用的是mysql gem和Ruby 1.9.3，而不是使用Rails。我有以下几点：

#!/bin/env ruby
# encoding: utf-8
require 'rubygems'
require 'mysql'
# Open DB connection
begin
  con = Mysql.new 'localhost', 'root', '', 'data'
  con.query("CREATE TABLE IF NOT EXISTS
    shops(id INT PRIMARY KEY AUTO_INCREMENT,
      name VARCHAR(255),
      latitude DECIMAL(15,10),
      longitude DECIMAL(15,10)
    )")
  ### Loop Starts ### 
    ...
    @place = {"name"=>"Tuba", "latitude"=>13.7383, "longitude"=>100.5883}
    # Write to DB
  ### Loop Ends ###
rescue Mysql::Error => e
  puts e.errno
  puts e.error
ensure
  con.close if con
end

问题

1. @place是一个哈希值。除了迭代之外，如何快速插入到data表中？
2. 循环将继续，直到整个过程结束。我应该在每次插入后关闭连接，还是在过程结束之前保持打开状态？
3. 如果进程意外终止怎么办？如果连接未正确关闭，会影响数据吗？

更新：我的第一次尝试：

col = @place.map { | key, value | key } # => ["name", "latitude", "longitude"]
result = @place.map { | key, value | value } # => ["Tuba", 13.7383, 100.5883]
con.query("INSERT INTO shops (#{col}) VALUES(#{result});")

正如预期的那样，这会生成以下错误：

You have an error in your SQL syntax; check the manual that corresponds 
to your MySQL server version for the right syntax to use 
near '["name", "latitude", "longitude"] at line 1

Answer 1

我会制作一种插入数据的方法：

def insert_place(hash, con)
   statement = "INSERT INTO shops (name, latitude, longitude) VALUES (#{hash['name']}, #{hash['latitude']}, #{hash['longitude']});"
   con.query(statement)
end

此方法将哈希和连接对象作为参数。应尽可能重复使用连接。

然后在您的循环中，我将像这样使用此方法：

@place = {"name"=>"Tuba", "latitude"=>13.7383, "longitude"=>100.5883}
insert_place(@place, con)

最后回答你的最后一个问题...如果程序在您的循环中途终止，我看不到任何会"损坏"您的数据的内容，因为它是单个查询，它将成功或失败。两者之间什么都没有。如果您希望能够在发生故障时再次运行脚本，则需要确定中断的位置，因为再次运行会导致重复。

您可以手动执行此操作并适当地管理数据

或

您可以将其添加到insert_place方法中，以便在条目已在数据库中时跳过con.query（statement）位。

Answer 2

在我看来

，您需要从数组中提取值

con.query("INSERT INTO shops (#{*col}) VALUES(#{*result});")

可以对代码进行一些改进。我希望这会起作用

col = @place.keys # => ["name", "latitude", "longitude"]
result = @place.values # => ["Tuba", 13.7383, 100.5883]
con.query("INSERT INTO shops (#{*col}) VALUES(#{*result});")
# (not tested variant)
con.query("INSERT INTO shops (?) VALUES(?);", col, result)