 public class AssetFileQueueFixedDAOImpl extends JdbcDaoSupport implements AssetFileQueueDAO {

private final static String SELECT="SELECT ID,REGION,IP,FILE_SIZE,OLD_FILE_NAME,NEW_FILE_NAME,FILE_PATH,TEMP_TABLE_NAME,UP_DATE,TOTAL_ASSET,FAILURE_REASON,STATUS FROM ASSET_FILE_QUEUE";
 /** *//**
* 保存
*/
 public void save(final FileAttributeVO vo) {
String sql="INSERT INTO ASSET_FILE_QUEUE(REGION,IP,FILE_SIZE,OLD_FILE_NAME,NEW_FILE_NAME,FILE_PATH,TEMP_TABLE_NAME,UP_DATE,STATUS) VALUES(?,?,?,?,?,?,?,sysdate,?)";
 getJdbcTemplate().update(sql,new PreparedStatementSetter() {

 public void setValues(PreparedStatement ps) throws SQLException {
int i=1;
ps.setString(i++,vo.getRegion());
ps.setString(i++,vo.getIP());
ps.setLong(i++,vo.getFileSize().longValue());
ps.setString(i++,vo.getOldFileName());
ps.setString(i++,vo.getNewFileName());
ps.setString(i++,vo.getFilePath());
ps.setString(i++,vo.getTempTabelName());
ps.setString(i++,vo.getStatus());
}
});
}

 /** *//**
* 查询
*/
 public List listFilesByStatus(final String status) {
String sql=SELECT + " WHERE STATUS=? AND ROWNUM<=10 ORDER BY ID";
 return (List)getJdbcTemplate().query(sql,new PreparedStatementSetter() {

 public void setValues(PreparedStatement ps) throws SQLException {
ps.setString(1,status);
}

// return result;
 },new ResultSetExtractor() {

List result=new ArrayList();

 public Object extractData(ResultSet rs) throws SQLException,DataAccessException {
 while(rs.next()) {
FileAttributeVO vo=new FileAttributeVO();
int i=1;
vo.setId(new Long(rs.getLong(i++)));
vo.setRegion(rs.getString(i++));
vo.setIP(rs.getString(i++));
vo.setFileSize(new Long(rs.getLong(i++)));
vo.setOldFileName(rs.getString(i++));
vo.setNewFileName(rs.getString(i++));
vo.setFilePath(rs.getString(i++));
vo.setTempTabelName(rs.getString(i++));
vo.setUpDate(rs.getString(i++));
vo.setTotalAsset(new Integer(rs.getInt(i++)));
vo.setFailureReason(rs.getString(i++));
vo.setStatus(rs.getString(i++));
result.add(vo);
}
return result;

}
});
}

 /** *//**
* 更新
*/
 public void update(final FileAttributeVO vo) {
String sql="UPDATE ASSET_FILE_QUEUE SET FAILURE_REASON=?,STATUS=?,TOTAL_ASSET=? where id=?";
 getJdbcTemplate().update(sql,new PreparedStatementSetter() {

 public void setValues(PreparedStatement ps) throws SQLException {
int i=1;
ps.setString(i++,StringUtils.trim(vo.getFailureReason())+"");
ps.setString(i++,vo.getStatus());
long total=vo.getTotalAsset()==null?0:vo.getTotalAsset().longValue();
ps.setLong(i++,total);
ps.setLong(i++,vo.getId().longValue());
}
});
}

}
posted on 2005-12-29 13:44 jacky 阅读(499) 评论(0) 编辑 收藏 所属分类: Open source
| |
30 | 31 | 1 | 2 | 3 | 4 | 5 | 6 | 7 | 8 | 9 | 10 | 11 | 12 | 13 | 14 | 15 | 16 | 17 | 18 | 19 | 20 | 21 | 22 | 23 | 24 | 25 | 26 | 27 | 28 | 29 | 30 | 1 | 2 | 3 | 4 | 5 | 6 | 7 | 8 | 9 | 10 |
常用链接
留言簿(10)
随笔档案
文章分类
文章档案
相册
收藏夹
java
搜索
最新评论

|
|