public ElectrMonitor() {
        TimerTask task = new TimerTask() {
            public void run() {
                insertElectr_data();
            }
        };
        Timer timer = new Timer();
        long delay = 0;
        long intevalPeriod = 1 * 1000;
        timer.scheduleAtFixedRate(task, delay, intevalPeriod);
    }

public ElectrMonitor() {
        new Thread() {
            public void run() {
                while (true) {
                    try {
                        insertElectr_data();
                        Thread.sleep(1000);
                    }
                    catch (Exception e) {
                        e.printStackTrace();
                    }
                }
            }
        }.start();
    }

private void insertElectr_data(){
        String sql ="insert into electr_data(ID,SUBSTATION,U_UAB,U_UBC,U_UCA,U_3U0," +
                "I_LA,I_LC,I_3I0,P_AP,P_RP,P_PF,S_SCP,S_OCP,S_OLP,S_LVP,S_PTB,S_LP,S_LA,S_CF," +
                "IS_BRAKE,EQUNAME,AREANAME,timestamp) " +
                "select ID,SUBSTATION,U_UAB,U_UBC,U_UCA,U_3U0," +
                "I_LA,I_LC,I_3I0,P_AP,P_RP,P_PF,S_SCP,S_OCP,S_OLP,S_LVP,S_PTB,S_LP,S_LA,S_CF," +
                "IS_BRAKE,EQUNAME,AREANAME,sysdate from electr_equ";
        try {
            executeSQL(sql);
        } catch (Exception e){
            e.printStackTrace();
        }
    }

private void executeSQL(String sql) {
        Connection conn      = null;
        Statement  stat      = null;
        try {
            conn   =  getConnection();
            stat   =  conn.createStatement();
        }
        catch (Exception e) {
            e.printStackTrace();
            return;
        }
        try {
            stat.execute(sql);
        }
        catch (Exception e) {
            e.printStackTrace();
            return;
        }
        try {
            if (stat != null) stat.close();
            if (conn != null) conn.close();
        }
        catch (Exception e) {
            e.printStackTrace();
        }
    }

public Connection getConnection(){
        Connection connection  = null;
        try {
            Class.forName(DRVIER);
            connection = DriverManager.getConnection(URL, USERNAMR, PASSWORD);
            System.out.println("成功连接数据库");
        } catch (ClassNotFoundException e) {
            throw new RuntimeException("class not find !", e);
        } catch (SQLException e) {
            throw new RuntimeException("get connection error!", e);
        }
        return connection;
    }