int logBusiness::logSend(std::vector<char>& data, size_t comm_fd) { if (((Head*)data.data())->type == SEARCHLOG_REQ) { searchLogReq * seaLogReq = (searchLogReq*)data.data(); Database conn; conn.connect("root", "123abcwo", "CFX", "1...-Go服务器开发

这段代码是一个 logBusiness 类的成员函数 logSend 的实现。下面是对代码进行逐行解释：

int logBusiness::logSend(std::vector<char>& data, size_t comm_fd)
{
	if (((Head*)data.data())->type == SEARCHLOG_REQ)
	{
		searchLogReq * seaLogReq = (searchLogReq*)data.data();

函数开始判断收到的数据包类型是否为搜索日志请求 (SEARCHLOG_REQ)。
如果是，则将接收到的 data 转换为指向 searchLogReq 结构体类型的指针，方便后续使用。

    Database conn;
	  conn.connect("root", "123abcwo", "CFX", "127.0.0.1");
	  char sql[2048] = { 0 };
  	sprintf(sql, "select * from log");
	  conn.query(sql);

创建一个数据库连接对象 conn，并使用指定的用户名、密码、数据库名和主机地址进行连接。
然后构造一个 SQL 查询语句，并调用数据库连接对象的 query 函数执行查询。

		std::string str = "SELECT * FROM log WHERE date BETWEEN '" + std::string(seaLogReq->beginTime) + "'" + "AND " + "'" + std::string(seaLogReq->endTime) + "' " + "AND logLevel = " + "'" + std::string(seaLogReq->logType) + "'";
		cout << str << endl;
    conn.query(sql);

构建一个包含起始时间、结束时间和日志级别等条件的 SQL 查询语句，并将其打印出来。
再次调用数据库连接对象的 query 函数执行查询。

		vector<vector<string>>result;
   
   while (conn.next()) {
   size_t i=0;
		result[i][0]= conn.value(0);
		result[i][1]= conn.value(1);
		result[i][2]= conn.value(2);
		result[i][3]= conn.value(3);
		result[i][4]= conn.value(4);
		result[i][5]= conn.value(5);
		result[i][6]= conn.value(6);
    i++;
	}

创建一个二维向量 result 来存储查询结果。
使用 while 循环遍历查询结果集，将每一行的数据存储到 result 中。

	int len = sizeof(searchLogReq) + sizeof(LogInfo)*result.size();

	searchLogRes* seaLogRes = (searchLogRes*)malloc(len);
	memset((void*)seaLogRes, 0, len);
	seaLogRes->head.len = len;
	seaLogRes->head.type = SEARCHLOG_RES;
	seaLogRes->cnt = static_cast<int>(result.size());

计算需要分配内存空间的大小，其中包括搜索日志请求结构体和查询结果条目所需的内存空间。
使用 malloc 函数为搜索日志响应结构体分配内存空间，并使用 memset 将该内存块中的内容全部置为 0。
设置搜索日志响应结构体的字段值。

	for (size_t i = 0; i < result.size(); ++i) {
		strcpy(seaLogRes->info[i].time, result[i][0].c_str());
		seaLogRes->info[i].processId = stoi(result[i][1]);
		seaLogRes->info[i].threadId = stoi(result[i][2]);
		strcpy(seaLogRes->info[i].fileName, result[i][3].c_str());
		strcpy(seaLogRes->info[i].functionName, result[i][4].c_str());
		strcpy(seaLogRes->info[i].logInfomation, result[i][5].c_str());
	}
	free(seaLogRes);
	seaLogRes = nullptr;
	return 0;
}