Chinaunix首页 | 论坛 | 博客

涅槃生，涅槃灭！np10.blog.chinaunix.net

首页　| 　博文目录　| 　关于我

file3

  • 博客访问： 318649
  • 博文数量： 43
  • 博客积分： 1044
  • 博客等级： 准尉
  • 技术积分： 658
  • 用 户 组： 普通用户
  • 注册时间： 2010-12-20 14:56
个人简介

人法地，地法天，天法道，道法自然。

文章分类

全部博文（43）

文章存档

2019年（1）

2013年（3）

2012年（15）

2011年（24）

我的朋友
最近访客
推荐博文
相关博文
mysql api examples

分类： Mysql/postgreSQL

2011-11-22 17:33:57

mysql api的简单例子。这个里面没有包括查询的API，因为mysql有两套查询api。
  1. /**********************************************************************************
  2.   * File name:mysql_api_examples.c
  3.   * Description:mysql api examples
  4.   * Author:Wales.guo
  5.   * Date:2011-11-22
  6.   * Revision History:
  7. ***********************************************************************************/
  8. #include <stdlib.h>
  9. #include <stdio.h>
  10. #include <string.h>

  12. #include <mysql.h>

  14. int main(int argc,char *argv[])
  15. {
  16.     MYSQL *mysql = NULL;
  17.     unsigned long client_flag = CLIENT_COMPRESS | CLIENT_SSL;

  19.     unsigned long client_version = 0;
  20.     unsigned long server_version = 0;
  21.     char *server_stat = NULL;

  23.     int ret = EXIT_SUCCESS;

  25.     client_version = mysql_get_client_version();
  26.     if(client_version < 50100) {
  27.         fprintf(stderr, "mysql client library version is too low.\n");
  28.         ret = EXIT_FAILURE;
  29.         goto END;
  30.     }

  32. #ifdef MYSQL_EMBEDDED
  33.     /*
  34.        * 英文文档里面写的是mysql_library_init
  35.        * 中文文档里面写的是mysql_server_init
  36.        * 最终发现这个:
  37.        *
  38.        * mysql_library_init()和mysql_library_end()实际上
  39.        * 是#define符号，这类符号使得它们
  40.        * 等效于mysql_server_init()和mysql_server_end()，
  41.        * 但其名称更清楚地指明，无论应
  42.        * 用程序使用的是mysqlclient或mysqld库，
  43.        * 启动或结束MySQL库时，应调用它们。
  44.        * 对于早期的MySQL版本，可调用
  45.        * mysql_server_init()和mysql_server_end()取而代之。
  46.        */
  47.     ret = mysql_server_init(0, NULL, NULL);
  48.     if (ret != 0) {
  49.       fprintf(stderr, "could not initialize MySQL library\n");
  50.       ret = EXIT_FAILURE;
  51.       goto END;
  52.     }
  53. #endif
  54.     mysql = mysql_init(NULL);
  55.     if (mysql == NULL) {
  56.         fprintf(stderr, "could not initialize MySQL\n");
  57.         ret = EXIT_FAILURE;
  58.         goto EMBEDDED_END;
  59.     }

  61.     ret = mysql_ssl_set(mysql, NULL, NULL, NULL, NULL, NULL);
  62.     if (ret != 0) {
  63.         printf("call mysql_ssl_set error.error = %s\n",mysql_error(pMySQL));
  64.         ret = EXIT_FAILURE;
  65.         goto EMBEDDED_END;
  66.     }

  68.     if (mysql_real_connect(mysql, "host", "user", "passwd", "mysql", port, NULL, client_flag)) {
  69.          fprintf(stderr, "failed to connect to database: Error: %s\n", mysql_error(mysql));
  70.          ret = EXIT_FAILURE;
  71.          goto MYSQL_END;
  72.     }

  74. #ifdef MYSQL_EMBEDDED
  75.     mysql_options(mysql, MYSQL_READ_DEFAULT_GROUP, "libmysqld_client");
  76.     mysql_options(mysql, MYSQL_OPT_USE_EMBEDDED_CONNECTION, NULL);
  77. #endif

  79.     ret = mysql_set_character_set(mysql, "utf8");
  80.     if (ret != 0) {
  81.         fprintf(stderr, "could not set character set. Error: %s\n",mysql_error(mysql));
  82.         ret = EXIT_FAILURE;
  83.         goto MYSQL_END;
  84.     }

  86.     mysql_set_server_option(mysql, MYSQL_OPTION_MULTI_STATEMENTS_ON);

  88.     ret = mysql_change_user(mysql, "root", "root123", NULL);
  89.     if (ret != 0) {
  90.        fprintf(stderr, "failed to change user. Error: %s\n", mysql_error(mysql));
  91.        ret = EXIT_FAILURE;
  92.        goto MYSQL_END;
  93.     }

  95.     server_version = mysql_get_server_version(mysql);
  96.     if (server_version < 50100) {
  97.         fprintf(stderr, "mysql server version is too low.\n");
  98.         ret = EXIT_FAILURE;
  99.         goto MYSQL_END;
  100.     }

  102.     ret = mysql_create_db(mysql, "my_database");
  103.     if (ret != 0) {
  104.        fprintf(stderr, "failed to create new database. Error: %s\n", mysql_error(mysql));
  105.        ret = EXIT_FAILURE;
  106.        goto MYSQL_END;
  107.     }

  109.     ret = mysql_select_db(mysql, "my_database");
  110.     if (ret != 0) {
  111.        fprintf(stderr, "failed to select database. Error: %s\n", mysql_error(mysql));
  112.        ret = EXIT_FAILURE;
  113.        goto DROP_DB_END;
  114.     }

  116.     ret = mysql_autocommit(mysql, 0);
  117.     if (ret != 0) {
  118.         fprintf(stderr, "failed to select database. Error: %s\n", mysql_error(mysql));
  119.         ret = EXIT_FAILURE;
  120.         goto DROP_DB_END;
  121.     }
  122.     /*
  123.       * 这里调用查询API，但是这里有两套API可以调用
  124.       * 下一遍介绍中会看到: 普通查询API和预处理API
  125.       */
  126.     ret = mysql_commit(mysql);
  127.     if (ret != 0) {
  128.         fprintf(stderr, "failed to commit. Error: %s\n", mysql_error(mysql));
  129.         ret = EXIT_FAILURE;
  130.         goto ROLL_BACK_END;
  131.     }

  133.     server_stat = mysql_stat(mysql);
  134.     if (server_stat != NULL) {
  135.         printf("%s",server_stat);
  136.     } else {
  137.         printf("%s","cannot get mysql server status. Error: %s\n", mysql_error(mysql));
  138.     }
  139.     goto DROP_DB_END;

  141. ROLL_BACK_END:
  142.      ret = mysql_rollback(mysql);
  143.      if (ret != 0) {
  144.         fprintf(stderr, "failed to roll back. Error: %s\n", mysql_error(mysql));
  145.         ret = EXIT_FAILURE;
  146.      }

  148. DROP_DB_END:
  149.     ret = mysql_drop_db(mysql, "my_database");
  150.     if (ret != 0) {
  151.        fprintf(stderr, "failed to select database. Error: %s\n", mysql_error(mysql));
  152.        ret = EXIT_FAILURE;
  153.        goto MYSQL_END;
  154.     }

  156. MYSQL_END:
  157.     if (mysql != NULL) {
  158.         mysql_close(mysql);
  159.         mysql = NULL;
  160.     }

  162. EMBEDDED_END:
  163. #ifdef MYSQL_EMBEDDED
  164.     mysql_server_end();
  165. #endif

  167. END:
  168.     return ret;
  169. }
以上代码在linux下使用：
  1. gcc mysql_api_examples.c -DMYSQL_EMBEDDED -o test1_libmysqld -lz \
  2. `/usr/local/mysql/bin/mysql_config --include --libmysqld-libs`
进行编译。

这里简单的组织出mysql api中非查询所用的函数，以及他们的调用顺序。一下简要介绍函数：
---------------------------------------------------------------------------------------------
  1. int mysql_library_init(int argc, char **argv, char **groups);
  2. void mysql_library_end(void);
像sqlite，leveldb一样，mysql所支持的内嵌式数据库的两个函数。
参照：http://dev.mysql.com/doc/refman/5.1/en/libmysqld.html
---------------------------------------------------------------------------------------------
  1. MYSQL *mysql_init(MYSQL *mysql);
  2. void mysql_close(MYSQL *mysql);
mysql库的初始化函数
参照：http://dev.mysql.com/doc/refman/5.1/zh/apis.html#mysql-init
---------------------------------------------------------------------------------------------
  1. int mysql_ssl_set(MYSQL *mysql, const char *key, const char *cert, const char *ca, const char *capath, const char *cipher);
使用mysql_ssl_set()，可采用SSL建立安全连接。必须在mysql_real_connect()之前调用它。
除非在客户端库中允许了OpenSSL支持，否则mysql_ssl_set()不作任何事。
参照：http://dev.mysql.com/doc/refman/5.1/zh/apis.html#mysql-ssl-set
---------------------------------------------------------------------------------------------
  1. 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 client_flag)
连接mysql数据库。mysql_connect处于废弃状态，建议不要使用。
参照：http://dev.mysql.com/doc/refman/5.1/zh/apis.html#mysql-real-connect
---------------------------------------------------------------------------------------------
  1. int mysql_options(MYSQL *mysql, enum mysql_option option, const void *arg)
参照：http://dev.mysql.com/doc/refman/5.1/en/mysql-options.html
---------------------------------------------------------------------------------------------
  1. int mysql_set_character_set(MYSQL *mysql, char *csname);
设置该连接的字符集。
参照：http://dev.mysql.com/doc/refman/5.1/zh/apis.html#mysql-set-character-set
另：和字符集相关的函数还有：
  1. const char *mysql_character_set_name(MYSQL *mysql);
为当前连接返回默认的字符集。
  1. void mysql_get_character_set_info(MYSQL *mysql, MY_CHARSET_INFO *cs)
该函数提供了关于默认客户端字符集的信息。
  1. int mysql_options(MYSQL *mysql, enum mysql_option option, const char *arg)
设置关于字符集的参数：MYSQL_SET_CHARSET_DIR和MYSQL_SET_CHARSET_NAME
  1. unsigned long mysql_real_escape_string(MYSQL *mysql, char *to, const char *from, unsigned long length)
该函数用于创建可在SQL语句中使用的合法SQL字符串。
---------------------------------------------------------------------------------------------
  1. unsigned long mysql_get_client_version(void)
返回表示客户端库版本的整数。该值的格式是XYYZZ，其中X是主版本号，YY是发布级别，ZZ是发布级别内的版本号。例如，值40102表示客户端库的版本是4.1.2。
参照：http://dev.mysql.com/doc/refman/5.1/zh/apis.html#mysql-get-client-version
  1. char *mysql_get_server_info(MYSQL *mysql)
返回代表服务器版本号的字符串。
参照：http://dev.mysql.com/doc/refman/5.1/zh/apis.html#mysql-get-server-info
---------------------------------------------------------------------------------------------
  1. my_bool mysql_change_user(MYSQL *mysql, const char *user, const char *password, const char *db)
更改用户，并使由db指定的数据库成为由mysql指定的连接上的默认数据库（当前数据库）。
参照：http://dev.mysql.com/doc/refman/5.1/zh/apis.html#mysql-get-server-info
---------------------------------------------------------------------------------------------
  1. int mysql_create_db(MYSQL *mysql, const char *db)
创建由db参数命名的数据库。该函数已过时。最好使用mysql_query()来发出SQL CREATE DATABASE语句。
参照：http://dev.mysql.com/doc/refman/5.1/zh/apis.html#mysql-get-server-info
  1. int mysql_drop_db(MYSQL *mysql, const char *db)
撤销由db参数命名数据库。该函数已过时。最好使用mysql_query()来发出SQL DROP DATABASE语句
参照：http://dev.mysql.com/doc/refman/5.1/zh/apis.html#mysql-drop-db
  1. int mysql_select_db(MYSQL *mysql, const char *db)
使由db指定的数据库成为由mysql指定的连接上的默认数据库（当前数据库）。
参照：http://dev.mysql.com/doc/refman/5.1/zh/apis.html#mysql-select-db
---------------------------------------------------------------------------------------------
  1. my_bool mysql_autocommit(MYSQL *mysql, my_bool mode)
  2. my_bool mysql_commit(MYSQL *mysql)
  3. my_bool mysql_rollback(MYSQL *mysql)
实务操作的三个函数。
参照：http://dev.mysql.com/doc/refman/5.1/zh/apis.html#mysql-rollbac
阅读(2211) | 评论(0) | 转发(0) |
0

上一篇：MYSQL系统信息相关

下一篇：mysql查詢api

给主人留下些什么吧！~~
关于我们 | 关于IT168 | 联系方式 | 广告合作 | 法律声明 | 免费注册

Copyright 2001-2010 ChinaUnix.net All Rights Reserved 北京皓辰网域网络信息技术有限公司. 版权所有

感谢所有关心和支持过ChinaUnix的朋友们

16024965号-6