added lastrecordıd function

uurdev · uurdev · commit d5fe872aad7d · 2020-04-09T12:15:56.000+03:00
new record id autogenerated
diff --git a/db-example/src/main/java/Main.java b/db-example/src/main/java/Main.java
@@ -1,6 +1,7 @@
 import config.DbConnectionManagement;
 import entity.Employee;
 import query.InsertQueryApi;
+import query.SelectQueryApi;
 
 import java.sql.Connection;
 import java.util.Date;
@@ -12,7 +13,7 @@ public static void main(String[] args) {
         try {
             Employee tempEmployee = new Employee("Ahmet", "Aksoy", "M", new Date(), new Date());
             Connection connection = DbConnectionManagement.connectToDatabase();
-            InsertQueryApi.insertRecord(tempEmployee, connection);
+            InsertQueryApi.insertOneRecord(tempEmployee, connection);
             DbConnectionManagement.killDbConnection(connection);
         } catch (SQLException e) {
             e.printStackTrace();
diff --git a/db-example/src/main/java/query/InsertQueryApi.java b/db-example/src/main/java/query/InsertQueryApi.java
@@ -13,16 +13,17 @@ public class InsertQueryApi {
     /*
        Bu fonksiyon dışarıdan parametre olarak verılmıs olan kullanıcıyı veritabanına kayıt eder
     */
-    public static void insertRecord(Employee employee, Connection connection) {
+    public static void insertOneRecord(Employee employee, Connection connection) {
         try {
             if (employee != null) {//gönderilen kaydın boş olup olmamasına bakıldı
                 if (ConnectionValidate.validateConnection(connection)) {//baglantının basarılı ıle true
                     PreparedStatement preparedStatement = connection.prepareStatement("INSERT INTO employee (id,name,lastName,gender,birthDate,hireDate) VALUES (?,?,?,?,?,?)");
                 /*
                     TODO burada son kayıdı bulup idsini alıp yenı kayıt ekleren son kaydın id'sini +1 yapmak gereklı auto +1 yükselicek her personel kaydı
                  */
+                    //son eklenen kaydın ıdsını aldı 1 arttırıp yeni kayıt oluşturdu
+                    preparedStatement.setLong(1, SelectQueryApi.resultLastRecordId(connection) + 1);
 
-                    preparedStatement.setLong(1, 0);//TODO +1 işlemi burada gerekli
                     preparedStatement.setString(2, employee.getName());
                     preparedStatement.setString(3, employee.getLastName());
                     preparedStatement.setString(4, employee.getGender());
diff --git a/db-example/src/main/java/query/SelectQueryApi.java b/db-example/src/main/java/query/SelectQueryApi.java
@@ -5,10 +5,28 @@
 
 import java.sql.Connection;
 import java.sql.PreparedStatement;
+import java.sql.ResultSet;
+import java.sql.Statement;
 
 public class SelectQueryApi {
 
 
+    /*
+         bu fonksiyon dışarıdan gelen tablo içindeki en son kaydın recordId'sını döner
+         fonksiyonun yazılma nedeni kayıt eklenirken son id'li kaydın recordId'sını 1 arttırabılmek için
+     */
+    public static int resultLastRecordId(Connection connection) {
+        int lastId = 0;
+        try {
+            Statement statement = connection.createStatement(ResultSet.TYPE_FORWARD_ONLY, ResultSet.CONCUR_READ_ONLY);
+            ResultSet resultSet = statement.executeQuery("SELECT id FROM employee");
+            resultSet.last();
+            lastId = resultSet.getInt(1);
+        } catch (Exception e) {
+            System.out.println(e.getMessage());
+        }
+        return lastId;
+    }
 
 
 }
