svn commit: r924208 - /ofbiz/trunk/framework/datafile/src/org/ofbiz/datafile/RecordIterator.java

Previous Topic Next Topic
 
classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

svn commit: r924208 - /ofbiz/trunk/framework/datafile/src/org/ofbiz/datafile/RecordIterator.java

jleroux@apache.org
Author: jleroux
Date: Wed Mar 17 10:26:56 2010
New Revision: 924208

URL: http://svn.apache.org/viewvc?rev=924208&view=rev
Log:
Reformatted and cleaned following best practices

Modified:
    ofbiz/trunk/framework/datafile/src/org/ofbiz/datafile/RecordIterator.java

Modified: ofbiz/trunk/framework/datafile/src/org/ofbiz/datafile/RecordIterator.java
URL: http://svn.apache.org/viewvc/ofbiz/trunk/framework/datafile/src/org/ofbiz/datafile/RecordIterator.java?rev=924208&r1=924207&r2=924208&view=diff
==============================================================================
--- ofbiz/trunk/framework/datafile/src/org/ofbiz/datafile/RecordIterator.java (original)
+++ ofbiz/trunk/framework/datafile/src/org/ofbiz/datafile/RecordIterator.java Wed Mar 17 10:26:56 2010
@@ -26,11 +26,9 @@ import java.io.InputStreamReader;
 import java.net.URL;
 import java.util.Stack;
 
-import org.ofbiz.base.util.Debug;
-
-
 /**
  *  Record Iterator for reading large files
+ *  Note: this is a memory intensive and will not handle files that exceed memory.
  *
  */
 
@@ -76,7 +74,6 @@ public class RecordIterator {
         } catch (Exception e) {
             throw new DataFileException("UTF-8 is not supported");
         }
-
         // get the line seeded
         this.getNextLine();
     }
@@ -93,7 +90,6 @@ public class RecordIterator {
             if (modelDataFile.recordLength <= 0) {
                 throw new DataFileException("Cannot read a fixed record length file if no record length is specified");
             }
-
             try {
                 char[] charData = new char[modelDataFile.recordLength + 1];
 
@@ -112,8 +108,8 @@ public class RecordIterator {
         } else {
             try {
                 nextLine = br.readLine();
-                Debug.logInfo("br.readLine()=\"" + nextLine + "\"", module);
-                } catch (IOException e) {
+                //Debug.logInfo("br.readLine()=\"" + nextLine + "\"", module);
+            } catch (IOException e) {
                 throw new DataFileException("Error reading line #" + nextLineNum + " from location: " + locationInfo, e);
             }
         }
@@ -141,7 +137,6 @@ public class RecordIterator {
     public boolean hasNext() {
         //return nextLine != null && !(eof.equals(nextLine.substring(0,1)) && 1 == nextLine.length());
         return nextLine != null && !((nextLine.contains(eof) ) );
-
     }
 
     public Record next() throws DataFileException {
@@ -152,7 +147,6 @@ public class RecordIterator {
         if (ModelDataFile.SEP_DELIMITED.equals(modelDataFile.separatorStyle) || ModelDataFile.SEP_FIXED_RECORD.equals(modelDataFile.separatorStyle) || ModelDataFile.SEP_FIXED_LENGTH.equals(modelDataFile.separatorStyle)) {
             boolean isFixedRecord = ModelDataFile.SEP_FIXED_RECORD.equals(modelDataFile.separatorStyle);
             // if (Debug.infoOn()) Debug.logInfo("[DataFile.readDataFile] separatorStyle is " + modelDataFile.separatorStyle + ", isFixedRecord: " + isFixedRecord, module);
-
             // advance the line (we have already checked to make sure there is a next line
             this.curLine = this.nextLine;
             this.curRecord = this.nextRecord;
@@ -183,18 +177,15 @@ public class RecordIterator {
                             parentRecord = null;
                         }
                     }
-
                     if (parentRecord == null) {
                         throw new DataFileException("Expected Parent Record not found for line " + this.getCurrentLineNumber() + "; record name of expected parent is " + this.nextRecord.getModelRecord().parentName);
                     }
-
                     parentRecord.addChildRecord(this.nextRecord);
 
                     // if the child record we just added is also a parent, push it onto the stack
                     if (this.nextRecord.getModelRecord().childRecords.size() > 0) {
                         parentStack.push(this.nextRecord);
                     }
-
                     // if it can't find a next line it will nextRecord will be null and the loop will break out
                     this.getNextLine();
                 }
@@ -202,7 +193,6 @@ public class RecordIterator {
         } else {
             throw new DataFileException("Separator style " + modelDataFile.separatorStyle + " not recognized.");
         }
-
         return curRecord;
     }
 
@@ -231,12 +221,10 @@ public class RecordIterator {
         ModelRecord modelRecord = null;
 
         for (ModelRecord curModelRecord: modelDataFile.records) {
-
             if (curModelRecord.tcPosition < 0) {
                 modelRecord = curModelRecord;
                 break;
             }
-
             String typeCode = line.substring(curModelRecord.tcPosition, curModelRecord.tcPosition + curModelRecord.tcLength);
 
             // try to match with a single typecode
@@ -251,7 +239,6 @@ public class RecordIterator {
                 if (curModelRecord.tcIsNum) {
                     // if (Debug.infoOn()) Debug.logInfo("[DataFile.findModelForLine] Doing ranged number typecode match - minNum=" + curModelRecord.tcMinNum + ", maxNum=" + curModelRecord.tcMaxNum + ", filelinecode=" + typeCode, module);
                     long typeCodeNum = Long.parseLong(typeCode);
-
                     if ((curModelRecord.tcMinNum < 0 || typeCodeNum >= curModelRecord.tcMinNum) &&
                             (curModelRecord.tcMaxNum < 0 || typeCodeNum <= curModelRecord.tcMaxNum)) {
                         modelRecord = curModelRecord;
@@ -259,8 +246,7 @@ public class RecordIterator {
                     }
                 } else {
                     // if (Debug.infoOn()) Debug.logInfo("[DataFile.findModelForLine] Doing ranged String typecode match - min=" + curModelRecord.tcMin + ", max=" + curModelRecord.tcMax + ", filelinecode=" + typeCode, module);
-                    if ((typeCode.compareTo(curModelRecord.tcMin) >= 0) &&
-                            (typeCode.compareTo(curModelRecord.tcMax) <= 0)) {
+                    if ((typeCode.compareTo(curModelRecord.tcMin) >= 0) && (typeCode.compareTo(curModelRecord.tcMax) <= 0)) {
                         modelRecord = curModelRecord;
                         break;
                     }
@@ -276,4 +262,3 @@ public class RecordIterator {
         return modelRecord;
     }
 }
-