解析excel拼接SQL 小脚本

解析excel拼接SQL 小脚本

由于数据同步原因,我们经常会受到对方给的excel文件去同步字段到数据库

这种情况遇到过多次,如果数据量小还好,手动拼一下Sql,如果对方给的同步数据过大,那么我采用了一个小脚本处理这件事

其实非常简单,读取同步excel,同时根据字段转存为sql文件,涉及到文件边读边写,然后处理拼接sql的操作

下面是 csv文件转sql语句

 

package com.group.wordskey.file;

import org.apache.commons.lang3.StringUtils;

import java.awt.*;
import java.io.*;

/**
 * Description:
 *
 * 
 * @date 2020/8/24 13:37
 */
public class FileReadSql{

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

        String path = "C:\\Users\\10015467\\Desktop\\poi\\sit01\\sit01.csv";
        String outPath = "C:\\Users\\10015467\\Desktop\\poi\\sit01\\200827b-aaa-DDL.sql";


        readFile(path,outPath);





    }

    public static StringBuilder readFile(String path,String outPath) throws IOException{
        File file = new File(path);
        File outFile = new File(outPath);
        StringBuilder result = new StringBuilder();
        OutputStream outputStream = null;
        BufferedReader br = null;
        try{
            outputStream = new FileOutputStream(outFile);

            br = new BufferedReader(new InputStreamReader(new FileInputStream(file), "UTF-8"));
            int index = 0;
            String s = null;
            while((s = br.readLine())!=null){
                if(index != 0 ){
                    System.out.println(s);
                }
                index++;
                if(index == 1){
                    continue;
                }
                String[] split = s.split(",");
                int len = split.length - 1;
                //字段1
                String sku = formatStr(split[0]);
                //字段2
                String startDate = formatStr(split[1]);
                //字段3
                String deliveryTimeType = formatStr(split[2]);
                //字段4
                Integer clothesCount = Integer.valueOf(split[3]);
                //字段5
                Integer beltState = Integer.valueOf(split[4]);
                //字段6
                String seriesBrandName =  "\'\'";
                if(len >= 5){
                    seriesBrandName = formatStr(split[5]);
                    if(StringUtils.isBlank(seriesBrandName)){
                        seriesBrandName =  "\'\'";
                    }

                }
                //字段7
                String consumablesTypeName = "\'\'";
                if(len >= 6){
                    consumablesTypeName = formatStr(split[6]);
                    if(StringUtils.isBlank(consumablesTypeName)){
                        consumablesTypeName = "\'\'";
                    }
                }

                //字段8 ,因为这里是一个逗号分隔的字符串,所以放在最后解析,重新拼接
               //重新拼接成一个逗号分隔的字符串
                String colors =  "\'\'";
                if(len >= 7){
                    //提取颜色字段
                    if(len == 7){
                        colors = formatStr(split[7]);
                    }else {
                        StringBuffer sb = new StringBuffer();
                        for(int i = 7;i < split.length;i++){
                            if(i == len){
                                sb.append(split[i]);
                            }else {
                                sb.append(split[i]).append(",");
                            }
                        }
                        colors = sb.toString();
                    }
                    if(StringUtils.isBlank(colors)){
                        colors =  "\'\'";
                    }
                }

                String sql = "";
                sql = "UPDATE  basic_sku_extend set start_date = %S,delivery_time_type = %S,clothes_count=%S,belt_state=%S," +
                        "colors=%S,series_brand_name=%S,consumables_type_name=%S WHERE sku =  %S;";
                String format = String.format(sql,startDate,deliveryTimeType,clothesCount,beltState,colors,seriesBrandName,consumablesTypeName,sku);
                //写入文件
                format = format + System.lineSeparator();
                outputStream.write(format.getBytes("UTF-8"));

                result.append(format + System.lineSeparator());
            }

        }catch(Exception e){
            e.printStackTrace();
        }finally{
            br.close();
            outputStream.close();
        }
        return result;

    }

    public static String formatStr(String str){
        String result = "\'\'";
        if(str == null || result.equals(str)){
            return result;
        }else {
            str = "\'" + str + "\'";
            return str;
        }
    }




}
                    

  

 

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请联系我们举报,一经查实,本站将立刻删除。

发布者:全栈程序员-站长,转载请注明出处:https://javaforall.net/2567.html原文链接:https://javaforall.net

(0)
全栈程序员-站长的头像全栈程序员-站长


相关推荐

  • 平均数、中位数和众数及它们之间的关系

    平均数、中位数和众数及它们之间的关系迁移到:http://www.bdata-cap.com/newsinfo/1741421.html本文内容平均数中位数众数参考资料演示最近大BOSS“迷上”了一个网络游戏(什么游戏就

    2022年7月2日
    35
  • springboot的启动流程图_@SpringBootApplication

    springboot的启动流程图_@SpringBootApplication首先会new一个SpringApplication然后在构造方法里初始化一些属性。判断应用类型是响应式REACTIVE的还是Web应用SERVLET去spring.factories文件加载初始化器ApplicationContextInitializer去spring.factories文件加载监听器ApplicationListener实例化之后执行run方法主体,run执行流程是基于观察者模式的,整个SpringBoot的启动流程就是各种事件的发布。获取并启用监听器Applicati..

    2025年9月5日
    3
  • c++ –static关键字

    c++ –static关键字

    2021年9月29日
    46
  • 解决libssl.so.1.0.0 => not found以及libcrypto.so.1.0.0 => not found

    解决libssl.so.1.0.0 => not found以及libcrypto.so.1.0.0 => not found现在的apt源中,libssl1.0的版本一般是libssl1.0.2,libcrypto1.0的版本一般是libcrypto1.0.2。但是很多应用要使用libssl.so.1.0.0和libcrypto.so.1.0.0。试过软链接,但是没用。所以只好手动下载它们的安装包了。下载地址:https://packages.debian.org/search?suite=jessie&……

    2022年6月29日
    228
  • GridView导出Excel的超好样例「建议收藏」

    GridView导出Excel的超好样例「建议收藏」事实上网上有非常多关于Excel的样例,可是不是非常好,他们的代码没有非常全,读的起来还非常晦涩。经过这几天的摸索,最终能够完毕我想要导出报表Excel的效果了。以下是我的效果图。一.前台的页面图Gr

    2022年7月4日
    27
  • git clone与git pull区别

    git clone与git pull区别原地址最近一直焦虑换工作与面试,自然面试过程中也被问到了很多问题,在一家公司中,被问到了git相关的知识。面试官提出了gitclone与gitpull有什么区别。由于自己对git的掌握情况不是特别深入,感觉瞬间被问蒙圈一样。后来,查了相关的文档,看了一些文章,自己有了一丁点的理解,觉得应该…

    2022年7月21日
    16

发表回复

您的邮箱地址不会被公开。 必填项已用 * 标注

关注全栈程序员社区公众号