关于mysql_free_result和mysql_close的解惑
浏览:2723次 出处信息
之前用mysql的时候一直是在用短链接,调用mysql_store_result获取一次数据之后就直接调用:
以下是代码片段:
mysql_free_result(m_result);
mysql_close(m_Database);
但是有两个问题:
以下是引用片段: 1.当使用长连接时(即connect之后一直不close),如果最后会调用mysql_close,需不需要每次都调用mysql_free_result呢? 2.当mysql_close调用之后,m_result的数据是否还可以用。 |
先说一下结论:
1.必须每次调用。因为经过测试,每次mysql_store_result的指针都是不同的,可见并不是共享了同一块buf。
2.还是可以使用。经过valgrind扫描,只调用mysql_close的扫描结果是:
以下是引用片段: ==9397== 16,468 (88 direct, 16,380 indirect) bytes in 1 blocks are definitely lost in loss record 4 of 5 ==9397== at 0x40219B3: malloc (vg_replace_malloc.c:195) ==9397== by 0x8053EA2: my_malloc (in /data/home/dantezhu/appbase/application/platform/openqqcom/share/db_openright/test/test) ==9397== by 0x806D314: mysql_store_result (in /data/home/dantezhu/appbase/application/platform/openqqcom/share/db_openright/test/test) ==9397== by 0x804BB04: CMySQLCppClient::Result(st_mysql_res*&) (mysql_cpp_client.cpp:127) ==9397== by 0x804AB58: CDBOpenRight::GetUinsByApp(unsigned int, std::set<unsigned int, std::less<unsigned int>, std::allocator<unsigned int> >&) (db_openright.cpp:58) ==9397== by 0x8049F10: main (test.cpp:27) |
这里连同测试代码和我之前写的一个简单的C++封装的mysql库一起放出下载,有需要的同学可以下载试试:
代码下载
代码下载
其中只有mysql_cpp_client.h和mysql_cpp_client.cpp是核心文件,其他均为测试代码.
里面有简单的演示,如查询:
char strSql[MAX_QUERYLEN_OPENRIGHT];
snprintf(strSql,sizeof(strSql),"select uin \
from %s where appid=%u;",OPENRIGHT_TB_CARE,appid);
int ret;
ret = m_SqlClient.Execute(strSql);
if(ret)
{
snprintf(m_StrErrMsg,sizeof(m_StrErrMsg),"[%s][%d][%s]Error:[%d][%s]\n",
__FILE__,__LINE__,__FUNCTION__,ret,m_SqlClient.GetErrMsg());
return -1;
}
MYSQL_RES *result = NULL;
ret = m_SqlClient.Result(result);
if(ret)
{
snprintf(m_StrErrMsg,sizeof(m_StrErrMsg),"[%s][%d][%s]Error:[%d][%s]\n",
__FILE__,__LINE__,__FUNCTION__,ret,m_SqlClient.GetErrMsg());
return -2;
}
//这里很重要,做了析构时自动调用mysql_free_result
StCppResult freeRes(result);
unsigned int unRecords = mysql_num_rows(result);
if (0 == unRecords)
{
snprintf(m_StrErrMsg,sizeof(m_StrErrMsg),"[%s][%d][%s]Error: Result is empty\n",
__FILE__,__LINE__,__FUNCTION__);
return 0;
}
MYSQL_ROW row;
for(unsigned int unIndex = 0; unIndex < unRecords; unIndex++)
{
row=mysql_fetch_row(result);
unsigned uin = unsigned(atoi((char*)row[0]));
setUins.insert(uin);
}
return 0;
插入:
if(setUins.size() <= 0) { return 0; } if(setUins.size() > 1000) { snprintf(m_StrErrMsg,sizeof(m_StrErrMsg),"[%s][%d][%s]Error:[uins more than 1000]\n", __FILE__,__LINE__,__FUNCTION__); return -1; } string strValues; char szValue[100]; for(set<unsigned int>::iterator it = setUins.begin();it!=setUins.end();++it) { if (setUins.begin() == it) { snprintf(szValue,sizeof(szValue),TPL_ADDUIN2APP,*it,appid); } else { snprintf(szValue,sizeof(szValue),","TPL_ADDUIN2APP,*it,appid); } strValues.append(szValue); } char strSql[MAX_QUERYLEN_OPENRIGHT]; snprintf(strSql,sizeof(strSql),"insert into %s(uin,appid) VALUES %s;",OPENRIGHT_TB_CARE,strValues.c_str()); int ret; ret = m_SqlClient.Execute(strSql); if(ret) { snprintf(m_StrErrMsg,sizeof(m_StrErrMsg),"[%s][%d][%s]Error:[%d][%s]\n", __FILE__,__LINE__,__FUNCTION__,ret,m_SqlClient.GetErrMsg()); return -2; } if(m_SqlClient.AffectRows()<=0) { snprintf(m_StrErrMsg,sizeof(m_StrErrMsg),"[%s][%d][%s]Error:[%d][%s]\n", __FILE__,__LINE__,__FUNCTION__,ret,m_SqlClient.GetErrMsg()); return -3; } return 0;
OK,就这样。
QQ技术交流群:445447336,欢迎加入!
扫一扫订阅我的微信号:IT技术博客大学习
扫一扫订阅我的微信号:IT技术博客大学习
<< 前一篇:phpMyAdmin一个用户只能管理自己数据库的设置方法
后一篇:PHP导出MySQL数据到Excel文件 >>
文章信息
- 作者:Dante 来源: Vimer
- 标签: mysql_close mysql_free_resul
- 发布时间:2010-10-12 22:21:08
近3天十大热文
- [65] Oracle MTS模式下 进程地址与会话信
- [64] Go Reflect 性能
- [64] 如何拿下简短的域名
- [59] IOS安全–浅谈关于IOS加固的几种方法
- [58] 【社会化设计】自我(self)部分――欢迎区
- [58] 图书馆的世界纪录
- [56] android 开发入门
- [53] 视觉调整-设计师 vs. 逻辑
- [46] 读书笔记-壹百度:百度十年千倍的29条法则
- [45] 界面设计速成