Convert all endpoints to Oracle (untested)

Author: DylanW01

src/main/java/Book.java

@@ -1,70 +1,40 @@
-import Objects.Book;
-import EJB.BookBean;
+import Objects.bookModel;
 import com.google.gson.Gson;
-import com.mongodb.client.FindIterable;
-import com.mongodb.client.MongoCursor;
+import EJB.BookOracleBean;
 import jakarta.ejb.EJB;
 import jakarta.servlet.ServletException;
 import jakarta.servlet.annotation.WebServlet;
 import jakarta.servlet.http.HttpServlet;
 import jakarta.servlet.http.HttpServletRequest;
 import jakarta.servlet.http.HttpServletResponse;
-import org.bson.Document;
-import org.bson.types.ObjectId;
 
 import java.io.IOException;
 import java.io.PrintWriter;
 import java.util.ArrayList;
-import java.util.Date;
-import java.util.List;
 
 
 @WebServlet(name = "Books", value = "/books")
 public class Books extends HttpServlet {
     @EJB
-    BookBean bookBean;
+    BookOracleBean bookBean;
 
     @Override
     protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
         response.setContentType("application/json");
 
         PrintWriter out = response.getWriter();
-        FindIterable<Document> foundBooks = bookBean.getBooks();
-        MongoCursor<Document> cursor = foundBooks.iterator();
+        ArrayList<bookModel> result = bookBean.getBooks();
 
-        List<Book> books = new ArrayList<Book>();
+        // Convert the list of documents to a JSON array
+        Gson gson = new Gson();
+        String jsonArray = gson.toJson(result);
 
-        try {
-            while (cursor.hasNext()) {
-                Document doc = cursor.next();
-
-                Book book = new Book(
-                        doc.get("_id").toString(),
-                        doc.get("Title").toString(),
-                        doc.get("Author").toString(),
-                        doc.get("ISBN").toString(),
-                        (Integer) doc.get("Pages"),
-                        (Date) doc.get("Added"),
-                        (Boolean) doc.get("OnLoan"));
-
-                books.add(book);
-            }
-        } finally {
-            cursor.close();
-        }
-
-        String booksJsonString = new Gson().toJson(books);
-        out.print(booksJsonString);
+        out.print(jsonArray);
         out.flush();
     }
 
     @Override
     protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
 
-    }
-
-    public void createCustomer(Document customer) {
-
-
     }
 }

src/main/java/Books.java

@@ -1,30 +1,97 @@
 package EJB;
 
-import Objects.loanModel;
+import Objects.bookModel;
 import jakarta.ejb.EJB;
 import jakarta.ejb.Stateless;
 
 import java.sql.*;
 import java.util.ArrayList;
-import java.util.Calendar;
-import java.util.Date;
 
 @Stateless(name = "BookOracleEJB")
 public class BookOracleBean {
     @EJB
     OracleClientProviderBean oracleClientProviderBean;
 
-    public void markAsBorrowed(int bookId) {
-    Connection con = oracleClientProviderBean.getOracleClient();
-    String insertLoan = "UPDATE books SET on_loan = 1 WHERE book_id = ?";
-
-    try (PreparedStatement preparedStatement = con.prepareStatement(insertLoan)) {
-        preparedStatement.setInt(1, bookId);
-        preparedStatement.executeUpdate();
-    } catch (SQLException e) {
-        // Handle any potential exceptions here
-        e.printStackTrace();
+    public ArrayList<bookModel> getBooks() {
+        String query = "SELECT b.BOOK_ID BOOK_ID," +
+                "b.TITLE TITLE," +
+                "b.ISBN ISBN," +
+                "b.PAGES PAGES," +
+                "b.CREATED CREATED," +
+                "b.ON_LOAN ON_LOAN," +
+                "a.FIRST_NAME AUTHOR_FIRST_NAME," +
+                "a.LAST_NAME AUTHOR_LAST_NAME FROM books b " +
+                "INNER JOIN authors a ON b.author_id = a.author_id";
+        ArrayList books_list = new ArrayList();
+        Statement stmt = null;
+
+        try {
+            Connection con = oracleClientProviderBean.getOracleClient();
+            stmt = con.createStatement();
+            ResultSet rs = stmt.executeQuery(query);
+
+            while (rs.next()) {
+                bookModel book = new bookModel();
+                book.setBookId(rs.getLong("BOOK_ID"));
+                book.setOnLoan(rs.getBoolean("ON_LOAN"));
+                book.setBookTitle(rs.getString("TITLE"));
+                book.setBookIsbn(rs.getLong("ISBN"));
+                book.setBookPages(rs.getInt("PAGES"));
+                book.setCreated(rs.getDate("CREATED"));
+                book.setAuthorFirstName(rs.getString("AUTHOR_FIRST_NAME"));
+                book.setAuthorLastName(rs.getString("AUTHOR_LAST_NAME"));
+                books_list.add(book);
+            }
+
+            stmt.close();
+            return books_list;
+        } catch(SQLException e) {
+            e.printStackTrace();
+        }
+
+        return null;
     }
+
+    public ArrayList<bookModel> getAvailableBooks() {
+        String query = "SELECT b.BOOK_ID BOOK_ID," +
+                "b.TITLE TITLE," +
+                "b.ISBN ISBN," +
+                "b.PAGES PAGES," +
+                "b.CREATED CREATED," +
+                "b.ON_LOAN ON_LOAN," +
+                "a.FIRST_NAME AUTHOR_FIRST_NAME," +
+                "a.LAST_NAME AUTHOR_LAST_NAME FROM books b " +
+                "INNER JOIN authors a ON b.author_id = a.author_id " +
+                "WHERE b.ON_LOAN = 0";
+
+        ArrayList books_list = new ArrayList();
+        Statement stmt = null;
+
+        try {
+            Connection con = oracleClientProviderBean.getOracleClient();
+            stmt = con.createStatement();
+            ResultSet rs = stmt.executeQuery(query);
+
+            while (rs.next()) {
+                bookModel book = new bookModel();
+                book.setBookId(rs.getLong("BOOK_ID"));
+                book.setOnLoan(rs.getBoolean("ON_LOAN"));
+                book.setBookTitle(rs.getString("TITLE"));
+                book.setBookIsbn(rs.getLong("ISBN"));
+                book.setBookPages(rs.getInt("PAGES"));
+                book.setCreated(rs.getDate("CREATED"));
+                book.setAuthorFirstName(rs.getString("AUTHOR_FIRST_NAME"));
+                book.setAuthorLastName(rs.getString("AUTHOR_LAST_NAME"));
+                books_list.add(book);
+            }
+
+            stmt.close();
+            return books_list;
+        } catch(SQLException e) {
+            e.printStackTrace();
+        }
+
+        return null;
     }
 
     public void markAsReturned(int bookId) {
@@ -39,4 +106,17 @@ public void markAsReturned(int bookId) {
             e.printStackTrace();
         }
     }
+
+    public void markAsBorrowed(int bookId) {
+        Connection con = oracleClientProviderBean.getOracleClient();
+        String insertLoan = "UPDATE books SET on_loan = 1 WHERE book_id = ?";
+
+        try (PreparedStatement preparedStatement = con.prepareStatement(insertLoan)) {
+            preparedStatement.setInt(1, bookId);
+            preparedStatement.executeUpdate();
+        } catch (SQLException e) {
+            // Handle any potential exceptions here
+            e.printStackTrace();
+        }
+    }
 }