public void execute()

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();
        }
    }