本章节将向您讲解如何使用 ruby 访问数据库。ruby dbi 模块为 ruby 脚本提供了类似于 perl dbi 模块的独立于数据库的接口。
dbi 即 database independent interface，代表了 ruby 独立于数据库的接口。dbi 在 ruby 代码与底层数据库之间提供了一个抽象层，允许您简单地实现数据库切换。它定义了一系列方法、变量和规范，提供了一个独立于数据库的一致的数据库接口。
dbi 可与下列进行交互：
dbi 独立于任何在后台中可用的数据库。无论您使用的是 oracle、mysql、informix，您都可以使用 dbi。下面的架构图清晰地说明了这点。
ruby dbi 一般的架构使用两个层：
如果您想要编写 ruby 脚本来访问 mysql 数据库，您需要先安装 ruby mysql 模块。
该模块是一个 dbd，可从 http://www.tmtm.org/en/mysql/ruby/ 上下载。
您可以从下面的链接下载并安装 ruby dbi 模块：
| http://rubyforge.org/projects/ruby-dbi/ |
在开始安装之前，请确保您拥有 root 权限。现在，请安装下面的步骤进行安装：
$ tar zxf dbi-0.2.0.tar.gz
进入目录 dbi-0.2.0，在目录中使用 setup.rb 脚本进行配置。最常用的配置命令是 config 参数后不跟任何参数。该命令默认配置为安装所有的驱动。
$ ruby setup.rb config
更具体地，您可以使用 --with 选项来列出了您要使用的特定部分。例如，如果只想配置主要的 dbi 模块和 mysql dbd 层驱动，请输入下面的命令：
$ ruby setup.rb config --with=dbi,dbd_mysql
最后一步是建立驱动器，使用下面命令进行安装：
$ ruby setup.rb setup $ ruby setup.rb install
假设我们使用的是 mysql 数据库，在连接数据库之前，请确保：
下面是连接 mysql 数据库 "testdb" 的实例：
#!/usr/bin/ruby -w
require "dbi"
begin
# 连接到 mysql 服务器
dbh = dbi.connect("dbi:mysql:testdb:localhost",
"testuser", "test123")
# 获取服务器版本字符串，并显示
row = dbh.select_one("select version()")
puts "server version: " + row[0]
rescue dbi::databaseerror => e
puts "an error occurred"
puts "error code: #{e.err}"
puts "error message: #{e.errstr}"
ensure
# 断开与服务器的连接
dbh.disconnect if dbh
end
当运行这段脚本时，将会在 linux 机器上产生以下结果。
server version: 5.0.45
如果建立连接时带有数据源，则返回数据库句柄（database handle），并保存到 dbh 中以便后续使用，否则 dbh 将被设置为 nil 值，e.err 和 e::errstr 分别返回错误代码和错误字符串。
最后，在退出这段程序之前，请确保关闭数据库连接，释放资源。
当您想要在数据库表中创建记录时，需要用到 insert 操作。
一旦建立了数据库连接，我们就可以准备使用 do 方法或 prepare 和 execute 方法创建表或创建插入数据表中的记录。
不返回行的语句可通过调用 do 数据库处理方法。该方法带有一个语句字符串参数，并返回该语句所影响的行数。
dbh.do("drop table if exists employee")
dbh.do("create table employee (
first_name char(20) not null,
last_name char(20),
age int,
sex char(1),
income float )" );
同样地，您可以执行 sql insert 语句来创建记录插入 employee 表中。
#!/usr/bin/ruby -w
require "dbi"
begin
# 连接到 mysql 服务器
dbh = dbi.connect("dbi:mysql:testdb:localhost",
"testuser", "test123")
dbh.do( "insert into employee(first_name,
last_name,
age,
sex,
income)
values ('mac', 'mohan', 20, 'm', 2000)" )
puts "record has been created"
dbh.commit
rescue dbi::databaseerror => e
puts "an error occurred"
puts "error code: #{e.err}"
puts "error message: #{e.errstr}"
dbh.rollback
ensure
# 断开与服务器的连接
dbh.disconnect if dbh
end
您可以使用 dbi 的 prepare 和 execute 方法来执行 ruby 代码中的 sql 语句。
创建记录的步骤如下：
下面是使用这两种方法的语法：
sth = dbh.prepare(statement) sth.execute ... zero or more sql operations ... sth.finish
这两种方法可用于传 bind 值给 sql 语句。有时候被输入的值可能未事先给出，在这种情况下，则会用到绑定值。使用问号（?）替代实际值，实际值通过 execute() api 来传递。
下面的实例在 employee 表中创建了两个记录：
#!/usr/bin/ruby -w
require "dbi"
begin
# 连接到 mysql 服务器
dbh = dbi.connect("dbi:mysql:testdb:localhost",
"testuser", "test123")
sth = dbh.prepare( "insert into employee(first_name,
last_name,
age,
sex,
income)
values (?, ?, ?, ?, ?)" )
sth.execute('john', 'poul', 25, 'm', 2300)
sth.execute('zara', 'ali', 17, 'f', 1000)
sth.finish
dbh.commit
puts "record has been created"
rescue dbi::databaseerror => e
puts "an error occurred"
puts "error code: #{e.err}"
puts "error message: #{e.errstr}"
dbh.rollback
ensure
# 断开与服务器的连接
dbh.disconnect if dbh
end
如果同时使用多个 insert，那么先准备一个语句，然后在一个循环中多次执行它要比通过循环每次调用 do 有效率得多。
对任何数据库的 read 操作是指从数据库中获取有用的信息。
一旦建立了数据库连接，我们就可以准备查询数据库。我们可以使用 do 方法或 prepare 和 execute 方法从数据库表中获取值。
获取记录的步骤如下：
下面的实例从 employee 表中查询所有工资（salary）超过 1000 的记录。
#!/usr/bin/ruby -w
require "dbi"
begin
# 连接到 mysql 服务器
dbh = dbi.connect("dbi:mysql:testdb:localhost",
"testuser", "test123")
sth = dbh.prepare("select * from employee
where income > ?")
sth.execute(1000)
sth.fetch do |row|
printf "first name: %s, last name : %s\n", row[0], row[1]
printf "age: %d, sex : %s\n", row[2], row[3]
printf "salary :%d \n\n", row[4]
end
sth.finish
rescue dbi::databaseerror => e
puts "an error occurred"
puts "error code: #{e.err}"
puts "error message: #{e.errstr}"
ensure
# 断开与服务器的连接
dbh.disconnect if dbh
end
这将产生以下结果：
first name: mac, last name : mohan age: 20, sex : m salary :2000 first name: john, last name : poul age: 25, sex : m salary :2300
对任何数据库的 update 操作是指更新数据库中一个或多个已有的记录。下面的实例更新 sex 为 'm' 的所有记录。在这里，我们将把所有男性的 age 增加一岁。这将分为三步：
#!/usr/bin/ruby -w
require "dbi"
begin
# 连接到 mysql 服务器
dbh = dbi.connect("dbi:mysql:testdb:localhost",
"testuser", "test123")
sth = dbh.prepare("update employee set age = age + 1
where sex = ?")
sth.execute('m')
sth.finish
dbh.commit
rescue dbi::databaseerror => e
puts "an error occurred"
puts "error code: #{e.err}"
puts "error message: #{e.errstr}"
dbh.rollback
ensure
# 断开与服务器的连接
dbh.disconnect if dbh
end
当您想要从数据库中删除记录时，需要用到 delete 操作。下面的实例从 employee 中删除 age 超过 20 的所有记录。该操作的步骤如下：
#!/usr/bin/ruby -w
require "dbi"
begin
# 连接到 mysql 服务器
dbh = dbi.connect("dbi:mysql:testdb:localhost",
"testuser", "test123")
sth = dbh.prepare("delete from employee
where age > ?")
sth.execute(20)
sth.finish
dbh.commit
rescue dbi::databaseerror => e
puts "an error occurred"
puts "error code: #{e.err}"
puts "error message: #{e.errstr}"
dbh.rollback
ensure
# 断开与服务器的连接
dbh.disconnect if dbh
end
事务是一种确保交易一致性的机制。事务应具有下列四种属性：
dbi 提供了两种执行事务的方法。一种是 commit 或 rollback 方法，用于提交或回滚事务。还有一种是 transaction 方法，可用于实现事务。接下来我们来介绍这两种简单的实现事务的方法：
第一种方法使用 dbi 的 commit 和 rollback 方法来显式地提交或取消事务：
dbh['autocommit'] = false # 设置自动提交为 false.
begin
dbh.do("update employee set age = age+1
where first_name = 'john'")
dbh.do("update employee set age = age+1
where first_name = 'zara'")
dbh.commit
rescue
puts "transaction failed"
dbh.rollback
end
dbh['autocommit'] = true
第二种方法使用 transaction 方法。这个方法相对简单些，因为它需要一个包含构成事务语句的代码块。transaction 方法执行块，然后根据块是否执行成功，自动调用 commit 或 rollback：
dbh['autocommit'] = false # 设置自动提交为 false
dbh.transaction do |dbh|
dbh.do("update employee set age = age+1
where first_name = 'john'")
dbh.do("update employee set age = age+1
where first_name = 'zara'")
end
dbh['autocommit'] = true
commit 是一种标识数据库已完成更改的操作，在这个操作后，所有的更改都不可恢复。
下面是一个调用 commit 方法的简单实例。
dbh.commit
如果您不满意某个或某几个更改，您想要完全恢复这些更改，则使用 rollback 方法。
下面是一个调用 rollback 方法的简单实例。
dbh.rollback
如需断开数据库连接，请使用 disconnect api。
dbh.disconnect
如果用户通过 disconnect 方法关闭了数据库连接，dbi 会回滚所有未完成的事务。但是，不需要依赖于任何 dbi 的实现细节，您的应用程序就能很好地显式调用 commit 或 rollback。
有许多不同的错误来源。比如在执行 sql 语句时的语法错误，或者是连接失败，又或者是对一个已经取消的或完成的语句句柄调用 fetch 方法。
如果某个 dbi 方法失败，dbi 会抛出异常。dbi 方法会抛出任何类型的异常，但是最重要的两种异常类是 dbi::interfaceerror 和 dbi::databaseerror。
这些类的 exception 对象有 err、errstr 和 state 三种属性，分表代表了错误号、一个描述性的错误字符串和一个标准的错误代码。属性具体说明如下：
在上面的实例中您已经看过下面的代码：
rescue dbi::databaseerror => e
puts "an error occurred"
puts "error code: #{e.err}"
puts "error message: #{e.errstr}"
dbh.rollback
ensure
# 断开与服务器的连接
dbh.disconnect if dbh
end
为了获取脚本执行时有关脚本执行内容的调试信息，您可以启用跟踪。为此，您必须首先下载 dbi/trace 模块，然后调用控制跟踪模式和输出目的地的 trace 方法：
require "dbi/trace" .............. trace(mode, destination)
mode 的值可以是 0（off）、1、2 或 3，destination 的值应该是一个 io 对象。默认值分别是 2 和 stderr。
有一些创建句柄的方法。这些方法通过代码块调用。使用带有方法的代码块的优点是，它们为代码块提供了句柄作为参数，当块终止时会自动清除句柄。下面是一些实例，有助于理解这个概念。
dbi.connect 可带有一个代码块，向它传递数据库句柄，且会在块的末尾自动断开句柄。
dbh = dbi.connect("dbi:mysql:testdb:localhost",
"testuser", "test123") do |dbh|
dbh.prepare 可带有一个代码块，向它传递语句句柄，且会在块的末尾自动调用 finish。
dbh.prepare("show databases") do |sth|
sth.execute
puts "databases: " + sth.fetch_all.join(", ")
end
dbh.execute 可带有一个代码块，向它传递语句句柄，且会在块的末尾自动调用 finish。
dbh.execute("show databases") do |sth|
puts "databases: " + sth.fetch_all.join(", ")
end
dbi transaction 方法也可带有一个代码块，这在上面的章节中已经讲解过了。
dbi 让数据库驱动程序提供了额外的特定数据库的函数，这些函数可被用户通过任何 handle 对象的 func 方法进行调用。
使用 []= or [] 方法可以设置或获取特定驱动程序的属性。
dbd::mysql 实现了下列特定驱动程序的函数：
| 序号 | 函数 & 描述 |
|---|---|
| 1 | dbh.func(:createdb, db_name) 创建一个新的数据库。 |
| 2 | dbh.func(:dropdb, db_name) 删除一个数据库。 |
| 3 | dbh.func(:reload) 执行重新加载操作。 |
| 4 | dbh.func(:shutdown) 关闭服务器。 |
| 5 | dbh.func(:insert_id) => fixnum 返回该连接的最近 auto_increment 值。 |
| 6 | dbh.func(:client_info) => string 根据版本返回 mysql 客户端信息。 |
| 7 | dbh.func(:client_version) => fixnum 根据版本返回客户端信息。这与 :client_info 类似，但是它会返回一个 fixnum，而不是返回字符串。 |
| 8 | dbh.func(:host_info) => string 返回主机信息。 |
| 9 | dbh.func(:proto_info) => fixnum 返回用于通信的协议。 |
| 10 | dbh.func(:server_info) => string 根据版本返回 mysql 服务器端信息。 |
| 11 | dbh.func(:stat) => stringb> 返回数据库的当前状态。 |
| 12 | dbh.func(:thread_id) => fixnum 返回当前线程的 id。 |
#!/usr/bin/ruby
require "dbi"
begin
# 连接到 mysql 服务器
dbh = dbi.connect("dbi:mysql:testdb:localhost",
"testuser", "test123")
puts dbh.func(:client_info)
puts dbh.func(:client_version)
puts dbh.func(:host_info)
puts dbh.func(:proto_info)
puts dbh.func(:server_info)
puts dbh.func(:thread_id)
puts dbh.func(:stat)
rescue dbi::databaseerror => e
puts "an error occurred"
puts "error code: #{e.err}"
puts "error message: #{e.errstr}"
ensure
dbh.disconnect if dbh
end
这将产生以下结果：
5.0.45 50045 localhost via unix socket 10 5.0.45 150621 uptime: 384981 threads: 1 questions: 1101078 slow queries: 4 \ opens: 324 flush tables: 1 open tables: 64 \ queries per second avg: 2.860
