Classe Mysql (insert, delete, update, select)

Andre Summers · Novembro 13, 2008

Olá. Estou estudando Programação Orientada a Objetos e resolvi tentar montar minha primeira Classe. Como tema, escolhi os comandos MYSQL.

Estou tentando fazer uma classe que englobe todas as funções MYSQL... INSERT, DELETE, SELECT, UPDATE.

Até agora esta bem básico (e provavelmente cheio de erros ainda). Gostaria que me ajudassem a melhorar a classe, dando suas opiniões, apontando erros e/ou melhores maneiras do código funcionar, etc.

class Mysql {
	var $conect;
	var $database;
	var $query;
	
	// Inicia a Conexão com a Base de Dados
	function conectar($host,$db,$usuario,$senha)
	{
		$this->conect = mysql_connect($host, $usuario, $senha);
		if(!$this->conect)
		{
		   echo "Falha na conexão com o Banco de Dados.<br />";
		   echo "Erro: " . mysql_error();
		   die();
		}
		$this->database = mysql_select_db($db, $this->conect);
		if(!mysql_select_db($db, $this->conect))
		{
		   echo "O Bando de Dados solicitado não pode ser aberto.<br />";
		   echo "Erro: " . mysql_error();
		   die();
		}
	}
#################################################################
	// Usando INSERT
	function inserir($tabela,$campo,$valor)
	{
	$this->query = mysql_query("INSERT INTO ".$tabela." ('".$campo."') VALUES ('".$valor."')");
	if($this->query)
		{
			$log = "Cadastrado com sucesso!";
			return $log;
		}
	else
		{
			$log = "Não foi possivel cadastrar! Erro: ".mysql_error();
			return $log;
		}
	}
####################################################################
	// Usando DELETE
	function deletar($tabela,$where)
	{
	$this->query = mysql_query("DELET FROM ".$tabela." WHERE ".$where."");
	if($this->query)
		{
			$log = "Dados deletados com sucesso!";
			return $log;
		}
	else
		{
			$log = "Não foi possivel deletar os dados! Erro: ".mysql_error();
			return $log;
		}
	}
####################################################################
	// Usando UPDATE
	function atualizar($tabela,$valores)
	{
	$this->query = mysql_query("UPDATE ".$tabela." SET ('".$valores."')");
	if($this->query)
		{
			$log = "Dados atualizados com sucesso!";
			return $log;
		}
	else
		{
			$log = "Não foi possivel atualizar os dados! Erro: ".mysql_error();
			return $log;
		}
	}
#####################################################################
	// Usando SELECT
	function selecionar($campos,$tabela,$where,$orderby,$alinhamento,$limit)
	{
		//SELECT campos FROM tabela
		if(!empty($campos) && !empty($tabela) && empty($where) && empty($orderby) && empty($alinhamento) && empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela."");
		}
		//SELECT campos FROM tabela WHERE variavel = variavel
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && empty($orderby) && empty($alinhamento) && empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where."");
		}
		//SELECT campos FROM tabela WHERE variavel = variavel LIMIT 5
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && empty($orderby) && empty($alinhamento) && !empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where." LIMIT ".$limit."");
		}
		//SELECT campos FROM tabela WHERE variavel = variavel DESC
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && empty($orderby) && !empty($alinhamento) && empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where." ".$alinhamento."");
		}
		//SELECT campos FROM tabela WHERE variavel = variavel ORDER BY variavel
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && !empty($orderby) && empty($alinhamento) && empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where." ORDER BY ".$orderby."");
		}
		//SELECT campos FROM tabela WHERE variavel = variavel ORDER BY variavel DESC
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && !empty($orderby) && !empty($alinhamento) && empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where." ORDER BY ".$orderby." ".$alinhamento."");
		}
		//SELECT campos FROM tabela WHERE variavel = variavel ORDER BY variavel DESC LIMIT 5
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && !empty($orderby) && !empty($alinhamento) && !empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where." ORDER BY ".$orderby." ".$alinhamento." LIMIT ".$limit."");
		}
	}
###################################################################
	// Fecha Conexão com a Base de Dados
	function desconectar()
	{
		mysql_close($this->conect);
	}
###################################################################
} //Fecha Classe
?>

<?php
// MODO DE USO include("classe.php"); // Inclui o arquivo da classe
$sql = new conectar('localhost','database','user','password'); // Estancia o objeto e já faz a conexão
$sql->inserir('tabela','campo','valor'); // Executa INSERT de dados
$sql->deletar('tabela','where'); // Executa DELETE de dados
$sql->atualizar('tabela','valores') // Executa PUDATE de dados
$sql->selecionar('campos','tabela','where','orderby','alinhamento','limit'); // Executa SELECT de dados
$sql->desconectar(); // Fecha a conexão com Banco de Dados
?>

Agradeço desde já a atenção e a ajuda de vocês.

http://forum.imasters.com.br/public/style_emoticons/default/thumbsup.gif

Tellys Castro · Novembro 13, 2008

algumas coisas para começar:

Sua class ta retornando impressoes na tela com echo.

Class é ideal que seja bollean ... ou seja retorne FALSE ou TRUE. Os print deixe por conta de uma outra camada de seus sistema

ex.:

function inserir($tabela,$campo,$valor)
	{
	$this->query = mysql_query("INSERT INTO ".$tabela." ('".$campo."') VALUES ('".$valor."')");
	if($this->query)
		{
			return true;
		}
	else return mysql_error();
	}

Outra coisa faltou sua função de iniciação, sem ela complica chamar sua class, funciona, mas complica. Teria que ser assim:

Mysql::conectar();

entao coloque +- isso aq

function __construct(){
	return $this->conectar();
}

Corrige ai e deixa bolleana, dai agente vem com mais lapidações..

vlw

Beraldo · Novembro 14, 2008

Já vá aplicando as coisas básicas da OO do PHP 5:

http://br.php.net/manual/pt_BR/language.oop5.php

Construtores (como o supertelnet disse), destrutores e visibilidade.

Para uma classe de conexão, seria legal gerar um log de erros num arquivo. http://forum.imasters.com.br/public/style_emoticons/default/thumbsup.gif

Andre Summers · Novembro 14, 2008

Agradeço a ajuda e espero que possam continuar ajudando. Dei uma atualizada:

class Mysql {
	var $conect;
	var $database;
	var $query;
	
	public function __construct(){
	return $this->conectar();
	}
	
	public function gravando_erros($erro){
	$arquivo = fopen('erro.txt','a');
	fwrite($arquivo,"[".date("r")."] Erro: $erro\r\n");
	fclose($arquivo);
	} 
	
	// Inicia a Conexão com a Base de Dados
	function conectar($host,$db,$usuario,$senha)
	{
		$this->conect = mysql_connect($host, $usuario, $senha);
		if($this->conect)
		{
			return true;
		}
		else
		{
			return mysql_error();
		}
		$this->database = mysql_select_db($db, $this->conect);
		if(mysql_select_db($db, $this->conect))
		{
		   return true;
		}
		else
		{
			return mysql_error();
		}
	}
##########################################################################
	// Usando INSERT
	function inserir($tabela,$campo,$valor)
	{
	$this->query = mysql_query("INSERT INTO ".$tabela." ('".$campo."') VALUES ('".$valor."')");
	if($this->query)
		{
			return true;
		}
	else
		{
			return mysql_error();
		}
	}
#########################################################################
	// Usando DELETE
	function deletar($tabela,$where)
	{
	$this->query = mysql_query("DELET FROM ".$tabela." WHERE ".$where."");
	if($this->query)
		{
			return true;
		}
	else
		{
			return mysql_error();
		}
	}
#########################################################################
	// Usando UPDATE
	function atualizar($tabela,$valores)
	{
	$this->query = mysql_query("UPDATE ".$tabela." SET ('".$valores."')");
	if($this->query)
		{
			return true;
		}
	else
		{
			return mysql_error();
		}
	}
#########################################################################	
	// Usando SELECT
	function selecionar($campos,$tabela,$where,$orderby,$alinhamento,$limit)
	{
		//SELECT campos FROM tabela
		if(!empty($campos) && !empty($tabela) && empty($where) && empty($orderby) && empty($alinhamento) && empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela."");
		}
		//SELECT campos FROM tabela WHERE variavel = variavel
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && empty($orderby) && empty($alinhamento) && empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where."");
		}
		//SELECT campos FROM tabela WHERE variavel = variavel LIMIT 5
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && empty($orderby) && empty($alinhamento) && !empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where." LIMIT ".$limit."");
		}
		//SELECT campos FROM tabela WHERE variavel = variavel DESC
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && empty($orderby) && !empty($alinhamento) && empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where." ".$alinhamento."");
		}
		//SELECT campos FROM tabela WHERE variavel = variavel ORDER BY variavel
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && !empty($orderby) && empty($alinhamento) && empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where." ORDER BY ".$orderby."");
		}
		//SELECT campos FROM tabela WHERE variavel = variavel ORDER BY variavel DESC
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && !empty($orderby) && !empty($alinhamento) && empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where." ORDER BY ".$orderby." ".$alinhamento."");
		}
		//SELECT campos FROM tabela WHERE variavel = variavel ORDER BY variavel DESC LIMIT 5
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && !empty($orderby) && !empty($alinhamento) && !empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where." ORDER BY ".$orderby." ".$alinhamento." LIMIT ".$limit."");
		}
	}
############################################################################
	// Fecha Conexão com a Base de Dados
	function desconectar()
	{
		mysql_close($this->conect);
	}
############################################################################

	public function __destruct(){
	return $this->conectar();
	}
} //Fecha Classe
?>

<?php
// MODO DE USO
include("classe_mysql.php"); // Inclui o arquivo da classe
$sql = new conectar('localhost','database','user','password'); // Estancia o objeto e já faz a conexão
$sql->inserir('tabela','campo','valor'); // Executa INSERT de dados
$sql->deletar('tabela','where'); // Executa DELETE de dados
$sql->atualizar('tabela','valores') // Executa UPDATE de dados
$sql->selecionar('campos','tabela','where','orderby','alinhamento','limit'); // Executa SELECT de dados
$sql->desconectar(); // Fecha a conexão com Banco de Dados
?>

Andre Summers · Novembro 14, 2008

Mais uma atualização:

class Mysql {
	var $conect;
	var $database;
	var $query;
	
	public function __construct(){
		return $this->conectar();
	}
	
	public function gravando_erros($erro){
		$arquivo = fopen('erro.txt','a');
		fwrite($arquivo,"[".date("r")."] Erro: $erro\r\n");
		fclose($arquivo);
	} 
	
	public function erro($msgerro){ 
		$exibemsg = "Ocorreu um problema durante a manipulação dos dados! ";
		$exibemsg .= "O erro encontrado foi: ";
		$exibemsg .= "$msgerro"; //Erro MYSQL 
		
		gravando_erros($msgerro);
		
		return $exibemsg;
	}
	
	
	// Inicia a Conexão com a Base de Dados
	function conectar($host,$db,$usuario,$senha)
	{
		$this->conect = mysql_connect($host, $usuario, $senha);
		if($this->conect)
		{
			return true;
		}
		else
		{
			erro(mysql_error());
		}
		$this->database = mysql_select_db($db, $this->conect);
		if(mysql_select_db($db, $this->conect))
		{
		   return true;
		}
		else
		{
			erro(mysql_error());
		}
	}
##########################################################################
	// Usando INSERT
	function inserir($tabela,$campo,$valor)
	{
	$this->query = mysql_query("INSERT INTO ".$tabela." ('".$campo."') VALUES ('".$valor."')");
	if($this->query)
		{
			return true;
		}
	else
		{
			return mysql_error();
		}
	}
#########################################################################
	// Usando DELETE
	function deletar($tabela,$where)
	{
	$this->query = mysql_query("DELET FROM ".$tabela." WHERE ".$where."");
	if($this->query)
		{
			return true;
		}
	else
		{
			return mysql_error();
		}
	}
#########################################################################
	// Usando UPDATE
	function atualizar($tabela,$valores)
	{
	$this->query = mysql_query("UPDATE ".$tabela." SET ('".$valores."')");
	if($this->query)
		{
			return true;
		}
	else
		{
			return mysql_error();
		}
	}
#########################################################################	
	// Usando SELECT
	function selecionar($campos,$tabela,$where,$orderby,$alinhamento,$limit)
	{
		//SELECT campos FROM tabela
		if(!empty($campos) && !empty($tabela) && empty($where) && empty($orderby) && empty($alinhamento) && empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela."");
		}
		//SELECT campos FROM tabela WHERE variavel = variavel
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && empty($orderby) && empty($alinhamento) && empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where."");
		}
		//SELECT campos FROM tabela WHERE variavel = variavel LIMIT 5
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && empty($orderby) && empty($alinhamento) && !empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where." LIMIT ".$limit."");
		}
		//SELECT campos FROM tabela WHERE variavel = variavel DESC
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && empty($orderby) && !empty($alinhamento) && empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where." ".$alinhamento."");
		}
		//SELECT campos FROM tabela WHERE variavel = variavel ORDER BY variavel
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && !empty($orderby) && empty($alinhamento) && empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where." ORDER BY ".$orderby."");
		}
		//SELECT campos FROM tabela WHERE variavel = variavel ORDER BY variavel DESC
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && !empty($orderby) && !empty($alinhamento) && empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where." ORDER BY ".$orderby." ".$alinhamento."");
		}
		//SELECT campos FROM tabela WHERE variavel = variavel ORDER BY variavel DESC LIMIT 5
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && !empty($orderby) && !empty($alinhamento) && !empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where." ORDER BY ".$orderby." ".$alinhamento." LIMIT ".$limit."");
		}
	}
############################################################################
	// Fecha Conexão com a Base de Dados
	function desconectar()
	{
		mysql_close($this->conect);
	}
############################################################################

	public function __destruct(){
		return $this->conectar();
	}
} //Fecha Classe
?>

<?php
// MODO DE USO
include("classe_mysql.php"); // Inclui o arquivo da classe
$sql = new conectar('localhost','database','user','password'); // Estancia o objeto e já faz a conexão
$sql->inserir('tabela','campo','valor'); // Executa INSERT de dados
$sql->deletar('tabela','where'); // Executa DELETE de dados
$sql->atualizar('tabela','valores') // Executa UPDATE de dados
$sql->selecionar('campos','tabela','where','orderby','alinhamento','limit'); // Executa SELECT de dados
$sql->desconectar(); // Fecha a conexão com Banco de Dados
?>

Andre Summers · Novembro 14, 2008

Mais atualizada... tentando incrementar um log de Erros...

class Mysql {
	var $conect;
	var $database;
	var $query;
	
	public function __construct(){
		return $this->conectar();
	}
	
	public function gravando_erros($erro){
		$arquivo = fopen('erro.txt','a');
		fwrite($arquivo,"[".date("r")."] Erro: $erro\r\n");
		fclose($arquivo);
	} 
	
	public function erro($msgerro){ 
		$exibemsg = "Ocorreu um problema durante a manipulação dos dados! ";
		$exibemsg .= "O erro encontrado foi: ";
		$exibemsg .= "$msgerro"; //Erro MYSQL 
		
		gravando_erros($msgerro);
		
		return $exibemsg;
	}
	
	
	// Inicia a Conexão com a Base de Dados
	function conectar($host,$db,$usuario,$senha)
	{
		$this->conect = mysql_connect($host, $usuario, $senha);
		if($this->conect)
		{
			return true;
		}
		else
		{
			erro(mysql_error());
		}
		$this->database = mysql_select_db($db, $this->conect);
		if(mysql_select_db($db, $this->conect))
		{
		   return true;
		}
		else
		{
			erro(mysql_error());
		}
	}
##########################################################################
	// Usando INSERT
	function inserir($tabela,$campo,$valor)
	{
	$this->query = mysql_query("INSERT INTO ".$tabela." ('".$campo."') VALUES ('".$valor."')");
	if($this->query)
		{
			return true;
		}
	else
		{
			return mysql_error();
		}
	}
#########################################################################
	// Usando DELETE
	function deletar($tabela,$where)
	{
	$this->query = mysql_query("DELET FROM ".$tabela." WHERE ".$where."");
	if($this->query)
		{
			return true;
		}
	else
		{
			return mysql_error();
		}
	}
#########################################################################
	// Usando UPDATE
	function atualizar($tabela,$valores)
	{
	$this->query = mysql_query("UPDATE ".$tabela." SET ('".$valores."')");
	if($this->query)
		{
			return true;
		}
	else
		{
			return mysql_error();
		}
	}
#########################################################################	
	// Usando SELECT
	function selecionar($campos,$tabela,$where,$orderby,$alinhamento,$limit)
	{
		//SELECT campos FROM tabela
		if(!empty($campos) && !empty($tabela) && empty($where) && empty($orderby) && empty($alinhamento) && empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela."");
		}
		//SELECT campos FROM tabela WHERE variavel = variavel
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && empty($orderby) && empty($alinhamento) && empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where."");
		}
		//SELECT campos FROM tabela WHERE variavel = variavel LIMIT 5
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && empty($orderby) && empty($alinhamento) && !empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where." LIMIT ".$limit."");
		}
		//SELECT campos FROM tabela WHERE variavel = variavel DESC
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && empty($orderby) && !empty($alinhamento) && empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where." ".$alinhamento."");
		}
		//SELECT campos FROM tabela WHERE variavel = variavel ORDER BY variavel
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && !empty($orderby) && empty($alinhamento) && empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where." ORDER BY ".$orderby."");
		}
		//SELECT campos FROM tabela WHERE variavel = variavel ORDER BY variavel DESC
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && !empty($orderby) && !empty($alinhamento) && empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where." ORDER BY ".$orderby." ".$alinhamento."");
		}
		//SELECT campos FROM tabela WHERE variavel = variavel ORDER BY variavel DESC LIMIT 5
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && !empty($orderby) && !empty($alinhamento) && !empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where." ORDER BY ".$orderby." ".$alinhamento." LIMIT ".$limit."");
		}
	}
############################################################################
	// Fecha Conexão com a Base de Dados
	function desconectar()
	{
		mysql_close($this->conect);
	}
############################################################################

	public function __destruct(){
		return $this->conectar();
	}
} //Fecha Classe
?>

<?php
// MODO DE USO
include("classe_mysql.php"); // Inclui o arquivo da classe
$sql = new conectar('localhost','database','user','password'); // Estancia o objeto e já faz a conexão
$sql->inserir('tabela','campo','valor'); // Executa INSERT de dados
$sql->deletar('tabela','where'); // Executa DELETE de dados
$sql->atualizar('tabela','valores') // Executa UPDATE de dados
$sql->selecionar('campos','tabela','where','orderby','alinhamento','limit'); // Executa SELECT de dados
$sql->desconectar(); // Fecha a conexão com Banco de Dados
?>

Andre Summers · Novembro 14, 2008

Nova atualização... agora o INSERT aceita array.

class Mysql {
	var $conect;
	var $database;
	var $query;
	
	public function __construct(){
		return $this->conectar();
	}
	
	public function gravando_erros($erro){
		$arquivo = fopen('erro.txt','a');
		fwrite($arquivo,"[".date("r")."] Erro: $erro\r\n");
		fclose($arquivo);
	} 
	
	public function erro($msgerro){ 
		$exibemsg = "Ocorreu um problema durante a manipulação dos dados! ";
		$exibemsg .= "O erro encontrado foi: ";
		$exibemsg .= "$msgerro"; //Erro MYSQL 
		
		gravando_erros($msgerro);
		
		return $exibemsg;
	}
	
	
	// Inicia a Conexão com a Base de Dados
	function conectar($host,$db,$usuario,$senha)
	{
		$this->conect = mysql_connect($host, $usuario, $senha);
		if($this->conect)
		{
			return true;
		}
		else
		{
			erro(mysql_error());
		}
		$this->database = mysql_select_db($db, $this->conect);
		if(mysql_select_db($db, $this->conect))
		{
		   return true;
		}
		else
		{
			erro(mysql_error());
		}
	}
##########################################################################
	// Usando INSERT
	function inserir($tabela,$dados)
	{
	// Dividimos o Array dentro de $dados em Chaves e Valores
	$campos = array_keys($dados);
	$valores = array_values($dados);
	//Executamos a Query	
		$this->query = mysql_query("INSERT INTO ".$tabela." (".implode(', ', $campos).") VALUES ('" . implode('\', \'', $valores) . "')");
	//Verificamos se a Query foi executada corretamente
	if($this->query)
		{
			return true;
		}
	else
		{
			return mysql_error();
		}
	}
#########################################################################
	// Usando DELETE
	function deletar($tabela,$where)
	{
	$this->query = mysql_query("DELETE FROM ".$tabela." WHERE ".$where."");
	if($this->query)
		{
			return true;
		}
	else
		{
			return mysql_error();
		}
	}
#########################################################################
	// Usando UPDATE
	function atualizar($tabela,$valores)
	{
	$this->query = mysql_query("UPDATE ".$tabela." SET ('".$valores."')");
	if($this->query)
		{
			return true;
		}
	else
		{
			return mysql_error();
		}
	}
#########################################################################	
	// Usando SELECT
	function selecionar($campos,$tabela,$where,$orderby,$alinhamento,$limit)
	{
		//SELECT campos FROM tabela
		if(!empty($campos) && !empty($tabela) && empty($where) && empty($orderby) && empty($alinhamento) && empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela."");
		}
		//SELECT campos FROM tabela WHERE variavel = variavel
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && empty($orderby) && empty($alinhamento) && empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where."");
		}
		//SELECT campos FROM tabela WHERE variavel = variavel LIMIT 5
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && empty($orderby) && empty($alinhamento) && !empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where." LIMIT ".$limit."");
		}
		//SELECT campos FROM tabela WHERE variavel = variavel DESC
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && empty($orderby) && !empty($alinhamento) && empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where." ".$alinhamento."");
		}
		//SELECT campos FROM tabela WHERE variavel = variavel ORDER BY variavel
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && !empty($orderby) && empty($alinhamento) && empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where." ORDER BY ".$orderby."");
		}
		//SELECT campos FROM tabela WHERE variavel = variavel ORDER BY variavel DESC
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && !empty($orderby) && !empty($alinhamento) && empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where." ORDER BY ".$orderby." ".$alinhamento."");
		}
		//SELECT campos FROM tabela WHERE variavel = variavel ORDER BY variavel DESC LIMIT 5
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && !empty($orderby) && !empty($alinhamento) && !empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where." ORDER BY ".$orderby." ".$alinhamento." LIMIT ".$limit."");
		}
	}
############################################################################
	// Fecha Conexão com a Base de Dados
	function desconectar()
	{
		mysql_close($this->conect);
	}
############################################################################

	public function __destruct(){
		return $this->conectar();
	}
} //Fecha Classe

Andre Summers · Novembro 17, 2008

Atualizado com função anti SQL injection

class Mysql {
	var $conect;
	var $database;
	var $query;
	
	public function __construct(){
		return $this->conectar();
	}
	
	public function gravando_erros($erro){
		$arquivo = fopen('erro.txt','a');
		fwrite($arquivo,"[".date("r")."] Erro: $erro\r\n");
		fclose($arquivo);
	} 
	
	public function erro($msgerro){ 
		$exibemsg = "Ocorreu um problema durante a manipulação dos dados! ";
		$exibemsg .= "O erro encontrado foi: ";
		$exibemsg .= "$msgerro"; //Erro MYSQL 
		
		gravando_erros($msgerro);
		
		return $exibemsg;
	}
	
	
	// Inicia a Conexão com a Base de Dados
	function conectar($host,$db,$usuario,$senha)
	{
		$this->conect = mysql_connect($host, $usuario, $senha);
		if($this->conect)
		{
			return true;
		}
		else
		{
			erro(mysql_error());
		}
		$this->database = mysql_select_db($db, $this->conect);
		if(mysql_select_db($db, $this->conect))
		{
		   return true;
		}
		else
		{
			erro(mysql_error());
		}
	}
##########################################################################
	// Função Anti SQL Injection
	public function antiSQLinjection($recebe){
		$recebe = get_magic_quotes_gpc() == 0 ? addslashes($recebe) : $recebe; // Verifica a configuração de "magic_quotes_gpc"
		$recebe = strip_tags($recebe); // Limpa as tags HTML
		$recebe = preg_replace(sql_regcase("/(from|select|insert|delete|where|drop table|show tables|\\\\)/"),"",$recebe);
		$recebe = preg_replace("@(--|\#|\*|;|=)@s", "", $recebe);
		return $recebe;
	}
##########################################################################
	// Usando INSERT
	function inserir($tabela,$dados)
	{
	// Dividimos o Array dentro de $dados em Chaves e Valores
	$campos = array_keys($dados);
	$valores = array_values($dados);
	//Executamos a Query	
		$this->query = mysql_query("INSERT INTO ".$tabela." (".implode(', ', $campos).") VALUES ('" . implode('\', \'', $valores) . "')");
	//Verificamos se a Query foi executada corretamente
	if($this->query)
		{
			return true;
		}
	else
		{
			return mysql_error();
		}
	}
#########################################################################
	// Usando DELETE
	function deletar($tabela,$where)
	{
	$this->query = mysql_query("DELETE FROM ".$tabela." WHERE ".$where."");
	if($this->query)
		{
			return true;
		}
	else
		{
			return mysql_error();
		}
	}
#########################################################################
	// Usando UPDATE
	function atualizar($tabela,$valores)
	{
	$this->query = mysql_query("UPDATE ".$tabela." SET ('".$valores."')");
	if($this->query)
		{
			return true;
		}
	else
		{
			return mysql_error();
		}
	}
#########################################################################	
	// Usando SELECT
	function selecionar($campos,$tabela,$where,$orderby,$alinhamento,$limit)
	{
		//SELECT campos FROM tabela
		if(!empty($campos) && !empty($tabela) && empty($where) && empty($orderby) && empty($alinhamento) && empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela."");
			return true;
		}
		//SELECT campos FROM tabela WHERE variavel = variavel
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && empty($orderby) && empty($alinhamento) && empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where."");
			return true;
		}
		//SELECT campos FROM tabela WHERE variavel = variavel LIMIT 5
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && empty($orderby) && empty($alinhamento) && !empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where." LIMIT ".$limit."");
			return true;
		}
		//SELECT campos FROM tabela WHERE variavel = variavel DESC
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && empty($orderby) && !empty($alinhamento) && empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where." ".$alinhamento."");
			return true;
		}
		//SELECT campos FROM tabela WHERE variavel = variavel ORDER BY variavel
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && !empty($orderby) && empty($alinhamento) && empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where." ORDER BY ".$orderby."");
			return true;
		}
		//SELECT campos FROM tabela WHERE variavel = variavel ORDER BY variavel DESC
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && !empty($orderby) && !empty($alinhamento) && empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where." ORDER BY ".$orderby." ".$alinhamento."");
			return true;
		}
		//SELECT campos FROM tabela WHERE variavel = variavel ORDER BY variavel DESC LIMIT 5
		elseif(!empty($campos) && !empty($tabela) && !empty($where) && !empty($orderby) && !empty($alinhamento) && !empty($limit))
		{
			$this->query = mysql_query("SELECT ".$campos." FROM ".$tabela." WHERE ".$where." ORDER BY ".$orderby." ".$alinhamento." LIMIT ".$limit."");
			return true;
		}
	}
############################################################################
	// Fecha Conexão com a Base de Dados
	function desconectar()
	{
		mysql_close($this->conect);
	}
############################################################################

	public function __destruct(){
		return $this->conectar();
	}
} //Fecha Classe

Tellys Castro · Novembro 17, 2008

cria uma função query

function query ($query,) {
		return mysql_query ($query);
	}

e aplica ela onde você tiver colocando mysql_query();

// Usando UPDATE
	function atualizar($tabela,$valores)
	{
	if($this->query("UPDATE ".$tabela." SET ('".$valores."')"))
		{
			$log = "Dados atualizados com sucesso!";
			return $log;
		}
	else
		{
			$log = "Não foi possivel atualizar os dados! Erro: ".mysql_error();
			return $log;
		}
	}

visitante_php · Novembro 18, 2008

pq você retorna a funcao conectar na __destruct? nela use mysql_close...

Arquivado

Classe Mysql (insert, delete, update, select)

Recommended Posts

Andre Summers 0

Compartilhar este post

Link para o post

Compartilhar em outros sites

Tellys Castro 12

Compartilhar este post

Link para o post

Compartilhar em outros sites

Beraldo 864

Compartilhar este post

Link para o post

Compartilhar em outros sites

Andre Summers 0

Compartilhar este post

Link para o post

Compartilhar em outros sites

Andre Summers 0

Compartilhar este post

Link para o post

Compartilhar em outros sites

Andre Summers 0

Compartilhar este post

Link para o post

Compartilhar em outros sites

Andre Summers 0

Compartilhar este post

Link para o post

Compartilhar em outros sites

Andre Summers 0

Compartilhar este post

Link para o post

Compartilhar em outros sites

Tellys Castro 12

Compartilhar este post

Link para o post

Compartilhar em outros sites

visitante_php 0

Compartilhar este post

Link para o post

Compartilhar em outros sites

Consulta SQL dentro de outra consulta

problema em usar json para realizar engenharia de dados

Soma dos dias utilizados

Fóruns

Tempo Real

Informação importante