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 Files\MySQL\MySQL Connector C 6.1\include\mysql.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("數據庫連接狀態:\n"
        "%s\n", a);

    // 創建一個數據庫
    char cmd[1024];
    sprintf(cmd, "CREATE DATABASE `my_test_db`");

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

    // 選擇數據庫
    sprintf(cmd, "USE `my_test_db`");
    if (mysql_query(mysql, cmd) != EXIT_SUCCESS) {
        printf("選擇失敗!\n"
            "%d: %s\n", mysql_errno(mysql), mysql_error(mysql));
        return ;
    } else {
        printf("選擇了表!\n");
    }

    // 創建表
    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("創建失敗!\n"
            "%d: %s\n", mysql_errno(mysql), mysql_error(mysql));
    }

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

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

    } else {

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

        if (res == NULL) {
            printf("查詢沒有返回結果\n");
        } else {

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

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("連接失敗!\n");
        printf("%d: %s\n", 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("\n"
        "The end.\n");

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

    return EXIT_SUCCESS;
}    

 

第一次運行:

再次運行: