🚀 Code Optimization with Jetbrains Clion

stepbystepcode · stepbystepcode · commit a6b924fa46ba · 2023-10-05T12:44:42.000+08:00
diff --git a/file_controller.cc b/file_controller.cc
@@ -1,15 +1,14 @@
 #include "file_controller.h"
 #include "jwt_controller.h"
 #include <json/json.h>
-#include <stdio.h>
+#include <cstdio>
 #include <mysql.h>
-#include <chrono>
 #include <iostream>
 #include <stdexcept>
 #include <string>
-std::string return_status(std::string result, std::string command,Json::Value &res_json)
+std::string return_status(std::string result, const std::string& command,Json::Value &res_json)
 {
-    if (result != ""){
+    if (!result.empty()){
         result = command + " success";
         res_json["code"] = 200;
     }
@@ -42,13 +41,13 @@ void add_lock(const HttpRequestPtr &req, std::function<void(const HttpResponsePt
 std::string shell_commands(const char *cmd)
 {
     char buffer[1280];
-    std::string result = "";
+    std::string result;
     FILE *pipe = popen(cmd, "r");
     if (!pipe)
         throw std::runtime_error("popen() failed!");
     try
     {
-        while (fgets(buffer, sizeof buffer, pipe) != NULL)
+        while (fgets(buffer, sizeof buffer, pipe) != nullptr)
         {
             result += buffer;
         }
@@ -115,9 +114,10 @@ void commandsCtrl(const HttpRequestPtr &req, std::function<void(const HttpRespon
             result = return_status(result, "mkdir",res_json);
             break;
         case touch:
-            if ("" == shell_commands(("ls  -l " + std::string(pathvar) + "/../root/" + params1 + " grep ^- ").c_str()))
+            if (shell_commands(("ls  -l " + std::string(pathvar) + "/../root/" + params1 + " grep ^- ").c_str()).empty())
             {
-                result = shell_commands(("touch " + std::string(pathvar) + "/../root/" + params1).c_str());
+                shell_commands(("touch " + std::string(pathvar) + "/../root/" + params1).c_str());
+                //result = shell_commands(("touch " + std::string(pathvar) + "/../root/" + params1).c_str());
                 result = "success";
                 res_json["code"] = 200;
             }
diff --git a/file_controller.h b/file_controller.h
@@ -14,6 +14,6 @@ void commandsCtrl(const HttpRequestPtr &req, std::function<void(const HttpRespon
 
 void add_lock(const HttpRequestPtr &req, std::function<void(const HttpResponsePtr &)> &&callback);
 //void return_status(std::string result);
-std::string return_status(std::string result, std::string command,Json::Value &res_json);
+std::string return_status(std::string result, const std::string& command,Json::Value &res_json);
 // std::string
 #endif
diff --git a/main.cc b/main.cc
@@ -1,12 +1,9 @@
 
-#include <drogon/drogon.h>
 #include "msg_controller.h"
 #include "user_controller.h"
 #include "file_controller.h"
-#include <drogon/WebSocketController.h>
 
 using namespace drogon;
-std::unordered_map<std::string, WebSocketConnectionPtr> clientTable;
 int main()
 {
     drogon::app().addListener("0.0.0.0", 8081);
diff --git a/msg_controller.cc b/msg_controller.cc
@@ -1,4 +1,3 @@
-#include <drogon/drogon.h>
 #include <json/json.h>
 #include "jwt_controller.h"
 #include "msg_controller.h"
diff --git a/mysql.cc b/mysql.cc
@@ -4,17 +4,15 @@
 #include "jdbc/mysql_driver.h"
 #include "json/json.h"
 
-void sql_unlocked(std::string DeleteName)
+void sql_unlocked(const std::string& DeleteName)
 {
     sql::mysql::MySQL_Driver *driver = sql::mysql::get_mysql_driver_instance();
     sql::Connection *con = driver->connect("tcp://8.130.48.157:3306", "root", "abc.123");
     con->setSchema("flypen");
     sql::Statement *stmt = con->createStatement();
     try
     {
-        std::string filename = DeleteName;
         std::string DeleteQuery = "DELETE FROM file WHERE filename = " + DeleteName;
-        int rowsDelete = stmt->executeUpdate(DeleteQuery);
     }
     catch (sql::SQLException &e)
     {
@@ -26,7 +24,7 @@ void sql_unlocked(std::string DeleteName)
 
 // relate to chat
 
-int sql_findexist(std::string receiver)
+int sql_findexist(const std::string& receiver)
 {
     sql::mysql::MySQL_Driver *driver = sql::mysql::get_mysql_driver_instance();
     sql::Connection *con = driver->connect("tcp://8.130.48.157:3306", "root", "abc.123");
@@ -42,7 +40,7 @@ int sql_findexist(std::string receiver)
     }
     return 0;
 }
-int lockcheck(std::string filename)
+int lockcheck(const std::string& filename)
 {
     sql::mysql::MySQL_Driver *driver = sql::mysql::get_mysql_driver_instance();
     sql::Connection *con = driver->connect("tcp://8.130.48.157:3306", "root", "abc.123");
@@ -87,7 +85,7 @@ void process(sql::PreparedStatement *readDatament, std::vector<std::string> s, s
     }
 }
 
-void sql_delete_operation(std::string sender, std::string receiver)
+void sql_delete_operation(const std::string& sender, const std::string& receiver)
 {
     sql::mysql::MySQL_Driver *driver = sql::mysql::get_mysql_driver_instance();
     sql::Connection *con = driver->connect("tcp://8.130.48.157:3306", "root", "abc.123");
@@ -102,7 +100,7 @@ void sql_delete_operation(std::string sender, std::string receiver)
     process(readDatament, s, con);
 }
 
-void sql_process_request(std::string sender, std::string receiver, std::string attitude)
+void sql_process_request(const std::string& sender, const std::string& receiver, const std::string& attitude)
 {
     std::vector<std::string> usernamelist;
     sql::mysql::MySQL_Driver *driver = sql::mysql::get_mysql_driver_instance();
@@ -135,7 +133,7 @@ void sql_process_request(std::string sender, std::string receiver, std::string a
     if (attitude == "allow")
     {
         std::string readData = "SELECT friends FROM users WHERE username = ?";
-        std::string *RS = new std::string[2]{receiver, sender}; // R, S
+        auto *RS = new std::string[2]{receiver, sender}; // R, S
 
         for (int i = 0; i < 2; i++)
         {
@@ -157,7 +155,7 @@ void sql_process_request(std::string sender, std::string receiver, std::string a
             std::string updateQuery = "UPDATE users SET friends = ? WHERE username = ?";
             sql::PreparedStatement *update = con->prepareStatement(updateQuery);
 
-            if (friendsList != "")
+            if (!friendsList.empty())
             {
                 friendsList += "," + RS[1 - i];
                 update->setString(1, friendsList);
@@ -178,10 +176,9 @@ void sql_process_request(std::string sender, std::string receiver, std::string a
     delete resultSet;
     delete readDatament;
     delete con;
-    return;
 }
 
-void sql_addrequest(std::string sender, std::string receiver)
+void sql_addrequest(const std::string& sender, const std::string& receiver)
 {
     std::vector<std::string> usernamelist;
 
@@ -208,7 +205,7 @@ void sql_addrequest(std::string sender, std::string receiver)
         std::string updateQuery = "UPDATE users SET req = ? WHERE username = ?";
         sql::PreparedStatement *updateStatement = con->prepareStatement(updateQuery);
 
-        if (req != "")
+        if (!req.empty())
         {
             req += "," + sender;
             updateStatement->setString(1, req);
@@ -229,28 +226,7 @@ void sql_addrequest(std::string sender, std::string receiver)
     delete con;
 }
 
-void sql_addconnect(std::string connectptr)
-{
-    try
-    {
-        sql::mysql::MySQL_Driver *driver = sql::mysql::get_mysql_driver_instance();
-        sql::Connection *con = driver->connect("tcp://8.130.48.157:3306", "root", "abc.123");
-        con->setSchema("flypen");
-
-        std::string classMysql = "INSERT INTO users(username, password, time, connection) VALUES (?, ?, NOW(), ?)";
-        sql::PreparedStatement *insertConnect = con->prepareStatement(classMysql);
-        insertConnect->setString(4, connectptr);
-
-        delete insertConnect;
-        delete con;
-    }
-    catch (sql::SQLException &e)
-    {
-        std::cerr << "SQL Exception: " << e.what() << std::endl;
-    }
-}
-
-void sql_addhistory(std::string sender, std::string receiver, std::string message, std::string isread)
+void sql_addhistory(const std::string& sender, const std::string& receiver, const std::string& message, const std::string& isread)
 {
     try
     {
@@ -278,7 +254,7 @@ void sql_addhistory(std::string sender, std::string receiver, std::string messag
 }
 
 // relate to user
-void sql_add(std::string username, std::string passwd, int avatar)
+void sql_add(const std::string& username, const std::string& passwd, int avatar)
 {
     try
     {
@@ -305,7 +281,7 @@ void sql_add(std::string username, std::string passwd, int avatar)
     }
 }
 
-Json::Value get_my_info(std::string me)
+Json::Value get_my_info(const std::string& me)
 {
     Json::Value json;
 
@@ -386,7 +362,7 @@ Json::Value get_my_info(std::string me)
     return json;
 }
 
-bool sql_check(std::string user, std::string passwd)
+bool sql_check(const std::string& user, const std::string& passwd)
 {
     bool result = false;
     try
@@ -410,7 +386,6 @@ bool sql_check(std::string user, std::string passwd)
             // 提取所有列的值
             std::string username = res->getString("username");
             std::string password = res->getString("password");
-            int createtime = res->getInt("createtime");
 
             if ((passwd != password) && (passwd != "@DEFAULT@"))
                 result = false;
@@ -428,7 +403,7 @@ bool sql_check(std::string user, std::string passwd)
   //  std::cout << result << std::endl;
     return result;
 }
-Json::Value sql_find_my_msg(std::string me, std::string connect_type)
+Json::Value sql_find_my_msg(const std::string& me, const std::string& connect_type)
 
 {
     // std::cout << "login user: " << me << std::endl;
@@ -437,8 +412,7 @@ Json::Value sql_find_my_msg(std::string me, std::string connect_type)
         sql::mysql::MySQL_Driver *driver = sql::mysql::get_mysql_driver_instance();
         sql::Connection *con = driver->connect("tcp://8.130.48.157:3306", "root", "abc.123");
         con->setSchema("flypen");
-        sql::PreparedStatement *prepStmt = nullptr;
-
+        sql::PreparedStatement *prepStmt;
         //===================    find begin
         // SELECT * FROM chat WHERE (sender = 'lglglglgy' OR receiver = 'lglglglgy') AND isread = 0
         std::string sqlFind_new_connect = "SELECT * FROM chat WHERE sender = ? OR receiver = ?";
@@ -534,7 +508,7 @@ Json::Value sql_find_my_msg(std::string me, std::string connect_type)
     }
 }
 
-void set_avatar(std::string person, int avatar)
+void set_avatar(const std::string& person, int avatar)
 {
     sql::mysql::MySQL_Driver *driver = sql::mysql::get_mysql_driver_instance();
     sql::Connection *con = driver->connect("tcp://8.130.48.157:3306", "root", "abc.123");
diff --git a/mysql.h b/mysql.h
@@ -4,18 +4,18 @@
 #include <jdbc/mysql_connection.h>
 #include <json/json.h>
 
-void sql_unlocked(std::string DeleteName);
-void sql_add(std::string username, std::string passwd, int avatar);
-bool sql_check(std::string, std::string passwd = "@DEFAULT@");
-void sql_addhistory(std::string, std::string, std::string, std::string);
+void sql_unlocked(const std::string& DeleteName);
+void sql_add(const std::string& username, const std::string& passwd, int avatar);
+bool sql_check(const std::string&, const std::string& passwd = "@DEFAULT@");
+void sql_addhistory(const std::string&, const std::string&, const std::string&, const std::string&);
 void sql_addconnect(std::string connectptr);
 
-void sql_addrequest(std::string send, std::string receiver);
-void sql_process_request(std::string, std::string, std::string);
-Json::Value sql_find_my_msg(std::string, std::string);
-int lockcheck(std::string filename);
-Json::Value get_my_info(std::string);
-void sql_delete_operation(std::string, std::string);
-void set_avatar(std::string person, int avatar);
-int sql_findexist(std::string receiver);
+void sql_addrequest(const std::string& send, const std::string& receiver);
+void sql_process_request(const std::string&, const std::string&, const std::string&);
+Json::Value sql_find_my_msg(const std::string&, const std::string&);
+int lockcheck(const std::string& filename);
+Json::Value get_my_info(const std::string&);
+void sql_delete_operation(const std::string&, const std::string&);
+void set_avatar(const std::string& person, int avatar);
+int sql_findexist(const std::string& receiver);
 #endif
diff --git a/root/lglglgly/lgylgy b/root/lglglgly/lgylgy
@@ -0,0 +1,14 @@
+### this is llggyy file~
+
+```c++
+#include <iostream>
+int main()
+{
+    std::cout<<"Hello, world!"<<std::endl;
+    return 0;
+}
+```
+![](http://127.0.0.1:8081/api/file/get?filename=No Authorization)
+
+![](http://127.0.0.1:8081/api/file/get?filename=1696040739895.png)
+
diff --git a/root/lgy b/root/lgy
diff --git a/user_controller.cc b/user_controller.cc
@@ -1,4 +1,3 @@
-#include <drogon/drogon.h>
 #include <json/json.h>
 #include "mysql.h"
 #include <iomanip>
@@ -48,7 +47,7 @@ void Handle(const HttpRequestPtr &req, std::function<void(const HttpResponsePtr
     callback(res);
 }
 
-std::string sha256(const std::string str)
+std::string sha256(const std::string& str)
 {
     unsigned char hash[SHA256_DIGEST_LENGTH];
 
@@ -60,8 +59,8 @@ std::string sha256(const std::string str)
 
     std::stringstream ss;
 
-    for (int i = 0; i < SHA256_DIGEST_LENGTH; i++)
-        ss << std::hex << std::setw(2) << std::setfill('0') << static_cast<int>(hash[i]);
+    for (unsigned char i : hash)
+        ss << std::hex << std::setw(2) << std::setfill('0') << static_cast<int>(i);
 
     return ss.str();
 }

Original file line number	Diff line number	Diff line change
`@@ -1,4 +1,3 @@`
`1`		`-#include <drogon/drogon.h>`
`2`	`1`	`#include <json/json.h>`
`3`	`2`	`#include "jwt_controller.h"`
`4`	`3`	`#include "msg_controller.h"`
Original file line number	Diff line number	Diff line change
`@@ -4,17 +4,15 @@`
`4`	`4`	`#include "jdbc/mysql_driver.h"`
`5`	`5`	`#include "json/json.h"`
`6`	`6`
`7`		`-void sql_unlocked(std::string DeleteName)`
	`7`	`+void sql_unlocked(const std::string& DeleteName)`
`8`	`8`	`{`
`9`	`9`	`sql::mysql::MySQL_Driver *driver = sql::mysql::get_mysql_driver_instance();`
`10`	`10`	`sql::Connection *con = driver->connect("tcp://8.130.48.157:3306", "root", "abc.123");`
`11`	`11`	`con->setSchema("flypen");`
`12`	`12`	`sql::Statement *stmt = con->createStatement();`
`13`	`13`	`try`
`14`	`14`	`{`
`15`		`- std::string filename = DeleteName;`
`16`	`15`	`std::string DeleteQuery = "DELETE FROM file WHERE filename = " + DeleteName;`
`17`		`- int rowsDelete = stmt->executeUpdate(DeleteQuery);`
`18`	`16`	`}`
`19`	`17`	`catch (sql::SQLException &e)`
`20`	`18`	`{`
`@@ -26,7 +24,7 @@ void sql_unlocked(std::string DeleteName)`
`26`	`24`
`27`	`25`	`// relate to chat`
`28`	`26`
`29`		`-int sql_findexist(std::string receiver)`
	`27`	`+int sql_findexist(const std::string& receiver)`
`30`	`28`	`{`
`31`	`29`	`sql::mysql::MySQL_Driver *driver = sql::mysql::get_mysql_driver_instance();`
`32`	`30`	`sql::Connection *con = driver->connect("tcp://8.130.48.157:3306", "root", "abc.123");`
`@@ -42,7 +40,7 @@ int sql_findexist(std::string receiver)`
`42`	`40`	`}`
`43`	`41`	`return 0;`
`44`	`42`	`}`
`45`		`-int lockcheck(std::string filename)`
	`43`	`+int lockcheck(const std::string& filename)`
`46`	`44`	`{`
`47`	`45`	`sql::mysql::MySQL_Driver *driver = sql::mysql::get_mysql_driver_instance();`
`48`	`46`	`sql::Connection *con = driver->connect("tcp://8.130.48.157:3306", "root", "abc.123");`
`@@ -87,7 +85,7 @@ void process(sql::PreparedStatement *readDatament, std::vector<std::string> s, s`
`87`	`85`	`}`
`88`	`86`	`}`
`89`	`87`
`90`		`-void sql_delete_operation(std::string sender, std::string receiver)`
	`88`	`+void sql_delete_operation(const std::string& sender, const std::string& receiver)`
`91`	`89`	`{`
`92`	`90`	`sql::mysql::MySQL_Driver *driver = sql::mysql::get_mysql_driver_instance();`
`93`	`91`	`sql::Connection *con = driver->connect("tcp://8.130.48.157:3306", "root", "abc.123");`
`@@ -102,7 +100,7 @@ void sql_delete_operation(std::string sender, std::string receiver)`
`102`	`100`	`process(readDatament, s, con);`
`103`	`101`	`}`
`104`	`102`
`105`		`-void sql_process_request(std::string sender, std::string receiver, std::string attitude)`
	`103`	`+void sql_process_request(const std::string& sender, const std::string& receiver, const std::string& attitude)`
`106`	`104`	`{`
`107`	`105`	`std::vector<std::string> usernamelist;`
`108`	`106`	`sql::mysql::MySQL_Driver *driver = sql::mysql::get_mysql_driver_instance();`
`@@ -135,7 +133,7 @@ void sql_process_request(std::string sender, std::string receiver, std::string a`
`135`	`133`	`if (attitude == "allow")`
`136`	`134`	`{`
`137`	`135`	`std::string readData = "SELECT friends FROM users WHERE username = ?";`
`138`		`- std::string *RS = new std::string[2]{receiver, sender}; // R, S`
	`136`	`+ auto *RS = new std::string[2]{receiver, sender}; // R, S`
`139`	`137`
`140`	`138`	`for (int i = 0; i < 2; i++)`
`141`	`139`	`{`
`@@ -157,7 +155,7 @@ void sql_process_request(std::string sender, std::string receiver, std::string a`
`157`	`155`	`std::string updateQuery = "UPDATE users SET friends = ? WHERE username = ?";`
`158`	`156`	`sql::PreparedStatement *update = con->prepareStatement(updateQuery);`
`159`	`157`
`160`		`- if (friendsList != "")`
	`158`	`+ if (!friendsList.empty())`
`161`	`159`	`{`
`162`	`160`	`friendsList += "," + RS[1 - i];`
`163`	`161`	`update->setString(1, friendsList);`
`@@ -178,10 +176,9 @@ void sql_process_request(std::string sender, std::string receiver, std::string a`
`178`	`176`	`delete resultSet;`
`179`	`177`	`delete readDatament;`
`180`	`178`	`delete con;`
`181`		`- return;`
`182`	`179`	`}`
`183`	`180`
`184`		`-void sql_addrequest(std::string sender, std::string receiver)`
	`181`	`+void sql_addrequest(const std::string& sender, const std::string& receiver)`
`185`	`182`	`{`
`186`	`183`	`std::vector<std::string> usernamelist;`
`187`	`184`
`@@ -208,7 +205,7 @@ void sql_addrequest(std::string sender, std::string receiver)`
`208`	`205`	`std::string updateQuery = "UPDATE users SET req = ? WHERE username = ?";`
`209`	`206`	`sql::PreparedStatement *updateStatement = con->prepareStatement(updateQuery);`
`210`	`207`
`211`		`- if (req != "")`
	`208`	`+ if (!req.empty())`
`212`	`209`	`{`
`213`	`210`	`req += "," + sender;`
`214`	`211`	`updateStatement->setString(1, req);`
`@@ -229,28 +226,7 @@ void sql_addrequest(std::string sender, std::string receiver)`
`229`	`226`	`delete con;`
`230`	`227`	`}`
`231`	`228`
`232`		`-void sql_addconnect(std::string connectptr)`
`233`		`-{`
`234`		`- try`
`235`		`- {`
`236`		`- sql::mysql::MySQL_Driver *driver = sql::mysql::get_mysql_driver_instance();`
`237`		`- sql::Connection *con = driver->connect("tcp://8.130.48.157:3306", "root", "abc.123");`
`238`		`- con->setSchema("flypen");`
`239`		`-`
`240`		`- std::string classMysql = "INSERT INTO users(username, password, time, connection) VALUES (?, ?, NOW(), ?)";`
`241`		`- sql::PreparedStatement *insertConnect = con->prepareStatement(classMysql);`
`242`		`- insertConnect->setString(4, connectptr);`
`243`		`-`
`244`		`- delete insertConnect;`
`245`		`- delete con;`
`246`		`- }`
`247`		`- catch (sql::SQLException &e)`
`248`		`- {`
`249`		`- std::cerr << "SQL Exception: " << e.what() << std::endl;`
`250`		`- }`
`251`		`-}`
`252`		`-`
`253`		`-void sql_addhistory(std::string sender, std::string receiver, std::string message, std::string isread)`
	`229`	`+void sql_addhistory(const std::string& sender, const std::string& receiver, const std::string& message, const std::string& isread)`
`254`	`230`	`{`
`255`	`231`	`try`
`256`	`232`	`{`
`@@ -278,7 +254,7 @@ void sql_addhistory(std::string sender, std::string receiver, std::string messag`
`278`	`254`	`}`
`279`	`255`
`280`	`256`	`// relate to user`
`281`		`-void sql_add(std::string username, std::string passwd, int avatar)`
	`257`	`+void sql_add(const std::string& username, const std::string& passwd, int avatar)`
`282`	`258`	`{`
`283`	`259`	`try`
`284`	`260`	`{`
`@@ -305,7 +281,7 @@ void sql_add(std::string username, std::string passwd, int avatar)`
`305`	`281`	`}`
`306`	`282`	`}`
`307`	`283`
`308`		`-Json::Value get_my_info(std::string me)`
	`284`	`+Json::Value get_my_info(const std::string& me)`
`309`	`285`	`{`
`310`	`286`	`Json::Value json;`
`311`	`287`
`@@ -386,7 +362,7 @@ Json::Value get_my_info(std::string me)`
`386`	`362`	`return json;`
`387`	`363`	`}`
`388`	`364`
`389`		`-bool sql_check(std::string user, std::string passwd)`
	`365`	`+bool sql_check(const std::string& user, const std::string& passwd)`
`390`	`366`	`{`
`391`	`367`	`bool result = false;`
`392`	`368`	`try`
`@@ -410,7 +386,6 @@ bool sql_check(std::string user, std::string passwd)`
`410`	`386`	`// 提取所有列的值`
`411`	`387`	`std::string username = res->getString("username");`
`412`	`388`	`std::string password = res->getString("password");`
`413`		`- int createtime = res->getInt("createtime");`
`414`	`389`
`415`	`390`	`if ((passwd != password) && (passwd != "@DEFAULT@"))`
`416`	`391`	`result = false;`
`@@ -428,7 +403,7 @@ bool sql_check(std::string user, std::string passwd)`
`428`	`403`	`// std::cout << result << std::endl;`
`429`	`404`	`return result;`
`430`	`405`	`}`
`431`		`-Json::Value sql_find_my_msg(std::string me, std::string connect_type)`
	`406`	`+Json::Value sql_find_my_msg(const std::string& me, const std::string& connect_type)`
`432`	`407`
`433`	`408`	`{`
`434`	`409`	`// std::cout << "login user: " << me << std::endl;`
`@@ -437,8 +412,7 @@ Json::Value sql_find_my_msg(std::string me, std::string connect_type)`
`437`	`412`	`sql::mysql::MySQL_Driver *driver = sql::mysql::get_mysql_driver_instance();`
`438`	`413`	`sql::Connection *con = driver->connect("tcp://8.130.48.157:3306", "root", "abc.123");`
`439`	`414`	`con->setSchema("flypen");`
`440`		`- sql::PreparedStatement *prepStmt = nullptr;`
`441`		`-`
	`415`	`+ sql::PreparedStatement *prepStmt;`
`442`	`416`	`//=================== find begin`
`443`	`417`	`// SELECT * FROM chat WHERE (sender = 'lglglglgy' OR receiver = 'lglglglgy') AND isread = 0`
`444`	`418`	`std::string sqlFind_new_connect = "SELECT * FROM chat WHERE sender = ? OR receiver = ?";`
`@@ -534,7 +508,7 @@ Json::Value sql_find_my_msg(std::string me, std::string connect_type)`
`534`	`508`	`}`
`535`	`509`	`}`
`536`	`510`
`537`		`-void set_avatar(std::string person, int avatar)`
	`511`	`+void set_avatar(const std::string& person, int avatar)`
`538`	`512`	`{`
`539`	`513`	`sql::mysql::MySQL_Driver *driver = sql::mysql::get_mysql_driver_instance();`
`540`	`514`	`sql::Connection *con = driver->connect("tcp://8.130.48.157:3306", "root", "abc.123");`