Нейл Мэтью - Основы программирования в Linux

int mysql_query(MYSQL *connection, const char *query);

He слишком сложная? Эта подпрограмма принимает указатель на дескриптор подключения и несколько, хочется надеяться, корректных SQL-операторов в виде текстовой строки (без завершения каждого из них точкой с запятой, как в мониторе mysql). В случае удачного завершения возвращается ноль. Вторую подпрограмму mysql_real_queryможно применять при запросе двоичных данных, но в этой главе мы используем только подпрограмму mysql_query.

Для простоты начнем с рассмотрения нескольких SQL-операторов, которые не возвращают данные: UPDATE, DELETEи INSERT.

Еще одна важная функция, которую мы рассмотрим, проверяет количество строк, затронутых запросом:

my_ulonglong mysql_affected_rows(MYSQL *connection);

Первое, что вы, вероятно, заметили в этой функции, — очень необычный тип возвращаемых данных. Из соображений переносимости применяется беззнаковый (unsigned) тип. Когда используется функция printf, рекомендуется приводить его к типу unsigned long(длинное беззнаковое) со спецификатором формата %lu. Эта функция возвращает количество строк, измененных предварительно выполненным запросом UPDATE, INSERTили DELETE. Возвращаемое значение, используемое в MySQL, может вас, озадачить, если у вас есть опыт работы с другими базами данных SQL. СУРБД MySQL возвращает количество строк, действительно измененных обновлением, в то время как многие другие СУБД будут считать запись измененной просто потому, что она соответствует одному из условий WHERE.

В основном в случае функций mysql_возврат 0 означает отсутствие измененных строк, а положительное значение указывает на реальный результат, обычно количество строк, затронутых оператором.

Сначала следует создать таблицу childrenв вашей базе данных foo, если вы еще не сделали этого. Удалите (с помощью команды drop) любую существующую таблицу, чтобы быть уверенным в том, что вы имеете дело с чистым определением таблицы, и повторно отправьте идентификаторы, применяемые в столбце AUTO_INCREMENT.

$ mysql -u rick -p foo

Enter password:

Welcome to the MySQL monitor. Commands end with ; or \g.

mysql> DROP TABLE children;

Query OK, 0 rows affected (0.58 sec)

mysql> CREATE TABLE children (

-> childno int(11) AUTO_INCREMENT NOT NULL PRIMARY KEY,

-> fname varchar(30),

-> age int

-> );

Query OK, 0 rows affected (0.09 sec)

mysql>

Теперь добавьте программный код в файл connect2.c, для того чтобы вставить новую строку в вашу таблицу. Назовите эту новую программу insert1.с. Учтите, что разбиение оператора на несколько строк объясняется физической шириной страницы; обычно вы не должны разбивать реальный SQL-оператор, если он не слишком длинный, в этом случае можно применить символ /в конце строки для переноса оставшейся части SQL-оператора на следующую строку.

#include

#include

#include "mysql.h"

int main(int argc, char *argv[]) {

MYSQL my_connection;

int res;

mysql_init(&my_connection);

if (mysql_real_connect(&my_connection, "localhost",

"rick", "secret", "foo", 0, NULL, 0)) {

printf("Connection success\n");

res = mysql_query(&my_connection,

"INSERT INTO children(fname, age) VALUES('Ann', 3)");

if (!res) {

printf("Inserted %lu rows\n",

(unsigned long)mysql_affected_rows(&my_connection));

} else {

fprintf(stderr, "Insert error %d: %s\n",

mysql_errno(&my_connection), &mysql_error(&my_connection));

}

mysql_close(&my_connection);

} else {

fprintf(stderr, "Connection failed\n");

if (mysql_errno(&my_connection)) {

printf(stderr, "Connection error %d: %s\n",

mysql_errno(&my_connection), mysql_error(&my_connection));

}

}

return EXIT_SUCCESS;

}

Как и ожидалось, одна строка добавлена.

Теперь измените код, чтобы включить UPDATEвместо INSERT, и посмотрите на сообщение об измененных строках.

mysql_errno(&my_connection), mysql_error(&my_connection));

}

}

res = mysql_query(&my_connection,

"UPDATE children SET AGE = 4 WHERE fname = 'Ann'");

if (!res) {

printf("Updated %lu rows\n",

(unsigned long)mysql_affected_rows(&my_connection));

} else {

fprintf (stderr, "Update error %d: %s\n",

mysql_errno(&my_connection), mysql_error(&my_connection));

}

Назовите эту программу update1.c. Она пытается задать возраст 4 года для всех детей с именем Ann.

Предположим, что ваша таблица childrenсодержит следующие данные:

mysql> SELECT * from CHILDREN;