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.dao.UinfDaoFactory;
|
import com.fgkj.db.DBUtil;
|
import com.fgkj.db.IDatabaseName;
|
import com.fgkj.dto.User_battgroup_baojigroup;
|
import com.fgkj.dto.User_battgroup_baojigroup_usr;
|
import com.fgkj.dto.User_inf;
|
import com.fgkj.dto.User_log;
|
import com.fgkj.services.User_logService;
|
|
public class User_battgroup_baojigroup_usrImpl implements BaseDAO, CallBack {
|
|
public List getResults(ResultSet rs) {
|
List list = new ArrayList();
|
try {
|
while (rs.next()) {
|
User_battgroup_baojigroup_usr userbaojigroupusr = new User_battgroup_baojigroup_usr();
|
|
userbaojigroupusr
|
.setNum(rs.getInt("num"));
|
|
userbaojigroupusr.setBaoji_group_id(Integer.parseInt(rs
|
.getString("baoji_group_id")));
|
userbaojigroupusr
|
.setuId(rs.getInt("uId"));
|
|
list.add(userbaojigroupusr);
|
}
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
return list;
|
}
|
//5.3添加(包机组中添加用户)
|
public boolean add(Object obj) {
|
User_battgroup_baojigroup_usr uusr = (User_battgroup_baojigroup_usr) obj;
|
String sql = "insert into db_user.tb_user_battgroup_baojigroup_usr(baoji_group_id,Uid) values(?,?)";
|
Boolean bl = DAOHelper.executeUpdate(
|
DBUtil.getConn(), sql, new Object[] {uusr.getBaoji_group_id(),uusr.getuId()});
|
return bl;
|
}
|
//5.3添加(包机组中添加用户)(多条记录)
|
public boolean addPro(Object obj) {
|
List<User_battgroup_baojigroup_usr> list=(List) obj;
|
List<User_log> listU=new ArrayList<User_log>();//存放user_log
|
ArrayList sql_strs=new ArrayList();
|
if(list!=null&&list.size()>0){
|
for (User_battgroup_baojigroup_usr uusr : list) {
|
String sql = "insert into db_user.tb_user_battgroup_baojigroup_usr(baoji_group_id,Uid) values("+uusr.getBaoji_group_id()+","+uusr.getuId()+")";
|
sql_strs.add(sql);
|
{
|
String msg="添加"+uusr.getUname()+"用户至"+uusr.getBaoji_group_name()+"包机组中";
|
User_log ulog=UinfDaoFactory.CreateULog(UinfDaoFactory.Increase, msg);
|
listU.add(ulog);
|
}
|
}
|
}
|
boolean bl=DAOHelper.makeManualCommit(DBUtil.getConn(), sql_strs);
|
(new User_logService()).addPro(listU);//将用户的操作记录下来
|
return bl;
|
}
|
|
public boolean update(Object obj) {
|
User_battgroup_baojigroup_usr uusr = (User_battgroup_baojigroup_usr) obj;
|
String sql = "update db_user.tb_user_battgroup_baojigroup_usr set baoji_group_id=?,Uid=? where num=?";
|
Boolean bl = DAOHelper.executeUpdate(
|
DBUtil.getConn(), sql, new Object[] {uusr.getBaoji_group_id(),uusr.getuId(),uusr.getNum()});
|
return bl;
|
}
|
//5.3删除(删除包机组中的用户)
|
public boolean del(Object obj) {
|
User_battgroup_baojigroup_usr uusr = (User_battgroup_baojigroup_usr) obj;
|
String sql = "delete from db_user.tb_user_battgroup_baojigroup_usr where num=?";
|
Boolean bl = DAOHelper.executeUpdate(
|
DBUtil.getConn(), sql, new Object[] {uusr.getNum()});
|
return bl;
|
}
|
|
//5.3删除(删除指定包机组下所有用户)
|
public String delAll(Object obj) {
|
User_battgroup_baojigroup ubao=(User_battgroup_baojigroup) obj;
|
String sql = "delete from db_user.tb_user_battgroup_baojigroup_usr where baoji_group_id="+ubao.getBaoji_group_id();
|
return sql;
|
}
|
public List searchAll() {
|
String sql = "select * from db_user.tb_user_battgroup_baojigroup_usr";
|
List list = DAOHelper.executeQuery(sql,
|
DBUtil.getConn(), null,
|
new User_battgroup_baojigroup_usrImpl());
|
return list;
|
}
|
|
public List serchByCondition(Object obj) {
|
User_battgroup_baojigroup_usr uusr = (User_battgroup_baojigroup_usr) obj;
|
String sql = "select * from db_user.tb_user_battgroup_baojigroup_usr where num=?";
|
List list = DAOHelper.executeQuery(sql,
|
DBUtil.getConn(), new Object[] {uusr.getNum()},
|
new User_battgroup_baojigroup_usrImpl());
|
return list;
|
}
|
|
//5.3查询不在某包机组下的用户
|
public List serchByInfo(Object obj) {
|
User_battgroup_baojigroup_usr uusr=(User_battgroup_baojigroup_usr) obj;
|
String sql="select uid,uname from db_user.tb_user_inf where uid not in(select uid from db_user.tb_User_battgroup_baojigroup_usr where baoji_group_id=?)";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{uusr.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) {
|
|
User_battgroup_baojigroup_usrImpl uu= new User_battgroup_baojigroup_usrImpl();
|
/*List<User_battgroup_baojigroup_usr> list =uu.searchAll();
|
for (User_battgroup_baojigroup_usr u : list) {
|
System.out.println(u);
|
}*/
|
User_battgroup_baojigroup_usr u=new User_battgroup_baojigroup_usr();
|
u.setNum(6);
|
List<User_battgroup_baojigroup_usr> list =uu.searchAll();
|
for (User_battgroup_baojigroup_usr uuu : list) {
|
System.out.println(uuu);
|
}
|
}
|
}
|
