findAllByKorisnik i byOglas

SkuciSe/src/main/java/com/example/SkuciSe/model/zahtev/Zahtev.java

@@ -10,7 +10,7 @@ import java.sql.*;
 @AllArgsConstructor
 @ToString
 public class Zahtev {
-        int terminId;
+        int zahtevId;
         int korisnikId;
         int oglasId;
         String datum;

SkuciSe/src/main/java/com/example/SkuciSe/repository/ZahtevRepository.java

@@ -22,7 +22,6 @@ public class ZahtevRepository {
         noviZahtev.setVreme( vreme);
         System.out.println( noviZahtev.toString());
 
-//        String sql = "insert into zahtev( oglasid, korisnikid, datum, vreme, stanje) values ("+noviZahtev.getOglasId()+","+noviZahtev.getKorisnikId()+",'"+noviZahtev.getDatum()+"','"+noviZahtev.getDatum()+"','"+noviZahtev.getStatus()+"')";
         String sql="{call insertZahtev(?,?,?,?,?)}";
         CallableStatement stmt=null;
         try {
@@ -41,10 +40,13 @@ public class ZahtevRepository {
     public List<Zahtev> findAllByKorisnikId( int korisnikId)
     {
         List<Zahtev> list = new ArrayList<Zahtev>();
-        String sql = "select * from zahtev where korisnikid = " + korisnikId;
+        String sql = "call findAllZahtevByKorisnikId(?)";
+        CallableStatement stmt = null;
         ResultSet rs = null;
         try {
-            rs = dataBase.statement.executeQuery( sql);
+            stmt = dataBase.connection.prepareCall( sql);
+            stmt.setInt( 1, korisnikId);
+            rs = stmt.executeQuery();
             while( rs.next())
             {
                 Zahtev zahtev =  new Zahtev( rs.getInt(1), rs.getInt(2), rs.getInt(3), rs.getString(4), rs.getString(5), StanjeZahteva.valueOf(rs.getString(6)));
@@ -60,10 +62,13 @@ public class ZahtevRepository {
     public List<Zahtev> findAllByOglasId( int oglasId)
     {
         List<Zahtev> list = new ArrayList<Zahtev>();
-        String sql = "select * from zahtev where oglasid = " + oglasId;
+        String sql = "call findAllZahtevByOglasId(?)";
+        CallableStatement stmt = null;
         ResultSet rs = null;
         try {
-            rs = dataBase.statement.executeQuery( sql);
+            stmt = dataBase.connection.prepareCall( sql);
+            stmt.setInt( 1, oglasId);
+            rs = stmt.executeQuery();
             while( rs.next())
             {
                 Zahtev zahtev =  new Zahtev( rs.getInt(1), rs.getInt(2), rs.getInt(3), rs.getString(4), rs.getString(5), StanjeZahteva.valueOf(rs.getString(6)));