12.1. Установление соединения и выполнение запроса.

Прежде чем выполнить запрос к базе данных, для начала необходимо установить с ней соединение. Как правило, установление соединения с базой данных выполняется в виде отдельной функции, которую приложение вызывает на запуске, например:

bool createConnection() { QSqlDatabase *db = QSqlDatabase::addDatabase("QOCI8"); db->setHostName("mozart.konkordia.edu"); db->setDatabaseName("musicdb"); db->setUserName("gbatstone"); db->setPassword("T17aV44"); if (!db->open()) { db->lastError().showMessage(); return false; } return true; } Первым делом, вызовом QSqlDatabase::addDatabase(), создается экземпляр класса QSqlDatabase. Аргумент функции определяет драйвер базы данных, используемый для доступа к ней. В данном случае -- это драйвер Oracle. Коммерческая версия Qt включает в себя следующий набор драйверов: QODBC3 (ODBC), QOCI8 (Oracle), QTDS7 (Sybase Adaptive Server), QPSQL7 (PostgreSQL), QMYSQL3 (MySQL), and QDB2 (IBM DB2). В некоммерческие версии Qt входит только часть этого набора. [1]

Затем указывается сетевое имя сервера баз данных, имя базы данных, имя пользователя и пароль, после чего выполняется попытка установить соединение. Если функция open() завершилась неудачей -- выводится сообщение об ошибке, с помощью QSqlError::showMessage().

Обычно функция, подобная createConnection() вызывается из функции main():

int main(int argc, char *argv[]) { QApplication app(argc, argv); if (!createConnection()) return 1; ... return app.exec(); } После установления соединения, посредством QSqlQuery, можно выполнять SQL-запросы к базе данных. Например, следующий код выполняет SQL-предложение -- SELECT: QSqlQuery query; query.exec("SELECT title, year FROM cd WHERE year >= 1998"); После вызова функции exec(), можно просматривать полученный набор данных: while (query.next()) { QString title = query.value(0).toString(); int year = query.value(1).toInt(); cerr << title.ascii() << ": " << year << endl; } Первый вызов next() позиционирует QSqlQuery на первую запись в наборе данных. Последующие вызовы next() передвигают указатель на следующую запись и так до тех пор, пока не будет достигнут конец набора. В этой точке next() вернет false.

Функция value() возвращает значение поля в виде QVariant. Поля нумеруются, начиная с 0, в порядке их следования в предложении SELECT. Класс QVariant может хранить огромное количество типов языка C++ и Qt, в том числе int и QString. Различные типы данных, которые могут храниться в базе данных переводятся в соответствующие типы C++ и Qt, и сохраняются в виде QVariant. Например, VARCHAR представляется в виде QString, а DATETIME -- как QDateTime.

Класс QSqlQuery предоставляет целый набор функций для навигации по набору данных: first(), last(), prev(), seek() и at(). Они очень удобны в использовании, но на некоторых базах данных могут оказаться довольно медлительными и ресурсоемкими. С целью оптимизациии, при работе с большими наборами данных, можно вызвать QSqlQuery::setForwardOnly(true), перед exec(), а затем выполнять просмотр набора данных с помощью next(), правда в этом случае мы получаем, так называемые, однонаправленные наборы данных, т.е. такие наборы, навигация по которым может осуществляться только вперед, с помощью next().

Чуть выше говорилось о том, что SQL-запрос передается как аргумент функции exec(), но текст запроса может передаваться напрямую, конструктору QSqlQuery:

QSqlQuery query("SELECT title, year FROM cd WHERE year >= 1998"); Проверка на наличие ошибок и выдача сообщения могут быть выполнены таким образом: if (!query.isActive()) query.lastError().showMessage(); Выполнение предложения INSERT ничуть не сложнее, чем SELECT: QSqlQuery query("INSERT INTO cd (id, artistid, title, year) " "VALUES (203, 102, 'Living in America', 2002)"); После выполнения такого запроса, QSqlQuery::numRowsAffected() возвращает количество записей, подвергшихся изменению (или -1, если база данных не предусматривает поставку такой информации).

В случае необходимости вставить в запрос значения переменных или когда нежелательно, или невозможно перевести аргументы предложения INSERT в строковый вид, можно построить параметризованный запрос, с помощью функции prepare(). Текст параметризованного запроса, вместо реальных значений содержит параметры, которые заполняются фактическими значениями после создания запроса. Qt поддерживает Oracle-подобный и ODBC-подобный стили именования параметров для всех типов баз данных. В примере ниже показано использование Oracle-подобного стиля именования:

QSqlQuery query(db); query.prepare("INSERT INTO cd (id, artistid, title, year) " "VALUES (:id, :artistid, :title, :year)"); query.bindValue(":id", 203); query.bindValue(":artistid", 102); query.bindValue(":title", QString("Living in America")); query.bindValue(":year", 2002); query.exec(); Теперь тот же самый пример, но в стиле ODBC: QSqlQuery query(db); query.prepare("INSERT INTO cd (id, artistid, title, year) " "VALUES (?, ?, ?, ?)"); query.addBindValue(203); query.addBindValue(102); query.addBindValue(QString("Living in America")); query.addBindValue(2002); query.exec(); После создания запроса, вызовом prepare(), параметры запроса заполняются фактическими значениями, с помощью функции bindValue() или addBindValue(), после чего запрос исполняется вызовом exec(). Параметризованные запросы можно выполнять в цикле. Перед началом цикла создается запрос, а в теле цикла производится заполнение параметров новыми значениями и исполнение запроса.

Параметризованные запросы очень часто используются в тех случаях, когда в базу данных нужно записать двоичные данные или строки, которые содержат символы из наборов, не принадлежащих диапазону ASCII или Latin-1. Для баз данных, которые поддерживают Unicode, Qt использует эту кодировку символов, в других случаях выполняется преобразование строк в соответствующую кодировку.

Qt поддерживает механизм транзакций для баз данных, в которых он присутствует. Для запуска транзакции вызывается метод объекта QSqlDatabase -- transaction(). Для завершения транзакции вызывается либо функция commit(), либо rollback(). Например, выполним поиск по внешнему ключу и вставим запись в таблицу в рамках транзакции:

QSqlDatabase::database()->transaction(); QSqlQuery query; query.exec("SELECT id FROM artist WHERE name = 'Gluecifer'"); if (query.next()) { int artistId = query.value(0).toInt(); query.exec("INSERT INTO cd (id, artistid, title, year) " "VALUES (201, " + QString::number(artistId) + ", 'Riding the Tiger', 1997)"); } QSqlDatabase::database()->commit(); Функция QSqlDatabase::database() возвращает указатель на объект QSqlDatabase, который был создан в createConnection(). Если транзакция не может быть запущена, QSqlDatabase::transaction() возвращает false.

Некоторые базы данных не поддерживают механизм транзакций. В этом случае, функции transaction(), commit() и rollback() не выполняют никаких действий. Наличие поддержки механизма транзакций, той или иной базой данных, можно проверить с помощью метода hasFeature(), объекта QSqlDriver, ассоциированного с базой данных:

QSqlDriver *driver = QSqlDatabase::database()->driver(); if (driver->hasFeature(QSqlDriver::Transactions)) ... В примерах выше рассматривались случаи с единственным подключением к базе данных. Однако ничто не мешает нам создать и второе, и третье и т.д. соединения. В этом случае необходимо просто передать имя соединения, вторым аргументом в функцию addDatabase(): QSqlDatabase *db = QSqlDatabase::addDatabase("QPSQL7", "OTHER"); db->setHostName("saturn.mcmanamy.edu"); db->setDatabaseName("starsdb"); db->setUserName("gilbert"); db->setPassword("ixtapa6"); Чтобы потом получить указатель на объект QSqlDatabase, достаточно просто передать имя соединения в функцию QSqlDatabase::database(): QSqlDatabase *db = QSqlDatabase::database("OTHER"); Для исполнения запросов через эти соединения, необходимо передать объект QSqlDatabase конструктору QSqlQuery: QSqlQuery query(db); query.exec("SELECT id FROM artist WHERE name = 'Mando Diao'"); Каждое соединение с базой данных может поддерживать только одну активную транзакцию, поэтому множественные подключения могут оказаться полезными в том случае, когда необходимо одновременно запустить несколько транзакций. При использовании нескольких соединений, в приложении по прежнему имеется одно неименованное соединение, которое используется по-умолчанию объектами QSqlQuery, если им явно не указать с каким соединением они должны работать.

В дополнение к QSqlQuery, Qt предоставляет класс QSqlCursor, производный от QSqlQuery. Этот класс расширяет функциональность предка большим числом дополнительных методов, которые позволяют отказаться от написания SQL-запросов для наиболее употребимых SQL-операций, таких как: SELECT, INSERT, UPDATE и DELETE. Кроме того QSqlCursor выступает в роли посредника между QDataTable и базой данных. Далее, в этом разделе мы будем говорить о QSqlCursor, а в следующем разделе покажем, как можно использовать QDataTable, для представления наборов данных в табличной форме.

Следующий пример демонстрирует выполнение SQL-запроса -- SELECT:

QSqlCursor cursor("cd"); cursor.select("year >= 1998"); Эквивалентный вариант с использованием QSqlQuery: QSqlQuery query("SELECT id, artistid, title, year FROM cd " "WHERE year >= 1998"); Навигация по набору данных выполняется точно так же, как и в QSqlQuery, за одним маленьким исключением -- теперь, вместо порядкового номера поля, функции value() можно передать его имя: while (cursor.next()) { QString title = cursor.value("title").toString(); int year = cursor.value("year").toInt(); cerr << title.ascii() << ": " << year << endl; } Для вставки записи в таблицу, предварительно нужно создать новую запись QSqlRecord, вызовом primeInsert(), а затем, для каждого из полей, вызвать setValue(). После всего этого можно выполнить вставку функцией insert(): QSqlCursor cursor("cd"); QSqlRecord *buffer = cursor.primeInsert(); buffer->setValue("id", 113); buffer->setValue("artistid", 224); buffer->setValue("title", "Shanghai My Heart"); buffer->setValue("year", 2003); cursor.insert(); Чтобы изменить запись -- нужно позиционировать QSqlCursor на запись, которая должна подвергнуться изменениям (например, с помощью select() и next()). Получить указатель на QSqlRecord, вызовом primeUpdate(). После этого записать новые значения функцией setValue() и вызвать update(), чтобы отправить сделанные изменения в базу данных: QSqlCursor cursor("cd"); cursor.select("id = 125"); if (cursor.next()) { QSqlRecord *buffer = cursor.primeUpdate(); buffer->setValue("title", "Melody A.M."); buffer->setValue("year", buffer->value("year").toInt() + 1); cursor.update(); } Процедура удаления записи похожа на процедуру изменения: QSqlCursor cursor("cd"); cursor.select("id = 128"); if (cursor.next()) { cursor.primeDelete(); cursor.del(); } Классы QSqlQuery и QSqlCursor реализуют интерфейс между Qt и базами данных SQL. В следующих двух разделах мы покажем как они могут использоваться в приложениях с графическим интерфейсом, которые позволяют пользователю просматривать и изменять наборы данных, хранящиеся в базе.