Fix bug in WriteJDBC

Author: jpaulm

META-INF/MANIFEST.MF

@@ -1,4 +1,3 @@
 Manifest-Version: 1.0
 Implementation-Title: JavaFBP
-Implementation-Version: 4.1.5
-
+Implementation-Version: 4.1.6

build.gradle

@@ -33,7 +33,7 @@ apply plugin: 'java-library'
 
 }
 
-version = '4.1.5'
+version = '4.1.6'
 
 group = 'com.jpaulmorrison'
 
@@ -74,7 +74,7 @@ java {
 
 
 jar {
-    archiveVersion = '4.1.5'
+    archiveVersion = '4.1.6'
     manifest {
        attributes 'Implementation-Title': 'JavaFBP', 'Implementation-Version': archiveVersion,
 
@@ -138,7 +138,7 @@ description = "Create default maven directory structure"
 
             groupId = 'com.jpaulmorrison'
             artifactId = 'javafbp'       
-            version = '4.1.5'
+            version = '4.1.6'
 
             from components.java
 

build/distributions/javafbp-4.1.6.tar

@@ -80,7 +80,7 @@ case "`uname`" in
     ;;
 esac
 
-CLASSPATH=$APP_HOME/lib/javafbp-4.1.5.jar:$APP_HOME/lib/gson-2.8.6.jar:$APP_HOME/lib/mysql-connector-java-8.0.21.jar:$APP_HOME/lib/protobuf-java-3.11.4.jar
+CLASSPATH=$APP_HOME/lib/javafbp-4.1.6.jar:$APP_HOME/lib/gson-2.8.6.jar:$APP_HOME/lib/mysql-connector-java-8.0.21.jar:$APP_HOME/lib/protobuf-java-3.11.4.jar
 
 
 # Determine the Java command to use to start the JVM.

build/distributions/javafbp-4.1.6.zip

@@ -82,7 +82,7 @@ set CMD_LINE_ARGS=%*
 :execute
 @rem Setup the command line
 
-set CLASSPATH=%APP_HOME%\lib\javafbp-4.1.5.jar;%APP_HOME%\lib\gson-2.8.6.jar;%APP_HOME%\lib\mysql-connector-java-8.0.21.jar;%APP_HOME%\lib\protobuf-java-3.11.4.jar
+set CLASSPATH=%APP_HOME%\lib\javafbp-4.1.6.jar;%APP_HOME%\lib\gson-2.8.6.jar;%APP_HOME%\lib\mysql-connector-java-8.0.21.jar;%APP_HOME%\lib\protobuf-java-3.11.4.jar
 
 
 @rem Execute javafbp

build/libs/javafbp-4.1.6-javadoc.jar

@@ -158,27 +158,38 @@ protected void execute() throws Exception {
 			    		System.out.println("Unexpected class in incoming IP: " + o.getClass());
 			    		continue;
 			    	}
-			    	String sqlInsert = "insert into " + iipContents[1] + " values (";
-			    	// iterate through fiArray
+			    	String sqlInsert = "insert into " + iipContents[1] + "(";
+			    	String sqlValues = " values(";
+			    	// iterate through hmColumns
 			    	String cma = ""; 
-			    	for (int i = 0; i < fiArray.length; i++) {
-			    		//String colName = fiArray[i].colName;
-						String objField = fiArray[i].objField;
-										
-						//System.out.println("JDBC: " + colName + " " + hmColumns.get(colName));
-						
-						//System.out.println("Obj: " + objField + " " + hmFields.get(objField));
-						
-						//String objFType = hmFields.get(objField).toString();
-						
-						Field field = curClass.getDeclaredField(objField);						
-						sqlInsert += cma + "\"" + field.get(o).toString() + "\"";
-						cma = ",";
-			    	} 
-			    	sqlInsert += ")";
+					for (String col : hmColumns.keySet()) {
+						Field field = null;
+						for (int i = 0; i < fiArray.length; i++) {
+							// String colName = fiArray[i].colName;
+							String objField = fiArray[i].objField;
+							if (fiArray[i].colName.equals(col)) {
+								field = curClass.getDeclaredField(objField);
+								break;								
+							}
+						}
+
+							if (field == null) {
+								System.out.println("Table column \"" + col + 
+										"\" not found in Field Info:" +
+										fldsStr);
+								return;										
+							}
+														
+							sqlInsert += cma + col;
+							sqlValues += cma + "\"" + field.get(o).toString() + "\"";
+							cma = ",";						 
+					}
+					sqlInsert += ")";
+			    	sqlValues += ")";
 			    	 //String sqlInsert = "insert into sales values (3001, 'Gone Fishing', 'Kumar', 'CAD11.11', 11)";
-			        System.out.println("The SQL statement is: " + sqlInsert + "\n");  // Echo for debugging
-			        int countInserted = stmt.executeUpdate(sqlInsert);
+			        System.out.println("The SQL statement is: " + sqlInsert + " " +
+			    	 sqlValues + "\n");  // Echo for debugging
+			        int countInserted = stmt.executeUpdate(sqlInsert + " " + sqlValues);
 			        if (countInserted != 1) {
 			        	System.out.println("Couldn't insert record:\n");
 			        	System.out.println("... " + sqlInsert);