81041
2019-06-20 e4efa2387409d35e1fc5e566b84e2065aafa30a6
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,7 +27,7 @@
   @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=" repalce 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;
@@ -36,7 +36,7 @@
   @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;
   }
@@ -51,7 +51,7 @@
   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  "
            + "  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() {
         
@@ -80,7 +80,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 +103,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 +126,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,sensor_dev_id,province,device_name 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
@@ -134,8 +134,12 @@
            List list=new ArrayList();
            try {
               while(rs.next()){
                  String county=rs.getString("county");
                  list.add(county);
                  Sensor_inf s=new Sensor_inf();
                  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.setDevice_name(rs.getString("device_name"));
               }
            } catch (SQLException e) {
               // TODO Auto-generated catch block
@@ -158,6 +162,12 @@
      return null;
   }
   public static void main(String[] args) {
      Sensor_infImpl simpl=new Sensor_infImpl();
      List list=simpl.serchProvice();
      System.out.println(list.size());
   }
}