2

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(),
    );

}
2
  • En lo sucesivo, te recomendaría seguir usando Doctrine para operaciones de base de datos, y revisar la herramienta "Profiler", que es capaz de presentar información detallada sobre doctrine (entre otras), como el número de consultas ejecutadas, el tiempo de ejecución, resultados, explicación y obtención de queries ejecutables.
    – Muriano
    Commented el 4 jul. 2016 a las 16:08
  • @Muriano Gracias por la recomendación, la tendré en cuenta! Commented el 4 jul. 2016 a las 16:36

1 respuesta 1

0

Al final he conseguido un resultado:

lo que hice fue ejecutar el archivo SQL mediante mysqli, no con el Manager de Dcotrine.

/**
 * @Route("/importar", name="importar")
 * @Template("SeguridadBundle:Default:index.html.twig")
 */
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) {
            /**
             * Seobtiene el contenido del SQL
             * y se Crea la conexion a MySQL
             */
            $contenido = $file->getContents();
            $em = $this->getDoctrine()->getEntityManager();
            $parametros = $em->getConnection()->getParams();

            /**
             * Creo un nuevo parametro de Mysqli
             */
            $mysqli = new \mysqli(
                $parametros['host'],
                $parametros['user'],
                $parametros['password'],
                $parametros['dbname']);

            /**
             * Ejecutor el archivo SQL
             * mediante la opcion de, multiple query
             * y valido si existen errores durante su ejecucion
             */
            if ($mysqli->multi_query($contenido)) {
                do {

                    if (!$mysqli->more_results()) {
                        break;
                    }
                    if (!$mysqli->next_result()) {
                        /**
                         * si hay error de algun tipo Se Mostrara el mensaje de ERROR
                         */
                        return $this->render('SeguridadBundle:Default:respuesta.html.twig', array(
                            'resultado' => 'Seha producido un error durante la ejecución del SQL!',
                        ));
                        break;
                    }
                } while (true);
                /**
                 * si todo esta bien Se muestra el MSG de CORRECTO
                 */
                return $this->render('SeguridadBundle:Default:respuesta.html.twig', array(
                    'resultado' => 'La importación de ha ejecutado correctamente!',
                ));
            }
            else {
                /**
                 * si hay error de algun tipo Se Mostrara el mensaje de ERROR
                 */
                return $this->render('SeguridadBundle:Default:respuesta.html.twig', array(
                    'resultado' => 'Seha producido un error durante la ejecución del SQL!',
                    'error'=>$mysqli->errno
                ));

            }
        }
    }

    return array(
        'form'   => $form->createView(),
    );

}
1
  • Marca tu respuesta como aceptada para que los usuarios (que puedan tener tu misma duda) encuentren la respuesta fácilmente. Commented el 12 ago. 2016 a las 19:50

Tu Respuesta

By clicking “Publica tu respuesta”, you agree to our terms of service and acknowledge you have read our privacy policy.

¿No es la respuesta que buscas? Examina otras preguntas con la etiqueta o formula tu propia pregunta.