++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
require 'mysql'
class MysqlDb
# attr_accessor :host, :user, :pass, :database
def open(host=nil, user=nil, pass=nil, database=nil,port=3306)
@host =host
@user = user
@pass = pass
@database = database
@port = port
begin
@connection = Mysql.new(@host, @user, @pass, @database, @port)
rescue
puts "connect faild! an error has occurred: #{$!}" # 错误信息保存在特殊变量$!中。
try_again
end
end
def try_again
puts '------------------try again, if not modify, leave a blank---------------'
print "host: "
host=STDIN.gets.strip
@host = check_value(host,@host)
puts "---------------current host: #{@host}"
print "user: "
user =STDIN.gets.strip
@user = check_value(user,@user)
puts "---------------current user: #{@user}"
print "password: "
pass =STDIN.gets.strip
@pass = check_value(pass,@pass)
puts "---------------current password: #{@pass}"
print "database: "
database =STDIN.gets.strip
@database = check_value(database,@database)
puts "---------------current database: #{@database}"
print "port: "
port =STDIN.gets.strip
@port = check_value(port,@port)
open(@host, @user, @pass, @database, @port)
puts "---------------current port: #{@port}"
end
def check_value(value,returnvalue)
if value == ""
nil
else
returnvalue = value
end
return returnvalue
end
def iquery(sql)
field = []
@connection.query(sql).each do |data|
field <<data
end
field.to_a
end
def iexecute(sql)
@connection.query(sql)
end
def close
@connection.close
end
end
# useages
adb = MysqlDb.new
adb.open('127.0.0.1','root','zyq001122','hello_z','3307')
# result = db.query "insert into user value(7,\"lilY\",\"256y42\",\"#{Time.now.strftime("%Y-%m-%d %H:%M:%S")}\" )" # 插入记录
# result.each {|row| puts row}
num_of_records = adb.iquery ('select count(*) from user') #查询
puts num_of_records
#sql = "insert into user value(10,\"Hello-Kitty\",\"256y42\",\"#{Time.now.strftime("%Y-%m-%d %H:%M:%S")}\" )"# 数据操作
# sql = 'update user set name=\'jackjhons\' where uid=5 ' # 更新一条记录
#adb.iexecute(sql)
# adb.close
ruby读取指定的行，可以使用readlines将整个文件的内容读取到一个数组中，再获得指定行的数据arr = io.readlines
p arr[9] # 读出第10行的数据
