Spring boot 集成poi 把页面上的数据插入到数据库中。

﹏ヽ暗。殇╰゛Y 2022-05-11 03:12 63阅读 0赞

### 前言： ###

今天做了一个小小的要求的时候运用这种情况，需要把HTMl 页面上的数据插入到数据库中。

先说一下什么样的数据和情况。

![70][]

这样的情况怎么搞呢。先说一下思路。根据这种情况的话。可以先把数据弄到excel ，然后操作excel表到数据库中去。这里也涉及到操作excel表。

### 步骤 ###

1.  先根据情况创建数据库表。上面图片中的其实都是英文的，我弄成了中文。创建表的时候要根据实际情况来设计，避免过多的内存浪费。
    
        CREATE TABLE `carriers` (
          `id` int(10) unsigned NOT NULL AUTO_INCREMENT,
          `mcc` char(3) NOT NULL,
          `mnc` varchar(3) NOT NULL,
          `country_iso` char(4) CHARACTER SET dec8 COLLATE dec8_swedish_ci NOT NULL,
          `country` varchar(64) NOT NULL,
          `country_code` int(11) NOT NULL DEFAULT '0',
          `network` varchar(128) CHARACTER SET dec8 COLLATE dec8_swedish_ci NOT NULL DEFAULT '',
          `status` tinyint(1) NOT NULL DEFAULT '1',
          `is_delete` tinyint(1) NOT NULL DEFAULT '0',
          `t_version` int(11) NOT NULL,
          `update_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
          `create_time` timestamp NOT NULL DEFAULT CURRENT_TIMESTAMP,
          PRIMARY KEY (`id`)
        ) ENGINE=InnoDB DEFAULT CHARSET=dec8
    
     
2.   把页面上的数据弄到excel 表中。这里有一点情况，先看一下。  
    ![70 1][]
    
    上面框出来的是页面上的数据内容，复制这样的内容到excel 表会把值变成数字  
    ![70 2][]  
    我想把复制到excel的内容原样复制进来。这个内容有1900条，我就不复制那么多了，就弄关键的就行了。  
    先把excel 表的单元格格式换成文本格式,怎么把单元格弄成文本格式呢。  
    ![70 3][]  
    ![70 4][]  
    单元格就设置好了。然后把页面上的内容复制进来。  
    ![70 5][]  
    然后根据上图点击，把内容原样复制过来。
3.  创建Springboot项目,其实随便弄个带有main方法的Maven项目就可以了，因为只需要poi的jar依赖嘛。  
      
    ![70 6][]  
    我这里用过来Spring boot
4.  引入依赖。主要的关键依赖，  
     
    
        <dependency>
                    <groupId>mysql</groupId>
                    <artifactId>mysql-connector-java</artifactId>
                    <version>8.0.11</version>
                    
                </dependency>
        
                <dependency>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-starter-jdbc</artifactId>
                </dependency>
        
                <dependency>
                    <groupId>org.apache.poi</groupId>
                    <artifactId>poi</artifactId>
                    <version>4.0.0</version>
                </dependency>
        
                <dependency>
                    <groupId>org.apache.poi</groupId>
                    <artifactId>poi-ooxml</artifactId>
                    <version>4.0.0</version>
                </dependency>
    
    配置配置文件  
    ![70 7][]  
    注意Url后面需要添加这些东西，为什么要添加请看我的另外2篇。
5.  创建与数据库对应的实体类,这里的@Data引入了lombok,省去set/get，因为我习惯操作对象，所以创建了实体类。有的大神根据实际情况来获取excel  
     
    
        @Data
        public class ImportData {
        
            private String mcc;
            private String mnc;
            private String country_iso;
            private String country;
            private String country_code;
            private String network;
        }
    
     
6.  把excel的每一行都转换成对象。这里我做了一个工具类。  
     
    
        public class ReadExcel {
        
            public static List<ImportData> getAllData(String path) {
                try {
                    XSSFWorkbook wb = new XSSFWorkbook(new FileInputStream(new File(path)));            //根据路径获取这个操作excel的实例
                    XSSFSheet sheet = wb.getSheetAt(0);                                       //根据页面index 获取sheet页
                    XSSFRow row = null;
                    List<ImportData> importDatas = new ArrayList<>();                                   //创建List存放多个list
                    for (int i = 0; i < sheet.getPhysicalNumberOfRows(); i++) {
                        row = sheet.getRow(i);                                                          //获取每一行
                        ImportData data = new ImportData();                                             //没一行一个对象，可优化
                        Field[] fields = data.getClass().getDeclaredFields();                           //通过反射获取字段
                        for (int j = 0; j < row.getPhysicalNumberOfCells(); j++) {
                            fields[j].setAccessible(true);                                              //能操作私有化的字段
                            row.getCell(j).setCellType(CellType.STRING);                                //把获取的每一单元格都设置成String
                            fields[j].set(data, row.getCell(j).getStringCellValue());                   //设置每个字段对应的单元格
                        }
                        importDatas.add(data);                                                          //把每个对象装进list里面
                    }
                    return importDatas;                                                                 //返回这个对象的集合(list)
                } catch (IOException e) {
                    e.printStackTrace();
                    System.out.println("没有找到文件");
                    return null;
                } catch (IllegalAccessException e) {
                    e.printStackTrace();
                    return null;
                }
            }
        }
    
     
7.  测试批量插入到数据库  
     
    
        @RunWith(SpringRunner.class)
        @SpringBootTest
        public class ImportdataApplicationTests {
        
            @Autowired
            private NamedParameterJdbcTemplate namedParameterJdbcTemplate;
        
            @Test
            public void contextLoads() {
                String path = "C:\\Users\\ASUS\\Desktop\\cms.xlsx";
                List<ImportData> allData = ReadExcel.getAllData(path);
                System.out.println(allData.size());
                allData.stream().forEach(data -> {
                    if("".equals(data.getCountry_code())){
                        data.setCountry_code("0");
                    }
                });
                String sql = "insert into carriers (mcc,mnc,country_iso,country,country_code,network,t_version)" +
                        " values (:mcc,:mnc,:country_iso,:country,:country_code,:network,1)";
                SqlParameterSource[] batch = SqlParameterSourceUtils.createBatch(allData.toArray());
                namedParameterJdbcTemplate.batchUpdate(sql, batch);
            }
        
        }
    
    启动测试，数据库查看结果  
    ![70 8][]

[70]: /images/20220511/7f9ef95bf67546bea286b02d943bc677.png
[70 1]: /images/20220511/98a062fb60ed4881baa3bf540640dd25.png
[70 2]: /images/20220511/7b568ed931524a50b48e2a6fa10fdf9f.png
[70 3]: /images/20220511/ff428e9a7cee468b8505c92028cef436.png
[70 4]: /images/20220511/a8fce04e87e846b19e294dd3326b1a09.png
[70 5]: /images/20220511/728d1a823e844da0a6d739973a56d707.png
[70 6]: /images/20220511/8584a7036d954be58ef3942b7ba0147e.png
[70 7]: /images/20220511/33407a523fb0496aa6298f0425e4695d.png
[70 8]: /images/20220511/c37adaf9a22a42dd9ab7b601282a1e25.png