diff options
| author | hugetoad <hugetoad@97f52cf1-0a1b-0410-bd0e-c28be96e8082> | 2005-01-06 21:05:53 +0000 |
|---|---|---|
| committer | hugetoad <hugetoad@97f52cf1-0a1b-0410-bd0e-c28be96e8082> | 2005-01-06 21:05:53 +0000 |
| commit | dd9c0f550bd2b3827c740651642c3c56c6de6dd0 (patch) | |
| tree | 307d66d5dc02d97f092f0c6233d0668e575b7bcc /include | |
| parent | 3d91e3c6f890b95194add73e44963a147e98af1a (diff) | |
| download | zabbix-dd9c0f550bd2b3827c740651642c3c56c6de6dd0.tar.gz zabbix-dd9c0f550bd2b3827c740651642c3c56c6de6dd0.tar.xz zabbix-dd9c0f550bd2b3827c740651642c3c56c6de6dd0.zip | |
- introduced 'insert delayed' and 'delete low_priority' for MySQL (Alexei)
git-svn-id: svn://svn.zabbix.com/trunk@1587 97f52cf1-0a1b-0410-bd0e-c28be96e8082
Diffstat (limited to 'include')
| -rw-r--r-- | include/db.c | 16 |
1 files changed, 16 insertions, 0 deletions
diff --git a/include/db.c b/include/db.c index 1ff89561..9374d91d 100644 --- a/include/db.c +++ b/include/db.c @@ -1689,7 +1689,11 @@ int DBadd_history_thread(MYSQL *database, int itemid, double value, int clock) zabbix_log(LOG_LEVEL_DEBUG,"In add_history()"); +#ifdef HAVE_MYSQL + snprintf(sql,sizeof(sql)-1,"insert delayed into history (clock,itemid,value) values (%d,%d,%f)",clock,itemid,value); +#else snprintf(sql,sizeof(sql)-1,"insert into history (clock,itemid,value) values (%d,%d,%f)",clock,itemid,value); +#endif DBexecute_thread(database, sql); DBadd_trend_thread(database, itemid, value, clock); @@ -1704,7 +1708,11 @@ int DBadd_history(int itemid, double value, int clock) zabbix_log(LOG_LEVEL_DEBUG,"In add_history()"); +#ifdef HAVE_MYSQL + snprintf(sql,sizeof(sql)-1,"insert delayed into history (clock,itemid,value) values (%d,%d,%f)",clock,itemid,value); +#else snprintf(sql,sizeof(sql)-1,"insert into history (clock,itemid,value) values (%d,%d,%f)",clock,itemid,value); +#endif DBexecute(sql); DBadd_trend(itemid, value, clock); @@ -1721,7 +1729,11 @@ int DBadd_history_str_thread(MYSQL *database, int itemid, char *value, int clock zabbix_log(LOG_LEVEL_DEBUG,"In add_history_str()"); DBescape_string(value,value_esc,MAX_STRING_LEN); +#ifdef HAVE_MYSQL + snprintf(sql,sizeof(sql)-1,"insert delayed into history_str (clock,itemid,value) values (%d,%d,'%s')",clock,itemid,value_esc); +#else snprintf(sql,sizeof(sql)-1,"insert into history_str (clock,itemid,value) values (%d,%d,'%s')",clock,itemid,value_esc); +#endif DBexecute_thread(database, sql); return SUCCEED; @@ -1736,7 +1748,11 @@ int DBadd_history_str(int itemid, char *value, int clock) zabbix_log(LOG_LEVEL_DEBUG,"In add_history_str()"); DBescape_string(value,value_esc,MAX_STRING_LEN); +#ifdef HAVE_MYSQL + snprintf(sql,sizeof(sql)-1,"insert delayed into history_str (clock,itemid,value) values (%d,%d,'%s')",clock,itemid,value_esc); +#else snprintf(sql,sizeof(sql)-1,"insert into history_str (clock,itemid,value) values (%d,%d,'%s')",clock,itemid,value_esc); +#endif DBexecute(sql); return SUCCEED; |