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_inf;
|
|
|
public class Sensor_infImpl implements BaseDAO,CallBack{
|
|
//添加信息
|
@Override
|
public boolean add(Object obj) {
|
Sensor_inf sinf=(Sensor_inf) obj;
|
String sql=" insert into db_sensor.tb_sensor_inf(sensor_dev_id,province,city,county,device_name)"
|
+ " values(?,?,?,?,?)";
|
boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{sinf.getSensor_dev_id(),sinf.getProvince(),sinf.getCity(),sinf.getCounty(),sinf.getDevice_name()});
|
return bl;
|
}
|
//修改信息
|
@Override
|
public boolean update(Object obj) {
|
Sensor_inf sinf=(Sensor_inf) obj;
|
String sql=" replace into db_sensor.tb_sensor_inf(sensor_dev_id,province,city,county,device_name)"
|
+ " values(?,?,?,?,?)";
|
boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{sinf.getSensor_dev_id(),sinf.getProvince(),sinf.getCity(),sinf.getCounty(),sinf.getDevice_name()});
|
return bl;
|
}
|
|
//修改告警值
|
public boolean replaceAlarm(Object obj){
|
Sensor_inf sinf=(Sensor_inf) obj;
|
String sql=" replace into db_sensor.tb_sensor_inf(sensor_dev_id,airtmp_alarm,airhum_alarm,smoke_alarm)"
|
+ " values(?,?,?,?)";
|
boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{sinf.getSensor_dev_id(),
|
sinf.getAirtmp_alarm(),sinf.getAirhum_alarm(),sinf.getSmoke_alarm()});
|
return bl;
|
}
|
//删除信息
|
@Override
|
public boolean del(Object obj) {
|
Sensor_inf sinf=(Sensor_inf) obj;
|
String sql=" delete from db_sensor.tb_sensor_inf where sensor_dev_id=?";
|
boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql, new Object[]{sinf.getSensor_dev_id()});
|
return bl;
|
}
|
|
@Override
|
public List searchAll() {
|
// TODO Auto-generated method stub
|
return null;
|
}
|
//根据设备id查询信息
|
@Override
|
public List serchByCondition(Object obj) {
|
Sensor_inf sinf=(Sensor_inf) obj;
|
String sql=" select distinct sensor_dev_id,num,province,city,county,airtmp_alarm,airhum_alarm,smoke_alarm,device_name "
|
+ " from db_sensor.tb_sensor_inf "
|
+ " where sensor_dev_id=? ";
|
List list=(List) DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{sinf.getSensor_dev_id()}, new CallBack() {
|
|
@Override
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Sensor_inf s=new Sensor_inf();
|
s.setNum(rs.getInt("num"));
|
s.setSensor_dev_id(rs.getInt("sensor_dev_id"));
|
s.setProvince(rs.getString("province"));
|
s.setCity(rs.getString("city"));
|
s.setCounty(rs.getString("county"));
|
s.setAirtmp_alarm(rs.getFloat("airtmp_alarm"));
|
s.setAirhum_alarm(rs.getFloat("airhum_alarm"));
|
s.setSmoke_alarm(rs.getInt("smoke_alarm"));
|
s.setDevice_name(rs.getString("device_name"));
|
list.add(s);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
//查询所有的省份（一级）
|
public List serchProvice(){
|
String sql=" select distinct province from db_sensor.tb_sensor_inf order by province asc";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
|
|
@Override
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
String province=rs.getString("province");
|
list.add(province);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
//查询所有的城市（二级）
|
public List serchCity(Object obj){
|
Sensor_inf sinf=(Sensor_inf) obj;
|
String sql=" select distinct city from db_sensor.tb_sensor_inf where province like ? order by province asc";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{"%"+sinf.getProvince()+"%"}, new CallBack() {
|
|
@Override
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
String city=rs.getString("city");
|
list.add(city);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
//查询所有的城市（三级）
|
public List serchCounty(Object obj){
|
Sensor_inf sinf=(Sensor_inf) obj;
|
String sql=" select distinct county from db_sensor.tb_sensor_inf where province like ? and city like ? order by province asc";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{"%"+sinf.getProvince()+"%","%"+sinf.getCity()+"%"}, new CallBack() {
|
|
@Override
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
String county=rs.getString("county");
|
list.add(county);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
//查询所有的设备（四级）
|
public List serchDevice(Object obj){
|
Sensor_inf sinf=(Sensor_inf) obj;
|
String sql=" select distinct sensor_dev_id,num,province,city,county,airtmp_alarm,airhum_alarm,smoke_alarm,device_name from db_sensor.tb_sensor_inf where province like ? and city like ? and county like ? order by province asc";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{"%"+sinf.getProvince()+"%","%"+sinf.getCity()+"%","%"+sinf.getCounty()+"%"}, new CallBack() {
|
|
@Override
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Sensor_inf s=new Sensor_inf();
|
s.setNum(rs.getInt("num"));
|
s.setSensor_dev_id(rs.getInt("sensor_dev_id"));
|
s.setProvince(rs.getString("province"));
|
s.setCity(rs.getString("city"));
|
s.setCounty(rs.getString("county"));
|
s.setAirtmp_alarm(rs.getFloat("airtmp_alarm"));
|
s.setAirhum_alarm(rs.getFloat("airhum_alarm"));
|
s.setSmoke_alarm(rs.getInt("smoke_alarm"));
|
s.setDevice_name(rs.getString("device_name"));
|
list.add(s);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
@Override
|
public List getResults(ResultSet rs) {
|
// TODO Auto-generated method stub
|
return null;
|
}
|
|
@Override
|
public List serchByInfo(Object obj) {
|
// TODO Auto-generated method stub
|
return null;
|
}
|
|
|
public static void main(String[] args) {
|
Sensor_infImpl simpl=new Sensor_infImpl();
|
//List list=simpl.serchProvice();
|
Sensor_inf sinf=new Sensor_inf();
|
sinf.setSensor_dev_id(291200001);
|
sinf.setAirhum_alarm(55.4f);
|
sinf.setAirhum_alarm(67.4f);
|
sinf.setSmoke_alarm(90000);
|
/*List<Sensor_inf> list=simpl.serchByCondition(sinf);
|
for (Sensor_inf s : list) {
|
System.out.println(s);
|
}
|
System.out.println(list.size());*/
|
boolean bl=simpl.replaceAlarm(sinf);
|
System.out.println(bl);
|
}
|
|
|
}
|
