Moon mission db

pom.xml

@@ -51,6 +51,11 @@
             <artifactId>mysql</artifactId>
             <version>1.21.3</version>
         </dependency>
+        <dependency>
+            <groupId>org.slf4j</groupId>
+            <artifactId>slf4j-nop</artifactId>
+            <version>2.0.17</version>
+        </dependency>
     </dependencies>
     <build>
         <plugins>

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

@@ -0,0 +1,10 @@
+package com.example;
+
+import java.sql.SQLException;
+
+public interface AccountRepository {
+    boolean findByNameAndPassword(String username, String password) throws SQLException;
+    int create(String firstName, String lastName, String ssn, String password, String username) throws SQLException;
+    int updatePassword(long userId, String newPassword) throws SQLException;
+    int delete(long userId) throws SQLException;
+}

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

@@ -0,0 +1,8 @@
+package com.example;
+
+import java.sql.Connection;
+import java.sql.SQLException;
+
+public interface DataSource {
+    Connection getConnection() throws SQLException;
+}

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

@@ -0,0 +1,67 @@
+package com.example;
+
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+
+public class JdbcAccountRepository implements AccountRepository {
+
+    private final DataSource dataSource;
+
+    public JdbcAccountRepository(DataSource dataSource) {
+        this.dataSource = dataSource;
+    }
+
+    @Override
+    public boolean findByNameAndPassword(String username, String password) throws SQLException {
+        String sql = "SELECT user_id FROM account WHERE name = ? AND password = ?";
+        // Använder try-with-resources för att säkerställa att Connection stängs
+        try (Connection connection = dataSource.getConnection();
+             PreparedStatement stmt = connection.prepareStatement(sql)) {
+            stmt.setString(1, username);
+            stmt.setString(2, password);
+            try (ResultSet rs = stmt.executeQuery()) {
+                return rs.next();
+            }
+        }
+    }
+
+    @Override
+    public int create(String firstName, String lastName, String ssn, String password, String username) throws SQLException {
+        String sql = "INSERT INTO account (first_name, last_name, ssn, password, name) VALUES (?, ?, ?, ?, ?)";
+        try (Connection connection = dataSource.getConnection();
+             PreparedStatement stmt = connection.prepareStatement(sql)) {
+            stmt.setString(1, firstName);
+            stmt.setString(2, lastName);
+            stmt.setString(3, ssn);
+            stmt.setString(4, password);
+            stmt.setString(5, username);
+
+            return stmt.executeUpdate();
+        }
+    }
+
+    @Override
+    public int updatePassword(long userId, String newPassword) throws SQLException {
+        String sql = "UPDATE account SET password = ? WHERE user_id = ?";
+        try (Connection connection = dataSource.getConnection();
+             PreparedStatement stmt = connection.prepareStatement(sql)) {
+            stmt.setString(1, newPassword);
+            stmt.setLong(2, userId);
+
+            return stmt.executeUpdate();
+        }
+    }
+
+    @Override
+    public int delete(long userId) throws SQLException {
+        String sql = "DELETE FROM account WHERE user_id = ?";
+        try (Connection connection = dataSource.getConnection();
+             PreparedStatement stmt = connection.prepareStatement(sql)) {
+            stmt.setLong(1, userId);
+
+            return stmt.executeUpdate();
+        }
+    }
+}

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

@@ -0,0 +1,56 @@
+package com.example;
+
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.Statement;
+import java.util.ArrayList;
+import java.util.List;
+
+public class JdbcMoonMissionRepository implements MoonMissionRepository {
+
+    private final DataSource dataSource;
+
+    public JdbcMoonMissionRepository(DataSource dataSource) {
+        this.dataSource = dataSource;
+    }
+
+    @Override
+    public List<String> findAllSpacecraftNames() throws SQLException {
+        List<String> names = new ArrayList<>();
+        String sql = "SELECT spacecraft FROM moon_mission";
+        try (Connection connection = dataSource.getConnection();
+             Statement stmt = connection.createStatement();
+             ResultSet rs = stmt.executeQuery(sql)) {
+            while (rs.next()) {
+                names.add(rs.getString("spacecraft"));
+            }
+        }
+        return names;
+    }
+
+
+    @Override
+    public ResultSet findMissionById(long missionId, Connection connection) throws SQLException {
+        String sql = "SELECT * FROM moon_mission WHERE mission_id = ?";
+        PreparedStatement stmt = connection.prepareStatement(sql);
+        stmt.setLong(1, missionId);
+        return stmt.executeQuery();
+    }
+
+    @Override
+    public int countMissionsByYear(int year) throws SQLException {
+        String sql = "SELECT COUNT(*) FROM moon_mission WHERE YEAR(launch_date) = ?";
+        try (Connection connection = dataSource.getConnection();
+             PreparedStatement stmt = connection.prepareStatement(sql)) {
+            stmt.setInt(1, year);
+            try (ResultSet rs = stmt.executeQuery()) {
+                if (rs.next()) {
+                    return rs.getInt(1);
+                }
+                return 0;
+            }
+        }
+    }
+}