C++使用Mysql的詳細步驟及各個常用方法的代碼演示：select,insert,update,delete

這幾天一直在學習C++下使用Mysql的方法及其中各種的問題，也看了很多Mysql的API函數，當然自己看的還是很基礎的。其實對於每種數據庫的操作，基本的方法都是非常類似的，大多都是connect,select,update,delete以及insert這幾個操作。接下來我就將這幾個步驟以代碼的方式展現給大家，相信應該能對大家對mysql的編程起到一個基礎模板的作用，方便大家以后對mysql數據庫的了解和學習。

1.mysql的初始化initConnection:

1)mysql_init():初始化數據庫

2)mysql_real_connect()(不推薦用Mysql_connect())：連接數據庫

詳細代碼如下：

bool dataBase::initConnection() {
    try {
        if (mysql_init(&m_sqlCon) == NULL) {
            std::cout << "初始化數據庫失敗" << std::endl;
            return false;
        }
        // localhost:服務器 root為賬號密碼 test為數據庫名 3306為端口    
        if (!mysql_real_connect(&m_sqlCon, host, user, pass,databaseName, port, NULL, 0))
        {
            std::cout << "數據庫連接失敗" << std::endl;
            return false;
        }
        std::cout << "數據庫連接成功" << std::endl;
        return true;
    }
    catch (...)
    {
        std::cout << "出錯啦" << std::endl;
        return false;
    }
}

2.mysql的查詢select：

1）mysql_query()：進行查詢語句

2）mysql_store_result()：獲得查詢結果

3)mysql_fetch_field()以及mysql_fetch_row()：獲得結果集中的內容

4）mysql_free_result()

代碼如下：

void dataBase::user_query() {
    if (mysql_query(&m_sqlCon, "select * from user")) {
        std::cout << "查詢失敗" << std::endl;
        return;
    }
    std::cout << "查詢成功" << std::endl;
    MYSQL_RES *result;
    result = mysql_store_result(&m_sqlCon);
    if (result) {
        int row_num,col_num;
        row_num = mysql_num_rows(result);
        col_num = mysql_num_fields(result);
        std::cout << "共有" << row_num << "條數據，以下為其詳細內容：" << std::endl;
        MYSQL_FIELD *fd;
        while (fd = mysql_fetch_field(result)) {
            std::cout << fd->name << "\t";
        }
        std::cout << std::endl;
        MYSQL_ROW sql_row;
        while (sql_row = mysql_fetch_row(result)) {
            for (int i = 0; i < col_num; i++) {
                if (sql_row[i] == NULL) std::cout << "NULL\t";
                else std::cout << sql_row[i] << "\t";
            }
            std::cout << std::endl;
        }
    }
    if(result!=NULL)
    mysql_free_result(result);

}

3.mysql的插入語句insert:

1）mysql_query()通過select判斷是否已經存在（可以省略）

2)通過mysql_query()進行插入

代碼如下：

void dataBase::user_insert(UserBody &body) {
    char select_user[255];
    char query[255];
    MYSQL_RES *result;
    sprintf(select_user, "select * from user where UserName='%s'", body.userName);
    if (mysql_query(&m_sqlCon, select_user)||!(result = mysql_store_result(&m_sqlCon))) {
        std::cout << "插入查詢失敗" << std::endl;
        return;
    }
    if (mysql_num_rows(result)) {
        std::cout << "用戶已存在" << std::endl;
        mysql_free_result(result);
        return;
    }
    mysql_free_result(result);
    sprintf(query, "insert into user(UserName,UserPass,ConnectionNum,UseFor) values('%s','%s',%d,%d)", body.userName, body.userPass, body.connection, body.type);
    if (mysql_query(&m_sqlCon, query)) {
        std::cout << "插入數據失敗" << std::endl;
        return;
    }
    std::cout << "插入數據成功,共插入：" <<mysql_affected_rows(&m_sqlCon)<<"行" << std::endl;
}

4.mysql的修改語句update

修改與添加的步驟類似，直接貼出代碼就不做贅述了。

代碼如下：

void dataBase::user_update(UserBody &body) {
    char query[255];
    char select_user[255];
    MYSQL_RES *result;
    sprintf(select_user, "select * from user where UserName='%s'", body.userName);
    if (mysql_query(&m_sqlCon, select_user) || !(result = mysql_store_result(&m_sqlCon))) {
        std::cout << "修改查詢失敗" << std::endl;
        return;
    }
    if (mysql_num_rows(result) == 0) {
        std::cout << "要修改的用戶不存在" << std::endl;
        mysql_free_result(result);
        return;
    }
    mysql_free_result(result);
    sprintf(query, "update user set UserPass='%s',ConnectionNum=%d,UseFor=%d where UserName='%s'", body.userPass, body.connection, body.type, body.userName);
    if (mysql_query(&m_sqlCon, query)) {
        std::cout << "修改失敗" << std::endl;
        return;
    }
    std::cout << "修改成功，共修改：" << mysql_affected_rows(&m_sqlCon) << "行" << std::endl;
}

 

5.mysql的刪除操作delete

其實刪除、修改和插入操作都是類似的，會其中一個其他應該都差不多了，我也就直接貼出代碼了。

代碼如下：

void dataBase::user_delete(char *userName) {
    char query[255];
    char select_user[255];
    MYSQL_RES *result;
    sprintf(select_user, "select * from user where UserName='%s'", userName);
    if (mysql_query(&m_sqlCon, select_user)||!(result = mysql_store_result(&m_sqlCon))) {
        std::cout << "刪除查詢失敗" << std::endl;
        return;
    }
    if (mysql_num_rows(result)==0) {
        std::cout << "要刪除的用戶不存在" << std::endl;
        mysql_free_result(result);
        return;
    }
    mysql_free_result(result);
    sprintf(query, "delete from user where UserName='%s'", userName);
    if (mysql_query(&m_sqlCon, query)) {
        std::cout << "刪除失敗" << std::endl;
        return;
    }
    std::cout << "刪除成功，共刪除：" << mysql_affected_rows(&m_sqlCon) << "行" << std::endl;
}

 

以上算是對Mysql中常用的一些代碼的總結，有什么不完善的希望大家能夠提出來，也希望這個能在平時幫到大家，起到一個模板的作用，也能方便大家對mysql的學習。我也屬於一個learner，也希望能和大家在平時中相互學習。

轉載請注明出處：http://www.cnblogs.com/fnlingnzb-learner/p/5829556.html。謝謝