文章摘要
这篇文章介绍了基于自动生成SQL语句的工具，提供了多种数据库适应器（如MySQL、Excel）来简化数据获取流程。文章详细描述了以下几个核心功能：
1. **自动生成SQL语句**：通过`generate_sql`函数可以根据给定的表名、字段和条件自动生成SQL语句。
2. **数据处理工具**：`generate_hash`函数用于将数据库结果转换为哈希表，便于后续处理。
3. **数据库适应器**：不同适应器（如`Mysql_Adapter`、`Excel_Adapter`）展示了如何处理MySQL、Excel等不同数据库类型的数据，包括数据连接、查询执行和结果处理。
文章整体围绕如何自动化数据提取和处理过程展开，旨在减少手动编码，简化数据获取和处理流程。
#encoding: utf-8
require ‘DBI’
require ‘odbc_utf8’
def generate_sql(table, what=nil, where=nil)
what=”*” unless what
where=”1=1″ unless where
“select %s from %s where %s” % [what, table, where]
end
def generate_hash(header, all_data)
t_arr=[]
all_data.each do | row |
t_hash={}
for i in 0..header.size-1 do
t_hash[header[i]]=row[i]
end
t_arr << t_hash
end
t_arr
end
def select_hash_db(dsn,user,password,db,sql)
begin
dbh=DBI.connect(dsn, user, password)
dbh.do(“use #{db}”)
dbh.do(“SET NAMES UTF8″) if dsn.split(‘:’)[1]==”Mysql”
sth=dbh.execute(sql)
arr=Array.new
sth.fetch_hash do | row |
arr << row
end
sth.finish
arr
rescue DBI::DatabaseError=> e
puts “An error occurred”
puts “Error code: #{e.err}”
puts “Error message: #{e.errstr}”
ensure
dbh.disconnect if dbh
end
end
class Text_Adapter
def initialize(file_path, sep=” “, col_num=nil, row_num=nil)
end
def get_pars(row=nil)
end
end
class Mysql_Adapter
def initialize(ds_connector, table_name, what=nil, where=nil)
@sql_str=generate_sql(table_name, what, where)
@ds_connector=ds_connector
end
def get_pars(row=nil)
dsc_arr=@ds_connector.split(“#”)
all_data=select_hash_db(dsc_arr[0],dsc_arr[1],dsc_arr[2],dsc_arr[3],@sql_str)
if row.class==Fixnum
all_data[row]
else
all_data
end
end
end
class Excel_Adapter
def initialize(ds_connector, table_name, what=nil, where=nil)
@connection=WIN32OLE.new(‘ADODB.Connection’)
@record_set=WIN32OLE.new(‘ADODB.Recordset’)
@ds_connector=ds_connector
@sql_str=generate_sql(table_name, what, where)
end
def get_pars(row=nil)
t_arr=[]
@connection.Open(@ds_connector)
@record_set.Open(@sql_str, @connection)
@record_set.Fields.count.times do | i |
t_arr << @record_set.Fields.Item(i).name
end
all_data=@record_set.GetRows.transpose
all_data=generate_hash(t_arr, all_data)
if row.class==Fixnum
all_data[row]
else
all_data
end
end
end
class Parameter
def initialize(ds_connector, table_name, what=nil, where=nil)
dsc_arr=ds_connector.split(“#”, 2)
eval(“@adp=#{dsc_arr[0]}.new dsc_arr[1], table_name, what, where”)
end
def get_pars(row=nil)
@adp.get_pars(row)
end
end