Последняя статья по работе с MySQL из программы на С++
Для начала создадим базу банных
Код:
# create.sql
# Создаем базу данных
CREATE database lib;
# Переключаемся на нее
use lib;
# Добавляем пользователя admin с паролем admin и связываем его с базой library
GRANT ALL ON lib.* TO 'admin'@'%' IDENTIFIED BY 'admin';
# Создаем таблицу книги
CREATE TABLE IF NOT EXISTS t_books
(
ID INT(6) UNSIGNED NOT NULL AUTO_INCREMENT,
Title CHAR(150) NOT NULL,
FIO CHAR(150) NOT NULL,
PRIMARY KEY(ID),
KEY(Title)
);
Интерфейс формы у меня получился такой (рис.1).
Компоненты:
TLabel и TEdit . по 5 штук, как из предыдущей статьи
ListBox - 1 шт список книг
GroupBox - 1 шт. В нем 2 TLabel и 2 TEdit, название книги и автор
TButton - 5 шт. Их желательно обозвать как у меня (Удалить, Изменить, Добавить, Подключиться, Закрыть).
BitBtn - 1 шт кнопка обновление данных.
TTimer - 1 шт проверка содинения.
Все подробности на скрине.
Объявляем необходимые переменные и подключаем все что нужно...
Код:
#define __LCC__
#pragma comment(lib, "libmysql_.lib")
#include <mysql.h>
const int buf = 512; // Буфер
bool connected = false; // Есть соединение или нет
int *arrIDs = NULL; // Массив идентификаторов
int ID = 0; // Идентификатор текущей книги
MYSQL mysql; // Дескриптор соединения
MYSQL_RES *res; // Структура результатов
MYSQL_ROW row; // Массив строк результата
/* Объявляем массивы для работы */
char host[buf];
char user[buf];
char passwd[buf];
char db[buf];
int port = 0;
Настройки таймера по умолчанию: Выключен и интервал в 5 секунд.
Код обработчика таймера
Код:
if (mysql_ping(&mysql) > 0) // Если соединение разорвано...
{
connected = false; // ставим флаг дисконнекта
if (arrIDs) delete []arrIDs; // Очищаем массив
Timer1->Enabled = false; // ... выключаем таймер
MessageBox(this->Handle, "Соединение с сервером потеряно", "Ошибка!",
MB_OK | MB_ICONERROR); // Выведем сообщение лоб этом
Button5->Click(); // Запустим повторное соединение
}
Далее обработчики кнопок
Код кнопки "Подключиться"
Код:
// Подключение
if (connected) return; // Если уже соединены, то выходим.
/* Проверим, что все данные были введены */
if (hostText->Text.IsEmpty() || userText->Text.IsEmpty() ||
passText->Text.IsEmpty() || dbText->Text.IsEmpty() ||
portText->Text.IsEmpty())
{
MessageBox(this->Handle, "Не все поля заполнены!", "Ошибка!",
MB_OK | MB_ICONERROR);
return;
}
/* Инициализируем имя хоста, пользователя, пароль, порт и БД */
strcpy(host, hostText->Text.c_str());
strcpy(user, userText->Text.c_str());
strcpy(db, dbText->Text.c_str());
strcpy(passwd, passText->Text.c_str());
port = portText->Text.ToInt();
mysql_init(&mysql); // Инициализация
if (!mysql_real_connect(&mysql, host, user, passwd, db, port, NULL, 0))
{ /* Пробуем подключиться, если кде-то ошибка, то сообщим об этом */
MessageBox(this->Handle, mysql_error(&mysql), "Error!",
MB_OK | MB_ICONERROR);
return;
}
connected = true; // Соединены
Timer1->Enabled = true; // Порверка соединения каждые 5 сек.
BitBtn1->Click();
Код кнопки "Обновить" (BitBtn1)
Код:
// Обновление списка книг
if (!connected) return; // Если соединения нет, то выходим
/* Так как, мы знаем что нам нужно, то и запрос будет статическим.
Получим названия всех книг и идентификаторов, потом заполним ими ListBox
Сортируем в порядке возрастания по названию книги */
if (mysql_query(&mysql, "SELECT ID, Title FROM t_books ORDER BY Title") > 0)
{ // Проверка на ошибки
MessageBox(this->Handle, mysql_error(&mysql), "Ошибка!",
MB_OK | MB_ICONERROR);
return;
}
ListBox1->Clear(); // Очистка списка.
if (arrIDs) delete []arrIDs;
// Заполняем структуру
res = mysql_store_result(&mysql);
// Получаем количество записей
int count = mysql_num_rows(res);
arrIDs = new int[count];
for (int i = 0; i < count; i++)
{
// Полчаем строку
row = mysql_fetch_row(res);
// Заполняем массив
arrIDs[i] = StrToInt(row[0]);
// Добавляем в ListBox название книги
ListBox1->Items->Add(row[1]);
}
mysql_free_result(res); // Освобождаем ресурсы