MySQL 数据库应用程序编程

普通用户使用客户端应用程序(Client Application)和服务器程序(Server Application)通信以取得服务, 而服务器程序通常要和数据库服务器通信以取得数据存取服务, 这时就需要使用到使用到数据库连接技术, 我本人将使用数据库连接技术编程, 称为数据库应用程序编程, 更多时候的数据库应用程序编程依赖数据库发行商提供的驱动程序或接口模块.

MySQL 为程序员提供了多种编程语言的接口, 如使用 C 语言编程, 则可以下载 MySQL Connector C 套件, 解压后得到 include 目录下的头文件, 和 lib 目录下的共态链接库 libmysql.dll, 该动态链接库 的导入库libmysql.lib, 以及静态对象库 mysqlclient.lib, 显然, 使用动态链接库的编译速度更快.

关于这些 API 的使用方法, 请参考官方文档, 下面是一个演示.

#include <Windows.h>
#include <stdio.h>
#include <stdlib.h>
#include <tchar.h>
#include <assert.h>
#include <C:Program FilesMySQLMySQL Connector C 6.1includemysql.h>

#pragma comment(lib, "C:\Program Files\MySQL\MySQL Connector C 6.1\lib\libmysql.lib")

void Todo(MYSQL *mysql) {

    const char *a = mysql_stat(mysql);
    printf("数据库连接状态:
"
        "%s
", a);

    // 创建一个数据库
    char cmd[1024];
    sprintf(cmd, "CREATE DATABASE `my_test_db`");

    if (mysql_query(mysql, cmd) != EXIT_SUCCESS) {
        printf("创建失败!
"
            "%d: %s
", mysql_errno(mysql), mysql_error(mysql));
    } else {
        printf("创建成功!
");
    }

    // 选择数据库
    sprintf(cmd, "USE `my_test_db`");
    if (mysql_query(mysql, cmd) != EXIT_SUCCESS) {
        printf("选择失败!
"
            "%d: %s
", mysql_errno(mysql), mysql_error(mysql));
        return ;
    } else {
        printf("选择了表!
");
    }

    // 创建表
    sprintf(cmd, "CREATE TABLE `t`("
        "ID INT NOT NULL AUTO_INCREMENT,"
        "Name VARCHAR(20) NOT NULL,"
        "PRIMARY KEY(ID)"
        ")");
    if (mysql_query(mysql, cmd) != EXIT_SUCCESS) {
        printf("创建失败!
"
            "%d: %s
", mysql_errno(mysql), mysql_error(mysql));
    }

    // 查看表型
    sprintf(cmd, "DESC `t`");
    if (mysql_query(mysql, cmd) != EXIT_SUCCESS) {

        printf("查看失败!
"
            "%d: %s
", mysql_errno(mysql), mysql_error(mysql));

    } else {

        // 取结果集
        MYSQL_RES *res;
        res = mysql_store_result(mysql);

        if (res == NULL) {
            printf("查询没有返回结果
");
        } else {

            int fc = mysql_field_count(mysql);
            printf("字段数量: %u.
", fc);
            // 一行一行地取结果
            MYSQL_ROW row;
            while (row = mysql_fetch_row(res)) {
                int i = 0;
                for (; i < fc; i++) {
                    printf("|%s	", row[i] != NULL ? row[i] : "NULL");
                }
                printf("
");
            }
        }
    }
}

void Test() {

    // 初始化 MySQL 客户端模块
    assert(mysql_library_init(0, NULL, NULL) == EXIT_SUCCESS);

    // 获取数据库描述符
    MYSQL *mysql = NULL;
    mysql = mysql_init(mysql);
    // 连接数据库
    if (mysql_real_connect(mysql, "localhost", "root", "passwd", NULL, 3306, NULL, 0) == NULL) {
        printf("连接失败!
");
        printf("%d: %s
", mysql_errno(mysql), mysql_error(mysql));
    }

    // 你想用数据库做些什么事情?
    Todo(mysql);

    // 关闭数据库连接
    mysql != 0 ? mysql_close(mysql) : 0;
    // 释放模块
    mysql_library_end();
}

int APIENTRY _tWinMain(HINSTANCE hInst, HINSTANCE hPrev, LPTSTR lpszCmdLine, int iCmdShow) {

    // 分配控制台
    AllocConsole();

    // 
    Test();

    printf("
"
        "The end.
");

    // 消息循环
    MSG msg;
    while (GetMessage(&msg, NULL, 0, 0) > 0) {
        TranslateMessage(&msg);
        DispatchMessage(&msg);
    }

    return EXIT_SUCCESS;
}    

第一次运行:

再次运行: