registermodule.java

文件共享虚拟社区,可以实现上传下载聊天等多种信息交互.

/*
 * 创建日期 2005-9-7
 *
 * TODO 要更改此生成的文件的模板，请转至
 * 窗口 － 首选项 － Java － 代码样式 － 代码模板
 */
package fsc.server.modules;

/**
 * @author 清澄
 *
 * TODO 要更改此生成的类型注释的模板，请转至
 * 窗口 － 首选项 － Java － 代码样式 － 代码模板
 */

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.PreparedStatement;
import java.util.Date;

import fsc.models.*;
import fsc.models.exceptions.*;


public class RegisterModule {
	private static RegisterModule registerModule= new RegisterModule();
	private static LogModule log= new LogModule("Register.txt");
	
	
	public static RegisterResultModel register(RegisterModel rm)
	{
		Statement st=null;
		PreparedStatement pst=null;
		ResultSet rs=null;
		RegisterResultModel ret=null;
		try
		{
            Connection conn = DatabaseModule.getConnection();
			
			st = conn.createStatement();
			rs = st.executeQuery("select username from user_info where username='" +
	                rm.getUserName() +"'");
			
			
			if (rs.next())
			{
				ret= new RegisterResultModel("NO\n该用户名已经被注册.请您重新选择.");
				log.log(new Date().toLocaleString()+'\t'+rm.getUserName() + "\t\t" + rm.getPassword()+" regesited\n" );
			}
			else
			{
				
				String newsql="insert into user_info (username,password,sex,question,answer,email,status,money) values (?,?,?,?,?,?,?,?)";
				
				pst= conn.prepareCall(newsql);
				pst.clearParameters();
				pst.setString(1,rm.getUserName());
				pst.setString(2,rm.getPassword());
				pst.setString(3,String.valueOf( rm.getSex() ));
				pst.setString(4,rm.getQuestion());
				pst.setString(5,rm.getAnswer());
				pst.setString(6,rm.getEmail());
				pst.setBoolean(7,false);
				int money=2000;
				pst.setLong(8,2000);
				try
				{
					pst.executeUpdate();
				}
				catch(SQLException sqle)
				{
					sqle.printStackTrace();
				}
				ret= new RegisterResultModel("YES\n"+rm.getUserName()+"\n"+rm.getEmail());
			
			
		
				/*
                String username=rm.getUserName();//取得输入的用户名
            	System.out.println("用户名:"+username);
            	String passwd=rm.getPassword();//取得输入的密码
            	String sex=String.valueOf(rm.getSex());   //sex
            	String ques=rm.getQuestion();
            	String ans= rm.getAnswer();
                String mail=rm.getEmail();   //邮箱
                int money=2000;
               // String sex=st.nextToken();    //性别
                String newSql="insert into user_info (username,password,sex,question,answer,email,money) values ('" +
                username+ "','" + passwd + "','" +sex+ "','"+ques+ "','"+ans+ "','" +mail+ "',"+ money + " )";
                System.out.println(newSql);
                st.executeUpdate(newSql);
                ret= new RegisterResultModel("YES\n"+rm.getUserName()+"\n"+rm.getEmail());
               */
                
               // String newsql="insert into user_info (username,password,sex,question,answer,email,status,money) values (?,?,?,?,?,?,?,?) ";

			//	ret= new RegisterResultModel("YES\nYou have successfully register the username "+rm.getUserName());
				log.log(new Date().toLocaleString()+'\t'+rm.getUserName() + "\t\t" + rm.getPassword()+" login failed \n" );
			}
		}
		catch(Exception ex)
		{
			ex.printStackTrace();
		}
		finally
		{
			try {
				//rs.clearWarnings();
				rs.close();
				st.close();
				rs=null;
				st=null;
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}
			
		}
		return ret;
	}
	
	public static void main(String[] args) {
	}
}