m.select_db("rtest2") # Выбрать другую базу данных.
in.drop_db("rtest") # Удалить базу данных.
m.close # Закрыть соединение.
В последних версиях методы
create_db
и
drop_db
объявлены устаревшими. Но можно «воскресить» их, определив следующим образом:
class Mysql
def create_db(db)
query("CREATE DATABASE #{db}")
end
def drop_db(db)
query("DROP DATABASE #{db}")
end
end
Метод
list_dbs
возвращает список имен доступных баз данных в виде массива.
dbs = m.list_dbs # ["people","places","things"]
Метод
query
принимает строковый параметр и по умолчанию возвращает объект
MysqlRes
. В зависимости от заданного значения свойства
query_with_result
может также возвращаться объект
Mysql
.
Если произошла ошибка, то ее номер можно получить, обратившись к методу
errno
. Метод
error
возвращает текст сообщения об ошибке.
begin
r=m.query("create table rtable
(
id int not null auto_increment,
name varchar(35) not null,
desc varchar(128) not null,
unique id(id)
)")
# Произошло исключение...
rescue
puts m.error
# Печатается: You have an error in your SQL syntax
# near 'desc varchar(128) not null ,
# unique id(id)
# )' at line 5"
puts m.errno
# Печатается 1064
# ('desc' is reserved for descending order)
end
Ниже перечислено несколько полезных методов экземпляра, определенных в классе
MysqlRes
:
•
fetch_fields
возвращает массив объектов
MysqlField
, соответствующих полям в следующей строке;
•
fetch_row
возвращает массив значений полей в следующей строке;
•
fetch_hash(with_table=false)
возвращает хэш, содержащий имена и значения полей в следующей строке;
•
num_rows
возвращает число строк в результирующем наборе;
•
each
— итератор, последовательно возвращающий массив значений полей;
•
each_hash(with_table=false)
— итератор, последовательно возвращающий хэш вида
{имя_поля => значение_поля}
(пользуйтесь нотацией
x['имя_поля']
для получения значения поля).
Вот некоторые методы экземпляра, определенные в классе
MysqlField
:
•
name
возвращает имя поля;
•
table
возвращает имя таблицы, которой принадлежит поле;
•
length
возвращает длину поля, заданную при определении таблицы;
•
max_length
возвращает длину самого длинного поля в результирующем
наборе;
•
hash
возвращает хэш с именами и значениями следующих элементов описания:
name
,
table
,
def
,
type
,
length
,
max_length
,
flags
,
decimals
.
Если изложенный здесь материал противоречит онлайновой документации, предпочтение следует отдать документации. Более подробную информацию вы найдете на официальном сайте MySQL и в архиве приложений Ruby.
10.4.3. Интерфейс с PostgreSQL
В архиве RAA есть также расширение, реализующее доступ к СУБД PostgreSQL (работает с версиями PostgreSQL 6.5/7.0).
В предположении, что PostgreSQL уже установлена и сконфигурирована (и в базе данных есть таблица
testdb
), нужно лишь выполнить те же шаги, что и для всех остальных интерфейсов Ruby с базами данных: загрузить модуль, установить соединение с базой данных и начать работу. Надо полагать, вам понадобится способ послать запрос, получить результаты и работать с транзакциями.
require 'postgres'
conn = PGconn.connect("", 5432, "", "", "testdb")
conn.exec("create table rtest ( number integer default 0 );")
conn.exec("insert into rtest values ( 99 )")
res = conn.query("select * from rtest")
# res id [["99"]]
В классе
PGconn
есть метод
connect
, который принимает обычные параметры для установления соединения: имя хоста, номер порта, имя базы данных, имя и пароль пользователя. Кроме того, третий и четвертый параметры — соответственно, флаги и параметры терминала. В приведенном примере мы установили соединение через сокет UNIX от имени привилегированного пользователя, поэтому не указывали ни имя пользователя, ни пароль, а имя хоста, флаги и параметры терминала оставили пустыми. Номер порта должен быть целым числом, а остальные параметры — строками. У метода
connect
есть синоним
new
.
Для работы с таблицами нужно уметь выполнять запросы. Для этого служат методы
PGconn#exec
и
PGconn#query
.
Метод
exec
посылает переданную ему строку — SQL-запрос — серверу PostgreSQL и получает ответ в виде объекта
PGresult
, если выполнение завершилось успешно. В противном случае он возбуждает исключение
PGError
.
Метод
query
также посылает свой строковый параметр в виде SQL-запроса. Но в случае успеха получает массив кортежей. В случае ошибки возвращается
nil
, а подробности можно получить, вызвав метод
error
.
Имеется специальный метод
insert_table
для вставки записи в указанную таблицу. Вопреки названию он не создает новую таблицу, а добавляет данные в существующую. Этот метод возвращает объект
PGconn
.
conn.insert_table("rtest",[[34]])
res = conn.query("select * from rtest")
res равно [["99"], ["34"]]
В этом примере в таблицу
rtest
вставляется одна строка. Для простоты мы указали только одну колонку. Отметим, что объект
res
класса
PGresult
после обновления возвращает массив из двух кортежей. Чуть ниже мы рассмотрим методы, определенные в классе