文章目录
- 一.C语言访问mysql
- 1.连接数据库使用的头文件和库文件
- 2.初始化连接句柄
- 3.连接数据库
- 4.关闭连接
- 5.执行sql语句
- 6.提取结果
- 7.获取结果集中有多少行
- 8.取出结果集中的一行记录
- 9.查看记录行的列数
- 10.释放结果集占用的内存
- 11.获取错误信息
- 二.连接数据库
- 三.操作数据库
一.C语言访问mysql
1.连接数据库使用的头文件和库文件
#include <mysql/mysql.h>
有些也在 #include <mysql.h>
程序中使用了访问mysql的有关函数接口,需要在链接时指定库名: linux平台为 -lmysqlclient
2.初始化连接句柄
MYSQL *mysql_init(MYSQL *mysql);
该方法用来初始化一个连接句柄,如果参数为空,则返回一个指向新分配的连接句柄的指针。如果传递一个已有的结构,它将被重新初始化。出错时返回为NULL。
3.连接数据库
MYSQL *mysql_real_connect(MYSQL *mysql,
const char *host,const char *user, const char *passwd,const char *db,
unsigned int port,const char *unix_socket,unsigned long clientflag);
参数介绍,其中
mysql是上一步mysql_init方法初始化后返回的指针,
host是主机名,或者连接的服务器IP地址,本地可以使用"localhost",或"127.0.0.1"或"",或
NULL
user是用户名,数据库中添加的用户,管理员是"root",
passwd 是用户的密码,
db 是数据库的名字,
port 是数据库的端口 3306,也可直接写0,意味着使用mysql默认端口,
unix_socket 一般为NULL,表示不使用unix套接字或者管道
clientflag 标志位,一般给0
返回值,失败为NULL,成功与第一个参数值相同。
4.关闭连接
void mysql_close(MYSQL *mysql);
在不使用时,可以用该方法关闭连接。
5.执行sql语句
int mysql_query(MYSQL *mysql, const char *q);
参数: mysql 是之前连接后返回的指针,
q 是要执行的sql语句,末尾可以没有分号,这个在命令工具中使用不同。
返回值:成功返回0。
注意:如果sql语句中有二进制数据,则应该使用mysql_real_query()
6.提取结果
MYSQL_RES *mysql_store_result(MYSQL *mysql); 一次性提取所有数据
//MYSQL_RES *mysql_use_result(MYSQL *mysql);一次提取一行数据
该方法,是在执行 mysql_query()成功之后调用的,可以立刻保存在客户端中收到的所有数据。它返回一个
指向结果集结构的指针。如果失败返回NULL;
7.获取结果集中有多少行
uint64_t mysql_num_rows(MYSQL_RES *res);
只有执行了 mysql_store_result()之后,才可以调用该方法,获取结果集中的行数。如果没有返回行,则
为0;
8.取出结果集中的一行记录
MYSQL_ROW mysql_fetch_row(MYSQL_RES *result);
从结果集中取出一行,并把它存放到一个行结构中。当数据用完或者出错时,返回为NULL,通常该方法需要循
环调用。
9.查看记录行的列数
unsigned int mysql_field_count(MYSQL *mysql);
10.释放结果集占用的内存
void mysql_free_result(MYSQL_RES *result);
执行完sql语句,得到返回的结果集,处理完数据后,需要调用该方法释放存放结果集的内存空间。
11.获取错误信息
unsigned int mysql_errno(MYSQL *mysql); 返回错误码
const char *mysql_error(MYSQL *mysql); 返回错误信息描述
二.连接数据库
#include<stdio.h>
#include<mysql/mysql.h>
void func()
{
MYSQL connect;//mysql连接对象
mysql_init(&connect);
//连接mysql
if(mysql_real_connect(&connect,"localhost","root","123456","c220",0,NULL,0))
{
printf("连接数据库成功\n");
}
else
{
printf("error:%s\n",mysql_error(&connect));
printf("连接失败\n");
}
//关闭连接
mysql_close(&connect);
}
int main()
{
func();
}
三.操作数据库
#include<stdio.h>
#include<mysql/mysql.h>
int main()
{
MYSQL c;
MYSQL *mysql=mysql_init(&c);
if(mysql_init(&c)==NULL)
{
printf("mysql_init error\n");
}
if(mysql_real_connect(&c,"localhost","root","123456","c220",0,NULL,0))
{
printf("connect success!\n");
}
else
{
printf("error:%s\n",mysql_error(&c));
printf("connect fail!\n");
}
//char * sql="insert into student values(5,'孙权',18)";
//char *sql="update student set age=25 where id=3";
//char * sql="delete from student where id=5";
char *sql="select * from student";
int query_res=mysql_query(&c,sql);
if(query_res!=0)
{
printf("query error:%s\n",mysql_error(&c));
return 0;
}
MYSQL_RES * mysql_res=mysql_store_result(mysql);//获取结果集,动态分配空间
if(mysql_res==NULL)
{
printf("error:%s\n",mysql_error(&c));
printf("mysql store result error\n");
mysql_close(&c);
return 0;
}
int row=mysql_num_rows(mysql_res);//获取结果有多少行
printf("row:%d\n",row);
int col=mysql_field_count(mysql);//获取结果有多少列
printf("col:%d\n",col);
for(int i=0;i<row;i++)//提取行记录
{
MYSQL_ROW r=mysql_fetch_row(mysql_res);
for(int j=0;j<col;j++)//提取列记录
{
printf("%s ",r[j]);
}
printf("\n");
}
mysql_free_result(mysql_res);//释放结果集占用的空间
mysql_close(&c);
exit(0);
}
以下是每次操作后的截图