userdb.java

网上购物系统 管理员模块和用户模块

package db;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import m.Admin;
import m.User;

public class UserDB {
	Connection con;
	PreparedStatement pstm;
	ResultSet rs=null;
	public UserDB()
	{
		try {
			Class.forName("com.mysql.jdbc.Driver");
			con=DriverManager.getConnection("jdbc:mysql://localhost:3306/t227","root","1234");
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}
	public boolean admin(Admin admin)
	{
		try {
			pstm=con.prepareStatement("select * from administrator where Name=? and Password=?");
			pstm.setString(1, admin.getName());
			pstm.setString(2,admin.getPassword());
			rs=pstm.executeQuery();
			while(rs.next())
			{
				rs.close();
				return true;
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		try {
			rs.close();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return false;
	}
	public boolean ser(User user)
	{
		try {
			pstm=con.prepareStatement("select * from users where name=? and password=?");
			pstm.setString(1, user.getName());
			pstm.setString(2,user.getPassword());
			rs=pstm.executeQuery();
			while(rs.next())
			{
				rs.close();
				return true;
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		try {
			rs.close();
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return false;
	}
	public double serMoney(String name)
	{
		try {
			pstm=con.prepareStatement("select money from users where name=?");
			pstm.setString(1, name);
			rs=pstm.executeQuery();
			while(rs.next())
			{
				return rs.getDouble("money");
			}
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
		return 0;
		
	}
	/*public void saveMoney(String name,double money)
	{
		double m=0;
		try {
			pstm=con.prepareStatement("update users set money=? where name=?");
			pstm.setDouble(1,serMoney(name)+money );
			pstm.setString(2, name);
			pstm.executeUpdate();
			m=serMoney(name)+money;
			System.out.println(m);
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}*/
	public void updateMoney(String name,double money)
	{
		//double m=0;
		try {
			pstm=con.prepareStatement("update users set money=? where name=?");
			pstm.setDouble(1,money);
			pstm.setString(2, name);
			pstm.executeUpdate();
			//m=serMoney(name)+money;
			//System.out.println(m);
		} catch (SQLException e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
		}
	}

}