主要要用到zip的文件输入输出流、对文件是目录还是非目录的判断，以及对文件的遍历
 
压缩
 
    public File zip(String filePath) {
        File target = null;
        File source = new File(filePath);
        if (source.exists()) {
            // 压缩文件名=源文件名.zip
            //这里可以对目标文件路径进行设置
            String zipName = source.getName() + ".zip";
            target = new File(source.getParent(), zipName);
            if (target.exists()) {
                target.delete(); // 删除旧的文件
            }
            FileOutputStream fos = null;
            ZipOutputStream zos = null;
            try {
                fos = new FileOutputStream(target);
                zos = new ZipOutputStream(new BufferedOutputStream(fos));
                // 添加对应的文件Entry
                File[] files = source.listFiles();
                for(int i = 0 ; i < files.length ;i++){
                    addEntry("", files[i], zos);
                }
                zos.close();
                fos.close();
            } catch (IOException e) {
                throw new RuntimeException(e);
            } 
        }
        return target;
    }

    private static void addEntry(String base, File source, ZipOutputStream zos)
            throws IOException {
        // 按目录分级，形如：/aaa/bbb.txt
        String entry = base + source.getName();
        if (source.isDirectory()) {
            for (File file : source.listFiles()) {
                // 递归列出目录下的所有文件，添加文件Entry
                addEntry(entry + "/", file, zos);
            }
        } else {
            FileInputStream fis = null;
            BufferedInputStream bis = null;
            try {
                byte[] buffer = new byte[1024 * 10];
                fis = new FileInputStream(source);
                bis = new BufferedInputStream(fis, buffer.length);
                int read = 0;
                zos.putNextEntry(new ZipEntry(entry));
                while ((read = bis.read(buffer, 0, buffer.length)) != -1) {
                    zos.write(buffer, 0, read);
                }
                zos.closeEntry();
            } finally {
                bis.close();
                fis.close();
            }
        }
    }
 
解压
 
public void UnZip(String zipFileName , String armFilePath){   
//解压文件，zipFileName为压缩文件路径，armFilePath为解压文件夹路径
        try {
            ZipInputStream zis = new ZipInputStream(new FileInputStream(new File(zipFileName)));
            BufferedInputStream bis = new BufferedInputStream(zis);
            ZipEntry zipEntry;

            while((zipEntry = zis.getNextEntry()) != null && !zipEntry.isDirectory()){
                File nowFileOut = new File(armFilePath,zipEntry.getName());
                if(!nowFileOut.exists()){
                    (new File(nowFileOut.getParent())).mkdirs();
                }
                BufferedOutputStream bos = new BufferedOutputStream(new FileOutputStream(nowFileOut));
                byte[] buffer = new byte[1024 * 10];
                int read = 0;
                while((read = bis.read(buffer,0,buffer.length)) != -1){
                    bos.write(buffer,0,read);
                }
                bos.close();
            }
            bis.close();
            zis.close();

        } catch (FileNotFoundException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
    }
 
删除整个文件夹
 
    private boolean deleteDir(File dir) {
        if (dir.isDirectory()) {
            String[] children = dir.list();
            for (int i=0; i<children.length; i++) {
                boolean success = deleteDir(new File(dir, children[i]));
                if (!success) {
                    return false;
                }
            }
        }
        // 目录此时为空，可以删除
        return dir.delete();
    }

/**
     * 解压zip压缩文件
     * @param needFilePath 需要解压的文件地址
     * @param savePath 解压后文件保存地址
     * @throws Exception
     */
    public static void unCompress(String needFilePath,String savePath) throws Exception {
        OutputStream os = null;
        InputStream is = null;
        //  获取当前需要解压的文件
        File srcFile = new File(needFilePath);
        if (!srcFile.exists()) {
            throw new Exception(srcFile.getPath() + "所指文件不存在");
        }
        // 插件保存的目录
        File pathFile = new File(savePath);
        if (!pathFile.exists()) {
            pathFile.mkdirs();
        }
        // 设置编码格式，防止中文名称目录读取不到和中文乱码
        ZipFile zip = new ZipFile(srcFile, Charset.forName("GBK"));
        Enumeration<? extends ZipEntry> entryEnum  = zip.entries();
        if (null != entryEnum) {
            ZipEntry zipEntry = null;
            while (entryEnum.hasMoreElements()) {
                zipEntry = (ZipEntry) entryEnum.nextElement();
                if (zipEntry.getSize() > 0) {
                    File targetFile = FileUtilZip.buildFile(savePath
                            + File.separator + zipEntry.getName(), false);
                    os = new BufferedOutputStream(new FileOutputStream(targetFile));
                    is = zip.getInputStream(zipEntry);
                    byte[] buffer = new byte[4096];
                    int readLen = 0;
                    while ((readLen = is.read(buffer, 0, 4096)) >= 0) {
                        os.write(buffer, 0, readLen);
                        os.flush();
                    }
                    is.close();
                    os.close();
                }
                if (zipEntry.isDirectory()) {
                    String pathTemp =  savePath + File.separator
                            + zipEntry.getName();
                    File file = new File(pathTemp);
                    file.mkdirs();
                }
            }
        }
    }
 
测试
 
public static void main(String[] args) {
        try {
            FileAboutZip.unCompress("F:\\project\\镇雄以勒项目2#清单.zip", "F:\\project\\zip");
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
 
删除
 
// zip文件解压后保存得文件，在执行完导入之后需要删除文件
    // 删除文件夹下所有的文件
    public static boolean delAllFile(String path) {
        boolean flag = false;
        File file = new File(path);
        if (!file.exists()) {
            return flag;
        }
        if (!file.isDirectory()) {
            return flag;
        }
        String[] tempList = file.list();
        File temp = null;
        for (int i = 0; i < tempList.length; i++) {
            if (path.endsWith(File.separator)) {
                temp = new File(path + tempList[i]);
            } else {
                temp = new File(path + File.separator + tempList[i]);
            }
            if (temp.isFile()) {
                temp.delete();
            }
            if (temp.isDirectory()) {
                delAllFile(path + "/" + tempList[i]);//先删除文件夹里面的文件
                delFolder(path + "/" + tempList[i]);//再删除空文件夹
                flag = true;
            }
        }
        return flag;
    }

    // 删除文件夹
    public static void delFolder(String folderPath) {
        try {
            delAllFile(folderPath); //删除完里面所有内容
            String filePath = folderPath;
            filePath = filePath.toString();
            File myFilePath = new File(filePath);
            myFilePath.delete(); //删除空文件夹
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
 
 

一、MySQL官网下载解压版
 
1.进入官网下载
 MySQL官网
 
 2.进入后看到社区服务器点击进入
 
 3.这里就可以下载，建议大家下载以前的版本，最新版本容易出现问题，这里我选择的是5.7版本
 
 4.如图选择
 
 5.直接下载解压
 
 
二、配置MySQL
 
1.解压后安装包目录如下（注意：此时没有data目录和.ini文件，这是我配置成功后的目录）
 
 2.将文件放入自己想放的文件， 由于解压后没有.ini文件在此目录下新建my.ini文件
 
 3.用记事本或者notepad++打开，添加内容如下：
 
[mysqld]

port = 3306

basedir=F:\MySQL\mysql-5.7.24-winx64

datadir=F:\MySQL\mysql-5.7.24-winx64\data 

max_connections=200

character-set-server=utf8

default-storage-engine=INNODB

sql_mode=NO_ENGINE_SUBSTITUTION,STRICT_TRANS_TABLES

[mysql]

default-character-set=utf8
 
4.注意标红路径，该路径是你自己选择的路径：
 5.配置环境变量
 
打开控制面板—>高级系统设置，在弹出的选项卡里选择“高级”—>“环境变量”
 在系统变量里面新建“MYSQL_HOME”
 值“F:\MySQL\mysql-5.7.24-winx64”（这里还是存放的路径）
 
三、安装MySQL
 
1.以管理员身份运行CMD
 进入MySQL的bin目录：F:\MySQL\mysql-5.7.24-winx64\bin
 2.运行mysqld --initialize（ 这步是直接初始化mysql，生成data文件夹中的文件。）
 
 3.运行mysqld -install( 这步是安装mysql，正确的应该显示)：
 
 （我这里显示已经存在）
 
 4.运行net start mysql启动服务（ 这步是启动服务器）
 
 5.设置Root账户密码
 
修改MySQL的配置文件（my.ini）,在[mysqld]下添加一行skip-grant-tables
 
 
重启mysql ，重启步骤如下，关闭MySQL 输入：net stop mysql
 
 重新打开MySQ 输入：net start mysql
 
 重启后，即可直接用 mysql -u root -p进入(此时密码为空)，看到Enter password,直接回车即可;
 
 
输入update mysql.user set authentication_string=password(“root（这里的root说你自己设置的密码）”) where user=“root”;
 
输入flush privileges;（刷新数据库）
 
输入quit;
 将my.ini文件还原(删除skip-grant-tables这一行)
 
重新启动mysql
 
这个时候可以使用 mysql -u root -p root进入,输入刚才设置的密码，下面是正确安装的显示。
 
使用show databases; 可以看到数据库的东西
 
 
6.备注：
 在安装过程中可能会遇到以下错误：
 MySQL服务无法启动。
 服务没有报告任何错误。
 
 
7.处理:
 检查MySQL目录中data是否存在，重新安装。
 
 输入sc delete mysql 删除原有的MYSQL 重复第三步的MySQL安装
 
本文借鉴的博客链接
 
后续通过root用户和密码进入SQLyog又出现了密码问题，链接放在这里了
 
解压版MySQL通过SQLyog可视化问题总结(错误号码1862)

1 、调用支付宝接口， 获取zip 下载地址
 
package com.ycmedia.task;

import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.alipay.api.AlipayClient;
import com.alipay.api.DefaultAlipayClient;
import com.alipay.api.request.AlipayDataDataserviceBillDownloadurlQueryRequest;
import com.alipay.api.response.AlipayDataDataserviceBillDownloadurlQueryResponse;
import com.google.common.base.Splitter;
import com.ycmedia.constants.Constants;
import com.ycmedia.dao.TaskDao;
import com.ycmedia.entity.RealIncom;
import com.ycmedia.utils.FileUtil;
import com.ycmedia.utils.ReadCsv;

import org.joda.time.DateTime;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.core.env.Environment;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;

import java.io.File;
import java.text.SimpleDateFormat;
import java.util.Date;
import java.util.List;

@Component
public class AliBillTask {

    @Autowired
    private Environment env;
    SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");

    @Autowired
    private TaskDao taskDao;

    @Scheduled(cron = "0 14 14 ? * *")
    public void runAlitask() throws Exception {
        downloadBill();
    }

    /**
     * 获取指定日期的账单
     */
    public void downloadBill() throws Exception {
        // 将订单提交至支付宝
        AlipayClient alipayClient = new DefaultAlipayClient(
                "https://openapi.alipay.com/gateway.do", Constants.ALI_APP_ID,
                Constants.ALI_PRIVATE_KEY, "json", "utf-8",
                Constants.ALI_DEV_PLAT_PUBLIC_KEY);
        AlipayDataDataserviceBillDownloadurlQueryRequest request = new AlipayDataDataserviceBillDownloadurlQueryRequest();
        JSONObject json = new JSONObject();
        json.put("bill_type", "trade");
        //昨天的数据
        json.put("bill_date", new DateTime().minusDays(1).toString("yyyy-MM-dd"));
        request.setBizContent(json.toString());
        AlipayDataDataserviceBillDownloadurlQueryResponse response = alipayClient
                .execute(request);
        if(response.isSuccess()){
            // 获取下载地址url
            String url = response.getBillDownloadUrl();
            // 设置下载后生成Zip目录
            String filePath = env.getProperty("file.path");
            String newZip = filePath + new Date().getTime() + ".zip";
            // 开始下载
            FileUtil.downloadNet(url, newZip);
            // 解压到指定目录
            FileUtil.unZip(newZip, env.getProperty("file.zip.path"));
            // 遍历文件 获取需要的汇整csv
            File[] fs = new File(env.getProperty("file.zip.path")).listFiles();
            RealIncom income = null;
            for (File file : fs) {
                if (file.getAbsolutePath().contains("汇总")) {
                    Double money = ReadCsv.getMoney("", file.getAbsolutePath());
                    income = new RealIncom();
                    income.setDate(new Date());
                    income.setMoney(money);
                    taskDao.insertTodayMoney(income);
                }
            }
            // 插入成功， 删除csv 文件
            for (File file : fs) {
                file.delete();
            }
            
        }else{
            //如果账单不存在， 插入一条空数据到数据库
            RealIncom income= new RealIncom();
            income.setDate(new Date());
            income.setMoney(0.00);
            taskDao.insertTodayMoney(income);
        }
    
        if (response.isSuccess()) {
            System.out.println("调用成功");
        } else {
            System.out.println("调用失败");
        }
        System.out.println(JSON.toJSONString(response));
    }



}
 
工具类代码：
 
package com.ycmedia.utils;

import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.File;
import java.io.FileNotFoundException;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.InputStream;
import java.net.MalformedURLException;
import java.net.URL;
import java.net.URLConnection;
import java.util.Enumeration;

import org.apache.tools.zip.ZipEntry;
import org.apache.tools.zip.ZipFile;

public class FileUtil {

    /**
     * 使用GBK编码可以避免压缩中文文件名乱码
     */
    private static final String CHINESE_CHARSET = "GBK";

    /**
     * 文件读取缓冲区大小
     */
    private static final int CACHE_SIZE = 1024;

    /**
     * 第一步： 把 支付宝生成的账单 下载到本地目录
     * 
     * @param path
     *            支付宝资源url
     * @param filePath
     *            生成的zip 包目录
     * @throws MalformedURLException
     */
    public static void downloadNet(String path, String filePath)
            throws MalformedURLException {
        // 下载网络文件
        int bytesum = 0;
        int byteread = 0;

        URL url = new URL(path);

        try {
            URLConnection conn = url.openConnection();
            InputStream inStream = conn.getInputStream();
            FileOutputStream fs = new FileOutputStream(filePath);

            byte[] buffer = new byte[1204];
            while ((byteread = inStream.read(buffer)) != -1) {
                bytesum += byteread;
                fs.write(buffer, 0, byteread);
            }
        } catch (FileNotFoundException e) {
            e.printStackTrace();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    public static void unZip(String zipFilePath, String destDir)
            throws Exception {

        ZipFile zipFile = new ZipFile(zipFilePath, CHINESE_CHARSET);
        Enumeration<?> emu = zipFile.getEntries();
        BufferedInputStream bis;
        FileOutputStream fos;
        BufferedOutputStream bos;
        File file, parentFile;
        ZipEntry entry;
        byte[] cache = new byte[CACHE_SIZE];
        while (emu.hasMoreElements()) {
            entry = (ZipEntry) emu.nextElement();
            if (entry.isDirectory()) {
                new File(destDir + entry.getName()).mkdirs();
                continue;
            }
            bis = new BufferedInputStream(zipFile.getInputStream(entry));
            file = new File(destDir + entry.getName());
            parentFile = file.getParentFile();
            if (parentFile != null && (!parentFile.exists())) {
                parentFile.mkdirs();
            }
            fos = new FileOutputStream(file);
            bos = new BufferedOutputStream(fos, CACHE_SIZE);
            int nRead = 0;
            while ((nRead = bis.read(cache, 0, CACHE_SIZE)) != -1) {
                fos.write(cache, 0, nRead);
            }
            bos.flush();
            bos.close();
            fos.close();
            bis.close();
        }
        zipFile.close();
    }

}