Zabbix

/*

** Copyright (C) 2001-2025 Zabbix SIA

**

** This program is free software: you can redistribute it and/or modify it under the terms of

** the GNU Affero General Public License as published by the Free Software Foundation, version 3.

**

** This program is distributed in the hope that it will be useful, but WITHOUT ANY WARRANTY;

** without even the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.

** See the GNU Affero General Public License for more details.

**

** You should have received a copy of the GNU Affero General Public License along with this program.

** If not, see <https://www.gnu.org/licenses/>.

**/

​

#include "zbxdbhigh.h"

​

#include "zbxthreads.h"

#include "zbxcfg.h"

#include "zbxcrypto.h"

#include "zbxnum.h"

#include "zbx_host_constants.h"

​

#ifdef HAVE_POSTGRESQL

#   include "zbx_dbversion_constants.h"

#endif

​

#define ZBX_DB_WAIT_DOWN    10

​

#define ZBX_MAX_SQL_SIZE    262144  /* 256KB */

#ifndef ZBX_MAX_OVERFLOW_SQL_SIZE

#   ifdef HAVE_ORACLE

        /* Do not use "overflowing" (multi-statement) queries for Oracle. */

        /* Zabbix benefits from cursor_sharing=force Oracle parameter */

        /* which doesn't apply to PL/SQL blocks. */

#       define ZBX_MAX_OVERFLOW_SQL_SIZE    0

#   else

#       define ZBX_MAX_OVERFLOW_SQL_SIZE    ZBX_MAX_SQL_SIZE

#   endif

#elif 0 != ZBX_MAX_OVERFLOW_SQL_SIZE && \

        (1024 > ZBX_MAX_OVERFLOW_SQL_SIZE || ZBX_MAX_OVERFLOW_SQL_SIZE > ZBX_MAX_SQL_SIZE)

#error ZBX_MAX_OVERFLOW_SQL_SIZE is out of range

#endif

​

#ifdef HAVE_ORACLE

#   if 0 == ZBX_MAX_OVERFLOW_SQL_SIZE

#       define  ZBX_SQL_EXEC_FROM   ZBX_CONST_STRLEN(ZBX_PLSQL_BEGIN)

#   else

#       define  ZBX_SQL_EXEC_FROM   0

#   endif

#else

#   define  ZBX_SQL_EXEC_FROM   0

#endif

​

#ifdef HAVE_MULTIROW_INSERT

#   define ZBX_ROW_DL   ","

#else

#   define ZBX_ROW_DL   ";\n"

#endif

​

ZBX_PTR_VECTOR_IMPL(db_event, zbx_db_event *)

ZBX_PTR_VECTOR_IMPL(events_ptr, zbx_event_t *)

ZBX_PTR_VECTOR_IMPL(escalation_new_ptr, zbx_escalation_new_t *)

ZBX_PTR_VECTOR_IMPL(item_diff_ptr, zbx_item_diff_t *)

ZBX_PTR_VECTOR_IMPL(trigger_diff_ptr, zbx_trigger_diff_t *)

ZBX_PTR_VECTOR_IMPL(db_field_ptr, zbx_db_field_t *)

ZBX_PTR_VECTOR_IMPL(db_value_ptr, zbx_db_value_t *)

​

void    zbx_item_diff_free(zbx_item_diff_t *item_diff)

{

    zbx_free(item_diff);

}

​

int zbx_item_diff_compare_func(const void *d1, const void *d2)

{

    const zbx_item_diff_t    *id_1 = *(const zbx_item_diff_t **)d1;

    const zbx_item_diff_t    *id_2 = *(const zbx_item_diff_t **)d2;

​

    ZBX_RETURN_IF_NOT_EQUAL(id_1->itemid, id_2->itemid);

​

    return 0;

}

​

int zbx_trigger_diff_compare_func(const void *d1, const void *d2)

{

    const zbx_trigger_diff_t    *id_1 = *(const zbx_trigger_diff_t **)d1;

    const zbx_trigger_diff_t    *id_2 = *(const zbx_trigger_diff_t **)d2;

​

    ZBX_RETURN_IF_NOT_EQUAL(id_1->triggerid, id_2->triggerid);

​

    return 0;

}