📄 w4usermgr.java
字号:
package dbmgr;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.*;
import userbean.w4User;
public class w4UserMgr {
DBConMgr db_conn=new DBConMgr();
public Collection search(String name)
{
db_conn.ConnectDB();
Collection showlist=new ArrayList();
ResultSet rs = null;
try{
String sql="select * from empcom where userid ='"+name+"'";
rs = db_conn.stmt.executeQuery(sql);
w4User user = null;
while(rs.next())
{
user=new w4User();
user.setUserid(rs.getInt("userid"));
user.setEmpname(rs.getString("empname"));
user.setHtid(rs.getInt("htid"));
user.setBegin(rs.getString("begin"));
user.setEnd(rs.getString("end"));
user.setDuty(rs.getString("duty"));
user.setHtattribute(rs.getString("htattribute"));
user.setHtname(rs.getString("htname"));
user.setHtstate(rs.getString("htstate"));
user.setHtcontent(rs.getString("htcontent"));
user.setRemark3(rs.getString("remark3"));
showlist.add(user);
}
return showlist;
}
catch (SQLException SqlE) {
SqlE.printStackTrace();
return null;
}
catch (Exception E) {
E.printStackTrace();
return null;
}
finally {
// 关闭连接,释放数据库资源:
db_conn.CloseDB();
}
}
public Collection getAll(){
db_conn.ConnectDB();
Collection showlist=new ArrayList();
ResultSet rs = null;
try{
String sql="select * from empcom order by userid asc";
rs = db_conn.stmt.executeQuery(sql);
w4User user = null;
while(rs.next())
{
user=new w4User();
user.setUserid(rs.getInt("userid"));
user.setEmpname(rs.getString("empname"));
user.setHtid(rs.getInt("htid"));
user.setBegin(rs.getString("begin"));
user.setEnd(rs.getString("end"));
user.setDuty(rs.getString("duty"));
user.setHtattribute(rs.getString("htattribute"));
user.setHtname(rs.getString("htname"));
user.setHtstate(rs.getString("htstate"));
user.setHtcontent(rs.getString("htcontent"));
user.setRemark3(rs.getString("remark3"));
showlist.add(user);
}
return showlist;
}
catch (SQLException SqlE) {
SqlE.printStackTrace();
return null;
}
catch (Exception E) {
E.printStackTrace();
return null;
}
finally {
// 关闭连接,释放数据库资源:
db_conn.CloseDB();
}
}
public int add(w4User user)
{
db_conn.ConnectDB();
try {
String sql = "insert into empcom(userid,empname,htid,begin,end,duty,htattribute,htname,htstate,htcontent,remark3)"+
"values("+user.getUserid()+",'" + user.getEmpname()+
"'," + user.getHtid()+",'" + user.getBegin()+"','" + user.getEnd()+"','" + user.getDuty()+"','" + user.getHtattribute()+"','" + user.getHtname()+"','" + user.getHtstate()+"','" + user.getHtcontent()+"','" + user.getRemark3()+"')";
int i = db_conn.stmt.executeUpdate(sql); // 执行sql语句
return i;
}
catch (SQLException SqlE){
SqlE.printStackTrace();
return -1;
}
catch (Exception E) {
E.printStackTrace();
return -2;
}
finally {
// 关闭连接,释放数据库资源:
db_conn.CloseDB();
}
}
public int chang(w4User user)
{
db_conn.ConnectDB();
try {
String sql = "update empcom set empname='"+
user.getEmpname()+"',htid="+
user.getHtid()+",begin='"+
user.getBegin()+"',end='"+
user.getEnd()+"',duty='"+
user.getDuty()+"',htattribute='"+
user.getHtattribute()+"',htname='"+
user.getHtname()+"',htstate='"+
user.getHtstate()+"',htcontent='"+
user.getHtcontent()+"',remark3='"+
user.getRemark3()+"' where userid="+
user.getUserid();
int i = db_conn.stmt.executeUpdate(sql); // 执行sql语句
return i;
}
catch (SQLException SqlE){
SqlE.printStackTrace();
return -1;
}
catch (Exception E) {
E.printStackTrace();
return -2;
}
finally {
// 关闭连接,释放数据库资源:
db_conn.CloseDB();
}
}
public int delete(int userid)
{
db_conn.ConnectDB();
try {
String sql="delete from empcom where userid="+userid+"";
int i = db_conn.stmt.executeUpdate(sql);
return i;
}
catch (SQLException SqlE){
SqlE.printStackTrace();
return -1;
}
catch (Exception E) {
E.printStackTrace();
return -2;
}
finally {
// 关闭连接,释放数据库资源:
db_conn.CloseDB();
}
}
public Collection getPage(int start,int size)
{
System.out.println(start+","+size);
db_conn.ConnectDB();
Collection showlist=new ArrayList();
ResultSet rs = null;
try{
String sql="select * from empcom order by userid asc";
rs = db_conn.stmt.executeQuery(sql);
w4User user = null;
int i=1;
while(rs.next())
{
if((i>=start)&&(i<start+size))
{user=new w4User();
user.setUserid(rs.getInt("userid"));
user.setEmpname(rs.getString("empname"));
user.setHtid(rs.getInt("htid"));
user.setBegin(rs.getString("begin"));
user.setEnd(rs.getString("end"));
user.setDuty(rs.getString("duty"));
user.setHtattribute(rs.getString("htattribute"));
user.setHtname(rs.getString("htname"));
user.setHtstate(rs.getString("htstate"));
user.setHtcontent(rs.getString("htcontent"));
user.setRemark3(rs.getString("remark3"));
showlist.add(user);
}
i=i+1;
}
return showlist;
}
catch (SQLException SqlE) {
SqlE.printStackTrace();
return null;
}
catch (Exception E) {
E.printStackTrace();
return null;
}
finally {
// 关闭连接,释放数据库资源:
db_conn.CloseDB();
}
}
}
⌨️ 快捷键说明
复制代码
Ctrl + C
搜索代码
Ctrl + F
全屏模式
F11
切换主题
Ctrl + Shift + D
显示快捷键
?
增大字号
Ctrl + =
减小字号
Ctrl + -