Update convertor script for inserting and updating values

Author: apik007

pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>cz.foresttech</groupId>
     <artifactId>ForestDatabase</artifactId>
-    <version>1.0.2</version>
+    <version>1.0.3</version>
 
     <properties>
         <maven.compiler.source>17</maven.compiler.source>

src/main/java/cz/foresttech/database/DatabaseEntityConvertor.java

@@ -198,11 +198,15 @@ public <T> String insertOrUpdateScript(Class<T> clazz, T object) throws IllegalA
             return null;
         }
 
-        String columns = processFieldsForScript(clazz, object, false);
+        String columns = getColumnsFromField(clazz);
+        String values = getValuesFromField(clazz, object);
+
+        String updateSetValues = processFieldsForScript(clazz, object, false);
+
         String conflictPolicy = getConflictPolicy(clazz);
 
         return String.format("INSERT INTO %s (%s) VALUES (%s) ON CONFLICT (%s) DO UPDATE SET (%s);",
-                tableName, columns, columns, conflictPolicy, columns);
+                tableName, columns, values, conflictPolicy, updateSetValues);
     }
 
     /**
@@ -260,6 +264,42 @@ private <T> String processFieldsForScript(Class<T> clazz, T object, boolean forD
         return keys + " = " + values;
     }
 
+    private <T> String getValuesFromField(Class<T> clazz, T object) throws IllegalAccessException {
+        StringBuilder values = new StringBuilder();
+
+        for (Field field : clazz.getDeclaredFields()) {
+            field.setAccessible(true);
+            Column column = field.getAnnotation(Column.class);
+            if (column == null) continue;
+            String dbName = getDbName(field, column);
+            Object fieldValue = field.get(object);
+            DatabaseValueProcessor valueProcessor = databaseAPI.getProcessor(field.getType());
+
+            String processedValue = processFieldValue(fieldValue, valueProcessor);
+            values.append(processedValue).append(",");
+        }
+
+        if (!values.isEmpty()) values.setLength(values.length() - 1);
+
+        return values.toString();
+    }
+
+    private <T> String getColumnsFromField(Class<T> clazz) {
+        StringBuilder keys = new StringBuilder();
+
+        for (Field field : clazz.getDeclaredFields()) {
+            field.setAccessible(true);
+            Column column = field.getAnnotation(Column.class);
+            if (column == null) continue;
+            String dbName = getDbName(field, column);
+            keys.append(dbName).append(",");
+        }
+
+        if (!keys.isEmpty()) keys.setLength(keys.length() - 1);
+
+        return keys.toString();
+    }
+
     /**
      * Processes the value of a field for inclusion in an SQL script.
      *