userdao.java

网上商城 1.注册登录 2.商品浏览 3.购物车 4.订单

package db.dao;
import java.sql.*;
import java.util.*;
import db.dto.*;
public class UserDAO {
	String driver = "org.gjt.mm.mysql.Driver";
	String url="jdbc:mysql://localhost:3306/dstore";
	String username="root";
	String password="123";
	//createByDTO
	public void createUser(UserDTO user){
		Connection con=null;
		Statement stmt=null;
		ResultSet rs=null;
		try{
			Class.forName(driver);
			con=DriverManager.getConnection(url,username,password);
			String sql="insert into user values ("
				+user.getUserId()+","
				+"'"+user.getUsername()+"'"+","
				+"'"+user.getPassword()+"'"+","
				+"'"+user.getName()+"'"+","
				+"'"+user.getPhone()+"'"+","
				+"'"+user.getEmail()+"'"+")";
			stmt=con.createStatement();
			stmt.execute(sql);
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			if(con!=null){
				try{
					con.close();
				}catch(SQLException e){
					e.printStackTrace();
				}
			}
		}
	}
	
	//updateByDTO
	public void updateUser(UserDTO user){
		Connection con=null;
		Statement stmt=null;
		ResultSet rs=null;
		try{
			Class.forName(driver);
			con=DriverManager.getConnection(url,username,password);
			String sql="update user set "
				+"username='"+user.getUsername()+"',"
				+"password='"+user.getPassword()+"'"+","
				+"name='"+user.getName()+"'"+","
				+"phone='"+user.getPhone()+"'"+","
				+"email'"+user.getEmail()+"'"
				+"where userId ='" + user.getUserId();
			stmt=con.createStatement();
			stmt.executeUpdate(sql);
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			if(con!=null){
				try{
					con.close();
				}catch(SQLException e){
					e.printStackTrace();
				}
			}
		}
	}
	
	//findByPrimaryKey
	public UserDTO findByPrimaryKey(Integer _userId){
		Connection con=null;
		Statement stmt=null;
		ResultSet rs=null;
		UserDTO user=new UserDTO();
;		try{
			Class.forName(driver);
			con=DriverManager.getConnection(url,username,password);
			String sql="select * from user where userId= " + _userId;
			stmt=con.createStatement();
			rs=stmt.executeQuery(sql);
			while(rs.next()){
				user.setUserId(new Integer(rs.getInt("userId")));
				user.setUsername(rs.getString("username"));
				user.setPassword(rs.getString("password"));
				user.setName(rs.getString("name"));
				user.setPhone(rs.getString("phone"));
				user.setEmail(rs.getString("email"));
			}
		}catch(Exception e){
			e.printStackTrace();
		}finally{
			if(con!=null){
				try{
					con.close();
				}catch(SQLException e){
					e.printStackTrace();
				}
			}
		}
		return user;
	}

}