userdaoimpl.java

房产交易平台 服务器端建议代码。工厂模型。

package com.fc.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 com.fc.dao.conn.DBConn;

public class UserDaoImpl implements UserDao {
	public UserDaoImpl() {
	}

	/*
	 * (non-Javadoc)
	 * 
	 * @see com.fc.dao.UserDao#findByUname(java.lang.String)
	 */
	public User findByUname(String uname) {
		User u = null;
		Connection conn = null;
		conn = DBConn.getConnection();
		PreparedStatement prst = null;
		try {
			prst = conn
					.prepareStatement("select id,uname,password,realname,tel,addr,email,cardid from user where uname=?");
			prst.setString(1, uname);
			ResultSet rs = prst.executeQuery();
			u=new User();
			if (rs.next()) {
				u.setId(rs.getLong(1));
				u.setUname(rs.getString(2));
				u.setPassword(rs.getString(3));
				u.setRealname(rs.getString(4));
				u.setTel(rs.getString(5));
				u.setAddr(rs.getString(6));
				u.setEmail(rs.getString(7));
				u.setCardid(rs.getString(8));
			}
		} catch (SQLException ea) {
			ea.printStackTrace();
		} finally {
			if (conn != null)
				try {
					conn.close();
				} catch (SQLException e) {
					e.printStackTrace();
				}
		}
		return u;
	}

	/*
	 * (non-Javadoc)
	 * 
	 * @see com.fc.dao.UserDao#findById(long)
	 */
	public User findById(long id) {
		User u = new User();
		Connection conn = null;
		conn = DBConn.getConnection();
		PreparedStatement prst = null;
		try {
			prst = conn
					.prepareStatement("select id,uname,password,realname,tel,addr,email,cardid from user where id=?");
			prst.setLong(1, id);
			ResultSet rs = prst.executeQuery();
			if(rs.next()){
			u.setId(rs.getLong(1));
			u.setUname(rs.getString(2));
			u.setPassword(rs.getString(3));
			u.setRealname(rs.getString(4));
			u.setTel(rs.getString(5));
			u.setAddr(rs.getString(6));
			u.setEmail(rs.getString(7));
			u.setCardid(rs.getString(8));
			}
		} catch (SQLException ea) {
			ea.printStackTrace();
		} finally {
			if (conn != null)
				try {
					conn.close();
				} catch (SQLException e) {
					e.printStackTrace();
				}
		}
		return u;
	}

	/*
	 * (non-Javadoc)
	 * 
	 * @see com.fc.dao.UserDao#findAll()
	 */
	public List findAll() {
		List<User> list = new ArrayList<User>();
		User u = null;
		Connection conn = null;
		ResultSet rs = null;
		PreparedStatement prst = null;
		try {
			conn = DBConn.getConnection();
			prst = conn
					.prepareStatement("select id,uname,password,realname,tel,addr,email,cardid from user");
			rs = prst.executeQuery();
			while (rs.next()) {
				u=new User();
				u.setId(rs.getLong(1));
				u.setUname(rs.getString(2));
				u.setPassword(rs.getString(3));
				u.setRealname(rs.getString(4));
				u.setTel(rs.getString(5));
				u.setAddr(rs.getString(6));
				u.setEmail(rs.getString(7));
				u.setCardid(rs.getString(8));
				list.add(u);
			}
		} catch (SQLException ea) {
			ea.printStackTrace();
		} finally {
			if (conn != null)
				try {
					rs.close();
					conn.close();
				} catch (SQLException e) {
					e.printStackTrace();
				}
		}
		return list;
	}

	/*
	 * (non-Javadoc)
	 * 
	 * @see com.fc.dao.UserDao#save(com.fc.dao.User)
	 */
	public boolean save(User u) {
		boolean ok = false;
		Connection conn = null;
		PreparedStatement prst = null;
		try {
			conn = DBConn.getConnection();
			prst = conn
					.prepareStatement("insert into user(uname,password,realname,tel,addr,email,cardid)values(?,?,?,?,?,?,?)");
			prst.setString(1, u.getUname());
			prst.setString(2, u.getPassword());
			prst.setString(3, u.getRealname());
			prst.setString(4, u.getTel());
			prst.setString(5, u.getAddr());
			prst.setString(6, u.getEmail());
			prst.setString(7, u.getCardid());
			prst.execute();
			ok = true;
		} catch (SQLException ea) {
			ea.printStackTrace();
			ok = false;
		} finally {
			if (conn != null)
				try {
					conn.close();
				} catch (SQLException e) {
					e.printStackTrace();
				}
		}
		return ok;
	}

	/*
	 * (non-Javadoc)
	 * 
	 * @see com.fc.dao.UserDao#modify(com.fc.dao.User)
	 */
	public boolean modify(User u) {
		boolean ok = false;
		Connection conn = null;
		PreparedStatement prst = null;
		try {
			conn = DBConn.getConnection();
			prst = conn
					.prepareStatement("update user set password=?,realname=?,tel=?,addr=?,email=?,cardid=? where id=?");
			prst.setString(1, u.getPassword());
			prst.setString(2, u.getRealname());
			prst.setString(3, u.getTel());
			prst.setString(4, u.getAddr());
			prst.setString(5, u.getEmail());
			prst.setString(6, u.getCardid());
			prst.setLong(7, u.getId());
			prst.execute();
			ok = true;
		} catch (SQLException ea) {
			ea.printStackTrace();
			ok = false;
		} finally {
			if (conn != null)
				try {
					conn.close();
				} catch (SQLException e) {
					e.printStackTrace();
				}
		}
		return ok;
	}

	/*
	 * (non-Javadoc)
	 * 
	 * @see com.fc.dao.UserDao#delete(com.fc.dao.User)
	 */
	public boolean delete(User u) {
		boolean ok = false;
		Connection conn = null;
		PreparedStatement prst = null;
		try {
			conn = DBConn.getConnection();
			prst = conn.prepareStatement("delete from user where id=?");
			prst.setLong(1, u.getId());
			prst.execute();
			ok = true;
		} catch (SQLException ea) {
			ea.printStackTrace();
			ok = false;
		} finally {
			if (conn != null)
				try {
					conn.close();
				} catch (SQLException e) {
					e.printStackTrace();
				}
		}
		return ok;
	}
}