بناء طبقة البيانات

// domain/repository/TaskRepository.java package com.example.taskapp.domain.repository; import com.example.taskapp.domain.model.Task; import java.util.List; import java.util.Optional; public interface TaskRepository { Task save(Task task); // إدراج أو تحديث Optional<Task> findById(long id); List<Task> findAll(); List<Task> findByStatus(String status); void deleteById(long id); }

// infrastructure/persistence/Database.java package com.example.taskapp.infrastructure.persistence; import org.sqlite.SQLiteDataSource; import javax.sql.DataSource; public final class Database { private static final DataSource DATA_SOURCE; static { SQLiteDataSource ds = new SQLiteDataSource(); ds.setUrl("jdbc:sqlite:taskapp.db"); DATA_SOURCE = ds; } private Database() {} public static DataSource get() { return DATA_SOURCE; } }

// infrastructure/persistence/SchemaInitializer.java package com.example.taskapp.infrastructure.persistence; import java.sql.Connection; import java.sql.SQLException; import java.sql.Statement; public final class SchemaInitializer { public static void run() { String ddl = """ CREATE TABLE IF NOT EXISTS tasks ( id INTEGER PRIMARY KEY AUTOINCREMENT, title TEXT NOT NULL, description TEXT, status TEXT NOT NULL DEFAULT 'TODO', created_at TEXT NOT NULL, updated_at TEXT NOT NULL ); """; try (Connection conn = Database.get().getConnection(); Statement stmt = conn.createStatement()) { stmt.execute(ddl); } catch (SQLException e) { throw new RuntimeException("فشل تهيئة المخطط", e); } } private SchemaInitializer() {} }

// infrastructure/persistence/JdbcTaskRepository.java package com.example.taskapp.infrastructure.persistence; import com.example.taskapp.domain.model.Task; import com.example.taskapp.domain.repository.TaskRepository; import java.sql.*; import java.time.LocalDateTime; import java.util.ArrayList; import java.util.List; import java.util.Optional; public class JdbcTaskRepository implements TaskRepository { private static final String INSERT = "INSERT INTO tasks (title, description, status, created_at, updated_at) VALUES (?, ?, ?, ?, ?)"; private static final String UPDATE = "UPDATE tasks SET title=?, description=?, status=?, updated_at=? WHERE id=?"; private static final String FIND_BY_ID = "SELECT * FROM tasks WHERE id = ?"; private static final String FIND_ALL = "SELECT * FROM tasks ORDER BY created_at DESC"; private static final String FIND_STATUS = "SELECT * FROM tasks WHERE status = ? ORDER BY created_at DESC"; private static final String DELETE = "DELETE FROM tasks WHERE id = ?"; @Override public Task save(Task task) { if (task.getId() == 0) { return insert(task); } else { return update(task); } } private Task insert(Task task) { String now = LocalDateTime.now().toString(); try (Connection conn = Database.get().getConnection(); PreparedStatement ps = conn.prepareStatement(INSERT, Statement.RETURN_GENERATED_KEYS)) { ps.setString(1, task.getTitle()); ps.setString(2, task.getDescription()); ps.setString(3, task.getStatus()); ps.setString(4, now); ps.setString(5, now); ps.executeUpdate(); try (ResultSet keys = ps.getGeneratedKeys()) { if (keys.next()) { return task.withId(keys.getLong(1)); } } throw new RuntimeException("الإدراج لم يُعِد مفتاحًا مولَّدًا"); } catch (SQLException e) { throw new DataAccessException("insert task", e); } } private Task update(Task task) { String now = LocalDateTime.now().toString(); try (Connection conn = Database.get().getConnection(); PreparedStatement ps = conn.prepareStatement(UPDATE)) { ps.setString(1, task.getTitle()); ps.setString(2, task.getDescription()); ps.setString(3, task.getStatus()); ps.setString(4, now); ps.setLong(5, task.getId()); ps.executeUpdate(); return task; } catch (SQLException e) { throw new DataAccessException("update task", e); } } @Override public Optional<Task> findById(long id) { try (Connection conn = Database.get().getConnection(); PreparedStatement ps = conn.prepareStatement(FIND_BY_ID)) { ps.setLong(1, id); try (ResultSet rs = ps.executeQuery()) { if (rs.next()) { return Optional.of(map(rs)); } } return Optional.empty(); } catch (SQLException e) { throw new DataAccessException("findById " + id, e); } } @Override public List<Task> findAll() { try (Connection conn = Database.get().getConnection(); PreparedStatement ps = conn.prepareStatement(FIND_ALL); ResultSet rs = ps.executeQuery()) { List<Task> result = new ArrayList<>(); while (rs.next()) result.add(map(rs)); return result; } catch (SQLException e) { throw new DataAccessException("findAll", e); } } @Override public List<Task> findByStatus(String status) { try (Connection conn = Database.get().getConnection(); PreparedStatement ps = conn.prepareStatement(FIND_STATUS)) { ps.setString(1, status); try (ResultSet rs = ps.executeQuery()) { List<Task> result = new ArrayList<>(); while (rs.next()) result.add(map(rs)); return result; } } catch (SQLException e) { throw new DataAccessException("findByStatus " + status, e); } } @Override public void deleteById(long id) { try (Connection conn = Database.get().getConnection(); PreparedStatement ps = conn.prepareStatement(DELETE)) { ps.setLong(1, id); ps.executeUpdate(); } catch (SQLException e) { throw new DataAccessException("deleteById " + id, e); } } // ---------- توابع مساعدة خاصة ---------- private Task map(ResultSet rs) throws SQLException { return new Task( rs.getLong("id"), rs.getString("title"), rs.getString("description"), rs.getString("status"), LocalDateTime.parse(rs.getString("created_at")), LocalDateTime.parse(rs.getString("updated_at")) ); } }

// infrastructure/persistence/DataAccessException.java package com.example.taskapp.infrastructure.persistence; public class DataAccessException extends RuntimeException { public DataAccessException(String operation, Throwable cause) { super("فشل الوصول إلى البيانات أثناء: " + operation, cause); } }

// Main.java (مقتطف) SchemaInitializer.run(); TaskRepository repository = new JdbcTaskRepository(); TaskService service = new TaskService(repository); // ... سلّم الخدمة إلى طبقة CLI أو HTTP