mysql lib

mysql lib postato il 10/12/2008 02:56:45 nel forum programmazione, gdrcd, open source, hosting

Ciao a tutti volevo postare questa semplice libreria per la gestione di mysql, mi è sempre stata molto utile e volevo semplicemente condividerla.

Questa è una versione versione momentanea (0.6), la prossima sfrutterà il design pattern singleton.

<?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;
}

}
?>

Il file di configurazione deve essere strutturato in questo modo:

Esempi di utilizzo:

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

$record deve essere un array associativo dove la chiave è il campo della tabella da modificare e valore è il valore da dare al campo, la chiave id viene ignorata poichè si presuppone che sia attiva l'opzione autoincrement all'interno del database.

La funzione di lettura ha una struttura molto simile e ritorna direttamente un array associativo contenente tutte le chiavi richieste con i rispettivi valori.

E' anche possibile far eseguire query scritte totalmente a mano tramite la funzione directQuery(), mentre la funzione dropQuery() non è stata testata.

Spero che questa piccola libreria possa essere utile, conto per la versione 1.0 di ottimizzare ed eventualmente ripulire questo codice aggiungendo anche il supporto alla caratteristica JOIN di mysql particolarmente utile per gestire i dati all'interno di più tabelle contemporaneamente.

War Thunder ↗
Aviazione, veicoli corazzati e flotte militari della seconda guerra mondiale. Parteciperai a tutte le principali battaglie!

quota

Pagine → 1

cicciokr

SCRIVI

10/12/2008 08:05:01

molto utile.. e poi è bello vedere in una guida i commenti ^^

E´ proprio quando un popolo è all´apice del successo, che ha inizio il suo declino..

quota

metalj

SCRIVI

10/12/2008 21:06:47

joshi ha scritto: secondo me è troppo "monolitica", senza contare che dato che prende i parametri da quella classe, non puoi parametrizzare connessioni a più database.
ah , poi bello il fatto che si perda immediatamente traccia della risorsa di connessione, almeno conservalo in una proprietà dell'oggetto.

inoltre ti tocca mantere un oggetto globale con la connessione, istanziato in libreria di inclusione. certo, questo è normale , ma dato che non è parametrizzato hai un po' di overhead.

hmm, non è pensata male, solo poco controllabile, poco scalabile.
tra l'altro, con un oggetto così, non c'è alcuna gestione degli errori, ne con un sistema vecchio ( array interno o last_error ) oppure Exception Handling.
questa è una pecca abbastanza grossa.

se fossi un professore e dovessi dare un voto, sarebbe un 5.

considerate una cosa: gli oggetti sono carini, ma sono lenti.
se non avete bisogno di logica ad oggetti, EVITATE di usarli, a maggior ragione se non li sapete usare.

le librerie "wrapper" possono sembrare una cosa sofisticata e utile, peccato che dopo vi costino in forma di lavoro raddoppiato.
perchè?
perchè dovete studiare sia come funziona lo libreria di sistema ( mysql in questo caso ), sia come funziona il wrapper, e per scrivere una query, o lavorare su una risorsa, vi tocca risputtanare il codice della libreria.. che andrà automaticamente a spaccare un'altra parte del vostro applicativo.

Accetto pienamente il 5 che mi hai dato questo perchè tale codice è incompleto (rispetto a quello che volevo fare io) e poco rifinito.
Ti do perfettamente ragione per quanto riguarda la variabile globale che decaderà con l'implementazione del pattern singleton che mi permetterà maggior elasticità di utilizzo senza contare la possibilità di monitorare al meglio ciò che faccio col db all'interno di una sessione.
Per quanto riguarda invece i parametri di accesso al database sono disposti in quel modo semplicemente perchè, all'interno del progetto dal quale è stato estrapolato il codice, i file di configurazione vengono caricati dinamicamente a seconda del modulo usato in base a delle istruzioni presenti in un file chiamato header.php, modificando gli elementi di questo file è possibile far girare contemporaneamente più progetti con lo stesso codice.
La scalabilità del codice invece è un aspetto che vorrei curare di più ma sfortunatamente non riesco a dedicarci il giusto tempo.

se non avete bisogno di logica ad oggetti, EVITATE di usarli, a maggior ragione se non li sapete usare.

Mi stai dicendo che non so usare gli oggetti? 😖

Entropia Universe ↗
Lascia che il tuo avatar esplori nuovi mondi e viaggi tra i pianeti in questo stupendo MmoRpg Sci-Fi Free to Play!

quota

metalj

SCRIVI

10/12/2008 23:45:24

Grazie per i consigli, sono sempre ben accetti...

Lineage II ↗
Entra in uno sconfinato mondo fantasy dominato da razze in contrasto tra loro. Scatena i tuoi poteri in uno dei Mmo più famosi al mondo!

quota

metalj

SCRIVI

15/12/2008 18:50:04

Ecco una bozza con alcune delle modifiche apportate...
Per il momento non vi è ancora nessuna gestione degli errori senza contare che vorrei inserire il supporto per l'utilizzo della sintassi join implicita ed i trigger.

<?
/*
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(){

}

}
?>

Il codice non è per nulla pronto per essere utilizzato l'ho postato semplicemente per far vedere a che punto sono arrivato (potendoci lavorare saltuariamente) per darvi la possibilità di intercedere dandomi consigli.

L'interfaccia serve solo nell'ambito del progetto tyrien quindi non è strettamente necessaria altrove.

World of Tanks ↗
Lanciati in epiche battaglie spalla a spalla con altri giocatori. Conquista la supremazia nel mondo dei Carri Armati!

quota

metalj

SCRIVI

19/12/2008 03:20:13 e modificato da metalj il 19/12/2008 03:21:43

Ecco una versione funzionante della libreria, ovviamente da testare.

Prima di tutto il controller, come scritto nel codice stesso non è prettamente necessario per lo script!

<?
/*
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');
}

}
?>

Ecco invece la libreria mysql riscritta:

<?
/*
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(){

}

}
?>

I file di configurazione è riportato qualche post più in su...

Dark Genesis ↗
Ascendi al cielo in Dark Genesis! Raduna potenti semidei, costruisci il tuo impero volante e scontrati in battaglie divine!

quota

metalj

SCRIVI

19/12/2008 19:57:03

Questo comunque è il link al repository svn http://tyrien.svn.sourceforge.net/viewvc/tyrien/TyrienCORE/trunk/modules/mysql/ ↗

Chiunque volesse apportare modifiche a questa libreria può farlo liberamente in locale, se invece siete interessati a seguire più da vicino il progetto createvi un account presso sourceforge.net e vi permetterò di accedere direttamente al repository, per eventuali domande usate i mp.

World of Tanks ↗
Lanciati in epiche battaglie spalla a spalla con altri giocatori. Conquista la supremazia nel mondo dei Carri Armati!

quota

Discussione seguita da › metalj › gemini

Pagine → 1

Rispondi alla Discussione Aggiungi ai Preferiti Inoltra Discussione Forum Programmazione, GDRCD, Open Source, Hosting Elenco Forum