测试

81041

2019-06-25 f675452aeecdf9394577f34a4ab08dc9f0ac1c07

 sensor/src/com/fgkj/dao/impl/Sensor_infImpl.java

@@ -18,7 +18,7 @@
   @Override

   public boolean add(Object obj) {

      Sensor_inf sinf=(Sensor_inf) obj;

      String sql=" insert into db_seneor.tb_sensor_inf(sensor_dev_id,province,city,county,device_name)"

      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;

@@ -27,16 +27,26 @@
   @Override

   public boolean update(Object obj) {

      Sensor_inf sinf=(Sensor_inf) obj;

      String sql=" repalce into db_seneor.tb_sensor_inf(sensor_dev_id,province,city,county,device_name)"

      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_seneor.tb_sensor_inf where sensor_dev_id=?";

      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;

   }

@@ -50,8 +60,8 @@
   @Override

   public List serchByCondition(Object obj) {

      Sensor_inf sinf=(Sensor_inf) obj;

      String sql=" select distinct sensor_dev_id,num,province,city,county,device_name "

            + "  from db_seneor.tb_sensor_inf  "

      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() {

         

@@ -66,6 +76,9 @@
                  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);

               }

@@ -80,7 +93,7 @@
   }

    //查询所有的省份（一级）

   public List serchProvice(){

      String sql=" select distinct province from db_seneor.tb_sensor_inf order by province asc";

      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

@@ -103,7 +116,7 @@
   //查询所有的城市（二级）

   public List serchCity(Object obj){

      Sensor_inf sinf=(Sensor_inf) obj;

      String sql=" select distinct city from db_seneor.tb_sensor_inf where province like ? order by province asc";

      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

@@ -126,7 +139,7 @@
   //查询所有的城市（三级）

   public List serchCounty(Object obj){

      Sensor_inf sinf=(Sensor_inf) obj;

      String sql=" select distinct county from db_seneor.tb_sensor_inf where province like ? and city like ? order by province asc";

      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

@@ -136,6 +149,38 @@
               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

@@ -158,6 +203,23 @@
      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);

   }





}