Subversion Repositories logviewer

<?php

/*

 * ViaThinkSoft LogViewer

 * Copyright 2018-2022 Daniel Marschall, ViaThinkSoft

 *

 * Licensed under the Apache License, Version 2.0 (the "License");

 * you may not use this file except in compliance with the License.

 * You may obtain a copy of the License at

 *

 *     http://www.apache.org/licenses/LICENSE-2.0

 *

 * Unless required by applicable law or agreed to in writing, software

 * distributed under the License is distributed on an "AS IS" BASIS,

 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.

 * See the License for the specific language governing permissions and

 * limitations under the License.

 */

// Please replace this code with your actual implementation

db_connect('localhost', 'root', '');

db_select_db('logviewer');

# ---

// Liefert die Anzahl der Zeilen im Ergebnis

function db_num_rows($result) {

        if (!$result) {

                $err = db_error();

                throw new Exception("Called db_num_rows() with an erroneous argument.".($err == '' ? '' : " Possible cause: $err"));

        }

        return $result->num_rows;

}

// Liefert eine Ergebniszeile als Objekt

function db_fetch_object($result, $class_name="stdClass", $params=null) {

        if (!$result) {

                $err = db_error();

                throw new Exception("Called db_fetch_object() with an erroneous argument.".($err == '' ? '' : " Possible cause: $err"));

        }

        if ($params) {

                return $result->fetch_object($class_name, $params);

        } else {

                return $result->fetch_object($class_name);

        }

}

// Öffnet eine Verbindung zu einem MySQL-Server

function db_connect($server=null, $username=null, $password=null, $new_link=false, $client_flags=0) {

        global $vts_mysqli;

        $ary = explode(':', $server);

        $host = $ary[0];

        $ini_port = ini_get("mysqli.default_port");

        $port = isset($ary[1]) ? (int)$ary[1] : ($ini_port ? (int)$ini_port : 3306);

        if (is_null($server)) $port = ini_get("mysqli.default_host");

        if (is_null($username)) $port = ini_get("mysqli.default_user");

        if (is_null($password)) $port = ini_get("mysqli.default_password");

        $vts_mysqli = new mysqli($host, $username, $password, /*dbname*/'', $port, ini_get("mysqli.default_socket"));

        return (empty($vts_mysqli->connect_error) && ($vts_mysqli->connect_errno == 0)) ? $vts_mysqli : false;

}

// Schließt eine Verbindung zu MySQL

function db_close($link_identifier=NULL) {

        global $vts_mysqli;

        $li = is_null($link_identifier) ? $vts_mysqli : $link_identifier;

        if (is_null($li)) throw new Exception("Cannot execute db_close(). No valid connection to server.");

        return $li->close();

}

// Liefert den Fehlertext der zuvor ausgeführten MySQL Operation

function db_error($link_identifier=NULL) {

        global $vts_mysqli;

        $li = is_null($link_identifier) ? $vts_mysqli : $link_identifier;

        if (is_null($li)) throw new Exception("Cannot execute db_error(). No valid connection to server.");

        return !empty($li->connect_error) ? $li->connect_error : $li->error;

}

// Maskiert spezielle Zeichen innerhalb eines Strings für die Verwendung in einer SQL-Anweisung

function db_real_escape_string($unescaped_string, $link_identifier=NULL) {

        global $vts_mysqli;

        $li = is_null($link_identifier) ? $vts_mysqli : $link_identifier;

        if (is_null($li)) throw new Exception("Cannot execute db_real_escape_string(). No valid connection to server.");

        return $li->escape_string($unescaped_string);

}

// Sendet eine Anfrage an MySQL

function db_query($query, $link_identifier=NULL) {

        global $vts_mysqli;

        $li = is_null($link_identifier) ? $vts_mysqli : $link_identifier;

        if (is_null($li)) throw new Exception("Cannot execute db_query(). No valid connection to server.");

        return $li->query($query, $resultmode=MYSQLI_STORE_RESULT);

}

// Auswahl einer MySQL Datenbank

function db_select_db($database_name, $link_identifier=NULL) {

        global $vts_mysqli;

        $li = is_null($link_identifier) ? $vts_mysqli : $link_identifier;

        if (is_null($li)) throw new Exception("Cannot execute db_select_db(). No valid connection to server.");

        return $li->select_db($database_name);

}

// Liefert die ID, die in der vorherigen Abfrage erzeugt wurde

function db_insert_id($link_identifier=NULL) {

        global $vts_mysqli;

        $li = is_null($link_identifier) ? $vts_mysqli : $link_identifier;

        if (is_null($li)) throw new Exception("Cannot execute db_insert_id(). No valid connection to server.");

        return $li->insert_id;

}