Heim >Datenbank >MySQL-Tutorial >libmysqld,嵌入式MySQL服务器库_MySQL

libmysqld,嵌入式MySQL服务器库_MySQL

WBOY
WBOYOriginal
2016-06-01 13:07:271270Durchsuche

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
Stellungnahme:
Der Inhalt dieses Artikels wird freiwillig von Internetnutzern beigesteuert und das Urheberrecht liegt beim ursprünglichen Autor. Diese Website übernimmt keine entsprechende rechtliche Verantwortung. Wenn Sie Inhalte finden, bei denen der Verdacht eines Plagiats oder einer Rechtsverletzung besteht, wenden Sie sich bitte an admin@php.cn
Vorheriger Artikel:HandlerSocketNächster Artikel:谁干的mysql无密码登录?_MySQL