c++操作mysql

1 需要安裝mysql客戶端

安裝mysql

2 查看依賴

mysql_config --cflags --libs

安裝依賴：yum install mysql-devel

3 導入頭文件

#include <mysql.h>

4 相關代碼

#include <stdio.h>
#include <mysql.h>

#define HOST "localhost"
#define USERNAME "root"
#define PASSWORD ""
#define DATABASE "test"

void insert_sql(char * sql);
void query_sql(char* sql);

int main(int argc,char *argv[])
{
    //insert_sql("insert into test values('user','123456')");
    query_sql("select * from test");
    return 0;
}

void insert_sql(char * sql)
{
    MYSQL conn;
    int res;
    mysql_init(&conn);
    if(mysql_real_connect(&conn,"localhost","root","","test",0,NULL,CLIENT_FOUND_ROWS))
    {
    printf("connect success!\n");
    res=mysql_query(&conn,sql);
    if(res)
    {
        printf("error\n");
    }
    else
    {
        printf("OK\n");
    }
    mysql_close(&conn);
    }

}

void query_sql(char* sql) 
{
    MYSQL my_connection; /*這是一個數據庫連接*/
    int res; /*執行sql語句后的返回標志*/
    MYSQL_RES *res_ptr; /*指向查詢結果的指針*/
    MYSQL_FIELD *field; /*字段結構指針*/
    MYSQL_ROW result_row; /*按行返回的查詢信息*/

    int row, column; /*查詢返回的行數和列數*/
    int i, j; /*只是控制循環的兩個變量*/

    /*初始化mysql連接my_connection*/
    mysql_init(&my_connection);

    /*這里就是用了mysql.h里的一個函數，用我們之前定義的那些宏建立mysql連接，並
     *     返回一個值，返回不為空證明連接是成功的*/
    if (mysql_real_connect(&my_connection, HOST, USERNAME, PASSWORD, DATABASE, 0, NULL, CLIENT_FOUND_ROWS)) 
    {
    /*連接成功*/
    printf("數據庫查詢query_sql連接成功！\n");
    /*這句話是設置查詢編碼為utf8，這樣支持中文*/
    mysql_query(&my_connection, "set names utf8");

    /*下面這句話就是用mysql_query函數來執行我們剛剛傳入的sql語句，
     *         這會返回一個int值，如果為0，證明語句執行成功*/
    res = mysql_query(&my_connection, sql);

    if (res) 
    { /*現在就代表執行失敗了*/
        printf("Error： mysql_query !\n");
        /*不要忘了關閉連接*/
        mysql_close(&my_connection);
    }
    else 
    { 
        /*現在就代表執行成功了*/
        /*將查詢的結果給res_ptr*/
        res_ptr = mysql_store_result(&my_connection);

        /*如果結果不為空，就把結果print*/
        if (res_ptr) 
        {
        /*取得結果的行數和*/
        column = mysql_num_fields(res_ptr);
        row = mysql_num_rows(res_ptr) + 1;
        printf("查詢到 %lu 行 \n", row);

        /*輸出結果的字段名*/
        for (i = 0; field = mysql_fetch_field(res_ptr); i++)
            printf("%s\t", field->name);
        printf("\n");

        /*按行輸出結果*/
        for (i = 1; i < row; i++)
        {
            result_row = mysql_fetch_row(res_ptr);
            for (j = 0; j < column; j++)
            printf("%s\t", result_row[j]);
            printf("\n");  
        }  

        }  
        mysql_free_result(res_ptr);
        /*不要忘了關閉連接*/  
        mysql_close(&my_connection); 
        /*釋放資源*/
        mysql_library_end();
    }  
    }  
} 

5  編譯

g++ testmysql.cpp `mysql_config --cflags --libs` -o test

 

參考資料：

https://www.cnblogs.com/wunaozai/p/3618383.html

http://blog.csdn.net/fykhlp/article/details/5950485#