package com.fgkj.dao.impl;
|
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.util.ArrayList;
|
import java.util.Date;
|
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.db.IDatabaseName;
|
import com.fgkj.dto.Device_inf;
|
import com.fgkj.dto.User_battgroup_baojigroup;
|
import com.fgkj.dto.User_inf;
|
import com.sun.org.apache.xerces.internal.impl.dv.dtd.IDDatatypeValidator;
|
|
public class User_battgroup_baojigroupImpl implements BaseDAO, CallBack {
|
|
public List getResults(ResultSet rs) {
|
List list = new ArrayList();
|
try {
|
while (rs.next()) {
|
User_battgroup_baojigroup userbaojigroup = new User_battgroup_baojigroup();
|
|
userbaojigroup.setBaoji_group_id(rs.getInt("baoji_group_id"));
|
|
userbaojigroup.setBaoji_group_name(rs
|
.getString("baoji_group_name"));
|
|
list.add(userbaojigroup);
|
}
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
return list;
|
}
|
|
//5.3添加新包机组
|
public boolean add(Object obj) {
|
User_battgroup_baojigroup ubao=(User_battgroup_baojigroup) obj;
|
String sql="insert into db_equip_user.tb_user_battgroup_baojigroup(baoji_group_name) values(?)";
|
Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql,new Object[]{ubao.getBaoji_group_name()});
|
return bl;
|
}
|
//5.3修改包机组名
|
public boolean update(Object obj) {
|
User_battgroup_baojigroup ubao=(User_battgroup_baojigroup) obj;
|
String sql="update db_equip_user.tb_user_battgroup_baojigroup set baoji_group_name=? where baoji_group_id=?";
|
Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql,new Object[]{ubao.getBaoji_group_name(),ubao.getBaoji_group_id()});
|
return bl;
|
}
|
|
//5.3删除包机组
|
public boolean del(Object obj) {
|
User_battgroup_baojigroup ubao=(User_battgroup_baojigroup) obj;
|
String sql="delete db_equip_user.tb_user_battgroup_baojigroup from db_equip_user.tb_user_battgroup_baojigroup where baoji_group_id=?";
|
Boolean bl=DAOHelper.executeUpdate(DBUtil.getConn(), sql,new Object[]{ubao.getBaoji_group_id()});
|
return bl;
|
}
|
|
//5.3删除包机组(多表删除事务回滚)
|
public String delPro(Object obj) {
|
User_battgroup_baojigroup ubao=(User_battgroup_baojigroup) obj;
|
String sql="delete db_equip_user.tb_user_battgroup_baojigroup from db_equip_user.tb_user_battgroup_baojigroup where baoji_group_id="+ubao.getBaoji_group_id();
|
return sql;
|
}
|
|
//5.3查所有包机组
|
public List searchAll() {
|
String sql = "select baoji_group_id,baoji_group_name from db_equip_user.tb_user_battgroup_baojigroup";
|
List list= DAOHelper.executeQuery(sql,
|
DBUtil.getConn(), null,
|
new User_battgroup_baojigroupImpl());
|
return list;
|
}
|
|
//5.3根据包机组id查包机组对应的用户
|
public List serchByCondition(Object obj) {
|
User_battgroup_baojigroup ubao=(User_battgroup_baojigroup) obj;
|
String sql="select distinct(db_equip_user.tb_user_inf.uid),db_equip_user.tb_user_inf.uName " +
|
"from db_equip_user.tb_user_inf,db_equip_user.tb_user_battgroup_baojigroup,db_equip_user.tb_user_battgroup_baojigroup_usr " +
|
"where db_equip_user.tb_user_battgroup_baojigroup.baoji_group_id=db_equip_user.tb_user_battgroup_baojigroup_usr.baoji_group_id " +
|
"and db_equip_user.tb_user_battgroup_baojigroup_usr.uId=db_equip_user.tb_user_inf.uId " +
|
"and db_equip_user.tb_user_battgroup_baojigroup.baoji_group_id=? " +
|
"order by db_equip_user.tb_user_inf.uid";
|
List list= DAOHelper.executeQuery(sql,
|
DBUtil.getConn(), new Object[]{ubao.getBaoji_group_id()},
|
new CallBack() {
|
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
User_inf uinf=new User_inf();
|
uinf.setUId(rs.getInt("uId"));
|
uinf.setUName(rs.getString("uName"));
|
list.add(uinf);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
|
|
public static void main(String[] args) {
|
|
}
|
//根据包机组id查询包机组下的设备
|
@Override
|
public List serchByInfo(Object obj) {
|
User_battgroup_baojigroup ubao=(User_battgroup_baojigroup) obj;
|
String sql=" select distinct db_equip_user.tb_user_battgroup_baojigroup_battgroup.dev_id,db_equipstand.tb_device_inf.dev_name " +
|
"from db_equip_user.tb_user_battgroup_baojigroup_battgroup,db_equipstand.tb_device_inf " +
|
"where db_equip_user.tb_user_battgroup_baojigroup_battgroup.dev_id=db_equipstand.tb_device_inf.dev_id " +
|
"and db_equip_user.tb_user_battgroup_baojigroup_battgroup.baoji_group_id=? " +
|
"order by db_equipstand.tb_device_inf.dev_id asc ";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{ubao.getBaoji_group_id()}, new CallBack() {
|
|
@Override
|
public List getResults(ResultSet rs) {
|
List list=new ArrayList();
|
try {
|
while(rs.next()){
|
Device_inf dinf=new Device_inf();
|
dinf.setDev_id(rs.getInt("dev_id"));
|
dinf.setDev_name(rs.getString("dev_name"));
|
list.add(dinf);
|
}
|
} catch (SQLException e) {
|
// TODO Auto-generated catch block
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
}
|
