如何用java POI将word中的内容导入到mysql数据库中

由于作业需要，要求我们将word文档中的数据直接导入到mysql中，在网上找了很常时间，终于将其解决。

由于比较初级，所以处理的word文档是那种比较规范的那种，条例比较清晰，设计的思路也比较简单，就是根据段落的内容判断每一段是标题还是内容，然后读完一条记录后直接像数据库中添加，知道最后都添加完成。代码如下：

本项目的结构如截图所示：

其中Bean.java里边是一个实体类，我将每一个新闻热词的标题，内容，分类都封装在一个类中，Dao.java是实现向数据库中插入数据的函数，DBUtil.java是链接数据库，WordToSql.java里边是具体的实现代码，test.java是一个测试类。

注：本人用的maven项目，需要导入一下依赖：

 <dependency>

      <groupId>org.apache.poi</groupId>

      <artifactId>poi-ooxml</artifactId>

      <version>3.8</version>

    </dependency>

    <dependency>

      <groupId>org.apache.poi</groupId>

      <artifactId>poi-scratchpad</artifactId>

      <version>3.8</version>

    </dependency>

    <dependency>

        <groupId>mysql</groupId>

        <artifactId>mysql-connector-java</artifactId>

        <version>5.1.38</version>

    </dependency>

Bean.java

package com.chry.WordToSql;

public class Bean {

    public String pian;

    public String zhang;

    public String title;

    public String content;

    public Bean(String pian, String zhang, String title, String content) {

        super();

        this.pian = pian;

        this.zhang = zhang;

        this.title = title;

        this.content = content;

    }

    public String getPian() {

        return pian;

    }

    public String getZhang() {

        return zhang;

    }

    public String getTitle() {

        return title;

    }

    public String getContent() {

        return content;

    }

    public void setPian(String pian) {

        this.pian = pian;

    }

    public void setZhang(String zhang) {

        this.zhang = zhang;

    }

    public void setTitle(String title) {

        this.title = title;

    }

    public void setContent(String content) {

        this.content = content;

    }

    public Bean() {

    }

    @Override

    public String toString() {

        return "Bean [pian=" + pian + ", zhang=" + zhang + ", title=" + title + ", content=" + content + "]";

    }

}

Dao.java

package com.chry.WordToSql;

import java.sql.Connection;

import java.sql.PreparedStatement;

import java.sql.SQLException;

public class Dao {

    public void add(Bean bean) {

        Connection connection = DBUtil.getConnection();

        PreparedStatement preparedStatement = null;

         String sql = "insert into data (pian,zhang,title,content) value (?,?,?,?)";

        try {

            preparedStatement = connection.prepareStatement(sql);

            preparedStatement.setString(1, bean.getPian());

            preparedStatement.setString(2, bean.getZhang());

            preparedStatement.setString(3, bean.getTitle());

            preparedStatement.setString(4, bean.getContent());

            preparedStatement.executeUpdate();

            System.out.println("插入成功");

        } catch (SQLException e) {

            // TODO Auto-generated catch block

            e.printStackTrace();

        }finally {

            DBUtil.close(preparedStatement);

            DBUtil.close(connection);

        }

    }

}

DBUtil.java

package com.chry.WordToSql;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

public class DBUtil {

public static Connection getConnection(){

 try {

    Class.forName("com.mysql.jdbc.Driver").newInstance();

} catch (InstantiationException e) {

    // TODO �Զ����ɵ� catch ��

    e.printStackTrace();

} catch (IllegalAccessException e) {

    // TODO �Զ����ɵ� catch ��

    e.printStackTrace();

} catch (ClassNotFoundException e) {

    // TODO �Զ����ɵ� catch ��

    e.printStackTrace();

}

 String user="root";

 String password="root";

 String url="jdbc:mysql://localhost:3306/bigdata";

 Connection connection=null;

 try {

    connection=DriverManager.getConnection(url, user, password);

} catch (SQLException e) {

    // TODO �Զ����ɵ� catch ��

    e.printStackTrace();

}

return connection;

}

public static void close(Connection connection)

{

 try {

     if(connection!=null)

     {

         connection.close();

     }

} catch (SQLException e) {

    // TODO �Զ����ɵ� catch ��

    e.printStackTrace();

}

}

public static void close(PreparedStatement preparedStatement)

{

 try {

     if(preparedStatement!=null)

     {

         preparedStatement.close();

     }

} catch (SQLException e) {

    // TODO �Զ����ɵ� catch ��

    e.printStackTrace();

}

}

public static void close(ResultSet resultSet)

{

 try {

     if(resultSet!=null)

     {

         resultSet.close();

     }

} catch (SQLException e) {

    // TODO �Զ����ɵ� catch ��

    e.printStackTrace();

}

}

}

注：链接数据库的用户名，密码，还有数据库的名称都要根据的情况进行修改。

WordToSql.java

package com.chry.WordToSql;

import java.io.File;

import java.io.FileInputStream;

import java.io.IOException;

import java.util.List;

import org.apache.poi.xwpf.extractor.XWPFWordExtractor;

import org.apache.poi.xwpf.usermodel.XWPFDocument;

import org.apache.poi.xwpf.usermodel.XWPFParagraph;

public class WordToSql {

    public static String pian;

    public static String zhang;

    public static void readAndWriterTest4() throws IOException {

        File file = new File("D:\\2.docx");

        String str = "";

        try {

            FileInputStream fis = new FileInputStream(file);

            XWPFDocument xdoc = new XWPFDocument(fis);

            List<XWPFParagraph> paras=xdoc.getParagraphs();

            Bean bean = new Bean();

            for(XWPFParagraph p : paras)//遍历段落

            {

            //获取段落的级别

                String jibie = p.getStyleID();

                if(jibie!=null) {

                    if(jibie.equals("8")) {

                        pian = p.getParagraphText();

                        bean.setPian(pian);

                    }else if(jibie.equals("9")) {

                        zhang = p.getParagraphText();

                        bean.setZhang(zhang);

                    }else if(jibie.equals("10")){       //判断的段落为标题

                        //System.out.println(bean.toString());

                        //写入数据库

                        Dao dao = new Dao();

                        dao.add(bean);
                        bean.setContent("");

                        String title = p.getParagraphText();

                        bean.setTitle(title);

                    }else {      //判断段落为正文

                        String content = p.getParagraphText();

                        if(bean.getContent()!=null) {

                            content = content + bean.getContent();

                        }

                        bean.setContent(content);

                    }

                }

            }

            fis.close();

            } catch (Exception e) {

                e.printStackTrace();

                }

        } 

    public static void main(String[] args) throws IOException {

        readAndWriterTest4();

    }

}

至此，便可以将一片word文档完整的导入数据库中，后续会进一步研究如何将更加复杂的word文档导入数据库中。

注：在word文档中，每个人的字号的级别都不太一样，所以可以先写一个测试函数，输出每个段落的字号，再去修改正式导入数据库中的代码，本博客是经过修正之后的。

如有问题，请留言。

巴特西

如何用java POI将word中的内容导入到mysql数据库中

最新文章

热门文章