DIAVIS-wiki

• バックアップ一覧
• ソース を表示
• 043_InfolinesRSS は削除されています。
  • 1 (2007-01-07 (日) 10:50:20)
  • 2 (2007-01-07 (日) 10:52:24)

---

---

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) {
		
	}
}