userdaoimp.java

学习资料学习资料学习资料学习资料学习资料

package com.java.dao;

import java.sql.Connection;
import java.sql.PreparedStatement;
import com.java.dao.impl.UserDao;
import com.java.entity.User;
import java.sql.ResultSet;

public class UserDaoimp extends Conn implements UserDao {

	public int UpdateUser(User user) {
		String sql="update username set upass=?,head=?,regtime=?,gender=? where uname=?";
		String [] suser=new String[5];
		suser[0]=user.getUPass();
		suser[1]=user.getHead();
		suser[2]=user.getRegTime();
		suser[3]=String.valueOf(user.getGender());
		suser[4]=user.getUName();
		return executeSql(sql,suser);
	}

	public int addUser(User user) {
		String sql="insert into username values(?,?,?,?,?)";
		String [] suser=new String[5];
		suser[0]=user.getUName();
		suser[1]=user.getUPass();
		suser[2]=user.getHead();
		suser[3]=user.getRegTime();
		suser[4]=String.valueOf(user.getGender());
		
		return executeSql(sql,suser);
	}

	public int DeleteUser(String username) {
		String sql="delete from username where uname=?";
		String [] suser=new String[1];
		suser[0]=username;
		return executeSql(sql,suser);
	}

	public User FindUser(String username) {		
		String sql="select * from username where uname=?";
		User user=new User();
		Connection conn=null;
		ResultSet rs=null;
		PreparedStatement pt=null;
		try {
			conn= sqlconnection();
			pt = conn.prepareStatement(sql);
			pt.setString(1, username);
			rs=pt.executeQuery();
			
			while(rs.next()){
				user.setUId(rs.getInt("uid"));
				user.setUName(rs.getString("uname"));
				user.setUPass(rs.getString("upass"));
				user.setHead(rs.getString("head"));
				user.setRegTime(rs.getString("regtime"));
				user.setGender(rs.getInt("gender"));
			}
			
		} catch (Exception e) {
			// TODO: handle exception
		}
		finally{
			closeConnection(conn,pt,rs);
		}
		return user;
	}

}