Differences

This shows you the differences between two versions of the page.

--- apuntes:dao [2023/10/21 11:44] – [Patrón DAO] Santiago Faci
+++ apuntes:dao [2023/10/21 11:47] (current) – [Patrón DAO] Santiago Faci
@@ Line 6: / Line 6: @@
 public class Database {
-    private Connection connection;
+  private Connection connection;
-    public Connection getConnection() {
+  public Connection getConnection() {
+    try {
+      Class.forName(MYSQL_DRIVER);
+      connection = DriverManager.getConnection(MYSQL_URL, USERNAME, PASSWORD);
+      System.out.println("Conectado!");
+    } catch (ClassNotFoundException cnfe) {
+      System.out.println("No se ha podido cargar el driver de conexión. Verifique que los drivers están disponibles");
+      cnfe.printStackTrace();
+    } catch (SQLException sqle) {
+      System.out.println("No se ha podido conectar con el servidor de base de datos. Comprueba que los datos son correctos y que el servidor se ha iniciado");
+      sqle.printStackTrace();
+    }
+    return connection;
+  }
+  public void close() {
+    try {
+      connection.close();
+    } catch (SQLException sqle) {
+      System.out.println("No se ha podido conectar con el servidor de base de datos. Comprueba que los datos son correctos y que el servidor se ha iniciado");
+      sqle.printStackTrace();
+    }
+  }
+}
+</file>
+<file java BookDao.java>
+public class BookDao {
+  private Connection connection;
+  public BookDao(Connection connection) {
+    this.connection = connection;
+  }
+  public void add(Book book) {
+    String sql = "INSERT INTO books (title, author, publisher) VALUES (?, ?, ?)";
+    try {
+      PreparedStatement statement = connection.prepareStatement(sql);
+      statement.setString(1, book.getTitle());
+      statement.setString(2, book.getAuthor());
+      statement.setString(3, book.getPublisher());
+      statement.executeUpdate();
+    } catch (SQLException sqle) {
+      System.out.println("No se ha podido conectar con el servidor de base de datos. Comprueba que los datos son correctos y que el servidor se ha iniciado");
+      sqle.printStackTrace();
+    }
+  }
+  public boolean delete(String title) {
+    String sql = "DELETE FROM books WHERE title = ?";
+    try {
+      PreparedStatement statement = connection.prepareStatement(sql);
+      statement.setString(1, title);
+      int rows = statement.executeUpdate();
+      return rows == 1;
+    } catch (SQLException sqle) {
+      System.out.println("No se ha podido conectar con el servidor de base de datos. Comprueba que los datos son correctos y que el servidor se ha iniciado");
+      sqle.printStackTrace();
+    }
+    return false;
+  }
+  public boolean modify(String title, Book book) {
+    String sql = "UPDATE books SET title = ?, author = ?, publisher = ? WHERE title = ?";
+    try {
+      PreparedStatement statement = connection.prepareStatement(sql);
+      statement.setString(1, book.getTitle());
+      statement.setString(2, book.getAuthor());
+      statement.setString(3, book.getPublisher());
+      statement.setString(4, title);
+      int rows = statement.executeUpdate();
+      return rows == 1;
+    } catch (SQLException sqle) {
+       System.out.println("No se ha podido conectar con el servidor de base de datos. Comprueba que los datos son correctos y que el servidor se ha iniciado");
+      sqle.printStackTrace();
+        }
+        return false;
+    }
+    public ArrayList<Book> findAll() {
+        String sql = "SELECT * FROM books ORDER BY title";
+        ArrayList<Book> books = new ArrayList<>();
         try {
-            Class.forName(MYSQL_DRIVER);
+            PreparedStatement statement = connection.prepareStatement(sql);
-            connection = DriverManager.getConnection(MYSQL_URL, USERNAME, PASSWORD);
+            ResultSet resultSet = statement.executeQuery();
-            System.out.println("Conectado!");
+            while (resultSet.next()) {
-        } catch (ClassNotFoundException cnfe) {
+                Book book = new Book();
-            System.out.println("No se ha podido cargar el driver de conexión. Verifique que los drivers están disponibles");
+                book.setTitle(resultSet.getString("title"));
-            cnfe.printStackTrace();
+                book.setAuthor(resultSet.getString("author"));
+                book.setPublisher(resultSet.getString("publisher"));
+                books.add(book);
+            }
         } catch (SQLException sqle) {
             System.out.println("No se ha podido conectar con el servidor de base de datos. Comprueba que los datos son correctos y que el servidor se ha iniciado");
@@ Line 21: / Line 110: @@
         }
-        return connection;
+        return books;
     }
-    public void close() {
+    public Book findByTitle(String title) {
+        String sql = "SELECT * FROM books WHERE title = ?";
+        Book book = null;
         try {
-            connection.close();
+            PreparedStatement statement = connection.prepareStatement(sql);
+            statement.setString(1, title);
+            ResultSet resultSet = statement.executeQuery();
+            if (resultSet.next()) {
+                book = new Book();
+                book.setTitle(resultSet.getString("title"));
+                book.setAuthor(resultSet.getString("author"));
+                book.setPublisher(resultSet.getString("publisher"));
+            }
         } catch (SQLException sqle) {
             System.out.println("No se ha podido conectar con el servidor de base de datos. Comprueba que los datos son correctos y que el servidor se ha iniciado");
             sqle.printStackTrace();
         }
+        return book;
     }
 }