diff options
author | alex <alex@97f52cf1-0a1b-0410-bd0e-c28be96e8082> | 2007-03-23 14:24:25 +0000 |
---|---|---|
committer | alex <alex@97f52cf1-0a1b-0410-bd0e-c28be96e8082> | 2007-03-23 14:24:25 +0000 |
commit | 643a4913561d844a4292cb28d9d83d7a66dfe623 (patch) | |
tree | dd5c54f0d53702ed19c476e7e291458cb1535b30 /src/libs/zbxdbhigh/db.c | |
parent | ca2394bf6c65466e40b5ea2dd37cc50b22543a16 (diff) | |
download | zabbix-643a4913561d844a4292cb28d9d83d7a66dfe623.tar.gz zabbix-643a4913561d844a4292cb28d9d83d7a66dfe623.tar.xz zabbix-643a4913561d844a4292cb28d9d83d7a66dfe623.zip |
Some code beautification.
git-svn-id: svn://svn.zabbix.com/trunk@3917 97f52cf1-0a1b-0410-bd0e-c28be96e8082
Diffstat (limited to 'src/libs/zbxdbhigh/db.c')
-rw-r--r-- | src/libs/zbxdbhigh/db.c | 208 |
1 files changed, 160 insertions, 48 deletions
diff --git a/src/libs/zbxdbhigh/db.c b/src/libs/zbxdbhigh/db.c index 4bbadedb..d1664cfa 100644 --- a/src/libs/zbxdbhigh/db.c +++ b/src/libs/zbxdbhigh/db.c @@ -250,19 +250,23 @@ int DBget_function_result(char **result,char *functionid) int res = SUCCEED; /* 0 is added to distinguish between lastvalue==NULL and empty result */ - dbresult = DBselect("select 0,lastvalue from functions where functionid=%s", functionid ); + dbresult = DBselect("select 0,lastvalue from functions where functionid=%s", + functionid ); row = DBfetch(dbresult); if(!row) { - zabbix_log(LOG_LEVEL_WARNING, "No function for functionid:[%s]", functionid ); - zabbix_syslog("No function for functionid:[%s]", functionid ); + zabbix_log(LOG_LEVEL_WARNING, "No function for functionid:[%s]", + functionid ); + zabbix_syslog("No function for functionid:[%s]", + functionid); res = FAIL; } else if(DBis_null(row[1]) == SUCCEED) { - zabbix_log(LOG_LEVEL_DEBUG, "function.lastvalue==NULL [%s]", functionid ); + zabbix_log(LOG_LEVEL_DEBUG, "function.lastvalue==NULL [%s]", + functionid); res = FAIL; } else @@ -306,7 +310,6 @@ static void get_latest_event_status(zbx_uint64_t triggerid, int *prev_status, in zbx_snprintf(sql,sizeof(sql),"select eventid,value,clock from events where source=%d and objectid=" ZBX_FS_UI64 " order by clock desc", EVENT_SOURCE_TRIGGERS, triggerid); - zabbix_log(LOG_LEVEL_DEBUG,"SQL [%s]", sql); result = DBselectN(sql,20); while((row=DBfetch(result))) @@ -352,7 +355,8 @@ int latest_service_alarm(zbx_uint64_t serviceid, int status) zabbix_log(LOG_LEVEL_DEBUG,"In latest_service_alarm()"); - result = DBselect("select max(clock) from service_alarms where serviceid=" ZBX_FS_UI64,serviceid); + result = DBselect("select max(clock) from service_alarms where serviceid=" ZBX_FS_UI64, + serviceid); row = DBfetch(result); if(!row || DBis_null(row[0])==SUCCEED) @@ -365,7 +369,9 @@ int latest_service_alarm(zbx_uint64_t serviceid, int status) clock=atoi(row[0]); DBfree_result(result); - result = DBselect("select value from service_alarms where serviceid=" ZBX_FS_UI64 " and clock=%d",serviceid,clock); + result = DBselect("select value from service_alarms where serviceid=" ZBX_FS_UI64 " and clock=%d", + serviceid, + clock); row = DBfetch(result); if(row && DBis_null(row[0]) != SUCCEED) { @@ -390,7 +396,10 @@ int DBadd_service_alarm(zbx_uint64_t serviceid,int status,int clock) return SUCCEED; } - DBexecute("insert into service_alarms(serviceid,clock,value) values(" ZBX_FS_UI64 ",%d,%d)", serviceid, clock, status); + DBexecute("insert into service_alarms(serviceid,clock,value) values(" ZBX_FS_UI64 ",%d,%d)", + serviceid, + clock, + status); zabbix_log(LOG_LEVEL_DEBUG,"End of add_service_alarm()"); @@ -429,7 +438,10 @@ int DBupdate_trigger_value(DB_TRIGGER *trigger, int new_value, int now, char *re get_latest_event_status(trigger->triggerid, &event_prev_status, &event_last_status); zabbix_log(LOG_LEVEL_DEBUG,"tr value [%d] event_prev_value [%d] event_last_status [%d] new_value [%d]", - trigger->value, event_prev_status, event_last_status, new_value); + trigger->value, + event_prev_status, + event_last_status, + new_value); /* The lastest event has the same status, skip of so. */ if(event_last_status != new_value) @@ -437,11 +449,18 @@ int DBupdate_trigger_value(DB_TRIGGER *trigger, int new_value, int now, char *re zabbix_log(LOG_LEVEL_DEBUG,"Updating trigger"); if(reason==NULL) { - DBexecute("update triggers set value=%d,lastchange=%d,error='' where triggerid=" ZBX_FS_UI64,new_value,now,trigger->triggerid); + DBexecute("update triggers set value=%d,lastchange=%d,error='' where triggerid=" ZBX_FS_UI64, + new_value, + now, + trigger->triggerid); } else { - DBexecute("update triggers set value=%d,lastchange=%d,error='%s' where triggerid=" ZBX_FS_UI64,new_value,now,reason, trigger->triggerid); + DBexecute("update triggers set value=%d,lastchange=%d,error='%s' where triggerid=" ZBX_FS_UI64, + new_value, + now, + reason, + trigger->triggerid); } if( ((trigger->value == TRIGGER_VALUE_TRUE) && (new_value == TRIGGER_VALUE_FALSE)) || ((trigger->value == TRIGGER_VALUE_FALSE) && (new_value == TRIGGER_VALUE_TRUE)) || @@ -475,7 +494,8 @@ int DBupdate_trigger_value(DB_TRIGGER *trigger, int new_value, int now, char *re } else { - zabbix_log(LOG_LEVEL_DEBUG,"Event not added for triggerid [" ZBX_FS_UI64 "]", trigger->triggerid); + zabbix_log(LOG_LEVEL_DEBUG,"Event not added for triggerid [" ZBX_FS_UI64 "]", + trigger->triggerid); ret = FAIL; } } @@ -491,7 +511,11 @@ void update_triggers_status_to_unknown(zbx_uint64_t hostid,int clock,char *reaso zabbix_log(LOG_LEVEL_DEBUG,"In update_triggers_status_to_unknown()"); - result = DBselect("select distinct t.triggerid,t.expression,t.description,t.status,t.priority,t.value,t.url,t.comments from hosts h,items i,triggers t,functions f where f.triggerid=t.triggerid and f.itemid=i.itemid and h.hostid=i.hostid and h.hostid=" ZBX_FS_UI64 " and i.key_ not in ('%s','%s','%s')",hostid,SERVER_STATUS_KEY, SERVER_ICMPPING_KEY, SERVER_ICMPPINGSEC_KEY); + result = DBselect("select distinct t.triggerid,t.expression,t.description,t.status,t.priority,t.value,t.url,t.comments from hosts h,items i,triggers t,functions f where f.triggerid=t.triggerid and f.itemid=i.itemid and h.hostid=i.hostid and h.hostid=" ZBX_FS_UI64 " and i.key_ not in ('%s','%s','%s')", + hostid, + SERVER_STATUS_KEY, + SERVER_ICMPPING_KEY, + SERVER_ICMPPINGSEC_KEY); while((row=DBfetch(result))) { @@ -515,7 +539,8 @@ void update_triggers_status_to_unknown(zbx_uint64_t hostid,int clock,char *reaso void DBdelete_service(zbx_uint64_t serviceid) { DBexecute("delete from services_links where servicedownid=" ZBX_FS_UI64 " or serviceupid=" ZBX_FS_UI64, - serviceid, serviceid); + serviceid, + serviceid); DBexecute("delete from services where serviceid=" ZBX_FS_UI64, serviceid); } @@ -526,8 +551,10 @@ void DBdelete_services_by_triggerid(zbx_uint64_t triggerid) DB_RESULT result; DB_ROW row; - zabbix_log(LOG_LEVEL_DEBUG,"In DBdelete_services_by_triggerid(" ZBX_FS_UI64 ")", triggerid); - result = DBselect("select serviceid from services where triggerid=" ZBX_FS_UI64, triggerid); + zabbix_log(LOG_LEVEL_DEBUG,"In DBdelete_services_by_triggerid(" ZBX_FS_UI64 ")", + triggerid); + result = DBselect("select serviceid from services where triggerid=" ZBX_FS_UI64, + triggerid); while((row=DBfetch(result))) { @@ -537,13 +564,15 @@ void DBdelete_services_by_triggerid(zbx_uint64_t triggerid) } DBfree_result(result); - zabbix_log(LOG_LEVEL_DEBUG,"End of DBdelete_services_by_triggerid(" ZBX_FS_UI64 ")", triggerid); + zabbix_log(LOG_LEVEL_DEBUG,"End of DBdelete_services_by_triggerid(" ZBX_FS_UI64 ")", + triggerid); } void DBdelete_trigger(zbx_uint64_t triggerid) { DBexecute("delete from trigger_depends where triggerid_down=" ZBX_FS_UI64 " or triggerid_up=" ZBX_FS_UI64, - triggerid, triggerid); + triggerid, + triggerid); DBexecute("delete from functions where triggerid=" ZBX_FS_UI64, triggerid); DBexecute("delete from events where triggerid=" ZBX_FS_UI64, @@ -643,7 +672,11 @@ void DBupdate_triggers_status_after_restart(void) now=time(NULL); - result = DBselect("select distinct t.triggerid,t.expression,t.description,t.status,t.priority,t.value,t.url,t.comments from hosts h,items i,triggers t,functions f where f.triggerid=t.triggerid and f.itemid=i.itemid and h.hostid=i.hostid and i.nextcheck+i.delay<%d and i.key_<>'%s' and h.status not in (%d,%d)",now,SERVER_STATUS_KEY, HOST_STATUS_DELETED, HOST_STATUS_TEMPLATE); + result = DBselect("select distinct t.triggerid,t.expression,t.description,t.status,t.priority,t.value,t.url,t.comments from hosts h,items i,triggers t,functions f where f.triggerid=t.triggerid and f.itemid=i.itemid and h.hostid=i.hostid and i.nextcheck+i.delay<%d and i.key_<>'%s' and h.status not in (%d,%d)", + now, + SERVER_STATUS_KEY, + HOST_STATUS_DELETED, + HOST_STATUS_TEMPLATE); while((row=DBfetch(result))) { @@ -656,7 +689,9 @@ void DBupdate_triggers_status_after_restart(void) trigger.url = row[6]; trigger.comments = row[7]; - result2 = DBselect("select min(i.nextcheck+i.delay) from hosts h,items i,triggers t,functions f where f.triggerid=t.triggerid and f.itemid=i.itemid and h.hostid=i.hostid and i.nextcheck<>0 and t.triggerid=%d and i.type<>%d",trigger.triggerid,ITEM_TYPE_TRAPPER); + result2 = DBselect("select min(i.nextcheck+i.delay) from hosts h,items i,triggers t,functions f where f.triggerid=t.triggerid and f.itemid=i.itemid and h.hostid=i.hostid and i.nextcheck<>0 and t.triggerid=%d and i.type<>%d", + trigger.triggerid, + ITEM_TYPE_TRAPPER); row2=DBfetch(result2); if(!row2 || DBis_null(row2[0])==SUCCEED) { @@ -695,13 +730,16 @@ void DBupdate_host_availability(zbx_uint64_t hostid,int available,int clock, cha strscpy(error_esc,""); } - result = DBselect("select available,disable_until from hosts where hostid=" ZBX_FS_UI64, hostid); + result = DBselect("select available,disable_until from hosts where hostid=" ZBX_FS_UI64, + hostid); row=DBfetch(result); if(!row) { - zabbix_log(LOG_LEVEL_ERR, "Cannot select host with hostid [" ZBX_FS_UI64 "]",hostid); - zabbix_syslog("Cannot select host with hostid [" ZBX_FS_UI64 "]",hostid); + zabbix_log(LOG_LEVEL_ERR, "Cannot select host with hostid [" ZBX_FS_UI64 "]", + hostid); + zabbix_syslog("Cannot select host with hostid [" ZBX_FS_UI64 "]", + hostid); DBfree_result(result); return; } @@ -716,7 +754,8 @@ void DBupdate_host_availability(zbx_uint64_t hostid,int available,int clock, cha } else {*/ - zabbix_log(LOG_LEVEL_DEBUG, "Host already has availability [%d]",available); + zabbix_log(LOG_LEVEL_DEBUG, "Host already has availability [%d]", + available); DBfree_result(result); return; /* }*/ @@ -726,7 +765,9 @@ void DBupdate_host_availability(zbx_uint64_t hostid,int available,int clock, cha if(available==HOST_AVAILABLE_TRUE) { - DBexecute("update hosts set available=%d,error=' ',errors_from=0 where hostid=" ZBX_FS_UI64,HOST_AVAILABLE_TRUE,hostid); + DBexecute("update hosts set available=%d,error=' ',errors_from=0 where hostid=" ZBX_FS_UI64, + HOST_AVAILABLE_TRUE, + hostid); } else if(available==HOST_AVAILABLE_FALSE) { @@ -740,14 +781,18 @@ void DBupdate_host_availability(zbx_uint64_t hostid,int available,int clock, cha }*/ /* '%s ' - space to make Oracle happy */ DBexecute("update hosts set available=%d,error='%s ' where hostid=" ZBX_FS_UI64, - HOST_AVAILABLE_FALSE,error_esc,hostid); + HOST_AVAILABLE_FALSE, + error_esc, + hostid); } else { zabbix_log( LOG_LEVEL_ERR, "Unknown host availability [%d] for hostid [" ZBX_FS_UI64 "]", - available, hostid); + available, + hostid); zabbix_syslog("Unknown host availability [%d] for hostid [" ZBX_FS_UI64 "]", - available, hostid); + available, + hostid); return; } @@ -772,9 +817,11 @@ int DBupdate_item_status_to_notsupported(zbx_uint64_t itemid, char *error) strscpy(error_esc,""); } - /* '&s ' to make Oracle happy */ + /* '%s ' to make Oracle happy */ DBexecute("update items set status=%d,error='%s ' where itemid=" ZBX_FS_UI64, - ITEM_STATUS_NOTSUPPORTED,error_esc,itemid); + ITEM_STATUS_NOTSUPPORTED, + error_esc, + itemid); return SUCCEED; } @@ -792,7 +839,8 @@ int DBadd_trend(zbx_uint64_t itemid, double value, int clock) hour=clock-clock%3600; result = DBselect("select num,value_min,value_avg,value_max from trends where itemid=" ZBX_FS_UI64 " and clock=%d", - itemid, hour); + itemid, + hour); row=DBfetch(result); @@ -809,12 +857,22 @@ int DBadd_trend(zbx_uint64_t itemid, double value, int clock) value_avg=(num*value_avg+value)/(num+1); num++; DBexecute("update trends set num=%d, value_min=" ZBX_FS_DBL ", value_avg=" ZBX_FS_DBL ", value_max=" ZBX_FS_DBL " where itemid=" ZBX_FS_UI64 " and clock=%d", - num, value_min, value_avg, value_max, itemid, hour); + num, + value_min, + value_avg, + value_max, + itemid, + hour); } else { DBexecute("insert into trends (clock,itemid,num,value_min,value_avg,value_max) values (%d," ZBX_FS_UI64 ",%d," ZBX_FS_DBL "," ZBX_FS_DBL "," ZBX_FS_DBL ")", - hour, itemid, 1, value, value, value); + hour, + itemid, + 1, + value, + value, + value); } DBfree_result(result); @@ -827,14 +885,19 @@ int DBadd_history(zbx_uint64_t itemid, double value, int clock) zabbix_log(LOG_LEVEL_DEBUG,"In add_history()"); DBexecute("insert into history (clock,itemid,value) values (%d," ZBX_FS_UI64 "," ZBX_FS_DBL ")", - clock,itemid,value); + clock, + itemid, + value); DBadd_trend(itemid, value, clock); if(CONFIG_MASTER_NODEID>0) { DBexecute("insert into history_sync (nodeid,clock,itemid,value) values (%d,%d," ZBX_FS_UI64 "," ZBX_FS_DBL ")", - get_nodeid_by_id(itemid),clock,itemid,value); + get_nodeid_by_id(itemid), + clock, + itemid, + value); } return SUCCEED; @@ -845,14 +908,19 @@ int DBadd_history_uint(zbx_uint64_t itemid, zbx_uint64_t value, int clock) zabbix_log(LOG_LEVEL_DEBUG,"In add_history_uint()"); DBexecute("insert into history_uint (clock,itemid,value) values (%d," ZBX_FS_UI64 "," ZBX_FS_UI64 ")", - clock,itemid,value); + clock, + itemid, + value); DBadd_trend(itemid, (double)value, clock); if(CONFIG_MASTER_NODEID>0) { DBexecute("insert into history_uint_sync (nodeid,clock,itemid,value) values (%d,%d," ZBX_FS_UI64 "," ZBX_FS_UI64 ")", - get_nodeid_by_id(itemid),clock,itemid,value); + get_nodeid_by_id(itemid), + clock, + itemid, + value); } return SUCCEED; @@ -866,12 +934,17 @@ int DBadd_history_str(zbx_uint64_t itemid, char *value, int clock) DBescape_string(value,value_esc,MAX_STRING_LEN); DBexecute("insert into history_str (clock,itemid,value) values (%d," ZBX_FS_UI64 ",'%s')", - clock,itemid,value_esc); + clock, + itemid, + value_esc); if(CONFIG_MASTER_NODEID>0) { DBexecute("insert into history_str_sync (nodeid,clock,itemid,value) values (%d,%d," ZBX_FS_UI64 ",'%s')", - get_nodeid_by_id(itemid),clock,itemid,value_esc); + get_nodeid_by_id(itemid), + clock, + itemid, + value_esc); } return SUCCEED; @@ -1192,7 +1265,19 @@ int DBget_queue_count(void) now=time(NULL); /* zbx_snprintf(sql,sizeof(sql),"select count(*) from items i,hosts h where i.status=%d and i.type not in (%d) and h.status=%d and i.hostid=h.hostid and i.nextcheck<%d and i.key_<>'status'", ITEM_STATUS_ACTIVE, ITEM_TYPE_TRAPPER, HOST_STATUS_MONITORED, now);*/ - result = DBselect("select count(*) from items i,hosts h where i.status=%d and i.type not in (%d) and ((h.status=%d and h.available!=%d) or (h.status=%d and h.available=%d and h.disable_until<=%d)) and i.hostid=h.hostid and i.nextcheck<%d and i.key_ not in ('%s','%s','%s','%s')", ITEM_STATUS_ACTIVE, ITEM_TYPE_TRAPPER, HOST_STATUS_MONITORED, HOST_AVAILABLE_FALSE, HOST_STATUS_MONITORED, HOST_AVAILABLE_FALSE, now, now, SERVER_STATUS_KEY, SERVER_ICMPPING_KEY, SERVER_ICMPPINGSEC_KEY, SERVER_ZABBIXLOG_KEY); + result = DBselect("select count(*) from items i,hosts h where i.status=%d and i.type not in (%d) and ((h.status=%d and h.available!=%d) or (h.status=%d and h.available=%d and h.disable_until<=%d)) and i.hostid=h.hostid and i.nextcheck<%d and i.key_ not in ('%s','%s','%s','%s')", + ITEM_STATUS_ACTIVE, + ITEM_TYPE_TRAPPER, + HOST_STATUS_MONITORED, + HOST_AVAILABLE_FALSE, + HOST_STATUS_MONITORED, + HOST_AVAILABLE_FALSE, + now, + now, + SERVER_STATUS_KEY, + SERVER_ICMPPING_KEY, + SERVER_ICMPPINGSEC_KEY, + SERVER_ZABBIXLOG_KEY); row=DBfetch(result); @@ -1242,7 +1327,15 @@ int DBadd_alert(zbx_uint64_t actionid, zbx_uint64_t userid, zbx_uint64_t trigger DBexecute("insert into alerts (alertid, actionid,triggerid,userid,clock,mediatypeid,sendto,subject,message,status,retries)" " values (" ZBX_FS_UI64 "," ZBX_FS_UI64 "," ZBX_FS_UI64 "," ZBX_FS_UI64 ",%d," ZBX_FS_UI64 ",'%s','%s','%s',0,0)", - DBget_maxid("alerts","alertid"), actionid,triggerid,userid,now,mediatypeid,sendto_esc,subject_esc,message_esc); + DBget_maxid("alerts","alertid"), + actionid, + triggerid, + userid, + now, + mediatypeid, + sendto_esc, + subject_esc, + message_esc); zbx_free(sendto_esc); zbx_free(subject_esc); @@ -1437,7 +1530,13 @@ zbx_uint64_t DBget_nextid(char *table, char *field) min = (zbx_uint64_t)__UINT64_C(100000000000000)*(zbx_uint64_t)CONFIG_NODEID; max = (zbx_uint64_t)__UINT64_C(100000000000000)*(zbx_uint64_t)(CONFIG_NODEID+1)-1; - result = DBselect("select max(%s) from %s where %s>=" ZBX_FS_UI64 " and %s<=" ZBX_FS_UI64, field, table, field, min, field, max); + result = DBselect("select max(%s) from %s where %s>=" ZBX_FS_UI64 " and %s<=" ZBX_FS_UI64, + field, + table, + field, + min, + field, + max); /* zabbix_log(LOG_LEVEL_WARNING, "select max(%s) from %s where %s>=" ZBX_FS_UI64 " and %s<=" ZBX_FS_UI64, field, table, field, min, field, max); */ row=DBfetch(result); @@ -1471,24 +1570,33 @@ zbx_uint64_t DBget_maxid(char *table, char *field) do { result = DBselect("select nextid from ids where nodeid=%d and table_name='%s' and field_name='%s'", - CONFIG_NODEID, table, field); + CONFIG_NODEID, + table, + field); row = DBfetch(result); if(!row || DBis_null(row[0])==SUCCEED) { DBfree_result(result); result = DBselect("select max(%s) from %s where " ZBX_COND_NODEID, - field, table, LOCAL_NODE(field)); + field, + table, + LOCAL_NODE(field)); row = DBfetch(result); if(!row || DBis_null(row[0])==SUCCEED) { DBexecute("insert into ids (nodeid,table_name,field_name,nextid) values (%d,'%s','%s',%d)", - CONFIG_NODEID, table, field, + CONFIG_NODEID, + table, + field, CONFIG_NODEID*(zbx_uint64_t)__UINT64_C(100000000000000)+1); } else { DBexecute("insert into ids (nodeid,table_name,field_name,nextid) values (%d,'%s','%s',%s)", - CONFIG_NODEID, table, field, row[0]); + CONFIG_NODEID, + table, + field, + row[0]); } DBfree_result(result); continue; @@ -1499,10 +1607,14 @@ zbx_uint64_t DBget_maxid(char *table, char *field) DBfree_result(result); DBexecute("update ids set nextid=nextid+1 where nodeid=%d and table_name='%s' and field_name='%s'", - CONFIG_NODEID, table, field); + CONFIG_NODEID, + table, + field); result = DBselect("select nextid from ids where nodeid=%d and table_name='%s' and field_name='%s'", - CONFIG_NODEID, table, field); + CONFIG_NODEID, + table, + field); row = DBfetch(result); if(!row || DBis_null(row[0])==SUCCEED) { |