apuntes:dao
Differences
This shows you the differences between two versions of the page.
Next revision | Previous revision | ||
apuntes:dao [2023/05/28 16:17] – created Santiago Faci | apuntes:dao [2023/10/21 11:47] (current) – [Patrón DAO] Santiago Faci | ||
---|---|---|---|
Line 1: | Line 1: | ||
- | ===== Aplicación que conecta con Base de datos: Patrón DAO ===== | + | ====== Aplicación que conecta con Base de datos. Patrón DAO ====== |
+ | |||
+ | ===== Patrón DAO ===== | ||
+ | |||
+ | <file java Database.java> | ||
+ | public class Database { | ||
+ | |||
+ | private Connection connection; | ||
+ | |||
+ | public Connection getConnection() { | ||
+ | try { | ||
+ | Class.forName(MYSQL_DRIVER); | ||
+ | connection = DriverManager.getConnection(MYSQL_URL, | ||
+ | System.out.println(" | ||
+ | } catch (ClassNotFoundException cnfe) { | ||
+ | System.out.println(" | ||
+ | cnfe.printStackTrace(); | ||
+ | } catch (SQLException sqle) { | ||
+ | System.out.println(" | ||
+ | sqle.printStackTrace(); | ||
+ | } | ||
+ | |||
+ | return connection; | ||
+ | } | ||
+ | |||
+ | public void close() { | ||
+ | try { | ||
+ | connection.close(); | ||
+ | } catch (SQLException sqle) { | ||
+ | System.out.println(" | ||
+ | sqle.printStackTrace(); | ||
+ | } | ||
+ | } | ||
+ | } | ||
+ | </ | ||
+ | |||
+ | <file java BookDao.java> | ||
+ | public class BookDao { | ||
+ | |||
+ | private Connection connection; | ||
+ | |||
+ | public BookDao(Connection connection) { | ||
+ | this.connection = connection; | ||
+ | } | ||
+ | |||
+ | public void add(Book book) { | ||
+ | String sql = " | ||
+ | try { | ||
+ | PreparedStatement statement = connection.prepareStatement(sql); | ||
+ | statement.setString(1, | ||
+ | statement.setString(2, | ||
+ | statement.setString(3, | ||
+ | statement.executeUpdate(); | ||
+ | } catch (SQLException sqle) { | ||
+ | System.out.println(" | ||
+ | sqle.printStackTrace(); | ||
+ | } | ||
+ | } | ||
+ | |||
+ | public boolean delete(String title) { | ||
+ | String sql = " | ||
+ | try { | ||
+ | PreparedStatement statement = connection.prepareStatement(sql); | ||
+ | statement.setString(1, | ||
+ | int rows = statement.executeUpdate(); | ||
+ | |||
+ | return rows == 1; | ||
+ | } catch (SQLException sqle) { | ||
+ | System.out.println(" | ||
+ | sqle.printStackTrace(); | ||
+ | } | ||
+ | |||
+ | return false; | ||
+ | } | ||
+ | |||
+ | public boolean modify(String title, Book book) { | ||
+ | String sql = " | ||
+ | try { | ||
+ | PreparedStatement statement = connection.prepareStatement(sql); | ||
+ | statement.setString(1, | ||
+ | statement.setString(2, | ||
+ | statement.setString(3, | ||
+ | statement.setString(4, | ||
+ | int rows = statement.executeUpdate(); | ||
+ | return rows == 1; | ||
+ | } catch (SQLException sqle) { | ||
+ | | ||
+ | sqle.printStackTrace(); | ||
+ | } | ||
+ | |||
+ | return false; | ||
+ | } | ||
+ | |||
+ | public ArrayList< | ||
+ | String sql = " | ||
+ | ArrayList< | ||
+ | try { | ||
+ | PreparedStatement statement = connection.prepareStatement(sql); | ||
+ | ResultSet resultSet = statement.executeQuery(); | ||
+ | while (resultSet.next()) { | ||
+ | Book book = new Book(); | ||
+ | book.setTitle(resultSet.getString(" | ||
+ | book.setAuthor(resultSet.getString(" | ||
+ | book.setPublisher(resultSet.getString(" | ||
+ | books.add(book); | ||
+ | } | ||
+ | } catch (SQLException sqle) { | ||
+ | System.out.println(" | ||
+ | sqle.printStackTrace(); | ||
+ | } | ||
+ | |||
+ | return books; | ||
+ | } | ||
+ | |||
+ | public Book findByTitle(String title) { | ||
+ | String sql = " | ||
+ | Book book = null; | ||
+ | |||
+ | try { | ||
+ | PreparedStatement statement = connection.prepareStatement(sql); | ||
+ | statement.setString(1, | ||
+ | ResultSet resultSet = statement.executeQuery(); | ||
+ | if (resultSet.next()) { | ||
+ | book = new Book(); | ||
+ | book.setTitle(resultSet.getString(" | ||
+ | book.setAuthor(resultSet.getString(" | ||
+ | book.setPublisher(resultSet.getString(" | ||
+ | } | ||
+ | } catch (SQLException sqle) { | ||
+ | System.out.println(" | ||
+ | sqle.printStackTrace(); | ||
+ | } | ||
+ | |||
+ | return book; | ||
+ | } | ||
+ | } | ||
+ | </ | ||
+ | ===== Librería Jdbi 3 ===== | ||
+ | |||
+ | {{ jdbi.png }} | ||
+ | |||
+ | ==== Creación de un DAO con Jdbi ==== | ||
+ | |||
+ | <code java> | ||
+ | @Data | ||
+ | @RequiredArgsConstructor | ||
+ | @AllArgsConstructor | ||
+ | @NoArgsConstructor | ||
+ | @ToString | ||
+ | public class Vehicle { | ||
+ | |||
+ | private int id; | ||
+ | @NonNull | ||
+ | private String licensePlate; | ||
+ | @NonNull | ||
+ | private String brand; | ||
+ | @NonNull | ||
+ | private String model; | ||
+ | @NonNull | ||
+ | private int kilometers; | ||
+ | @NonNull | ||
+ | private String image; | ||
+ | @NonNull | ||
+ | private LocalDate registrationDate; | ||
+ | } | ||
+ | </ | ||
+ | |||
+ | <code java> | ||
+ | public class Database { | ||
+ | |||
+ | public static Jdbi jdbi; | ||
+ | public static Handle db; | ||
+ | |||
+ | public static void connect() { | ||
+ | jdbi = Jdbi.create(DATABASE_URL, | ||
+ | jdbi.installPlugin(new SqlObjectPlugin()); | ||
+ | db = jdbi.open(); | ||
+ | } | ||
+ | |||
+ | public static void close() { | ||
+ | db.close(); | ||
+ | } | ||
+ | } | ||
+ | </ | ||
+ | |||
+ | <code java> | ||
+ | public interface VehicleDAO { | ||
+ | |||
+ | @SqlQuery(" | ||
+ | @UseRowMapper(VehicleMapper.class) | ||
+ | List< | ||
+ | |||
+ | @SqlQuery(" | ||
+ | @UseRowMapper(VehicleMapper.class) | ||
+ | List< | ||
+ | |||
+ | @SqlQuery(" | ||
+ | @UseRowMapper(VehicleMapper.class) | ||
+ | List< | ||
+ | |||
+ | @SqlQuery(" | ||
+ | @UseRowMapper(VehicleMapper.class) | ||
+ | Vehicle getVehicle(int id); | ||
+ | |||
+ | @SqlUpdate(" | ||
+ | void addVehicle(String licensePlate, | ||
+ | |||
+ | @SqlUpdate(" | ||
+ | void removeVehicle(int id); | ||
+ | |||
+ | @SqlUpdate(" | ||
+ | void editVehicle(String licensePlate, | ||
+ | |||
+ | @SqlUpdate(" | ||
+ | void editVehicle(String licensePlate, | ||
+ | } | ||
+ | </ | ||
+ | |||
+ | <code java> | ||
+ | public class VehicleMapper implements RowMapper< | ||
+ | |||
+ | @Override | ||
+ | public Vehicle map(ResultSet rs, StatementContext ctx) throws SQLException { | ||
+ | return new Vehicle(rs.getInt(" | ||
+ | rs.getString(" | ||
+ | rs.getString(" | ||
+ | rs.getString(" | ||
+ | rs.getInt(" | ||
+ | rs.getString(" | ||
+ | DateUtils.getLocalDate(rs.getDate(" | ||
+ | ); | ||
+ | } | ||
+ | } | ||
+ | </ | ||
+ | |||
+ | ---- | ||
+ | |||
+ | (c) 2023 Santiago Faci |
apuntes/dao.1685290641.txt.gz · Last modified: 2023/05/28 16:17 by Santiago Faci