程序師世界是廣大編程愛好者互助、分享、學習的平台,程序師世界有你更精彩!
首頁
編程語言
C語言|JAVA編程
Python編程
網頁編程
ASP編程|PHP編程
JSP編程
數據庫知識
MYSQL數據庫|SqlServer數據庫
Oracle數據庫|DB2數據庫
 程式師世界 >> 數據庫知識 >> MYSQL數據庫 >> MySQL綜合教程 >> libmysqld,嵌入式MySQL服務器庫

libmysqld,嵌入式MySQL服務器庫

編輯:MySQL綜合教程

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服務器使用的一些庫。 執行“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中,而不是單引號內。

25.1.3. 使用嵌入式MySQL服務器時的限制

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

· 不支持ISAM表。 (這樣做的主要目的是為了使庫更小)。

· 沒有自定義函數(UDF)。

· 沒有對核心轉儲的堆棧跟蹤。

· 沒有內部RAID支持。 (由於大多數當前操作系統均支持大文件,通常情況下不需要它)。

· 不能將其設置為“主”或“從”(無復制)。

· 在內存較低的系統上,可能無法使用很大的結果集。

· 不能使用套接字或TCP/IP從外部進程連接到嵌入式服務器。 但是,你可以連接到中間應用程序,隨後,該中間應用程序可代表遠程客戶端或外部進程連接到嵌入式服務器。

通過編輯“mysql_embed.h”包含文件並重新編譯MySQL,可更改某些限制。

25.1.4. 與嵌入式服務器一起使用的選項

對於任何能夠與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節,“使用選項文件”。

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

· 我們將提供一些選項以省去MySQL的某些部分,從而使庫變得更小。

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

· 錯誤將被寫入stderr。我們將增加1個選項為它們指定文件名。

· 使用嵌入式版本時,需要更改InnoDB,使之不再冗長。如果你的數據庫不含InnoDB表,要想抑制相關消息,可為組[libmysqd_server]下的選項文件增加“--skip-innodb”選項,或在用mysql_server_init()初始化服務器時添加該選項。

25.1.6. 嵌入式服務器示例

在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

  1. 上一頁:
  2. 下一頁:
Copyright © 程式師世界 All Rights Reserved