ejecutar una funcion dentro de otra

[stevens82]

Hola a todos, no se si el titulo va a corde con lo que necesito pero espero explicarme bien, estoy ingresando a dos tablas relacionadas ciertos registros, pero en la segunda tabla se pueden ingresar 1, 2, 3 o mas registros a la ves, aca un ejemplo de lo que tengo me funciona pero en dos funciones diferentes sin ningun problema:

en mi controlador tengo esto

Código PHP:

public funcion nuevo()
{
//codigo ...
 
$fecha_enc = date('Y-m-d', strtotime($_POST['fecha_enc']));
 
            $this->_encuestas->registrarEncuesta(
            $this->getPostParam('titulo'),
            $this->getPostParam('cargo'),
            $this->getPostParam('departamento'),
            $this->getPostParam('provincia'),
            $this->getPostParam('distrito'),
            $fecha_enc);
 
            $num = count($this->_encuestas->getCandidatosCount());
            // var_dump($num);
             for ($i=0; $i<$num; $i++) {
                $this->_encuestas->insertOpcionesEncuesta(
                    $_POST['candidato'][$i]
                );
            }
}
 

y en el modelo:

Código PHP:

public function registrarEncuesta($titulo, $cargo, $departamento, $provincia, $distrito, $fecha_enc)
    {
        $this->_db->prepare("INSERT INTO encuestas (id, titulo, id_cargo, id_pais, id_departamento, id_provincia, id_distrito, fecha_encuesta, fecha_registro, usuario_registrador) VALUES (null, :titulo, :cargo, 1, :departamento, :provincia, :distrito, :fecha_enc, now(), '" . Session::get('id_usuario') . "')"
        )->execute(array(
            ':titulo'           => $titulo,
            ':cargo'            => $cargo,
            ':departamento'     => $departamento,
            ':provincia'        => $provincia,
            ':distrito'         => $distrito,
            ':fecha_enc'        => $fecha_enc)
        );
 
    public function insertOpcionesEncuesta($id_candidato){
        $sql = "SELECT MAX(id) AS id FROM encuestas LIMIT 1";
        $query = $this->_db->prepare($sql);
        $query->execute();
        $row = $query->fetch();
        $sql = "INSERT INTO opciones (id, id_encuesta, id_candidato) VALUES (null, :id_encuesta, :id_candidato)";
        $statement = $this->_db->prepare($sql);
        $statement->execute(array(
            ':id_encuesta'   => $row['id'],
            ':id_candidato'  => $id_candidato
        ));
    }
 

con esto me funciona perfecto pero que pasa si no registra la primera funcion la segfunda me ingresaria con el id del ultimo registro de la primera tabla ya registrada antes, por lo que necesito saber como ejecutar la segunda consulta si y solo si la primera se ejecuto correctamente, esto meterlo talvez en una TRANSACCION, espero alguien me peuda dar una ayuda al respecto.

[xfxstudios]

para ello puedes trabajar con try catch

Código PHP:

public function loquesea(){
    try{
        //AQUI PRIMERA EJECUCIÓN DE TUSA CONSULTAS
        $a = $this->_db->prepare("INSERT INTO encuestas (id, titulo, id_cargo, id_pais, id_departamento, id_provincia, id_distrito, fecha_encuesta, fecha_registro, usuario_registrador) VALUES (null, :titulo, :cargo, 1, :departamento, :provincia, :distrito, :fecha_enc, now(), '" . Session::get('id_usuario') . "')"
            )->execute(array(
                ':titulo'           => $titulo,
                ':cargo'            => $cargo,
                ':departamento'     => $departamento,
                ':provincia'        => $provincia,
                ':distrito'         => $distrito,
                ':fecha_enc'        => $fecha_enc)
            );
        
        if(!$a){
            throw new Exception("AQUI EL ERROR GENERADO");
            //Si se genera la excepcion, se corta automaticamente la ejecución de la secuencia, por ende no llegara a la siguiente funcion o peticion
        }
        return $this->segunda($id);//Aqui solicito la ejecución de la segunda funcion
 
    }catch(Exception $e){
        $this->db->rollback();
        return $e->getMessage();
    }
}
 

Ahora debes tomar en cuenta que esto:

$sql = "SELECT MAX(id) AS id FROM encuestas LIMIT 1";

podría traerte ciertos problemas al concurrir varios usuarios en la ejecución del código, sería bueno trabajar con un código personalizado a parte de la id de control primaria, de esa manera tendrías mayor control sobre las operaciones.

[stevens82]

hola, gracias por responder, tengo serias dudas con respecto a tu ayuda.

La funcion loquesea() es un nombre cualquiera que le puedo poner a dicha funcion?
Como paso los parametros a la primera consulta?
$a = registrarEncuesta($titulo, $cargo, $departamento, $provincia, $distrito, $fecha_enc)
la segunda consulta me la ejecuta en su respectiva funcion y la que esta dentro con un error: Notice: Undefined variable: id in

[mortiprogramador]

Saludo

Pues puedes hacer una combinación,
es decir, en tu función inicial que hace el insert,
envías también el parámetro de las opciones,
ejecutas el insert, y obtienes el id de la inserción
(podrías usar $this->_db->insert_id() o similar, dependiendo las funciones de db)

Y una vez obtengas ese dato, haces el recorrido
que haces en el controlador, pero ahora en el modelo.

Y la excepción que te muestra con id es porque la variable
esta ahí, pero no se le asigna valor en ningún momento,
en cuyo caso en el ejemplo, podrías hacer un else del if,
y en este obtener el valor del id insertado.

[stevens82]

Hola aun no logro resolver esta duda, tengo esto en mi codigo:

Código PHP:

  public function registrarEncuesta($titulo, $cargo, $departamento, $provincia, $distrito, $fecha_enc, $id_candidato)
    {
        try {
            $this->_db->beginTransaction(); // iniciar transacción
            // tabla 1
            $this->_db->prepare("INSERT INTO encuestas (id, titulo, id_cargo, id_pais, id_departamento, id_provincia, id_distrito, fecha_encuesta, fecha_registro, usuario_registrador) VALUES (null, :titulo, :cargo, 1, :departamento, :provincia, :distrito, :fecha_enc, now(), '" . Session::get('id_usuario') . "')"
                )->execute(array(
                    ':titulo'           => $titulo,
                    ':cargo'            => $cargo,
                    ':departamento'     => $departamento,
                    ':provincia'        => $provincia,
                    ':distrito'         => $distrito,
                    ':fecha_enc'        => $fecha_enc)
                );
            $lastReciboId = $this->_db->lastInsertId();
            // tabla 2

          /*  ¿AQUI QUE COLOCO? */

            $this->_db->commit();
            echo 'Datos insertados';
        } catch (PDOException $e) {
            // si ocurre un error hacemos rollback para anular todos los insert
            $this->_db->rollBack();
            echo $e->getMessage();
        }
    } 
   

[stevens82]

Hola bueno con esto me funciona no se si podria optimizarlo o mejorar el codigo

controlador:

Código PHP:

  $fecha_enc = date('Y-m-d', strtotime($_POST['fecha_enc']));
             for ($i=0; $i<count($_POST['candidato']); $i++) {
                $candidato[] = $_POST['candidato'][$i];
            }
 
            $this->_encuestas->registrarEncuesta(
            $this->getPostParam('titulo'),
            $this->getPostParam('cargo'),
            $this->getPostParam('departamento'),
            $this->getPostParam('provincia'),
            $this->getPostParam('distrito'),
            $fecha_enc,
            $candidato); 
   

Modelo:

Código PHP:

  public function registrarEncuesta($titulo, $cargo, $departamento, $provincia, $distrito, $fecha_enc, $id_candidato)
    {
        try {
            $this->_db->beginTransaction(); // iniciar transacción
            // tabla 1
            $this->_db->prepare("INSERT INTO encuestas (id, titulo, id_cargo, id_pais, id_departamento, id_provincia, id_distrito, fecha_encuesta, fecha_registro, usuario_registrador) VALUES (null, :titulo, :cargo, 1, :departamento, :provincia, :distrito, :fecha_enc, now(), '" . Session::get('id_usuario') . "')"
                )->execute(array(
                    ':titulo'           => $titulo,
                    ':cargo'            => $cargo,
                    ':departamento'     => $departamento,
                    ':provincia'        => $provincia,
                    ':distrito'         => $distrito,
                    ':fecha_enc'        => $fecha_enc)
                );
            $lastReciboId = $this->_db->lastInsertId();
            for ($i=0; $i<count($id_candidato); $i++) {
                $sql = "INSERT INTO opciones (id, id_encuesta, id_candidato) VALUES (null, :id_encuesta, :id_candidato)";
                $statement = $this->_db->prepare($sql);
                $statement->execute(array(
                    ':id_candidato'  => $id_candidato[$i],
                    ':id_encuesta'   => $lastReciboId
                ));
                }
 
            $this->_db->commit();
            echo 'Datos insertados';
        } catch (PDOException $e) {
            // si ocurre un error hacemos rollback para anular todos los insert
            $this->_db->rollBack();
            echo $e->getMessage();
        }
    } 
   

[mortiprogramador]

Saludo

Pues tal vez podrías envíar el parámetro $_POST de candidato directamente
al modelo, en vez de recorrerlo antes en el controlador, así evitas
doble recorrido.

Y otra podría ser que no uses $_POST como tal,
para eso puedes hacer lo mismo que haces con los demás parámetros,
el getPostParam.

[stevens82]

Hola gracias por la respuesta, tengo una consulta respecto a la transaccion, hice a proposito un error para que no me ingrese los egistros a la segunda tabla, y necesito que si no ingresa ningun registro la primera tabla tampoco pero me sucede que si lo ingresa asi no haya ingresado ningun registro en la segunda como puedo resolver problema?

[stevens82]

Creo que esto me funciona pero tengo ciertas dudas con parte del coidgo

Código PHP:

  public function registrarEncuesta($titulo, $cargo, $departamento, $provincia, $distrito, $fecha_enc, $id_candidato)
    {
        try {
            $this->_db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
            $this->_db->beginTransaction(); // iniciar transacción
            $a = $this->_db->prepare("INSERT INTO encuestas (id, titulo, id_cargo, id_pais, id_departamento, id_provincia, id_distrito, fecha_encuesta, fecha_registro, usuario_registrador) VALUES (null, :titulo, :cargo, 1, :departamento, :provincia, :distrito, :fecha_enc, now(), '" . Session::get('id_usuario') . "')"
                )->execute(array(
                    ':titulo'           => $titulo,
                    ':cargo'            => $cargo,
                    ':departamento'     => $departamento,
                    ':provincia'        => $provincia,
                    ':distrito'         => $distrito,
                    ':fecha_enc'        => $fecha_enc)
                );
            $lastReciboId = $this->_db->lastInsertId();
            if (!$a) {
                throw new Exception("ERROR AL INGRESAR LOS DATOS");
            } else {
                for ($i=0; $i<count($id_candidato); $i++) {
                    $b = $sql = "INSERT INTO opciones (id, id_encuesta, id_candidato) VALUES (null, :id_encuesta, :id_candidato)";
                    $statement = $this->_db->prepare($sql);
                    $statement->execute(array(
                    ':id_candidato'  => $id_candidato[$i],
                    ':id_encuesta'   => $lastReciboId
                ));
                }
            }
            if($a && $b) {
                $this->_db->commit();
            } else {
                $this->_db->rollBack();
            }
            // echo 'Datos insertados correctamente';
        } catch (PDOException $e) {
            // si ocurre un error hacemos rollback para anular todos los insert
            $this->_db->rollBack();
            throw $e;
            // echo $e->getMessage();
        }
    } 
   

[mortiprogramador]

Pues $b es igual al query, debería ser igual al $statement (como esta $a)

Y el if-else de $a vs $b debería ir en el ciclo,
para que valide cada operación a la tabla opciones.

[stevens82]

Gracias por tus respuestas, modifique el codigo asi:

Controller:

Código PHP:

  $fecha_enc = date('Y-m-d', strtotime($_POST['fecha_enc']));
            $candidato = $_POST['candidato'];

            $this->_encuestas->registrarEncuesta(
            $this->getPostParam('titulo'),
            $this->getPostParam('cargo'),
            $this->getPostParam('departamento'),
            $this->getPostParam('provincia'),
            $this->getPostParam('distrito'),
            $fecha_enc,
            $candidato); 
   

y en el model:

Código PHP:

  public function registrarEncuesta($titulo, $cargo, $departamento, $provincia, $distrito, $fecha_enc, array $id_candidato)
    {
        try {
            $this->_db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
            $this->_db->beginTransaction(); // iniciar transacción
            $a = $this->_db->prepare("INSERT INTO encuestas (id, titulo, id_cargo, id_pais, id_departamento, id_provincia, id_distrito, fecha_encuesta, fecha_registro, usuario_registrador) VALUES (null, :titulo, :cargo, 1, :departamento, :provincia, :distrito, :fecha_enc, now(), '" . Session::get('id_usuario') . "')"
                )->execute(array(
                    ':titulo'           => $titulo,
                    ':cargo'            => $cargo,
                    ':departamento'     => $departamento,
                    ':provincia'        => $provincia,
                    ':distrito'         => $distrito,
                    ':fecha_enc'        => $fecha_enc)
                );
            $lastReciboId = $this->_db->lastInsertId();
            if (!$a) {
                throw new Exception("ERROR AL INGRESAR LOS DATOS");
            } else {
                for ($i=0; $i<count($id_candidato); $i++) {
                    $sql = "INSERT INTO opciones (id, id_encuesta, id_candidato) VALUES (null, :id_encuesta, :id_candidato)";
                    $b = $statement = $this->_db->prepare($sql);
                    $statement->execute(array(
                    ':id_candidato'  => $id_candidato[$i],
                    ':id_encuesta'   => $lastReciboId
                ));
                }
                if($a && $b) {
                    $this->_db->commit();
                } else {
                    $this->_db->rollBack();
                }
            }
            // echo 'Datos insertados correctamente';
        } catch (PDOException $e) {
            // si ocurre un error hacemos rollback para anular todos los insert
            $this->_db->rollBack();
            throw $e;
            // echo $e->getMessage();
        }
    } 
   

Ahra hare el editar, gracias

[hhs]

Iniciado por stevens82

Gracias por tus respuestas, modifique el codigo asi:

Controller:

Código PHP:

  $fecha_enc = date('Y-m-d', strtotime($_POST['fecha_enc']));
            $candidato = $_POST['candidato'];
 
            $this->_encuestas->registrarEncuesta(
            $this->getPostParam('titulo'),
            $this->getPostParam('cargo'),
            $this->getPostParam('departamento'),
            $this->getPostParam('provincia'),
            $this->getPostParam('distrito'),
            $fecha_enc,
            $candidato); 
   

y en el model:

Código PHP:

  public function registrarEncuesta($titulo, $cargo, $departamento, $provincia, $distrito, $fecha_enc, array $id_candidato)
    {
        try {
            $this->_db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
            $this->_db->beginTransaction(); // iniciar transacción
            $a = $this->_db->prepare("INSERT INTO encuestas (id, titulo, id_cargo, id_pais, id_departamento, id_provincia, id_distrito, fecha_encuesta, fecha_registro, usuario_registrador) VALUES (null, :titulo, :cargo, 1, :departamento, :provincia, :distrito, :fecha_enc, now(), '" . Session::get('id_usuario') . "')"
                )->execute(array(
                    ':titulo'           => $titulo,
                    ':cargo'            => $cargo,
                    ':departamento'     => $departamento,
                    ':provincia'        => $provincia,
                    ':distrito'         => $distrito,
                    ':fecha_enc'        => $fecha_enc)
                );
            $lastReciboId = $this->_db->lastInsertId();
            if (!$a) {
                throw new Exception("ERROR AL INGRESAR LOS DATOS");
            } else {
                for ($i=0; $i<count($id_candidato); $i++) {
                    $sql = "INSERT INTO opciones (id, id_encuesta, id_candidato) VALUES (null, :id_encuesta, :id_candidato)";
                    $b = $statement = $this->_db->prepare($sql);
                    $statement->execute(array(
                    ':id_candidato'  => $id_candidato[$i],
                    ':id_encuesta'   => $lastReciboId
                ));
                }
                if($a && $b) {
                    $this->_db->commit();
                } else {
                    $this->_db->rollBack();
                }
            }
            // echo 'Datos insertados correctamente';
        } catch (PDOException $e) {
            // si ocurre un error hacemos rollback para anular todos los insert
            $this->_db->rollBack();
            throw $e;
            // echo $e->getMessage();
        }
    } 
   

Ahra hare el editar, gracias

No era necesario complicar tu códifgo como lo hiciste para capturar excepciones.
Tu código original estaba bien, solo tienes que capturar una excepción mas general porque solo esperas que falle los insert y pueden suceder otras cosas.
agrega un catch adicional para que captures un Exception y debe de funcionar sin necesidad de usar condiciones

Código PHP:

public function registrarEncuesta($titulo, $cargo, $departamento, $provincia, $distrito, $fecha_enc, $id_candidato) 
{ 
        try { 
            $this->_db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);
            $this->_db->beginTransaction();
            
            $this->_db->prepare("INSERT INTO encuestas (id, titulo, id_cargo, id_pais, id_departamento, id_provincia, id_distrito, fecha_encuesta, fecha_registro, usuario_registrador) VALUES (null, :titulo, :cargo, 1, :departamento, :provincia, :distrito, :fecha_enc, now(), '" . Session::get('id_usuario') . "')" 
                )->execute(array( 
                    ':titulo'           => $titulo, 
                    ':cargo'            => $cargo, 
                    ':departamento'     => $departamento, 
                    ':provincia'        => $provincia, 
                    ':distrito'         => $distrito, 
                    ':fecha_enc'        => $fecha_enc) 
                ); 
                
            $lastReciboId = $this->_db->lastInsertId(); 
            for ($i=0; $i<count($id_candidato); $i++) { 
                $sql = "INSERT INTO opciones (id, id_encuesta, id_candidato) VALUES (null, :id_encuesta, :id_candidato)"; 
                $statement = $this->_db->prepare($sql); 
                $statement->execute(array( 
                    ':id_candidato'  => $id_candidato[$i], 
                    ':id_encuesta'   => $lastReciboId 
                )); 
                } 
 
            $this->_db->commit(); 
            echo 'Datos insertados'; 
            
        } catch (PDOException $e) { 
            // si ocurre un error hacemos rollback para anular todos los insert 
            $this->_db->rollBack(); 
            echo $e->getMessage(); 
        } catch (Exception $e) {
            //si sucede otra cosa inesperada
            $this->_db_rollbak()
            //aqui puedes mandar a un log el mensaje de error $e->getMessage()
        }
}
 

[stevens82]

Hola hhs, gracias por responder, a eso mereferia hacerlo menos complicado, otra consulta para la modificacion de las opciones, tengo que hacer una consulta para eliminar y otra para insertar no es asi?