PsyDB+ Class

Extendable MySQL object for database based applications.

also includes table maintance utilities

<?php

class psydb {
    /* psydb class 0.4 --- 13.01.2013
     * provides low-level mysql functions
     * coded by Armagan Corlu
     * root@psychip.net
     * 
     * + support for predefined connection parameters
     * + can parse external database resources
     * + simple and clean
     * + Low memory usage
     * + provides predefined maintance queries 
     * 
     * - Fixed warning and notices
     * - Fixed table update procedure
     * 
     * generic functions:
     * rquery($query): returns a simple mysql resource
     * aquery($query): return a single line in one array
     * mquery($query): return all results in a inception (array in array)
     * q2table($query,$id): returns sql output as html table
     */

private $c;
    private $p;
    private $res;
    private $buf;
    private $opened = false;

function __destruct() {
        if ($this->opened) {
            if ($this->p == false) {
                @mysql_close($this->c);
            }
        }
    }

/* base read-write functions */

public function rquery($query) {
        if ($this->opened) {
            $this->res = mysql_query($query, $this->c) or die(mysql_error());
            return $this->res;
        } else {
            $this->res = mysql_query($query) or die(mysql_error());
            return $this->res;
        }
    }

public function aquery($query) {
        $res = $this->rquery($query);
        $data = mysql_fetch_array($res);
        $cikti = array();
        if (count($data) > 1) {
            foreach ($data as $key => $value) {
                if (!is_int($key)) {
                    $cikti[$key] = $value;
                }
            }
        }
        return $cikti;
    }

private function multiparse($res) {
        $cikti = array();
        while ($this->buf = mysql_fetch_assoc($res)) {
            array_push($cikti, $this->buf);
        }

return $cikti;
    }

public function mquery($query) {
        $link = $this->rquery($query);
        return $this->multiparse($link);
    }

public function insert($tablo, $array) {
        /* "column" => "value" formatli bir array'i tabloya basar
         * array icinde en az 2 baslik bulunmali!
         */
        $toplam = count($array);
        $basliklar = array_keys($array);

$bstr = "";
        $vstr = "";
        for ($i = 0; $i < $toplam - 1; $i++) {
            $bstr.=mysql_escape_string($basliklar[$i]) . ', ';
            $vstr.="'" . mysql_escape_string($array[$basliklar[$i]]) . "', ";
        }

$bstr.=mysql_escape_string($basliklar[$toplam - 1]);
        $vstr.="'" . mysql_escape_string($array[$basliklar[$toplam - 1]]) . "'";
        echo $vstr;
        $cikti = $this->rquery("INSERT INTO " . $tablo . " (" . $bstr . ") VALUES (" . $vstr . ");");
        return $cikti;
    }

public function newtable($tablo, $array) {
        /* "title" => "type" formatli bir array'den tablo olusturur
         * array icinde en az 2 baslik bulunmali!
         */
        $sqlstr = "";

foreach (array_keys($array) as $caption) {
            $sqlstr.=$caption . " " . $array[$caption] . ', ';
        }

$cikti = $this->rquery("CREATE TABLE IF NOT EXISTS " . $tablo . " (ID int AUTO_INCREMENT NOT NULL, " . $sqlstr . "PRIMARY KEY (ID)) ENGINE = InnoDB;");
        return $cikti;
    }

public function update($tablo, $array, $where, $value) {
        /* "column" => "value" formatli bir array'i tabloya basar
         * array icinde en az 2 baslik bulunmali!
         */
        $toplam = count($array);
        $basliklar = array_keys($array);
        $bstr = "SET ";
        for ($i = 0; $i < $toplam - 1; $i++) {
            $bstr.=mysql_escape_string($basliklar[$i]) . '=' . "'" . mysql_escape_string($array[$basliklar[$i]]) . "'" . ', ';
        }

$bstr.=mysql_escape_string($basliklar[$i]) . '=' . "'" . mysql_escape_string($array[$basliklar[$i]]) . "'";

$cikti = $this->rquery("UPDATE " . $tablo . " " . $bstr . " WHERE " . $where . "=" . "'" . $value . "'");
        return $cikti;
    }

/* Extra Stuff */

public function q2table($query, $id = "") {
        $array = $this->mquery($query);
        if ($id == "") {
            $id = md5($query);
        }
        if (count($array) > 1) {
            $output = '<table id="' . $id . '" border="1"><thead><tr>';
            foreach (array_keys($array[0]) as $title) {
                $output .= '<th>' . $title . '</th>';
            }
            $output .= '</tr></thead><tbody>';
            foreach ($array as $inarray) {
                $output.='<tr>';
                foreach (array_keys($inarray) as $title) {
                    $output .= '<td>' . $inarray[$title] . '</td>';
                }
                $output.='</tr>';
            }
            $output.='</tbody></table>';
            return $output;
        } else {
            return "No Results";
        }
    }

/* Maintance Tools */

function applyuserfunc($table, $column, $func) {
        /*
         * string analiz eden bir kullanici fonksiyonunu
         * belirtilen tablodan gecirir
         * 
         * true yada false ceviren tek parametreli bir fonksiyon olmali
         * eger true cevirirse cikti verir
         * 
         * $column must be a text field!
         *  
         */

$hede = $this->mquery("SELECT * FROM " . $table);
        $cikti = array();
        foreach ($hede as $entry) {
            $var = false;
            eval('$var=' . $func . "('" . addslashes($entry[$column]) . "');");
            if ($var == true) {      // burasi duruma göre modifiye edilebilir
                $cikti[] = $entry;     // cikti alani
            }
        }
        return $cikti;
    }

function duplicatecheck($table, $column) {
        $hede = $this->mquery("SELECT DISTINCT(" . $column . ") AS entry, COUNT(" . $column . ") AS entrycount FROM " . $table . " GROUP BY " . $column . " HAVING entrycount > 1");
        return $hede;
    }

function duplicateremove($table, $column) {
        /*
         * returns deleted line count 
         */
        $hede = $this->mquery("SELECT DISTINCT(" . $column . ") AS entry, COUNT(" . $column . ") AS entrycount FROM " . $table . " GROUP BY " . $column . " HAVING entrycount > 1");
        $i = 0;
        foreach ($hede as $entry) {
            $this->rquery("DELETE FROM " . $table . " WHERE " . $column . "='" . addslashes($entry['entry']) . "' LIMIT " . ($entry['entrycount'] - 1) . ";");
            $i++;
        }
        return $i;
    }

}

Size:	7 KB
Date:	20/10/2021
Crc32:	2834945679
Modified on:	2 Year, 6 Month ago

October 20, 2021