前提・実現したいこと

ruby初心者でクローラーを作成してます。
その中でWebから取得した情報をmysqlに登録する箇所でエラーが発生しました。

発生している問題・エラーメッセージ

/Users/hiroyuki/.rbenv/versions/2.1.3/lib/ruby/site_ruby/2.1.0/rubygems/core_ext/kernel_require.rb:55:in `require': /Users/hiroyuki/.rbenv/versions/2.1.3/lib/ruby/gems/2.1.0/gems/anemone-0.7.2/lib/anemone/storage/mysql.rb:105: can't find string "SQL" anywhere before EOF (SyntaxError)
/Users/hiroyuki/.rbenv/versions/2.1.3/lib/ruby/gems/2.1.0/gems/anemone-0.7.2/lib/anemone/storage/mysql.rb:82: syntax error, unexpected end-of-input, expecting tSTRING_CONTENT or tSTRING_DBEG or tSTRING_DVAR or tSTRING_END
    from /Users/hiroyuki/.rbenv/versions/2.1.3/lib/ruby/site_ruby/2.1.0/rubygems/core_ext/kernel_require.rb:55:in `require'
    from /Users/hiroyuki/.rbenv/versions/2.1.3/lib/ruby/gems/2.1.0/gems/anemone-0.7.2/lib/anemone/storage.rb:44:in `MySQL'
    from anemone-mysql.rb:8:in `<main>'

該当のソースコード

require 'anemone'

urls = []
urls.push("http://www.yahoo.co.jp")

opts = {
:storage => Anemone::Storage::MySQL(),
:depth_limit => 0
}

Anemone.crawl(urls, opts) do |anemone|
anemone.on_every_page do |page|
puts page.url
puts page.doc.xpath("//title/text()").to_s if page.doc
end
end

試したこと

補足情報(言語/FW/ツール等のバージョンなど)

関係ファイルのソースコードを下記に記載します。

mysql.rb

begin
require 'mysql2'
rescue LoadError
puts "You need the mysql2 gem to use Anemone::Storage::MySQL"
exit
end

module Anemone
module Storage
class MySQL

def initialize(opts = {})
host = opts[:host] || 'localhost'
username = opts[:username] || 'crawler'
password = opts[:password] || 'anemone_pass'
database = opts[:database] || 'anemone'
@db = Mysql2::Client.new(:host => host, :username => username, :password => password, :database => database)
create_schema
end

def [](url)
value = @db.query("SELECT data FROM anemone_storage WHERE page_key = '#{get_hash_value(url)}'").first['data']
if value
Marshal.load(value)
end
end

def []=(url, value)
data = Marshal.dump(value)
key = get_hash_value(url)
if has_key?(url)
@db.query("UPDATE anemone_storage SET page_data = '#{data}' WHERE page_key = '#{key}'")
else
@db.query("INSERT INTO anemone_storage (page_key, page_data) VALUES('#{key}', '#{data}')")
end
end

def delete(url)
page = self[url]
@db.query("DELETE FROM anemone_storage WHERE page_key = '#{get_hash_value(url)}'")
page
end

def each
@db.execute("SELECT page_key, page_data FROM anemone_storage ORDER BY id") do |row|
value = Marshal.load(row[1])
yield row[0], value
end
end

def merge!(hash)
hash.each { |key, value| self[key] = value }
self
end

def size
@db.query('SELECT COUNT(*) FROM anemone_storage')
end

def keys
@db.query("SELECT page_key FROM anemone_storage ORDER BY id").map{|t| t[0]}
end

def has_key?(url)
key = get_hash_value(url)
result = @db.query("SELECT count(id) FROM anemone_storage WHERE page_key = '#{key}'")
if result.first['count(id)'] > 0
return true
else
return false
end
end

def close
@db.close
end

private
def create_schema
@db.query <<-SQL
create table if not exists anemone_storage (
id int(11) NOT NULL auto_increment,
page_key varchar(255),
page_data BLOB,
PRIMARY KEY (id),
key (page_key)
) DEFAULT CHARSET=utf8;SQL
end

def load_page(hash)
BINARY_FIELDS.each do |field|
hash[field] = hash[field].to_s
end
Page.from_hash(hash)
end

def get_hash_value(key)
Digest::SHA1.hexdigest(key)
end
end
end
end

storage.rb

module Anemone
module Storage

def self.Hash(*args)
hash = Hash.new(*args)

 add close method for compatibility with Storage::Base

class << hash; def close; end; end
hash
end

def self.PStore(*args)
require 'anemone/storage/pstore'
self::PStore.new(*args)
end

def self.TokyoCabinet(file = 'anemone.tch')
require 'anemone/storage/tokyo_cabinet'
self::TokyoCabinet.new(file)
end

def self.KyotoCabinet(file = 'anemone.kch')
require 'anemone/storage/kyoto_cabinet'
self::KyotoCabinet.new(file)
end

def self.MongoDB(mongo_db = nil, collection_name = 'pages')
require 'anemone/storage/mongodb'
mongo_db ||= Mongo::Connection.new.db('anemone')
raise "First argument must be an instance of Mongo::DB" unless mongo_db.is_a?(Mongo::DB)
self::MongoDB.new(mongo_db, collection_name)
end

def self.Redis(opts = {})
require 'anemone/storage/redis'
self::Redis.new(opts)
end

def self.SQLite3(file = 'anemone.db')
require 'anemone/storage/sqlite3'
self::SQLite3.new(file)
end

def self.MySQL(opts = {})
require 'anemone/storage/mysql'
self::MySQL.new(opts)
end

end
end