Cache tuple column types.

This speeds up writing when many tuples have to be written.

Author: Daniel Junglas

lib/jdbc-custom-data-source.jar

@@ -102,16 +102,14 @@ String getInsertQuery(IloTupleSchema schema, String table) {
       return query;
     }
 
-    void updateValues(IloTuple tuple, IloTupleSchema schema, 
-                      IloOplTupleSchemaDefinition tupleSchemaDef, PreparedStatement stmt) throws SQLException {
-      for (int i = 0; i < schema.getSize(); i++) {
+    void updateValues(IloTuple tuple, PreparedStatement stmt, Type[] columnType) throws SQLException {
+      for (int i = 0; i < columnType.length; i++) {
           int index = i+1;  // index in PreparedStatement
-          Type columnType = tupleSchemaDef.getComponent(i).getElementDefinitionType();
-          if (columnType == Type.INTEGER)
+          if (columnType[i] == Type.INTEGER)
               stmt.setInt(index, tuple.getIntValue(i));
-          else if (columnType == Type.FLOAT)
+          else if (columnType[i] == Type.FLOAT)
               stmt.setDouble(index, tuple.getNumValue(i));
-          else if (columnType == Type.STRING)
+          else if (columnType[i] == Type.STRING)
               stmt.setString(index, tuple.getStringValue(i));
       }
     }
@@ -149,14 +147,17 @@ void customWrite(String name, String table) {
             try {
               IloOplElementDefinition tupleDef = _def.getElementDefinition(schema.getName());
               IloOplTupleSchemaDefinition tupleSchemaDef = tupleDef.asTupleSchema();
+              final Type[] columnType = new Type[schema.getSize()];
+              for (int i = 0; i < columnType.length; ++i)
+                  columnType[i] = tupleSchemaDef.getComponent(i).getElementDefinitionType();
 
               conn.setAutoCommit(false); // begin transaction
               String psql = getInsertQuery(schema, table);
               PreparedStatement pstmt = conn.prepareStatement(psql);
               // iterate the set and create the final insert statement
               for (java.util.Iterator it1 = tupleSet.iterator(); it1.hasNext();) {
                   IloTuple tuple = (IloTuple) it1.next();
-                  updateValues(tuple, schema, tupleSchemaDef, pstmt);
+                  updateValues(tuple, pstmt, columnType);
                   pstmt.executeUpdate();
               }
               conn.commit();
@@ -175,4 +176,4 @@ void customWrite(String name, String table) {
             }
         }
     }
-}
+}