db_util.inc

<?php

// MySQL code for Librarian DB access

$link = null;
$db_error = '';

// connect to a DB with the given parameters
//
function init_db($config) {
    global $link;
    $link = @mysqli_connect(
        $config->db_host, $config->db_user, $config->db_passwd, $config->db_name
    );
    return $link;
}

// get ID of last insert
//
function insert_id() {
    global $link;
    return mysqli_insert_id($link);
}

// get string describing last error
//
function db_error() {
    global $link;
    return mysqli_error($link);
}

function enum_general($query) {
    global $link;
    $r = mysqli_query($link, $query);
    $items = array();
    while ($f = mysqli_fetch_object($r)) {
        $items[] = $f;
    }
    mysqli_free_result($r);
    return $items;
}

// enumerate a table
//
function enum($table, $clause=null) {
    if (!$clause) $clause = 'TRUE';
    $query = "select * from $table where $clause";
    return enum_general($query);
}

function table_count($table, $clause) {
    global $link;
    if (!$clause) $clause = 'TRUE';
    $query = "select count(*) as total from $table where $clause";
    $r = mysqli_query($link, $query);
    $x = mysqli_fetch_object($r);
    mysqli_free_result($r);
    return $x->total;
}

// look up record from table with given ID
//
function lookup_id($table, $id) {
    global $link;
    $query = "select * from $table where id=$id";
    $r = mysqli_query($link, $query);
    $source = mysqli_fetch_object($r);
    mysqli_free_result($r);
    return $source;
}

// return # of rows affected by last query
//
function affected_rows() {
    global $link;
    return $link->affected_rows;
}

?>