نمط DAO

package com.example.dao; import com.example.model.Product; import java.util.List; import java.util.Optional; public interface ProductDao { List<Product> findAll(); Optional<Product> findById(int id); List<Product> findByCategory(String category); void save(Product product); // INSERT أو UPDATE void delete(int id); }

package com.example.model; public class Product { private int id; private String name; private String category; private double price; private int stock; // المنشئ الأساسي public Product(int id, String name, String category, double price, int stock) { this.id = id; this.name = name; this.category = category; this.price = price; this.stock = stock; } // منشئ بدون معاملات لحالة "الإدراج بدون ID" public Product() {} // getters and setters مختصرة للإيجاز public int getId() { return id; } public String getName() { return name; } public String getCategory() { return category; } public double getPrice() { return price; } public int getStock() { return stock; } public void setId(int id) { this.id = id; } public void setName(String name) { this.name = name; } public void setCategory(String cat) { this.category = cat; } public void setPrice(double price) { this.price = price; } public void setStock(int stock) { this.stock = stock; } }

package com.example.dao; import com.example.model.Product; import javax.sql.DataSource; import java.sql.*; import java.util.ArrayList; import java.util.List; import java.util.Optional; public class JdbcProductDao implements ProductDao { private final DataSource dataSource; // حقن DataSource — بدون DriverManager، بدون URL مضمّن public JdbcProductDao(DataSource dataSource) { this.dataSource = dataSource; } @Override public List<Product> findAll() { String sql = "SELECT id, name, category, price, stock FROM products ORDER BY name"; List<Product> results = new ArrayList<>(); try (Connection conn = dataSource.getConnection(); PreparedStatement ps = conn.prepareStatement(sql); ResultSet rs = ps.executeQuery()) { while (rs.next()) { results.add(mapRow(rs)); } } catch (SQLException e) { throw new DataAccessException("فشل findAll", e); } return results; } @Override public Optional<Product> findById(int id) { String sql = "SELECT id, name, category, price, stock FROM products WHERE id = ?"; try (Connection conn = dataSource.getConnection(); PreparedStatement ps = conn.prepareStatement(sql)) { ps.setInt(1, id); try (ResultSet rs = ps.executeQuery()) { return rs.next() ? Optional.of(mapRow(rs)) : Optional.empty(); } } catch (SQLException e) { throw new DataAccessException("فشل findById للمعرف=" + id, e); } } @Override public List<Product> findByCategory(String category) { String sql = "SELECT id, name, category, price, stock FROM products WHERE category = ?"; List<Product> results = new ArrayList<>(); try (Connection conn = dataSource.getConnection(); PreparedStatement ps = conn.prepareStatement(sql)) { ps.setString(1, category); try (ResultSet rs = ps.executeQuery()) { while (rs.next()) results.add(mapRow(rs)); } } catch (SQLException e) { throw new DataAccessException("فشل findByCategory", e); } return results; } @Override public void save(Product product) { if (product.getId() == 0) { insert(product); } else { update(product); } } private void insert(Product p) { String sql = "INSERT INTO products (name, category, price, stock) VALUES (?, ?, ?, ?)"; try (Connection conn = dataSource.getConnection(); PreparedStatement ps = conn.prepareStatement(sql, Statement.RETURN_GENERATED_KEYS)) { ps.setString(1, p.getName()); ps.setString(2, p.getCategory()); ps.setDouble(3, p.getPrice()); ps.setInt(4, p.getStock()); ps.executeUpdate(); try (ResultSet keys = ps.getGeneratedKeys()) { if (keys.next()) p.setId(keys.getInt(1)); } } catch (SQLException e) { throw new DataAccessException("فشل الإدراج", e); } } private void update(Product p) { String sql = "UPDATE products SET name=?, category=?, price=?, stock=? WHERE id=?"; try (Connection conn = dataSource.getConnection(); PreparedStatement ps = conn.prepareStatement(sql)) { ps.setString(1, p.getName()); ps.setString(2, p.getCategory()); ps.setDouble(3, p.getPrice()); ps.setInt(4, p.getStock()); ps.setInt(5, p.getId()); ps.executeUpdate(); } catch (SQLException e) { throw new DataAccessException("فشل التحديث", e); } } @Override public void delete(int id) { String sql = "DELETE FROM products WHERE id = ?"; try (Connection conn = dataSource.getConnection(); PreparedStatement ps = conn.prepareStatement(sql)) { ps.setInt(1, id); ps.executeUpdate(); } catch (SQLException e) { throw new DataAccessException("فشل الحذف", e); } } // مُعيّن الصف الخاص — المكان الوحيد الذي يعرف أسماء الأعمدة private Product mapRow(ResultSet rs) throws SQLException { return new Product( rs.getInt("id"), rs.getString("name"), rs.getString("category"), rs.getDouble("price"), rs.getInt("stock") ); } }

package com.example.dao; public class DataAccessException extends RuntimeException { public DataAccessException(String message, Throwable cause) { super(message, cause); } }

@WebServlet("/products") public class ProductServlet extends HttpServlet { private ProductDao productDao; @Override public void init() { // البحث عن DataSource من JNDI (مُهيأ في خادم التطبيق) DataSource ds = (DataSource) new InitialContext() .lookup("java:comp/env/jdbc/shopDB"); productDao = new JdbcProductDao(ds); } @Override protected void doGet(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException { String cat = req.getParameter("category"); List<Product> products = (cat != null && !cat.isBlank()) ? productDao.findByCategory(cat) : productDao.findAll(); req.setAttribute("products", products); req.getRequestDispatcher("/WEB-INF/views/products.jsp").forward(req, resp); } }

// في اختبار JUnit 5 — بدون Mockito، بدون مقلّدات، فقط H2 حقيقية في الذاكرة class JdbcProductDaoTest { private static HikariDataSource ds; private ProductDao dao; @BeforeAll static void setupPool() { HikariConfig cfg = new HikariConfig(); cfg.setJdbcUrl("jdbc:h2:mem:testdb;DB_CLOSE_DELAY=-1"); cfg.setUsername("sa"); cfg.setPassword(""); ds = new HikariDataSource(cfg); } @BeforeEach void setupSchema() throws Exception { try (Connection c = ds.getConnection(); Statement s = c.createStatement()) { s.execute("DROP TABLE IF EXISTS products"); s.execute(""" CREATE TABLE products ( id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(100), category VARCHAR(50), price DOUBLE, stock INT )"""); } dao = new JdbcProductDao(ds); } @Test void saveAndFindById() { Product p = new Product(); p.setName("Widget"); p.setCategory("tools"); p.setPrice(9.99); p.setStock(50); dao.save(p); assertTrue(p.getId() > 0, "يجب ضبط المفتاح المُولَّد بعد الإدراج"); Optional<Product> found = dao.findById(p.getId()); assertTrue(found.isPresent()); assertEquals("Widget", found.get().getName()); } }