package com.fgkj.dao.impl;
|
|
import java.sql.ResultSet;
|
import java.sql.SQLException;
|
import java.util.ArrayList;
|
import java.util.List;
|
|
import com.fgkj.actions.ActionUtil;
|
import com.fgkj.dao.BaseDAO;
|
import com.fgkj.dao.CallBack;
|
import com.fgkj.dao.DAOHelper;
|
import com.fgkj.db.DBUtil;
|
import com.fgkj.dto.User_inf;
|
|
public class User_infImpl implements BaseDAO, CallBack {
|
|
@Override
|
public List getResults(ResultSet rs) {
|
// TODO Auto-generated method stub
|
return null;
|
}
|
//添加用户
|
@Override
|
public boolean add(Object obj) {
|
User_inf uinf=(User_inf) obj;
|
String sql=" insert into db_equip_user.tb_user_inf(USnId,UName,Upassword) values(?,?,?) ";
|
boolean bl=DAOHelper.executeUpdate( DBUtil.getConn(), sql, new Object[]{uinf.getUSnId(),uinf.getUName(),ActionUtil.EncryptionBase64(uinf.getUSnId())});
|
return bl;
|
}
|
//修改用户密码
|
@Override
|
public boolean update(Object obj) {
|
User_inf uinf=(User_inf) obj;
|
String sql=" update db_equip_user.tb_user_inf set USnId=?,Upassword=? where uid=? ";
|
boolean bl=DAOHelper.executeUpdate( DBUtil.getConn(), sql, new Object[]{uinf.getUSnId(),ActionUtil.EncryptionBase64(uinf.getUSnId()),uinf.getUId()});
|
return bl;
|
}
|
//删除用户
|
@Override
|
public boolean del(Object obj) {
|
User_inf uinf=(User_inf) obj;
|
String sql="delete from db_equip_user.tb_user_inf where uid=? ";
|
boolean bl=DAOHelper.executeUpdate( DBUtil.getConn(), sql, new Object[]{uinf.getUId()});
|
return bl;
|
}
|
//查询所有的用户(不含密码)
|
@Override
|
public List searchAll() {
|
String sql=" select distinct uid,UName from db_equip_user.tb_user_inf ";
|
List list=DAOHelper.executeQuery(sql, DBUtil.getConn(), null, new CallBack() {
|
|
@Override
|
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;
|
}
|
//根据输入的用户名查询存在数据库中的用户名和加密密码
|
@Override
|
public List serchByCondition(Object obj) {
|
User_inf uinf=(User_inf) obj;
|
String sql = "select uid,uname,upassword,unote from db_equip_user.tb_user_inf where uname=?";
|
List list = DAOHelper.executeQuery(sql, DBUtil.getConn(), new Object[]{uinf.getUName()},
|
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"));
|
uinf.setUNote(rs.getString("uNote"));
|
uinf.setUpassword(rs.getString("upassword"));
|
list.add(uinf);
|
}
|
} catch (SQLException e) {
|
e.printStackTrace();
|
}
|
return list;
|
}
|
});
|
return list;
|
}
|
|
@Override
|
public List serchByInfo(Object obj) {
|
// TODO Auto-generated method stub
|
return null;
|
}
|
|
|
|
}
|