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 HistorydataImpl 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;
|
}
|
//实时页面数据图形前100笔数据
|
@Override
|
public List serchByCondition(Object obj) {
|
Historydata hdata=(Historydata) obj;
|
int limitnum=100*hdata.getAm_num();
|
String sql=" select distinct dev_id,num,record_time,am_num,analog_value,switch_value,state_value "
|
+ " from db_equipstand.tb_historydata_"+hdata.getDev_id()+" "
|
+ " where dev_id=? "
|
+ " order by record_time asc, am_num asc"
|
+ " limit 0,"+limitnum;
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{hdata.getDev_id()}, new CallBack() {
|
|
@Override
|
public List getResults(ResultSet rs) {
|
// TODO Auto-generated method stub
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Historydata h=new Historydata();
|
h.setNum(rs.getInt("num"));
|
h.setDev_id(rs.getInt("dev_id"));
|
h.setRecord_time(rs.getTimestamp("record_time"));
|
h.setAm_num(rs.getInt("am_num"));
|
h.setAnalog_value(rs.getFloat("analog_value"));
|
h.setSwitch_value(rs.getFloat("switch_value"));
|
h.setState_value(rs.getFloat("state_value"));
|
list.add(h);
|
}
|
} 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) {
|
HistorydataImpl himpl=new HistorydataImpl();
|
Historydata h=new Historydata();
|
h.setDev_id(1001);
|
h.setAm_num(24);
|
List list=himpl.serchByCondition(h);
|
System.out.println(list.size());
|
}
|
|
|
}
|
