in code-bugfixing/etl-processing/java/src/main/java/com/epam/poc/aicode/javabugfixing/etlprocessing/CsvEtlCommand.java [14:37]
public void execute() throws IOException {
BufferedReader reader = null;
BufferedWriter writer = null;
try {
reader = new BufferedReader(new FileReader(sourceFile));
writer = new BufferedWriter(new FileWriter(targetFile));
// Extract
String line = reader.readLine();
// Transform and Load
while (line != null) {
String[] columns = line.split(",");
var transformedLine = transform(columns);
writer.write(transformedLine + "\n");
line = reader.readLine();
}
} finally {
if (reader != null) reader.close();
if (writer != null) writer.close();
}
}