C++操作mysql数据库范例代码

#include <my_global.h>
#include <mysql.h>
 
void TestMySQL()
{
    TRACE("MySQL client version: %s\n", mysql_get_client_info());
 
    MYSQL *conn = mysql_init(NULL);
    if (conn == NULL) {
        TRACE("Error %u: %s\n", mysql_errno(conn), mysql_error(conn));
    }
 
    if (mysql_real_connect(conn, "127.0.0.1", "user", "pass", "testdb", 0, NULL, 0) == NULL) {
        TRACE("Error %u: %s\n", mysql_errno(conn), mysql_error(conn));
    }
 
    mysql_query(conn, "set names utf8");
 
    // SELECT
    mysql_query(conn, "SELECT * FROM nihongo");
    MYSQL_RES *result = mysql_store_result(conn);
 
    int num_fields = mysql_num_fields(result);
 
    CString str = _T("");
    wchar_t bufUnicode[MAX_PATH];
    char bufUTF8[MAX_PATH];
 
    MYSQL_ROW row;
    while ((row = mysql_fetch_row(result))) {
        for (int i = 0; i < num_fields; i++) {
            if (row[i] == NULL) {
                TRACE("NULL ");
                continue;
            }
 
            int iLenUnicode = MultiByteToWideChar(CP_UTF8, 0, row[i], -1, NULL, 0);
            if (iLenUnicode <= sizeof(bufUnicode)/sizeof(bufUnicode[0])) {
                MultiByteToWideChar(CP_UTF8, 0, row[i], -1, bufUnicode, MAX_PATH);
                str += bufUnicode;
                str += _T(", ");
            }
        }
 
        TRACE("\n");
    }
 
    mysql_free_result(result);
 
    // INSERT
    CTime now = CTime::GetCurrentTime();
    CString s_now = now.Format(_T("%Y-%m-%d %H:%M:%S"));
    CString insert = _T("INSERT INTO nihongo VALUES('本日は") + s_now + _T("です')");
    wchar_t *p = insert.GetBuffer();
 
    int iLenUtf8 = WideCharToMultiByte(CP_UTF8, 0, p, -1, NULL, 0, NULL, NULL);
    if (iLenUtf8 <= sizeof(bufUTF8)) {
        WideCharToMultiByte(CP_UTF8, 0, p, -1, bufUTF8, sizeof(bufUTF8), NULL, NULL);
        mysql_query(conn, bufUTF8);
    }
 
    insert.ReleaseBuffer();
 
    mysql_close(conn);
 
    AfxMessageBox(str);
}