C中MySQL自动重新连接(部分zz)
时间:2010-08-04 来源:axejonny
MySQL服务器每隔一段时间会关闭连接,需要重新连一下,方法是调用mysql_ping。
我的代码:
MYSQL *conn;
MYSQL_RES *result;
MYSQL_ROW row;
int num_fields;
int i;
//for reconnect #if MYSQL_VERSION_ID >= 50013 my_bool reconnect;//my_bool = char #endif
conn = mysql_init(NULL);
#if MYSQL_VERSION_ID >= 50013
reconnect = 1;
//set re-conn to true. could use ping to reconn if (mysql_options(conn, MYSQL_OPT_RECONNECT, &reconnect) != 0) { printf("Error %u: %s\n", mysql_errno(conn), mysql_error(conn)); exit(1); }
#endif
if (conn == NULL) { //printf("%s\n",__LINE__); printf("Error %u: %s\n", mysql_errno(conn), mysql_error(conn)); exit(1); }
if (mysql_real_connect(conn, "localhost", "root", "", "online_stat", 0, NULL, 0) == NULL) { //printf("%s\n",__LINE__); printf("Error %u: %s\n", mysql_errno(conn), mysql_error(conn)); exit(1); }
/* mysql_query(conn, "SELECT * FROM daily_online_stat"); result = mysql_store_result(conn);
num_fields = mysql_num_fields(result);
while ((row = mysql_fetch_row(result))) { for(i = 0; i < num_fields; i++) { printf("%s ", row[i] ? row[i] : "NULL"); } printf("\n"); } */ char strSql[1000]; bzero(strDate, 20); bzero(strSql, 1000); //TODO:TEST getDate(strDate); printf("%s", strDate); strPeak = "999"; strWebId = "Adios"; strTotalLogin = "12345"; sprintf(strSql, "insert into daily_online_stat values ('NULL', '%s', '%s', '%s', '%s');", strDate, strPeak.c_str(), strTotalLogin.c_str(), strWebId.c_str()); printf("%s\n", strSql); mysql_query(conn, strSql); //mysql_free_result(result);
mysql_close(conn);
以下摘自:http://blog.chinaunix.net/u1/50685/showart_1805135.html
1) 增大/etc/my.cnf中wait_timeout的值,比如设置wait_timeout=8640000,即100天。这个值缺省是8小时。这个方法简单,但是不能彻底解决问题。推荐第二种解决方法。
2)使用mysql_ping来自动检查重连。用到两个函数,一个是mysql_ping,另外一个是mysql_options。具体使用方法是在mysql_real_connect之前,mysql_init之后,使用mysql_options。用法如下:
char value = 1;
(void) mysql_init (&mysql);
mysql_options(&mysql, MYSQL_OPT_RECONNECT, (char *)&value);
然后在以后mysql_query之前首先使用mysql_ping进行判断,如果连接已经断开,会自动重连。
不过,请注意,自动重新连接也会导致一些副作用,如下:
* 任何活动的交易都被回滚,autocommit模式被置为reset。
* 所有表锁都释放
* 所有临时表是关闭(撤消)
* Session variables are reinitialized to the values of the corresponding variables.会话变量被重新初始化为相应的变量。 这也影响那些隐式声明的变量,SET NAMES。比如使用This also affects variables that are set implicitly by statements such as SET NAMES.这也影响了变量,是一套由含蓄的声明,例如订定的名称。
* 用户变量设置都将丢失。
* 编制报表释放。
* 句柄变量被关闭。
* LAST_INSERT_ID()被重置为0 。
* 使用GET_LOCK()获得的锁被释放
首先,如果使用了长连接而长期没有对数据库进行任何操作,那么在timeout值后,mysql server就会关闭此连接,而客户端在执行查询的时候就会得到一个类似于“MySQL server has gone away“这样的错误。
一个好的解决方法是使用mysql_ping。在使用mysql_real_connect连接数据库之后,再使用mysql_options( &mysql, MYSQL_OPT_RECONNECT, … ) 来设置为自动重连。这样当mysql连接丢失的时候,使用mysql_ping能够自动重连数据库。如果是在mysql 5.1.6之前,那么则应在每次执行完real_connect 之后执行mysql_options( &mysql, MYSQL_OPT_RECONNECT, … ) ,如果是mysql 5.1.6+,则在connect之前执行一次就够了。
有一种很自然的想法就是,新开一个线程,让它隔一定时间(如20秒)就执行一次mysql_ping.除此而外它什么都不用做。但是显然,这个线程必须与其它线程共享一个mysql连接,共享该mysql句柄。否则这样做一点意义都没有。
但是,mysql_ping会改变mysql_affected_rows的返回值。所以最好是给该MYSQL句柄再加一个mutex(最好是读写 锁)。当其它线程准备执行query的时候,就获取锁,执行完就释放。而这个执行mysql_ping的线程在执行ping之间先尝试获取锁,如果获取失 败,则继续sleep,放弃这一轮的ping。
//for reconnect #if MYSQL_VERSION_ID >= 50013 my_bool reconnect;//my_bool = char #endif
conn = mysql_init(NULL);
#if MYSQL_VERSION_ID >= 50013
reconnect = 1;
//set re-conn to true. could use ping to reconn if (mysql_options(conn, MYSQL_OPT_RECONNECT, &reconnect) != 0) { printf("Error %u: %s\n", mysql_errno(conn), mysql_error(conn)); exit(1); }
#endif
if (conn == NULL) { //printf("%s\n",__LINE__); printf("Error %u: %s\n", mysql_errno(conn), mysql_error(conn)); exit(1); }
if (mysql_real_connect(conn, "localhost", "root", "", "online_stat", 0, NULL, 0) == NULL) { //printf("%s\n",__LINE__); printf("Error %u: %s\n", mysql_errno(conn), mysql_error(conn)); exit(1); }
/* mysql_query(conn, "SELECT * FROM daily_online_stat"); result = mysql_store_result(conn);
num_fields = mysql_num_fields(result);
while ((row = mysql_fetch_row(result))) { for(i = 0; i < num_fields; i++) { printf("%s ", row[i] ? row[i] : "NULL"); } printf("\n"); } */ char strSql[1000]; bzero(strDate, 20); bzero(strSql, 1000); //TODO:TEST getDate(strDate); printf("%s", strDate); strPeak = "999"; strWebId = "Adios"; strTotalLogin = "12345"; sprintf(strSql, "insert into daily_online_stat values ('NULL', '%s', '%s', '%s', '%s');", strDate, strPeak.c_str(), strTotalLogin.c_str(), strWebId.c_str()); printf("%s\n", strSql); mysql_query(conn, strSql); //mysql_free_result(result);
mysql_close(conn);
以下摘自:http://blog.chinaunix.net/u1/50685/showart_1805135.html
1) 增大/etc/my.cnf中wait_timeout的值,比如设置wait_timeout=8640000,即100天。这个值缺省是8小时。这个方法简单,但是不能彻底解决问题。推荐第二种解决方法。
2)使用mysql_ping来自动检查重连。用到两个函数,一个是mysql_ping,另外一个是mysql_options。具体使用方法是在mysql_real_connect之前,mysql_init之后,使用mysql_options。用法如下:
char value = 1;
(void) mysql_init (&mysql);
mysql_options(&mysql, MYSQL_OPT_RECONNECT, (char *)&value);
然后在以后mysql_query之前首先使用mysql_ping进行判断,如果连接已经断开,会自动重连。
不过,请注意,自动重新连接也会导致一些副作用,如下:
* 任何活动的交易都被回滚,autocommit模式被置为reset。
* 所有表锁都释放
* 所有临时表是关闭(撤消)
* Session variables are reinitialized to the values of the corresponding variables.会话变量被重新初始化为相应的变量。 这也影响那些隐式声明的变量,SET NAMES。比如使用This also affects variables that are set implicitly by statements such as SET NAMES.这也影响了变量,是一套由含蓄的声明,例如订定的名称。
* 用户变量设置都将丢失。
* 编制报表释放。
* 句柄变量被关闭。
* LAST_INSERT_ID()被重置为0 。
* 使用GET_LOCK()获得的锁被释放
首先,如果使用了长连接而长期没有对数据库进行任何操作,那么在timeout值后,mysql server就会关闭此连接,而客户端在执行查询的时候就会得到一个类似于“MySQL server has gone away“这样的错误。
一个好的解决方法是使用mysql_ping。在使用mysql_real_connect连接数据库之后,再使用mysql_options( &mysql, MYSQL_OPT_RECONNECT, … ) 来设置为自动重连。这样当mysql连接丢失的时候,使用mysql_ping能够自动重连数据库。如果是在mysql 5.1.6之前,那么则应在每次执行完real_connect 之后执行mysql_options( &mysql, MYSQL_OPT_RECONNECT, … ) ,如果是mysql 5.1.6+,则在connect之前执行一次就够了。
有一种很自然的想法就是,新开一个线程,让它隔一定时间(如20秒)就执行一次mysql_ping.除此而外它什么都不用做。但是显然,这个线程必须与其它线程共享一个mysql连接,共享该mysql句柄。否则这样做一点意义都没有。
但是,mysql_ping会改变mysql_affected_rows的返回值。所以最好是给该MYSQL句柄再加一个mutex(最好是读写 锁)。当其它线程准备执行query的时候,就获取锁,执行完就释放。而这个执行mysql_ping的线程在执行ping之间先尝试获取锁,如果获取失 败,则继续sleep,放弃这一轮的ping。
相关阅读 更多 +