本章节将向您讲解如何使用 Ruby 访问数据库。Ruby DBI 模块为 Ruby 脚本提供了类似于 Perl DBI 模块的独立于数据库的接口。

DBI 即 Database independent interface,代表了 Ruby 独立于数据库的接口。DBI 在 Ruby 代码与底层数据库之间提供了一个抽象层,允许您简单地实现数据库切换。它定义了一系列方法、变量和规范,提供了一个独立于数据库的一致的数据库接口。

DBI 可与下列进行交互:

  • ADO (ActiveX Data Objects)
  • DB2
  • Frontbase
  • MySQL
  • ODBC
  • Proxy/Server
  • Oracle
  • mSQL
  • OCI8 (Oracle)
  • PostgreSQL
  • SQLite
  • SQLRelay

DBI 应用架构

DBI 独立于任何在后台中可用的数据库。无论您使用的是 Oracle、Informix、MySQL,您都可以使用 DBI。下面的架构图清晰地说明了这点。

Ruby DBI 一般的架构使用两个层:

  • 数据库接口(DBI)层。该层是独立于数据库,并提供了一系列公共访问方法,方法的使用不分数据库服务器类型。
  • 数据库驱动(DBD)层。该层是依赖于数据库,不同的驱动提供了对不同的数据库引擎的访问。MySQL、PostgreSQL、InterBase、Oracle 等分别使用不同的驱动。每个驱动都负责解释来自 DBI 层的请求,并把这些请求映射为适用于给定类型的数据库服务器的请求。

安装

如果您想要编写 Ruby 脚本来访问 MySQL 数据库,您需要先安装 Ruby MySQL 模块。

安装 Mysql 开发包

# Ubuntu
sudo apt-get install mysql-client
sudo apt-get install libmysqlclient15-dev
 
# Centos
yum install mysql-devel

Mac OS 系统需要修改 ~/.bash_profile 或 ~/.profile 文件,添加如下代码:

MYSQL=/usr/local/mysql/bin
export PATH=$PATH:$MYSQL
export DYLD_LIBRARY_PATH=/usr/local/mysql/lib:$DYLD_LIBRARY_PATH

或者使用软连接:

sudo ln -s /usr/local/mysql/lib/libmysqlclient.18.dylib /usr/lib/libmysqlclient.18.dylib

使用 RubyGems 安装 DBI(推荐)

RubyGems大约创建于2003年11月,从Ruby 1.9版起成为Ruby标准库的一部分。更多详情可以查看:Ruby RubyGems

使用 gem 安装 dbi 与 dbd-mysql:

sudo gem install dbi
sudo gem install mysql
sudo gem install dbd-mysql

使用源码安装(Ruby版本 小于1.9的使用此方法)

该模块是一个 DBD,可从 http://tmtm.org/downloads/mysql/ruby/ 上下载。

下载后最新包,解压进入到目录,执行以下命令安装:

ruby extconf.rb
 
或者
 
ruby extconf.rb --with-mysql-dir=/usr/local/mysql
 
或者
 
ruby extconf.rb --with-mysql-config

然后编译:

make

获取并安装 Ruby/DBI

您可以从下面的链接下载并安装 Ruby DBI 模块:

https://github.com/erikh/ruby-dbi

在开始安装之前,请确保您拥有 root 权限。现在,请安装下面的步骤进行安装:

步骤 1

git clone https://github.com/erikh/ruby-dbi.git

或者直接下再 zip 包并解压。

步骤 2

进入目录 ruby-dbi-master,在目录中使用 setup.rb 脚本进行配置。最常用的配置命令是 config 参数后不跟任何参数。该命令默认配置为安装所有的驱动。

ruby setup.rb config

更具体地,您可以使用 --with 选项来列出了您要使用的特定部分。例如,如果只想配置主要的 DBI 模块和 MySQL DBD 层驱动,请输入下面的命令:

ruby setup.rb config --with=dbi,dbd_mysql

步骤 3

最后一步是建立驱动器,使用下面命令进行安装:

ruby setup.rb setup ruby setup.rb install

数据库连接

假设我们使用的是 MySQL 数据库,在连接数据库之前,请确保:

  • 您已经创建了一个数据库 TESTDB。
  • 您已经在 TESTDB 中创建了表 EMPLOYEE。
  • 设置用户 ID "testuser" 和密码 "test123" 来访问 TESTDB
  • 已经在您的机器上正确地安装了 Ruby 模块 DBI。
  • 该表带有字段 FIRST_NAME、LAST_NAME、AGE、SEX 和 INCOME。
  • 您已经看过 MySQL 教程,理解了 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 操作

当您想要在数据库表中创建记录时,需要用到 INSERT 操作。

一旦建立了数据库连接,我们就可以准备使用 do 方法或 prepare 和 execute 方法创建表或创建插入数据表中的记录。

使用 do 语句

不返回行的语句可通过调用 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

使用 prepare 和 execute

您可以使用 DBI 的 prepare 和 execute 方法来执行 Ruby 代码中的 SQL 语句。

创建记录的步骤如下:

  • 准备带有 INSERT 语句的 SQL 语句。这将通过使用 prepare 方法来完成。
  • 执行 SQL 查询,从数据库中选择所有的结果。这将通过使用 execute 方法来完成。
  • 释放语句句柄。这将通过使用 finish API 来完成。
  • 如果一切进展顺利,则 commit 该操作,否则您可以 rollback 完成交易。

下面是使用这两种方法的语法:

实例

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 操作

对任何数据库的 READ 操作是指从数据库中获取有用的信息。

一旦建立了数据库连接,我们就可以准备查询数据库。我们可以使用 do 方法或 prepare 和 execute 方法从数据库表中获取值。

获取记录的步骤如下:

  • 基于所需的条件准备 SQL 查询。这将通过使用 prepare 方法来完成。
  • 执行 SQL 查询,从数据库中选择所有的结果。这将通过使用 execute 方法来完成。
  • 逐一获取结果,并输出这些结果。这将通过使用 fetch 方法来完成。
  • 释放语句句柄。这将通过使用 finish 方法来完成。

下面的实例从 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
 

Logo

腾讯云面向开发者汇聚海量精品云计算使用和开发经验,营造开放的云计算技术生态圈。

更多推荐