3. Consultas no preparadas
a. Leer datos
El método que permite ejecutar una consulta SQL es: query().
Este método forma parte del objeto conexión que ha devuelto con new PDO(). Toma como argumento la consulta SQL en forma de cadena de caracteres.
Esta función devuelve un objeto resultado que contiene todo lo que la consulta SQL vuelve a enviar.
El método que permite conocer el número de registros en el resultado de la consulta es: rowCount().
Este método forma parte del objeto $resultado que el método query() ha devuelto.
Por ejemplo, para obtener el número de registros en la tabla Persona:
<?php
try
{
$base = new PDO(’mysql:host=127.0.0.1;dbname=_prueba’, ’root’, ’’);
$base->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
// Recuperación datos de la tabla Persona
$resultado = $base->query(’SELECT * FROM Persona’);
echo "Número de personas:".$resultado->rowCount();
// Muestra el número de registros
$resultado->closeCursor(); // Cierre de la consulta
}
catch(Exception $e)
{
// mensaje en caso de error
die(’Error : ’.$e->GetMessage());
}
?>
Da como resultado:
Número de personas:6
Si ahora quiere mostrar los datos de la tabla Persona, debe utilizar fetch, que permite leer el registro actual y desplazarse al siguiente registro.
El método que permite realizar el fetch de la consulta es: fetch().
Este método forma parte del objeto $resultado que el método query() ha devuelto.
Por ejemplo, para mostrar los apellidos y los nombres contenidos en la tabla Persona:
<?php
try
{
$base = new PDO(’mysql:host=127.0.0.1;dbname=_test’, ’root’, ’’);
$base->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
// Recuperación de datos de la tabla Persona
$resultado = $base->query(’SELECT Nombre, Apellidos FROM Persona’);
echo "Número de personas:".$resultado->rowCount();
// Muestra el número de registros
while ($datos = $resultado->fetch())
{
?>
<p>
Apellidos : <?php echo $datos[’Apellido’]; ?>,
Nombre : <?php echo $datos[’Nombre’]; ?>
</p>
<?php
}
$resultado->closeCursor(); // Cierre de la consulta
}
catch(Exception $e)
{
// mensaje en caso de error
die(’Error : ’.$e->GetMessage());
}
?>
Da como resultado:
Número de personas:6
Apellidos:Gómez del Pozo y nombre:Carolina
Apellidos:Morales HonHon y nombre:Estefanía
Apellidos:Morales y nombre:Luna
Apellidos:Del Morán y nombre:Luis
Apellidos:López y nombre:María
Apellidos:Prieto y nombre:Mónica
b. Escribir datos
Para escribir datos, debe ejecutar una consulta de tipo INSERT.
El método que permite ejecutar una consulta SQL de tipo UPDATE, INSERT o DELETE es: exec().
Este método forma parte del objeto conexión que se ha devuelto por new PDO(). Toma como argumento la consulta SQL en forma de cadena de caracteres.
Por ejemplo, para insertar una persona llamada Oliver Durán, de 36 años de edad:
<?php
try
{
$base = new PDO(’mysql:host=127.0.0.1;dbname=_test’, ’root’, ’’);
$base->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
$sql = "INSERT INTO Persona (Nombre, Apellidos, Edad) VALUES
(’Oliver’,’Durán’,36)";
// Añadir datos en la tabla Persona
$base->exec($sql);
echo "Persona añadida.";
}
catch(Exception $e)
{
// mensaje en caso de error
die(’Error : ’.$e->GetMessage());
}
?>
Entonces obtiene un nuevo registro en la base de datos:
Observe que el id_person no se ha añadido en la consulta. Como es autoincremental, la base de datos asignará un nuevo número al id_person.
Por lo tanto, cuando inserta una nueva persona, no conoce su identificador. Para recuperar el último Id autoincremental que se ha añadido en la base de datos, debe utilizar el método lastInsertId(). Este método forma parte del objeto conexión que se ha devuelto por new PDO() y devuelve el último entero autoincremental que se ha añadido en la base de datos.
Por ejemplo, para insertar una persona llamada Gerardo Roldán, de 64 años de edad:
<?php
try
{
$base = new PDO(’mysql:host=127.0.0.1;dbname=_prueba’, ’root’, ’’);
$base->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
$sql = "INSERT INTO Persona (Nombre, Apellidos, Edad) VALUES
(’Gerardo’,’Roldán’,64)";
// Añadir de datos en la tabla Persona
$base->exec($sql);
echo "El identificador de la última persona añadida es:";
echo $base->lastInsertId().".";
}
catch(Excepción $e)
{
// mensaje en caso de error
die(’Error : ’.$e->GetMessage());
}
?>
Da como resultado:
El identificador de la última persona añadida es:8.
c. Eliminar datos
Para eliminar datos, debe ejecutar una consulta de tipo DELETE.
El método que permite ejecutar una consulta SQL de tipo UPDATE, INSERT o DELETE es: exec().
Este método forma parte del objeto conexión que se ha devuelto por new PDO(). Toma como argumento la consulta SQL en forma de cadena de caracteres.
Por ejemplo, para eliminar una persona cuyo apellido es López:
<?php
try
{
$base = new PDO(’mysql:host=127.0.0.1;dbname=_prueba’, ’root’, ’’);
$base->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
$sql = "DELETE FROM Persona WHERE Apellidos = ’López";
// Eliminación de datos en la tabla Persona
$base->exec($sql);
echo "Persona eliminada.";
}
catch(Exception $e)
{
// mensaje en caso de error
die(’Error : ’.$e->GetMessage());
}
?>
Da como resultado:
Persona eliminada.
d. Actualizar datos
Para modificar datos, ejecute una consulta de tipo UPDATE.
El método que permite ejecutar una consulta SQL de tipo UPDATE, INSERT o DELETE es: exec().
Este método forma parte del objeto conexión que se ha devuelto por new PDO(). Toma como argumento la consulta SQL en forma de cadena de caracteres.
Para obtener el número de registros modificados en una consulta de tipo UPDATE, utilice el retorno del método exec(), que devuelve el número de registros afectados.
Por ejemplo, para modificar el apellido Prieto por Lucas y la edad de 36 a 33 años:
<?php
try
{
$base = new PDO(’mysql:host=127.0.0.1;dbname=_prueba’, ’root’, ’’);
$base->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
$sql = "UPDATE Persona SET Apellidos = ’Lucas’, Edad = 33 WHERE
Apellidos = ’Prieto’";
// Modificación de datos en la tabla Persona
$numero = $base->exec($sql);
echo "Número de personas modificadas:".$numero;
}
catch(Excepción $e)
{
// mensaje en caso de error
die(’Error : ’.$e->GetMessage());
}
?>
Da como resultado:
Número de personas modificadas:1
4. Consultas preparadas
a. Leer datos
El método que permite preparar una consulta SQL de tipo SELECT, UPDATE, DELETE o INSERT es: prepare().
Este método forma parte del objeto conexión que se ha devuelto por new PDO(). Toma como argumento una cadena de caracteres que contiene la consulta SQL con apellidos o marcadores que hay que unir a valores diferentes.
Esta función devuelve un objeto de tipo PDOStatement que contiene todo lo que vuelve a enviar la consulta SQL.
Por ejemplo, para mostrar los apellidos y los nombres incluidos en la tabla Persona con una edad > 5 y un apellido que comienza por ’Mo’:
<?php
try
{
$base = new PDO(’mysql:host=127.0.0.1;dbname=_prueba’, ’root’, ’’);
$base->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
$sql = "Select Nombre, Apellidos FROM Persona WHERE Edad > ?
AND Apellidos LIKE ?";
// Preparación de la consulta con los marcadores
$resultado = $base->prepare($sql);
$resultado->ejecuta(array(5,’Mo%’)); //execute toma como parámetro
una tabla que contiene los valores en el orden cuyo marcador es un ?
while ($registro = $resultado->fetch())
{
echo ’Apellidos:’.$registro[’Apellido’].’,
Nombre:’.$registro[’Nombre’].’<br />’;
}
$resultado->closeCursor();
}
catch(Excepción $e)
{
// mensaje en caso de error
die(’Error : ’.$e->GetMessage());
}
?>
Da como resultado:
Apellidos:Morales HonHon, Nombre:Nanie
Y el mismo ejemplo designando los marcadores:
<?php
try
{
$base = new PDO(’mysql:host=127.0.0.1;dbname=_prueba’, ’root’, ’’);
$base->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
$sql = "Select Nombre, Apellidos FROM Persona WHERE Edad > :Edad
AND Apellidos LIKE :apellido";
// Preparación de la consulta con los marcadores
$resultado = $base->prepare($sql);
$resultado->ejecuta(array(’edad’ => 5,’apellido’ => ’Mo%’)); //execute
toma como parámetro una tabla que contiene como clave el número
de marcadores y sus valores correspondientes
while ($registro = $resultado->fetch())
{
echo ’Apellidos:’.$registro[’Apellido’].’,
Nombre:’.$registo[’Nombre’].’<br />’;
}
$resultado->closeCursor();
}
catch(Exception $e)
{
// mensaje en caso de error
die(’Error : ’.$e->GetMessage());
}
?>
Da como resultado:
Apellidos:Morales HonHon, Nombre:Nanie
Esta solución tiene la ventaja de ser un poco más legible en los argumentos que pasan a la consulta SQL.
b. Escribir datos
Al igual que para leer datos, va a utilizar los métodos prepare() y execute().
Por ejemplo, para insertar una persona llamada Clara Rincón López, de 42 años de edad:
<?php
try
{
$base = new PDO(’mysql:host=127.0.0.1;dbname=_prueba’, ’root’, ’’);
$base->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
$sql = "INSERT INTO Persona (Nombre, Apellidos, Edad) VALUES
(:apellido, :nombre, :edad)";
// Preparación de la consulta con los marcadores
$resultado = $base->prepare($sql);
$resultado->ejecuta(array(’apellido’ => ’Rincón López’,’Nombre’ =>
’Clara’,
’Edad’ => 42));
echo "El identificador de la última persona añadida es:";
echo $base->lastInsertId().".";
$resultado->closeCursor();
}
catch(Excepción $e)
{
// mensaje en caso de error
die(’Error : ’.$e->GetMessage());
}
?>
Da como resultado:
El identificador de la última persona añadida es:9.
Puede ver en PHPMyADmin lo siguiente:
Si quiere ejecutar una consulta de inserción varias veces seguidas, utilice el enlace de argumentos con el método bindParam().
Por ejemplo, para insertar una persona llamada Juan López Ruiz, de 57 años, y otra persona llamada Bob Martínez, de 45 años de edad:
<?php
try
{
$base = new PDO(’mysql:host=127.0.0.1;dbname=_prueba’, ’root’, ’’);
$base->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
$sql = "INSERT INTO Persona (Nombre, Apellidos, Edad) VALUES
(:apellido, :nombre, :edad)";
// Preparación de la consulta con los marcadores
$resultado = $base->prepare($sql);
// Enlace de argumentos.
$resultado->bindParam(’:apellido’,$apellido);
$resultado->bindParam(’:nombre’,$nombre);
$resultado->bindParam(’:edad’,$edad);
//primera persona
$apellidos = "López Ruiz ";
$nombre = " Juan";
$edad = 57;
$resultado->ejecuta();
echo "El identificador de la última persona añadida es:";
echo $base->lastInsertId().".<br />";
//segunda persona
$nombre = "Bob";
$apellidos = "Martínez";
$edad = 45;
$resultado->ejecuta();
echo "El identificador de la última persona añadida es:";
echo $base->lastInsertId().".";
$resultado->closeCursor();
}
catch(Exception $e)
{
// mensaje en caso de error
die(’Error : ’.$e->GetMessage());
}
?>
Da como resultado:
El identificador de la última persona añadida es:10.
El identificador de la última persona añadida es:11.
c. Eliminar datos
Al igual que para escribir y leer datos, va a utilizar los métodos prepare() y execute().
Par ejemplo, para eliminar el registro Martínez:
<?php
try
{
$base = new PDO(’mysql:host=127.0.0.1;dbname=_prueba’, ’root’, ’’);
$base->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
$sql = "DELETE FROM Persona WHERE Apellidos =:apellido";
// Preparación de la consulta con los marcadores
$resultado = $base->prepare($sql);
$resultado->ejecuta(array(’apellido’ => ’Martínez’));
echo "Persona eliminada.";
$resultado->closeCursor();
}
catch(Exception $e)
{
// mensaje en caso de error
die(’Error : ’.$e->GetMessage());
}
?>
Da como resultado:
Persona eliminada.
d. Modificar datos
Al igual que para escribir y leer datos, va a utilizar los métodos prepare() y execute().
Por ejemplo, para modificar la edad de Nanie Morales HonHon de 55 a 36 años:
<?php
try
{
$base = new PDO(’mysql:host=127.0.0.1;dbname=_prueba’, ’root’, ’’);
$base->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
$sql = "UPDATE Persona SET Edad = :edad WHERE Apellidos = :apellidos
AND Nombre = :nombre";
// Preparación de la consulta con los marcadores
$resultado = $base->prepare($sql);
$resultado->ejecuta(array(’edad’ => 36, ’apellido’ => ’Morales HonHon’,
’Nombre’ => ’Nanie’));
echo "Persona modificada.";
$resultado->closeCursor();
}
catch(Excepción $e)
{
// mensaje en caso de error
die(’Error : ’.$e->GetMessage());
}
?>
Da como resultado:
Persona modificada.
e. Llamar a un procedimiento almacenado
Un procedimiento almacenado tiene un nombre y puede tener argumentos de entrada y de salida.
Lo hemos explicado más detalladamente en este capítulo, sección SQL avanzado - Los procedimientos almacenados y funciones.
Para empezar, debe crear los procedimientos almacenados creacion_persona y cubo de la sección SQL avanzado - Los procedimientos almacenados y funciones. Compruebe que el campo Id_idioma no está en el procedimiento almacenado creacion_persona.
El primer procedimiento almacenado creacion_persona solo tiene argumentos de entrada. Este procedimiento utiliza la palabra clave CALL y solo debe unir sus argumentos a la función bindParam() y ejecutar la consulta.
Por ejemplo, para añadir la persona David MORALES, de 40 años de edad:
<?php
try
{
// Conexión a la base de datos
$base = new PDO(’mysql:host=127.0.0.1;dbname=_prueba’, ’root’, ’’);
$base->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
$stmt = $base->prepare("CALL creacion_persona(?,?,?)");
$apellidos = ’MORALES’;
$nombre = ’David’;
$edad = 40;
$stmt->bindParam(1, $apellido, PDO::PARAM_STR, 20); //argumento de tipo
//STRING
$stmt->bindParam(2, $nombre, PDO::PARAM_STR, 20);
$stmt->bindParam(3, $edad, PDO::PARAM_INT); //argumento de tipo INTEGER
// Ejecución del procedimiento almacenado
$stmt->ejecuta();
echo "El procedimiento ha insertado una nueva persona.";
}
catch(Exception $e)
{
// mensaje en caso de error
die(’Error : ’.$e->GetMessage());
}
?>
Da como resultado:
El procedimiento ha insertado una nueva persona.
El segundo procedimiento almacenado cubo tiene un argumento de entrada y un argumento de salida.
Este procedimiento vuelve a enviar el valor en entrada al cubo. El problema es que hay un bug en PDO/MySQL que impide recuperar el valor de retorno de manera estándar. Por lo tanto, debe ejecutar una segunda consulta para recuperar el valor de salida.
<?php
try
{
// Conexión a la base de datos
$base = new PDO(’mysql:host=127.0.0.1;dbname=_prueba’, ’root’, ’’);
$base->setAttribute(PDO::ATTR_ERRMODE,PDO::ERRMODE_EXCEPTION);
//llamada al procedimiento almacenado y la consulta que recupera el
//argumento de salida.
$statement = $base->prepare(’CALL cubo(:entrada, @salida); SELECT
@salida AS salida;’);
$entrada = 3;
$statement->bindParam(’:entrada’, $entrada);
//ejecución de la procedimiento almacenada
$statement->ejecuta();
$statement->nextRowset();
//lectura del argumento de salida
$row = $statement->fetchObject();
echo "El valor ".$entrada." Al cubo es:".$row->salida;
}
catch(Exception $e)
{
// mensaje en caso de error
die(’Error : ’.$e->GetMessage());
}
?>
Da como resultado:
El valor de 3 al cubo es:27
Espero haber ayudado en algo. Hasta la próxima oportunidad!
Twittear
No hay comentarios:
Publicar un comentario