JavaWeb开发项目 电子书城项目(一) 用户模块：用户注册与用户登录

本节开始我们将利用JavaWeb方面的知识做一个电子书城的小项目，达到学以致用的效果。

1.JavaEE项目三层架构解析

JavaEE项目三层架构:

• web表现层：主要是指用户交互界面，用于接收用户输入的数据和显示处理后用户需要的数据；
• service业务层：web表现层与Dao数据访问层之间的桥梁，实现业务逻辑；
• Dao数据访问层：主要实现对数据的增、删、改、查。将存储在数据库中的数据提交给业务层，同时将业务层处理的数据保存到数据库中。

JavaEE项目三层架构之间的关系可以用下图详细进行阐述：

三层架构的优点：

• 结构清晰，耦合度低；
• 可维护性高，可扩展性高；
• 利于开发任务的同步进行；

---

2.电子书城项目的三层架构

电子书城项目三层构架	作用
web表现层	此处常使用Servlet，接收用户的请求，调用service业务逻辑层处理用户请求，显示处理结果
service业务逻辑层	调用Dao数据访问层处理业务逻辑，采用面向接口编程的思想，先定义接口，再创建实现类
Dao数据访问层	用来操作数据库，对数据库进行增删改查，采用面向接口编程的思想，先定义接口，再创建实现类

---

3.搭建项目环境与项目技术选型

3.1 搭建开发环境

搭建开发环境
操作系统：Windows7/10
开发工具：Idea
数据库：MySQL5.6
Web服务器：Tomcat8.0
浏览器：Chrome

---

3.2 技术选型

工具	版本	备注
Servlet、Filter、JSP、html、EL、JSTL		Web表现层
JDBCUtils		Dao持久层
无		service业务层
junit	4.12	单元测试
Druid	1.5	数据库连接池
jQuery	1.12.4	前端

---

在IDEA中搭建电子书城开发环境如下：

---

4.电子书城代码书写

4.1 创建电子书城项目的数据库的表

创建电子书城项目的数据库和表

//如果有book数据库先进行删除
drop database if exists book;
//创建book数据库
create database book;
//使用book数据库
use book;
//创建用户表
create table t_user(
`id` int primary key auto_increment,
`username` varchar(20) not null unique,
`password` varchar(32) not null,
`email` varchar(200)
);
insert into t_user(`username`,`password`,`email`) values('admin','admin','admin@atguigu.com');
select * from t_user

• 生成的数据库与表格如下：
  

---

4.2 编写数据库表t_user对应的实体类

public class User {private Integer id;private String username;private String password;private String email;public User(Integer id, String username, String password, String email) {this.id = id;this.username = username;this.password = password;this.email = email;}public User() {}public Integer getId() {return id;}public void setId(Integer id) {this.id = id;}public String getUsername() {return username;}public void setUsername(String username) {this.username = username;}public String getPassword() {return password;}public void setPassword(String password) {this.password = password;}public String getEmail() {return email;}public void setEmail(String email) {this.email = email;}@Overridepublic String toString() {return "User{" +"id=" + id +", username='" + username + '\'' +", password='" + password + '\'' +", email='" + email + '\'' +'}';}
}

---

4.3 编写工具类JDBCUtils

4.3.1 添加项目需要的jar包

当项目中需添加jar包时，先进行添加jar包。

添加jar包成功后，jar包前会有箭头

---

4.3.2 编写jdbc.properties配置文件

注意：编写jdbc.properties在项目的src路径下

public class JdbcUtils {private static DruidDataSource dataSource;static {//创建properties用来读取配置文件Properties properties = new Properties();//读取jdbc.properties属性配置文件try {InputStream is = JdbcUtils.class.getClassLoader().getResourceAsStream("jdbc.properties");properties.load(is);//创建数据库连接池dataSource=(DruidDataSource) DruidDataSourceFactory.createDataSource(properties);} catch (Exception e) {e.printStackTrace();}}/****获取数据库连接池中的连接*/public static Connection  getConnection(){Connection connection=null;try {connection = dataSource.getConnection();} catch (SQLException e) {e.printStackTrace();}return connection;}/***关闭连接，将连接可以放回数据库连接池*/public static void close(Connection connection){if (connection!=null) {try {connection.close();} catch (Exception e) {e.printStackTrace();}}}}

4.3.3 编写JdbcUtils工具类

public class JdbcUtils {private static DruidDataSource dataSource;static {//创建properties用来读取配置文件Properties properties = new Properties();//读取jdbc.properties属性配置文件try {InputStream is = JdbcUtils.class.getClassLoader().getResourceAsStream("jdbc.properties");properties.load(is);//创建数据库连接池dataSource=(DruidDataSource) DruidDataSourceFactory.createDataSource(properties);} catch (Exception e) {e.printStackTrace();}}/****获取数据库连接池中的连接*/public static Connection  getConnection(){Connection connection=null;try {connection = dataSource.getConnection();} catch (SQLException e) {e.printStackTrace();}return connection;}/***关闭连接，将连接可以放回数据库连接池*/public static void close(Connection connection){if (connection!=null) {try {connection.close();} catch (Exception e) {e.printStackTrace();}}}}

---

4.4 编写Dao层代码

4.4.1 编写BaseDao

在使用BaseDao之前需要使用导入DBUtils的jar包，对数据库中的数据进行增删改查的功能。

public abstract class BaseDao {//使用DBUtils操作数据库private QueryRunner queryRunner= new QueryRunner();/****  update()方法用来执行：insert/update/delete语句* @param sql* @param args* @return  如果返回-1，说明执行失败，返回其他表示影响的行数*/public int update(String sql,Object...args){//获取连接Connection connection=JdbcUtils.getConnection();try {return queryRunner.update(connection,sql,args);} catch (Exception e) {e.printStackTrace();}finally {JdbcUtils.close(connection);}return -1;}/***查询返回一个javaBean的sql语句* @param type* @param sql* @param args* @param <T>* @return*/public  <T> T queryForOne(Class<T>type,String sql,Object...args){Connection connection = JdbcUtils.getConnection();try {return queryRunner.query(connection,sql,new BeanHandler<T>(type),args);} catch (Exception e) {e.printStackTrace();} finally {JdbcUtils.close(connection);}return null;}/**** 查询返回多个javaBean的sql语句*/public  <T> List<T> queryForList(Class<T>type, String sql, Object...args){Connection connection = JdbcUtils.getConnection();try {return queryRunner.query(connection,sql,new BeanListHandler<T>(type),args);} catch (Exception e) {e.printStackTrace();} finally {JdbcUtils.close(connection);}return null;}/**** 查询返回一行一列的sql语句*/public  Object queryForSingleValue( String sql, Object...args){Connection connection = JdbcUtils.getConnection();try {return queryRunner.query(connection,sql,new ScalarHandler(),args);} catch (Exception e) {e.printStackTrace();} finally {JdbcUtils.close(connection);}return null;}
}

---

4.4.2 编写UserDao接口

public interface UserDao {/**** 根据用户名查询用户信息* @param username* @return*/public User queryUserName(String username);/***** 根据用户名和密码查询用户信息* @param username* @param password* @return*/public User queryUserNameAndPassword(String username,String password);/****保存用户信息*/public int saveUser(User user);}

---

4.4.3 编写UserDaoImpl实现类

public class UserDaoImpl extends BaseDao implements UserDao {@Override//根据用户名来查询用户public User queryUserName(String username) {String sql="select id,username,password,email from t_user where username=?";return queryForOne(User.class,sql,username);}@Override//根据用户名和密码来查询用户public User queryUserNameAndPassword(String username, String password) {String sql="select id,username,password,email from t_user where username=? and password=?";return queryForOne(User.class,sql,username,password);}@Override//保存用户的信息public int saveUser(User user) {String sql="insert into t_user(username,password,email) values(?,?,?)";return update(sql,user.getUsername(),user.getPassword(),user.getEmail());}
}

---

4.4.4 测试UserDao

ublic class TestUserDao {private UserDao userDao= new UserDaoImpl();@Test//测试用户名是否可用public void queryUserName(){//判断用户名是否存在if (userDao.queryUserName("admin")==null) {//不存在，可用System.out.println("用户名可用！");}else{//存在System.out.println("用户名已存在！");}}@Testpublic void queryUserNameAndPassword(){//判断用户名和密码是否存在if (userDao.queryUserNameAndPassword("admin","admin")==null) {//不存在System.out.println("用户名或者密码错误，查询失败！");}else{System.out.println("查询用户名与密码成功!");}}@Testpublic void saveUser(){System.out.println(userDao.saveUser(new User(null,"jay","123456",null)));}
}

运行后的结果为：

---

4.5 编写service层代码

4.5.1 编写UserService接口

/**** service层：进行业务逻辑处理*/
public interface UserService {/*** 注册用户* @param user*/public void register(User user);/***用户登录* @param user* @return  如果返回null,登录失败*/public User login(User user);/****检查用户名是否可用* @param user* @return  返回true表示用户名已经存在，不可用*/public boolean existsUserName(User user);
}

---

4.5.2 编写UserServiceImpl类

public class UserServiceImpl implements UserService {//这里service层会调用Dao层把数据保存在数据库中UserDao userDao=new UserDaoImpl();@Overridepublic void register(User user) {userDao.saveUser(user);}@Overridepublic User login(User user) {return userDao.queryUserNameAndPassword(user.getUsername(), user.getPassword());}@Overridepublic boolean existsUserName(User user) {if (userDao.queryUserName(user.getUsername())==null) {//如果用户名不存在，则用户名可用return false;}//如果用户名存在,则用户名不可用return true;}
}

---

4.5.3 测试UserService

public class TestUserService {private UserService userService=new UserServiceImpl();@Testpublic void register(){userService.register(new User(null,"liudehua","123456789","147258369@qq.com"));}@Testpublic void login(){System.out.println(userService.login(new User(null, "jay", "123456", null)));}@Testpublic void existUseName(){System.out.println(userService.existsUserName(new User(null, "admin", "admin", "admin@163.com")));}
}

测试后的结果为：

---

4.6 编写web层代码

4.6.1 实现用户注册功能

用户注册过程可以用下图进行展示：

public class RegistServlet extends HttpServlet {private UserService userService=new UserServiceImpl();@Overrideprotected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {//1.获取请求参数String username = req.getParameter("username");String password = req.getParameter("password");String email = req.getParameter("email");String code = req.getParameter("code");//2.检查验证码是否正确====写死，要求验证码为abcdeif ("abcde".equalsIgnoreCase(code)){//正确//3.检查用户名是否可用if (userService.exsitsUsername(username)) {//用户名已存在，不可用System.out.println("用户名["+username+"]已存在！");req.getRequestDispatcher("/pages/user/regist.html").forward(req,resp);}else {//用户名可用//调用service保存在数据库中userService.registUser(new User(null,username,password,email));//跳转到用户注册成功regist_success.htmlreq.getRequestDispatcher("/pages/user/regist_success.html").forward(req,resp);}}else{//不正确//跳回注册页面System.out.println("验证码["+code+"]错误");req.getRequestDispatcher("/pages/user/regist.html").forward(req,resp);}}
}

注册成功页面：

---

4.6.2 实现用户登录

public class LoginServlet extends HttpServlet {private UserService userService=new UserServiceImpl();@Overrideprotected void doPost(HttpServletRequest req, HttpServletResponse resp) throws ServletException, IOException {//1.获取请求参数String username = req.getParameter("username");String password = req.getParameter("password");//2.调用service层进行登录if (userService.login(new User(null,username,password,null))==null) {//返回null表示登录失败//跳转回登录界面req.getRequestDispatcher("/pages/user/login.html").forward(req,resp);}else{//登陆成功//跳转到登录成功界面req.getRequestDispatcher("/pages/user/login_success.html").forward(req,resp);}}}

登陆成功界面：