-
Notifications
You must be signed in to change notification settings - Fork 438
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Task: jv-jdbc-intro. Executor: Oleksii Bashkirov. #355
Open
OleksiiBashkirov
wants to merge
1
commit into
mate-academy:main
Choose a base branch
from
OleksiiBashkirov:hw-1-solution
base: main
Could not load branches
Branch not found: {{ refName }}
Loading
Could not load tags
Nothing to show
Loading
Are you sure you want to change the base?
Some commits from the old base branch may be removed from the timeline,
and old review comments may become outdated.
Open
Changes from all commits
Commits
File filter
Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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); | ||
} | ||
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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); | ||
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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 -> { | ||||||||
Comment on lines
+77
to
+78
There was a problem hiding this comment. Choose a reason for hiding this commentThe reason will be displayed to describe this comment to others. Learn more.
Suggested change
|
||||||||
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
16
src/main/java/mate/academy/exception/DataProcessingException.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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); | ||
} | ||
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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 | ||
+ '}'; | ||
} | ||
} |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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
43
src/main/java/mate/academy/service/impl/BookServiceImpl.java
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
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); | ||
} | ||
} |
Oops, something went wrong.
Oops, something went wrong.
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
In such case, you can move Sqls to a separate file