Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
699c044800 | ||
|
|
e6e6967017 | ||
|
|
09f468d9dd | ||
|
|
922d7afd74 |
Generated
+10
@@ -0,0 +1,10 @@
|
|||||||
|
# Default ignored files
|
||||||
|
/shelf/
|
||||||
|
/workspace.xml
|
||||||
|
# Ignored default folder with query files
|
||||||
|
/queries/
|
||||||
|
# Datasource local storage ignored files
|
||||||
|
/dataSources/
|
||||||
|
/dataSources.local.xml
|
||||||
|
# Editor-based HTTP Client requests
|
||||||
|
/httpRequests/
|
||||||
Generated
+13
@@ -0,0 +1,13 @@
|
|||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<project version="4">
|
||||||
|
<component name="CompilerConfiguration">
|
||||||
|
<annotationProcessing>
|
||||||
|
<profile name="Maven default annotation processors profile" enabled="true">
|
||||||
|
<sourceOutputDir name="target/generated-sources/annotations" />
|
||||||
|
<sourceTestOutputDir name="target/generated-test-sources/test-annotations" />
|
||||||
|
<outputRelativeToContentRoot value="true" />
|
||||||
|
<module name="WS-10-Database" />
|
||||||
|
</profile>
|
||||||
|
</annotationProcessing>
|
||||||
|
</component>
|
||||||
|
</project>
|
||||||
Generated
+12
@@ -0,0 +1,12 @@
|
|||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<project version="4">
|
||||||
|
<component name="DataSourceManagerImpl" format="xml" multifile-model="true">
|
||||||
|
<data-source source="LOCAL" name="postgres@localhost" uuid="7eaa055b-aec6-4a3e-a6f8-6ca90a4ee622">
|
||||||
|
<driver-ref>postgresql</driver-ref>
|
||||||
|
<synchronize>true</synchronize>
|
||||||
|
<jdbc-driver>org.postgresql.Driver</jdbc-driver>
|
||||||
|
<jdbc-url>jdbc:postgresql://localhost:5432/postgres</jdbc-url>
|
||||||
|
<working-dir>$ProjectFileDir$</working-dir>
|
||||||
|
</data-source>
|
||||||
|
</component>
|
||||||
|
</project>
|
||||||
Generated
+7
@@ -0,0 +1,7 @@
|
|||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<project version="4">
|
||||||
|
<component name="Encoding">
|
||||||
|
<file url="file://$PROJECT_DIR$/src/main/java" charset="UTF-8" />
|
||||||
|
<file url="file://$PROJECT_DIR$/src/main/resources" charset="UTF-8" />
|
||||||
|
</component>
|
||||||
|
</project>
|
||||||
Generated
+20
@@ -0,0 +1,20 @@
|
|||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<project version="4">
|
||||||
|
<component name="RemoteRepositoriesConfiguration">
|
||||||
|
<remote-repository>
|
||||||
|
<option name="id" value="central" />
|
||||||
|
<option name="name" value="Maven Central repository" />
|
||||||
|
<option name="url" value="https://repo1.maven.org/maven2" />
|
||||||
|
</remote-repository>
|
||||||
|
<remote-repository>
|
||||||
|
<option name="id" value="jboss.community" />
|
||||||
|
<option name="name" value="JBoss Community repository" />
|
||||||
|
<option name="url" value="https://repository.jboss.org/nexus/content/repositories/public/" />
|
||||||
|
</remote-repository>
|
||||||
|
<remote-repository>
|
||||||
|
<option name="id" value="central" />
|
||||||
|
<option name="name" value="Central Repository" />
|
||||||
|
<option name="url" value="https://maven.myket.ir" />
|
||||||
|
</remote-repository>
|
||||||
|
</component>
|
||||||
|
</project>
|
||||||
Generated
+12
@@ -0,0 +1,12 @@
|
|||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<project version="4">
|
||||||
|
<component name="ExternalStorageConfigurationManager" enabled="true" />
|
||||||
|
<component name="MavenProjectsManager">
|
||||||
|
<option name="originalFiles">
|
||||||
|
<list>
|
||||||
|
<option value="$PROJECT_DIR$/pom.xml" />
|
||||||
|
</list>
|
||||||
|
</option>
|
||||||
|
</component>
|
||||||
|
<component name="ProjectRootManager" version="2" languageLevel="JDK_25" default="true" project-jdk-name="25" project-jdk-type="JavaSDK" />
|
||||||
|
</project>
|
||||||
Generated
+6
@@ -0,0 +1,6 @@
|
|||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<project version="4">
|
||||||
|
<component name="SqlDialectMappings">
|
||||||
|
<file url="file://$PROJECT_DIR$/database.sql" dialect="GenericSQL" />
|
||||||
|
</component>
|
||||||
|
</project>
|
||||||
Generated
+7
@@ -0,0 +1,7 @@
|
|||||||
|
<?xml version="1.0" encoding="UTF-8"?>
|
||||||
|
<project version="4">
|
||||||
|
<component name="VcsDirectoryMappings">
|
||||||
|
<mapping directory="" vcs="Git" />
|
||||||
|
<mapping directory="$PROJECT_DIR$" vcs="Git" />
|
||||||
|
</component>
|
||||||
|
</project>
|
||||||
+64
-125
@@ -1,141 +1,80 @@
|
|||||||
-- Restaurant Database Management System
|
|
||||||
--
|
|
||||||
-- Instructions:
|
|
||||||
-- 1. Create all required tables.
|
|
||||||
-- 2. Design appropriate PRIMARY KEY and FOREIGN KEY relationships.
|
|
||||||
-- 3. Add suitable constraints based on the requirements.
|
|
||||||
-- 4. Insert initial mock data.
|
|
||||||
-- 5. Insert at least 3 menu items.
|
|
||||||
-- 6. The script should be executable from start to finish without errors.
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
-- =======================================================
|
|
||||||
-- USER TABLE
|
-- USER TABLE
|
||||||
-- =======================================================
|
CREATE TABLE users (
|
||||||
--
|
id SERIAL PRIMARY KEY,
|
||||||
-- Represents customers using the system.
|
username VARCHAR(50) UNIQUE NOT NULL,
|
||||||
--
|
password VARCHAR(255) NOT NULL,
|
||||||
-- Required information:
|
email VARCHAR(100)
|
||||||
-- - Unique identifier
|
);
|
||||||
-- - Username
|
|
||||||
-- - Password
|
|
||||||
-- - Email (optional)
|
|
||||||
--
|
|
||||||
-- Requirements:
|
|
||||||
-- - Each user must have a unique identifier.
|
|
||||||
-- - Usernames must be unique.
|
|
||||||
-- - Username and password are required.
|
|
||||||
-- - Passwords should not be stored in plain text.
|
|
||||||
--
|
|
||||||
-- CREATE TABLE ...
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
-- =======================================================
|
|
||||||
-- MENU ITEM TABLE
|
-- MENU ITEM TABLE
|
||||||
-- =======================================================
|
CREATE TABLE menu_items (
|
||||||
--
|
id SERIAL PRIMARY KEY,
|
||||||
-- Represents available food and drink items.
|
name VARCHAR(100) NOT NULL,
|
||||||
--
|
description TEXT,
|
||||||
-- Required information:
|
price DECIMAL(10,2) NOT NULL CHECK (price > 0),
|
||||||
-- - Unique identifier
|
category VARCHAR(50)
|
||||||
-- - Name
|
);
|
||||||
-- - Description (optional)
|
|
||||||
-- - Price
|
|
||||||
-- - Category (optional)
|
|
||||||
--
|
|
||||||
-- Requirements:
|
|
||||||
-- - Each menu item must have a unique identifier.
|
|
||||||
-- - Name is required.
|
|
||||||
-- - Price must always be positive.
|
|
||||||
--
|
|
||||||
-- CREATE TABLE ...
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
-- =======================================================
|
|
||||||
-- ORDER TABLE
|
-- ORDER TABLE
|
||||||
-- =======================================================
|
CREATE TABLE orders (
|
||||||
--
|
id SERIAL PRIMARY KEY,
|
||||||
-- Represents orders placed by customers.
|
user_id INT NOT NULL,
|
||||||
--
|
created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
|
||||||
-- Required information:
|
total_price DECIMAL(10, 2) NOT NULL DEFAULT 0.00,
|
||||||
-- - Unique identifier
|
CONSTRAINT fk_user_order FOREIGN KEY (user_id) REFERENCES users(id) ON DELETE CASCADE
|
||||||
-- - Reference to customer
|
);
|
||||||
-- - Creation date and time
|
|
||||||
-- - Total price
|
|
||||||
--
|
|
||||||
-- Requirements:
|
|
||||||
-- - Each order must belong to exactly one user.
|
|
||||||
-- - A user can have multiple orders.
|
|
||||||
-- - The relationship between User and Order must be implemented.
|
|
||||||
--
|
|
||||||
-- Note:
|
|
||||||
-- Avoid using reserved SQL keywords as table names.
|
|
||||||
-- Consider using a name such as "orders" or "customer_orders".
|
|
||||||
--
|
|
||||||
-- CREATE TABLE ...
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
-- =======================================================
|
|
||||||
-- ORDER DETAIL TABLE
|
-- ORDER DETAIL TABLE
|
||||||
-- =======================================================
|
CREATE TABLE order_details (
|
||||||
--
|
id SERIAL PRIMARY KEY,
|
||||||
-- Represents items inside an order.
|
order_id INT NOT NULL,
|
||||||
--
|
menu_item_id INT NOT NULL,
|
||||||
-- Required information:
|
quantity INT NOT NULL CHECK (quantity>0),
|
||||||
-- - Unique identifier
|
price_at_purchase DECIMAL(10,2) NOT NULL,
|
||||||
-- - Reference to an order
|
CONSTRAINT fk_detail_order FOREIGN KEY (order_id) REFERENCES orders(id) ON DELETE CASCADE,
|
||||||
-- - Reference to a menu item
|
CONSTRAINT fk_detail_menu FOREIGN KEY (menu_item_id) REFERENCES menu_items(id)
|
||||||
-- - Quantity
|
)
|
||||||
-- - Item price at purchase time
|
|
||||||
--
|
|
||||||
-- Requirements:
|
|
||||||
-- - Each detail record must belong to one order.
|
|
||||||
-- - Each detail record must reference one menu item.
|
|
||||||
-- - Quantity must always be greater than zero.
|
|
||||||
-- - Store the item's price at the moment of purchase.
|
|
||||||
--
|
|
||||||
-- CREATE TABLE ...
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
-- =======================================================
|
|
||||||
-- INITIAL MENU DATA
|
-- INITIAL MENU DATA
|
||||||
-- =======================================================
|
INSERT INTO menu_items (name, description, price, category) VALUES
|
||||||
--
|
('Cheeseburger', 'Juicy beef patty with cheddar cheese', 8.99, 'Food'),
|
||||||
-- Insert at least 3 food or drink items.
|
('Pepperoni Pizza', 'Classic pizza with pepperoni and mozzarella', 12.50, 'Food'),
|
||||||
--
|
('Iced Latte', 'Espresso with cold milk and ice', 4.25, 'Drink');
|
||||||
-- Example categories:
|
|
||||||
-- - Pizza
|
|
||||||
-- - Burger
|
|
||||||
-- - Pasta
|
|
||||||
-- - Drink
|
|
||||||
--
|
|
||||||
-- INSERT INTO ...
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
-- =======================================================
|
|
||||||
-- OPTIONAL TEST DATA
|
-- OPTIONAL TEST DATA
|
||||||
-- =======================================================
|
INSERT INTO users (username, password, email) VALUES
|
||||||
--
|
('mardin_dev', 'hashed_pass_123', 'mardin@example.com'),
|
||||||
-- You may insert sample users and orders for testing.
|
('sara_kh', 'hashed_pass_456', 'sara@example.com');
|
||||||
-- This section is optional.
|
|
||||||
--
|
INSERT INTO orders (user_id, total_price) VALUES
|
||||||
-- INSERT INTO ...
|
(1, 21.49),
|
||||||
|
(2, 4.25);
|
||||||
|
|
||||||
|
INSERT INTO order_details (order_id, menu_item_id, quantity, price_at_purchase) VALUES
|
||||||
|
(1, 1, 1, 8.99),
|
||||||
|
(1, 2, 1, 12.50);
|
||||||
|
|
||||||
|
INSERT INTO order_details (order_id, menu_item_id, quantity, price_at_purchase) VALUES
|
||||||
|
(2, 3, 1, 4.25);
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
-- =======================================================
|
|
||||||
-- VERIFICATION QUERIES
|
-- VERIFICATION QUERIES
|
||||||
-- =======================================================
|
SELECT * FROM users;
|
||||||
--
|
SELECT * FROM menu_items;
|
||||||
-- Uncomment these queries to verify your database.
|
SELECT * FROM orders;
|
||||||
--
|
SELECT * FROM order_details;
|
||||||
-- SELECT * FROM ...;
|
|
||||||
-- SELECT * FROM ...;
|
SELECT
|
||||||
-- SELECT * FROM ...;
|
o.id AS order_number,
|
||||||
-- SELECT * FROM ...;
|
u.username AS customer,
|
||||||
|
m.name AS food_item,
|
||||||
|
od.quantity,
|
||||||
|
od.price_at_purchase,
|
||||||
|
(od.quantity * od.price_at_purchase) AS subtotal,
|
||||||
|
o.created_at
|
||||||
|
FROM orders o
|
||||||
|
JOIN users u ON o.user_id = u.id
|
||||||
|
JOIN order_details od ON od.order_id = o.id
|
||||||
|
JOIN menu_items m ON od.menu_item_id = m.id;
|
||||||
@@ -1,23 +1,60 @@
|
|||||||
package dev.dao;
|
package dev.dao;
|
||||||
|
|
||||||
|
import dev.database.DatabaseConnection;
|
||||||
import dev.model.MenuItem;
|
import dev.model.MenuItem;
|
||||||
|
|
||||||
|
import java.sql.*;
|
||||||
|
import java.util.ArrayList;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
|
||||||
public class MenuItemDao {
|
public class MenuItemDao {
|
||||||
|
|
||||||
public List<MenuItem> findAll() {
|
public List<MenuItem> findAll() {
|
||||||
|
List<MenuItem> items = new ArrayList<>();
|
||||||
|
String sql = "select * FROM menu_item";
|
||||||
|
|
||||||
// TODO:
|
try (Connection connection = DatabaseConnection.getConnection();
|
||||||
// Retrieve all menu items
|
Statement statement = connection.createStatement();
|
||||||
|
ResultSet resultSet = statement.executeQuery(sql)
|
||||||
|
) {
|
||||||
|
while (resultSet.next()) {
|
||||||
|
MenuItem item = new MenuItem(
|
||||||
|
resultSet.getInt("id"),
|
||||||
|
resultSet.getString("name"),
|
||||||
|
resultSet.getString("description"),
|
||||||
|
resultSet.getDouble("price"),
|
||||||
|
resultSet.getString("category")
|
||||||
|
);
|
||||||
|
items.add(item);
|
||||||
|
}
|
||||||
|
} catch (SQLException e) {
|
||||||
|
System.err.println("Error fetching menu items: " + e.getMessage());
|
||||||
|
}
|
||||||
|
|
||||||
return null;
|
return items;
|
||||||
}
|
}
|
||||||
|
|
||||||
public MenuItem findById(int id) {
|
public MenuItem findById(int id) {
|
||||||
|
String sql = "SELECT * FROM menu_items WHERE id = ?";
|
||||||
|
|
||||||
// TODO:
|
try (Connection conn = DatabaseConnection.getConnection();
|
||||||
// Find menu item by id
|
PreparedStatement pstmt = conn.prepareStatement(sql)) {
|
||||||
|
|
||||||
|
pstmt.setInt(1, id);
|
||||||
|
try (ResultSet rs = pstmt.executeQuery()) {
|
||||||
|
if (rs.next()) {
|
||||||
|
return new MenuItem(
|
||||||
|
rs.getInt("id"),
|
||||||
|
rs.getString("name"),
|
||||||
|
rs.getString("description"),
|
||||||
|
rs.getDouble("price"),
|
||||||
|
rs.getString("category")
|
||||||
|
);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
} catch (SQLException e) {
|
||||||
|
System.err.println("Error finding menu item: " + e.getMessage());
|
||||||
|
}
|
||||||
|
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,25 +1,61 @@
|
|||||||
package dev.dao;
|
package dev.dao;
|
||||||
|
|
||||||
|
import dev.database.DatabaseConnection;
|
||||||
import dev.model.Order;
|
import dev.model.Order;
|
||||||
|
|
||||||
|
import java.sql.*;
|
||||||
|
import java.util.ArrayList;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
|
||||||
public class OrderDao {
|
public class OrderDao {
|
||||||
|
|
||||||
public int save(Order order) {
|
public int save(Order order) {
|
||||||
|
|
||||||
// TODO:
|
String sql = "INSERT INTO orders (user_id, total_price) VALUES (?, ?)";
|
||||||
// Insert order and return generated id
|
|
||||||
|
|
||||||
|
try (Connection conn = DatabaseConnection.getConnection();
|
||||||
|
PreparedStatement pstmt = conn.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS)) {
|
||||||
|
|
||||||
|
pstmt.setInt(1, order.getUserId());
|
||||||
|
pstmt.setDouble(2, order.getTotalPrice());
|
||||||
|
pstmt.executeUpdate();
|
||||||
|
|
||||||
|
//Generated ID
|
||||||
|
try (ResultSet rs = pstmt.getGeneratedKeys()) {
|
||||||
|
if (rs.next()) {
|
||||||
|
return rs.getInt(1);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
} catch (SQLException e) {
|
||||||
|
System.err.println("Error saving order: " + e.getMessage());
|
||||||
|
}
|
||||||
return -1;
|
return -1;
|
||||||
}
|
}
|
||||||
|
|
||||||
public List<Order> findByUserId(int userId) {
|
public List<Order> findByUserId(int userId) {
|
||||||
|
List<Order> orders = new ArrayList<>();
|
||||||
|
String sql = "SELECT * FROM orders WHERE user_id = ? ORDER BY created_at DESC";
|
||||||
|
|
||||||
// TODO:
|
try (Connection conn = DatabaseConnection.getConnection();
|
||||||
// Retrieve all orders of a user
|
PreparedStatement pstmt = conn.prepareStatement(sql)) {
|
||||||
|
|
||||||
return null;
|
pstmt.setInt(1, userId);
|
||||||
|
|
||||||
|
try (ResultSet rs = pstmt.executeQuery()) {
|
||||||
|
while (rs.next()) {
|
||||||
|
Order order = new Order(
|
||||||
|
rs.getInt("id"),
|
||||||
|
rs.getInt("user_id"),
|
||||||
|
rs.getTimestamp("created_at"),
|
||||||
|
rs.getDouble("total_price")
|
||||||
|
);
|
||||||
|
orders.add(order);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
} catch (SQLException e) {
|
||||||
|
System.err.println("Error retrieving orders for user: " + e.getMessage());
|
||||||
|
}
|
||||||
|
return orders;
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
@@ -1,24 +1,62 @@
|
|||||||
package dev.dao;
|
package dev.dao;
|
||||||
|
|
||||||
|
import dev.database.DatabaseConnection;
|
||||||
import dev.model.OrderDetail;
|
import dev.model.OrderDetail;
|
||||||
|
|
||||||
|
import java.sql.Connection;
|
||||||
|
import java.sql.PreparedStatement;
|
||||||
|
import java.sql.ResultSet;
|
||||||
|
import java.sql.SQLException;
|
||||||
|
import java.util.ArrayList;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
|
|
||||||
public class OrderDetailDao {
|
public class OrderDetailDao {
|
||||||
|
|
||||||
public void save(OrderDetail detail) {
|
public void save(OrderDetail detail) {
|
||||||
|
|
||||||
// TODO:
|
String sql = "INSERT INTO order_details (order_id, menu_item_id, quantity, price_at_purchase) VALUES (?, ?, ?, ?)";
|
||||||
// Insert order detail
|
|
||||||
|
|
||||||
|
try (Connection conn = DatabaseConnection.getConnection();
|
||||||
|
PreparedStatement pstmt = conn.prepareStatement(sql)) {
|
||||||
|
|
||||||
|
pstmt.setInt(1, detail.getOrderId());
|
||||||
|
pstmt.setInt(2, detail.getMenuItemId());
|
||||||
|
pstmt.setInt(3, detail.getQuantity());
|
||||||
|
pstmt.setDouble(4, detail.getPriceAtPurchase());
|
||||||
|
|
||||||
|
pstmt.executeUpdate();
|
||||||
|
|
||||||
|
} catch (SQLException e) {
|
||||||
|
System.err.println("Error saving order detail: " + e.getMessage());
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public List<OrderDetail> findByOrderId(int orderId) {
|
public List<OrderDetail> findByOrderId(int orderId) {
|
||||||
|
|
||||||
// TODO:
|
List<OrderDetail> details = new ArrayList<>();
|
||||||
// Retrieve order details
|
String sql = "SELECT * FROM order_details WHERE order_id = ?";
|
||||||
|
|
||||||
return null;
|
try (Connection conn = DatabaseConnection.getConnection();
|
||||||
|
PreparedStatement pstmt = conn.prepareStatement(sql)) {
|
||||||
|
|
||||||
|
pstmt.setInt(1, orderId);
|
||||||
|
|
||||||
|
try (ResultSet rs = pstmt.executeQuery()) {
|
||||||
|
while (rs.next()) {
|
||||||
|
OrderDetail detail = new OrderDetail(
|
||||||
|
rs.getInt("id"),
|
||||||
|
rs.getInt("order_id"),
|
||||||
|
rs.getInt("menu_item_id"),
|
||||||
|
rs.getInt("quantity"),
|
||||||
|
rs.getDouble("price_at_purchase")
|
||||||
|
);
|
||||||
|
details.add(detail);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
} catch (SQLException e) {
|
||||||
|
System.err.println("Error retrieving order details: " + e.getMessage());
|
||||||
|
}
|
||||||
|
return details;
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
@@ -1,22 +1,59 @@
|
|||||||
package dev.dao;
|
package dev.dao;
|
||||||
|
|
||||||
|
import dev.database.DatabaseConnection;
|
||||||
import dev.model.User;
|
import dev.model.User;
|
||||||
|
|
||||||
|
import java.sql.*;
|
||||||
|
|
||||||
public class UserDao {
|
public class UserDao {
|
||||||
|
|
||||||
public boolean save(User user) {
|
public boolean save(User user) {
|
||||||
|
|
||||||
// TODO:
|
String sql = "INSERT INTO users (username, password, email) VALUES (?, ?, ?)";
|
||||||
// Insert user into database
|
|
||||||
|
|
||||||
|
try (Connection conn = DatabaseConnection.getConnection();
|
||||||
|
PreparedStatement pstmt = conn.prepareStatement(sql)) {
|
||||||
|
|
||||||
|
pstmt.setString(1, user.getUsername());
|
||||||
|
pstmt.setString(2, user.getPassword());
|
||||||
|
|
||||||
|
if (user.getEmail() == null || user.getEmail().trim().isEmpty()) {
|
||||||
|
pstmt.setNull(3, Types.VARCHAR);
|
||||||
|
} else {
|
||||||
|
pstmt.setString(3, user.getEmail());
|
||||||
|
}
|
||||||
|
|
||||||
|
int rowsAffected = pstmt.executeUpdate();
|
||||||
|
return rowsAffected > 0;
|
||||||
|
|
||||||
|
} catch (SQLException e) {
|
||||||
|
System.err.println("Error saving user: " + e.getMessage());
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
public User findByUsername(String username) {
|
public User findByUsername(String username) {
|
||||||
|
|
||||||
// TODO:
|
String sql = "SELECT * FROM users WHERE username = ?";
|
||||||
// Find a user by username
|
|
||||||
|
|
||||||
|
try (Connection conn = DatabaseConnection.getConnection();
|
||||||
|
PreparedStatement pstmt = conn.prepareStatement(sql)) {
|
||||||
|
|
||||||
|
pstmt.setString(1, username);
|
||||||
|
|
||||||
|
try (ResultSet rs = pstmt.executeQuery()) {
|
||||||
|
if (rs.next()) {
|
||||||
|
return new User(
|
||||||
|
rs.getInt("id"),
|
||||||
|
rs.getString("username"),
|
||||||
|
rs.getString("password"),
|
||||||
|
rs.getString("email")
|
||||||
|
);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
} catch (SQLException e) {
|
||||||
|
System.err.println("Error finding user by username: " + e.getMessage());
|
||||||
|
}
|
||||||
return null;
|
return null;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -1,6 +1,7 @@
|
|||||||
package dev.database;
|
package dev.database;
|
||||||
|
|
||||||
import java.sql.Connection;
|
import java.sql.Connection;
|
||||||
|
import java.sql.DriverManager;
|
||||||
import java.sql.SQLException;
|
import java.sql.SQLException;
|
||||||
|
|
||||||
public class DatabaseConnection {
|
public class DatabaseConnection {
|
||||||
@@ -17,11 +18,7 @@ public class DatabaseConnection {
|
|||||||
|
|
||||||
public static Connection getConnection()
|
public static Connection getConnection()
|
||||||
throws SQLException {
|
throws SQLException {
|
||||||
|
return DriverManager.getConnection(URL, USER, PASSWORD);
|
||||||
// TODO:
|
|
||||||
// Return a valid PostgreSQL connection
|
|
||||||
|
|
||||||
return null;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
@@ -12,4 +12,31 @@ public class MenuItem {
|
|||||||
|
|
||||||
private String category;
|
private String category;
|
||||||
|
|
||||||
|
public MenuItem(int id, String name, String description, double price, String category) {
|
||||||
|
this.id = id;
|
||||||
|
this.name = name;
|
||||||
|
this.description = description;
|
||||||
|
this.price = price;
|
||||||
|
this.category = category;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getDescription() {
|
||||||
|
return this.description;
|
||||||
|
}
|
||||||
|
|
||||||
|
public int getId() {
|
||||||
|
return this.id;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getName() {
|
||||||
|
return this.name;
|
||||||
|
}
|
||||||
|
|
||||||
|
public double getPrice() {
|
||||||
|
return this.price;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getCategory() {
|
||||||
|
return this.category;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
@@ -1,5 +1,6 @@
|
|||||||
package dev.model;
|
package dev.model;
|
||||||
|
|
||||||
|
import java.sql.Timestamp;
|
||||||
import java.time.LocalDateTime;
|
import java.time.LocalDateTime;
|
||||||
|
|
||||||
public class Order {
|
public class Order {
|
||||||
@@ -12,4 +13,18 @@ public class Order {
|
|||||||
|
|
||||||
private double totalPrice;
|
private double totalPrice;
|
||||||
|
|
||||||
|
public Order(int id, int userId, Timestamp createdAt, double totalPrice) {
|
||||||
|
this.id = id;
|
||||||
|
this.userId = userId;
|
||||||
|
this.createdAt = createdAt.toLocalDateTime();
|
||||||
|
this.totalPrice = totalPrice;
|
||||||
|
}
|
||||||
|
|
||||||
|
public int getUserId() {
|
||||||
|
return userId;
|
||||||
|
}
|
||||||
|
|
||||||
|
public double getTotalPrice() {
|
||||||
|
return totalPrice;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
@@ -12,4 +12,27 @@ public class OrderDetail {
|
|||||||
|
|
||||||
private double price;
|
private double price;
|
||||||
|
|
||||||
|
public OrderDetail(int id, int orderId, int menuItemId, int quantity, double priceAtPurchase) {
|
||||||
|
this.id = id;
|
||||||
|
this.orderId = orderId;
|
||||||
|
this.menuItemId = menuItemId;
|
||||||
|
this.quantity = quantity;
|
||||||
|
this.price = priceAtPurchase;
|
||||||
|
}
|
||||||
|
|
||||||
|
public int getOrderId() {
|
||||||
|
return orderId;
|
||||||
|
}
|
||||||
|
|
||||||
|
public int getMenuItemId() {
|
||||||
|
return menuItemId;
|
||||||
|
}
|
||||||
|
|
||||||
|
public int getQuantity() {
|
||||||
|
return quantity;
|
||||||
|
}
|
||||||
|
|
||||||
|
public double getPriceAtPurchase() {
|
||||||
|
return price;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
@@ -10,4 +10,26 @@ public class User {
|
|||||||
|
|
||||||
private String email;
|
private String email;
|
||||||
|
|
||||||
|
public User(int id, String username, String password, String email) {
|
||||||
|
this.id = id;
|
||||||
|
this.username = username;
|
||||||
|
this.password = password;
|
||||||
|
this.email = email;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getUsername() {
|
||||||
|
return this.username;
|
||||||
|
}
|
||||||
|
|
||||||
|
public int getId() {
|
||||||
|
return this.id;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getEmail() {
|
||||||
|
return this.email;
|
||||||
|
}
|
||||||
|
|
||||||
|
public String getPassword() {
|
||||||
|
return this.password;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
@@ -1,23 +1,75 @@
|
|||||||
package dev.service;
|
package dev.service;
|
||||||
|
|
||||||
|
import dev.database.DatabaseConnection;
|
||||||
import dev.model.User;
|
import dev.model.User;
|
||||||
|
|
||||||
|
import java.security.MessageDigest;
|
||||||
|
import java.sql.*;
|
||||||
|
import java.util.Base64;
|
||||||
|
|
||||||
public class AuthService {
|
public class AuthService {
|
||||||
|
|
||||||
|
private String hashPassword(String password) {
|
||||||
|
try {
|
||||||
|
MessageDigest digest = MessageDigest.getInstance("SHA-256");
|
||||||
|
byte[] hash = digest.digest(password.getBytes("UTF-8"));
|
||||||
|
return Base64.getEncoder().encodeToString(hash);
|
||||||
|
} catch (Exception e) {
|
||||||
|
throw new RuntimeException("Hashing failed", e);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
public boolean register(String username, String password, String email) {
|
public boolean register(String username, String password, String email) {
|
||||||
|
|
||||||
// TODO:
|
if (username == null || username.trim().isEmpty() || password == null || password.isEmpty()) {
|
||||||
// Validate and register user
|
System.out.println("Username and password cannot be empty.");
|
||||||
|
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
String sql = "INSERT INTO users (username, password, email) VALUES (?, ?, ?)";
|
||||||
|
try (Connection conn = DatabaseConnection.getConnection();
|
||||||
|
PreparedStatement pstmt = conn.prepareStatement(sql)) {
|
||||||
|
|
||||||
|
pstmt.setString(1, username);
|
||||||
|
pstmt.setString(2, hashPassword(password));
|
||||||
|
if (email == null || email.trim().isEmpty()) {
|
||||||
|
pstmt.setNull(3, Types.VARCHAR);
|
||||||
|
} else {
|
||||||
|
pstmt.setString(3, email);
|
||||||
|
}
|
||||||
|
|
||||||
|
pstmt.executeUpdate();
|
||||||
|
return true;
|
||||||
|
} catch (SQLException e) {
|
||||||
|
System.out.println("Registration failed (Username might already exist): " + e.getMessage());
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
public User login(String username, String password) {
|
public User login(String username, String password) {
|
||||||
|
|
||||||
// TODO:
|
String sql = "SELECT * FROM users WHERE username = ? AND password = ?";
|
||||||
// Authenticate user
|
try (Connection conn = DatabaseConnection.getConnection();
|
||||||
|
PreparedStatement pstmt = conn.prepareStatement(sql)) {
|
||||||
|
|
||||||
|
pstmt.setString(1, username);
|
||||||
|
pstmt.setString(2, hashPassword(password));
|
||||||
|
|
||||||
|
try (ResultSet rs = pstmt.executeQuery()) {
|
||||||
|
if (rs.next()) {
|
||||||
|
return new User(
|
||||||
|
rs.getInt("id"),
|
||||||
|
rs.getString("username"),
|
||||||
|
rs.getString("password"),
|
||||||
|
rs.getString("email")
|
||||||
|
);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
} catch (SQLException e) {
|
||||||
|
System.out.println("Login error: " + e.getMessage());
|
||||||
|
}
|
||||||
return null;
|
return null;
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
@@ -1,12 +1,27 @@
|
|||||||
package dev.service;
|
package dev.service;
|
||||||
|
|
||||||
|
import dev.dao.MenuItemDao;
|
||||||
|
import dev.model.MenuItem;
|
||||||
|
|
||||||
|
import java.util.List;
|
||||||
|
|
||||||
public class MenuService {
|
public class MenuService {
|
||||||
|
|
||||||
public void showMenu() {
|
public void showMenu() {
|
||||||
|
final MenuItemDao menuItemDao = new MenuItemDao();
|
||||||
|
|
||||||
// TODO:
|
List<MenuItem> items = menuItemDao.findAll();
|
||||||
// Display menu items
|
if (items.isEmpty()) {
|
||||||
|
System.out.println("The menu is currently empty.");
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
System.out.println("\n===== MENU =====");
|
||||||
|
for (MenuItem item : items) {
|
||||||
|
System.out.printf("[%d] %s - $%.2f (%s)\n", item.getId(), item.getName(), item.getPrice(), item.getCategory());
|
||||||
|
if (item.getDescription() != null) {
|
||||||
|
System.out.println(" " + item.getDescription());
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
@@ -1,26 +1,158 @@
|
|||||||
package dev.service;
|
package dev.service;
|
||||||
|
|
||||||
|
import dev.dao.MenuItemDao;
|
||||||
|
import dev.database.DatabaseConnection;
|
||||||
|
import dev.model.MenuItem;
|
||||||
|
|
||||||
|
import java.sql.*;
|
||||||
|
import java.util.Scanner;
|
||||||
|
|
||||||
public class OrderService {
|
public class OrderService {
|
||||||
|
private final MenuItemDao menuItemDao = new MenuItemDao();
|
||||||
|
private final Scanner scanner = new Scanner(System.in);
|
||||||
|
|
||||||
public void placeOrder(int userId) {
|
public void placeOrder(int userId) {
|
||||||
|
Connection conn = null;
|
||||||
|
try {
|
||||||
|
conn = DatabaseConnection.getConnection();
|
||||||
|
conn.setAutoCommit(false);
|
||||||
|
|
||||||
// TODO:
|
String insertOrderSql = "INSERT INTO orders (user_id, total_price) VALUES (?, 0.00)";
|
||||||
// Create order
|
PreparedStatement orderStmt = conn.prepareStatement(insertOrderSql, Statement.RETURN_GENERATED_KEYS);
|
||||||
|
orderStmt.setInt(1, userId);
|
||||||
|
orderStmt.executeUpdate();
|
||||||
|
|
||||||
|
ResultSet generatedKeys = orderStmt.getGeneratedKeys();
|
||||||
|
int orderId = 0;
|
||||||
|
if (generatedKeys.next()) {
|
||||||
|
orderId = generatedKeys.getInt(1);
|
||||||
|
}
|
||||||
|
|
||||||
|
double grandTotal = 0.0;
|
||||||
|
boolean addingItems = true;
|
||||||
|
String insertDetailSql = "INSERT INTO order_details (order_id, menu_item_id, quantity, price_at_purchase) VALUES (?, ?, ?, ?)";
|
||||||
|
PreparedStatement detailStmt = conn.prepareStatement(insertDetailSql);
|
||||||
|
|
||||||
|
while (addingItems) {
|
||||||
|
System.out.print("Enter Menu Item ID to add (or 0 to finish): ");
|
||||||
|
int itemId = scanner.nextInt();
|
||||||
|
if (itemId == 0) {
|
||||||
|
addingItems = false;
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
MenuItem item = menuItemDao.findById(itemId);
|
||||||
|
if (item == null) {
|
||||||
|
System.out.println("Invalid Item ID. Try again.");
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
System.out.print("Enter quantity: ");
|
||||||
|
int quantity = scanner.nextInt();
|
||||||
|
if (quantity <= 0) {
|
||||||
|
System.out.println("Quantity must be greater than zero.");
|
||||||
|
continue;
|
||||||
|
}
|
||||||
|
|
||||||
|
double subtotal = (item.getPrice()) * quantity;
|
||||||
|
grandTotal += subtotal;
|
||||||
|
|
||||||
|
detailStmt.setInt(1, orderId);
|
||||||
|
detailStmt.setInt(2, item.getId());
|
||||||
|
detailStmt.setInt(3, quantity);
|
||||||
|
detailStmt.setDouble(4, item.getPrice());
|
||||||
|
detailStmt.executeUpdate();
|
||||||
|
}
|
||||||
|
|
||||||
|
if (grandTotal == 0.0) {
|
||||||
|
System.out.println("No items selected. Canceling order.");
|
||||||
|
conn.rollback();
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
|
||||||
|
String updateOrderSql = "UPDATE orders SET total_price = ? WHERE id = ?";
|
||||||
|
PreparedStatement updateStmt = conn.prepareStatement(updateOrderSql);
|
||||||
|
updateStmt.setDouble(1, grandTotal);
|
||||||
|
updateStmt.setInt(2, orderId);
|
||||||
|
updateStmt.executeUpdate();
|
||||||
|
|
||||||
|
conn.commit();
|
||||||
|
System.out.println("Order successfully saved!");
|
||||||
|
printReceipt(orderId);
|
||||||
|
|
||||||
|
} catch (SQLException e) {
|
||||||
|
System.out.println("Order failed: " + e.getMessage());
|
||||||
|
if (conn != null) {
|
||||||
|
try { conn.rollback(); } catch (SQLException ex) { ex.printStackTrace(); }
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public void printReceipt(int orderId) {
|
public void printReceipt(int orderId) {
|
||||||
|
|
||||||
// TODO:
|
String sql = "SELECT od.quantity, od.price_at_purchase, m.name, o.total_price " +
|
||||||
// Print order receipt
|
"FROM order_details od " +
|
||||||
|
"JOIN menu_items m ON od.menu_item_id = m.id " +
|
||||||
|
"JOIN orders o ON od.order_id = o.id " +
|
||||||
|
"WHERE od.order_id = ?";
|
||||||
|
|
||||||
|
try (Connection conn = DatabaseConnection.getConnection();
|
||||||
|
PreparedStatement pstmt = conn.prepareStatement(sql)) {
|
||||||
|
|
||||||
|
pstmt.setInt(1, orderId);
|
||||||
|
try (ResultSet rs = pstmt.executeQuery()) {
|
||||||
|
System.out.println("\n========= RECEIPT (Order #" + orderId + ") =========");
|
||||||
|
double grandTotal = 0.0;
|
||||||
|
boolean hasRows = false;
|
||||||
|
|
||||||
|
while (rs.next()) {
|
||||||
|
hasRows = true;
|
||||||
|
String name = rs.getString("name");
|
||||||
|
int qty = rs.getInt("quantity");
|
||||||
|
double price = rs.getDouble("price_at_purchase");
|
||||||
|
double subtotal = qty * price;
|
||||||
|
grandTotal = rs.getDouble("total_price");
|
||||||
|
|
||||||
|
System.out.printf("- %s x%d @ $%.2f = $%.2f\n", name, qty, price, subtotal);
|
||||||
|
}
|
||||||
|
if (!hasRows) {
|
||||||
|
System.out.println("Order not found.");
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
System.out.println("----------------------------------------");
|
||||||
|
System.out.printf("GRAND TOTAL: $%.2f\n", grandTotal);
|
||||||
|
System.out.println("========================================");
|
||||||
|
}
|
||||||
|
} catch (SQLException e) {
|
||||||
|
System.out.println("Error generating receipt: " + e.getMessage());
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
public void showOrderHistory(int userId) {
|
public void showOrderHistory(int userId) {
|
||||||
|
String sql = "SELECT id, created_at, total_price FROM orders WHERE user_id = ? ORDER BY created_at DESC";
|
||||||
|
|
||||||
// TODO:
|
try (Connection conn = DatabaseConnection.getConnection();
|
||||||
// Display user's order history
|
PreparedStatement pstmt = conn.prepareStatement(sql)) {
|
||||||
|
|
||||||
|
pstmt.setInt(1, userId);
|
||||||
|
try (ResultSet rs = pstmt.executeQuery()) {
|
||||||
|
System.out.println("\n===== YOUR ORDER HISTORY =====");
|
||||||
|
boolean hasHistory = false;
|
||||||
|
while (rs.next()) {
|
||||||
|
hasHistory = true;
|
||||||
|
System.out.printf("Order #%d | Date: %s | Total Spent: $%.2f\n",
|
||||||
|
rs.getInt("id"),
|
||||||
|
rs.getTimestamp("created_at").toString(),
|
||||||
|
rs.getDouble("total_price")
|
||||||
|
);
|
||||||
|
}
|
||||||
|
if (!hasHistory) {
|
||||||
|
System.out.println("You haven't placed any orders yet.");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
} catch (SQLException e) {
|
||||||
|
System.out.println("Error fetching history: " + e.getMessage());
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
@@ -1,11 +1,20 @@
|
|||||||
package dev.ui;
|
package dev.ui;
|
||||||
|
|
||||||
|
import dev.model.MenuItem;
|
||||||
|
import dev.model.User;
|
||||||
|
import dev.service.AuthService;
|
||||||
|
import dev.service.MenuService;
|
||||||
|
import dev.service.OrderService;
|
||||||
|
|
||||||
import java.util.Scanner;
|
import java.util.Scanner;
|
||||||
|
|
||||||
public class ConsoleMenu {
|
public class ConsoleMenu {
|
||||||
|
|
||||||
private final Scanner scanner =
|
private final Scanner scanner =
|
||||||
new Scanner(System.in);
|
new Scanner(System.in);
|
||||||
|
private final AuthService authService = new AuthService();
|
||||||
|
private final MenuService menuService = new MenuService();
|
||||||
|
private final OrderService orderService = new OrderService();
|
||||||
|
|
||||||
public void start() {
|
public void start() {
|
||||||
|
|
||||||
@@ -22,11 +31,11 @@ public class ConsoleMenu {
|
|||||||
switch (choice) {
|
switch (choice) {
|
||||||
|
|
||||||
case 1:
|
case 1:
|
||||||
// TODO
|
handleLogin();
|
||||||
break;
|
break;
|
||||||
|
|
||||||
case 2:
|
case 2:
|
||||||
// TODO
|
handleRegister();
|
||||||
break;
|
break;
|
||||||
|
|
||||||
case 3:
|
case 3:
|
||||||
@@ -41,4 +50,64 @@ public class ConsoleMenu {
|
|||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
private void handleRegister() {
|
||||||
|
System.out.print("Choose Username: ");
|
||||||
|
String user = scanner.nextLine();
|
||||||
|
System.out.print("Choose Password: ");
|
||||||
|
String pass = scanner.nextLine();
|
||||||
|
System.out.print("Email (Optional, press Enter to skip): ");
|
||||||
|
String email = scanner.nextLine();
|
||||||
|
|
||||||
|
if (authService.register(user, pass, email)) {
|
||||||
|
System.out.println("Registration successful! You can now log in.");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private void handleLogin() {
|
||||||
|
System.out.print("Username: ");
|
||||||
|
String user = scanner.nextLine();
|
||||||
|
System.out.print("Password: ");
|
||||||
|
String pass = scanner.nextLine();
|
||||||
|
|
||||||
|
User loggedInUser = authService.login(user, pass);
|
||||||
|
if (loggedInUser != null) {
|
||||||
|
System.out.println("Welcome back, " + loggedInUser.getUsername() + "!");
|
||||||
|
showCustomerDashboard(loggedInUser);
|
||||||
|
} else {
|
||||||
|
System.out.println("Invalid username or password.");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
private void showCustomerDashboard(User user) {
|
||||||
|
while (true) {
|
||||||
|
System.out.println("\n===== CUSTOMER MENU =====");
|
||||||
|
System.out.println("1. Browse Menu");
|
||||||
|
System.out.println("2. Place New Order");
|
||||||
|
System.out.println("3. View Order History");
|
||||||
|
System.out.println("4. Logout");
|
||||||
|
System.out.print("Choose an option: ");
|
||||||
|
|
||||||
|
int choice = scanner.nextInt();
|
||||||
|
scanner.nextLine();
|
||||||
|
|
||||||
|
switch (choice) {
|
||||||
|
case 1:
|
||||||
|
menuService.showMenu();
|
||||||
|
break;
|
||||||
|
case 2:
|
||||||
|
menuService.showMenu();
|
||||||
|
orderService.placeOrder(user.getId());
|
||||||
|
break;
|
||||||
|
case 3:
|
||||||
|
orderService.showOrderHistory(user.getId());
|
||||||
|
break;
|
||||||
|
case 4:
|
||||||
|
System.out.println("Logged out successfully.");
|
||||||
|
return;
|
||||||
|
default:
|
||||||
|
System.out.println("Invalid choice.");
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
}
|
}
|
||||||
Reference in New Issue
Block a user