package dao;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;
import common.DBConnection;
import entity.Users;
public class UsersDao extends DBConnection {
private Connection conn;// 用于保存数据库连接对象
private PreparedStatement pstmt;// 用于执行SQL语句（预处理）
private ResultSet rs;// 用于保存查询的结果集
public static final int PAGE_NUM = 10;
/**
* 根据用户名和密码，判断该用户是否存在
* @param userName
* @param password
* @return 用户对象
*/
public Users validUser(String userName, String password) {
Users user = null;
String sql = "select * from Users where userName=? and password=? ";
try {
conn = DBConnection.getConnection();
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, userName);
pstmt.setString(2, password);
rs = pstmt.executeQuery();
//System.out.print(rs.next());
if (rs.next()) {
user = new Users();
user.setId(rs.getInt("id"));
user.setUserName(rs.getString("userName"));
user.setPassword(rs.getString("password"));
user.setRealName(rs.getString("realName"));
user.setSex(rs.getString("sex"));
user.setAge(rs.getInt("age"));
user.setBirthdayTime(rs.getString("birthdayTime"));
user.setHeader(rs.getString("header"));
user.setPhone(rs.getString("phone"));
user.setEmail(rs.getString("email"));
user.setQuestion(rs.getString("question"));
user.setAnswer(rs.getString("answer"));
user.setAddress(rs.getString("address"));
user.setMarryStatus(rs.getInt("marryStatus"));
user.setOnStatus(rs.getInt("onStatus"));
user.setLasttime(rs.getString("lasttime"));
user.setRegisttime(rs.getString("registtime"));
user.setHeight(rs.getInt("height"));
user.setWeight(rs.getInt("weight"));
user.setHobby(rs.getString("hobby"));
user.setIntroduction(rs.getString("introduction"));
}
} catch (Exception e) {
e.printStackTrace();
} finally {
DBConnection.closeResultSet(rs);
DBConnection.closeStatement(pstmt);
DBConnection.closeConnection();
}
return user;
}
/**
* 添加用户信息
* @param userName
* @param password
* @return 操作数据库影响行数
*/
public int insertUser(String userName, String password,int status) {
String sql = "insert into users values(?,?,?) ";
String[] params = new String[] { userName, password ,status+""};
return this.executeSQL(sql, params);
}
/**
* 查找所有的注册用户信息
* @return 用户列表
*/
public List selectAllUser(){
List list=new ArrayList();
String sql = "select * from Users ";
try {
conn = this.getConnection();
pstmt = conn.prepareStatement(sql);
rs = pstmt.executeQuery();
while(rs.next()) {
Users user = new Users();
user.setId(rs.getInt("id"));
user.setUserName(rs.getString("userName"));
user.setPassword(rs.getString("password"));
user.setRealName(rs.getString("realName"));
user.setSex(rs.getString("sex"));
user.setAge(rs.getInt("age"));
user.setBirthdayTime(rs.getString("birthdayTime"));
user.setHeader(rs.getString("header"));
user.setPhone(rs.getString("phone"));
user.setEmail(rs.getString("email"));
user.setQuestion(rs.getString("question"));
user.setAnswer(rs.getString("answer"));
user.setAddress(rs.getString("address"));
user.setMarryStatus(rs.getInt("marryStatus"));
user.setOnStatus(rs.getInt("onStatus"));
user.setLasttime(rs.getString("lasttime"));
user.setRegisttime(rs.getString("registtime"));
user.setHeight(rs.getInt("height"));
user.setWeight(rs.getInt("weight"));
user.setHobby(rs.getString("hobby"));
user.setIntroduction(rs.getString("introduction"));
list.add(user);
}
} catch (Exception e) {
e.printStackTrace();
} finally {
this.closeAll(conn, pstmt, rs);
}
return list;
}
/**
* 根据用户ID,进行删除操作
* @param userID
* @return 执行SQL语句所影响的数据库行数
*/
public int deleteUserByID(String id){
String sql="delete from Users where id = ? ";
String[] param = new String[]{ id };
return this.executeSQL(sql, param);
}
public Users selectUserByID(int id) {
Users user = null;
String sql = "select * from Users where id = ? ";
try {
conn = DBConnection.getConnection();
pstmt = conn.prepareStatement(sql);
pstmt.setInt(1, id);
rs = pstmt.executeQuery();
//System.out.print(rs.next());
if (rs.next()) {
user = new Users();
user.setId(rs.getInt("id"));
user.setUserName(rs.getString("userName"));
user.setPassword(rs.getString("password"));
user.setRealName(rs.getString("realName"));
user.setSex(rs.getString("sex"));
user.setAge(rs.getInt("age"));
user.setBirthdayTime(rs.getString("birthdayTime"));
user.setHeader(rs.getString("header"));
user.setPhone(rs.getString("phone"));
user.setEmail(rs.getString("email"));
user.setQuestion(rs.getString("question"));
user.setAnswer(rs.getString("answer"));
user.setAddress(rs.getString("address"));
user.setMarryStatus(rs.getInt("marryStatus"));
user.setOnStatus(rs.getInt("onStatus"));
user.setLasttime(rs.getString("lasttime"));
user.setRegisttime(rs.getString("registtime"));
user.setHeight(rs.getInt("height"));
user.setWeight(rs.getInt("weight"));
user.setHobby(rs.getString("hobby"));
user.setIntroduction(rs.getString("introduction"));
}
} catch (Exception e) {
e.printStackTrace();
} finally {
DBConnection.closeResultSet(rs);
DBConnection.closeStatement(pstmt);
DBConnection.closeConnection();
}
return user;
}
public int UpdateUserInfo(Users user){
int count=0;
String sql = "update Users set userName=?,password=?,realName=?,sex=?,birthdayTime=?,header=?,phone=?,email=?,question=?,answer=?,address=?,marryStatus=?,height=?,weight=?,hobby=?,introduction=? where id=?";
try {
conn = DBConnection.getConnection();
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, user.getUserName());
pstmt.setString(2, user.getPassword());
pstmt.setString(3, user.getRealName());
pstmt.setString(4, user.getSex());
pstmt.setString(5, user.getBirthdayTime());
pstmt.setString(6,user.getHeader());
pstmt.setString(7,user.getPhone());
pstmt.setString(8,user.getEmail());
pstmt.setString(9,user.getQuestion());
pstmt.setString(10,user.getAnswer());
pstmt.setString(11,user.getAddress());
pstmt.setInt(12, user.getMarryStatus());
pstmt.setInt(13,user.getHeight());
pstmt.setInt(14,user.getWeight());
pstmt.setString(15,user.getHobby());
pstmt.setString(16,user.getIntroduction());
pstmt.setInt(17, user.getId());
count=pstmt.executeUpdate();
} catch (SQLException e) {
e.printStackTrace();
}
finally{
DBConnection.closeResultSet(rs);
DBConnection.closeStatement(pstmt);
DBConnection.closeConnection();
}
return count;
}
////////////////////////////////////////////////////////////////////////
//得到用户的状态
public int getStatusByUserName(String userName){
int count=0;
String sql="select onStatus from Users where userName=? ";
try {
conn = DBConnection.getConnection();
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, userName);
rs = pstmt.executeQuery();
if (rs.next()) {
count=rs.getInt("onStatus");
}
} catch (Exception e) {
e.printStackTrace();
} finally {
DBConnection.closeResultSet(rs);
DBConnection.closeStatement(pstmt);
DBConnection.closeConnection();
}
return count;
}
//更新用户状态
public int updateOnStatusUp(String userName){
String sql = "update Users set onStatus=1 where userName=? ";
String[] params = new Strin
Java+SQL2005 交友网站
5星 · 超过95%的资源 需积分: 9 42 浏览量
2010-02-04
15:16:41
上传
评论 4
收藏 5.38MB RAR 举报 
Java+SQL2005 交友网站 （557个子文件） 
UsersDao.class 10KB PhotoDao.class 9KB AlbumDao.class 6KB CommunicationDao.class 5KB ArticleDao.class 5KB FriendDao.class 5KB Users.class 4KB AlbumServlet.class 4KB MessageDao.class 3KB DBConnection.class 3KB NoticeDao.class 3KB AdminDao.class 3KB UpdateUserInfoServlet.class 3KB AddCommunicationServlet.class 3KB SelectFriendsServlet.class 3KB SQLCommandBean.class 3KB AddArticleServlet.class 3KB SelectCommunicationServlet.class 3KB UpdateCommunicationServlet.class 3KB MessagePostServlet.class 2KB ArticleCotentServlet.class 2KB SelectArticleServlet.class 2KB LoginServlet.class 2KB DeleteMessageServlet.class 2KB Album.class 2KB Photo.class 2KB DeleteArticleServlet.class 2KB DeleteCommunicationServlet.class 2KB PartionPage.class 2KB Communication.class 2KB MyTools.class 2KB LogoutServlet.class 1KB Message.class 1KB Article.class 1KB Notice.class 1KB Admin.class 909B Friend.class 826B CommunicationType.class 733B Validate.class 422B CommunicationTypeDao.class 293B .classpath 450B css.css 10KB uutangMainStyle.css 8KB base.css 3KB exobud.css 210B Thumbs.db 260KB Thumbs.db 128KB Thumbs.db 100KB Thumbs.db 85KB Thumbs.db 66KB Thumbs.db 54KB Thumbs.db 18KB
0112.gif 39KB 033.gif 26KB 1919452.gif 19KB toolbar_bg.gif 16KB img_005.gif 11KB face_bg.gif 11KB 1919454.gif 9KB 1919456.gif 9KB 1919458.gif 9KB tu07.gif 8KB 19194511.gif 8KB 1919453.gif 7KB 1919450.gif 7KB 1919451.gif 7KB tu02.gif 6KB tu03.gif 6KB 19194518.gif 6KB tu01.gif 5KB 19194526.gif 5KB tu06.gif 5KB 0110.gif 5KB 07j.gif 5KB tu04.gif 5KB tu08.gif 4KB 022.gif 4KB tu05.gif 4KB 044.gif 4KB 011.gif 4KB 0113.gif 3KB ParaFormatting.gif 3KB girl.gif 2KB 036.gif 2KB 066.gif 2KB justifyformat_bg.gif 2KB title_bg.gif 2KB 099.gif 2KB actup.gif 2KB 002.gif 2KB 019.gif 2KB 14.gif 2KB play.gif 2KB 055.gif 2KB playup.gif 2KB paste_over.gif 2KB 039.gif 2KB 010.gif 2KB dog.gif 2KB ParaFormatting_over.gif 2KB共 557 条
- 1
- 2
- 3
- 4
- 5
- 6
- 1
- 2
前往页