【JavaWeb】书城项目之与数据库交互的登录案例实现

本文涉及的产品
密钥管理服务KMS,1000个密钥,100个凭据,1个月
简介: 【JavaWeb】书城项目之与数据库交互的登录案例实现

 👉引言💎


学习的最大理由是想摆脱平庸,早一天就多一份人生的精彩;迟一天就多一天平庸的困扰。 热爱写作,愿意让自己成为更好的人............

铭记于心
🎉✨🎉我唯一知道的,便是我一无所知🎉✨🎉


准备工作


项目源代码

链接pan.baidu.com/s/1Uj3Q9swg…

提取码:1314


首先更改前端页面中的url路径


0a2653c851af460fa595bd959398a8f1.png


三层架构


为什么要使用三层架构


所有和当前业务功能需求相关的代码全部耦合在一起,如果其中有任何一个部分出现了问题,牵一发而动全身,导致其他无关代码也要进行相应的修改。这样的话代码会非常难以维护。

所以为了提高开发效率,需要对代码进行模块化的拆分。整个项目模块化、组件化程度越高,越容易管理和维护,出现问题更容易排查。


三层架构的划分


  • 表述层:又可以称之为控制层,负责处理浏览器请求、返回响应、页面调度
  • 业务逻辑层:负责处理业务逻辑,根据业务逻辑把持久化层从数据库查询出来的数据进行运算、组装,封装好后返回给表述层,也可以根据业务功能的需要调用持久化层把数据保存到数据库、修改数据库中的数据、删除数据库中的数据
  • 持久化层:根据上一层的调用对数据库中的数据执行增删改查的操作


三层架构和数据模型的关系


0eacb84100b54626af849e6b562bf92a.png

模型对整个项目中三层架构的每一层都提供支持,具体体现是使用模型对象封装业务功能数据

其实数据模型就是我们之前学习的JavaBean,也是Java实体类,当然他还有很多其他的名称:

  • POJO:Plain old Java Object,传统的普通的Java对象
  • entity:实体类
  • bean或Java bean
  • domain:领域模型


持久层操作


创建数据库


2d65d23f6d4748949b924e4057485923.png


封装工具类


封装JDBCUtils


将druid连接池与jdbc操作封装成工具类


package com.example.WebGo.utils;
import com.alibaba.druid.pool.DruidDataSourceFactory;
import javax.sql.DataSource;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Properties;
public class JDBCUtils {
    private static DataSource dataSource;
    static {
        // 1.创建一个用于存储外部属性文件信息的Properties对象
        Properties properties = new Properties();
        // 2.使用当前类的类加载器加载外部属性文件:jdbc.properties
        InputStream inputStream = com.example.WebGo.utils.JDBCUtils.class.getClassLoader().getResourceAsStream("jdbc.properties");
        try {
            // 3.将外部属性文件jdbc.properties中的数据加载到properties对象中
            properties.load(inputStream);
            // 4.创建数据源对象
            dataSource = DruidDataSourceFactory.createDataSource(properties);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    /**
     * 从数据源中获取数据库连接
     *
     * @return 数据库连接对象
     */
    public static Connection getConnection() {
        Connection connection = null;
        try {
            connection = dataSource.getConnection();
        } catch (SQLException e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        }
        return connection;
    }
    /**
     * 释放数据库连接
     *
     * @param connection 要执行释放操作的连接对象
     */
    public static void releaseConnection(Connection connection) {
        if (connection != null) {
            try {
                connection.close();
            } catch (SQLException e) {
                e.printStackTrace();
                throw new RuntimeException(e);
            }
        }
    }
}


配置文件


driverClassName=com.mysql.jdbc.Driver
url=jdbc:mysql://localhost:3306/WebGo
username=root
password=123456
initialSize=10
maxActive=20
maxWait=10000


封装DButils为Dao基类


import com.example.WebGo.utils.JDBCUtils;
import org.apache.commons.dbutils.QueryRunner;
import org.apache.commons.dbutils.handlers.BeanHandler;
import org.apache.commons.dbutils.handlers.BeanListHandler;
import java.sql.SQLException;
import java.time.Clock;
import java.util.List;
public class BaseDao<T> {
   private QueryRunner queryRunner= new QueryRunner();
   public int update(String sql,Object...params){
       try {
           int update = queryRunner.update(JDBCUtils.getConnection(), sql, params);
           return update;
       } catch (SQLException throwables) {
           throwables.printStackTrace();
           throw new RuntimeException();
       }
   }
   public T getBean(Class<T>clasz,String sql,Object...params){
       try {
          return queryRunner.query(JDBCUtils.getConnection(), sql, new BeanHandler<>(clasz),params);
       } catch (SQLException throwables) {
           throwables.printStackTrace();
           throw new RuntimeException();
       }
   }
    public List<T> getBeanList(Class<T>clasz, String sql, Object...params){
        try {
            return queryRunner.query(JDBCUtils.getConnection(), sql, new BeanListHandler<>(clasz),params);
        } catch (SQLException throwables) {
            throwables.printStackTrace();
            throw new RuntimeException();
        }
    }
}


实现用户dao类


package com.example.WebGo.dao.impl;
import com.example.WebGo.dao.BaseDao;
import com.example.WebGo.dao.api.Userdao;
import com.example.WebGo.entity.User;
import java.sql.SQLException;
public class Userdaoimpl extends BaseDao<User> implements Userdao {
    @Override
    public User findByUsername(String username) throws SQLException {
        String sql="select user_id userId,user_name username,user_pwd userPwd,email from t_user where user_name=?";
        User user = getBean(User.class,sql,username);
        return user;
    }
    @Override
    public void addUser(User user) throws SQLException {
        String sql="insert into t_user (user_name,user_pwd,email) values (?,?,?)";
       update(sql,user.getUserName(),user.getUserPwd(),user.getEmail());
    }
}


测试


0a2653c851af460fa595bd959398a8f1.png0eacb84100b54626af849e6b562bf92a.png


封装MD5Utils加密工具类


由于下面登录时 我们需要对用户输入的密码信息 进行加密处理,所以在这里实现一个MD5工具类的封装,该代码直接复制粘贴即可,无需过多关注

public class MD5Util {
    /**
     * 针对明文字符串执行MD5加密
     * @param source
     * @return
     */
    public static String encode(String source) {
        // 1.判断明文字符串是否有效
        if (source == null || "".equals(source)) {
            throw new RuntimeException("用于加密的明文不可为空");
        }
        // 2.声明算法名称
        String algorithm = "md5";
        // 3.获取MessageDigest对象
        MessageDigest messageDigest = null;
        try {
            messageDigest = MessageDigest.getInstance(algorithm);
        } catch (NoSuchAlgorithmException e) {
            e.printStackTrace();
        }
        // 4.获取明文字符串对应的字节数组
        byte[] input = source.getBytes();
        // 5.执行加密
        byte[] output = messageDigest.digest(input);
        // 6.创建BigInteger对象
        int signum = 1;
        BigInteger bigInteger = new BigInteger(signum, output);
        // 7.按照16进制将bigInteger的值转换为字符串
        int radix = 16;
        String encoded = bigInteger.toString(radix).toUpperCase();
        return encoded;
    }
}


业务逻辑层操作


开发中对业务代码返回值的介绍


  • 方法的返回值应该对应这个方法本身的业务功能
  • 写操作:没有返回值
  • 读操作:有返回值,返回值就是查询的结果
  • 方法执行是否成功
  • 成功:不抛异常
  • 失败:抛异常
  • 最好失败便是抛异常,不要返回布尔类型


登录与注册的业务逻辑处理


public class UserServiceimpl implements UserService {
  private Userdao userdao= new Userdaoimpl();
   @Override
    public void doRegister(User userForm) throws Exception {
       User user = userdao.findByUsername(userForm.getUserName());
       if(user!=null){
            throw new RuntimeException("用户名已存在");
       }
       String olduserPwd=userForm.getUserPwd();
       String encode = MD5Util.encode(olduserPwd);
       userForm.setUserPwd(encode);
       userdao.addUser(userForm);
   }
    @Override
    public User doLogin(User parameterUser) throws Exception {
        //1. 调用dao层的方法根据用户名查询用户信息
        User loginUser = userdao.findByUsername(parameterUser.getUserName());
        //2. 判断loginUser是否为空
        if (loginUser != null) {
            //说明用户名正确,那么接下来校验密码
            //parameterUser中的密码是用户输入的密码,我们对其进行MD5加密,完之后跟loginUser中的密码(数据库中的密码)进行比对
            String encodePwd = MD5Util.encode(parameterUser.getUserPwd());//加密之后的用户输入的密码
            String dbPwd = loginUser.getUserPwd();//数据库中的密码
            if (dbPwd.equals(encodePwd)) {
                //说明密码正确,登录成功,返回loginUser对象
                return loginUser;
            }else {
                //密码错误
                throw new RuntimeException("密码错误");
            }
        }
        throw new RuntimeException("用户名错误");
    }
}


表现层(接收请求并响应)


0a2653c851af460fa595bd959398a8f1.png

public class RigisterServlet extends HttpServlet {
    UserService userService = new UserServiceimpl();
    @Override
    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        request.setCharacterEncoding("UTF-8");response.setContentType("text/html;charset=UTF-8");
        Map<String, String[]> map = request.getParameterMap();
        map.forEach((a,b)->{
            for(String str:b)
            { System.out.println(a+"="+b);}
        });
        User user = new User();
        try {
            BeanUtils.populate(user, map);
            System.out.println(user);
            userService.doRegister(user);
            response.sendRedirect(request.getContextPath() + "/pages/user/regist_success.html");
        } catch (Exception e) {
            e.printStackTrace();
            response.getWriter().write("注册失败!!!" + e.getMessage());
        }
    }
    @Override
    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        doGet(request, response);
    }
}

0eacb84100b54626af849e6b562bf92a.png

public class LoginServlet extends HttpServlet {
UserService userService=  new UserServiceimpl();
  @Override
  protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
     request.setCharacterEncoding("UTF-8");response.setContentType("text/html;charset=UTF-8");
      User user = new User();
      Map<String, String[]> map = request.getParameterMap();
      try {
          BeanUtils.populate(user,map);
          User User = userService.doLogin(user);
          response.sendRedirect(request.getContextPath()+"/pages/user/Login_success.html");
      } catch (Exception e) {
          e.printStackTrace();
          response.getWriter().write("登陆失败!!!"+e.getMessage());
      }
  }
  @Override
  protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
doGet(request, response);
  }
}
复制代码


案例效果


登陆


2d65d23f6d4748949b924e4057485923.png2e9b90b2ca334476abebe75bafe6eeaa.png



用户名检测


4cebaac233b3433da32a72337a77fc60.png

image.png


注册



0a2653c851af460fa595bd959398a8f1.png0eacb84100b54626af849e6b562bf92a.png

🌹写在最后💖: 路漫漫其修远兮,吾将上下而求索!伙伴们,再见!🌹🌹🌹


相关文章
|
2月前
|
存储 SQL 关系型数据库
PHP与数据库交互:从基础到进阶
【10月更文挑战第9天】在编程的世界里,数据是流动的血液,而数据库则是存储这些珍贵资源的心脏。PHP作为一门流行的服务器端脚本语言,其与数据库的交互能力至关重要。本文将带你从PHP与数据库的基本连接开始,逐步深入到复杂查询的编写和优化,以及如何使用PHP处理数据库结果。无论你是初学者还是有一定经验的开发者,这篇文章都将为你提供宝贵的知识和技巧,让你在PHP和数据库交互的道路上更加从容不迫。
|
2月前
|
存储 关系型数据库 MySQL
一个项目用5款数据库?MySQL、PostgreSQL、ClickHouse、MongoDB区别,适用场景
一个项目用5款数据库?MySQL、PostgreSQL、ClickHouse、MongoDB——特点、性能、扩展性、安全性、适用场景比较
|
17天前
|
存储 SQL API
探索后端开发:构建高效API与数据库交互
【10月更文挑战第36天】在数字化时代,后端开发是连接用户界面和数据存储的桥梁。本文深入探讨如何设计高效的API以及如何实现API与数据库之间的无缝交互,确保数据的一致性和高性能。我们将从基础概念出发,逐步深入到实战技巧,为读者提供一个清晰的后端开发路线图。
|
27天前
|
存储 Java 关系型数据库
在Java开发中,数据库连接是应用与数据交互的关键环节。本文通过案例分析,深入探讨Java连接池的原理与最佳实践
在Java开发中,数据库连接是应用与数据交互的关键环节。本文通过案例分析,深入探讨Java连接池的原理与最佳实践,包括连接创建、分配、复用和释放等操作,并通过电商应用实例展示了如何选择合适的连接池库(如HikariCP)和配置参数,实现高效、稳定的数据库连接管理。
51 2
|
28天前
|
关系型数据库 MySQL Linux
在 CentOS 7 中通过编译源码方式安装 MySQL 数据库的详细步骤,包括准备工作、下载源码、编译安装、配置 MySQL 服务、登录设置等。
本文介绍了在 CentOS 7 中通过编译源码方式安装 MySQL 数据库的详细步骤,包括准备工作、下载源码、编译安装、配置 MySQL 服务、登录设置等。同时,文章还对比了编译源码安装与使用 RPM 包安装的优缺点,帮助读者根据需求选择最合适的方法。通过具体案例,展示了编译源码安装的灵活性和定制性。
83 2
|
2月前
|
存储 数据挖掘 数据库
数据库数据恢复—SQLserver数据库ndf文件大小变为0KB的数据恢复案例
一个运行在存储上的SQLServer数据库,有1000多个文件,大小几十TB。数据库每10天生成一个NDF文件,每个NDF几百GB大小。数据库包含两个LDF文件。 存储损坏,数据库不可用。管理员试图恢复数据库,发现有数个ndf文件大小变为0KB。 虽然NDF文件大小变为0KB,但是NDF文件在磁盘上还可能存在。可以尝试通过扫描&拼接数据库碎片来恢复NDF文件,然后修复数据库。
|
2月前
|
关系型数据库 MySQL 数据库
一个 MySQL 数据库死锁的案例和解决方案
本文介绍了一个 MySQL 数据库死锁的案例和解决方案。
75 3
|
2月前
|
Java 数据库
案例一:去掉数据库某列中的所有英文,利用java正则表达式去做,核心:去掉字符串中的英文
这篇文章介绍了如何使用Java正则表达式从数据库某列中去除所有英文字符。
53 15
|
2月前
|
存储 Oracle 关系型数据库
数据库数据恢复—Oracle ASM磁盘组故障数据恢复案例
Oracle数据库数据恢复环境&故障: Oracle ASM磁盘组由4块磁盘组成。Oracle ASM磁盘组掉线 ,ASM实例不能mount。 Oracle数据库故障分析&恢复方案: 数据库数据恢复工程师对组成ASM磁盘组的磁盘进行分析。对ASM元数据进行分析发现ASM存储元数据损坏,导致磁盘组无法挂载。
|
2月前
|
SQL JavaScript 关系型数据库
node博客小项目:接口开发、连接mysql数据库
【10月更文挑战第14天】node博客小项目:接口开发、连接mysql数据库