core_sql.php

Go to the documentation of this file.

<?PHP
/*~ core_sql.php
.---------------------------------------------------------------------------.
|  Software: Sencillo Core                                                  |
|   Version: 2014.008                                                       |
|   Contact: ph@mastery.sk                                                  |
| ------------------------------------------------------------------------- |
|    Author: Bc. Peter Horváth (original founder)                           |
| Copyright (c) 2014, Bc. Peter Horváth. All Rights Reserved.               |
| ------------------------------------------------------------------------- |
|   License: Distributed under the General Public License (GPL)             |
|            http://www.gnu.org/copyleft/gpl.html                           |
| This program is distributed in the hope that it will be useful - WITHOUT  |
| ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or     |
| FITNESS FOR A PARTICULAR PURPOSE.                                         |
'---------------------------------------------------------------------------'
~*/
class mysql
{
    public  $DBHost;
    public  $DBName;
    public  $DBUser;
    public  $DBPass;
    private $checksum;
    public  $con;

    public function __construct($DBHost,$DBName,$DBUser,$DBPass)
    {
        $this->DBHost = $DBHost;
        $this->DBName = $DBName;
        $this->DBUser = $DBUser;
        $this->DBPass = $DBPass;

        if(($this->DBHost!='')&&($this->DBUser!='')&&($this->DBPass!='')&&($this->DBName!=''))
        {
            $this->checksum=md5($this->DBHost.$this->DBUser.$this->DBPass.$this->DBName);
        }
        $this->con = mysql_connect($this->DBHost, $this->DBUser, $this->DBPass);
        if(! $this->con)
        {
            die("<b>core_sql: MySQL connection failed!</b> ".mysql_error());
        }
        mysql_select_db($this->DBName, $this->con);
    }
    
    final public function query($sql)
    {
        mysql_query($sql);
    }
    
    final public function write($sql)
    {
        $this->query($sql);
    }
    
    final public function close()
    {
        mysql_close($this->con);
    }
    
    final public function test()
    {
        if($this->checksum==md5($this->DBHost.$this->DBUser.$this->DBPass.$this->DBName))
        {
            if(! $this->con)
            {
                return mysql_error();
            }
            else
            {
                return true;
            }
        }
    }
}

class mysqlEdit extends mysql
{
    private $construct;
    private $table;
    private $sql;
    private $result;
    private $column;
    private $setupdate;
    private $colout;
    private $out;
    private $metaout;
    private $csum;
    private $sizeout;

    public function newColumn($name,$type="INT")
    {
        $this->construct .= ' , `'.$name.'` '.strtoupper($type).'';
    }
    
    public function createTable($name)
    {
        $this->table = $name;
        $this->query('CREATE TABLE IF NOT EXISTS `'.$name.'` ( `id` INT NOT NULL AUTO_INCREMENT, PRIMARY KEY(`id`)'.$this->construct.');');
    }
    
    public function openTable($name)
    {
        $this->table = $name;
        $this->sql="SELECT `COLUMN_NAME` FROM `INFORMATION_SCHEMA`.`COLUMNS` WHERE `TABLE_SCHEMA`='".$this->DBName."' AND `TABLE_NAME`='".$this->table."';";
        $this->con=mysql_connect($this->DBHost,$this->DBUser,$this->DBPass);
        mysql_select_db($this->DBName, $this->con);
        $this->result=mysql_query($this->sql);
        while($row=mysql_fetch_array($this->result))
        {
            $this->column.='`'.$row['COLUMN_NAME'].'`,';
        }
    }
    
    public function insert($values)
    {
        $this->query('INSERT INTO '.$this->table.' ('.substr($this->column, 0, -1).') VALUES (null,'.$values.');');
    }
    
    public function set($column,$value)
    {
        if(is_numeric($value))
        {
            $this->setupdate.='`'.$column.'`='.$value.',';
        }
        else
        {
            $this->setupdate.='`'.$column.'`="'.$value.'",';
        }
    }
    
    public function update($if,$sets=null)
    {
        $this->query('UPDATE '.$this->table.' SET '.substr($this->setupdate, 0, -1).$sets.' WHERE '.$if.';');
    }
    
    public function delete($if)
    {
        if($if=="all")
        {
            $this->query('DELETE FROM `'.$this->table.'` WHERE `id`>0;');
        }
        else
        {
            $this->query('DELETE FROM `'.$this->table.'` WHERE '.$if.';');
        }
    }
    
    public function output($if="`id`>0",$order="`id` ASC",$limit=1000)
    {
        $this->sql="SELECT * FROM `".$this->table."` WHERE ".$if." ORDER BY ".$order." LIMIT ".$limit.";";
        $this->con=mysql_connect($this->DBHost,$this->DBUser,$this->DBPass);
        mysql_select_db($this->DBName, $this->con);
        $this->result=mysql_query($this->sql);
        $this->colout=explode(",",str_replace("`","",substr($this->column, 0, -1)));
        $i=0;
        $j=0;
        $this->out = array('header'=>$this->colout,'line'=>array(array()));
        $this->csum = md5($this->con);
        while($row=mysql_fetch_array($this->result))
        {
            $i=0;
            $j++;
            while(sizeof($this->colout)>$i)
            {
                $this->out['line'][$j][$i]=$row[$this->colout[$i++]];
            }
        }
        return $this->out;
    }
}
$mysql = new mysqlEdit($DBHost,$DBName,$DBUser,$DBPass);
?>