达内DMS（JAVA初学者首选）

package combine; import java.sql.Connection; import java.sql.PreparedStatement; import java.sql.ResultSet; import java.sql.Statement; import java.util.Calendar; import DBUtil.DBUtil; import exception.CombineException; public class DataCombinator { private Connection con; // public void combineDayData() throws CombineException { // Calendar c = Calendar.getInstance(); // c.set(1970, 0, 17); // c.add(Calendar.DAY_OF_MONTH, -1); // c.set(Calendar.HOUR_OF_DAY, 0); // c.set(Calendar.MINUTE ,0); // c.set(Calendar.SECOND , 0); // int day = c.get(Calendar.DAY_OF_MONTH); // int month = c.get(Calendar.MONTH)+1;//月从0开始 // long start = c.getTimeInMillis(); // long end = start + 24*60*60*1000; // String sql = "select username,labIp,sum(duration) day_time " + // " from logs " + // " where loginTime <= "+end+" and loginTime >= "+start+ // " group by username,labIp"; // String sql1 = "insert into log_day"+day+" values(?,?,?,"+month+")"; // Statement stmt = null; // ResultSet rs = null; // PreparedStatement pstmt = null; // try { // con = DBUtil.getConnection(); // stmt = con.createStatement(); // rs = stmt.executeQuery(sql); // while (rs.next()) { // pstmt = con.prepareStatement(sql1); // pstmt.setString(1, rs.getString(1)); // pstmt.setString(2, rs.getString(2)); // pstmt.setInt(3, rs.getInt(3)); // pstmt.executeUpdate(); // } // } catch (Exception e) { // e.getStackTrace(); // } finally { // DBUtil.close(); // } // // // } // // public void combineMonthData() { // Calendar c = Calendar.getInstance(); // c.set(1970, 1, 16);//1970年2月17日 // c.add(Calendar.MONTH, -1); // c.set(Calendar.DAY_OF_MONTH, 1); // c.set(Calendar.HOUR, 0); // c.set(Calendar.MINUTE ,0); // c.set(Calendar.SECOND ,0); // int month = c.get(Calendar.MONTH)+1; // int year = c.get(Calendar.YEAR); // long start = c.getTimeInMillis(); // c.add(Calendar.MONTH, 1); // long end = c.getTimeInMillis(); // String sql = "select username,labIp,sum(duration) day_time " + // " from logs " + // " where loginTime <= "+end+" and loginTime >= "+start+ // " group by username,labIp"; // String sql1 = "insert into log_month"+month+" values(?,?,?,"+year+")"; // Statement stmt = null; // ResultSet rs = null; // PreparedStatement pstmt = null; // try { // con = DBUtil.getConnection(); // stmt = con.createStatement(); // rs = stmt.executeQuery(sql); // while (rs.next()) { // pstmt = con.prepareStatement(sql1); // pstmt.setString(1, rs.getString(1)); // pstmt.setString(2, rs.getString(2)); // pstmt.setString(3, rs.getString(3)); // pstmt.executeUpdate(); // } // } catch (Exception e) { // // TODO: handle exception // } finally { // DBUtil.close(); // } // } public void combineYearData() { // Calendar c = Calendar.getInstance(); // c.set(1971, 1, 17);//1971年2月17日 // c.add(Calendar.YEAR, -1); // c.set(Calendar.MONTH, 0); // c.set(Calendar.DAY_OF_MONTH, 1); // c.set(Calendar.HOUR, 0); // c.set(Calendar.MINUTE ,0); // c.set(Calendar.SECOND ,0); // int year = c.get(Calendar.YEAR); // long start = c.getTimeInMillis(); // c.add(Calendar.YEAR, 1); // long end = c.getTimeInMillis(); String sql = "select username,labIp,sum(duration) day_time " + " from logs group by username,labIp"; String sql1 = "insert into log_year values(?,?,?)"; Statement stmt = null; ResultSet rs = null; PreparedStatement pstmt = null; try { con = DBUtil.getConnection(); stmt = con.createStatement(); rs = stmt.executeQuery(sql); while (rs.next()) { pstmt = con.prepareStatement(sql1); pstmt.setString(1, rs.getString(1)); pstmt.setString(2, rs.getString(2)); pstmt.setString(3, rs.getString(3)); pstmt.executeUpdate(); } } catch (Exception e) { e.printStackTrace(); } finally { DBUtil.close(); } } }