C++ Socket庫與數據庫交互

在C++中，使用Socket庫與數據庫進行交互通常涉及到網絡通信和數據庫操作兩個部分。這里以MySQL數據庫為例，介紹如何使用C++ Socket庫與MySQL數據庫進行交互。

1. 安裝MySQL C++驅動程序

首先，需要在項目中包含MySQL C++驅動程序。可以通過以下方式安裝：

• 從MySQL官方網站下載MySQL Connector/C++庫，并將其添加到項目中。
• 使用包管理器（如apt、yum等）安裝MySQL Connector/C++庫。

2. 創建Socket客戶端

接下來，創建一個Socket客戶端，用于與MySQL數據庫服務器建立連接。以下是一個簡單的Socket客戶端示例：

#include <iostream>
#include <string>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <mysql.h>

int main() {
    int sockfd = socket(AF_INET, SOCK_STREAM, 0);
    if (sockfd < 0) {
        std::cerr << "socket() error" << std::endl;
        return 1;
    }

    struct sockaddr_in server_addr;
    memset(&server_addr, 0, sizeof(server_addr));
    server_addr.sin_family = AF_INET;
    server_addr.sin_port = htons(3306);
    inet_pton(AF_INET, "127.0.0.1", &server_addr.sin_addr);

    if (connect(sockfd, (struct sockaddr *)&server_addr, sizeof(server_addr)) < 0) {
        std::cerr << "connect() error" << std::endl;
        return 1;
    }

    // 在這里添加與數據庫交互的代碼

    close(sockfd);
    return 0;
}

3. 與數據庫交互

在上面的示例中，我們已經創建了一個Socket客戶端并與MySQL數據庫服務器建立了連接。接下來，我們需要使用MySQL C++驅動程序與數據庫進行交互。以下是一個簡單的示例，展示了如何使用C++ Socket客戶端連接到MySQL數據庫并執行查詢：

#include <iostream>
#include <string>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <mysql.h>

int main() {
    int sockfd = socket(AF_INET, SOCK_STREAM, 0);
    if (sockfd < 0) {
        std::cerr << "socket() error" << std::endl;
        return 1;
    }

    struct sockaddr_in server_addr;
    memset(&server_addr, 0, sizeof(server_addr));
    server_addr.sin_family = AF_INET;
    server_addr.sin_port = htons(3306);
    inet_pton(AF_INET, "127.0.0.1", &server_addr.sin_addr);

    if (connect(sockfd, (struct sockaddr *)&server_addr, sizeof(server_addr)) < 0) {
        std::cerr << "connect() error" << std::endl;
        return 1;
    }

    // 設置MySQL用戶名和密碼
    const char *user = "your_username";
    const char *password = "your_password";

    // 創建MySQL C++驅動程序對象
    mysql::mysql_connection con(sockfd);
    con.set_option(mysql::connect_option::host, "127.0.0.1");
    con.set_option(mysql::connect_option::user, user);
    con.set_option(mysql::connect_option::password, password);
    con.set_option(mysql::connect_option::database, "your_database");

    // 執行查詢
    std::string query = "SELECT * FROM your_table";
    mysql::query(con, query);

    // 獲取查詢結果
    mysql::result res = mysql::store_result(con);

    // 遍歷查詢結果并輸出
    for (unsigned int i = 0; i < res.affected_rows(); ++i) {
        mysql::row row = res[i];
        for (unsigned int j = 0; j < row.size(); ++j) {
            std::cout << row[j] << " ";
        }
        std::cout << std::endl;
    }

    // 釋放結果集
    res.clear();

    // 關閉連接
    con.close();

    close(sockfd);
    return 0;
}

請注意，這個示例僅用于演示目的，實際應用中可能需要處理更多的錯誤情況和異常。在實際項目中，建議使用更高級別的庫（如Boost.Asio）來處理Socket通信，以提高代碼的可讀性和可維護性。