Changeset 2403

Timestamp:

11/01/09 14:14:20 (2 years ago)

Author:

jvelde

Message:

 

File:

• molgenis/3.3/src/org/molgenis/framework/db/jdbc/AbstractJDBCMapper.java (modified) (2 diffs)

molgenis/3.3/src/org/molgenis/framework/db/jdbc/AbstractJDBCMapper.java

@@ -591 +591 @@
         }
 
-        public void find(CsvWriter writer, boolean skipIdFields, QueryRule... rules) throws DatabaseException
-        {
-                try
-                {
+        /**
+         * Reason for backup: function needs to be looked at - possible bug
+         * See other find() function below for explanation!
+         */
+        public void findBACKUP(CsvWriter writer, boolean skipIdFields, QueryRule... rules) throws DatabaseException
+        {
+                try
+                {
+                        System.out.println("new ResultSetTuple(executeSelect(rules)....");
                         ResultSetTuple rs = new ResultSetTuple(executeSelect(rules));
                         System.out.println("executeSelect(rules)");
@@ -666 +671 @@
                 }
         }
+        
+        public void find(CsvWriter writer, boolean skipIdFields, QueryRule... rules) throws DatabaseException
+        {
+                try
+                {
+                        System.out.println("new ResultSetTuple(executeSelect(rules)....");
+                        ResultSetTuple rs = new ResultSetTuple(executeSelect(rules));
+                        System.out.println("executeSelect(rules)");
+                        for(QueryRule q : rules){
+                                System.out.println("rule: " + q.toString());
+                        }
+                        // transform result set in writer
+                        E entity = create();
+                        Vector<String> fields;
+                        
+                        if (skipIdFields)
+                        {
+                                fields = entity.getFields();
+                                Vector<String> fieldsCopy = entity.getFields();
+                                fieldsCopy.remove("id");
+                                for(String field : fields){
+                                        if(hasXrefByNameEquivalent(field, fields)){
+                                                fieldsCopy.remove(field);
+                                        }
+                                }
+                                fields = fieldsCopy;
+                        }
+                        else
+                        {
+                                fields = entity.getFields();
+                        }
+                        writer.setHeaders(fields);
+                        writer.writeHeader();
+                        int i = 0;
+                        List<E> entityBatch = new ArrayList<E>();
+                        while (rs.next())
+                        {
+                                entity = create();
+                                entity.set(rs);
+                                entityBatch.add(entity);
+                                i++;
+
+                                // write batch
+                                if (i % BATCH_SIZE == 0)
+                                {
+                                        // load mrefs
+                                        try{
+                                        mapMrefs(entityBatch);
+                                        //FIXME: this FAILS because rs is open!! program ends without try-catch
+                                        //strange: problem seems to occur in very specific cases..
+                                        //reasons? speculation..
+                                        // a) either the function gets usually empty values and exits (no mrefs)
+                                        // b) the specific data causes an error that bugs the function, rs is not closed, and errors here
+                                        // c) ... ?
+                                        //is the function that opens another rs allowed here?
+                                        //ie. can it be executed at all? and why would it fail if it has been tested?
+                                        }
+                                        catch(Exception e){
+                                                e.printStackTrace();
+                                        }
+                                        for (E e : entityBatch)
+                                        {
+                                                writer.writeRow(e);
+                                        }
+                                        entityBatch.clear();
+                                }
+                        }
+                        // write remaining
+                        // load mrefs
+                        mapMrefs(entityBatch);
+                        for (E e : entityBatch)
+                        {
+                                writer.writeRow(e);
+                        }
+                        entityBatch.clear();
+
+                        rs.close();
+
+                        logger.debug("find(" + create().getClass().getSimpleName() + ", CsvWriter, " + Arrays.asList(rules)
+                                        + "): wrote " + i + " lines.");
+                }
+                catch (Exception e)
+                {
+                        throw new DatabaseException(e);
+                }
+                finally
+                {
+                        getDatabase().closeConnection();
+                }
+        }
 
         /**