封裝MySQLAPI

我們先把初始化句柄和斷開句柄進行一個封裝

static MYSQL* MySQLInit(){ //1.初始化一個Mysql句柄建立連接 MYSQL* connect_fd = mysql_init(NULL); //2.和數據庫建立連接 if (mysql_real_connect(connect_fd, "127.0.0.1", "root", "123456", "blog_system", 3306, NULL, 0) == NULL) { printf("連接失敗! %s\n", mysql_error(connect_fd)); return NULL; } //3.設置字符編碼集 mysql_set_character_set(connect_fd, "utf8"); return connect_fd; } static void MySQLRelease(MYSQL* mysql) { //釋放句柄并斷開連接 mysql_close(mysql); }

博客表操作的實現

接下來的實現操作，我們需要借助一個庫，這個庫是Json庫，
大概了解一下Json
上面哪個鏈接可以大概了解Json，json 出自 JavaScript, 是一種非常方便的鍵值對數據組織格式, 目前被業界廣泛使用.
C++ 中可以使用 jsoncpp 這個庫來解析和構造 json 數據。但是我們并不用里面提到的CJson的庫，我們是用Linux下yum源中的Json庫，可以通過下面這個命令進行下載

yum install jsoncpp-devel

以下的操作相關參數都同一使用Json的方式
Json::Value jsoncpp中最核心的類，Json::Value 就表示一個具體的對象，例如我們之前設計的API

{title:"博客標題",content:"博客正文",create_time:"創建時間",tag_id:"標簽id" }

為什么我們要使用Json這個庫呢？
其實最大的好處就是方便我們以后進行功能上的擴展
Json可以跨語言編程

實現插入博客

我們需要把博客對象傳進去，因為一些特赦字符的原因，我們先進行轉義，然后進行申請空間，這里使用智能指針來幫助我們管理內存，我們就不必在考慮其中的釋放問題。最后拼裝sql語句并進行返回值校驗
智能指針原理

bool Insert(const Json::Value& blog) { // 由于博客內容中可能包含一些特殊字符(\n, '', "" 等), 會導致拼裝出的 sql 語句有問題. // 應該使用 mysql_real_escape_string 對 content 字段來進行轉義 // 轉義只是為了讓 SQL 語句拼接正確. 實際上插入成功后數據庫的內容已經自動轉義回來了. const std::string& content = blog["content"].asString(); // 文檔上要求轉義的緩沖區長度必須是之前的 2 倍 + 1 // 使用 unique_ptr 管理內存 std::unique_ptr<char> content_escape(new char[content.size() * 2 + 1]); mysql_real_escape_string(mysql_, content_escape.get(), content.c_str(), content.size()); // 插入的博客內容可能較長, 需要搞個大點的緩沖區(根據用戶請求的長度自適應), std::unique_ptr<char> sql(new char[content.size() * 2 + 4096]); sprintf(sql.get(), "insert into blog_table values(null, '%s', '%s', %d,'%s')", blog["title"].asCString(), content_escape.get(), blog["tag_id"].asInt(), blog["create_time"].asCString()); int ret = mysql_query(mysql_, sql.get()); if (ret != 0) { printf("執行 sql 失敗! sql=%s, %s\n", sql.get(), mysql_error(mysql_)); return false; } return true; }

實現查詢所有博客

因為是獲取所有博客內容，我們需要一個返回的結果，blogs作為輸出型參數,除此之外我們還可以按照標簽來篩選，初始給標簽id默認為空，如果用戶提供標簽則進行篩選，沒有提供則不進行篩選，然后執行sql語句，并判斷是否成功，然后我們還需要對結果集合進行遍歷打印

bool SelectAll(Json::Value* blogs, const std::string& tag_id = "") { //查找不需要太長的sql，固定長度就行了 char sql[1024 * 4] = {0}; // 可以根據 tag_id 來篩選結果 if (tag_id == "") { //此時不需要按照標簽來進行篩選 sprintf(sql, "select blog_id, title, tag_id, create_time from blog_table"); } else { //此時我們就要按標簽進行篩選了 sprintf(sql, "select blog_id, title, tag_id, create_time from blog_table where tag_id = '%s'", tag_id.c_str()); } int ret = mysql_query(mysql_, sql); if (ret != 0) { printf("執行 查找 失敗! %s\n", mysql_error(mysql_)); return false; } MYSQL_RES* result = mysql_store_result(mysql_); if (result == NULL) { printf("獲取結果失敗! %s\n", mysql_error(mysql_)); return false; } int rows = mysql_num_rows(result); //把結果集合寫到blogs參數中，返回給調用者 for (int i = 0; i < rows; ++i) { MYSQL_ROW row = mysql_fetch_row(result); Json::Value blog; //row[]中的下標和上面的select語句中寫的列順序是相關的 blog["blog_id"] = atoi(row[0]); blog["title"] = row[1]; blog["tag_id"] = atoi(row[2]); blog["create_time"] = row[3]; // 遍歷結果依次加入到 dishes 中 blogs->append(blog); } printf("執行查找成功\n"); //mysql查詢的結果集合需要記得釋放 mysql_free_result(result); return 0;}

實現查詢單個博客

我們在查看單個博客時，blog同樣是輸出型參數，根據當前的blog_id在數據庫中找到具體的內容，博客內容通過blog參數返回給調用者。這回我們只需要拼接一條sql語句即可，然后再去遍歷結果集合就可以。

bool SelectOne(int32_t blog_id, Json::Value* blog) {char sql[1024 * 4] = {0};sprintf(sql, "select * from blog_table where blog_id = %d", blog_id);int ret = mysql_query(mysql_, sql);if (ret != 0) {printf("執行 sql 失敗! %s\n", mysql_error(mysql_));return false;}MYSQL_RES* result = mysql_store_result(mysql_);if (result == NULL) {printf("獲取結果失敗! %s\n", mysql_error(mysql_));return false;}int rows = mysql_num_rows(result);if (rows != 1) {printf("查找結果不為 1 條. rows = %d!\n", rows);return false;}MYSQL_ROW row = mysql_fetch_row(result);(*blog)["blog_id"] = atoi(row[0]);(*blog)["title"] = row[1];(*blog)["content"] = row[2];(*blog)["tag_id"] = atoi(row[3]);(*blog)["create_time"] = row[4];return true;}

實現更新博客

因為要更新博客，涉及到有關正文的操作，所以需要先轉義，然后申請空間再由智能指針管理

bool Update(const Json::Value& blog) { //此處還需要轉義， const std::string& content = blog["content"].asString(); std::unique_ptr<char> content_escape(new char[content.size() * 2 + 1]); mysql_real_escape_string(mysql_, content_escape.get(), content.c_str(), content.size()); //插入的博客內容會有點長，我們可以盡量把緩沖區變大點 std::unique_ptr<char> sql(new char[content.size() * 2 + 4096]); //拼接sql語句 sprintf(sql.get(), "update blog_table set title='%s', content='%s',tag_id=%d where blog_id=%d", blog["title"].asCString(), content_escape.get(), blog["tag_id"].asInt(), blog["blog_id"].asInt()); int ret = mysql_query(mysql_, sql.get()); if (ret != 0) { printf("執行更新博客 失敗! sql=%s, %s\n", sql.get(), mysql_error(mysql_)); return false; } printf("執行博客成功\n"); return true; }

實現刪除博客

bool Delete(int blog_id) {char sql[1024 * 4] = {0};sprintf(sql, "delete from blog_table where blog_id=%d", blog_id);int ret = mysql_query(mysql_, sql);if (ret != 0) {printf("執行刪除博客失敗! sql=%s, %s\n", sql, mysql_error(mysql_));return false;}printf("刪除博客成功\n");return true; }

對博客表操作進行單元測試

void TestBlogTable(){ //方便我們進行格式化結果，打印出來的結果更好看一些 Json::StyledWriter writer; MYSQL* mysql = blog_system::MySQLInit(); blog_system::BlogTable blog_table(mysql); bool ret = false; Json::Value blog; /* blog["title"] = "第一篇博客"; blog["content"] = "我要好好學習"; blog["tag_id"] = 1; blog["create_time"] = "2019/-/-"; bool ret = blog_table.Insert(blog); printf("Insert:%d\n",ret); */ //測試查找 /*Json::Value blogs; ret = blog_table.SelectAll(&blogs); printf("select ALl %d\n",ret); printf("%s\n",writer.write(blogs).c_str()); */ //測試查找單個博客 /*ret = blog_table.SelectOne(1,&blog); printf("select one %d\n",ret); printf("blog:%s\n",writer.write(blog).c_str());//序列化，方便我們看輸出 */ //測試修改博客/* blog["blog_id"] = 1;blog["title"] = "第一篇項目博客";blog["content"] = "1.博客表\n 博客'就是總結與學習',幫助我們記事。";ret = blog_table.Update(blog);printf("Update %d\n",ret);*///測試刪除博客ret = blog_table.Delete(1);printf("Delete %d\n",ret);blog_system::MySQLRelease(mysql); }

實現標簽表的操作

實現新增標簽

這塊我們還是跟博客表的操作是一樣的，都是拼裝sql語句，然后執行，判斷是否執行成功，打印提示。

bool Insert(const Json::Value& tag) { char sql[1024 * 4] = {0}; // 此處 dish_ids 需要先轉成字符串(本來是一個對象, // 形如 [1, 2, 3]. 如果不轉, 是無法 asCString) sprintf(sql,"insert into tag_table values(null, '%s')",tag["tag_name"].asCString()); int ret = mysql_query(mysql_, sql); if (ret != 0) { printf("插入標簽失敗! sql=%s, %s\n", sql, mysql_error(mysql_)); return false; } printf("插入標簽成功\n"); return true; }

實現刪除標簽

bool Delete(int32_t tag_id) { char sql[1024 * 4] = {0}; sprintf(sql, "delete from tag_table where tag_id = %d", tag_id); int ret = mysql_query(mysql_, sql); if (ret != 0) { printf("插入標簽失敗! sql=%s, %s\n", sql, mysql_error(mysql_)); return false; } printf("插入標簽成功\n"); return 0; }

實現查看所有標簽

bool SelectAll( Json::Value* tags) { char sql[1024 * 4] = {0}; sprintf(sql, "select * from tag_table"); int ret = mysql_query(mysql_, sql); if (ret != 0) { printf("查找失敗! %s\n", mysql_error(mysql_)); return false; } MYSQL_RES* result = mysql_store_result(mysql_); if (result == NULL) { printf("獲取結果失敗! %s\n", mysql_error(mysql_)); return false; } int rows = mysql_num_rows(result); for (int i = 0; i < rows; ++i) { MYSQL_ROW row = mysql_fetch_row(result); Json::Value tag; tag["tag_id"] = atoi(row[0]); tag["tag_name"] = row[1]; tags->append(tag); } printf("查找標簽成功!共找到 %d 個\n",rows); return true; }

對標簽操作進行單元測試

void TestTagTable(){ MYSQL* mysql = blog_system::MySQLInit(); blog_system::TagTable tag_table(mysql); Json::Value tags; Json::StyledWriter writer; /*tag["tag_name"] = "項目"; bool ret = tag_table.Insert(tag); printf("insert %d\n",ret); */ //測試查找 /* bool ret = tag_table.SelectAll(&tags); printf("select all %d\n",ret); printf("tags:%s\n",writer.write(tags).c_str()); */ //測試刪除 bool ret = tag_table.Delete(1); printf("Delete %d\n",ret); blog_system::MySQLRelease(mysql); }

總結

以上是生活随笔為你收集整理的私人博客定制----封装数据库接口的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。