переместить данные в формате csv в zip-архив в качестве объектов zipentry - конструктор ZipEntry (Path) не определен - PullRequest
0 голосов
/ 07 июня 2019

У меня есть этот метод в моем приложении springboot, которое генерирует 3 CSV-файла (связанных с Employee, Customer и Building) в каталоге custom_users с меткой времени, добавленной к его имени, как показано ниже.Следующий код прекрасно работает для меня.

public void sendMessage(String msg) throws DaoException {

    DataSource ds = null;
    Connection conn = null;
    PreparedStatement pstmt = null;
    PreparedStatement pstmtEmployee = null;
    PreparedStatement pstmtCompany = null; 
    PreparedStatement pstmBuilding = null; 

    ResultSet rs = null;
    ResultSet rsDemo = null;
    ResultSet rsCompany = null;
    ResultSet rsBuildings = null;


     String[] parts = msg.split("#");
     String requestID = parts[0].trim();
     String userName = parts[1].trim();
     String applicationName = parts[2].trim();

    logger.info("Request ID "+requestID);
    logger.info("User Name "+userName);
    logger.info("Application Name "+applicationName);



     try {

            ds = jdbcTemplate.getDataSource();
            conn = ds.getConnection();  

            /*===========================================================================*/
            /*    Code to generate a employee CSV file              */ 
            /*===========================================================================*/
            pstmtEmployee = conn.prepareStatement(getPatientEmployeeSQL);
            pstmtEmployee.setString(1, requestID);
            rsDemo = pstmtEmployee.executeQuery();

            ResultSetMetaData rsmd = rsDemo.getMetaData();



             Path dir = Paths.get("/srv/custom_users", userName);
             Files.createDirectories(dir);

             Path file = dir.resolve("employee_custom_file" + unixTimestamp + ".csv");
             try (CSVWriter writer = new CSVWriter(Files.newBufferedWriter(file))) {
                 writer.writeAll(rsDemo, true);
             }

             logger.info("Employee File Generated");


             /*===========================================================================*/
             /*    Code to generate a company CSV file                                      */ 
             /*===========================================================================*/

            pstmtCompany = conn.prepareStatement(getCompanySQL);
            pstmtCompany.setString(1, requestID);
            rsCompany = pstmtCompany.executeQuery();

            ResultSetMetaData rsmdFacts = rsCompany.getMetaData();


             Path filecompany = dir.resolve("company_custom_file_" + unixTimestamp + ".csv");
             try (CSVWriter writer = new CSVWriter(Files.newBufferedWriter(filecompany))) {
                 writer.writeAll(rsCompany, true);
             }

             logger.info("Company CSV File Generated");


             /*===========================================================================*/
             /*    Code to generate a building CSV file                                 */ 
             /*===========================================================================*/

             pstmBuilding = conn.prepareStatement(getBuildingSQL);
              pstmBuilding.setString(1, requestID);
              rsBuildings = pstmBuilding.executeQuery();

               ResultSetMetaData rsmdBuildings = rsBuildings.getMetaData();


                Path fileBuildings = dir.resolve("building_custom_file_" + unixTimestamp + ".csv");
                 try (CSVWriter writer = new CSVWriter(Files.newBufferedWriter(fileBuildings))) {
                     writer.writeAll(rsBuildings, true);
                 }

                logger.info("Buildings CSV File Generated");




            }
        catch(Throwable th) {
            throw new DaoException(th.getMessage(), th);
        }
        finally {
            //resource closing statements

        }   



}

Мои вопросы:

Я пытаюсь изменить конструктор CSVWriter таким образом, чтобыДанные CSV должны идти непосредственно в ZIP-архив как объекты ZipEntry.

Поэтому я внес изменения в приведенный выше код (это видно после этой строки ResultSetMetaData rsmd = rsDemo.getMetaData(); в приведенном ниже коде).Сейчас я просто пытаюсь поместить один файл в ZIP-архив для проверки, но я заметил следующие ошибки:

Ошибка в строке # 173 говорит: Конструктор ZipEntry (Путь) не определен.

Ошибка в строке # 175 говорит: Несколько маркеров в этой строке (одна из двух ошибок - конструктор CSVWriter (ZipOutputStream) не определен).

Скриншот из моего затмения: enter image description here

Как мне обращаться с конструктором ZipEntry и CSVWriter?

public void sendMessage(String msg) throws DaoException {

        DataSource ds = null;
        Connection conn = null;
        PreparedStatement pstmt = null;
        PreparedStatement pstmtEmployee = null;
        PreparedStatement pstmtCompany = null; 
        PreparedStatement pstmBuilding = null; 

        ResultSet rs = null;
        ResultSet rsDemo = null;
        ResultSet rsCompany = null;
        ResultSet rsBuildings = null;


         String[] parts = msg.split("#");
         String requestID = parts[0].trim();
         String userName = parts[1].trim();
         String applicationName = parts[2].trim();

        logger.info("Request ID "+requestID);
        logger.info("User Name "+userName);
        logger.info("Application Name "+applicationName);



         try {

                ds = jdbcTemplate.getDataSource();
                conn = ds.getConnection();  

                /*===========================================================================*/
                /*    Code to generate a employee CSV file              */ 
                /*===========================================================================*/
                pstmtEmployee = conn.prepareStatement(getPatientEmployeeSQL);
                pstmtEmployee.setString(1, requestID);
                rsDemo = pstmtEmployee.executeQuery();

                ResultSetMetaData rsmd = rsDemo.getMetaData();

                 FileOutputStream fos = new FileOutputStream("your_files.zip");
                 BufferedOutputStream bos = new BufferedOutputStream(fos);
                 ZipOutputStream zos = new ZipOutputStream(bos);

                 Path dir = Paths.get("/srv/custom_users", userName);
                 Files.createDirectories(dir);

                 Path file = dir.resolve("employee_custom_file" + unixTimestamp + ".csv");
                 /*try (CSVWriter writer = new CSVWriter(Files.newBufferedWriter(file))) {
                     writer.writeAll(rsDemo, true);
                 }*/
                 ZipEntry entry = new ZipEntry(file);
                 zos.putNextEntry(entry);
                 try (CSVWriter writer = new CSVWriter(zos)) {
                     writer.writeAll(rsDemo, true);
                 }


                 logger.info("Employee File Generated");



                 /*===========================================================================*/
                 /*    Code to generate a company CSV file                                      */ 
                 /*===========================================================================*/

                pstmtCompany = conn.prepareStatement(getCompanySQL);
                pstmtCompany.setString(1, requestID);
                rsCompany = pstmtCompany.executeQuery();

                ResultSetMetaData rsmdFacts = rsCompany.getMetaData();


                 Path filecompany = dir.resolve("company_custom_file_" + unixTimestamp + ".csv");
                 try (CSVWriter writer = new CSVWriter(Files.newBufferedWriter(filecompany))) {
                     writer.writeAll(rsCompany, true);
                 }

                 logger.info("Company CSV File Generated");


                 /*===========================================================================*/
                 /*    Code to generate a building CSV file                                 */ 
                 /*===========================================================================*/

                 pstmBuilding = conn.prepareStatement(getBuildingSQL);
                  pstmBuilding.setString(1, requestID);
                  rsBuildings = pstmBuilding.executeQuery();

                   ResultSetMetaData rsmdBuildings = rsBuildings.getMetaData();


                    Path fileBuildings = dir.resolve("building_custom_file_" + unixTimestamp + ".csv");
                     try (CSVWriter writer = new CSVWriter(Files.newBufferedWriter(fileBuildings))) {
                         writer.writeAll(rsBuildings, true);
                     }

                    logger.info("Buildings CSV File Generated");




                }
            catch(Throwable th) {
                throw new DaoException(th.getMessage(), th);
            }
            finally {
                //resource Closing statements

            }   



    }

1 Ответ

0 голосов
/ 07 июня 2019

Конструктор ZipEntry ожидает либо String, либо другой ZipEntry, отметьте здесь .

CSVWriter, предполагая, что вы используете opencsv, ожидает класс, который реализует интерфейс Writer, проверьте здесь .

Таким образом, вы должны использовать (не проверено):

ZipEntry entry = new ZipEntry(file.toString());

и

try (CSVWriter writer = new CSVWriter(new OutputStreamWriter(zos))) {
    ...
}
...