userserviceimpl.java

青年论坛设计想关代码

package com.ql.bbs.service.impl;

import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.util.List;

import com.ql.bbs.model.User;
import com.ql.bbs.service.UserService;
import com.ql.bbs.util.JdbcUtils;

public class UserServiceImpl implements UserService {

	/**
	 *  增加用户
	 */
	public boolean addUser(User user) {
		Connection con = null;
		PreparedStatement pstmt = null;
		ResultSet rs = null;
		String sql = "insert into t_user(name, password,realName,age,sex,addr,qq,email, birthday,createTime) "+
					 "values(?,?,?,?,?,?,?,?,?,?)";
		try {
			con = JdbcUtils.getInstance().getConnection();
			pstmt = con.prepareStatement(sql);
			
			pstmt.setString(1, user.getName());
			pstmt.setString(2, user.getPassword());
			pstmt.setString(3, user.getRealName());
			pstmt.setInt(4, user.getAge());
			pstmt.setInt(5, user.getSex());
			pstmt.setString(6, user.getAddr());
			pstmt.setString(7, user.getQq());
			pstmt.setString(8, user.getEmail());
			pstmt.setDate(9, new java.sql.Date(user.getBirthday().getTime()));
			pstmt.setDate(10, new java.sql.Date(user.getCreateTime().getTime()));
			
			pstmt.executeUpdate();
		} catch (Exception e) {
			e.printStackTrace();
			JdbcUtils.getInstance().close(con, pstmt, rs);
			return false;
		} finally {
			JdbcUtils.getInstance().close(con, pstmt, rs);
		}
		return true;
	}

	/**
	 * 删除用户
	 */
	public boolean delUser(int id) {
		Connection con = null;
		PreparedStatement pstmt = null;
		ResultSet rs = null;
		String sql = "delete from t_user where id = ?";
		try {
			con = JdbcUtils.getInstance().getConnection();
			pstmt = con.prepareStatement(sql);
			pstmt.setInt(1, id);
			pstmt.executeUpdate();
		} catch (Exception e) {
			e.printStackTrace();
			JdbcUtils.getInstance().close(con, pstmt, rs);
			return false;
		} finally {
			JdbcUtils.getInstance().close(con, pstmt, rs);
		}
		return true;
	}

	/**
	 * 按照ID查找用户
	 */
	public User findUserById(int id) {
		Connection con = null;
		PreparedStatement pstmt = null;
		ResultSet rs = null;
		User user = null;
		String sql = "select id,name, password,realName,age,sex,addr,qq,email, birthday,createTime " +
					 "from t_user where id=?";
		try {
			con = JdbcUtils.getInstance().getConnection();
			pstmt = con.prepareStatement(sql);
			pstmt.setInt(1, id);
			rs = pstmt.executeQuery();
			
			if (rs.next()) {
				user = new User();
				user.setId(id);
				user.setName(rs.getString("name"));
				user.setPassword(rs.getString("password"));
				user.setRealName(rs.getString("realName"));
				user.setAge(rs.getInt("age"));
				user.setSex(rs.getInt("sex"));
				user.setAddr(rs.getString("addr"));
				user.setQq(rs.getString("qq"));
				user.setEmail(rs.getString("email"));
				user.setBirthday(rs.getDate("birthday"));
				user.setCreateTime(rs.getDate("createTime"));
			}
			
		} catch (Exception e) {
			e.printStackTrace();
			JdbcUtils.getInstance().close(con, pstmt, rs);
			return null;
		} finally {
			JdbcUtils.getInstance().close(con, pstmt, rs);
		}
		return user;
	}

	/**
	 * 验证用户登陆
	 */
	public User login(String name, String password) {
		Connection con = null;
		PreparedStatement pstmt = null;
		ResultSet rs = null;
		User user = null;
		String sql = "select id,name, password,realName,age,sex,addr,qq,email, birthday,createTime " +
					 "from t_user where name = ? and password = ?";
		try {
			con = JdbcUtils.getInstance().getConnection();
			pstmt = con.prepareStatement(sql);
			pstmt.setString(1, name);
			pstmt.setString(2, password);
			rs = pstmt.executeQuery();
			
			if (rs.next()) {
				user = new User();
				user.setId(rs.getInt("id"));
				user.setName(rs.getString("name"));
				user.setPassword(rs.getString("password"));
				user.setRealName(rs.getString("realName"));
				user.setAge(rs.getInt("age"));
				user.setSex(rs.getInt("sex"));
				user.setAddr(rs.getString("addr"));
				user.setQq(rs.getString("qq"));
				user.setEmail(rs.getString("email"));
				user.setBirthday(rs.getDate("birthday"));
				user.setCreateTime(rs.getDate("createTime"));
			}
			
		} catch (Exception e) {
			e.printStackTrace();
			JdbcUtils.getInstance().close(con, pstmt, rs);
			return null;
		} finally {
			JdbcUtils.getInstance().close(con, pstmt, rs);
		}
		return user;
	}

	/**
	 * 显示所有用户
	 */
	public List searchUsers() {
		// TODO Auto-generated method stub
		return null;
	}

	/**
	 * 更新用户
	 */
	public boolean updateUser(User user) {
		Connection con = null;
		PreparedStatement pstmt = null;
		ResultSet rs = null;
		String sql = "update t_user set name = ?, password = ?,realName = ?, age = ?, sex = ?,addr = ?,qq = ?," +
					"email=?, birthday = ?,createTime = ? where id = ? ";
		try {
			con = JdbcUtils.getInstance().getConnection();
			pstmt = con.prepareStatement(sql);
			
			pstmt.setString(1, user.getName());
			pstmt.setString(2, user.getPassword());
			pstmt.setString(3, user.getRealName());
			pstmt.setInt(4, user.getAge());
			pstmt.setInt(5, user.getSex());
			pstmt.setString(6, user.getAddr());
			pstmt.setString(7, user.getQq());
			pstmt.setString(8, user.getEmail());
			pstmt.setDate(9, new java.sql.Date(user.getBirthday().getTime()));
			pstmt.setDate(10, new java.sql.Date(user.getCreateTime().getTime()));
			pstmt.setInt(11, user.getId());
			pstmt.executeUpdate();
		} catch (Exception e) {
			e.printStackTrace();
			JdbcUtils.getInstance().close(con, pstmt, rs);
			return false;
		} finally {
			JdbcUtils.getInstance().close(con, pstmt, rs);
		}
		return true;
	}

}