MySQL嵌入式版本的小程序例子

2019-07-13 03:34发布

MySQL嵌入式版本越来越式微了。碰巧有个小应用用到了它,顺便记录一下。
文档可以参考http://dev.mysql.com/doc/refman/5.6/en/libmysqld-example.html,看起来年久失修的样子,没法一看就懂。
希望下面这个简化的步骤可以起到点作用。
1. 下载代码并且进行版本编译。这个还比较简单,文档说的也很靠谱。
$ cmake . -DCMAKE_INSTALL_PREFIX=/home/mysql -DWITH_EMBEDDED_SERVER=1
$ make clean $ make -j 8 
$ make install

2. 写个小程序
$ ls
GNUmakefile  main.cc  my.cnf
具体代码就看附件好了,其实很简单。
$ make

3. 安装好MySQL,初始化一下
$ cd /home/mysql
$ scripts/mysql_install_db --defaults-file=/home/mysql/my.cnf

4. 启动小程序
$ ./main
附件: # 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 topdir := /home/mysql/mysql-5.5.35 inc := $(topdir)/include lib := $(topdir)/libmysqld CXX := g++ CPPFLAGS := -I$(inc) -D_THREAD_SAFE -D_REENTRANT CXXFLAGS := -g -Wall LDFLAGS := # You can change -lmysqld to -lmysqlclient to use the # client/server library LDLIBS = -L$(lib) -lmysqld -lm -lcrypt -ldl -lz -lrt ifneq (,$(shell grep FreeBSD /COPYRIGHT 2>/dev/null)) # FreeBSD LDFLAGS += -pthread else # Assume Linux LDLIBS += -pthread endif # This works for simple one-file test programs sources := $(wildcard *.cc) objects := $(patsubst %cc,%o,$(sources)) targets := $(basename $(sources)) all: $(targets) clean: rm -f $(targets) $(objects) *.core --- #include #include #include using namespace std; const char *server_options[] = { "mysql_test", "--defaults-file=my.cnf", NULL }; int num_elements = (sizeof(server_options) / sizeof(char *)) - 1; const char *server_groups[]= { "libmysqld_server", "libmysqld_client", NULL}; bool is_server_started= false; MYSQL *MySQL= NULL; const char *db= NULL; void start_server() { cout << "enter start_server()" << endl; if (mysql_library_init(num_elements, (char **) server_options, (char **) server_groups)) { is_server_started= false; cout << "ERROR: start server failed." << endl; } else { is_server_started= true; cout << "INFO: start server OK." << endl; } } void stop_server() { cout << "enter stop_server()" << endl; mysql_server_end(); } bool connect_server() { cout << "enter connect_server()" << endl; bool rc = true; MySQL = mysql_init(NULL); if (!MySQL) return rc; if (mysql_real_connect(MySQL, NULL, NULL, NULL, db, 0, NULL, 0)) rc = false; MySQL->reconnect= 1; return rc; } void output_rows(MYSQL_RES *res) { MYSQL_ROW row; unsigned long n = 0; while ((row= mysql_fetch_row(res)) != 0) { mysql_field_seek(res, 0); for (unsigned int i= 0 ; i < mysql_num_fields(res); i++) cout << "row[" << n++ << "]:"<< row[i] << endl; } } bool get_dbs() { MYSQL_RES *res; if (!is_server_started) return true; if (!(res= mysql_list_dbs(MySQL, "%"))) return true; output_rows(res); mysql_free_result(res); return false; } int main(int argc, char *argv[]) { start_server(); if (is_server_started) { cout << "server started." << endl; if (!connect_server()) { get_dbs(); } stop_server(); } return 0; } --- [libmysqld_client] [libmysqld_server] basedir=/home/mysql/ datadir=/home/mysql/data tmpdir=/home/mysql/tmp log-error=/home/mysql/alert.log lc_messages_dir=/home/mysql/share innodb_data_home_dir=/home/mysql/data innodb_log_group_home_dir=/home/mysql/data