import java.sql.*;

public class BookFloatingServer
{
	public static int Login(String Email,String Password) {
		Connection conn = null;
		String url="jdbc:mysql://gameharbor.cn:3306/test";
		Statement stmt = null;
		ResultSet rs = null;
		int ret=0;
		
		String RemotePassword = new String();
		try{
			conn=DriverManager.getConnection(url,"testuser","pwdtest");
			stmt=conn.createStatement();
			rs=stmt.executeQuery("SELECT pwass FROM user where email=\""+Email+"\"");
			if(rs.next())
			{
				RemotePassword=rs.getString(1);
			}
			
			if(RemotePassword.equals(Password))
			{
				ret=1;///Password Matchs
			}
			else
			{
				ret=0;///Password Does not Matchs
			}
		} catch(SQLException e) {
			e.printStackTrace();
			ret=-1;// Connection Error
		}
		finally
		{
			try{
				if(rs!=null) rs.close();
			} catch(SQLException e) {
				e.printStackTrace();
			}
			
			try{
				if(stmt!=null) stmt.close();
			} catch(SQLException e){
				e.printStackTrace();
			}
			
			try{
				if(conn!=null) conn.close();
			} catch(SQLException e) {
				e.printStackTrace();
			}
		}
		
		return ret;
	}
	
	public static int Register(String Email,String Password,String Nickname,String School){
		int upret=-1;
		Connection conn=null;
		String url="jdbc:mysql://gameharbor.cn:3306/test";
		PreparedStatement stmt = null;
		
		try{
			conn=DriverManager.getConnection(url,"testuser","pwdtest");
			String sqlString=new String("INSERT into test.user VALUES (?,?,?,?,?,?)");
			stmt=conn.prepareStatement(sqlString,Statement.RETURN_GENERATED_KEYS);
			stmt.setString(1,Email);
			stmt.setString(2, Password);
			stmt.setString(3, Nickname);
			stmt.setString(4, School);
			stmt.setString(5, "");
			stmt.setString(6, "");
			upret=stmt.executeUpdate();
		} catch(SQLException e) {
			e.printStackTrace();
		} finally {
			try {
				if(stmt!=null) stmt.close();
			} catch(SQLException e) {
				e.printStackTrace();
			}
			
			try{
				if(conn!=null) conn.close();
			} catch(SQLException e) {
				e.printStackTrace();
			}
		}
		
		return upret;
	}
	
	public static void main(String[] args) {
		try {
			Class.forName("com.mysql.jdbc.Driver");
		} catch (ClassNotFoundException e) {
			e.printStackTrace();
			System.exit(-1);
		}
		
		/// ret=Login("test2@me.com","030201");
		int ret=Register("test3@me.com","030201","LiuTongYuan","QUST");
		System.out.println("Ret is "+ret);
	}
}

/*
import java.io.*;
import java.net.*;

public class BookFloatingServer {
	public class ServerThread implements Runnable
	{
		Socket s=null;
		BufferedReader br=null;
		public ServerThread(Socket s)
		{
			System.out.println("Thread Ready, ID="+Thread.currentThread().getId());
			this.s=s;
			try
			{
				br=new BufferedReader(
					new InputStreamReader(
						s.getInputStream())
					);
			}
			catch(Exception e)
			{
				e.printStackTrace();
				return;
			}
		}
		public void run()
		{
			System.out.println("Thread Start, ID="+Thread.currentThread().getId());
			try
			{
				s.close();
			}
			catch(Exception e)
			{
				e.printStackTrace();
			}
			
			System.out.println("Thread Over, ID="+Thread.currentThread().getId());
		}
	}
	public static void main(String[] args)
	{
		ServerSocket ss;
		try
		{
			ss=new ServerSocket(50001);
		}
		catch(Exception e)
		{
			e.printStackTrace();
			return;
		}
		
		while(true)
		{
			Socket s;
			try
			{
				s=ss.accept();
			}
			catch(Exception e)
			{
				e.printStackTrace();
				continue;
			}
			
			new Thread(new ServerThread(s)).start();
		}
	}
}
*/