dbusermsg.java

本程序用jsp+servlet+javaBean+EJB实现交友系统

package com.database;

import java.sql.*;
import java.util.*;
import com.database.DataBase;
import com.database.strformat;
import com.database.userMsg;
import javax.servlet.http.*;

/**
 *这里以JSP页面的提交对象request作为参数传进改类中
 *关联用户注册页面reg.jsp
 */

public class dbUserMsg extends DataBase{
	private userMsg user=new userMsg();//创建新的用户对象
	private HttpServletRequest request;//建立页面请求	
	private String message="";	//声明出错信息提示
	private long id;		//声明注册后返回的用户ID
	//private String userType;//声明注册后返回的用户类别
	//private String nickName="";//声明注册后返回的用户名	
	//private String userGender;
	private Calendar MyDate = Calendar.getInstance();
	
	public dbUserMsg() throws Exception{
		super();
	}
	
	public String getGbk(String str){
		try{
			//return new String(str.getBytes("gb2312"));
			return str;
		}catch(Exception e){
			return str;
		}
	}	
//	将页面表单传来的资料分解
	public boolean getRequest(HttpServletRequest newrequest){
		boolean flag=false;
		try{
			request=newrequest;
//			获取userType参数			
			String userType=request.getParameter("userType");
			if(userType==null||userType.equals("")){
				userType="";
				message=message+"<br>请选择会员类别";
			}
			user.setUserType(getGbk(userType));			
//			获取nickName参数
			String nickName=request.getParameter("nickName");
			if(nickName==null||nickName.equals("")){
				nickName="";
				message=message+"<br>请输入您的登录用户名";
			}
			user.setNickName(getGbk(nickName));
//			获取password参数
			String password=request.getParameter("password");
			if(password==null||password.equals("")){
				password="";
				message=message+"<br>请输入您的密码";
			}
			user.setPassword(getGbk(password));
//			获取userGender参数
			String userGender=request.getParameter("userGender");
			if(userGender==null||userGender.equals("")){
				userGender="";
				message=message+"<br>请选择您的性别";
			}
			user.setUserGender(getGbk(userGender));
//			获取Birthday参数
			String year=request.getParameter("year");
			String month=request.getParameter("month");
			String day=request.getParameter("day");
			String Birthday=year+"."+month+"."+day;
			if(year==null||year.equals("")||month==null||month.equals("")||day==null||day.equals("")){
				Birthday="";
				message=message+"<br>请选择您的出生时间";
			}
			user.setBirthday(getGbk(Birthday));
//			获取province参数
			String province=request.getParameter("province");
			if(province==null||province.equals("")){
				province="";
				message=message+"<br>请选择您所在的省";
			}
			user.setProvince(getGbk(province));		
//			获取city参数
			String city=request.getParameter("city");
			if(city==null||city.equals("")){
				city="";
				message=message+"<br>请选择您所在的城市";
			}
			user.setCity(getGbk(city));		
//			获取email参数
			String email=request.getParameter("email");
			if(email==null||email.equals("")){
				email="";
				message=message+"<br>请输入您的电子邮箱";
			}
			user.setEmail(getGbk(email));
//			获取telephone参数
			String telephone=request.getParameter("telephone");
			if(telephone==null||telephone.equals("")){
				telephone="";
				message=message+"<br>请输入您的联系电话";
			}
			user.setTelephone(getGbk(telephone));
//			
		if(message.equals("")){
			flag=true;
		}
		return flag;
		}catch(Exception e){
			return flag;
		}
	}
//	将用户信息加入数据库	
	public boolean insert(HttpServletRequest req)throws Exception{
		if(getRequest(req)){
			sql="select * from my_users where nickName='"
				+user.getNickName()+"'";
			rs=stmt.executeQuery(sql);
			if(rs.next()){
				message=message+"改用户名已存在！";
				rs.close();
				return false;
			}	
			
			sql="select max(id) as id from my_users WHERE province='"
				+user.getProvince() +"' and city='" 
				+user.getCity()+"'";
			rs=stmt.executeQuery(sql);
			if(rs.next()){
				id=rs.getLong("id")+1;
			}
			
			sql="insert into my_users(id,userType,nickName,password,userGender,Birthday,province,city,email,telephone,regTime,regIPAddress) values('";
			sql=sql+id+"','";
			sql=sql+strformat.toSql(user.getUserType())+"','";
			sql=sql+strformat.toSql(user.getNickName())+"','";
			sql=sql+strformat.toSql(user.getPassword())+"','";
			sql=sql+strformat.toSql(user.getUserGender())+"','";
			sql=sql+strformat.toSql(user.getBirthday())+"','";
			sql=sql+strformat.toSql(user.getProvince())+"','";
			sql=sql+strformat.toSql(user.getCity())+"','";
			sql=sql+strformat.toSql(user.getEmail())+"','";
			sql=sql+strformat.toSql(user.getTelephone())+"','";
			sql=sql+MyDate.getTime()+"','";//使用getTime()获得系统时间
			sql=sql+strformat.toSql(req.getRemoteAddr());//利用getRemoteAddr()函数取得用户IP	
			sql=sql+"');";
			
			try{
				stmt.execute(sql);
				return true;
			}catch(SQLException sqle){
				System.out.println(sqle.toString());
				return false;
			}
		}else{
			return false;
		}
	}

//	检测帐号	
	public boolean excute(String nickName)throws Exception{
		sql="select nickName from my_users where nickName='"
			+nickName+"'";
		rs=stmt.executeQuery(sql);
		if(rs.next()){
			//message=message+"改用户名已存在！";
			rs.close();
			return false;
		}
		return true;
	}

	public String getMessage() {
		return message;
	}
	/*
	public String getNickName() {
		return nickName;
	}
	public long getId() {
		return id;
	}
	public String getUserGender() {
		return userGender;
	}
	public String getUserType() {
		return userType;
	}*/
}