やりたかった事
定期的に行うバッチ処理やメンテナンス作業とかなども
リモート（異なるマシン）に存在するMySQL DBに対し、少しずつ条件を変えながら合致するものを受け取って、それぞれ異なる処理を行う・・・みたいな時。
手動でSQLコマンド打ち込んで処理するのは面倒。
受け取ったデータに対する処理も自動化したい。
概要
net-ssh-getway を使って、MySQLサーバが存在するリモートに接続する。
接続をもとに
ソース
論より証拠 とか 型から入る みたいな話ですが
vagrantで作ったホストオンリー環境を参照し、総務省の自治体コードをベースにしたデータを参照し、
千葉市に属する自治体コードを持つのデータをすべて取ってくるというデモ的な処理を行っています
接続例
require 'mysql2'
require 'net/ssh/gateway'
gateway = Net::SSH::Gateway.new(
'192.168.33.10',
'vagrant',
password: 'vagrant,
port: 22,
keys: ['~/.ssh/ssh-key']
)
gateway.open('127.0.0.1', 3306) do |local_port|
client = Mysql2::Client.new(host: '127.0.0.1', database: 'if_kaigoworks', username: 'normal_user', password: 'normal_user', port: local_port )
results = client.query(" select * from city_list where state_code = '12' and city_code like('10%') ")
results.each do |row|
p row
end
end
SSH接続の設定部分
ssh接続
gateway = Net::SSH::Gateway.new(
'192.168.33.10',
'vagrant',
port: 22,
keys: ['~/.ssh/ssh-key']
)
接続部分
接続部分
gateway.open('127.0.0.1', 3306) do |local_port|
client = Mysql2::Client.new(host: '127.0.0.1', database: 'if_kaigoworks', username: 'normal_user', password: 'normal_user', port: local_port )
results = client.query(" select * from city_list where state_code = '12' and city_code like('10%') ")
results.each do |row|
p row
end
end
こういう描き方をしても良い
接続だけ作って、他の部分で使うことも考える
接続をよそでも使いまわしたい
@client = nil
gateway.open('127.0.0.1', 3306) do |local_port|
client = Mysql2::Client.new(host: '127.0.0.1', database: 'if_kaigoworks', username: 'username', password: 'password', port: local_port )
@client = client
end
results = @client.query(" select * from state_city_tags where state_code = '12' and city_code like('10%') ")
results.each do |row|
p row
end
実施結果
sshのパスワードを求められるので、入力する。
正しければスクリプトが走り、MySQLサーバに接続しSQLが実行され
実施例
$ ruby mysql_connect.rb
vagrant@192.168.33.10's password:
{"id"=>611, "state_code"=>"12", "city_code"=>"1002", "state_name"=>"千葉県", "city_name"=>"千葉市"}
{"id"=>612, "state_code"=>"12", "city_code"=>"1011", "state_name"=>"千葉県", "city_name"=>"千葉市中央区"}
{"id"=>613, "state_code"=>"12", "city_code"=>"1029", "state_name"=>"千葉県", "city_name"=>"千葉市花見川区"}
{"id"=>614, "state_code"=>"12", "city_code"=>"1037", "state_name"=>"千葉県", "city_name"=>"千葉市稲毛区"}
{"id"=>615, "state_code"=>"12", "city_code"=>"1045", "state_name"=>"千葉県", "city_name"=>"千葉市若葉区"}
{"id"=>616, "state_code"=>"12", "city_code"=>"1053", "state_name"=>"千葉県", "city_name"=>"千葉市緑区"}
{"id"=>617, "state_code"=>"12", "city_code"=>"1061", "state_name"=>"千葉県", "city_name"=>"千葉市美浜区"}
クエリの内容通り、state_codeが"12"（文字）かつ、city_codeが"10"で始まるレコードの一覧が取れた
（この場合、state_code="12"が千葉県で、city_code like('10%') が、千葉市の区分になる）
参考
RubyでSSHトンネル経由でサーバにアクセスする
http://qiita.com/yuku_t/items/03e2e507add1cd2e2a40