Ruby 数据库访问 - DBI 教程(上)
Ruby 数据库访问 - DBI 教程(上)
本章节将向您讲解如何使用 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
更多推荐
所有评论(0)