Trifulcas

Usar mi capa de datos en un mantenimiento:

package com.trifulcas.datos;


import java.util.List;
import java.util.Scanner;

public class AccesoDAO {

	public static void main(String[] args) {

		try {
			// He abstraído la base de datos
			// Sólo tengo que crear una instancia de mi capa de Datos
			ActorDAO bd = new ActorDAO();

			Scanner in = new Scanner(System.in);
			int res = 0;
			do {
				System.out.println(
						"1.- Buscar actores\n2.- Añadir actores\n3.- Modificar actores\n4.- Eliminar\n0.- Salir");
				res = in.nextInt();
				String sql, nombre, apellido;
				int actor_id;
				switch (res) {
				case 1:
					System.out.println("Buscar actores");

					System.out.println("Dime una parte el apellido");
					String cad = in.next();
					List<Actor> actores = bd.getActors(cad);
					for (Actor actor : actores) {
						System.out.println(actor);
					}

					break;
				case 2:
					System.out.println("Añadir actores");
					System.out.println("Dime el nombre");
					nombre = in.next();
					System.out.println("Dime el apellido");
					apellido = in.next();

					if (bd.addActor(new Actor(0, nombre, apellido, null))) {
						System.out.println("Registro insertado");
					} else {
						System.out.println("No se ha insertado el registro");
					}

					break;
				case 3:
					System.out.println("Modificar actores");
					System.out.println("Dime el id del actor que quieres modificar");
					actor_id = in.nextInt();
					System.out.println("Dime el nombre");
					nombre = in.next();
					System.out.println("Dime el apellido");
					apellido = in.next();

					if (bd.updateActor(new Actor(actor_id, nombre, apellido, null))) {
						System.out.println("Registro modificado");
					} else {
						System.out.println("No se ha modificado el registro");
					}
					break;
				case 4:
					System.out.println("Eliminar actores");
					System.out.println("Dime el id del actor que quieres eliminar");
					actor_id = in.nextInt();
					if (bd.deleteActor(actor_id)) {
						System.out.println("Registro eliminado");
					} else {
						System.out.println("No se ha eliminado el registro");
					}
					break;
				}
			} while (res != 0);

		} catch (Exception ex) {

			System.out.println(ex);
		}
	}

}

package com.trifulcas.datos;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;

public class ActorDAO {

	private Connection con;
	private int max_records=1000;
	public ActorDAO() {
		try {
			Class.forName("com.mysql.cj.jdbc.Driver");
			con = DriverManager.getConnection("jdbc:mysql://localhost:3306/sakila", "root", "");

		} catch (Exception ex) {
			System.out.println(ex);
		}
	}

	public Actor getActor(int id) {
		Actor res = null;
		try {
			String sql = "select * from actor where actor_id=?" ;
			PreparedStatement stmt = con.prepareStatement(sql);

			stmt.setInt(1, id);

			ResultSet rs = stmt.executeQuery();
			if (rs.next()) {
				res = new Actor(rs.getInt("actor_id"), rs.getString("first_name"),rs.getString("last_name"),rs.getDate("last_update"));
			}

		} catch (Exception ex) {
			System.out.println(ex);
		}
		return res;
	}
	
	public List<Actor> getActors(int limite){
		List<Actor> res=new ArrayList<Actor>();
		try {
			String sql = "select * from actor limit ?" ;
			PreparedStatement stmt = con.prepareStatement(sql);
			stmt.setInt(1, limite);
			ResultSet rs = stmt.executeQuery();
			while (rs.next()) {
				Actor temp = new Actor(rs.getInt("actor_id"), rs.getString("first_name"),rs.getString("last_name"),rs.getDate("last_update"));
				res.add(temp);
			}

		} catch (Exception ex) {
			System.out.println(ex);
		}
		return res;
	}
	public List<Actor> getActors(){
		return getActors(max_records);
	}

/**
	 * Devuelve un arraylist de actores cuyo apellido contenga la cadena que le pasamos
	 * @param cad cadena a buscar
	 * @return ArrayList de actores
	 */
	public List<Actor> getActors(String cad) {
		List<Actor> res = new ArrayList<Actor>();
		try {
			String sql = "select * from actor where last_name like ?";
			PreparedStatement stmt = con.prepareStatement(sql);
			stmt.setString(1, '%'+cad+'%');
			ResultSet rs = stmt.executeQuery();
			while (rs.next()) {
				Actor temp = new Actor(rs.getInt("actor_id"), rs.getString("first_name"), rs.getString("last_name"),
						rs.getDate("last_update"));
				res.add(temp);
			}

		} catch (Exception ex) {
			System.out.println(ex);
		}
		return res;
	}


	public boolean addActor(Actor actor) {
		try {
			String sql = "insert into actor (first_name, last_name) values (?,?)" ;
			PreparedStatement stmt = con.prepareStatement(sql);
			stmt.setString(1, actor.getFirst_name());
			stmt.setString(2, actor.getLast_name());
			int res=stmt.executeUpdate();
			return res==1;
		} catch (Exception ex) {
			System.out.println(ex);
		}
		return false;
	}
	
	public boolean updateActor(Actor actor) {
		try {
			String sql = "update actor set first_name=?, last_name=? where actor_id=?" ;
			PreparedStatement stmt = con.prepareStatement(sql);
			stmt.setString(1, actor.getFirst_name());
			stmt.setString(2, actor.getLast_name());
			stmt.setInt(3, actor.getActor_id());
			int res=stmt.executeUpdate();
			return res==1;
		} catch (Exception ex) {
			System.out.println(ex);
		}
		return false;
	}
	
	public boolean deleteActor(Actor actor) {
		try {
			return deleteActor(actor.getActor_id());
		} catch (Exception ex) {
			System.out.println(ex);
		}
		return false;
	}
	
	public boolean deleteActor(int actor_id) {
		try {
			String sql = "delete from actor where actor_id=?" ;
			PreparedStatement stmt = con.prepareStatement(sql);
			stmt.setInt(1, actor_id);
			int res=stmt.executeUpdate();
			return res==1;
		} catch (Exception ex) {
			System.out.println(ex);
		}
		return false;
	}

}

package com.trifulcas.datos;

import java.util.List;

public class AccesoDAO {

	public static void main(String[] args) {
		
		// He abstraído la base de datos
		// Sólo tengo que crear una instancia de mi capa de Datos
		ActorDAO bd=new ActorDAO();
		
		// Trabajo exclusivamente con POJO no con registros de la base de datos
		// Que hasta desconozco o no me interesa como están implementados
		Actor penelope=bd.getActor(1);
		
		System.out.println(penelope.getFirst_name());

		// Obtengo todos los actores en una lista y recorro la lista
		List<Actor> actores=bd.getActors(20);
		for(Actor actor:actores) {
			System.out.println(actor);
		}
		
		// Para añadir creo un actor nuevo y después llamo a la capa DAO para añadirlo
		Actor nuevo=new Actor(1,"wilfredo","etxevarria",null);
		if(bd.addActor(nuevo)) {
			System.out.println("Actor "+nuevo+" añadido");
		}
		
		// Modifico un actor
		penelope.setLast_name("Campofrío");
		bd.updateActor(penelope);
		
		// Elimino el actor concreto o por id
		Actor w=bd.getActor(320);
		bd.deleteActor(w);
		bd.deleteActor(321);
	}

}

Primero creamos el POJO:

package com.trifulcas.datos;

import java.sql.Date;

public class Actor {

	private int actor_id;
	private String first_name;
	private String last_name;
	private Date last_update;
	
	public Actor(int actor_id, String first_name, String last_name, Date last_update) {
		super();
		this.actor_id = actor_id;
		this.first_name = first_name;
		this.last_name = last_name;
		this.last_update = last_update;
	}
	
	/**
	 * @return the actor_id
	 */
	public int getActor_id() {
		return actor_id;
	}
	/**
	 * @param actor_id the actor_id to set
	 */
	public void setActor_id(int actor_id) {
		this.actor_id = actor_id;
	}
	/**
	 * @return the first_name
	 */
	public String getFirst_name() {
		return first_name;
	}
	/**
	 * @param first_name the first_name to set
	 */
	public void setFirst_name(String first_name) {
		this.first_name = first_name;
	}
	
	/**
	 * @return the last_name
	 */
	public String getLast_name() {
		return last_name;
	}
	/**
	 * @param last_name the last_name to set
	 */
	public void setLast_name(String last_name) {
		this.last_name = last_name;
	}
	/**
	 * @return the last_update
	 */
	public Date getLast_update() {
		return last_update;
	}
	/**
	 * @param last_update the last_update to set
	 */
	public void setLast_update(Date last_update) {
		this.last_update = last_update;
	}
	
	public String toString() {
		return actor_id+" | "+first_name+" | "+last_name+" | "+last_update;
	}
	
}

Capa de datos:

package com.trifulcas.datos;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.ArrayList;
import java.util.List;

public class ActorDAO {

	private Connection con;

	public ActorDAO() {
		try {
			Class.forName("com.mysql.cj.jdbc.Driver");
			con = DriverManager.getConnection("jdbc:mysql://localhost:3306/sakila", "root", "");

		} catch (Exception ex) {
			System.out.println(ex);
		}
	}

	public Actor getActor(int id) {
		Actor res = null;
		try {
			String sql = "select * from actor where actor_id=?" ;
			PreparedStatement stmt = con.prepareStatement(sql);

			stmt.setInt(1, id);

			ResultSet rs = stmt.executeQuery();
			if (rs.next()) {
				res = new Actor(rs.getInt("actor_id"), rs.getString("first_name"),rs.getString("last_name"),rs.getDate("last_update"));
			}

		} catch (Exception ex) {
			System.out.println(ex);
		}
		return res;
	}
	
	public List<Actor> getActors(){
		List<Actor> res=new ArrayList<Actor>();
		try {
			String sql = "select * from actor " ;
			PreparedStatement stmt = con.prepareStatement(sql);
			ResultSet rs = stmt.executeQuery();
			while (rs.next()) {
				Actor temp = new Actor(rs.getInt("actor_id"), rs.getString("first_name"),rs.getString("last_name"),rs.getDate("last_update"));
				res.add(temp);
			}

		} catch (Exception ex) {
			System.out.println(ex);
		}
		return res;
	}

}

Ejemplo de uso:

package com.trifulcas.datos;

import java.util.List;

public class AccesoDAO {

	public static void main(String[] args) {
		
		// He abstraído la base de datos
		ActorDAO bd=new ActorDAO();
		
		Actor penelope=bd.getActor(1);
		
		System.out.println(penelope.getFirst_name());

		List<Actor> actores=bd.getActors();
		for(Actor actor:actores) {
			System.out.println(actor);
		}
		
		Actor nuevo=new Actor(1,"w","e",null);
	}

}

Vamos a realizar un CRUD de países para la base de datos Sakila

Tarea extra:

Añadir una opción 5.- Insertar varios

Que nos pregunte ¿Cuantos países quieres insertar?
Si le decimos, por ejemplo, 4, nos insertará en la tabla country lo siguiente:

Pais fake 1
Pais fake 2
Pais fake 3
Pais fake 4

package com.trifulcas.datos;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.Scanner;

public class MantenimientoActores {
	public static void main(String[] args) {

		try {

			Class.forName("com.mysql.cj.jdbc.Driver");
			Connection con = DriverManager.getConnection("jdbc:mysql://localhost:3306/sakila", "root", "");
			System.out.println("Conexión correcta");

			Scanner in = new Scanner(System.in);
			int res = 0;
			do {
				System.out.println(
						"1.- Buscar actores\n2.- Añadir actores\n3.- Modificar actores\n4.- Eliminar\n0.- Salir");
				res = in.nextInt();
				String sql, nombre, apellido;
				int actor_id;
				PreparedStatement ps;
				switch (res) {
				case 1:
					System.out.println("Buscar actores");

					System.out.println("Dime una parte el apellido");
					String cad = in.next();
					sql = "select * from actor where last_name like ?";
					// Creo mi sentencia preparada. Tiene 1 parámetro
					ps = con.prepareStatement(sql);
					ps.setString(1, "%" + cad + "%");
					ResultSet rs = ps.executeQuery();
					while (rs.next()) {
						System.out.println(rs.getString("first_name") + " " + rs.getString("last_name"));
					}

					break;
				case 2:
					System.out.println("Añadir actores");
					System.out.println("Dime el nombre");
					nombre = in.next();
					System.out.println("Dime el apellido");
					apellido = in.next();

					sql = "insert into actor(first_name,last_name) values (?,?)";
					ps = con.prepareStatement(sql);
					ps.setString(1, nombre);
					ps.setString(2, apellido);
					if (ps.executeUpdate() == 1) {
						System.out.println("Registro insertado");
					} else {
						System.out.println("No se ha insertado el registro");
					}

					break;
				case 3:
					System.out.println("Modificar actores");
					System.out.println("Dime el id del actor que quieres modificar");
					actor_id = in.nextInt();
					System.out.println("Dime el nombre");
					nombre = in.next();
					System.out.println("Dime el apellido");
					apellido = in.next();

					sql = "update actor set first_name=?, last_name=? where actor_id=?";
					ps = con.prepareStatement(sql);
					ps.setString(1, nombre);
					ps.setString(2, apellido);
					ps.setInt(3, actor_id);
					if (ps.executeUpdate() == 1) {
						System.out.println("Registro modificado");
					} else {
						System.out.println("No se ha modificado el registro");
					}
					break;
				case 4:
					System.out.println("Eliminar actores");
					System.out.println("Dime el id del actor que quieres eliminar");
					actor_id = in.nextInt();
					sql = "delete from actor where actor_id=?";
					ps = con.prepareStatement(sql);
					ps.setInt(1, actor_id);
					if (ps.executeUpdate() == 1) {
						System.out.println("Registro eliminado");
					} else {
						System.out.println("No se ha eliminado el registro");
					}
					break;
				}
			} while (res != 0);

			con.close();

		} catch (Exception ex) {

			System.out.println(ex);
		}
	}
}

http://chuwiki.chuidiang.org/index.php?title=Ejemplo_con_preparedStatement

https://www.arquitecturajava.com/jdbc-prepared-statement-y-su-manejo/

http://puntocomnoesunlenguaje.blogspot.com/2017/11/java-jdbc-prepared-statements.html

Un ejemplo:

package com.trifulcas.datos;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

public class AccesoSakila {

	public static void main(String[] args) {

		try {
			// Lo primero de todo crear una conexión CTRL+MAY+O -> importación automática de
			// los paquetes que falten

			// Esta línea nos 'registra' el conector mysql dentro de Java
			Class.forName("com.mysql.cj.jdbc.Driver");
			// Aquí nos creamos la conexión con una cadena de conexión
			// Lo primero es el tipo de conector: jdbc:mysql
			// Después la url del servidor SGBD //localhost:3306/
			// Después opcionalmente pero está bien ponerlo la base de datos /sakila
			// Por último usuario y contraseña root ''
			Connection con = DriverManager.getConnection("jdbc:mysql://localhost:3306/sakila", "root", "");
			System.out.println("Conexión correcta");

			// Statement es una sentencia SQL
			// PreparedStatement es una sentencia SQL lo único que 'preparada'

			String sql = "Select * from actor where last_name like '%b%'";
			System.out.println(sql);
			String cad = "b";

			sql = "select * from actor where last_name like '%" + cad + "%'";
			System.out.println(sql);

			// Cuando en mi sentencia tengo parámetros dinámicos que me pueden venir
			// de un teclado, o de un fichero o de un bucle o de donde sea
			// Yo puedo crear una sentencia preparada
			// Una sentencia sql en la que dejamos unos huecos para insertar un valor

			// En este insert yo estoy diciendo que voy a insertar un actor, pero no
			// especifico los valores
			// Estoy dejando dos huecos: los interrogantes
			sql = "insert into actor(first_name,last_name) values (?,?)";
			PreparedStatement ps = con.prepareStatement(sql);

			// Yo no puedo ejecutar mi sentencia preparada porque no he rellenado los huecos
			// Pero el conector ya ha establecido un 'plan' para mi sql

			// Para poder ejecutar la sentencia tengo que poner valores en los huecos
			ps.setString(1, "Juan");
			ps.setString(2, "L'hopital");
			// Aquí ejecuto la sentencia
			ps.executeUpdate();

			// Pongo otros valores en los huecos
			ps.setString(1, "Ana");
			ps.setString(2, "D'anjou");

			// ventajas: Más claridad que con la concatenación
			// Más rapidez porque se analiza el plan de ejecución una vez aunque se llame
			// varias
			// Evita inyección SQL
			// Evita problemas con comillas simples

			// Desventajas: Tenmos que indicar los parámetros y cuando son muchos podemos
			// liarnos
			ps.executeUpdate();

			
			// Podemos usarlo para modificar o en una condición para leer los datos
			ps = con.prepareStatement("select * from actor where first_name like ?");
			ps.setString(1, "%ar%");
			ResultSet rs = ps.executeQuery();
			while (rs.next()) {
				System.out.println(
						rs.getInt("actor_id") + "  " + rs.getString("first_name") + "  " + rs.getString("last_name"));
			}

		} catch (Exception ex) {
			System.out.println(ex);
		}
	}

}

https://www.ramoncarrasco.es/es/content/es/kb/119/que-es-pojo

https://www.baeldung.com/java-pojo-class

Vamos a hacer un ejercicio muy sencillo de mantenimiento de actores. Un programa que nos va a mostrar el siguiente menú:

1.- Buscar actores
2.- Añadir actores
0.- Salir

En la primera opción nos va a pedir una cadena y nos va a mostrar los actores cuyo last_name contengan esa cadena (recordad que estamos en SQL: like).

En la segunda opción nos va a pedir un first_name y un last_name y nos va a añadir el actor a la base de datos.

package com.trifulcas.datos;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

public class AccesoSakila {

	public static void main(String[] args) {

		try {
			// Lo primero de todo crear una conexión CTRL+MAY+O -> importación automática de los paquetes que falten

			// Esta línea nos 'registra' el conector mysql dentro de Java
			Class.forName("com.mysql.cj.jdbc.Driver");
			// Aquí nos creamos la conexión con una cadena de conexión
			// Lo primero es el tipo de conector: jdbc:mysql
			// Después la url del servidor SGBD //localhost:3306/
			// Después opcionalmente pero está bien ponerlo la base de datos /sakila
			// Por último usuario y contraseña root ''
			Connection con = DriverManager.getConnection("jdbc:mysql://localhost:3306/sakila", "root", "");
			System.out.println("Conexión correcta");
			
			// Con esta conexión yo puedo lanzar comandos a la base de datos.
			// Los comandos son SQL y pueden ser de dos tipos:
			// Lectura de datos (SELECT)
			// Modificación de datos (INSERT,UPDATE,DELETE)
			
			// Crear una sentencia Statement
			// Puedo lanzar dos tipos de ejecución: 
			// executeQuery: consulta, me devolverá datos
			// executeUpdate: modificación, no me devuelve datos
			Statement stmt = con.createStatement();
			
			// Crearme una sentencia sql para obtener unos datos
			String sql="select * from actor where first_name like 'b%'";
			
			// Guardo los resultados en un ResultSet: Una clase que nos permite ir leyendo los
			// Registros que nos ha devuelto nuestra consulta
			ResultSet rs = stmt.executeQuery(sql);
		
			// Cada vez que yo quiero un registro llamo a next()
			// Cuando no haya registros devuelve false y sale del while
			while (rs.next()) {
				// Una vez he 'cargado' un registro puedo acceder a los campos de dos maneras
				// Por el índice de la columna (empezando por el 1)
				System.out.println(rs.getInt(1) + "  " + rs.getString(2) + "  " + rs.getString(3));
				int id=rs.getInt(1);
				String first_name=rs.getString(2);
				String last_name=rs.getString(3);
				System.out.println(id+"-"+first_name+" - "+last_name);

				// Por el nombre de la columna
				// En los dos casos como Java es tipado tengo que usar el tipo correspondiente
				// getInt, getString,...
				id=rs.getInt("actor_id");
				first_name=rs.getString("first_name");
				last_name=rs.getString("last_name");
				System.out.println(id+" | "+first_name+" | "+last_name);
			}
			
			// Para modificar datos es más sencillo puesto que no tenemos resultados
			// Plantamos nuestra sentencia sql
			sql="insert into actor (first_name,last_name) values ('aa','bb')";
			
			// La ejecutamos con executeUpdate que no devuelve un ResultSet
			// Devuelve el número de filas afectadas
			int res=stmt.executeUpdate(sql);
			System.out.println(res);
			
			// La sentencia sql pueder un update o un delete
			sql="update actor set last_name='bbb' where first_name ='aa'";
			res=stmt.executeUpdate(sql);
			System.out.println(res);
			
		} catch (Exception ex) {
			System.out.println(ex);
		}
	}

}