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.Sensor_state;
|
|
|
public class Sensor_stateImpl 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;
|
}
|
//根据设备id查询状态
|
@Override
|
public List serchByCondition(Object obj) {
|
Sensor_state state=(Sensor_state) obj;
|
String sql=" select distinct num,sensor_dev_id,record_time,airtmp,airhum,smoke,water,lightintensity"
|
+ " ,CO2concentration,COconcentration,CH4concentration,O2concentration,dev_commcount,dev_errcommcount "
|
+ " from db_sensor.tb_sensor_state "
|
+ " where sensor_dev_id=? ";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{state.getSensor_dev_id()}, new CallBack() {
|
|
@Override
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Sensor_state s=new Sensor_state();
|
s.setNum(rs.getInt("num"));
|
s.setSensor_dev_id(rs.getInt("sensor_dev_id"));
|
s.setRecord_time(rs.getTimestamp("record_time"));
|
s.setAirtmp(rs.getFloat("airtmp"));
|
s.setAirhum(rs.getFloat("airhum"));
|
s.setSmoke(rs.getInt("smoke"));
|
s.setWater(rs.getInt("water"));
|
s.setLightintensity(rs.getInt("lightintensity"));
|
s.setCO2concentration(rs.getInt("cO2concentration"));
|
s.setCOconcentration(rs.getInt("cOconcentration"));
|
s.setCH4concentration(rs.getInt("cH4concentration"));
|
s.setO2concentration(rs.getInt("o2concentration"));
|
s.setDev_commcount(rs.getInt("dev_commcount"));
|
s.setDev_errcommcount(rs.getInt("dev_errcommcount"));
|
list.add(s);
|
}
|
} 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) {
|
|
}
|
}
|
