#pragma once
|
|
#include <string>
|
#include <WinSock2.h>
|
#include "MySQL/include/mysql.h"
|
#include <string.h>
|
#include <chrono>
|
#include <iostream>
|
#include <memory>
|
#include <queue>
|
#include <mutex>
|
#include <condition_variable>
|
#include <regex>
|
#pragma comment(lib,"./MySQL/lib/libmysql.lib")
|
|
using namespace std;
|
class MysqlConn
|
{
|
public:
|
// ³õʼ»¯Á¬½Ó
|
MysqlConn();
|
// Á¬½ÓÊý¾Ý¿â
|
//bool connect();
|
// ÊÍ·Å×ÊÔ´
|
~MysqlConn();
|
// ¸üÐÂÊý¾Ý¿â ( insert update delete )
|
bool update(string sql);
|
// ²éѯÊý¾Ý¿â
|
bool query(string sql, vector<vector<string>>& result);
|
bool query(string sql);
|
// µÃµ½½á¹û¼¯
|
bool getResult();
|
// »ñÈ¡½á¹û¼¯µÄ×Ö¶Î
|
string getField(int index);
|
// ÊÂÎñ²Ù×÷
|
bool transaction();
|
// Ìá½»ÊÂÎñ
|
bool commit();
|
// ÊÂÎñ»Ø¹ö
|
bool rollback();
|
|
|
void refreshActiveTime(); // ˢлîԾʱ¼ä
|
long long getActiveTime(); // »ñÈ¡µ±Ç°»îÔ¾µÄʱ¼ä¼ä¸ô
|
// °²È«Ð£Ñé½Ó¿Ú
|
bool isSqlSafe(const string& sql);
|
bool isConnected();
|
protected:
|
void freeRes();
|
MYSQL* m_mysql;
|
MYSQL_RES* m_res;
|
MYSQL_ROW m_row;
|
chrono::steady_clock::time_point m_activeTime;
|
|
};
|
