在MySQL数据库中使用C执行SQL语句
2009-08-14 17:30
561 查看
作者:IBM
来源:IBM
与PostgreSQL相似,可使用许多不同的语言来访问MySQL,包括C、C++、Java和Perl。从下列章节中,NeilMatthew和Richard Stones使用详尽的MySQL
C接口向我们介绍了如何在MySQL数据库中执行SQL语句。他们将讨论返回数据的语句,例如INSERT以及不返回数据的语句,例如UPDATE和
DELETE。然后,他们将编写从数据库检索数据的简单程序。
执行SQL语句
现在,我们已经有了一个连接,并且知道如何处理错误,是时候讨论使用我们的数据库来作一些实际工作了。执行所有类型的SQL的主关键字是mysql_query:
int mysql_query(MYSQL *connection, const char *query) [/code] |
和包含要执行的SQL的文本字符串;与命令行工具不同,将不使用结束分号。成功之后,返回0。在需要包含二进制数据的特殊情况下,可以使用相关的函
数,mysql_real_query。虽然出于本章的目的,我们仅需要讨论mysql_query。
不返回数据的SQL语句
我们将先讨论UPDATE、DELETE和INSERT语句。因为它们不返回数据,所以更易于使用。
这里我们将介绍的另一个重要函数是检查受影响的行数的函数:
my_ulonglong mysql_affected_rows(MYSQL *connection); [/code] |
回结果。由于可移植性原因,这是一个特殊的无符号类型。为了在printf中使用,建议将其强制转换成使用%lu格式规范的无符号长整数。这个函数返回受
以前的UPDATE、INSERT或DELETE查询影响的行数,这些查询是使用 mysql_query执行的。
通常对于mysql_函数,返回码0表示没有行受影响;正数表示实际结果,通常是受影响的行数。
如前所述,当使用mysql_affected_rows时可能出现未期望的结果。让我们先讨论受INSERT语句影响的行数,它将按预期进行操作。将下列代码添加到程序 connect2.c 中,并且称其为insert1.c:
#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", "bar", "rick", 0, NULL, 0)) { printf("Connection successn"); res = mysql_query(&my_connection, "INSERT INTO children(fname,age), VALUES('Ann',3)"); if (!res) { printf("Inserted %lu rowsn", (unsigned long)mysql_affected_rows(&my_connection)); } else { fprintf(stderr, "Insert error %d: sn",mysql_errno , (&my_connection), mysql_error(&my_connection)); } mysql_close(&my_connection); } else { fprintf(stderr, "Connection failedn"); if (mysql_errno(&my_connection)) { fprintf(stderr, "Connection error %d: %sn", mysql_errno(&my_connection), mysql_error(&my_connection)); } } return EXIT_SUCCESS; } [/code] |
现在,我们更改代码,所以 '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 rowsn", (unsigned long)mysql_affected_rows(&my_connection)); } else { fprintf(stderr, "Update error %d: %sn", mysql_errno(&my_connection), mysql_error(&my_connection)); } [/code] |
childno | fname | age |
1 2 3 4 5 6 7 8 9 10 11 | Jenny Andrew Gavin Duncan Emma Alex Adrian Ann Ann Ann Ann | 14 10 4 2 0 11 5 3 4 3 4 |
mysql_affected_rows报告的结果为4这可能是熟悉其它数据库的人所期望的),则需要记住将CLIENT_FOUND_ROWS标志传递
到mysql_real_connect,在 update2.c中的程序如下:
if (mysql_real_connect(&my_connection, "localhost", "rick", "bar", "rick", 0, NULL, CLIENT_FOUND_ROWS)) { [/code] |
函数 mysql_affected_rows还有最后一个奇怪之处,它发生在从数据库中删除数据时。如果使用WHERE子句,则
mysql_affected_rows将按预期返回删除行数。但是,如果没有WHERE子句,则删除所有行,报告受影响的行数却为0。这是因为由于效率
原因优化删除整个表。这种行为不受CLIENT_FOUND_ROWS选项标志的影响。
返回数据的语句
现在是时候讨论SQL的最普遍用法了,从数据库检索数据的SELECT语句。
MySQL 还支持返回结果的SHOW、DESCRIBE和EXPLAIN SQL语句,但是这里不考虑它们。按惯例,手册中包含这些语句的说明。
您将会从PostgreSQL章记起,可以从PQexec中的SQL SELECT 语句检索数据,这里马上获取所有数据,或者使用游标从数据库中逐行检索数据,以便搞定大数据。
由于完全相同的原因,MySQL的检索方法几乎完全相同,虽然它实际上不用游标的形式描述逐行检索。但是,它提供了缩小这两种方法间差异的API,如果需要,它通常使两种方法的互换更加容易。
通常,从MySQL数据库中检索数据有4个阶段:
发出查询
检索数据
处理数据
执行所需的任何整理
象
以前一样,我们使用mysql_query发出查询。数据检索是使用mysql_store_result或mysql_use_result完成的,这
取决于想如何检索数据,随后使用mysql_fetch_row调用序列来处理数据。最后,必须调用mysql_free_result以允许
MySQL执行任何所需的整理。
全部立即数据检索的函数
可以从SELECT语句(或其他返回数据的语句)中检索完所有数据,在单一调用中,使用mysql_store_result:
MYSQL_RES *mysql_store_result(MYSQL *connection); [/code] |
使用等价的PostgreSQL时,应该知道返回NULL意味着已经发生了错误,并且这与未检索到数据的情况不同。即使,返回值不是NULL,也不意味着当前有数据要处理。
如果未返回NULL,则可以调用mysql_num_rows并且检索实际返回的行数,它当然可能是0。
my_ulonglong mysql_num_rows(MYSQL_RES *result); [/code] |
这 种mysql_store_result和mysql_num_rows的组合是检索数据的一种简便并且直接的方法。一旦
mysql_store_result成功返回,则所有查询数据都已经存储在客户机上并且我们知道可以从结果结构中检索它,而不用担心会发生数据库或网络
错误,因为对于程序所有数据都是本地的。还可以立即发现返回的行数,它可以使编码更简便。如前所述,它将所有结果立即地发送回客户机。对于大结果集,它可
能耗费大量的服务器、网络和客户机资源。由于这些原因,使用更大的数据集时,最好仅检索需要的数据。不久,我们将讨论如何使用
mysql_use_result函数来完成该操作。
一旦检索了数据,则可以使用mysql_fetch_row来检索它,并且使用mysql_data_seek、mysql_row_seek、mysql_row_tell操作结果集。在开始检索数据阶段之前,让我们先讨论一下这些函数。
MYSQL_ROW mysql_fetch_row(MYSQL_RES *result); [/code] |
void mysql_data_seek(MYSQL_RES *result, my_ulonglong offset); [/code] |
MYSQL_ROW_OFFEST mysql_row_tell(MYSQL_RES *result); [/code] |
MYSQL_ROW_OFFSET mysql_row_seek(MYSQL_RES *result, MYSQL_ROW_OFFSET offset); [/code] |
有时,这一对函数对于在结果集中的已知点之间跳转很有用。请注意,不要将row tell和row seek使用的偏移值与data_seek使用的行号混淆。这些是不可交换的,结果将是您所希望看到的。
void mysql_free_result(MYSQL_RES *result); [/code] |
检索数据
现在开始编写从数据库中检索数据的第一个程序。我们将选择所有年龄大于5的行的内容。不幸的是我们还不知道如何处理这个数据,所以我们能做的只有循环检索它。这便是 select1.c:
#include #include #include "mysql.h" MYSQL my_connection; MYSQL_RES *res_ptr; MYSQL_ROW sqlrow; int main(int argc, char *argv[]) { int res; mysql_init(&my_connection); if (mysql_real_connect(&my_connection, "localhost", "rick", "bar", "rick", 0, NULL, 0)) { printf("Connection successn"); res = mysql_query(&my_connection, "SELECT childno, fname, age FROM children WHERE age > 5"); if (res) { printf("SELECT error: %sn", mysql_error(&my_connection)); } else { res_ptr = mysql_store_result(&my_connection); if (res_ptr) { printf("Retrieved %luowsn",(unsignedlong)mysql_num_rows(res_ptr)); while ((sqlrow = mysql_fetch_row(res_ptr))) { printf("Fetched data...n"); } if (mysql_errno(&my_connection)) { fprintf(stderr, "Retrive error: sn",mysql_error(&my_connection)); } } mysql_free_result(res_ptr); } mysql_close(&my_connection); } else { fprintf(stderr, "Connection failedn"); if (mysql_errno(&my_connection)) { fprintf(stderr, "Connection error %d: %sn", mysql_errno(&my_connection),mysql_error(&my_connection)); } } return EXIT_SUCCESS; } [/code] |
一次检索一行数据
要按需要逐行检索数据,而不是立即获取全部数据并将它存储在客户机中,可以将mysql_store_result调用替换成 mysql_use_result:
MYSQL_RES *mysql_use_result(MYSQL *connection); [/code] |
相关文章推荐
- 在mysql数据库执行sql语句时使用正则表达式
- 在MySQL数据库中使用C执行SQL语句
- 在MySQL数据库中使用C执行SQL语句的方法
- 使用C#对MySQL数据库执行存在中文的SQL语句,不返回值的问题
- 在MySQL数据库中使用C执行SQL语句的方法
- 在MySQL数据库中使用C执行SQL语句
- [引]SQL帮助文档:使用 WAITFOR 使SQL语句停顿后执行
- MySQL数据库中SQL语句的基本使用(一)
- 【二十四】使用mysqli扩展类批量执行多条sql语句
- 使用hibernate执行sql语句
- 使用Oracle的DBMS_SQL包执行动态SQL语句
- 使用DbVisualizer划线执行SQL语句的时候提示Selection executes are onlyallowed in DbVisualizer Personel edition
- 使用 Navicat for MySQL 执行 SQL 语句时,出现 out of memory 问题的解决方法
- MySQL数据库中,如何记录SQL执行语句
- 使用C语言访问MySQL数据 —— 执行SQL语句(3)
- 使用EXPLAIN PLAN 获取SQL语句执行计划
- 使用BAT批处理执行sql语句的代码
- 使用 EXPLAIN PLAN 获取SQL语句执行计划
- 使用@@,select case及Exec动态执行SQL语句
- SQLCMD的用法,使用CMD 执行sql语句