added delete one record

uurdev · uurdev · commit aea59b264ae2 · 2020-04-09T12:46:42.000+03:00
and added search recordId for employee
diff --git a/db-example/src/main/java/Main.java b/db-example/src/main/java/Main.java
@@ -1,5 +1,6 @@
 import config.DbConnectionManagement;
 import entity.Employee;
+import query.DeleteQueryApi;
 import query.InsertQueryApi;
 import query.SelectQueryApi;
 
@@ -9,11 +10,33 @@
 
 public class Main {
     public static void main(String[] args) {
-
         try {
-            Employee tempEmployee = new Employee("Ahmet", "Aksoy", "M", new Date(), new Date());
+            //database'e baglantı kurar ve bir adet connection nesnesi yaratır
             Connection connection = DbConnectionManagement.connectToDatabase();
+
+
+            /*10 idli kayıdın silme işlemini yapar
+
+             DeleteQueryApi.deleteRecord(10, connection);
+             */
+
+            /* verilen id'nin veri tabanında olup olmadıgını kontrol eder
+
+            if (SelectQueryApi.findByEmployeeId(10, connection)!=null) {
+                System.out.println("Kayıt bulundu");
+            } else {
+                System.out.println("Kayıt bulunamadı");
+            }
+
+             */
+
+            /* yeni kayıt ekleme yapar
+
+            Employee tempEmployee = new Employee("Ahmet", "Aksoy", "M", new Date(), new Date());
             InsertQueryApi.insertOneRecord(tempEmployee, connection);
+
+            */
+            //database baglantısını kapatır
             DbConnectionManagement.killDbConnection(connection);
         } catch (SQLException e) {
             e.printStackTrace();
diff --git a/db-example/src/main/java/query/DeleteQueryApi.java b/db-example/src/main/java/query/DeleteQueryApi.java
@@ -1,4 +1,23 @@
 package query;
 
+import java.sql.Connection;
+import java.sql.PreparedStatement;
+
 public class DeleteQueryApi {
+
+
+    public static void deleteRecord(int recordId, Connection connection) {
+        try {
+            PreparedStatement preparedStatement = connection.prepareStatement("DELETE FROM employee WHERE id= ?");
+
+            if (SelectQueryApi.findByEmployeeId(recordId, connection) != null) {//bu recordId'de kayıt varsa eğer
+                preparedStatement.setInt(1, recordId);
+                int deleteRowCount = preparedStatement.executeUpdate();
+                System.out.println(deleteRowCount + "rows deleted !");
+            }
+        } catch (Exception e) {
+            System.out.println(e.getMessage());
+        }
+    }
+
 }
diff --git a/db-example/src/main/java/query/SelectQueryApi.java b/db-example/src/main/java/query/SelectQueryApi.java
@@ -28,5 +28,27 @@ public static int resultLastRecordId(Connection connection) {
         return lastId;
     }
 
+    /*
+    bu fonksiyon dışarıdan parametre olarak verılmıs olan id'nin veritabanında olup olmadıgına bakar
+    eger verilen id'de kayıt varsa o kaydın recordId'sını döner
+
+    --- Neden bu fonksiyonu kullanmalıyız ----
+    1-> Kayıt silerken o kaydın veritabanında olup olmadığı önemlidir çünkü olmayan kayıdı silmeye calısırsak hata alırız
+    2-> Kayıt eklerken aynı id'de kayıt olabilir bu seferde hata alırız  ve kayıt ekleyemeyebiliriz
+     */
+    public static Integer findByEmployeeId(int id, Connection connection) {
+        Integer recordId = null;
+        try {
+            PreparedStatement preparedStatement = connection.prepareStatement("SELECT * FROM employee WHERE id= ?");
+            preparedStatement.setInt(1, id);
+            ResultSet resultSet = preparedStatement.executeQuery();
+            if (resultSet.next()) {
+                recordId = resultSet.getInt(1);
+            }
+        } catch (Exception e) {
+            System.out.println(e.getMessage());
+        }
+        return recordId;
+    }
 
 }
