竞博体育 > 应用 > 不得不建设布局MYSQL实例,在前后相继中须求加载MySQL驱动头文件

不得不建设布局MYSQL实例,在前后相继中须求加载MySQL驱动头文件

MySQL学习笔记_11_Linux下C++/C连接MySQL数据库(一)



linux程序设计——使用C语言访问MySQL(第八章)

先看结构体

Linux 下 C++/C 连接 MySQL 数据库(一)

 

8.3 使用C语言访问MySQL数据

Windows本地程序(如Access)可以通过ODBC驱动程序来访问MySQL,甚至有针对linuxODBC驱动程序。
下面讨论使用C语言来访问MySQL.

----------------------------------------------

一、连接前准备

原材料:Ubuntu12.04LTS

竞博体育app下载 ,(已经安装了MySQL5.5或者更高级版本,新立得软件包,gcc/g++或者CodeBlosks编译器)

安装了以上的软件包后,我们可以正常使用MySQL完成数据管理工作,但是很多时候我们需要通过编写程序访问MySQL。此时,在程序中需要加载MySQL驱动头文件,但是默认这些驱动包是没有安装的,因此我们需要在新立得中找到"libmysqld-dev"包并安装。

安装完成之后,在”/usr/include/mysql/”目录下会有很多相对应的头文件,如mysql.h等。

当写好程序,需要编译时:

1、如果选用的是使用gcc/g++在命令行下完成,则需要加上-lmysqlclient选项。如:

 

[plain] view plaincopyprint?竞博体育app下载 1竞博体育app下载 2

  • g++ -lmysqlclient mysql_test.cc -o mysqltest

    g++ -lmysqlclient mysql_test.cc -o mysqltest
    

    2、如果选用的是CodeBlocks,则需在构建选项中,将连接库设为mysqlclient。

    开始编译。

     

     

    二、头文件及相关函数分析

    这篇博客中所列的函数全部包含在头文件下,因此,需要在程序编写开始处,加入一行:

    [cpp] view plaincopyprint?竞博体育app下载 3竞博体育app下载 4

    1. #include

      #include 
      

       

      1、用CAPI连接MySQL数据库有两个步骤:

      1)初始化一个连接句柄

      2)建立连接

      所用到的函数如下:

       

      [cpp] view plaincopyprint?竞博体育app下载 5竞博体育app下载 6

      1. MYSQL *mysql_init(MYSQL *connection); // 初始化连接句柄 //成功返回MySQL结构指针,失败返回NULL
      2. MYSQL *mysql_real_connect(MYSQL *connection,
      3. const char *server_host, const char *sql_user_name,
      4. const char *sql_password, const char *db_name,
      5. unsigned int port_number, const char *unix_socket_name,
      6. unsigned int flags); //建立连接 //成功返回MySQL结构指针,失败返回NULL

        MYSQL *mysql_init(MYSQL *connection);    // 初始化连接句柄
        //成功返回MySQL结构指针,失败返回NULL
        
        MYSQL *mysql_real_connect(MYSQL *connection,   
                                  const char *server_host,                          
                                  const char *sql_user_name,  
                                  const char *sql_password,   
                                  const char *db_name,   
                                  unsigned int port_number,   
                                  const char *unix_socket_name,   
                                  unsigned int flags);  //建立连接
        //成功返回MySQL结构指针,失败返回NULL
        

         

        2、MySQL连接工作完成之后,需要对MySQL的连接进行释放

        [cpp] view plaincopyprint?竞博体育app下载 7竞博体育app下载 8

        1. void mysql_close(MYSQL *connection); //关闭连接 //参数connection被清空,指针变为无效

          void mysql_close(MYSQL *connection); //关闭连接
          //参数connection被清空,指针变为无效
          
            3、mysql_options用于设置额外选项,并影响连接行为,但是它只能在mysql_init和mysql_real_connect之间调用

            **[cpp]** view
            plaincopyprint?![](http://www.bkjia.com/uploads/allimg/150512/041Q53c4-0.png)![](http://www.2cto.com/uploadfile/Collfiles/20150509/20150509095700126.svg)

            1.  int mysql_options(MYSQL *connection, enum
                mysql_option option, const char *argument);
                //设置连接选项

                    int mysql_options(MYSQL *connection, enum mysql_option option, const char *argument);     //设置连接选项  



                option的值为下列四个值之一:

                 

                **[plain]** view
                plaincopyprint?![](http://www.bkjia.com/uploads/allimg/150512/041Q53c4-0.png)![](http://www.2cto.com/uploadfile/Collfiles/20150509/20150509095700126.svg)

            2.  MYSQL_INIT_COMMAND
                //连接到MySQL服务器时将执行的命令,再次连接时将自动再次执行。
                MYSQL_OPT_CONNECT_TIMEOUT //连接超时前的等待秒数
            3.  MYSQL_OPT_COMPRESS //网络连接中使用压缩机制
                MYSQL_OPT_PROTOCOL
                //要使用的协议类型,影视mysql.h中定义的mysql_protocol_type枚举值之一

                    MYSQL_INIT_COMMAND      //连接到MySQL服务器时将执行的命令,再次连接时将自动再次执行。
                    MYSQL_OPT_CONNECT_TIMEOUT    //连接超时前的等待秒数
                    MYSQL_OPT_COMPRESS           //网络连接中使用压缩机制
                    MYSQL_OPT_PROTOCOL      //要使用的协议类型,影视mysql.h中定义的mysql_protocol_type枚举值之一



                 

                4、以上的函数是在假设没有错误的情况下运行,如果数据库连接过程中出现了错误,我们就需要以下两个函数来处理错误信息:

                **[cpp]** view
                plaincopyprint?![](http://www.bkjia.com/uploads/allimg/150512/041Q53c4-0.png)![](http://www.2cto.com/uploadfile/Collfiles/20150509/20150509095700126.svg)

                1.  unsigned int mysql_errno(MYSQL *connection);
                    //返回错误代码(0表示为出现错误) char
                    *mysql_error(MYSQL *connection);
                    //返回错误信息,是以NULL作为终结的字符串

                        unsigned int mysql_errno(MYSQL *connection); //返回错误代码(0表示为出现错误)  
                        char *mysql_error(MYSQL *connection);    //返回错误信息,是以NULL作为终结的字符串 



                    5、程序访问数据库不只是与数据库建立连接,更重要的是通过SQL语句的执行查询或改变数据库中数据。执行SQL语句可以通过下列函数实现。

                     

                    **[cpp]** view
                    plaincopyprint?![](http://www.bkjia.com/uploads/allimg/150512/041Q53c4-0.png)![](http://www.2cto.com/uploadfile/Collfiles/20150509/20150509095700126.svg)

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

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



                         

                        SQL语句分为两类,返回数据的SQL和不返回数据的SQL(UPDATE、DELETE、INSERT)。

                        下面我们只介绍不返回数据的SQL

                         

                        **[cpp]** view
                        plaincopyprint?![](http://www.bkjia.com/uploads/allimg/150512/041Q53c4-0.png)![](http://www.2cto.com/uploadfile/Collfiles/20150509/20150509095700126.svg)

                        1.  my_ulonglong
                            mysql_affected_rows(MYSQL
                            *connection); //返回查询受影响的行
                            //对一段SQL语句执行后可以通过调用此函数查看SQL语句执行后,数据库中数据状态改变的行数,以此判断SQL的执行成功与否。

                                my_ulonglong mysql_affected_rows(MYSQL *connection); //返回查询受影响的行
                                //对一段SQL语句执行后可以通过调用此函数查看SQL语句执行后,数据库中数据状态改变的行数,以此判断SQL的执行成功与否。



                             

                            三、实例
                            --------

                            **[cpp]** view
                            plaincopyprint?![](http://www.bkjia.com/uploads/allimg/150512/041Q53c4-0.png)![](http://www.2cto.com/uploadfile/Collfiles/20150509/20150509095700126.svg)

                            1.  #include #include
                            2.  #include #include
                            3.  using namespace std;
                            4.  void mysql_err_function(MYSQL *
                                connection);
                            5.  int main()
                            6.  { //freopen("input.txt","r",stdin);
                            7.  MYSQL * connection;
                            8.  connection = mysql_init(NULL);
                            9.  if (!connection) {
                            10. cout << "mysql_init failed!"
                                << endl;
                            11. exit(-1); }
                            12. if
                                (!mysql_real_connect(connection,"localhost","root","123456","test",0,NULL,0))
                            13. { cout << "Connection To MySQL
                                failed!" << endl;
                            14. mysql_err_function(connection); }
                            15. cout << "Connection To MySQL
                                Server is Success..." << endl;
                            16. string str;
                            17. getline(cin,str);
                            18. int res = 0; int affected_count =
                                0;
                            19. while (str != "close" && str != ""
                                && !res) {
                            20. res =
                                mysql_query(connection,str.c_str());
                            21. affected_count +=
                                mysql_affected_rows(connection);
                            22. if (res) {
                            23. if (mysql_errno(connection)) {
                            24. cout << "Error " <<
                                mysql_errno(connection) << "
                                : " <<
                                mysql_error(connection) <<
                                '\n' << endl;
                            25. break; }
                            26. } getline(cin,str);
                            27. }
                            28. cout << "Have affected "
                                << affected_count << "
                                rows!" << endl;
                            29. mysql_close(connection);
                            30. cout << "Connection To MySQL
                                Server is closed..." << endl;
                            31. return 0; }
                            32. void mysql_err_function(MYSQL *
                                connection)
                            33. { if (mysql_errno(connection))
                            34. { cout << "Error " <<
                                mysql_errno(connection) << "
                                : "
                            35. << mysql_error(connection)
                                << endl;
                            36. exit(-1); }
                            37. }

) Linux 下 C++/C 连接 MySQL 数据库(一) 一、连接前准备 原材料:Ubuntu12.04LTS (已经安装了MySQL5.5或...

8.3.1 连接例程

用C语言连接MySQL数据库包含两个步骤:
1.初始化一个连接句柄结构
2.实际进行连接

首先,使用mysql_init来初始化连接句柄
#include <mysql.h>
MYSQL *mysql_init(MYSQL *);
通常传递NULL给这个例程,它会返回一个指向新分配的连接句柄结构的指针。如果传递一个已有的结构,它将被重新初始化。这个例程出错时返回NULL。
目前为止,只是分配和初始化了一个结构,仍然需要使用mysql_real_connect来向一个连接提供参数
MYSQL *mysql_real_connect(MYSQL *connection,
const char *server_host,
const char *sql_user_name,
const char *sql_password,
const char *db_name,
unsigned int port_number,
const char *unix_socket_name,
unsigned int flags);
指针connection必须指向已经被mysql_init初始化过的结构。其他参数的含义相当明了,server_host既可以是主机名,也可以是IP地址。如果只是连接到本地机器,可以通过指定localhost来优化连接类型。
sql_user_name和sql_password的含义和它们的字面含义一样。如果登录名为NULL,则假设登录名为当前linux用户的登录ID。如果密码是NULL,则只能访问服务器上无需密码就可访问的数据。密码会在通过传输前进行加密。
port_number和unix_socket_name应该分别为0和NULL,除非改变了MYSQL安装的默认设置。
flag参数用来对一些定义的位模式进行OR操作,使得改变使用协议的某些特征。
如果无法连接,它将返回NULL。mysql_error函数可以提供有帮助的信息。
使用完连接之后,通常在程序退出时,要像下面这样调用函数mysql_close
void mysql_close(MYSQL *connection);
这将关闭连接,如果连接是由mysql_init建立的,MySQL结构会被释放。指针将会无效并无法再次使用。
mysql_options例程(仅能在mysql_init和mysql_real_connect之间调用)可以设置一些选项:
int mysql_options(MYSQL *connection, enum option_to_set, const char *argument);
因为mysql_options一次只能设置一个选项,所以每设置一个选项就要调用它一次。下面列出了3个最常用的选项:
enum选项 实际参数类型 说明
MySQL_OPT_CONNECT_TIMEOUT const unsigned int * 连接超时之前的等待秒数
MySQL_OPT_COMPRESS None,使用NULL 网络连接中使用压缩机制
MySQL_INIT_COMMAND const char * 每次连接建立后发送的命令
如果要设置连接超时时间为7秒,使用的代码片段如下所示:
unsigned int timeout = 7;
connection = mysql_init(NULL);
ret = mysql_options(connection, MYSQL_OPT_CONNECT_TIMEOUT, (const char *)&timeout);
if (ret){
}
connection = mysql_real_connect(connection...)
接下来使用一个简短的程序测试一下。
首先进入rick用户,创建一个数据库foo;
mysql -u rick -p
CREATE DATABASE foo;
如果直接在mysql命令行中输入许多创建表和添加数据的命令,这比较容易出错,而且如果再次输入这些命令的话,也很不高效。因此,创建一个包含所需要命令的文件。
这个文件名为create_children.sql;
. /绝对路径/create_children.sql 来执行这个文件
一定要使用create_children.sql的绝对路径
.
现在有一个用户,一个数据库和一个保存了一些数据的表,接下来看一下如果通过代码来访问这些数据。
编写程序connect1.c,它以用户名rick和密码secret来连接本机服务器上名为foo的数据库。如果出现mysql.h找不到的情况,参见linux找不到mysql.h.
编译这个程序需要同时添加include路径和库文件路径,以及指定链接的库模块mysqlclient.
$ gcc connect1.c -o connect1.exe -I/usr/include/mysql -L/usr/lib/mysql -lmysqlclient
-I/usr/include/mysql是mysql.h的头文件路径
-L/usr/lib/mysql是库文件路径

 以下代码块是用来连接数据库的通讯过程,要连接MYSQL,必须建立MYSQL实例,通过mysql_init初始化方能开始进行连接.

8.3.2 错误处理

MySQL使用一系列由连接句柄结构报告的返回码.两个必备的例程是:
unsigned int mysql_errno(MYSQL *connection);
char *mysql_error(MYSQL *connection)
;
可以通过调用mysql_errno并传递连接结构来获得错误码,它通常都是非0值.如果未设定错误码,它将返回0.
mysql_errno的返回值实际上就是错误码,它们在errmsg.h或者mysqld_error.h中定义,前者是报告客户端错误,后者关注服务端错误.mysql_error提供有意义的文本信息,而不是单调的错误码,这些信息被写入一些内部静态内存空间中,如果想保存错误文本,需要把它复制到别的地方.
当调用mysql_real_connect时会遇到一个问题,因为它在失败时返回NULL指针,并没有提供一个错误码.但如果将连接句柄作为一个变量,那么及时mysql_real_connect失败,仍然能够处理它.
编写程序connect2.c,它示例如何使用非动态分配的连接结构,以及如何编写一些基本的错误处理代码.

8.3 使用C语言访问MySQL数据 Windows本地程序(如Access)可以通过ODBC驱动程序来访问MySQL,甚至...

typedef struct st_mysql {

 NET           net;            /* Communication parameters */

 gptr          connector_fd;   /* ConnectorFd for SSL */

 char          *host,*user,*passwd,*unix_socket,

                *server_version,*host_info,*info,*db;

 unsigned int port,client_flag,server_capabilities;

 unsigned int protocol_version;

 unsigned int field_count;

 unsigned int server_status;

 unsigned long thread_id;      /* Id for connection in server */

 my_ulonglong affected_rows;

 my_ulonglong insert_id;       /* id if insert on table with NEXTNR */

 my_ulonglong extra_info;              /* Used by mysqlshow */

 unsigned long packet_length;

 enum mysql_status status;

 MYSQL_FIELD   *fields;

 MEM_ROOT      field_alloc;

 my_bool       free_me;        /* If free in mysql_close */

 my_bool       reconnect;      /* set to 1 if automatic reconnect */

 struct st_mysql_options options;

 char          scramble_buff[9];

 struct charset_info_st *charset;

 unsigned int server_language;

} MYSQL;

这个结构代表返回行的一个查询的(SELECT, SHOW, DESCRIBE, EXPLAIN)的结果。返回的数据称为“数据集”,用过数据库的朋友应该对数据库中查询后得到的结果集不会陌生,在C的API里对应的就是MYSQL_RES了,从数据库读取数据,最后就是从MYSQL_RES中读取数据。

typedef struct st_mysql_res {

 my_ulonglong row_count;

 unsigned int field_count, current_field;

 MYSQL_FIELD   *fields;

 MYSQL_DATA    *data;

 MYSQL_ROWS    *data_cursor;

 MEM_ROOT      field_alloc;

 MYSQL_ROW     row;            /* If unbuffered read */

 MYSQL_ROW     current_row;    /* buffer to current row */

 unsigned long *lengths;       /* column lengths of current row */

 MYSQL         *handle;        /* for unbuffered reads */

 my_bool       eof;            /* Used my mysql_fetch_row */

} MYSQL_RES;

 

----------------------------------------------

再看函数:

 

C语言操作mysql数据 常用函数

所需头文件: #include <mysql/mysql.h>
功能:  获得或初始化一个MYSQL结构
函数原型: MYSQL *mysql_init(MYSQL *mysql)
函数返回值: 一个被始化的MYSQL*句柄
备注:  在内存不足的情况下,返回NULL

所需头文件: #include <mysql/mysql.h>
函数功能: 关闭一个服务器连接,并释放与连接相关的内存
函数原型: void mysql_close(MYSQL *mysql);
函数传入值: MYSQL:类型的指针
函数返回值: 无

所需头文件: #include <mysql/mysql.h>
函数功能: 连接一个MySQL服务器
函数原型: MYSQL * mysql_connect(MYSQL *mysql,const char *host,const char *user,const char *passwd);
函数传入值: mysql表示一个现存mysql结构的地址
  host表示MYSQL服务器的主机名或IP
  user表示登录的用户名
  passwd表示登录的密码
函数返回值: 如果连接成功,一个MYSQL *连接句柄:如果连接失败,NULL
备注:  该函数不推荐,使用mysql_real_connect()代替

所需文件: #include <mysql/mysql.h>
函数功能: 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 int client_flag);
函数传入值: mysql表示一个现存mysql结构的地址
  host表示MYSQL服务器的主机名或IP
  user表示登录的用户名
  passwd表示登录的密码
  db表示要连接的数据库
  port表示MySQL服务器的TCP/IP端口
  unix_socket表示连接类型
  client_flag表示MySQL运行ODBC数据库的标记
函数返回值: 如果连接成功,一个MYSQL*连接句柄:如果连接失败,NULL

所需头文件: #include <mysql/mysql.h>
函数功能: 返回最新的UPDATE,DELETE或INSERT查询影响的行数
函数传入值: MYSQL:类型指针
函数返回值: 大于零的一个整数表示受到影响或检索出来的行数。零表示没有区配查序中WHERE子句的记录或目前还没有查询被执行;-1表示查询返回一个错误,或对于一个SELECT查询

所需头文件: #include <mysql/mysql.h>
函数功能: 对指定的连接执行查询
函数原型: int mysql_query(MYSQL *mysql,const char *query);
函数传入值: query表示执行的SQL语句
函数返回值: 如果查询成功,为零,出错为非零。
相关函数: mysql_real_query

所需头文件: #include <mysql/mysql.h>
函数功能: 为无缓冲的结果集获得结果标识符
函数原形: MYSQL_RES *mysql_use_result(MYSQL *mysql);
函数传入值: MYSQL:类型的指针
函数返回值: 一个MYSQL_RES结果结构,如果发生一个错误发NULL

#incluee <mysql/mysql.h>
检索一个结果集合的下一行
MYSQL_ROW mysql_fetch_row(MYSQL_RES *result);
MYSQL_RES:结构的指针
下一行的一个MYSQL_ROW结构。如果没有更多的行可检索或如果出现一个错误,NULL

#include <mysql/mysql.h>
返回指定结果集中列的数量
unsigned int mysql_num_fields(MYSQL_RES *res);
MYSQL_RES 结构的指针
结果集合中字段数量的一个无符号整数

#include <mysql/mysql.h>
创建一个数据库
int mysql_create_db(MYSQL *mysql,const char *db);
MYSQL:类型的指针
db:要创建的数据库名
如果数据库成功地被创建,返回零,如果发生错误,为非零。

#include <mysql/mysql.h>
选择一个数据库
int mysql_select_db(MYSQL *mysql,const char *db);
MYSQL:类型的指针
db:要创建的数据库名
如果数据库成功地被创建,返回零,如果发生错误,为非零。

 

----------------------------------------------

再看例子:

      很多人用到MySQL来开发一些项目,有时为了性能,我们会直接用C语言来开发相关的模块,尤其在我们的web应用中,虽然PHP、JSP等脚本均 提供了MySQL的接口,但是显然直接使用C语言具有更好的安全性和性能,Michael以前用PHP开发的多个项目中就使用了C语言编写的这类接口,然 后再编译到php里面,供php脚本直接使用,这方面的话题就不多说了,下面主要说一下在Linux下如何用C语言连接MySQL数据库,并且读取里面的 数据返回,同时如何进行编译。

  这里的大部分代码参考了MySQL发行包里面的.c源文件,大家也可以去里面找找相关的代码,下面这段代码实现了连接到本地MySQL服务器上9tmd_bbs_utf8数据库,从数据表tbb_user中根据输入的userid取得该用户的用户名并打印输出到终端。

#if defined(_WIN32) || defined(_WIN64) //为了支持Windows平台上的编译
#include <windows.h>
#endif
#include <stdio.h>
#include <stdlib.h>
#include "mysql.h"  //我的机器上该文件在/usr/local/include/mysql下
 
//定义数据库操作的宏,也可以不定义留着后面直接写进代码
#define SELECT_QUERY "select username from tbb_user where userid = %d"
 
int main(int argc, char **argv) //char **argv 相当于 char *argv[]
{
    MYSQL mysql,*sock;    //定义数据库连接的句柄,它被用于几乎所有的MySQL函数
    MYSQL_RES *res;       //查询结果集,结构类型
    MYSQL_FIELD *fd ;     //包含字段信息的结构
    MYSQL_ROW row ;       //存放一行查询结果的字符串数组
    char qbuf[160];      //存放查询sql语句字符串
    
    if (argc != 2) { //检查输入参数
        fprintf(stderr,"usage : mysql_select <userid>nn");
        exit(1);
    }
    
    mysql_init(&mysql);
    if (!(sock = mysql_real_connect(&mysql,"localhost","dbuser","dbpwd","9tmd_bbs_utf8",0,NULL,0))) {
        fprintf(stderr,"Couldn't connect to engine!n%snn",mysql_error(&mysql));
        perror("");
        exit(1);
    }
    
    sprintf(qbuf,SELECT_QUERY,atoi(argv[1]));
    if(mysql_query(sock,qbuf)) {
        fprintf(stderr,"Query failed (%s)n",mysql_error(sock));
        exit(1);
    }
    
    if (!(res=mysql_store_result(sock))) {
        fprintf(stderr,"Couldn't get result from %sn", mysql_error(sock));
        exit(1);
    }
    
    printf("number of fields returned: %dn",mysql_num_fields(res));
        
    while (row = mysql_fetch_row(res)) {
        printf("Ther userid #%d 's username is: %sn", atoi(argv[1]),(((row[0]==NULL)&&(!strlen(row[0]))) ? "NULL" : row[0])) ;
        puts( "query ok !n" ) ;
    }
    
    mysql_free_result(res);
    mysql_close(sock);
    exit(0);
    return 0;   //. 为了兼容大部分的编译器加入此行
}

编译的时候,使用下面的命令

gcc -o mysql_select ./mysql_select.c -I/usr/local/include/mysql -L/usr/local/lib/mysql -lmysqlclient (-lz) (-lm) 后面两个选项可选,根据您的环境情况

运行的时候,执行下面的命令

./mysql_select 1

将返回如下结果:

number of fields returned: 1
Ther userid #1 's username is: Michael
query ok !

上面的代码我想大部分都能看明白,不明白的可以参考一下MySQL提供的有关C语言API部分文档,各个函数都有详细说明,有时间我整理一份常用的API说明出来。

 


  • 首页
  • 电话
  • 软件