Labb3

README.md

@@ -1,3 +1,4 @@
+[![Review Assignment Due Date](https://classroom.github.com/assets/deadline-readme-button-22041afd0340ce965d47ae6ef1cefeee28c7c493a6346c4f15d667ab976d596c.svg)](https://classroom.github.com/a/339Lr3BJ)
 ### How the tests work (and Docker requirement)
 
 This project ships with an end‑to‑end CLI integration test suite that uses Testcontainers to spin up a temporary MySQL database. 

src/main/java/com/example/AccountRepository.java

@@ -0,0 +1,12 @@
+package com.example;
+
+public interface AccountRepository {
+
+    boolean isValidLogin(String username, String password);
+
+    boolean createAccount(String firstName, String lastName, String ssn, String password);
+
+    boolean updatePassword(long userId, String newPassword);
+
+    boolean deleteAccount(long userId);
+}

src/main/java/com/example/DataSource.java

@@ -0,0 +1,11 @@
+package com.example;
+
+import java.sql.Connection;
+import java.sql.SQLException;
+
+// define a new standard method for connection
+public interface DataSource {
+
+    Connection getConnection() throws SQLException;
+
+}

src/main/java/com/example/JdbcAccountRepository.java

@@ -0,0 +1,107 @@
+package com.example;
+
+import java.sql.*;
+
+public class JdbcAccountRepository implements AccountRepository{
+
+    //Fetching Datasource object
+    private final DataSource dataSource;
+
+
+    //injection the datasource object into the constructor:
+    public JdbcAccountRepository(DataSource dataSource){
+        this.dataSource=dataSource;
+    }
+
+
+    @Override
+    public boolean isValidLogin(String username, String password) {
+        String sql = "SELECT COUNT(*) FROM account WHERE name = ? AND password = ?";
+
+        try(
+                Connection connection= dataSource.getConnection();
+                PreparedStatement ps= connection.prepareStatement(sql)
+                ) {
+                ps.setString(1, username);
+                ps.setString(2, password);
+
+                try(ResultSet rs = ps.executeQuery()) {
+                    if (rs.next()){
+                        return rs.getInt(1)>0;
+                    }
+                }
+
+        } catch (SQLException e){
+            System.err.println("Database error during login validation: " + e.getMessage());
+            return false;
+        }
+
+        return false;
+
+    }
+
+    @Override
+    public boolean createAccount(String firstName, String lastName, String ssn, String password) {
+
+        // concatenation of firstname and lastname to create username (name column in sql) for proper usage of the app.
+        String username = firstName.substring(0, Math.min(firstName.length(), 3)) +
+                lastName.substring(0, Math.min(lastName.length(), 3));
+
+        String sql= "INSERT INTO account (first_name, last_name, ssn, password, name) VALUES (?, ?, ?, ?, ?)";
+
+        try(Connection connection= dataSource.getConnection();
+            PreparedStatement ps= connection.prepareStatement(sql)){
+
+            ps.setString(1, firstName);
+            ps.setString(2, lastName);
+            ps.setString(3, ssn);
+            ps.setString(4, password);
+            ps.setString(5, username);
+
+            int rowsAffected= ps.executeUpdate();
+            return rowsAffected>0;
+        } catch (SQLException e){
+            System.err.println("Could not create account: " + e.getMessage());
+            return false;
+        }
+    }
+
+    @Override
+    public boolean updatePassword(long userId, String newPassword) {
+        String sql= "UPDATE account SET password = ? WHERE user_id = ?";
+
+        try(Connection connection= dataSource.getConnection();
+            PreparedStatement ps=connection.prepareStatement(sql)){
+
+            ps.setString(1, newPassword);
+            ps.setLong(2, userId);
+
+            int rowsAffected=ps.executeUpdate();
+            return rowsAffected>0;
+
+        }catch (SQLException e){
+            System.err.println(" Could not update password: " + e.getMessage());
+            return false;
+        }
+    }
+
+    @Override
+    public boolean deleteAccount(long userId) {
+        String sql= " DELETE FROM account WHERE user_id = ?";
+
+        try(Connection connection= dataSource.getConnection();
+            PreparedStatement ps=connection.prepareStatement(sql)){
+
+            ps.setLong(1, userId);
+
+            int rowsAffected=ps.executeUpdate();
+            return rowsAffected>0;
+
+        }catch (SQLException e){
+            System.err.println(" Could not delete account: " + e.getMessage());
+            return false;
+        }
+
+
+    }
+}

src/main/java/com/example/JdbcMoonMissionRepository.java

@@ -0,0 +1,94 @@
+package com.example;
+
+import java.sql.*;
+import java.time.LocalDate;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.Optional;
+
+public class JdbcMoonMissionRepository implements MoonMissionRepository{
+
+    //declare datasource object
+    private final DataSource dataSource;
+
+
+// inject into contructor:
+    public JdbcMoonMissionRepository(DataSource dataSource){
+        this.dataSource=dataSource;
+    }
+
+    @Override
+    public List<String> findAllSpacecraftNames() {
+        List<String> names = new ArrayList<>();
+
+        String sql= "SELECT spacecraft FROM moon_mission ORDER BY launch_date";
+
+        try( Connection connection= dataSource.getConnection();
+        Statement statement= connection.createStatement();
+        ResultSet rs= statement.executeQuery(sql)) {
+
+            while (rs.next()){
+                names.add(rs.getString("spacecraft"));
+
+            }
+        } catch (SQLException e){
+            System.err.println(" Failure to find names: " +e.getMessage());
+
+        }
+
+        return names;
+    }
+
+    @Override
+    public Optional<MoonMission> findById(long missionId) {
+        String sql = "SELECT mission_id, spacecraft, launch_date, carrier_rocket, operator, mission_type, outcome FROM moon_mission WHERE mission_id = ?";
+
+        try( Connection connection= dataSource.getConnection();
+             PreparedStatement ps= connection.prepareStatement(sql)){
+
+            ps.setLong(1, missionId);
+
+            try(ResultSet rs = ps.executeQuery()){
+                if(rs.next()){
+                    //Map to MoonMission object:
+                    MoonMission mission= new MoonMission(
+                            rs.getLong("mission_id"),
+                            rs.getString("spacecraft"),
+                            rs.getObject("launch_date", LocalDate.class),
+                            rs.getString("carrier_rocket"),
+                            rs.getString("operator"),
+                            rs.getString("mission_type"),
+                            rs.getString("outcome")
+                    );
+
+                    return Optional.of(mission);
+                }
+            }
+        }catch (SQLException e){
+            System.err.println(" Failure in receiving mission per ID: " + e.getMessage());
+        }
+        return Optional.empty();
+    }
+
+    @Override
+    public int countByYear(int year) {
+        String sql = "SELECT COUNT(*) FROM moon_mission WHERE YEAR(launch_date) = ?";
+
+        try( Connection connection=dataSource.getConnection();
+        PreparedStatement ps=connection.prepareStatement(sql)){
+
+            ps.setInt(1, year);
+
+            try(ResultSet rs=ps.executeQuery()){
+                if(rs.next()){
+                    //Result is COUNT(*) column 1:
+                    return rs.getInt(1);
+                }
+            }
+        } catch (SQLException e ){
+            System.err.println(" Failure in counting missions per year: " + e.getMessage());
+        }
+        //return 0 if no results are found:
+        return 0;
+    }
+}