Skip to content

Commit

Permalink
Created Book model.
Browse files Browse the repository at this point in the history
Created DAO layer for Book model with save, findById, findAll, update and deleteById methods. Also created helper methods executeUpdate and executeQuery to reduce code duplication.
And created two func.interfaces SqlConsumer and SqlFunction in the util package.
Created a service layer with CRUD methods.
Created custom exception.
Also connected to Database(book_storage).
Created new table (books) for this task.
Created init_db.sql file in src/main/resources folder and put the scripts for creating required table.
Used the @dao annotation on the BookDaoImpl class
Edited the Main class.
  • Loading branch information
OleksiiBashkirov committed May 22, 2024
1 parent bc1d800 commit 897b5ae
Show file tree
Hide file tree
Showing 12 changed files with 424 additions and 0 deletions.
9 changes: 9 additions & 0 deletions pom.xml
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,15 @@
</maven.checkstyle.plugin.configLocation>
</properties>

<dependencies>
<dependency>
<groupId>com.mysql</groupId>
<artifactId>mysql-connector-j</artifactId>
<version>8.3.0</version>
</dependency>

</dependencies>

<build>
<plugins>
<plugin>
Expand Down
48 changes: 48 additions & 0 deletions src/main/java/mate/academy/Main.java
Original file line number Diff line number Diff line change
@@ -1,7 +1,55 @@
package mate.academy;

import java.math.BigDecimal;
import java.util.List;
import java.util.Optional;
import mate.academy.dao.BookDao;
import mate.academy.lib.Injector;
import mate.academy.model.Book;
import mate.academy.service.BookService;
import mate.academy.service.impl.BookServiceImpl;

public class Main {
private static final String PACKAGE_NAME = "mate.academy";
private static final Injector injector = Injector.getInstance(PACKAGE_NAME);

public static void main(String[] args) {
var bookDao = (BookDao) injector.getInstance(BookDao.class);
var bookService = new BookServiceImpl(bookDao);
var newBook = saveNewBook(bookService);
getBookById(bookService, newBook);
updateBook(bookService, newBook);
getAllBooks(bookService);
deleteBook(bookService, newBook);
}

private static Book saveNewBook(BookService bookService) {
var newBook = new Book();
newBook.setTitle("New Book");
newBook.setPrice(BigDecimal.valueOf(30.99));
Book savedBook = bookService.save(newBook);
System.out.println("Saved book: " + savedBook);
return savedBook;
}

private static void getBookById(BookService bookService, Book savedBook) {
Optional<Book> bookById = bookService.get(savedBook.getId());
System.out.println("Book by id " + savedBook.getId() + " is: " + bookById.orElse(null));
}

private static void updateBook(BookService bookService, Book savedBook) {
savedBook.setTitle("New Book.Second Edition.");
savedBook.setPrice(BigDecimal.valueOf(35.99));
System.out.println("Updated book: " + bookService.update(savedBook));
}

private static void getAllBooks(BookService bookService) {
List<Book> allBooks = bookService.getAll();
allBooks.forEach(book -> System.out.println("Book: " + book));
}

private static void deleteBook(BookServiceImpl bookService, Book savedBook) {
boolean isDeleted = bookService.delete(savedBook.getId());
System.out.println("Deleted book with id " + savedBook.getId() + " : " + isDeleted);
}
}
18 changes: 18 additions & 0 deletions src/main/java/mate/academy/dao/BookDao.java
Original file line number Diff line number Diff line change
@@ -0,0 +1,18 @@
package mate.academy.dao;

import java.util.List;
import java.util.Optional;
import mate.academy.model.Book;

public interface BookDao {

Book save(Book book);

Optional<Book> findById(Long id);

List<Book> findAll();

Book update(Book book);

boolean deleteById(Long id);
}
131 changes: 131 additions & 0 deletions src/main/java/mate/academy/dao/impl/BookDaoImpl.java
Original file line number Diff line number Diff line change
@@ -0,0 +1,131 @@
package mate.academy.dao.impl;

import static java.sql.PreparedStatement.RETURN_GENERATED_KEYS;

import java.math.BigDecimal;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
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 mate.academy.util.SqlConsumer;
import mate.academy.util.SqlFunction;

@Dao
public class BookDaoImpl implements BookDao {
private static final String SAVE_SQL = """
INSERT INTO books (title, price)
VALUES(?, ?)
""";
private static final String UPDATE_SQL = """
UPDATE books
SET title = ?, price = ?
WHERE id = ?
""";
private static final String FIND_BY_ID_SQL = """
SELECT id, title, price
FROM books
WHERE id = ?
""";
private static final String FIND_ALL_SQL = """
SELECT id,
title,
price
FROM books
""";
private static final String DELETE_BY_ID_SQL = """
DELETE FROM books
WHERE id = ?
""";

@Override
public Book save(Book book) {
try (var connection = ConnectionUtil.getConnection();
var preparedStatement =
connection.prepareStatement(SAVE_SQL, RETURN_GENERATED_KEYS)) {
preparedStatement.setString(1, book.getTitle());
preparedStatement.setObject(2, book.getPrice());
preparedStatement.executeUpdate();
var generatedKeys = preparedStatement.getGeneratedKeys();
if (generatedKeys.next()) {
book.setId(generatedKeys.getLong(1));
}
return book;
} catch (SQLException e) {
throw new DataProcessingException("Cannot save book: " + book, e);
}
}

@Override
public Optional<Book> findById(Long id) {
return executeQuery(FIND_BY_ID_SQL, ps -> ps.setLong(1, id), rs -> {
if (rs.next()) {
return Optional.of(mapResultSetToBook(rs));
}
return Optional.empty();
});
}

@Override
public List<Book> findAll() {
return executeQuery(FIND_ALL_SQL, ps -> {
}, rs -> {
List<Book> bookList = new ArrayList<>();
while (rs.next()) {
bookList.add(mapResultSetToBook(rs));
}
return bookList;
});
}

@Override
public Book update(Book book) {
executeUpdate(UPDATE_SQL, ps -> {
ps.setString(1, book.getTitle());
ps.setObject(2, book.getPrice());
ps.setLong(3, book.getId());
});
return book;
}

@Override
public boolean deleteById(Long id) {
return executeUpdate(DELETE_BY_ID_SQL, ps -> ps.setLong(1, id));
}

private Book mapResultSetToBook(ResultSet resultSet) throws SQLException {
var book = new Book();
book.setId(resultSet.getLong("id"));
book.setTitle(resultSet.getString("title"));
book.setPrice(resultSet.getObject("price", BigDecimal.class));
return book;
}

private boolean executeUpdate(String sql, SqlConsumer<PreparedStatement> parameterSetter) {
try (var connection = ConnectionUtil.getConnection();
var preparedStatement = connection.prepareStatement(sql)) {
parameterSetter.accept(preparedStatement);
return preparedStatement.executeUpdate() > 0;
} catch (SQLException e) {
throw new DataProcessingException("Cannot execute update from SQL: " + sql, e);
}
}

private <T> T executeQuery(String sql, SqlConsumer<PreparedStatement> parameterSetter,
SqlFunction<ResultSet, T> resultMapper) {
try (var connection = ConnectionUtil.getConnection();
var preparedStatement = connection.prepareStatement(sql)) {
parameterSetter.accept(preparedStatement);
var resultSet = preparedStatement.executeQuery();
return resultMapper.apply(resultSet);
} catch (SQLException e) {
throw new DataProcessingException("Cannot execute query for SQL: " + sql, e);
}
}
}
16 changes: 16 additions & 0 deletions src/main/java/mate/academy/exception/DataProcessingException.java
Original file line number Diff line number Diff line change
@@ -0,0 +1,16 @@
package mate.academy.exception;

public class DataProcessingException extends RuntimeException {

public DataProcessingException() {
super();
}

public DataProcessingException(String message) {
super(message);
}

public DataProcessingException(String message, Throwable cause) {
super(message, cause);
}
}
62 changes: 62 additions & 0 deletions src/main/java/mate/academy/model/Book.java
Original file line number Diff line number Diff line change
@@ -0,0 +1,62 @@
package mate.academy.model;

import java.math.BigDecimal;
import java.util.Objects;

public class Book {
private long id;
private String title;
private BigDecimal price;

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 boolean equals(Object o) {
if (this == o) {
return true;
}
if (o == null || getClass() != o.getClass()) {
return false;
}
Book book = (Book) o;
return Objects.equals(id, book.id)
&& Objects.equals(title, book.title)
&& Objects.equals(price, book.price);
}

@Override
public int hashCode() {
return Objects.hash(id, title, price);
}

@Override
public String toString() {
return "Book{"
+ "id=" + id
+ ", title='" + title + '\''
+ ", price=" + price
+ '}';
}
}
18 changes: 18 additions & 0 deletions src/main/java/mate/academy/service/BookService.java
Original file line number Diff line number Diff line change
@@ -0,0 +1,18 @@
package mate.academy.service;

import java.util.List;
import java.util.Optional;
import mate.academy.model.Book;

public interface BookService {

Book save(Book book);

Optional<Book> get(Long id);

List<Book> getAll();

Book update(Book book);

boolean delete(Long id);
}
43 changes: 43 additions & 0 deletions src/main/java/mate/academy/service/impl/BookServiceImpl.java
Original file line number Diff line number Diff line change
@@ -0,0 +1,43 @@
package mate.academy.service.impl;

import java.util.List;
import java.util.Optional;
import mate.academy.dao.BookDao;
import mate.academy.exception.DataProcessingException;
import mate.academy.model.Book;
import mate.academy.service.BookService;

public class BookServiceImpl implements BookService {

private final BookDao bookDao;

public BookServiceImpl(BookDao bookDao) {
this.bookDao = bookDao;
}

@Override
public Book save(Book book) {
return bookDao.save(book);
}

@Override
public Optional<Book> get(Long id) {
return Optional.ofNullable(bookDao.findById(id)
.orElseThrow(() -> new DataProcessingException("Cannot find book by id: " + id)));
}

@Override
public List<Book> getAll() {
return bookDao.findAll();
}

@Override
public Book update(Book book) {
return bookDao.update(book);
}

@Override
public boolean delete(Long id) {
return bookDao.deleteById(id);
}
}
Loading

0 comments on commit 897b5ae

Please sign in to comment.