поиск:
Полезные ссылки

  • Форум по MySQL

  • Статьи по MySQL

  • Вопросы по MySQL

  • MySQL.com


  • Базы данных

  • MySQL

  • PostgreSQL


  • PHP конференция 2005
    Подробности!

    8.4.9.6. Пример простого встраиваемого сервера

    Этот пример программы и сборочного файла должен работать без каких-либо изменений под операционными системами Linux или FreeBSD. Для других операционных систем потребуются небольшие изменения. При разработке данного примера мы ставили перед собой цель предоставить достаточно информации для понимания рассматриваемой темы и в то же время не перегружать текст руководства лишними деталями, специфическими для реального приложения.

    Чтобы запустить этот пример, создайте каталог test_libmysqld там же, где находится каталог исходного кода mysql-4.0. Сохраните исходный код test_libmysqld.c и GNUmakefile в данном каталоге и запустите GNU make в каталоге test_libmysqld.

    test_libmysqld.c

    /*
    * Клиент простого примера с использованием библиотеки встраиваемого
    сервера MySQL
    */
    #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[] = {
        "test_libmysqld_SERVER", "embedded", "server", NULL
    };
    int
    main(int argc, char **argv)
    {
      MYSQL *one, *two;
      /* Функцию mysql_server_init() необходимо вызывать перед любыми другими *
      функциями mysql.
      * Можно задать mysql_server_init(0, NULL, NULL); тогда для
      * инициализации сервера будут использоваться группы "server",
      * "embedded", NULL
      *}.
      *
      * В файле $HOME/.my.cnf можно указать:
    [test_libmysqld_SERVER]
    language = /path/to/source/of/mysql/sql/share/english
    * Можно было бы, конечно, модифицировать argc и argv непосредственно
      * перед передачей их в эту функцию или создать
      * новые аргументы - для этого годится любой выбранный вами способ.
      * Однако все аргументы в argv (кроме argv[0], который
      * представляет собой имя программы) должны быть допустимыми опциями
      * для сервера MySQL.
      *
      * Если данный клиент линкуется с нормальной библиотекой mysqlclient,
      * то эта функция является просто заглушкой, ничего не делающей.
      */
    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);
    /* Эта функция должна вызываться после всех других функций mysql */
    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");
    /*
    * Обратите внимание: клиент и сервер используют разные имена групп.
    * Это обязательное условие, поскольку сервер не должен использовать опции
    * клиента и наоборот.
    */
    mysql_options(db, MYSQL_READ_DEFAULT_GROUP, "test_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);
    }
    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

    # Предполагается, что программное обеспечение MySQL установлено в
    #/usr/local/mysql
    inc := /usr/local/mysql/include/mysql
    lib := /usr/local/mysql/lib
    # Если программное обеспечение MySQL еще не установлено, сделайте такую
    замену:
    #inc := $(HOME)/mysql-4.0/include
    #lib := $(HOME)/mysql-4.0/libmysqld
    CC := gcc
    CPPFLAGS := -I$(inc) -D_THREAD_SAFE -D_REENTRANT
    CFLAGS := -g -W -Wall
    LDFLAGS := -static
    # Можно изменить -lmysqld на -lmysqlclient для того, чтобы использовать
    # обычную клиент-серверную библиотеку
    LDLIBS = -L$(lib) -lmysqld -lz -lm -lcrypt
    ifneq (,$(shell grep FreeBSD /COPYRIGHT 2>/dev/null))
    # Для FreeBSD
    LDFLAGS += -pthread
    else
    # Предполагается Linux
    LDLIBS += -lpthread
    endif
    # Это работает для простых однофайловых тестовых программ
    sources := $(wildcard *.c)
    objects := $(patsubst %c,%o,$(sources))
    targets := $(basename $(sources))
    all: $(targets)
    clean:
    rm -f $(targets) $(objects) *.core
    

     
    © 1997-2005 PHP Club Team
    Rambler's Top100