首页 >数据库 >mysql教程 >libmysqld,嵌入式MySQL服务器库_MySQL

libmysqld,嵌入式MySQL服务器库_MySQL

WBOY
WBOY原创
2016-06-01 13:07:271264浏览

bitsCN.com

25.1.1. 嵌入式MySQL服务器库概述

使用嵌入式MySQL服务器库,能够在客户端应用程序中使用具备全部特性的MySQL服务器。 主要优点在于,增加了速度,并使得嵌入式应用程序的管理更简单。

嵌入式服务器库是以MySQL的客户端/服务器版本为基础的,采用C/C++语言编写。 其结果是嵌入式服务器也是用C/C++语言编写的。 在其他语言中,嵌入式服务器不可用。

API与嵌入式MySQL版本和客户端/服务器版本等效。 要想更改旧的线程式应用程序以使用嵌入式库,正常情况下,仅需添加对下述函数的调用即可。

函数

何时调用

mysql_server_init()

应在调用任何其他MySQL函数之前调用,最好是在main()函数中调用。

mysql_server_end()

应在程序退出前调用。

mysql_thread_init()

应在你所创建的、用于访问MySQL的每个线程中调用。

mysql_thread_end()

应在调用pthread_exit()之前调用。

随后,必须将你的代码与libmysqld.a链接起来,而不是libmysqlclient.a。

在libmysqlclient.a中还包含mysql_server_xxx()函数,使用这类函数,通过将应用程序链接到恰当的库,即可在嵌入式版本和客户端/服务器版本之间切换。 请参见25.2.12.1节,“mysql_server_init()”。

嵌入式服务器和独立服务器之间的一项差别在于,对于嵌入式服务器,默认情况下,连接鉴定是禁止的。 对于嵌入式服务器,要想使用鉴定功能,可在激活“configure”以配置MySQL分发版时使用“--with-embedded-privilege-control”选项。

25.1.2. 使用libmysqld编译程序

要想获得libmysqld库,应使用“--with-embedded-server”选项配置MySQL。 请参见2.8.2节,“典型配置选项”。

将你的程序与libmysqld链接时,还必须包含系统的pthread库以及MySQL服务器使用的一些库。 执行“<strong>mysql_config --libmysqld-libs</strong>”,可获得库的完整列表。

对于线程程序的编译和链接,必须使用正确的标志,即使你未在代码中直接调用任何线程函数也同样。

要想编译C程序以包含必要文件,并将MySQL服务器库嵌入到程序的编译版本中,可使用GNU C编译器(gcc)。 编译器需要知道各种文件的位置,并需了解如何编译程序的指令。 在下面的示例中,介绍了如何从命令行编译程序的方法:

<code class="literal">gcc mysql_test.c -o mysql_test -lz /</code>
<code class="literal">`/usr/local/mysql/bin/mysql_config --include --libmysqld-libs`</code>

在gcc命令后紧跟着未编译C程序文件的名称。 接下来,给定的“-o”选项指明,它后面的文件名是编译器将输出文件的名称,即编译后的程序。 在下一行的代码中,通知编译器获取包含文件和库的位置,以及在其上进行编译的系统的其他设置。 由于“<strong>mysql_config</strong>”存在的问题,在此添加了“-lz”选项(压缩)。 “<strong>mysql_config</strong>”部分包含在backticks中,而不是单引号内。

25.1.3. 使用嵌入式MySQL服务器时的限制

嵌入式服务器存在下述限制:

· 不支持ISAM表。 (这样做的主要目的是为了使库更小)。

· 没有自定义函数(UDF)。

· 没有对核心转储的堆栈跟踪。

· 没有内部RAID支持。 (由于大多数当前操作系统均支持大文件,通常情况下不需要它)。

· 不能将其设置为“主”或“从”(无复制)。

· 在内存较低的系统上,可能无法使用很大的结果集。

· 不能使用套接字或TCP/IP从外部进程连接到嵌入式服务器。 但是,你可以连接到中间应用程序,随后,该中间应用程序可代表远程客户端或外部进程连接到嵌入式服务器。

通过编辑“mysql_embed.h”包含文件并重新编译MySQL,可更改某些限制。

25.1.4. 与嵌入式服务器一起使用的选项

对于任何能够与<strong>mysqld</strong>服务器端口监督程序一起给定的选项,也可以与嵌入式服务器库一起使用。在数组中,可将服务器选项作为参量指定给用于初始化服务器的mysql_server_init()。也能在诸如my.cnf的选项文件中给定它们。要想为C程序指定选项文件,请使用“--defaults-file”选项作为函数mysql_server_init()的第2个参量的元素之一。关于mysql_server_init()函数的更多信息,请参见25.2.12.1节,“mysql_server_init()”。

使用选项文件,能够简化客户端/服务器应用程序和嵌入了MySQL的应用程序之间的切换。将常用选项置于[server]组。它们可被两种MySQL版本读取。客户端/服务器选项应被放在[mysqld]部分。将嵌入式MySQL服务器库的选项放在[embedded]部分。将与应用程序相关的选项放在标记为[ApplicationName_SERVER]的部分。请参见4.3.2节,“使用选项文件”。

25.1.5. 嵌入式服务器中尚需完成的事项(TODO)

· 我们将提供一些选项以省去MySQL的某些部分,从而使库变得更小。

· 仍有很多速度优化工作需要完成。

· 错误将被写入stderr。我们将增加1个选项为它们指定文件名。

· 使用嵌入式版本时,需要更改InnoDB,使之不再冗长。如果你的数据库不含InnoDB表,要想抑制相关消息,可为组[libmysqd_server]下的选项文件增加“--skip-innodb”选项,或在用<strong>mysql_server_init()</strong>初始化服务器时添加该选项。

25.1.6. 嵌入式服务器示例

在Linux或FreeBSD系统上,无需更改就能使用下面这两个示例程序。对于其他操作系统,需要进行小的修改,主要是文件路径。设计这两个示例的目的在于,为你提供足够的细节信息,以便理解问题,它们是实际应用程序的必要组成部份。第1个示例十分直观。第2个示例采用了一些错误检查功能,略为复杂。在第1个示例的后面,给出了用于编译程序的命令行条目。在第2个示例的后面,给出了GNUmake文件,该文件可用于编译。

<strong>示例:1</strong>

test1_libmysqld.c

<code class="literal">#include <stdio.h></code>
<code class="literal">#include <stdlib.h></code>
<code class="literal">#include <stdarg.h></code>
<code class="literal">#include "mysql.h"</code>
<code class="literal"> </code>
<code class="literal">MYSQL *mysql;</code>
<code class="literal">MYSQL_RES *results;</code>
<code class="literal">MYSQL_ROW record;</code>
<code class="literal"> </code>
<code class="literal">static char *server_options[] = { "mysql_test", "--defaults-file=my.cnf" };</code>
<code class="literal">int num_elements = sizeof(server_options)/ sizeof(char *);</code>
<code class="literal"> </code>
<code class="literal">static char *server_groups[] = { "libmysqld_server", "libmysqld_client" };</code>
<code class="literal"> </code>
<code class="literal">int main(void)</code>
<code class="literal">{</code>
<code class="literal">   mysql_server_init(num_elements, server_options, server_groups);</code>
<code class="literal">   mysql = mysql_init(NULL);</code>
<code class="literal">   mysql_options(mysql, MYSQL_READ_DEFAULT_GROUP, "libmysqld_client");</code>
<code class="literal">   mysql_options(mysql, MYSQL_OPT_USE_EMBEDDED_CONNECTION, NULL);</code>
<code class="literal"> </code>
<code class="literal">   mysql_real_connect(mysql, NULL,NULL,NULL, "database1", 0,NULL,0);</code>
<code class="literal"> </code>
<code class="literal">   mysql_query(mysql, "SELECT column1, column2 FROM table1");</code>
<code class="literal"> </code>
<code class="literal">   results = mysql_store_result(mysql);</code>
<code class="literal"> </code>
<code class="literal">   while((record = mysql_fetch_row(results))) {</code>
<code class="literal">      printf("%s - %s /n", record[0], record[1]);</code>
<code class="literal">   }</code>
<code class="literal"> </code>
<code class="literal">   mysql_free_result(results);</code>
<code class="literal">   mysql_close(mysql);</code>
<code class="literal">   mysql_server_end();</code>
<code class="literal"> </code>
<code class="literal">   return 0;</code>
<code class="literal">}</code>

下面给出了编译上述程序的命令行命令:

<code class="literal">gcc test1_libmysqld.c -o test1_libmysqld -lz /</code>
<code class="literal"> `/usr/local/mysql/bin/mysql_config --include --libmysqld-libs`</code>

<strong>示例:2</strong>

要想检验该示例,创建一个与MySQL源目录同级的test2_libmysqld目录。将test2_libmysqld.c源文件和GNUmakefile保存到该目录,并在test2_libmysqld目录下运行GNUmake。

test2_libmysqld.c

<code class="literal">/*</code>
<code class="literal"> * A simple example client, using the embedded MySQL server library</code>
<code class="literal">*/</code>
<code class="literal"> </code>
<code class="literal">#include <mysql.h></code>
<code class="literal">#include <stdarg.h></code>
<code class="literal">#include <stdio.h></code>
<code class="literal">#include <stdlib.h></code>
<code class="literal"> </code>
<code class="literal">MYSQL *db_connect(const char *dbname);</code>
<code class="literal">void db_disconnect(MYSQL *db);</code>
<code class="literal">void db_do_query(MYSQL *db, const char *query);</code>
<code class="literal"> </code>
<code class="literal">const char *server_groups[] = {</code>
<code class="literal">  "test2_libmysqld_SERVER", "embedded", "server", NULL</code>
<code class="literal">};</code>
<code class="literal"> </code>
<code class="literal">int</code>
<code class="literal">main(int argc, char **argv)</code>
<code class="literal">{</code>
<code class="literal">  MYSQL *one, *two;</code>
<code class="literal"> </code>
<code class="literal">  /* mysql_server_init() must be called before any other mysql</code>
<code class="literal">   * functions.</code>
<code class="literal">   *</code>
<code class="literal">   * You can use mysql_server_init(0, NULL, NULL), and it</code>
<code class="literal">   * initializes the server using groups = {</code>
<code class="literal">   *   "server", "embedded", NULL</code>
<code class="literal">   *  }.</code>
<code class="literal">   *</code>
<code class="literal">   * In your $HOME/.my.cnf file, you probably want to put:</code>
<code class="literal"> </code>
<code class="literal">[test2_libmysqld_SERVER]</code>
<code class="literal">language = /path/to/source/of/mysql/sql/share/english</code>
<code class="literal"> </code>
<code class="literal">   * You could, of course, modify argc and argv before passing</code>
<code class="literal">   * them to this function.  Or you could create new ones in any</code>
<code class="literal">   * way you like.  But all of the arguments in argv (except for</code>
<code class="literal">   * argv[0], which is the program name) should be valid options</code>
<code class="literal">   * for the MySQL server.</code>
<code class="literal">   *</code>
<code class="literal">   * If you link this client against the normal mysqlclient</code>
<code class="literal">   * library, this function is just a stub that does nothing.</code>
<code class="literal">   */</code>
<code class="literal">  mysql_server_init(argc, argv, (char **)server_groups);</code>
<code class="literal"> </code>
<code class="literal">  one = db_connect("test");</code>
<code class="literal">  two = db_connect(NULL);</code>
<code class="literal"> </code>
<code class="literal">  db_do_query(one, "SHOW TABLE STATUS");</code>
<code class="literal">  db_do_query(two, "SHOW DATABASES");</code>
<code class="literal"> </code>
<code class="literal">  mysql_close(two);</code>
<code class="literal">  mysql_close(one);</code>
<code class="literal"> </code>
<code class="literal">  /* This must be called after all other mysql functions */</code>
<code class="literal">  mysql_server_end();</code>
<code class="literal"> </code>
<code class="literal">  exit(EXIT_SUCCESS);</code>
<code class="literal">}</code>
<code class="literal"> </code>
<code class="literal">static void</code>
<code class="literal">die(MYSQL *db, char *fmt, ...)</code>
<code class="literal">{</code>
<code class="literal">  va_list ap;</code>
<code class="literal">  va_start(ap, fmt);</code>
<code class="literal">  vfprintf(stderr, fmt, ap);</code>
<code class="literal">  va_end(ap);</code>
<code class="literal">  (void)putc(&#39;/n&#39;, stderr);</code>
<code class="literal">  if (db)</code>
<code class="literal">    db_disconnect(db);</code>
<code class="literal">  exit(EXIT_FAILURE);</code>
<code class="literal">}</code>
<code class="literal"> </code>
<code class="literal">MYSQL *</code>
<code class="literal">db_connect(const char *dbname)</code>
<code class="literal">{</code>
<code class="literal">  MYSQL *db = mysql_init(NULL);</code>
<code class="literal">  if (!db)</code>
<code class="literal">    die(db, "mysql_init failed: no memory");</code>
<code class="literal">  /*</code>
<code class="literal">   * Notice that the client and server use separate group names.</code>
<code class="literal">   * This is critical, because the server does not accept the</code>
<code class="literal">   * client&#39;s options, and vice versa.</code>
<code class="literal">   */</code>
<code class="literal">  mysql_options(db, MYSQL_READ_DEFAULT_GROUP, "test2_libmysqld_CLIENT");</code>
<code class="literal">  if (!mysql_real_connect(db, NULL, NULL, NULL, dbname, 0, NULL, 0))</code>
<code class="literal">    die(db, "mysql_real_connect failed: %s", mysql_error(db));</code>
<code class="literal"> </code>
<code class="literal">  return db;</code>
<code class="literal">}</code>
<code class="literal"> </code>
<code class="literal">void</code>
<code class="literal">db_disconnect(MYSQL *db)</code>
<code class="literal">{</code>
<code class="literal">  mysql_close(db);</code>
<code class="literal">}</code>
<code class="literal"> </code>
<code class="literal">void</code>
<code class="literal">db_do_query(MYSQL *db, const char *query)</code>
<code class="literal">{</code>
<code class="literal">  if (mysql_query(db, query) != 0)</code>
<code class="literal">    goto err;</code>
<code class="literal"> </code>
<code class="literal">  if (mysql_field_count(db) > 0)</code>
<code class="literal">  {</code>
<code class="literal">    MYSQL_RES   *res;</code>
<code class="literal">    MYSQL_ROW    row, end_row;</code>
<code class="literal">    int num_fields;</code>
<code class="literal"> </code>
<code class="literal">    if (!(res = mysql_store_result(db)))</code>
<code class="literal">      goto err;</code>
<code class="literal">    num_fields = mysql_num_fields(res);</code>
<code class="literal">    while ((row = mysql_fetch_row(res)))</code>
<code class="literal">    {</code>
<code class="literal">      (void)fputs(">> ", stdout);</code>
<code class="literal">      for (end_row = row + num_fields; row < end_row; ++row)</code>
<code class="literal">        (void)printf("%s/t", row ? (char*)*row : "NULL");</code>
<code class="literal">      (void)fputc(&#39;/n&#39;, stdout);</code>
<code class="literal">    }</code>
<code class="literal">    (void)fputc(&#39;/n&#39;, stdout);</code>
<code class="literal">    mysql_free_result(res);</code>
<code class="literal">  }</code>
<code class="literal">  else</code>
<code class="literal">    (void)printf("Affected rows: %lld/n", mysql_affected_rows(db));</code>
<code class="literal"> </code>
<code class="literal">  return;</code>
<code class="literal"> </code>
<code class="literal">err:</code>
<code class="literal">  die(db, "db_do_query failed: %s [%s]", mysql_error(db), query);</code>
<code class="literal">}</code>

GNUmakefile

<code class="literal"># This assumes the MySQL software is installed in /usr/local/mysql</code>
<code class="literal">inc      := /usr/local/mysql/include/mysql</code>
<code class="literal">lib      := /usr/local/mysql/lib</code>
<code class="literal"> </code>
<code class="literal"># If you have not installed the MySQL software yet, try this instead</code>
<code class="literal">#inc      := $(HOME)/mysql-5.1/include</code>
<code class="literal">#lib      := $(HOME)/mysql-5.1/libmysqld</code>
<code class="literal"> </code>
<code class="literal">CC       := gcc</code>
<code class="literal">CPPFLAGS := -I$(inc) -D_THREAD_SAFE -D_REENTRANT</code>
<code class="literal">CFLAGS   := -g -W -Wall</code>
<code class="literal">LDFLAGS  := -static</code>
<code class="literal"># You can change -lmysqld to -lmysqlclient to use the</code>
<code class="literal"># client/server library</code>
<code class="literal">LDLIBS    = -L$(lib) -lmysqld -lz -lm -lcrypt</code>
<code class="literal"> </code>
<code class="literal">ifneq (,$(shell grep FreeBSD /COPYRIGHT 2>/dev/null))</code>
<code class="literal"># FreeBSD</code>
<code class="literal">LDFLAGS += -pthread</code>
<code class="literal">else</code>
<code class="literal"># Assume Linux</code>
<code class="literal">LDLIBS += -lpthread</code>
<code class="literal">endif</code>
<code class="literal"> </code>
<code class="literal"># This works for simple one-file test programs</code>
<code class="literal">sources := $(wildcard *.c)</code>
<code class="literal">objects := $(patsubst %c,%o,$(sources))</code>
<code class="literal">targets := $(basename $(sources))</code>
<code class="literal"> </code>
<code class="literal">all: $(targets)</code>
<code class="literal"> </code>
<code class="literal">clean:</code>
<code class="literal">        rm -f $(targets) $(objects) *.core</code>
bitsCN.com
声明:
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn