Migrations and DBrepository refactory

.gitignore

@@ -1 +1,7 @@
+# Default ignored files
+/shelf/
+/workspace.xml
 /target/
+logback.xml
+logs/
+.idea

pom.xml

@@ -3,9 +3,14 @@
          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
     <modelVersion>4.0.0</modelVersion>
-
+    <parent>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-starter-parent</artifactId>
+        <version>3.3.0</version>
+        <relativePath/> <!-- lookup parent from repository -->
+    </parent>
     <groupId>org.example</groupId>
-    <artifactId>AppForTests</artifactId>
+    <artifactId>AppwithPostgreSQL</artifactId>
     <version>1.0-SNAPSHOT</version>
 
     <properties>
@@ -14,6 +19,15 @@
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     </properties>
     <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
         <dependency>
             <groupId>org.junit.jupiter</groupId>
             <artifactId>junit-jupiter-api</artifactId>
@@ -64,6 +78,11 @@
             <artifactId>logback-classic</artifactId>
             <version>1.5.18</version>
         </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-autoconfigure</artifactId>
+            <version>3.4.4</version>
+        </dependency>
     </dependencies>
     <build>
         <plugins>
@@ -79,6 +98,33 @@
                     </includes>
                 </configuration>
             </plugin>
+            <plugin>
+                <groupId>org.flywaydb</groupId>
+                <artifactId>flyway-maven-plugin</artifactId>
+                <version>11.10.0</version>
+                <configuration>
+                    <serverId>flyway-db</serverId>
+                    <url>jdbc:postgresql://172.31.224.1:5432/findb</url>
+                    <!-- where V1__*.sql live -->
+                    <locations>
+                        <location>filesystem:src/main/resources/db/migration</location>
+                    </locations>
+                </configuration>
+                <dependencies>
+                <!-- 1️⃣  PostgreSQL database module -->
+                <dependency>
+                    <groupId>org.flywaydb</groupId>
+                    <artifactId>flyway-database-postgresql</artifactId>
+                    <version>11.10.0</version>
+                </dependency>
+                <!-- 2️⃣  JDBC driver (Flyway won’t ship it for licensing reasons) -->
+                <dependency>
+                    <groupId>org.postgresql</groupId>
+                    <artifactId>postgresql</artifactId>
+                    <version>42.7.4</version>
+                </dependency>
+                </dependencies>
+            </plugin>
         </plugins>
     </build>
 </project>

src/main/java/org/example/Currencies/CurrencyAPI.java

@@ -14,7 +14,7 @@
 
 public class CurrencyAPI {
 
-    private static final String url_str = "https://v6.exchangerate-api.com/v6/79f34354ceb4dc1276fecca5/latest/USD";
+    private static final String url_str = System.getenv("currencyAPI");
 
 
     public HashMap getCurrencies() throws IOException {

src/main/java/org/example/DriverManagerDB.java

@@ -6,9 +6,9 @@
 
 public class DriverManagerDB {
 
-    private final String url = "jdbc:postgresql://localhost:5432/findb";      // put into properties file
-    private final String username = "simon";
-    private final String password = "password";
+    private final String url = System.getenv("DBurl");      // put into properties file
+    private final String username = System.getenv("DBuser");
+    private final String password = System.getenv("DBpassword");
 
     public DriverManagerDB() throws SQLException {
     }

src/main/java/org/example/Repositories/CustomerEntityRepository.java

@@ -0,0 +1,132 @@
+package org.example.Repositories;
+
+
+import org.example.DriverManagerDB;
+import org.example.Model.Customer;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import java.sql.*;
+
+public class CustomerEntityRepository {
+
+    DriverManagerDB drivermanagerdb = new DriverManagerDB();
+
+    Connection connection = drivermanagerdb.connect();
+
+    final Logger logger = LoggerFactory.getLogger(TransfersRepository.class);
+
+    public CustomerEntityRepository() throws SQLException {
+    }
+
+    public void addCustomerRecord(String name, int money, String password) throws SQLException {
+        String sql = "INSERT INTO customers (nickname, money, password) VALUES (?, ?, ?)";
+
+        PreparedStatement ps = connection.prepareStatement(
+                sql,
+                Statement.RETURN_GENERATED_KEYS);{
+
+            ps.setString(1, name);
+            ps.setInt(2, money);
+            ps.setString(3, password);
+
+            int rows = ps.executeUpdate();                          // returns 1
+            logger.trace("Number of rows inserted: {}", rows);
+            if (rows == 0){
+                logger.error("Error");
+            }
+            try (ResultSet keys = ps.getGeneratedKeys()) {
+                if (keys.next()) {
+                    long id = keys.getLong(1);                      // ← your SERIAL / IDENTITY value
+                    logger.info("New customer id = {}", id);
+                }
+            }
+        }
+    }
+
+    public Customer returnRecord(int customerId) throws SQLException {
+
+        int id = customerId;
+        String name = null;
+        int money = 0;
+        String cusPassword = null;
+        String sql = "SELECT id, nickname, money, password FROM customers WHERE id = ?";
+
+        try (
+                PreparedStatement ps = connection.prepareStatement(sql)) {
+            ps.setLong(1, id);
+
+            ResultSet rs = ps.executeQuery();
+
+            while (rs.next()) {
+                id = rs.getInt("id");           // error here probably
+                name = rs.getString("nickname");
+                money = rs.getInt("money");
+                cusPassword = rs.getString("password");
+            }
+            //TODO: make this code with error logging
+        } catch (SQLException e) {
+            System.out.println(e.getMessage());
+        }
+        return new Customer(id, name, money, cusPassword);
+    }
+
+    public int findCustomerByUsername(String name){
+        int id = 0;
+        String sql = "SELECT id FROM customers WHERE nickname = ?";
+        try (
+                PreparedStatement ps = connection.prepareStatement(sql)) {
+            ps.setString(1, name);
+
+            ResultSet rs = ps.executeQuery();
+
+            while (rs.next()) {
+                id = rs.getInt("id");
+                return id;
+            }
+        } catch (SQLException e) {
+            logger.error("error: {}", e);
+        }
+        return id;
+    }
+
+
+    public boolean updateCustomerFunds(int customerId, int newAmount) {  //void
+
+        String sql = "UPDATE customers SET money = ? WHERE id = ? ";
+        try ( //
+              PreparedStatement ps = connection.prepareStatement(sql)) {
+
+            ps.setInt(1, newAmount);
+            ps.setInt(2,customerId);
+
+            ps.executeUpdate();
+
+        } catch (SQLException e) {
+            System.out.println(e.getMessage());
+            return false;
+        }
+        return true;
+    }
+
+    public boolean checkIfHasFriend(int senderId, int receiverId) throws SQLException {
+        String sql = "SELECT FROM friendships WHERE customer_id = ? AND friend_id = ?";
+        PreparedStatement ps = connection.prepareStatement(sql);
+
+        ps.setLong(1, senderId);
+        ps.setLong(2, receiverId);
+
+        ResultSet rs = ps.executeQuery();
+        boolean result = rs.next();
+
+        if (!result) {
+            ps.setLong(1, receiverId);
+            ps.setLong(2, senderId);
+
+            rs = ps.executeQuery();
+            return rs.next();
+        }
+        return true;
+    }
+}
+