java获取压缩文件中的XML并解析保存到数据库

更新时间：2025年06月11日 10:21:41 作者：cccl.

这篇文章主要为大家详细介绍了如何使用java实现获取压缩文件中的XML并解析保存到数据库,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下

实体类(ResourceLib)

import lombok.Data;

@Data
public class ResourceLib {
    private String MC; //名称
    private String TIME;//时间
    private String PRODUCTS_ID;//id
}

实现类

package com.idea.satresoure.util;

import com.idea.satresoure.vo.ResourceLib;
import org.dom4j.Document;
import org.dom4j.Element;
import org.dom4j.io.SAXReader;
import org.springframework.beans.factory.annotation.Value;

import java.io.*;
import java.nio.charset.Charset;
import java.sql.*;
import java.util.ArrayList;
import java.util.List;
import java.util.zip.ZipEntry;
import java.util.zip.ZipFile;
import java.util.zip.ZipInputStream;



public class ReadXMLFromZIP {

@Value("${FileXml_Path}")
private static String FileXml_Path;  //临时新建XML文件地址

private static String url = "数据库Url路径";
private static String Parent_id = "";//主键ID(根据实际需求可有可无)
/**
 * 获取压缩文件里的XML并进行解析
 * @param file
 * @throws Exception
 */
public static void readZipFile(String file,String Parentid) throws Exception {
    Parent_id = Parentid;
    readZipFile(new File(file));
}
public static void readZipFile(File file) throws Exception {
    ZipFile zf = new ZipFile(file, Charset.forName("GBK"));
    InputStream in = new BufferedInputStream(new FileInputStream(file));
    ZipInputStream zis = new ZipInputStream(in);
    ZipEntry ze;
    while ((ze = zis.getNextEntry()) != null) {
        if (ze.isDirectory()) {
        }else {
            if (ze.getName().endsWith(".xml")) {
                // 不解压直接读取size为-1
                if (ze.getSize() == -1) {
                    ByteArrayOutputStream baos = new ByteArrayOutputStream();
                    while (true) {
                        int bytes = zis.read();
                        if (bytes == -1) {
                            break;
                        }
                        baos.write(bytes);
                    }
                    baos.close();
                } else {
                    // ZipEntry的size正常
                    byte[] bytes = new byte[(int) ze.getSize()];
                    zis.read(bytes, 0, (int) ze.getSize());
                    //新建xml
                    File file1 = new File(FileXml_Path);
                    PrintWriter pw = new PrintWriter(file1);
                    pw.println(new String(bytes));
                    pw.close();
                    System.out.println("开始解析xml----");
                    List<ResourceLib> listnode = getXml(FileXml_Path);
                    if (file1.exists()){
                        file1.delete();
                    }
                    System.out.println("解析xml完成----");
                    //调用writeToMysql方法保存至数据库
                    writeToMysql(listnode);
                }
            } else if (ze.getName().endsWith("zip")) {
                //判断是否为压缩包，若是则将其解压出再读取
                String fileName = file.getName().substring(0, file.getName().lastIndexOf("."));
                File temp = new File(file.getParent() + File.separator + fileName + File.separator + ze.getName());
                if (!temp.getParentFile().exists()) {
                    temp.getParentFile().mkdirs();
                }
                OutputStream os = new FileOutputStream(temp);
                //通过ZipFile的getInputStream方法拿到具体的ZipEntry的输入流
                InputStream is = zf.getInputStream(ze);
                int len;
                while ((len = is.read()) != -1) {
                    os.write(len);
                }
                os.close();
                is.close();
                // 递归调取解压
                readZipFile(temp.getPath(),Parent_id);
            }
        }
    }
    zis.closeEntry();
    zis.close();
    zf.close();
}


/**
 * 解析XML
 * @param filePath
 * @return
 * @throws IOException
 */
private static List<ResourceLib> getXml(String filePath) throws IOException {
    //解析
    SAXReader reader = new SAXReader();
    List<ResourceLib> listnode = new ArrayList<>();
    try {
        Document doc = reader.read(filePath);
        Element root=doc.getRootElement();//获取根节点
        System.out.println(root.getName());//打印根节点root
        List<Element> list = root.elements();//所有root下第一子节点存进一个集合中
        //遍历节点
        for (Element e : list) {
            ResourceLib resourceLib = new ResourceLib();//放在循环里面，循环完一个后接着下一个
            System.out.println(e.getName());//获取根结点下第一根子节点
            resourceLib.setTIME(e.elementText("sj"));
            resourceLib.setMC(e.elementText("mc"));
            listnode.add(resourceLib);
        }
    } catch (Exception e) {
        e.printStackTrace();
    }
    return listnode;
}


/**
 * 保存到数据库
 * @param resourceLibs
 */
public static void writeToMysql(List<ResourceLib> resourceLibs) {
    Connection conn = null;
    try {
        // 加载MySql的驱动类
        Class.forName("com.mysql.jdbc.Driver");
    } catch (ClassNotFoundException e) {
        System.out.println("找不到驱动程序类 ，加载驱动失败！");
        e.printStackTrace();
    }
    //2.建立连接
    Statement st = null;
    //调用DriverManager对象的getConnection()方法，获得一个Connection对象
    Connection con  =null;
    try {
        //建立数据库连接
        con = DriverManager.getConnection(url, "root", "123456");
        for (int i=0;i<resourceLibs.size();i++){
            String Parentid = Parent_id;
            String SJ= resourceLibs.get(i).getTIME();
            String MC = resourceLibs.get(i).getMBMC();
            //插入语句格式;
            String sql = "insert into resourcelib(sj,Parentid,mc) values(\""+SJ+"\",\""+Parentid+"\",\""+MC+"\")";
            System.out.println(sql);
            st =  con.createStatement(); //创建一个Statement对象
            st.executeUpdate(sql);//提交数据更新
        }

    } catch (SQLException e) {
        e.printStackTrace();
    }finally{
        try {
            st.close();
            con.close();
        } catch (SQLException e) {
            e.printStackTrace();
         }
     }
  }	
}

方法补充

下面小编为大家整理了Java读取zip压缩包下xml文件的相关方法，有需要的可以参考一下

方法一：

1.主方法入口

这里省略controller层直接进来，读取端上传的文件，添加非空判断。inputStream流通过自定义工具类的转换方法转成file文件，再将其转为ZipFile进行循环读取。

/**
 * 读取传入的xml
 */
public Result readXml(MultipartFile multipartFile) throws Exception {
    // 判断是否有文件
    if (multipartFile == null || multipartFile.isEmpty()) {
        return Result.failed("请选择要导入的文件");
    }
    File zipFile = new File(multipartFile.getOriginalFilename());
    // 将zip文件夹中文件通过inputStream形式存入zipFile
    FileUtil.inputStreamToFile(multipartFile.getInputStream(), zipFile);
    HashMap<String, JSONObject> map = readZipFile(zipFile);
    zipFile.delete();
    return Result.success(readXmlRespVO);
}

2.自定义工具类

import lombok.extern.slf4j.Slf4j;
import java.io.File;
import java.io.FileOutputStream;
import java.io.InputStream;
import java.io.OutputStream;
/**
 * @author yhl
 * @date 2023/7/19 17:49
 */
@Slf4j
public class FileUtil {

    public static void inputStreamToFile(InputStream ins, File file) {
        try {
            OutputStream os = new FileOutputStream(file);
            int bytesRead = 0;
            byte[] buffer = new byte[8192];
            while ((bytesRead = ins.read(buffer, 0, 8192)) != -1) {
                os.write(buffer, 0, bytesRead);
            }
            os.flush();
            os.close();
            ins.close();
        } catch (Exception e) {
            log.error(" FileUtil下 --> inputStreamToFile() 异常 {}",e);
        }
    }
}

3.主体解析方法

public HashMap<String, JSONObject> readZipFile(File file) throws Exception {
        ZipFile zip = new ZipFile(file, Charset.forName("GBK"));
        InputStream in = new BufferedInputStream(new FileInputStream(file));
        ZipInputStream zis = new ZipInputStream(in);
        HashMap<String, JSONObject> map = new HashMap<>();
        // 循环zip包下的文件,只读取后缀是xml格式的
        for (Enumeration enumeration = zip.entries(); enumeration.hasMoreElements(); ) {
            ZipEntry ze = (ZipEntry) enumeration.nextElement();
            if (ze.getName().endsWith(".xml") && ze.getSize() > 0) {
                log.info("file - " + ze.getName() + " : " + ze.getSize() + " bytes");
                BufferedReader br = new BufferedReader(new InputStreamReader(zip.getInputStream(ze), StandardCharsets.UTF_8));
                // 解析读取xml
                StringBuffer reqXmlData = new StringBuffer();
                String s;
                while ((s = br.readLine()) != null) {
                    reqXmlData.append(s);
                }
                br.close();
                JSONObject jsonObject = XML.toJSONObject(reqXmlData.toString());
                map.put(ze.getName(), jsonObject);
                log.info("JSONObject {}", JacksonUtil.toJsonString(jsonObject));
            }
        }
        zis.closeEntry();
        zis.close();
        zip.close();
        return map;
    }

方法二：

完整代码

import java.io.BufferedReader;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.io.StringReader;
import java.util.Enumeration;
import java.util.zip.ZipEntry;
import java.util.zip.ZipFile;
import javax.xml.parsers.DocumentBuilder;
import javax.xml.parsers.DocumentBuilderFactory;
import org.w3c.dom.Document;
import org.xml.sax.InputSource;

public class ZipXmlReader {
    public static void main(String[] args) {
        String zipFilePath = "path/to/your/zip/file.zip";
        try {
            ZipFile zipFile = new ZipFile(zipFilePath);
            Enumeration<? extends ZipEntry> entries = zipFile.entries();
            while (entries.hasMoreElements()) {
                ZipEntry entry = entries.nextElement();
                if (!entry.isDirectory() && entry.getName().endsWith(".xml")) {
                    InputStream inputStream = zipFile.getInputStream(entry);
                    BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream));
                    String line;
                    StringBuilder xmlContent = new StringBuilder();
                    while ((line = reader.readLine()) != null) {
                        xmlContent.append(line);
                    }
                    reader.close();
                    DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance();
                    DocumentBuilder builder = factory.newDocumentBuilder();
                    Document document = builder.parse(new InputSource(new StringReader(xmlContent.toString())));
                    // 处理解析后的xml文件
                    // ...
                }
            }
            zipFile.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

到此这篇关于java获取压缩文件中的XML并解析保存到数据库的文章就介绍到这了,更多相关java xml获取与解析内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！

您可能感兴趣的文章:

java
xml

SpringCloud Config统一配置中心问题分析解决与客户端动态刷新实现
springcloud config是一个解决分布式系统的配置管理方案。它包含了 client和server两个部分，server端提供配置文件的存储、以接口的形式将配置文件的内容提供出去，client端通过接口获取数据、并依据此数据初始化自己的应用
2022-10-10
Spring AOP概念及原理解析
这篇文章主要介绍了Spring AOP概念及原理 ,通过使用 Spring AOP 实现日志管理,我们可以将日志记录的逻辑从业务逻辑中分离出来,简化了代码的维护,需要的朋友可以参考下
2024-07-07
Java java.lang.InstantiationException异常案例详解
这篇文章主要介绍了Java java.lang.InstantiationException异常案例详解,本篇文章通过简要的案例,讲解了该项技术的了解与使用,以下就是详细内容,需要的朋友可以参考下
2021-08-08
Netty事件循环主逻辑NioEventLoop的run方法分析
这篇文章主要介绍了Netty事件循环主逻辑NioEventLoop的run方法分析，有需要的朋友可以借鉴参考下，希望能够有所帮助，祝大家多多进步，早日升职加薪
2022-03-03
SpringBoot解析yml全流程详解
本文主要介绍了SpringBoot解析yml全流程详解，文中通过示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2022-03-03
springboot连接sqllite遇到的坑及解决
这篇文章主要介绍了springboot连接sqllite遇到的坑及解决方案，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2022-06-06
Java instanceof用法详解及实例代码
这篇文章主要介绍了Java instanceof用法详解及实例代码的相关资料,需要的朋友可以参考下
2017-02-02
Java 发送http请求（get、post）的示例
这篇文章主要介绍了Java 发送http请求的示例，帮助大家更好的理解和使用Java，感兴趣的朋友可以了解下
2020-10-10
Spring Boot项目如何使用Maven打包并带上依赖
在这篇博客中，介绍如何使用Maven将Spring Boot项目及其依赖项打包成一个可执行的jar文件。我们将使用Spring Boot的spring-boot-maven-plugin插件来完成这个任务，感兴趣的朋友跟随小编一起看看吧
2023-06-06
idea2023.3安装及配置详细图文教程
IDEA全称IntelliJ IDEA,是Java语言对的集成开发环境,IDEA在业界被认为是公认最好的Java开发工具,这篇文章主要给大家介绍了关于idea2023.3安装及配置的相关资料,需要的朋友可以参考下
2023-11-11

java获取压缩文件中的XML并解析保存到数据库

相关文章

最新评论

大家感兴趣的内容

最近更新的内容

常用在线小工具