mySQL-基础

mySQL-C语言接口

1. Mysql初始化

  MYSQL *mysql_init(MYSQL *mysql)用来分配或者初始化一个MYSQL对象，用于连接mysql服务端。Mysql：如果参数是NULL指针，它将自动为你分配一个MYSQL对象返回值：失败=NULL 成功=!NULL

2. Mysql建立连接函数

MYSQL *mysql_real_connect(MYSQL *mysql, //mysql结构地址 mysql_init()返回值char *host, //主机名或ip地址const char *user, //mysql用户名称 rootconst char *passwd, //登录用户的密码const char *db, //连接的数据库  unsigned int port, //连接端口号 3306  const char *unix_socket, //unix套接字  unsigned long client_flag) 功能: 与运行在主机上的MySQL数据库引擎建立连接

3. 执行SQL语句

int mysql_query(MYSQL *mysql, const char *sql_str)
功能：连接数据库成功之后就可以执行sql语句
参数：   Mysql:mysql_init()函数返回值Sql_str:执行SQL语句
返回值：成功=0 失败=-1

4. 获取结果集合

（1）获取结果集合MYSQL_RES *mysql_use_result(MYSQL *connection)功能：获取sql语句的结果参数：connection：连接好的数据库返回值：成功=返回指向结果集对象的指针 失败=NUL
（2）获取结果集合后，获取每条数据MYSQL_ROW mysql_fetch_row( MYSQL_RES *result)获取数据库表中的一条记录。参数：result:mysql_use_result()的返回值返回值：成功=一条记录  数据用完或发生错误时=NULL通过ret[n]访问一条记录中的字段。
注意：sql的返回的结果集都是字符串。

注意：在代码中使用数据库后要把数据库关闭，否则多次使用数据库会出错

makefile文件

all:gcc test.c -I/usr/include/mysql -L/usr/lib/mysql -lmysqlclient  -o exe

执行sql语句

#include <stdio.h>
#include <mysql/mysql.h>
int main()
{MYSQL *mysql;	mysql = mysql_init(NULL);if(mysql ==NULL){perror("mysql_init");return -1;}mysql=mysql_real_connect(mysql, "127.0.0.1","root","123456"，//mysql -uroot -p123456"student_db"，//usr student_db0,  //0表示默认NULL,0);if(mysql == NULL) {printf("mysql_read_connect error:%s\n",mysql_error(mysql));//mysql_error(mysql)输出错误信息goto ERR;}else{printf("connect database is successs.\n");}//sqlint ret;char sql_str[]="insert into info(name,tel,address) values(\"zhaoyun\", 110110110, \"shuguo\");";ret = mysql_query(mysql, sql_str);if(ret < 0){printf("mysql_query error:%s\n",mysql_error(mysql));goto ERR; }ERR:mysql_close(mysql);return 0;
}

执行sql语句，显示结果集合

#include <stdio.h>
#include <mysql/mysql.h>
int main()
{MYSQL *mysql; mysql= mysql_init(NULL);if(mysql==NULL){perror("mysql_init");return -1;}mysql = mysql_real_connect(mysql, "127.0.0.1","root","123456",//mysql -uroot -p123456"student_db",//usr student_db0,NULL,0);if(mysql == NULL){printf("mysql_read_connecterror:%s\n",mysql_error(mysql));goto ERR;}else{printf("connectdatabase is successs.\n");}//sqlint ret;char sql_str[]="select * from info;";ret = mysql_query(mysql, sql_str);if(ret < 0){printf("mysql_queryerror:%s\n",mysql_error(mysql));goto ERR;      }else{printf("mysql_queryis success.\n");}//MYSQL_RES *sql_results = mysql_use_result(mysql);if(sql_results==NULL){printf("mysql_use_rsult error:%s\n",mysql_error(mysql));goto ERR;}else{printf("mysql_use_rsult is success.\n");}MYSQL_ROW sql_row;while(sql_row = mysql_fetch_row( sql_results)){printf("id=%s:name=%s:tel=%s:age=%s:addr=%s\n",sql_row[0],sql_row[1],sql_row[2],sql_row[3],sql_row[4]);}
ERR:mysql_close(mysql);return 0;
}