240717班级，工业化控制系统，煤矿相关行业，昆仑系统
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
gong
2024-11-06 828ba1dcdd1fa803dddf94f4f1643452d5efa703 
 Server/ÍõçûÔª/code/MysqlConn.h


@@ -1,63 +1,49 @@


#pragma once


#include<iostream>


#include <memory>


#include <string>


#include <mysql.h>


#include <chrono> // æ—¶é’Ÿ


#include <fstream>




#pragma comment(lib, "./lib/libmysql.lib") // åŠ è½½æ•°æ®åº“库文件


using namespace std;


using namespace chrono;


typedef long long ll;


#include <string>


#include <WinSock2.h>


//#include <mysql.h>


#include "MySQL/include/mysql.h"


#include <string.h>


#include <chrono>




#pragma comment(lib,"./MySQL/lib/libmysql.lib")




class MysqlConn


{


private:


   // ç»å¯¹æ—¶é’Ÿ


   steady_clock::time_point   m_alivetime;


   // è¿žæŽ¥


   MYSQL* m_conn;


   // æŸ¥è¯¢çš„结果集


   MYSQL_RES* m_result;


   // å•è®°å½•ç»“果集


   MYSQL_ROW               m_mysqlRow;




   // ç»“果集释放


   void freeRes();


   // å¯¼å‡ºæŸä¸€å¼ è¡¨ä¸­çš„数据


   void backupCurrentTable(const string path, const string tableName);


public:


   // åˆå§‹åŒ–数据库


   // åˆå§‹åŒ–连接


   MysqlConn();


   // æ•°æ®åº“连接释放


   ~MysqlConn();


   // è¿žæŽ¥æ•°æ®åº“, éœ€æä¾›ç”¨æˆ· å¯†ç  æ•°æ®åº“名称 ip ç«¯å£


   bool connect(const string user, const string passwd, \


      const string dbName, string ip, \


      const unsigned short port = 3306U);


   // æ›´æ–°æ•°æ®åº“:增删改操作


   bool update(const string sql) const;


   // è¿žæŽ¥æ•°æ®åº“


   bool connect(std::string ip, std::string userName, std::string passwd, std::string db , int port = 3306);


   // é‡Šæ”¾èµ„源


   ~MysqlConn( );


   // æ›´æ–°æ•°æ®åº“  ( insert  update delete )


   bool update(std::string sql);


   // æŸ¥è¯¢æ•°æ®åº“


   bool query(const string sql);


   // éåŽ†æŸ¥è¯¢ç»“果集


   bool getRes();


   // èŽ·å–结果集中的字段值


   string getValue(const int fieldIndex) const;


   // åˆ‡æ¢æ•°æ®åº“


   bool selectDB(const string dbName) const;


   // å»ºåº“


   //bool createDB(const string dbName) const;


   // å¤‡ä»½æŸä¸ªåº“


   void backupCurrentDB(const string path);


   bool query(std::string sql);


   // å¾—到结果集


   bool getResult();


   // èŽ·å–结果集的字段


   std::string getField(int index);


   // äº‹åŠ¡æ“ä½œ


   bool transaction() const;


   bool transaction();


   // æäº¤äº‹åŠ¡


   bool commit() const;


   bool commit( );


   // äº‹åŠ¡å›žæ»š


   bool rollback() const;


   // åˆ·æ–°èµ·å§‹çš„空闲时间点


   void refreashAliveTime();


   // è®¡ç®—存活总时长


   ll getAliveTime();


   bool rollback();




   void refreshActiveTime( );   // åˆ·æ–°æ´»è·ƒæ—¶é—´


   long long getActiveTime();   // èŽ·å–当前活跃的时间间隔 


   // å®‰å…¨æ ¡éªŒæŽ¥å£


   bool isSqlSafe(const std::string& sql);




private:




   void freeRes();


   MYSQL* mysql_ = NULL ;


   MYSQL_RES* res_ = NULL;


   MYSQL_ROW row_ = nullptr;


   std::chrono::steady_clock::time_point  activeTime_;


};