SlopeThread.java

package heyingzhe;

import java.io.IOException;
import java.nio.file.Paths;
import java.sql.SQLException;

public class SlopeThread extends Thread {
    private int[][] filledDem;
    private String outPutDirectory;
    private String outputSlopePath;
    private String dbUserName;
    private String dbPassword;

    public SlopeThread(int[][] filledDem, String outPutDirectory, String outputSlopePath, String dbUserName, String dbPassword) {
        this.filledDem = filledDem;
        this.outPutDirectory = outPutDirectory;
        this.outputSlopePath = outputSlopePath;
        this.dbUserName = dbUserName;
        this.dbPassword = dbPassword;
    }

    public void run() {
        System.out.println("正在进行坡度计算……");
        SlopeCalculation slopeCalculation = new SlopeCalculation(); //坡度计算
        double[][] slope = slopeCalculation.calculateSlope(filledDem);
        System.out.println("坡度计算完成");

        ImageVisualizer imageVision = new ImageVisualizer();
        imageVision.convertArrayToImage(slope);
        try {
            imageVision.saveImage(Paths.get(outPutDirectory, outputSlopePath).toString(), "png");
        } catch (IOException e) {
            throw new RuntimeException(e);
        }

        SaveResult saveProcessing = new SaveResult();
        // 配置数据库
        saveProcessing.setMySQLProperty(dbUserName, dbPassword);
        System.out.println("你已确认数据库用户名和密码！");
        try {
            saveProcessing.createDatabase("result");
        } catch (SQLException e) {
            throw new RuntimeException(e);
        } catch (ClassNotFoundException e) {
            throw new RuntimeException(e);
        }
        System.out.println("数据库result创建成功！");

        try {
            saveProcessing.createTable("result", "slope"); //创建坡度表格
        } catch (SQLException e) {
            throw new RuntimeException(e);
        } catch (ClassNotFoundException e) {
            throw new RuntimeException(e);
        } catch (IOException e) {
            throw new RuntimeException(e);
        }
        try {
            saveProcessing.saveArrayToAscFile(slope, outPutDirectory, "slope.asc"); //保存为二进制文件
            //saveProcessing.saveArrayToMySQL(slope, "slope");
        } catch (IOException e) {
            throw new RuntimeException(e);
        }
        System.out.println("slope数据已经添加到数据库里面");
    }
}