mysql lib

<?php
/*
This file is part of Tyrien Framework.

Tyrien is free software: you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation,version 2 of the License.

Tyrien 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 General Public License for more details.

You should have received a copy of the GNU General Public License
along with Foobar. If not, see <http://www.gnu.org/licenses/>.
*/

$db=new mysql;
$MYSQL=array();

class mysql {
const NAME="mysql";
const VERSION="0.6";
public $db;
public $record;
public $result;
public $tabella;

private $db_host=mysqlSetting::DB_HOST;
private $db_port=mysqlSetting::DB_PORT;
private $db_user=mysqlSetting::DB_USER;
private $db_pass=mysqlSetting::DB_PASS;
private $db_name=mysqlSetting::DB_NAME;

//Connessione al database.
public function connetti(){

$connessione=mysql_connect("$this->db_host"."$this->db_port","$this->db_user","$this->db_pass");
if ($connessione){
$link_db=mysql_select_db("$this->db_name",$connessione);
if($link_db) $this->db=$connessione;
if(globalSetting::DEBUG==1)echo "Connessione mysql $link_db <BR>";
}
}

public function disconnetti(){
//mysql_free_result($result); // libero la memoria di php occupata dai record estratti con SELECT
mysql_close($this->db); // Chiudo la connessione MySQL
}

private function pulisciStringa($string){
// Pulisce una stringa dagli spazi iniziali e finali...
$string=rtrim($string);
$string=ltrim($string);
return $string;
}

private function query2array($result){
// Prende in entrata il risultato odella query e ritorna un array...
if ($result){
$i=0;
do{
$riga=mysql_fetch_array($result);
$recordset[$i]=$riga;
$i++;
}while($riga);
unset($recordset[$i-1]);
return $recordset;
}else{
return FALSE;
}
}

public function scriviQuery($record,$tabella){
/*
* Prende in entrata in array associativo contenente i dati da inserire.
*/
$query="insert into $tabella (";
$valori="";
foreach($record as $chiave=>$valore){
// Il campo id è determinato da mysql...
if($chiave=="id") continue;
$query.="$chiave,";
$valori.="'$valore',";
}
$query=substr($query,0,-1);
$valori=substr($valori,0,-1);
$query.=") values($valori) ";
$result=mysql_query($query);
if($result){
return mysql_insert_id();//Stampa l'ultimo id...
}else{
return $result;
}
}

public function leggiQuery($tabella=false,$campi="*",$condizione=false,$ordine=false,$limite=false){
/*
* Guida all'utilizzo:
* leggiQuery($tabella,$campi,$condizione);
*
* $campi accetta come unico parametro in entrata una stringa
* contenente tutti i valori separati da una virgola:
* "ciao,ciao,ciao,ciao,ciao,ciao"
*
* $tabella="utenti";
* leggiQuery($tabella);
*
* In questo caso verranno stampati tutti i campi della cartella utenti,
* questo perch� se lasciate vuote le variabili $campi e $condizione
* assumeranno automaticamente i valori * e false quindi la query inviata
* a mysql sarˆ la seguente:
* "SELECT * FROM utenti"
* Il campo where non viene neanche preso in considerazione poich�
* condizione � settato false.
*/
if(!$tabella)$tabella=$this->tabella;
$this->result="";
$campi=$this->pulisciStringa($campi);
$query="select $campi from $tabella"; // Query base per il recupero dei dati.
if ($condizione != false)$query.=" WHERE ".$condizione; // Se condizione � utilizzato lo include nella query.
if ($ordine != false)$query.=" ORDER BY ".$ordine; // Ordino il risultato della richiesta se richiesto.
if ($limite != false) $query.=" LIMIT ".$limite; // Limito i risultati della richiesta se richiesto.
$result=mysql_query($query,$this->db);
$result=$this->query2array($result); // In questo modo metto tutto in un array...
$this->result=$result;
if(globalSetting::DEBUG==1)echo "NN MySQL, risultato query: $result <BR>";
return $result;
}

public function directQuery($query){
$result=mysql_query($query,$this->db);
$result=$this->query2array($result); // In questo modo metto tutto in un array...
$this->result=$result;
if(globalSetting::DEBUG==1)echo "NN MySQL, risultato query: $result <BR>";
return $result;
}

public function dropQuery($table,$where){
if(globalSetting::DEBUG==1)echo "!! MySQL :: Cancello il campo relativo a...".$where."<BR>";
$preQuery="DELETE FROM ".$table." WHERE ".$where;
$result=mysql_query($preQuery,$this->db);
return $result;
}

}
?>

<?
/*
This file is part of Tyrien Framework.

Tyrien is free software: you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation,version 2 of the License.

Tyrien 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 General Public License for more details.

You should have received a copy of the GNU General Public License
along with Foobar. If not, see <http://www.gnu.org/licenses/>.
*/
class mysqlSetting{
const DB_NAME='';
const DB_USER='';
const DB_PASS='';
const DB_HOST='';
const DB_PORT=':3306';
const P_CONN=false;
}
?>

<?
$db=new mysql;
$db->connetti();
$db->scriviQuery($record,$tabella);
?>

<?
/*
This file is part of Tyrien.

Tyrien is free software: you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation,version 2 of the License.

Tyrien 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 General Public License for more details.

You should have received a copy of the GNU General Public License
along with Foobar. If not, see <http://www.gnu.org/licenses/>.

*/

/*----------------------------------*
INTERFACCIA
*----------------------------------*/

interface Daemon {
public static function getInstance();
public static function start();
public static function stop();
public static function restart();
}

class mysql{

/*----------------------------------*
INFO
*----------------------------------*/

const NAME="mysql";
const VERSION="0.7";

/*----------------------------------*
OGGETTO E PATTERN SINGLETON
*----------------------------------*/

private static $instance=null;
private $db_link=null;

private function __construct(){

}

public static function getInstance(){
if(self::$instance==null){
$c=__CLASS__;
self::$instance=new $c;
}
return self::$instance;
}

/*----------------------------------*
FUNZIONI DI CONTROLLO OGGETTO
*----------------------------------*/

/*
* La funzione start() inizializza tutti gli elementi necessari all'utilizzo della libreria.
* Prima di tutto crea l'istanza dell'oggetto mysql poi abbia la connessione al database e ne
* seleziona uno.
* Dato che la funzione start() si puòà inserire all'interno del costruttore potrebbe essere
* conveniente renderla privata, in questo modo il modulo partirà ugualmente e l'utente avrà la
* possibilità di disinserirlo quando vuole o semplicemente riavvialo.
*/
public static function start(){
self::getInstance();
self::connect();
self::dbSelect();

}

public static function stop(){
mysql_close(self::$db_link);
self::$instance=null;
}

public static function restart(){
self::stop();
self::start();
}

/*----------------------------------*
FUNZIONI DI CONTROLLO MYSQL
*----------------------------------*/

private function connect(){
self::$db_link=mysql_connect(mysqlSetting::DB_HOST.mysqlSetting::DB_PORT,mysqlSetting::DB_USER,mysqlSetting::DB_PASS)
or die('Errore di connessione al database!');
}

private function dbSelect(){
if(self::$db_link==null)die('Non è stato trovato un link valido al database!');
self::$db_link=mysql_select_db(mysqlSetting::DB_NAME,self::$db_link) or die('Database richiesto non trovato!');
}

private function mysqlError(){
if(mysql_errno()!=0)return mysql_error();
}

private function query2array($result){
// Prende in entrata il risultato odella query e ritorna un array...
if ($result){
$i=0;
do{
$riga=mysql_fetch_array($result);
$recordset[$i]=$riga;
$i++;
}while($riga);
unset($recordset[$i-1]);
return $recordset;
}else{
return FALSE;
}
}

private function sendQuery($query){
$result=mysql_query($query,self::$db_link);
return $result;
}

public function read($tabella=false,$campi="*",$condizione=false,$ordine=false,$limite=false){
if(!$tabella)die('Non è stata specificata una tabella in cui leggere');
$query="select $campi from $tabella"; // Query base per il recupero dei dati.
if ($condizione != false)$query.=' WHERE '.$condizione; // Se condizione � utilizzato lo include nella query.
if ($ordine != false)$query.=' ORDER BY '.$ordine; // Ordino il risultato della richiesta se richiesto.
if ($limite != false) $query.=' LIMIT '.$limite; // Limito i risultati della richiesta se richiesto.
$result=self::query2array(self::sendQuery($query)); // In questo modo metto tutto in un array...
return $result;
}

public function write($table,$record){
/*
* Prende in entrata in array associativo contenente i dati da inserire.
*/
$query="insert into $table (";
$valori="";
foreach($record as $chiave=>$valore){
// Il campo id è determinato da mysql...
if($chiave=="id") continue;
$query.="$chiave,";
$valori.="'$valore',";
}
$query=substr($query,0,-1);
$valori=substr($valori,0,-1);
$query.=") values($valori) ";
$result=self::sendQuery($query);
if($result){
return mysql_insert_id();//Stampa l'ultimo id...
}else{
return $result;
}
}

public function update($tabella=null,$campi=null,$condizione){
if($tabella==null)die('Non è stata specificata una tabella su cui agire!');
if($campi==null)die('Bisogna specificare i campi interessati');
// Ancora da finire...
}

public function del(){

}

public function drop(){

}

public function join(){

}


}
?>

<?
/*
This file is part of Tyrien Framework.

Tyrien is free software: you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation,version 2 of the License.

Tyrien 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 General Public License for more details.

You should have received a copy of the GNU General Public License
along with Foobar. If not, see <http://www.gnu.org/licenses/>.
*/

Per quanto riguarda il file di configurazione è identico a quello precedente, lo trovate un post più in alto.

class mysqlController{
/*
Il controller in questo caso serve unicamente a caricare i file necessari al funzionamento del modulo.
E' ovvio ed abbastanza scontato che il programmatore potrebbe preferire la sostituzione di questo codice
con un metodo più uniforme con il sistema di destinazione.

La necessità di utilizzare questo controller si avverte solo al primo caricamento del modulo all'interno di uno script.

Allo stato attuale la singola funzione init() gestisce come unico parametro in entrata il path di un
eventuale file di configurazione alternativo('../config/mysql.php' in questo caso).

*/
public function init($path=null){
$configPath='FILE DI CONFIGURAZIONE';
if($path!=null)$configPath=$path;
require_once($configPath);
require_once('POSIZIONE LIBRERIA');
}

}
?>

<?
/*
This file is part of Tyrien.

Tyrien is free software: you can redistribute it and/or modify
it under the terms of the GNU General Public License as published by
the Free Software Foundation,version 2 of the License.

Tyrien 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 General Public License for more details.

You should have received a copy of the GNU General Public License
along with Foobar. If not, see <http://www.gnu.org/licenses/>.

*/

/*----------------------------------*
INTERFACCIA
*----------------------------------*/

interface Daemon {
public static function getInstance();
public function start();
public function stop();
public function restart();
}

class mysql{

/*----------------------------------*
INFO
*----------------------------------*/

const NAME="mysql";
const VERSION="0.7";

/*----------------------------------*
OGGETTO E PATTERN SINGLETON
*----------------------------------*/

private static $instance=null;
public $db_link=null;

private function __construct(){
$this->start();
}

public static function getInstance(){
if(self::$instance==null){
$c=__CLASS__;
self::$instance=new $c;
}
return self::$instance;
}

/*----------------------------------*
FUNZIONI DI CONTROLLO OGGETTO
*----------------------------------*/

/*
* La funzione start() inizializza tutti gli elementi necessari all'utilizzo della libreria.
* Prima di tutto crea l'istanza dell'oggetto mysql poi abbia la connessione al database e ne
* seleziona uno.
* Dato che la funzione start() si puòà inserire all'interno del costruttore potrebbe essere
* conveniente renderla privata, in questo modo il modulo partirà ugualmente e l'utente avrà la
* possibilità di disinserirlo quando vuole o semplicemente riavvialo.
*/
public function start(){
//self::getInstance();
$this->connect();
$this->dbSelect();

}

public function stop(){
mysql_close($this->db_link);
$this->instance=null;
}

public function restart(){
$this->stop();
$this->start();
}

/*----------------------------------*
FUNZIONI DI CONTROLLO MYSQL
*----------------------------------*/

public function connect(){
$this->db_link=mysql_connect(mysqlSetting::DB_HOST.mysqlSetting::DB_PORT,mysqlSetting::DB_USER,mysqlSetting::DB_PASS)
or die('Errore di connessione al database!');
}

private function dbSelect(){
if($this->db_link==null)die('Non è stato trovato un link valido al database!');
mysql_select_db(mysqlSetting::DB_NAME,$this->db_link) or die('Database richiesto non trovato!');
}

private function mysqlError(){
if(mysql_errno()!=0)return mysql_error();
}

private function query2array($result){
// Prende in entrata il risultato odella query e ritorna un array...
if ($result){
$i=0;
do{
$riga=mysql_fetch_array($result);
$recordset[$i]=$riga;
$i++;
}while($riga);
unset($recordset[$i-1]);
return $recordset;
}else{
return FALSE;
}
}

private function sendQuery($query){
$result=mysql_query($query,$this->db_link);
return $result;
}

public function read($tabella=false,$campi="*",$condizione=false,$ordine=false,$limite=false){
if(!$tabella)die('Non è stata specificata una tabella in cui leggere');
$query="select $campi from $tabella"; // Query base per il recupero dei dati.
if ($condizione != false)$query.=' WHERE '.$condizione; // Se condizione � utilizzato lo include nella query.
if ($ordine != false)$query.=' ORDER BY '.$ordine; // Ordino il risultato della richiesta se richiesto.
if ($limite != false) $query.=' LIMIT '.$limite; // Limito i risultati della richiesta se richiesto.
$result=$this->query2array($this->sendQuery($query)); // In questo modo metto tutto in un array...
return $result;
}

public function write($table,$record){
/*
* Prende in entrata in array associativo contenente i dati da inserire.
*/
$query="insert into $table (";
$valori="";
foreach($record as $chiave=>$valore){
// Il campo id è determinato da mysql...
if($chiave=="id") continue;
$query.="$chiave,";
$valori.="'$valore',";
}
$query=substr($query,0,-1);
$valori=substr($valori,0,-1);
$query.=") values($valori) ";
$result=$this->sendQuery($query);
if($result){
return mysql_insert_id();//Stampa l'ultimo id...
}else{
return $result;
}
}

public function update($tabella=null,$campi=null,$condizione){
if($tabella==null)die('Non è stata specificata una tabella su cui agire!');
if($campi==null)die('Bisogna specificare i campi interessati');
// Ancora da finire...
}

public function del(){

}

public function drop(){

}

public function join(){

}


}
?>