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/>.

**/

​

package oracle

​

import (

    "context"

​

    "golang.zabbix.com/sdk/errs"

    "golang.zabbix.com/sdk/zbxerr"

)

​

func archiveHandler(ctx context.Context, conn OraClient, params map[string]string, _ ...string) (interface{}, error) {

    var archiveLogs string

​

    query, args := getArchiveQuery(params["Destination"])

​

    row, err := conn.QueryRow(ctx, query, args...)

    if err != nil {

        return nil, errs.WrapConst(err, zbxerr.ErrorCannotFetchData)

    }

​

    err = row.Scan(&archiveLogs)

    if err != nil {

        return nil, errs.WrapConst(err, zbxerr.ErrorCannotFetchData)

    }

​

    if archiveLogs == "" {

        archiveLogs = "[]"

    }

​

    return archiveLogs, nil

}

​

func getArchiveQuery(destName string) (string, []any) {

    const query = `

    SELECT

        JSON_ARRAYAGG(

            JSON_OBJECT(d.DEST_NAME VALUE

                JSON_OBJECT(

                    'status'       VALUE DECODE(d.STATUS, 'VALID', 3, 'DEFERRED', 2, 'ERROR', 1, 0),

                    'log_sequence' VALUE d.LOG_SEQUENCE,

                    'error'        VALUE NVL(TO_CHAR(d.ERROR), ' ')

                )

            ) RETURNING CLOB 

        )       

    FROM

        V$ARCHIVE_DEST d,

        V$DATABASE db

    WHERE 

        d.STATUS != 'INACTIVE' 

        AND db.LOG_MODE = 'ARCHIVELOG'`