nova instância

conexao.class.php

<?php /* * Constantes de parâmetros para configuração da conexão */ define('HOST', 'localhost'). define('DBNAME', 'banco_de_dados'). define('CHARSET', 'utf8'). define('USER', 'root'). define('PASSWORD', ''). class Conexao { /* * Atributo estático para instância do PDO */ private static $pdo. /* * Escondendo o construtor da classe */ private function __construct() { // } /* * Método estático para retornar uma conexão válida * Verifica se já existe uma instância da conexão, caso não, configura uma nova conexão */ public static function getInstance() { if (!isset(self::$pdo)) { try { $opcoes = array(PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES UTF8', PDO::ATTR_PERSISTENT => TRUE). self::$pdo = new PDO("mysql:host=". HOST. ". dbname=". DBNAME. ". charset=". CHARSET. ". ", USER, PASSWORD, $opcoes). self::$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION). } catch (PDOException $e) { print "Erro: ". $e->getMessage(). } } return self::$pdo. } }?>

crud.class.php

<?php header('Content-Type: text/html. charset=utf-8'). class Crud{ // Atributo para guardar uma conexão PDO private $pdo = null. // Atributo onde será guardado o nome da tabela private $tabela = null. // Atributo estático que contém uma instância da própria classe private static $crud = null. /* * Método privado construtor da classe * @param $conexao = Conexão PDO configurada * @param $tabela = Nome da tabela */ private function __construct($conexao, $tabela=NULL){ if (!empty($conexao)): $this->pdo = $conexao. else: echo "<h3>Conexão inexistente!</h3>". exit(). endif. if (!empty($tabela)) $this->tabela =$tabela. } /* * Método público estático que retorna uma instância da classe Crud * @param $conexao = Conexão PDO configurada * @param $tabela = Nome da tabela * @return Atributo contendo instância da classe Crud */ public static function getInstance($conexao, $tabela=NULL){ // Verifica se existe uma instância da classe if(!isset(self::$crud)): try { self::$crud = new Crud($conexao, $tabela). } catch (Exception $e) { echo "Erro ". $e->getMessage(). } endif. return self::$crud. } /* * Método para setar o nome da tabela na propriedade $tabela * @param $tabela = String contendo o nome da tabela */ public function setTableName($tabela){ if(!empty($tabela)){ $this->tabela = $tabela. } } /* * Método privado para construção da instrução SQL de INSERT * @param $arrayDados = Array de dados contendo colunas e valores * @return String contendo instrução SQL */ private function buildInsert($arrayDados){ // Inicializa variáveis $sql = "". $campos = "". $valores = "". // Loop para montar a instrução com os campos e valores foreach($arrayDados as $chave => $valor): $campos.= $chave. ', '. $valores.= '?, '. endforeach. // Retira vírgula do final da string $campos = (substr($campos, -2) == ', ')? trim(substr($campos, 0, (strlen($campos) - 2))): $campos. // Retira vírgula do final da string $valores = (substr($valores, -2) == ', ')? trim(substr($valores, 0, (strlen($valores) - 2))): $valores. // Concatena todas as variáveis e finaliza a instrução $sql.= "INSERT INTO {$this->tabela} (". $campos. ")VALUES(". $valores. ")". // Retorna string com instrução SQL return trim($sql). } /* * Método privado para construção da instrução SQL de UPDATE * @param $arrayDados = Array de dados contendo colunas, operadores e valores * @param $arrayCondicao = Array de dados contendo colunas e valores para condição WHERE * @return String contendo instrução SQL */ private function buildUpdate($arrayDados, $arrayCondicao){ // Inicializa variáveis $sql = "". $valCampos = "". $valCondicao = "". // Loop para montar a instrução com os campos e valores foreach($arrayDados as $chave => $valor): $valCampos.= $chave. '=?, '. endforeach. // Loop para montar a condição WHERE foreach($arrayCondicao as $chave => $valor): $valCondicao.= $chave. '? AND '. endforeach. // Retira vírgula do final da string $valCampos = (substr($valCampos, -2) == ', ')? trim(substr($valCampos, 0, (strlen($valCampos) - 2))): $valCampos. // Retira vírgula do final da string $valCondicao = (substr($valCondicao, -4) == 'AND ')? trim(substr($valCondicao, 0, (strlen($valCondicao) - 4))): $valCondicao. // Concatena todas as variáveis e finaliza a instrução $sql.= "UPDATE {$this->tabela} SET ". $valCampos. " WHERE ". $valCondicao. // Retorna string com instrução SQL return trim($sql). } /* * Método privado para construção da instrução SQL de DELETE * @param $arrayCondicao = Array de dados contendo colunas, operadores e valores para condição WHERE * @return String contendo instrução SQL */ private function buildDelete($arrayCondicao){ // Inicializa variáveis $sql = "". $valCampos= "". // Loop para montar a instrução com os campos e valores foreach($arrayCondicao as $chave => $valor): $valCampos.= $chave. '? AND '. endforeach. // Retira a palavra AND do final da string $valCampos = (substr($valCampos, -4) == 'AND ')? trim(substr($valCampos, 0, (strlen($valCampos) - 4))): $valCampos. // Concatena todas as variáveis e finaliza a instrução $sql.= "DELETE FROM {$this->tabela} WHERE ". $valCampos. // Retorna string com instrução SQL return trim($sql). } /* * Método público para inserir os dados na tabela * @param $arrayDados = Array de dados contendo colunas e valores * @return Retorna resultado booleano da instrução SQL */ public function insert($arrayDados){ try { // Atribui a instrução SQL construida no método $sql = $this->buildInsert($arrayDados). // Passa a instrução para o PDO $stm = $this->pdo->prepare($sql). // Loop para passar os dados como parâmetro $cont = 1. foreach ($arrayDados as $valor): $stm->bindValue($cont, $valor). $cont++. endforeach. // Executa a instrução SQL e captura o retorno $retorno = $stm->execute(). return $retorno. } catch (PDOException $e) { echo "Erro: ". $e->getMessage(). } } /* * Método público para atualizar os dados na tabela * @param $arrayDados = Array de dados contendo colunas e valores * @param $arrayCondicao = Array de dados contendo colunas e valores para condição WHERE - Exemplo array('$id='=>1) * @return Retorna resultado booleano da instrução SQL */ public function update($arrayDados, $arrayCondicao){ try { // Atribui a instrução SQL construida no método $sql = $this->buildUpdate($arrayDados, $arrayCondicao). // Passa a instrução para o PDO $stm = $this->pdo->prepare($sql). // Loop para passar os dados como parâmetro $cont = 1. foreach ($arrayDados as $valor): $stm->bindValue($cont, $valor). $cont++. endforeach. // Loop para passar os dados como parâmetro cláusula WHERE foreach ($arrayCondicao as $valor): $stm->bindValue($cont, $valor). $cont++. endforeach. // Executa a instrução SQL e captura o retorno $retorno = $stm->execute(). return $retorno. } catch (PDOException $e) { echo "Erro: ". $e->getMessage(). } } /* * Método público para excluir os dados na tabela * @param $arrayCondicao = Array de dados contendo colunas e valores para condição WHERE - Exemplo array('$id='=>1) * @return Retorna resultado booleano da instrução SQL */ public function delete($arrayCondicao){ try { // Atribui a instrução SQL construida no método $sql = $this->buildDelete($arrayCondicao). // Passa a instrução para o PDO $stm = $this->pdo->prepare($sql). // Loop para passar os dados como parâmetro cláusula WHERE $cont = 1. foreach ($arrayCondicao as $valor): $stm->bindValue($cont, $valor). $cont++. endforeach. // Executa a instrução SQL e captura o retorno $retorno = $stm->execute(). return $retorno. } catch (PDOException $e) { echo "Erro: ". $e->getMessage(). } } /* * Método genérico para executar instruções de consulta independente do nome da tabela passada no _construct * @param $sql = Instrução SQL inteira contendo, nome das tabelas envolvidas, JOINS, WHERE, ORDER BY, GROUP BY e LIMIT * @param $arrayParam = Array contendo somente os parâmetros necessários para clásusla WHERE * @param $fetchAll = Valor booleano com valor default TRUE indicando que serão retornadas várias linhas, FALSE retorna apenas a primeira linha * @return Retorna array de dados da consulta em forma de objetos */ public function getSQLGeneric($sql, $arrayParams=null, $fetchAll=TRUE){ try { // Passa a instrução para o PDO $stm = $this->pdo->prepare($sql). // Verifica se existem condições para carregar os parâmetros if (!empty($arrayParams)): // Loop para passar os dados como parâmetro cláusula WHERE $cont = 1. foreach ($arrayParams as $valor): $stm->bindValue($cont, $valor). $cont++. endforeach. endif. // Executa a instrução SQL $stm->execute(). // Verifica se é necessário retornar várias linhas if($fetchAll): $dados = $stm->fetchAll(PDO::FETCH_OBJ). else: $dados = $stm->fetch(PDO::FETCH_OBJ). endif. return $dados. } catch (PDOException $e) { echo "Erro: ". $e->getMessage(). } } }?>

Estou tendo um problema para inserir os dados na tabela contatos, o insert está entendendo que eu quero conectar na tabela usuarios e na verdade eu quero usar a tabela contatos A mensagem de erro que eu recebo é de que a coluna assunto não existe, justamente pq a coluna assunto é da tabela contatos e ele entende que eu quero inserir na tabela usuarios <?php
// Atribui uma conexão PDO

$pdo = Conexao::getInstance(). $tabela = 'usuarios'. $crud = Crud::getInstance($pdo, $tabela). 

/ CONSULTA /

$sql = "SELECT * FROM ".$tabela." WHERE id =?". $arrayParam = array($id). $dados = $crud->getSQLGeneric($sql, $arrayParam, FALSE). 

/ INSERT /

$tabela = 'contatos'. $crud = Crud::getInstance($pdo, $tabela). $contato = array("nome"=>dados->nome,"telefone"=>dados->telefone,"assunto"=>"teste","email"=>dados->email). $crud->insert($contato).?>