package com.fgkj.dao.impl; import java.sql.ResultSet; import java.sql.SQLException; import java.util.ArrayList; import java.util.List; import com.fgkj.dao.BaseDAO; import com.fgkj.dao.CallBack; import com.fgkj.dao.DAOHelper; import com.fgkj.db.DBUtil; import com.fgkj.dto.Devdata_rt; import com.fgkj.dto.Historydata; public class Devdata_rtImpl implements BaseDAO,CallBack{ @Override public List getResults(ResultSet rs) { // TODO Auto-generated method stub return null; } @Override public boolean add(Object obj) { // TODO Auto-generated method stub return false; } @Override public boolean update(Object obj) { // TODO Auto-generated method stub return false; } @Override public boolean del(Object obj) { // TODO Auto-generated method stub return false; } @Override public List searchAll() { // TODO Auto-generated method stub return null; } //根据查询条件实时查询数据 @Override public List serchByCondition(Object obj) { Devdata_rt rtdata=(Devdata_rt) obj; String sql=" select distinct dev_id,num,record_time,am_num,analog_value,switch_value,state_value " + " from db_equipstand.tb_devdata_rt " + " where dev_id=? " + " order by record_time desc, am_num asc"; List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{rtdata.getDev_id()}, new CallBack() { @Override public List getResults(ResultSet rs) { // TODO Auto-generated method stub List list=new ArrayList(); try { while(rs.next()){ Devdata_rt rt=new Devdata_rt(); rt.setNum(rs.getInt("num")); rt.setDev_id(rs.getInt("dev_id")); rt.setRecord_time(rs.getTimestamp("record_time")); rt.setAm_num(rs.getInt("am_num")); rt.setAnalog_value(rs.getFloat("analog_value")); rt.setSwitch_value(rs.getFloat("switch_value")); rt.setState_value(rs.getFloat("state_value")); list.add(rt); } } catch (SQLException e) { // TODO Auto-generated catch block e.printStackTrace(); } return list; } }); return list; } @Override public List serchByInfo(Object obj) { // TODO Auto-generated method stub return null; } public static void main(String[] args) { Devdata_rtImpl dimpl=new Devdata_rtImpl(); Devdata_rt rt=new Devdata_rt(); rt.setDev_id(1001); List list=dimpl.serchByCondition(rt); System.out.println(list.size()); } }