AccessToMySql数据库的导入以及java生成.exe文件

一、AccessToMySql

最近做了一个Access数据库导入MySql的小工具，期间遇到诸多问题，这里小计一下。

表名为cur_rec，共有5个字段

比较奇葩的是这个表居然是四个字段的联合主键，要实现的功能为从Access数据库里面导一个时间段的数据到Mysql，例如：起始日期：2015-02-27  截止日期：2015-03-02

一开始是准备用ODBC，后来觉得还要配置数据源，比较麻烦，还有路径问题（后续会制作成.exe）

于是下载了一个Access_JDBC30.jar的驱动（官网的似乎是需要付费的，下载的驱动包有一个问题就是一次最大能够读取1000条数据）

于是乎想到了分页查询，使用的时候发现Mysql的分页语句不能使用，纠结了好久.....

但是在分页查询的时候查找网上资料，一般都是只有一个主键的，最后请教了一下我们的牛人，

什么都不说了，直接上代码：

MysqlTest.java

package com.cn.jpz.mysql;

import java.awt.EventQueue;

import javax.swing.JFrame;
import javax.swing.JLabel;
import javax.swing.JOptionPane;

import java.awt.BorderLayout;
import java.awt.Color;
import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.sql.Connection;
import java.sql.Date;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.text.ParseException;
import java.text.SimpleDateFormat;
import java.util.ArrayList;
import java.util.List;

import javax.swing.JTextField;
import javax.swing.JButton;

public class MysqlTest {

    private JFrame frame;
    private JTextField textField;
    private JTextField textField_1;

    private JButton btnInsert;
    private String sDriver;
    private Connection conn;
    private PreparedStatement pstmt = null;
    private Statement stmt;
    private PreparedStatement pst = null;
    private List<ChildVista> datas = new ArrayList<ChildVista>();
    private JButton btnNewButton;

    public static String startDateString;
    public static String endDateString;
    public static boolean isValidDate;
    private JTextField textField_2;
    private PreparedStatement pst2 = null;
    private ResultSet rst = null;
    private ResultSet rs;
    public static int equipNo;
    private static final int PAGE_SIZE=1000;

    /**
     * Launch the application.
     */
    public static void main(String[] args) {
        EventQueue.invokeLater(new Runnable() {
            public void run() {
                try {
                    MysqlTest window = new MysqlTest();
                    window.frame.setVisible(true);
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }
        });
    }

    /**
     * Create the application.
     */
    public MysqlTest() {
        initialize();
    }

    /**
     * Initialize the contents of the frame.
     */
    private void initialize() {
        frame = new JFrame();
        frame.getContentPane().setBackground(Color.WHITE);
        frame.setBounds(100, 100, 450, 300);
        frame.setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
        frame.getContentPane().setLayout(null);

        JLabel lblNewLabel = new JLabel("u8D77u59CBu65E5u671FuFF1A");
        lblNewLabel.setBounds(24, 69, 69, 15);
        frame.getContentPane().add(lblNewLabel);

        JLabel lblNewLabel_1 = new JLabel("u622Au6B62u65E5u671FuFF1A");
        lblNewLabel_1.setBounds(246, 69, 66, 15);
        frame.getContentPane().add(lblNewLabel_1);

        textField = new JTextField();
        textField.setText("2015-02-27");
        textField.setBounds(103, 66, 79, 21);
        frame.getContentPane().add(textField);
        textField.setColumns(10);

        textField_1 = new JTextField();
        textField_1.setText("2015-03-02");
        textField_1.setBounds(322, 66, 79, 21);
        frame.getContentPane().add(textField_1);
        textField_1.setColumns(10);

        btnInsert = new JButton("u5F00u59CB");
        btnInsert.addActionListener(new ActionListener() {
            public void actionPerformed(ActionEvent e) {
                batchInsertIntoMysql();
            }
        });
        btnInsert.setBounds(164, 154, 93, 23);
        frame.getContentPane().add(btnInsert);

        btnNewButton = new JButton("u83B7u53D6u65E5u671F");
        btnNewButton.addActionListener(new ActionListener() {
            public void actionPerformed(ActionEvent e) {
                isValidDate = getDate();
                if (isValidDate) {
                    ConnODBC();
                    getDataFromAccess();
                } else {
                    JOptionPane.showMessageDialog(null, "日期、设备号格式不正确，请重新输入！！");
                }
            }
        });
        btnNewButton.setBounds(164, 114, 93, 23);
        frame.getContentPane().add(btnNewButton);

        JLabel lblNewLabel_2 = new JLabel(
                "u65E5u671Fu683Cu5F0FuFF1A2015-03-20");
        lblNewLabel_2.setBounds(24, 23, 129, 21);
        frame.getContentPane().add(lblNewLabel_2);

        JLabel lblNewLabel_3 = new JLabel(
                "u6CE8uFF1Au8F93u5165u8D77u59CBu65E5u671Fu548Cu622Au6B62u65E5u671Fu4EE5u540EuFF0Cu70B9u51FBu83B7u53D6u65E5u671FuFF0Cu7136u540Eu70B9u51FBu5F00u59CB");
        lblNewLabel_3.setForeground(Color.MAGENTA);
        lblNewLabel_3.setBounds(10, 187, 414, 23);
        frame.getContentPane().add(lblNewLabel_3);

        JLabel lblNewLabel_4 = new JLabel(
                "u5219u5F00u59CBu6570u636Eu7684u5BFCu5165uFF0Cu5F00u59CBu6309u94AEu6062u590Du6B63u5E38uFF0Cu6216u8005u7A0Bu5E8Fu9000u51FAu5219u5BFCu5165u7ED3u675F");
        lblNewLabel_4.setForeground(Color.MAGENTA);
        lblNewLabel_4.setBounds(24, 208, 400, 21);
        frame.getContentPane().add(lblNewLabel_4);

        JLabel label = new JLabel("u8BBEu5907u53F7uFF1A");
        label.setBounds(203, 26, 54, 15);
        frame.getContentPane().add(label);

        textField_2 = new JTextField();
        textField_2.setText("100");
        textField_2.setBounds(272, 23, 66, 21);
        frame.getContentPane().add(textField_2);
        textField_2.setColumns(10);

        JLabel lbls = new JLabel("u8BF7u8010u5FC3u7B49u5F855s");
        lbls.setForeground(Color.MAGENTA);
        lbls.setBackground(Color.BLUE);
        lbls.setBounds(267, 118, 93, 19);
        frame.getContentPane().add(lbls);
    }

    /**
     * 获取mysql连接
     * 
     * @return
     */
    public Connection getMysqlConn() {
        sDriver = "com.mysql.jdbc.Driver";
        String url = "jdbc:mysql://localhost:3306/vista";
        String user = "boctek";
        String passwd = "BCERA1688";
        try {
            Class.forName("com.mysql.jdbc.Driver");
            conn = DriverManager.getConnection(url, user, passwd);
        } catch (Exception e1) {
            e1.printStackTrace();
        }
        return conn;
    }

    /**
     * 关闭mysql连接
     */
    public void closeMysqlConn(Connection conn) {
        try {
            if (conn != null || !conn.isClosed()) {
                conn.close();
            }
        } catch (SQLException e) {
            e.printStackTrace();
        }

    }

    // 批量插入数据
    public boolean batchInsertIntoMysql() {
        System.out.println("开始插入");
        List<ChildVista> initialize = datas;
        for (ChildVista cv : initialize) {
            insertToMysql(cv);
        }
        return false;

    }

    public void insertToMysql(ChildVista childVista) {
        conn = getMysqlConn();
        try {// 执行数据库查询，返回结果
            String sql = "insert into cur_rec values(?,?,?,?,?)";
            pst = conn.prepareStatement(sql);
            pst.setDate(1, childVista.getTmDate());
            pst.setInt(2, childVista.getStan());
            pst.setInt(3, childVista.getEquipNo());
            pst.setInt(4, childVista.getYcNo());
            pst.setString(5, childVista.getData().toString());
            pst.execute();
            pst.close();
        } catch (SQLException e) {
            System.out.println(e.getMessage());
        } finally {
            // 关闭数据库连接
            closeMysqlConn(conn);
        }
    }

    /*
     * // 批量插入数据 public boolean batchInsertIntoMysql() { List<ChildVista>
     * initialize = datas; try { insertToMysql(initialize); } catch
     * (ParseException e) { e.printStackTrace(); } return false;
     * 
     * }
     * 
     * public void insertToMysql(List<ChildVista> childVista) throws
     * ParseException { conn = getMysqlConn(); SimpleDateFormat sdf = new
     * SimpleDateFormat("yyyy-MM-dd"); java.util.Date startDate =
     * sdf.parse(startDateString); java.util.Date endDate =
     * sdf.parse(endDateString);
     * 
     * String deleteSql = "delete from cur_rec where tmdate >= '"+ new
     * Date(startDate.getTime()) +"' and tmdate <= '"+new
     * Date(endDate.getTime())+"'"; try { System.out.println(deleteSql); pst =
     * conn.prepareStatement(deleteSql); pst.executeUpdate(); } catch
     * (SQLException e1) { e1.printStackTrace(); }
     * 
     * String sql = "insert into cur_rec values(?,?,?,?,?)"; try {//
     * 执行数据库查询，返回结果 pst = conn.prepareStatement(sql); int count = 0; for (int i
     * = 0; i < childVista.size(); i++) { ChildVista child = childVista.get(i);
     * pst.setDate(1, child.getTmDate()); pst.setInt(2, child.getStan());
     * pst.setInt(3, child.getEquipNo()); pst.setInt(4, child.getYcNo());
     * pst.setString(5, child.getData().toString()); pst.addBatch(); }
     * pst.executeBatch(); } catch (Exception e) { e.printStackTrace(); }
     * finally { try{ //关闭步骤3所开启的state对象 pst.close();
     * System.out.println("关闭pst对象"); } catch(SQLException e){} try{ //关闭数据库连接
     * conn.close(); System.out.println("关闭sql数据库连接对象"); } catch(SQLException
     * e){
     * 
     * } } }
     */
    public boolean getDate() {
        boolean convertSuccess = true;
        startDateString = textField.getText();
        endDateString = textField_1.getText();
        String equipNoString = textField_2.getText();
        if (startDateString == null || startDateString.length() <= 0
                || endDateString == null || endDateString.length() <= 0
                || equipNoString == null || equipNoString.length() <= 0) {
            JOptionPane.showMessageDialog(null, "日期、设备号不能为空");
            return false;
        }
        SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");
        format.setLenient(false);
        try {
            format.parse(startDateString);
            format.parse(endDateString);
            equipNo = Integer.parseInt(equipNoString);
        } catch (ParseException e) {
            // TODO Auto-generated catch block
            convertSuccess = false;
            e.printStackTrace();
        }

        return convertSuccess;
    }

    public void ConnODBC() {

        // 步骤1：加载驱动程序
        sDriver = "com.hxtt.sql.access.AccessDriver";
        try {
            Class.forName(sDriver);
        } catch (Exception e) {
            System.out.println("无法加载驱动程序");
            e.printStackTrace();

        }
        System.out.println("步骤1：加载驱动程序--成功！");
        conn = null;
        stmt = null;
        String sCon = "jdbc:access:///ChildVista.mdb";

        try {
            conn = DriverManager.getConnection(sCon);
            if (conn != null) {
                System.out.println("步骤2：连接数据库--成功！");
            }
            // 步骤3：建立JDBC的Statement对象
            stmt = conn.createStatement();
        } catch (SQLException e) {
            System.out.println("连接错误：" + sCon);
            System.out.println(e.getMessage());

        }
    }

    public void getDataFromAccess() {
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd");

        try {// 执行数据库查询，返回结果
            java.util.Date startDate = sdf.parse(startDateString);
            java.util.Date endDate = sdf.parse(endDateString);
            // where tmdate between #"+new Date(startDate.getTime())+"# and
            // #"+new Date(endDate.getTime())+"#"
            
            //Sql语句  获取规定时间段内的数据
            String sSQL = "SELECT count (*) FROM cur_rec where tmdate >= ? and tmdate <= ?";
            pst = conn.prepareStatement(sSQL);
            pst.setDate(1, new Date(startDate.getTime()));
            pst.setDate(2, new Date(endDate.getTime()));
            System.out.println(sSQL);
            rs = pst.executeQuery();
            ChildVista childVista;
            Date date;
            int count = 0;
            if (rs.next()) {
                count = rs.getInt(1);
            }
            //获取分页
            int page=count/PAGE_SIZE;
            page = page +( count % PAGE_SIZE > 0 ? 1 : 0);
            System.out.println("page"+page);
            for (int i = 0; i < page; i++) {
                int s = count - i * PAGE_SIZE;
                int pageSize = s > PAGE_SIZE ? PAGE_SIZE : s;
                //Access分页获取规定时间段内的数据
                String sql = "SELECT TOP "+pageSize+" * FROM( SELECT * FROM (SELECT TOP "+PAGE_SIZE*(i+1)+" * FROM cur_rec where tmdate >= ? and tmdate <= ? ORDER BY tmdate DESC,STA_N DESC,EQUIP_NO DESC,YC_NO DESC) ORDER BY tmdate,STA_N,EQUIP_NO,YC_NO)";
                //String sql = "SELECT * FROM cur_rec where tmdate >= ? and tmdate <= ?";
                pst2  = conn.prepareStatement(sql);
                pst2.setDate(1, new Date(startDate.getTime()));
                pst2.setDate(2, new Date(endDate.getTime()));
                rst =pst2.executeQuery();
                while (rst.next()) {
                    date = rst.getDate("tmdate");
                    childVista = new ChildVista(date, rst.getInt("STA_N"),rst.getInt("EQUIP_NO") + equipNo,rst.getInt("YC_NO"), rst.getBytes("data"));
                    datas.add(childVista);
                }
                System.out.println("第"+(i+1)+"次插入数据。。。");
            }
            System.out.println(count + "条");
        } catch (SQLException e) {
            e.printStackTrace();
        } catch (ParseException e1) {
            e1.printStackTrace();
        } finally {
            try {
                // 关闭步骤3所开启的state对象
                rst.close();
                pst2.close();
                rs.close();
                pst.close();
                System.out.println("关闭statement对象");
            } catch (SQLException e) {
            }
            try {
                // 关闭数据库连接
                stmt.close();
                conn.close();
                System.out.println("关闭数据库连接对象");
            } catch (SQLException e) {

            }
        }
    }
}

ChildVista.java

/*
 * ChildVista 模型
 */
public class ChildVista {
    public Date tmDate;
    public int stan;
    public int equipNo;
    public int ycNo;
    public byte[] data;

    public ChildVista() {
        super();
    }

    public ChildVista(Date tmDate, int stan, int equipNo, int ycNo, byte[] data) {
        super();
        this.tmDate = tmDate;
        this.stan = stan;
        this.equipNo = equipNo;
        this.ycNo = ycNo;
        this.data = data;
    }

    public Date getTmDate() {
        return tmDate;
    }

    public void setTmDate(Date tmDate) {
        this.tmDate = tmDate;
    }

    public int getStan() {
        return stan;
    }

    public void setStan(int stan) {
        this.stan = stan;
    }

    public int getEquipNo() {
        return equipNo;
    }

    public void setEquipNo(int equipNo) {
        this.equipNo = equipNo;
    }

    public int getYcNo() {
        return ycNo;
    }

    public void setYcNo(int ycNo) {
        this.ycNo = ycNo;
    }

    public byte[] getData() {
        return data;
    }

    public void setData(byte[] data) {
        this.data = data;
    }

}

以上即完成了Access往MySql里的数据插入。

二、java打包生成.exe(参考ice world的博客)

前言：

我们都知道Java可以将二进制程序打包成可执行jar文件，双击这个jar和双击exe效果是一样一样的，但感觉还是不同。其实将java程序打包成exe也需要这个可执行jar文件。

准备：

第一步：

eclipse、exe4j

选择Java文件夹下的Runnable JAR file，点击Next，

点击finish即可。完成了AccessToMySql.jar的导出

第二步：

将项目打包成exe，这里要明确一点，并不是把所有的文件都打包成一个exe，资源文件是不能包进去的，往下看↓

首先，在任意目录创建一个文件夹，最好命名和项目名相同，我在D盘创建了一个“AccessToMySql”文件夹，之后将所有的资源文件以及我们生成的可执 行jar文件(我的AccessToMySql.jar)都拷贝到这个文件夹里，lib目录，如果你怕执行该程序的机器上没安装jre，那么你需 要将自己机器上的jre目录也拷贝进来，我安装的jre1.8.0_25，最后的目录结构：

打开exe4j，跳过欢迎，直接点击左侧导航的第二项，因为我们已经提前将java项目打包成可执行jar文件了

在弹出窗口，选择“JAR in EXE mode”，点击“Next”

在新窗口中，为我们的应用取个名称，之后选择exe生成目录（我的D:AccessToMySql），点击“Next”

为我们要生成的exe取名，如果想生成自定义图标，那么选择你的ico文件，如果你不想在一台电脑上运行多个你的程序，你可以勾选“Allow only a single...”，这里我没选，点击“Next”

点击绿色“＋”，设置程序运行的Class Path，先选择我们自己的可执行jar文件（我的AccessToMySql.jar），点击OK

之后点击General中的Main Class选择按钮，在弹出窗口中，exe4j会自动搜索当前Class Path下的全部jar中包含main方法的类，并列出，我这里是MysqlTest，直接选择它点击“OK”，程序入口类就设置完成了

点击绿色“＋”，然后添加我们所依赖的lib库，Access_JDBC30.jar，mysql-connector-java-commercial-5.1.30-bin.jar

输入Java最小Jre版本号，即低于这个版本的Jre无法运行该程序，接着点击“Advanced Options”-“Search sequence”，设置一下我们的JRE，之前说过，如果客户机上没装Jre咋办？，没关系我们捆绑一个进去

点击绿色“＋”来选择捆绑的JRE位置

默认，点击“Next”

默认，点击“Next”

默认，点击“Next”

即在D盘的文件夹下生成了我们所需的AccessToMySql.exe