#
include
<
stdlib.
h>
#
include
<
stdio.
h>
#
include
"mysql.h"
MYSQL my_connection;
MYSQL_RES *
res_ptr;
MYSQL_ROW sqlrow;
void
display_row(
)
;
int
main(
int
argc,
char
*
argv[
]
)
{
int
res;
mysql_init(
&
my_connection)
;
if
(
mysql_real_connect(
&
my_connection,
"localhost"
,
"rick"
,
"secret"
,
"foo"
,
0,
NULL
,
0)
)
{
/* 设置数据库默认字符集 */
if
(
mysql_set_character_set(
&
my_connection,
"utf8"
)
)
{
fprintf
(
stderr
,
"错误, %s/n"
,
mysql_error(
&
my_connection)
)
;
}
res =
mysql_query(
&
my_connection,
"SELECT childno, fname, age FROM children WHERE age > 5"
)
;
if
(
res)
{
fprintf
(
stderr
,
"SELECT error: %s/n"
,
mysql_error(
&
my_connection)
)
;
}
else
{
res_ptr =
mysql_use_result(
&
my_connection)
;
if
(
res_ptr)
{
while
(
(
sqlrow =
mysql_fetch_row(
res_ptr)
)
)
{
display_row(
)
;
}
if
(
mysql_errno(
&
my_connection)
)
{
fprintf
(
stderr
,
"Retrive error: %s/n"
,
mysql_error(
&
my_connection)
)
;
}
mysql_free_result(
res_ptr)
;
}
}
mysql_close(
&
my_connection)
;
}
else
{
fprintf
(
stderr
,
"Connection failed/n"
)
;
if
(
mysql_errno(
&
my_connection)
)
{
fprintf
(
stderr
,
"Connection error %d: %s/n"
,
mysql_errno(
&
my_connection)
,
mysql_error(
&
my_connection)
)
;
}
}
return
EXIT_SUCCESS
;
}
void
display_row(
)
{
unsigned
int
field_count;
field_count =
0;
while
(
field_count <
mysql_field_count(
&
my_connection)
)
{
if
(
sqlrow[
field_count]
)
printf
(
"%s "
,
sqlrow[
field_count]
)
;
else
printf
(
"NULL"
)
;
field_count+
+
;
}
printf
(
"/n"
)
;
}
|