libmysqld，嵌入式MySQL服务器库

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

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

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

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

gcc mysql_test.c -o mysql_test -lz \

`/usr/local/mysql/bin/mysql_config --include --libmysqld-libs`

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

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

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

·        没有自定义函数（UDF）。

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

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

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

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

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

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

对于任何能够与mysqld服务器端口监督程序一起给定的选项，也可以与嵌入式服务器库一起使用。在数组中，可将服务器选项作为参量指定给用于初始化服务器的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节，“使用选项文件”。

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

示例：1

test1_libmysqld.c

#include <stdio.h>

#include <stdlib.h>

#include <stdarg.h>

#include "mysql.h"

MYSQL *mysql;

MYSQL_RES *results;

MYSQL_ROW record;

static char *server_options[] = { "mysql_test", "--defaults-file=my.cnf" };

int num_elements = sizeof(server_options)/ sizeof(char *);

static char *server_groups[] = { "libmysqld_server", "libmysqld_client" };

int main(void)

{

   mysql_server_init(num_elements, server_options, server_groups);

   mysql = mysql_init(NULL);

   mysql_options(mysql, MYSQL_READ_DEFAULT_GROUP, "libmysqld_client");

   mysql_options(mysql, MYSQL_OPT_USE_EMBEDDED_CONNECTION, NULL);

   mysql_real_connect(mysql, NULL,NULL,NULL, "database1", 0,NULL,0);

   mysql_query(mysql, "SELECT column1, column2 FROM table1");

   results = mysql_store_result(mysql);

   while((record = mysql_fetch_row(results))) {

      printf("%s - %s \n", record[0], record[1]);

   }

   mysql_free_result(results);

   mysql_close(mysql);

   mysql_server_end();

   return 0;

}

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

gcc test1_libmysqld.c -o test1_libmysqld -lz \

 `/usr/local/mysql/bin/mysql_config --include --libmysqld-libs`

示例：2

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

test2_libmysqld.c

/*

 * A simple example client, using the embedded MySQL server library

*/

#include <mysql.h>

#include <stdarg.h>

#include <stdio.h>

#include <stdlib.h>

MYSQL *db_connect(const char *dbname);

void db_disconnect(MYSQL *db);

void db_do_query(MYSQL *db, const char *query);

const char *server_groups[] = {

  "test2_libmysqld_SERVER", "embedded", "server", NULL

};

int

main(int argc, char **argv)

{

  MYSQL *one, *two;

  /* mysql_server_init() must be called before any other mysql

   * functions.

   *

   * You can use mysql_server_init(0, NULL, NULL), and it

   * initializes the server using groups = {

   *   "server", "embedded", NULL

   *  }.

   *

   * In your $HOME/.my.cnf file, you probably want to put:

[test2_libmysqld_SERVER]

language = /path/to/source/of/mysql/sql/share/english

   * You could, of course, modify argc and argv before passing

   * them to this function.  Or you could create new ones in any

   * way you like.  But all of the arguments in argv (except for

   * argv[0], which is the program name) should be valid options

   * for the MySQL server.

   *

   * If you link this client against the normal mysqlclient

   * library, this function is just a stub that does nothing.

   */

  mysql_server_init(argc, argv, (char **)server_groups);

  one = db_connect("test");

  two = db_connect(NULL);

  db_do_query(one, "SHOW TABLE STATUS");

  db_do_query(two, "SHOW DATABASES");

  mysql_close(two);

  mysql_close(one);

  /* This must be called after all other mysql functions */

  mysql_server_end();

  exit(EXIT_SUCCESS);

}

static void

die(MYSQL *db, char *fmt, ...)

{

  va_list ap;

  va_start(ap, fmt);

  vfprintf(stderr, fmt, ap);

  va_end(ap);

  (void)putc(‘\n‘, stderr);

  if (db)

    db_disconnect(db);

  exit(EXIT_FAILURE);

}

MYSQL *

db_connect(const char *dbname)

{

  MYSQL *db = mysql_init(NULL);

  if (!db)

    die(db, "mysql_init failed: no memory");

  /*

   * Notice that the client and server use separate group names.

   * This is critical, because the server does not accept the

   * client‘s options, and vice versa.

   */

  mysql_options(db, MYSQL_READ_DEFAULT_GROUP, "test2_libmysqld_CLIENT");

  if (!mysql_real_connect(db, NULL, NULL, NULL, dbname, 0, NULL, 0))

    die(db, "mysql_real_connect failed: %s", mysql_error(db));

  return db;

}

void

db_disconnect(MYSQL *db)

{

  mysql_close(db);

}

void

db_do_query(MYSQL *db, const char *query)

{

  if (mysql_query(db, query) != 0)

    goto err;

  if (mysql_field_count(db) > 0)

  {

    MYSQL_RES   *res;

    MYSQL_ROW    row, end_row;

    int num_fields;

    if (!(res = mysql_store_result(db)))

      goto err;

    num_fields = mysql_num_fields(res);

    while ((row = mysql_fetch_row(res)))

    {

      (void)fputs(">> ", stdout);

      for (end_row = row + num_fields; row < end_row; ++row)

        (void)printf("%s\t", row ? (char*)*row : "NULL");

      (void)fputc(‘\n‘, stdout);

    }

    (void)fputc(‘\n‘, stdout);

    mysql_free_result(res);

  }

  else

    (void)printf("Affected rows: %lld\n", mysql_affected_rows(db));

  return;

err:

  die(db, "db_do_query failed: %s [%s]", mysql_error(db), query);

}

GNUmakefile

# This assumes the MySQL software is installed in /usr/local/mysql

inc      := /usr/local/mysql/include/mysql

lib      := /usr/local/mysql/lib

# If you have not installed the MySQL software yet, try this instead

#inc      := $(HOME)/mysql-5.1/include

#lib      := $(HOME)/mysql-5.1/libmysqld

CC       := gcc

CPPFLAGS := -I$(inc) -D_THREAD_SAFE -D_REENTRANT

CFLAGS   := -g -W -Wall

LDFLAGS  := -static

# You can change -lmysqld to -lmysqlclient to use the

# client/server library

LDLIBS    = -L$(lib) -lmysqld -lz -lm -lcrypt

ifneq (,$(shell grep FreeBSD /COPYRIGHT 2>/dev/null))

# FreeBSD

LDFLAGS += -pthread

else

# Assume Linux

LDLIBS += -lpthread

endif

# This works for simple one-file test programs

sources := $(wildcard *.c)

objects := $(patsubst %c,%o,$(sources))

targets := $(basename $(sources))

all: $(targets)

clean:

        rm -f $(targets) $(objects) *.core