loginquary.java

手工完成

package Bean;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

public class LogInQuary {
	
	public boolean Query(String name,String pw)
	{
		boolean flag = false;
		String username = name;
		String password = pw;
		Connection conn=new DBConn().getConn();
		
		Statement stmt = null;
		ResultSet sqlRst = null;

		String sql = "select * from users where username = '" + username + "' and password = '" + password + "' and usertype = 'user'";
//		String sql = "select * from users where username = '" + username + "' and password = '" + password + "'";
		System.out.println(sql);
	
			try {
				stmt = conn.createStatement();
				sqlRst=stmt.executeQuery(sql); //结果集对象 
				if(sqlRst.next())
				{System.out.println(sqlRst.getString("usertype"));
					flag = true;
				}
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}finally
			{
				if(sqlRst != null)
				{
					try {
						sqlRst.close();
						stmt.close();
						conn.close();
					} catch (SQLException e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					}
				}
			}
			return flag;
			
	}
	
	public boolean Query(String name)
	{
		boolean flag = false;
		String username = name;
	
		Connection conn=new DBConn().getConn();
		
		Statement stmt = null;
		ResultSet sqlRst = null;
//		conn.createStatement().executeUpdate("insert into UsersTable(ID, userName, passWord) values('aaa','bbb','aaa')");

		String sql = "select * from users where username = '" + username + "'";
		System.out.println(sql);
	
			try {
				 stmt = conn.createStatement();

				sqlRst=stmt.executeQuery(sql); //结果集对象 
//			System.out.println("还没有进入While中");
				if(sqlRst.next())
				{
					flag = true;System.out.println("true");
				}
			} catch (SQLException e) {System.out.println("@@@@");
				// TODO Auto-generated catch block
				e.printStackTrace();
			}finally
			{
				try {
					sqlRst.close();
					stmt.close();
					conn.close();
				} catch (SQLException e) {System.out.println("!!!!");
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				
			}System.out.println(flag);
			return flag;
			
	}
	
	public Bean.UserBean UserQuery(String name)	//-----此方法用来查看用户的个人信息-并返回一个userBean---
	{
		Bean.UserBean user= new Bean.UserBean();
		String username = name;
	
		Connection conn=new DBConn().getConn();
		
		Statement stmt = null;
		ResultSet sqlRst = null;
//		conn.createStatement().executeUpdate("insert into UsersTable(ID, userName, passWord) values('aaa','bbb','aaa')");

		String sql = "select * from users where username = '" + username + "'";
		System.out.println(sql);
	
			try {
				 stmt = conn.createStatement();

				sqlRst=stmt.executeQuery(sql); //结果集对象 
				if(sqlRst.next())
				{
//					user.setUsername(username);
					user.setUsername(sqlRst.getString("username"));
					user.setPassword(sqlRst.getString("password"));
					user.setGender(sqlRst.getString("gender"));
					user.setEmail(sqlRst.getString("email"));
					user.setTelphone(sqlRst.getString("telphone"));
					user.setMoney(sqlRst.getDouble("money"));
					user.setUsertype(sqlRst.getString("usertype"));
				}
			} catch (SQLException e) {System.out.println("@@@@");
				// TODO Auto-generated catch block
				e.printStackTrace();
			}finally
			{
				try {
					sqlRst.close();
					stmt.close();
					conn.close();
				} catch (SQLException e) {System.out.println("!!!!");
					// TODO Auto-generated catch block
					e.printStackTrace();
				}
				
			}
			return user;
			
	}

	public boolean AdminQuery(String name,String pw)
	{
		boolean flag = false;
		String username = name;
		String password = pw;
		Connection conn=new DBConn().getConn();
		
		Statement stmt = null;
		ResultSet sqlRst = null;
//		conn.createStatement().executeUpdate("insert into UsersTable(ID, userName, passWord) values('aaa','bbb','aaa')");

		String sql = "select * from users where username = '" + username + "' and password = '" + password + "' and usertype = 'admin'";
		System.out.println(sql);
	
			try {
				 stmt = conn.createStatement();

				sqlRst=stmt.executeQuery(sql); //结果集对象 
//			System.out.println("还没有进入While中");
				if(sqlRst.next())
				{
					flag = true;
				}
			} catch (SQLException e) {
				// TODO Auto-generated catch block
				e.printStackTrace();
			}finally
			{
				if(sqlRst != null)
				{
					try {
						sqlRst.close();
						stmt.close();
						conn.close();
					} catch (SQLException e) {
						// TODO Auto-generated catch block
						e.printStackTrace();
					}
				}
			}
			return flag;	
	}
}