Utilizo el siguiente código para ejecutar un archivo SQL en mi aplicación de symfony 2.7, y funciona, pero quiero saber cómo validar si la consulta se ejecutó correctamente o no.
Éste es mi código:
public function importarAction(Request $request)
{
/**
* Creo un formulario para Seleccionar el archivo SQL
*/
$defaultData = array('message' => 'Type your message here');
$form = $this->createFormBuilder($defaultData)
->add('archivo', 'file', array('label' => 'Seleccione el Archivo SQL: '))
->getForm();
$form->handleRequest($request);
if ($form->isSubmitted() && $form->isValid()) {
/**
* Obtengo la ruta del Archivo y lo Muevo hasta
* mi propio directorio dentro de la Aplicacion symfony
*/
$file= $form->get('archivo')->getData();
$nombre='SQLimportado'.date("dmYHis", time()).'.sql';
$cvDir = $this->container->getparameter('kernel.root_dir').'\Resources\importados\\';
$file->move($cvDir,$nombre);
/**
* Busco el archivo utilizando los datos anteriores
* como la ruta y el nombre del archivo
*/
$finder = new Finder();
$finder->files()->in($cvDir);
$finder->name($nombre);
foreach ($finder as $file) {
/**
* Ejecuo el SQL
*/
$contenido = $file->getContents();
$em = $this->getDoctrine()->getEntityManager();
$db = $em->getConnection()->executeQuery($contenido);
var_dump($db->errorInfo());
}
}
return array(
'form' => $form->createView(),
);
}