Ruby MySQL错误处理

断开数据库

如需断开数据库连接,请使用 disconnect API

dbh.disconnect

如果用户通过 disconnect 方法关闭了数据库连接,DBI 会回滚所有未完成的事务。但是,不需要依赖于任何 DBI 的实现细节,您的应用程序就能很好地显式调用 commit 或 rollback。

处理错误

有许多不同的错误来源。比如在执行 SQL 语句时的语法错误,或者是连接失败,又或者是对一个已经取消的或完成的语句句柄调用 fetch 方法。

如果某个 DBI 方法失败,DBI 会抛出异常。DBI 方法会抛出任何类型的异常,但是最重要的两种异常类是 DBI::InterfaceError 和 DBI::DatabaseError。

这些类的 Exception 对象有 err、errstr 和 state 三种属性,分表代表了错误号、一个描述性的错误字符串和一个标准的错误代码。属性具体说明如下:

错误 说明
err 返回所发生的错误的整数表示法,如果 DBD 不支持则返回 nil。例如,Oracle DBD 返回 ORA-XXXX 错误消息的数字部分。
errstr 返回所发生的错误的字符串表示法。
state 返回所发生的错误的 SQLSTATE 代码。SQLSTATE 是五字符长度的字符串。大多数的 DBD 并不支持它,所以会返回 nil。

如下代码:

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 该方法生成一个数据库句柄,建议在块的末尾调用 disconnect 来断开数据库。
dbh.prepare 该方法生成一个语句句柄,建议在块的末尾调用 finish。在块内,您必须调用 execute 方法来执行语句。
dbh.execute 该方法与 dbh.prepare 类似,但是 dbh.execute 不需要在块内调用 execute 方法。语句句柄会自动执行。

案例1

DBI.connect 可带有一个代码块,向它传递数据库句柄,且会在块的末尾自动断开句柄。

dbh = DBI.connect("DBI:Mysql:TESTDB:localhost", "testuser", "test123") do |dbh|

案例2

dbh.prepare 可带有一个代码块,向它传递语句句柄,且会在块的末尾自动调用 finish。

dbh.prepare("SHOW DATABASES") do |sth| sth.execute puts "Databases: " + sth.fetch_all.join(", ") end

实例3

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