DIAVIS-wiki
Timer timer = new Timer(); timer.schedule( new CheckTask(), 0, interval ) long interval = 60000; class CheckTask extends TimerTask { public CheckTask( ) { } public void run() { updateChannels(); updateObjects(); Calendar calendar = GregorianCalendar.getInstance(); current = calendar.getTime(); prevUpdated = new Timestamp( current.getTime() ); //removeTime = timeCycleOfUserCheck; System.out.println("prevUpdated: " + prevUpdated.toString() ); } } public void updateObjects() { System.out.println("//////////////////////////////////////////////////\n updateObjects()"); if( prevUpdated == null ) return; try { Connection con = Database.getInstance().getConnection(); StringBuffer sql = new StringBuffer(); sql.append("select * from items where TIMESTAMP >'"); sql.append(prevUpdated); sql.append("'order by date desc"); PreparedStatement stmt = con.prepareStatement(sql.toString()); ResultSet rs = stmt.executeQuery(); // DAOItem.getItem(id) ItemIF item; int rowcount = 0; while( rs.next() ) { item = DAOItem.getItem(rs.getLong("ITEM_ID")); System.out.println("[ " + rowcount + " ] : " + rs.getString("TITLE") + " | " + item.getDate().toString() + " > prevUpdated" + prevUpdated.toString() ); if( item != null ) { newItems.add(item); } latestTime = rs.getTimestamp("DATE"); rowcount++; } for( int i = 0 ; i < newItems.size(); i++ ) { item = (ItemIF)newItems.get(i); viewer.addItem(item); } newItems.clear(); rs.close(); stmt.close(); } catch( Exception e) { } } |