usermanagedaojdbcimple.java

用myeclipse开发的一个BBS论坛系统的源代码。大家可以看看。

package cn.edu.rjxy.dao;

import java.util.ArrayList;
import java.util.Map;
import java.sql.*;

import javax.sql.DataSource;
public class UserManageDAOJDBCImple implements UserManageDAOInterface 
{
	private java.sql.Connection con=null;
	ConnectDBInterface connectDBBean=null;
	public UserManageDAOJDBCImple() 
	{
		connectDBBean=new ConnectDBBean();
	}
	public boolean BatchDeleteUserInfo(ArrayList deletedUserIDs) {
		// TODO 自动生成方法存根
		return false;
	}

	public boolean DeleteOneUserInfo(int deletedUserID) {
		// TODO 自动生成方法存根
		return false;
	}
	public boolean InsertOneUserInfo(UserInfoPO oneUserInfoPO) {
		// TODO 自动生成方法存根
		String insert_SqlStatement=null;
		insert_SqlStatement="insert into userinfo(userName,userPassWord,nickname,email,birthday,blood,gender,qq,msn) values(?,?,?,?,?,?,?,?,?)";
		
		//insert_SqlStatement="insert into info(userName,userPassWord) values(?,?)";
		con=connectDBBean.getConnection();
	
		try
		{
			
			java.sql.PreparedStatement pstmt = con.prepareStatement(insert_SqlStatement,
					ResultSet.TYPE_SCROLL_SENSITIVE,
					ResultSet.CONCUR_UPDATABLE);

			//System.out.println(oneUserInfoPO.getGender());
			pstmt.setString(1, oneUserInfoPO.getUserName());
			pstmt.setString(2, oneUserInfoPO.getUserPassWord());
			pstmt.setString(3, oneUserInfoPO.getNickname());
			pstmt.setString(4, oneUserInfoPO.getEmail());
			pstmt.setString(5, oneUserInfoPO.getBirthday());
			pstmt.setString(6, oneUserInfoPO.getBlood());
			pstmt.setString(7, oneUserInfoPO.getGender());
			pstmt.setString(8, oneUserInfoPO.getQq());
			pstmt.setString(9, oneUserInfoPO.getMsn());
			pstmt.executeUpdate();
		}
		catch(SQLException e)
		{
			e.printStackTrace();
			System.out.println("在插入数据库表时出现错误!");
			return false;
		}
		return true;
	}
	public ArrayList SelectAllUserInfoData() {
		// TODO 自动生成方法存根
		return null;
	}
	
	
	public boolean isLogin(String userName,String userPassword){
		con=connectDBBean.getConnection();
		String sql = "select userPassword from userInfo where userName='"
			+ userName + "'";
		try{
		Statement pstmt = con.createStatement();
		ResultSet rs = pstmt.executeQuery(sql);
		String password = "";
		if (rs.next()) {			
			password = rs.getString("userPassword");
			// System.out.println(password);
		}
		if (password.equals(userPassword)) {
			return true;
		} else {
			return false;
		}
		}catch(SQLException e)
		{
			System.out.println(e.getMessage());
			return false;
		}		
	}
	
	public UserInfoPO SelectOneUserInfoData(String userName) 
	{
		ResultSet rs=null;
		UserInfoPO oneUserInfo=null;
		String select_SqlStatement=null;
		
	    select_SqlStatement="select * from userinfo where userName='"+userName+ "'";
		con=connectDBBean.getConnection();
		try
		{
			java.sql.PreparedStatement pstmt = con.prepareStatement(select_SqlStatement,
					ResultSet.TYPE_SCROLL_SENSITIVE,
					ResultSet.CONCUR_UPDATABLE);
			rs = pstmt.executeQuery();
			if(rs.next())
			{
				//rs.getString(columnIndex)
				oneUserInfo=new UserInfoPO();   //目前只转换下面的几个属性
				oneUserInfo.setUserName(rs.getString("userName"));
				oneUserInfo.setUserPassWord(rs.getString("userPassWord"));
				oneUserInfo.setNickname(rs.getString("nickname"));
				oneUserInfo.setEmail(rs.getString("email"));
				oneUserInfo.setBirthday(rs.getString("birthday"));
				oneUserInfo.setBlood(rs.getString("blood"));
				oneUserInfo.setGender(rs.getString("gender"));
				oneUserInfo.setQq(rs.getString("qq"));
				oneUserInfo.setMsn(rs.getString("msn"));
				
				//oneUserInfo.setUserDepartment(rs.getString("userDepartment"));
			}
			else
			{
				oneUserInfo=null;
			}
		}
		catch(SQLException e)
		{
			System.out.println("在查询数据库表时出现错误！");
		}
		return oneUserInfo;
	}
	public ArrayList SelectSomeUserInfoData(Map whereMap) {
		// TODO 自动生成方法存根
		return null;
	}
	public boolean UpdateOneUserInfo(UserInfoPO oneUserInfo) 
	{
		//ResultSet rs=null;
		
		con=connectDBBean.getConnection();
		//String select_SqlStatement=null;
		
		
		//检查userEmail是否为空，若不是则更新

			String updateUserPassWord = "update UserInfo set msn=?,nickname=?" +
			",email=?,birthday=?,blood=?,gender=?,qq=? where userName = ?";
			try
			{   
				PreparedStatement pstmt = con.prepareStatement(updateUserPassWord, ResultSet.TYPE_SCROLL_INSENSITIVE,ResultSet.CONCUR_UPDATABLE);
				con.setAutoCommit(true);
				//pstmt.setString(1,oneUserInfo.getMsn());
				pstmt.setString(1,"123456");
				pstmt.setString(2,oneUserInfo.getNickname());
				pstmt.setString(3,oneUserInfo.getEmail());
				pstmt.setString(4,oneUserInfo.getBirthday());
				pstmt.setString(5,oneUserInfo.getBlood());
				pstmt.setString(6,oneUserInfo.getGender());
				pstmt.setString(7,oneUserInfo.getQq());
				pstmt.setString(8,oneUserInfo.getUserName());


//				pstmt.setString(1,"1");
//				pstmt.setString(2,"1");
//				pstmt.setString(3,"1");
//				pstmt.setString(4,"1");
//				pstmt.setString(5,"1");
//				pstmt.setString(6,"1");
//				pstmt.setString(7,"1");
//				pstmt.setString(8,"wsk");
				
				pstmt.executeUpdate();
			}catch(SQLException e)
			{
				System.out.println(e.getMessage());
			}
			return true;
	}		
	

	public UserInfoPO SelectOneUserInfoData(String userName, String userPassWord) {
		// TODO Auto-generated method stub
		return null;
	}	
	
	
}