IP-jv-jdbc-intro-hw

pom.xml

@@ -13,5 +13,14 @@
         <maven.compiler.target>17</maven.compiler.target>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     </properties>
+    <dependencies>
+        <!-- https://mvnrepository.com/artifact/mysql/mysql-connector-java -->
+        <dependency>
+            <groupId>mysql</groupId>
+            <artifactId>mysql-connector-java</artifactId>
+            <version>8.0.33</version>
+        </dependency>
+
+    </dependencies>
 
 </project>

src/main/java/mate/academy/Main.java

@@ -1,7 +1,29 @@
 package mate.academy;
 
+import mate.academy.dao.BookDao;
+import mate.academy.lib.Injector;
+import mate.academy.model.Book;
+import java.math.BigDecimal;
+
 public class Main {
+    final static Injector injector = Injector.getInstance("mate");
     public static void main(String[] args) {
+        BookDao bookDao = (BookDao) injector.getInstance(BookDao.class);
+        Book book = new Book();
+        book.setTitle("The Witcher");
+        book.setPrice(BigDecimal.valueOf(12));
+
+        bookDao.create(book);
+
+        System.out.println(book);
+
+        book.setPrice(BigDecimal.valueOf(25));
+        System.out.println(bookDao.update(book));
+
+        System.out.println(bookDao.findById(book.getId()));
+
+        System.out.println(bookDao.findAll());
 
+        System.out.println(bookDao.deleteById(book.getId()));
     }
 }

src/main/java/mate/academy/dao/BookDao.java

@@ -0,0 +1,13 @@
+package mate.academy.dao;
+
+import mate.academy.model.Book;
+import java.util.List;
+import java.util.Optional;
+
+public interface BookDao {
+    Book create(Book book);
+    Optional<Book> findById(Long id);
+    List<Book> findAll();
+    Book update(Book book);
+    boolean deleteById(Long id);
+}

src/main/java/mate/academy/dao/impl/BookDaoImpl.java

@@ -0,0 +1,113 @@
+package mate.academy.dao.impl;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Optional;
+import mate.academy.dao.BookDao;
+import mate.academy.exception.DataProcessingException;
+import mate.academy.lib.Dao;
+import mate.academy.model.Book;
+import mate.academy.util.ConnectionUtil;
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+
+@Dao
+public class BookDaoImpl implements BookDao {
+    @Override
+    public Book create(Book book) {
+        String insertRequest
+                = "INSERT INTO books (title, price) VALUES (?, ?)";
+        try (Connection connection = ConnectionUtil.getConnection();
+             PreparedStatement createStatement = connection
+                     .prepareStatement(insertRequest, Statement.RETURN_GENERATED_KEYS)) {
+            createStatement.setString(1, book.getTitle());
+            createStatement.setBigDecimal(2, book.getPrice());
+            createStatement.executeUpdate();
+            ResultSet generatedKeys = createStatement.getGeneratedKeys();
+            if (generatedKeys.next()) {
+                Long id = generatedKeys.getObject(1, Long.class);
+                book.setId(id);
+            }
+        } catch (SQLException e) {
+            throw new DataProcessingException("Can't insert book data to DB. Book: " + book, e);
+        }
+        return book;
+    }
+
+    @Override
+    public Optional<Book> findById(Long id) {
+        String request = "SELECT id, title, price " +
+                "FROM books b " +
+                "WHERE b.id = ? AND b.is_deleted = FALSE;";
+        Book book = null;
+        try (Connection connection = ConnectionUtil.getConnection();
+             PreparedStatement getStatement = connection.prepareStatement(request)) {
+            getStatement.setLong(1, id);
+            ResultSet resultSet = getStatement
+                    .executeQuery();
+            if (resultSet.next()) {
+                book = parseBookFromResultSet(resultSet);
+            }
+        } catch (SQLException e) {
+            throw new RuntimeException("Can't get book from DB. Book Id: " + id, e);
+        }
+        return Optional.ofNullable(book);
+    }
+
+    @Override
+    public List<Book> findAll() {
+        String getAllRequest = "SELECT * FROM books b " +
+                "WHERE b.is_deleted = FALSE;";
+        List<Book> books = new ArrayList<>();
+        try (Connection connection = ConnectionUtil.getConnection();
+             PreparedStatement getAllStatement = connection.prepareStatement(getAllRequest)) {
+            ResultSet resultSet = getAllStatement.executeQuery();
+            while (resultSet.next()) {
+                books.add(parseBookFromResultSet(resultSet));
+            }
+        } catch (SQLException e) {
+            throw new RuntimeException("Can't get all books from DB.", e);
+        }
+        return books;
+    }
+
+    @Override
+    public Book update(Book book) {
+        String updateRequest = "UPDATE books SET title = ?, price = ? " +
+                "WHERE id = ? AND is_deleted = FALSE";
+        try (Connection connection = ConnectionUtil.getConnection();
+             PreparedStatement updateStatement = connection.prepareStatement(updateRequest)) {
+            updateStatement.setLong(3, book.getId());
+            updateStatement.setString(1, book.getTitle());
+            updateStatement.setBigDecimal(2, book.getPrice());
+            updateStatement.executeUpdate();
+        } catch (SQLException e) {
+            throw new DataProcessingException("Can't update book in DB. Book:  " + book,e);
+        }
+        return book;
+    }
+
+    @Override
+    public boolean deleteById(Long id) {
+        String deleteBookRequest = "UPDATE books SET is_deleted = TRUE WHERE id = ?";
+        try (Connection connection = ConnectionUtil.getConnection();
+             PreparedStatement deleteStatement = connection.prepareStatement(deleteBookRequest)) {
+            deleteStatement.setLong(1, id);
+            int numberOfDeletedRows = deleteStatement.executeUpdate();
+            return numberOfDeletedRows != 0;
+        } catch (SQLException e) {
+            throw new DataProcessingException("Can't delete book with id: " + id, e);
+        }
+    }
+
+    private Book parseBookFromResultSet(ResultSet resultSet) throws SQLException {
+        Book book = new Book();
+        book.setTitle(resultSet.getString("title"));
+        book.setPrice(resultSet.getBigDecimal("price"));
+        book.setId(resultSet.getObject("id", Long.class));
+        return book;
+    }
+}

src/main/java/mate/academy/exception/DataProcessingException.java

@@ -0,0 +1,7 @@
+package mate.academy.exception;
+
+public class DataProcessingException extends RuntimeException {
+    public DataProcessingException(String message, Throwable cause) {
+        super(message, cause);
+    }
+}

src/main/java/mate/academy/model/Book.java

@@ -0,0 +1,45 @@
+package mate.academy.model;
+
+import java.math.BigDecimal;
+
+public class Book {
+    private Long id;
+    private String title;
+    private BigDecimal price;
+
+    public Book() {
+    }
+
+    public Long getId() {
+        return id;
+    }
+
+    public void setId(Long id) {
+        this.id = id;
+    }
+
+    public String getTitle() {
+        return title;
+    }
+
+    public void setTitle(String title) {
+        this.title = title;
+    }
+
+    public BigDecimal getPrice() {
+        return price;
+    }
+
+    public void setPrice(BigDecimal price) {
+        this.price = price;
+    }
+
+    @Override
+    public String toString() {
+        return "Book{" +
+                "id=" + id +
+                ", title='" + title + '\'' +
+                ", price=" + price +
+                '}';
+    }
+}

src/main/java/mate/academy/util/ConnectionUtil.java

@@ -0,0 +1,27 @@
+package mate.academy.util;
+
+import java.sql.Connection;
+import java.sql.DriverManager;
+import java.sql.SQLException;
+import java.util.Properties;
+
+public class ConnectionUtil {
+    static {
+        try {
+            Class.forName("com.mysql.cj.jdbc.Driver");
+        } catch (ClassNotFoundException e) {
+            throw new RuntimeException("Can't get Driver", e);
+        }
+    }
+    public static Connection getConnection() {
+        Connection connection;
+        try {
+            Properties dbProperties = new Properties();
+            dbProperties.put("user" , "root");
+            dbProperties.put("password", "JDBC1901MySQL");
+            return DriverManager.getConnection("jdbc:mysql://localhost:3306/library_db", dbProperties);
+        } catch (SQLException e) {
+            throw new RuntimeException("Can't create connection to DB", e);
+        }
+    }
+}

src/main/java/resources/init_db.sql

@@ -0,0 +1,7 @@
+CREATE DATABASE `library_db` /*!40100 DEFAULT CHARACTER SET utf8mb3 */ /*!80016 DEFAULT ENCRYPTION='N' */;
+CREATE TABLE `literary_formats` (
+                                    `format` varchar(255) DEFAULT NULL,
+                                    `id` bigint NOT NULL AUTO_INCREMENT,
+                                    `is_deleted` tinyint NOT NULL DEFAULT '0',
+                                    PRIMARY KEY (`id`)
+) ENGINE=InnoDB AUTO_INCREMENT=18 DEFAULT CHARSET=utf8mb3;