Fazendo uma query no Magento

Como montar uma query no Magento e executa-la utilizando os recursos nativos da própria plataforma.

Nada de “models”, apenas o SQL.

Executando uma consulta “SELECT”

Vamos direto ao ponto.

$resource = Mage::getSingleton('core/resource');

$readConnection = $resource->getConnection('core_read');

No código acima, primeiro pegamos a instancia da classe “core/resource” e com método “getConnection”  iremos ter acesso a conexão de leitura passando como parâmetro o valor ‘core_read’.

$query = ' SELECT col1 FROM tabela_test LIMIT 1 ';
 
$one_result = $readConnection->fetchCol( $query );

Acima montamos um query de teste e a executamos com método “fetchCol”, utilizamos essa função pois queremos apenas a primeira coluna das linhas resultantes.

Podemos utilizar também “fetchAll”, para trazer várias linhas e todas as colunas da query.

$results = $readConnection->fetchAll( $query );

Você poderá percorrer cada linha retornada com “foreach” na variável “results”.

Caso você queira retornar apenas 1 linha e 1 coluna, utilize o método a seguir:

$result = $readConnection->fetchOne($query);

A função “fetchOne” irá retornar imediatamente o valor da coluna na variável “result”.

Executando um “INSERT”

$resource = Mage::getSingleton('core/resource');

$writeConnection = $resource->getConnection('core_write');

Utilizamos a mesma instancia anterior “core/resource”, mudando apenas o parâmetro no “getConnection” para “core_write”, pois iremos fazer uma inserção “escrita” no banco.

$query = " INSERT INTO test (ab,cd) VALUES ('ab','cd'); ";

$writeConnection->query($query)

Com método “query” em nosso objeto executamos nossa query.

Executando um “UPDATE” ou “DELETE”

Dá mesma forma que o “insert”, iremos utilizar “core_write” invés do “core_read”.

$resource = Mage::getSingleton('core/resource');

$writeConnection = $resource->getConnection('core_write');

Exemplo UPDATE:

   
$query = " UPDATE test SET name = 'test' WHERE id = 1 "; 
  
$writeConnection->query($query);

Exemplo de DELETE:

$query = " DELETE FROM test WHERE id = 1 "; 

$writeConnection->query($query);

Observações

Muito cuidado ao executar essas query, aconselho a você sempre estar utilizando os “models”, pois eles irão padronizar o seu código e ajudarão a proteger suas consultas.

Contudo em algumas situações e necessário executar uma consulta complexa ou algo do tipo, neste caso nunca se esqueça de validar os parâmetros utilizados na sua query, evitando “SQL Injection”.