SpringJDBC

2024-06-01 1389阅读

1.前言

Spring JDBC可以帮助开发者节省大量开发工作自动去处理一些低级细节比如：异常处理、打开和关闭资源(Connection、PreparedStatement、Statement、ResultSet)

需要下载的jar包(普通jar包、源码jar包)：

由于依赖其他的jar包所以需要另行下载其他的jar包

总之需要下载的jar包有：spring-jdbc、spring-beans(spring-jdbc依赖)、spring-core(spring-jdbc依赖)、spring-tx(spring-jdbc依赖)、spring-jcl(spring-core依赖)

2.拷贝模块

我们可以通过ctrl+c、ctrl+v拷贝模块

每一个项目中都存在一个iml文件作为项目的配置文件里面储存了项目所依赖的库一旦该文件失效那么项目中使用到依赖库的任何地方也会失效在模块拷贝的过程中虽然项目名称被我们手动修改了但是iml文件的名称并没有随之修改所以我们要去项目所在文件夹中进行手动修改才能正常使用项目
我们在导入拷贝以后的模块时如果选择iml描述文件来代替整个项目的话那么将不需要若干个下一步的操作提高效率

模块拷贝之后由于没有进行编译打包的操作所以Tomcat服务器无法加载该模块因此我们需要编译打包将其置于aritfacts目录中之后在将其部署到Tomcat服务器上即可

3.Sprint JDBC的核心类：JdbcTemplate

构造方法

public JdbcTemplate(DataSource dataSource)

执行DDL、DML语句

int update(String sql, Object… args)

执行DQL语句

List query(String sql, RowMapper rowMapper, Object… args)

我们利用JdbcTemplate来简化Dbs、Dao两个类

具体就是Dbs中用getTpl来代替update、query、RowMapper三个接口原因在于JdbcTemplat内置了这三个接口 Dao中的save、list分别调用tpl的update、query方法来执行相关操作

我们可以通过BeanPropertyRowMapper(Class beanClass)来代替代码形参如此也简化了代码的编写

他的底层实现大致为先通过getField获取bean的Class对象中的属性然后带入rs的get方法获取相应字段值接着通过拼串的方式获取相应的setter方法比如：set+name 最后在根据getMethod调用相应的setter方法
底层已经做了Java规范和数据库规范的映射在Java中我们的属性标识符通常采用小驼峰形式而在数据库中我们的字段标识符通常采用小写、_拼接的方式(比如：my_name)
如果Java的属性名称和数据库的字段名称对应不上的话/映射关系不符的话那么BeanPropertyRowMapper将无法作用于相关的字段/属性

代码实现

Dbs.java

package com.axihh.util;
import com.alibaba.druid.pool.DruidDataSourceFactory;
import org.springframework.jdbc.core.JdbcTemplate;
import javax.sql.DataSource;
import java.io.InputStream;
import java.util.Properties;
public class Dbs {
    // 常量
    private static JdbcTemplate tpl;
    static {
        try(// 通过当前类获取字节码文件 然后通过字节码文件获取类加载器 然后通过类加载器获取资源文件 并且通过字节输入流读取该资源文件
            InputStream is = Dbs.class.getClassLoader().getResourceAsStream("druid.properties")) {
            // 创建properties对象 然后将字节输入流读取的内容加载进该对象中
            Properties properties = new Properties();
            properties.load(is);
            // 然后创建连接池
            DataSource ds = DruidDataSourceFactory.createDataSource(properties);
            // 通过连接池创建tpl
            tpl = new JdbcTemplate(ds);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    // 提供一个获取tpl的方法 来代替update、list以及RowMapper 以后可以通过调用tpl的api来访问被代替的方法
    public static JdbcTemplate getTpl() {
        return tpl;
    }
}

CustomerDao.java

package com.axihh.dao;
import com.axihh.bean.Customer;
import com.axihh.util.Dbs;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import java.util.List;
public class CustomerDao {
    public boolean save(Customer customer){
        String sql = "INSERT INTO customer(name, age, height) VALUES (?, ?, ?)";
        return Dbs.getTpl().update(sql, customer.getName(), customer.getAge(), customer.getHeight()) > 0;
    }
    public List list() {
        String sql = "SELECT id, name, age, height FROM customer";
//        return Dbs.getTpl().query(sql, (rs, row) -> {
//            Customer customer = new Customer();
//            customer.setId(rs.getInt("id"));
//            customer.setName(rs.getString("name"));
//            customer.setAge(rs.getInt("age"));
//            customer.setHeight(rs.getDouble("height"));
//            return customer;
//        });
        return Dbs.getTpl().query(sql, new BeanPropertyRowMapper(Customer.class));
    }
}

4.删除功能的实现

前面我们已经实现了增删改查中的增、查两个功能现在我们就来实现一下删除功能吧具体的操作就是在展示页面中的每一条记录旁边多出可点击的删除按钮一点击删除按钮就会执行servlet中的remove方法而该方法则会执行dao中的remove方法而该方法又会调用dbs中tpl的update方法该方法专门用于执行dml语句(包括增加、删除、修改记录)

CustomerServlet.java

package com.axihh.servlet;
import com.axihh.bean.Customer;
import com.axihh.dao.CustomerDao;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.lang.reflect.Method;
@WebServlet("/customer/*")
public class CustomerServlet extends HttpServlet {
    // 定义一个CustomerDao对象 用于访问其中的save、list方法
    private final CustomerDao cd = new CustomerDao();
    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        try {
            // 获取调用方法的名称
            String[] cmps = request.getRequestURI().split("/");
            String methodName = cmps[cmps.length - 1];
            // 第四步 利用Java中的反射技术 根据methodName调用该类中的对应方法
            Method method = getClass().getMethod(methodName, HttpServletRequest.class, HttpServletResponse.class);
            // 第五步 调用反射得到的结果
            method.invoke(this, request, response);
        } catch (Exception e) {
            e.printStackTrace();
            // 当你随意传递一个路径的时候 需要给予一个友善的界面进行提醒
            request.setAttribute("error", "你的路径有问题");
            request.getRequestDispatcher("/page/error.jsp").forward(request, response);
        }
    }
    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        doPost(request, response);
    }
    // 提供一个方法 用于模拟SaveServlet 由于请求路径中需要访问 所以直接公有化
    public void save(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        // 获取客户端发送的用户信息 并且封装为bean
        Customer customer = new Customer();
        customer.setName(request.getParameter("name"));
        customer.setAge(Integer.parseInt(request.getParameter("age")));
        customer.setHeight(Double.parseDouble(request.getParameter("height")));
        // 如果保存成功的话 就跳转到展示页面 如果保存失败的话 那么就跳转到失败页面
        if(cd.save(customer)) {
            // 执行的是重定向操作
            response.sendRedirect("/crm6/customer/list");
        } else {
            // 执行的是转发操作
            request.setAttribute("error", "保存客户信息失败");
            request.getRequestDispatcher("/page/error.jsp").forward(request, response);
        }
    }
    // 提供一个方法 用于模拟ListServlet 由于请求路径中同样需要访问 所以直接公有化
    public void list(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        // 将返回值存入attribute中
        request.setAttribute("customers", cd.list());
        // 转发到展示页面
        request.getRequestDispatcher("/page/list.jsp").forward(request, response);
    }
    // 提供一个方法 用于删除客户表的某一条记录
    public void remove(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        // 获取当前记录的id
        int id = Integer.parseInt(request.getParameter("id"));
        // 如果成功删除 那么就跳转到展示页面
        if(cd.remove(id)) {
            response.sendRedirect("/crm6/customer/list");
        }else {
            // 如果删除失败的话 那么就跳转到失败页面
            request.setAttribute("error", "删除客户信息失败");
            request.getRequestDispatcher("/page/error.jsp").forward(request, response);
        }
    }
}

CustomerDao.java

package com.axihh.dao;
import com.axihh.bean.Customer;
import com.axihh.util.Dbs;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import java.util.List;
public class CustomerDao {
    public boolean save(Customer customer){
        String sql = "INSERT INTO customer(name, age, height) VALUES (?, ?, ?)";
        return Dbs.getTpl().update(sql, customer.getName(), customer.getAge(), customer.getHeight()) > 0;
    }
    public List list() {
        String sql = "SELECT id, name, age, height FROM customer";
//        return Dbs.getTpl().query(sql, (rs, row) -> {
//            Customer customer = new Customer();
//            customer.setId(rs.getInt("id"));
//            customer.setName(rs.getString("name"));
//            customer.setAge(rs.getInt("age"));
//            customer.setHeight(rs.getDouble("height"));
//            return customer;
//        });
        return Dbs.getTpl().query(sql, new BeanPropertyRowMapper(Customer.class));
    }
    public boolean remove(int id) {
        String sql = "DELETE FROM customer WHERE id = ?";
        return Dbs.getTpl().update(sql, id) > 0;
    }
}

Dbs.java

package com.axihh.util;
import com.alibaba.druid.pool.DruidDataSourceFactory;
import org.springframework.jdbc.core.JdbcTemplate;
import javax.sql.DataSource;
import java.io.InputStream;
import java.util.Properties;
public class Dbs {
    // 常量
    private static JdbcTemplate tpl;
    static {
        try(// 通过当前类获取字节码文件 然后通过字节码文件获取类加载器 然后通过类加载器获取资源文件 并且通过字节输入流读取该资源文件
            InputStream is = Dbs.class.getClassLoader().getResourceAsStream("druid.properties")) {
            // 创建properties对象 然后将字节输入流读取的内容加载进该对象中
            Properties properties = new Properties();
            properties.load(is);
            // 然后创建连接池
            DataSource ds = DruidDataSourceFactory.createDataSource(properties);
            // 通过连接池创建tpl
            tpl = new JdbcTemplate(ds);
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
    // 提供一个获取tpl的方法 来代替update、list以及RowMapper 以后可以通过调用tpl的api来访问被代替的方法
    public static JdbcTemplate getTpl() {
        return tpl;
    }
}

list.jsp





    Title
    
        th, td {
            border: 1px solid red;
        }
    


添加

id	姓名	年龄	身高	操作
${customer.id}	${customer.name}	${customer.age}	${customer.height}	编辑删除

5.修改功能的实现

前面我们已经实现了增加、删除、查找三个功能三缺一还差一个修改功能具体的实现方式为：执行servlet 将完整信息展示到要跳转的jsp页面在jsp中修改当前记录提交给servlet 再由servlet对数据库进行修改修改成功便转发到展示页面否则就重定向到失败页面

CustomerServlet

package com.axihh.servlet;
import com.axihh.bean.Customer;
import com.axihh.dao.CustomerDao;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.lang.reflect.Method;
@WebServlet("/customer/*")
public class CustomerServlet extends HttpServlet {
    // 定义一个CustomerDao对象 用于访问其中的save、list方法
    private final CustomerDao cd = new CustomerDao();
    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        try {
            // 获取调用方法的名称
            String[] cmps = request.getRequestURI().split("/");
            String methodName = cmps[cmps.length - 1];
            // 第四步 利用Java中的反射技术 根据methodName调用该类中的对应方法
            Method method = getClass().getMethod(methodName, HttpServletRequest.class, HttpServletResponse.class);
            // 第五步 调用反射得到的结果
            method.invoke(this, request, response);
        } catch (Exception e) {
            e.printStackTrace();
            // 当你随意传递一个路径的时候 需要给予一个友善的界面进行提醒
            request.setAttribute("error", "路径错误");
            request.getRequestDispatcher("/page/error.jsp").forward(request, response);
        }
    }
    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        doPost(request, response);
    }
    // 提供一个方法 用于模拟SaveServlet 由于请求路径中需要访问 所以直接公有化
    public void save(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        // 获取客户端发送的用户信息 并且封装为bean
        Customer customer = new Customer();
        customer.setName(request.getParameter("name"));
        customer.setAge(Integer.parseInt(request.getParameter("age")));
        customer.setHeight(Double.parseDouble(request.getParameter("height")));
        // 如果保存成功的话 就跳转到展示页面 如果保存失败的话 那么就跳转到失败页面
        if(cd.save(customer)) {
            // 执行的是重定向操作
            response.sendRedirect("/crm6/customer/list");
        } else {
            // 执行的是转发操作
            request.setAttribute("error", "保存客户信息失败");
            request.getRequestDispatcher("/page/error.jsp").forward(request, response);
        }
    }
    // 提供一个方法 用于模拟ListServlet 由于请求路径中同样需要访问 所以直接公有化
    public void list(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        // 将返回值存入attribute中
        request.setAttribute("customers", cd.list());
        // 转发到展示页面
        request.getRequestDispatcher("/page/list.jsp").forward(request, response);
    }
    // 提供一个方法 用于删除客户表的某一条记录
    public void remove(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        // 获取当前记录的id
        Integer id = Integer.valueOf(request.getParameter("id"));
        // 如果成功删除 那么就跳转到展示页面
        if(cd.remove(id)) {
            response.sendRedirect("/crm6/customer/list");
        }else {
            // 如果删除失败的话 那么就跳转到失败页面
            request.setAttribute("error", "删除客户信息失败");
            request.getRequestDispatcher("/page/error.jsp").forward(request, response);
        }
    }
    // 提供一个方法 用于获取客户表某一条记录修改前的完整信息
    public void edit(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        // 获取当前记录的id
        Integer id = Integer.valueOf(request.getParameter("id"));
        // 获取id对应的这一行记录的完整信息
        Customer customer = cd.find(id);
        // 将customer储存到request中 然后转发到edit.jsp页面
        request.setAttribute("customer", customer);
        request.getRequestDispatcher("/page/edit.jsp").forward(request, response);
    }
    // 提供一个方法 用于修改客户某一条记录的信息 并且转发到展示页面
    public void update(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        // 将表单数据映射为bean
        Customer customer = new Customer();
        customer.setId(Integer.valueOf(request.getParameter("id")));
        customer.setName(request.getParameter("name"));
        customer.setAge(Integer.valueOf(request.getParameter("age")));
        customer.setHeight(Double.valueOf(request.getParameter("height")));
        // 调用Dao中的Update方法 用于将更新以后的记录添加到数据库中 如果修改成功的话 那么就跳转到展示页面 否则的话 就跳转到失败页面
        if(cd.update(customer)) {
            response.sendRedirect("/crm6/customer/list");
        }else {
            request.setAttribute("error", "修改客户信息失败");
            request.getRequestDispatcher("/page/error.jsp");
        }
    }
}

CustomerDao.java

package com.axihh.dao;
import com.axihh.bean.Customer;
import com.axihh.util.Dbs;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import java.util.List;
public class CustomerDao {
    public boolean save(Customer customer){
        String sql = "INSERT INTO customer(name, age, height) VALUES (?, ?, ?)";
        return Dbs.getTpl().update(sql, customer.getName(), customer.getAge(), customer.getHeight()) > 0;
    }
    public List list() {
        String sql = "SELECT id, name, age, height FROM customer";
//        return Dbs.getTpl().query(sql, (rs, row) -> {
//            Customer customer = new Customer();
//            customer.setId(rs.getInt("id"));
//            customer.setName(rs.getString("name"));
//            customer.setAge(rs.getInt("age"));
//            customer.setHeight(rs.getDouble("height"));
//            return customer;
//        });
        return Dbs.getTpl().query(sql, new BeanPropertyRowMapper(Customer.class));
    }
    public boolean remove(int id) {
        String sql = "DELETE FROM customer WHERE id = ?";
        return Dbs.getTpl().update(sql, id) > 0;
    }
    public Customer find(Integer id) {
        String sql = "SELECT id, name, age, height FROM customer WHERE id = ?";
        return Dbs.getTpl().queryForObject(sql, new BeanPropertyRowMapper(Customer.class), id);
    }
    public boolean update(Customer customer) {
        String sql = "UPDATE customer SET name = ?, age = ?, height = ? WHERE id = ?";
        return Dbs.getTpl().update(sql, customer.getName(), customer.getAge(), customer.getHeight(), customer.getId()) > 0;
    }
}

edit.jsp




    Title



    
    姓名 
    年龄 
    身高 
    更新

6.重复代码抽取

我们发现增删改查功能齐全的servlet中仍然存在大量重复的代码比如：失败页面的跳转、表单数据映射为bean

抽取失败页面的跳转代码(封装到forwardError方法中)

package com.axihh.servlet;
import com.axihh.bean.Customer;
import com.axihh.dao.CustomerDao;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.lang.reflect.Method;
@WebServlet("/customer/*")
public class CustomerServlet extends HttpServlet {
    // 定义一个CustomerDao对象 用于访问其中的save、list方法
    private final CustomerDao cd = new CustomerDao();
    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        try {
            // 获取调用方法的名称
            String[] cmps = request.getRequestURI().split("/");
            String methodName = cmps[cmps.length - 1];
            // 第四步 利用Java中的反射技术 根据methodName调用该类中的对应方法
            Method method = getClass().getMethod(methodName, HttpServletRequest.class, HttpServletResponse.class);
            // 第五步 调用反射得到的结果
            method.invoke(this, request, response);
        } catch (Exception e) {
            e.printStackTrace();
            String error = "路径错误";
            forwardError(request, response, error);
        }
    }
    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        doPost(request, response);
    }
    // 提供一个方法 用于模拟SaveServlet 由于请求路径中需要访问 所以直接公有化
    public void save(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        // 获取客户端发送的用户信息 并且封装为bean
        Customer customer = new Customer();
        customer.setName(request.getParameter("name"));
        customer.setAge(Integer.parseInt(request.getParameter("age")));
        customer.setHeight(Double.parseDouble(request.getParameter("height")));
        // 如果保存成功的话 就跳转到展示页面 如果保存失败的话 那么就跳转到失败页面
        if(cd.save(customer)) {
            // 执行的是重定向操作
            response.sendRedirect("/crm6/customer/list");
        } else {
            String error = "保存客户信息失败";
            forwardError(request, response, error);
        }
    }
    // 提供一个方法 用于模拟ListServlet 由于请求路径中同样需要访问 所以直接公有化
    public void list(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        // 将返回值存入attribute中
        request.setAttribute("customers", cd.list());
        // 转发到展示页面
        request.getRequestDispatcher("/page/list.jsp").forward(request, response);
    }
    // 提供一个方法 用于删除客户表的某一条记录
    public void remove(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        // 获取当前记录的id
        Integer id = Integer.valueOf(request.getParameter("id"));
        // 如果成功删除 那么就跳转到展示页面
        if(cd.remove(id)) {
            response.sendRedirect("/crm6/customer/list");
        }else {
            String error = "删除客户信息失败";
            forwardError(request, response, error);
        }
    }
    // 提供一个方法 用于获取客户表某一条记录修改前的完整信息
    public void edit(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        // 获取当前记录的id
        Integer id = Integer.valueOf(request.getParameter("id"));
        // 获取id对应的这一行记录的完整信息
        Customer customer = cd.find(id);
        // 将customer储存到request中 然后转发到edit.jsp页面
        request.setAttribute("customer", customer);
        request.getRequestDispatcher("/page/edit.jsp").forward(request, response);
    }
    // 提供一个方法 用于修改客户某一条记录的信息 并且转发到展示页面
    public void update(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        // 将表单数据映射为bean
        Customer customer = new Customer();
        customer.setId(Integer.valueOf(request.getParameter("id")));
        customer.setName(request.getParameter("name"));
        customer.setAge(Integer.valueOf(request.getParameter("age")));
        customer.setHeight(Double.valueOf(request.getParameter("height")));
        // 调用Dao中的Update方法 用于将更新以后的记录添加到数据库中 如果修改成功的话 那么就跳转到展示页面 否则的话 就跳转到失败页面
        if(cd.update(customer)) {
            response.sendRedirect("/crm6/customer/list");
        }else {
            String error = "更新客户信息失败";
            forwardError(request, response, error);
        }
    }
    // 提供一个方法 用于跳转到失败页面
    private void forwardError(HttpServletRequest request, HttpServletResponse response, String error) throws ServletException, IOException {
        // 设置失败信息
        request.setAttribute("error", error);
        // 转发到失败页面
        request.getRequestDispatcher("/page/error.jsp").forward(request, response);
    }
}

抽取表单数据映射为bean模型的重复代码(封装为newCustomer)

方法一

package com.axihh.servlet;
import com.axihh.bean.Customer;
import com.axihh.dao.CustomerDao;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
@WebServlet("/customer/*")
public class CustomerServlet extends HttpServlet {
    // 定义一个CustomerDao对象 用于访问其中的save、list方法
    private final CustomerDao cd = new CustomerDao();
    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        try {
            // 获取调用方法的名称
            String[] cmps = request.getRequestURI().split("/");
            String methodName = cmps[cmps.length - 1];
            // 第四步 利用Java中的反射技术 根据methodName调用该类中的对应方法
            Method method = getClass().getMethod(methodName, HttpServletRequest.class, HttpServletResponse.class);
            // 第五步 调用反射得到的结果
            method.invoke(this, request, response);
        }  catch (Exception e) {
            e.printStackTrace();
            String error = "路径错误";
            forwardError(request, response, error);
        }
    }
    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        doPost(request, response);
    }
    // 提供一个方法 用于模拟SaveServlet 由于请求路径中需要访问 所以直接公有化
    public void save(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        // 获取客户端发送的用户信息 并且封装为bean
        Customer customer = newCustomer(request);
        // 如果保存成功的话 就跳转到展示页面 如果保存失败的话 那么就跳转到失败页面
        if(cd.save(customer)) {
            // 执行的是重定向操作
            response.sendRedirect("/crm6/customer/list");
        } else {
            String error = "保存客户信息失败";
            forwardError(request, response, error);
        }
    }
    // 提供一个方法 用于模拟ListServlet 由于请求路径中同样需要访问 所以直接公有化
    public void list(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        // 将返回值存入attribute中
        request.setAttribute("customers", cd.list());
        // 转发到展示页面
        request.getRequestDispatcher("/page/list.jsp").forward(request, response);
    }
    // 提供一个方法 用于删除客户表的某一条记录
    public void remove(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        // 获取当前记录的id
        Integer id = Integer.valueOf(request.getParameter("id"));
        // 如果成功删除 那么就跳转到展示页面
        if(cd.remove(id)) {
            response.sendRedirect("/crm6/customer/list");
        }else {
            String error = "删除客户信息失败";
            forwardError(request, response, error);
        }
    }
    // 提供一个方法 用于获取客户表某一条记录修改前的完整信息
    public void edit(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        // 获取当前记录的id
        Integer id = Integer.valueOf(request.getParameter("id"));
        // 获取id对应的这一行记录的完整信息
        Customer customer = cd.find(id);
        // 将customer储存到request中 然后转发到edit.jsp页面
        request.setAttribute("customer", customer);
        request.getRequestDispatcher("/page/edit.jsp").forward(request, response);
    }
    // 提供一个方法 用于修改客户某一条记录的信息 并且转发到展示页面
    public void update(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        // 将表单数据映射为bean
        Customer customer = newCustomer(request);
        customer.setId(Integer.valueOf(request.getParameter("id")));
        // 调用Dao中的Update方法 用于将更新以后的记录添加到数据库中 如果修改成功的话 那么就跳转到展示页面 否则的话 就跳转到失败页面
        if(cd.update(customer)) {
            response.sendRedirect("/crm6/customer/list");
        }else {
            String error = "更新客户信息失败";
            forwardError(request, response, error);
        }
    }
    // 提供一个方法 用于跳转到失败页面
    private void forwardError(HttpServletRequest request, HttpServletResponse response, String error) throws ServletException, IOException {
        // 设置失败信息
        request.setAttribute("error", error);
        // 转发到失败页面
        request.getRequestDispatcher("/page/error.jsp").forward(request, response);
    }
    // 提供一个方法 用于保存表单数据映射为bean模型的代码
    private Customer newCustomer(HttpServletRequest request) {
        Customer customer = new Customer();
        // 将表单数据保存到bean模型中
        customer.setName(request.getParameter("name"));
        customer.setAge(Integer.valueOf(request.getParameter("age")));
        customer.setHeight(Double.valueOf(request.getParameter("height")));
        return customer;
    }
}

方法二

方法二的优越性在于它利用了Java的反射技术简化了手动设置参数的过程
需要依赖函数库commons-beanutils.jar、commons-collections.jar、commons-loggin.jar 调用他们的api 即BeanUtils.populate方法

同时我们优化了异常抛出将增删改查方法所抛出的异常全部修改为Exception 但是forwardError、doGet、doPost这三个方法所抛出的异常不能修改因为他们都受到父类或者主调方法的限制不能超出他们所抛异常的范围

package com.axihh.servlet;
import com.axihh.bean.Customer;
import com.axihh.dao.CustomerDao;
import org.apache.commons.beanutils.BeanUtils;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
@WebServlet("/customer/*")
public class CustomerServlet extends HttpServlet {
    // 定义一个CustomerDao对象 用于访问其中的save、list方法
    private final CustomerDao cd = new CustomerDao();
    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        try {
            // 获取调用方法的名称
            String[] cmps = request.getRequestURI().split("/");
            String methodName = cmps[cmps.length - 1];
            // 第四步 利用Java中的反射技术 根据methodName调用该类中的对应方法
            Method method = getClass().getMethod(methodName, HttpServletRequest.class, HttpServletResponse.class);
            // 第五步 调用反射得到的结果
            method.invoke(this, request, response);
        }  catch (Exception e) {
            e.printStackTrace();
            String error = "路径错误";
            forwardError(request, response, error);
        }
    }
    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        doPost(request, response);
    }
    // 提供一个方法 用于模拟SaveServlet 由于请求路径中需要访问 所以直接公有化
    public void save(HttpServletRequest request, HttpServletResponse response) throws Exception {
        // 获取客户端发送的用户信息 并且封装为bean
        Customer customer = new Customer();
        BeanUtils.populate(customer, request.getParameterMap());
        // 如果保存成功的话 就跳转到展示页面 如果保存失败的话 那么就跳转到失败页面
        if(cd.save(customer)) {
            // 执行的是重定向操作
            response.sendRedirect("/crm6/customer/list");
        } else {
            String error = "保存客户信息失败";
            forwardError(request, response, error);
        }
    }
    // 提供一个方法 用于模拟ListServlet 由于请求路径中同样需要访问 所以直接公有化
    public void list(HttpServletRequest request, HttpServletResponse response) throws Exception {
        // 将返回值存入attribute中
        request.setAttribute("customers", cd.list());
        // 转发到展示页面
        request.getRequestDispatcher("/page/list.jsp").forward(request, response);
    }
    // 提供一个方法 用于删除客户表的某一条记录
    public void remove(HttpServletRequest request, HttpServletResponse response) throws Exception {
        // 获取当前记录的id
        Integer id = Integer.valueOf(request.getParameter("id"));
        // 如果成功删除 那么就跳转到展示页面
        if(cd.remove(id)) {
            response.sendRedirect("/crm6/customer/list");
        }else {
            String error = "删除客户信息失败";
            forwardError(request, response, error);
        }
    }
    // 提供一个方法 用于获取客户表某一条记录修改前的完整信息
    public void edit(HttpServletRequest request, HttpServletResponse response) throws Exception {
        // 获取当前记录的id
        Integer id = Integer.valueOf(request.getParameter("id"));
        // 获取id对应的这一行记录的完整信息
        Customer customer = cd.find(id);
        // 将customer储存到request中 然后转发到edit.jsp页面
        request.setAttribute("customer", customer);
        request.getRequestDispatcher("/page/edit.jsp").forward(request, response);
    }
    // 提供一个方法 用于修改客户某一条记录的信息 并且转发到展示页面
    public void update(HttpServletRequest request, HttpServletResponse response) throws Exception {
        // 将表单数据映射为bean
        Customer customer = new Customer();
        BeanUtils.populate(customer, request.getParameterMap());
        // 调用Dao中的Update方法 用于将更新以后的记录添加到数据库中 如果修改成功的话 那么就跳转到展示页面 否则的话 就跳转到失败页面
        if(cd.update(customer)) {
            response.sendRedirect("/crm6/customer/list");
        }else {
            String error = "更新客户信息失败";
            forwardError(request, response, error);
        }
    }
    // 提供一个方法 用于跳转到失败页面
    private void forwardError(HttpServletRequest request, HttpServletResponse response, String error) throws ServletException, IOException {
        // 设置失败信息
        request.setAttribute("error", error);
        // 转发到失败页面
        request.getRequestDispatcher("/page/error.jsp").forward(request, response);
    }
}

以上是Servlet中所有可抽取的点接下来我们将抽取的目光放在Dao中可以发现其中 sql语句参数的传递可能会因为数量过多导致设置麻烦又因为他们存在公共部分所以说我们将为sql语句设置参数的代码部分抽取为一个方法即buildArgs

package com.axihh.dao;
import com.axihh.bean.Customer;
import com.axihh.util.Dbs;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import java.util.ArrayList;
import java.util.List;
public class CustomerDao {
    public boolean save(Customer customer){
        String sql = "INSERT INTO customer(name, age, height) VALUES (?, ?, ?)";
        List args = buildArgs(customer);
        return Dbs.getTpl().update(sql, args.toArray()) > 0;
    }
    public List list() {
        String sql = "SELECT id, name, age, height FROM customer";
//        return Dbs.getTpl().query(sql, (rs, row) -> {
//            Customer customer = new Customer();
//            customer.setId(rs.getInt("id"));
//            customer.setName(rs.getString("name"));
//            customer.setAge(rs.getInt("age"));
//            customer.setHeight(rs.getDouble("height"));
//            return customer;
//        });
        return Dbs.getTpl().query(sql, new BeanPropertyRowMapper(Customer.class));
    }
    public boolean remove(int id) {
        String sql = "DELETE FROM customer WHERE id = ?";
        return Dbs.getTpl().update(sql, id) > 0;
    }
    public Customer find(Integer id) {
        String sql = "SELECT id, name, age, height FROM customer WHERE id = ?";
        return Dbs.getTpl().queryForObject(sql, new BeanPropertyRowMapper(Customer.class), id);
    }
    public boolean update(Customer customer) {
        String sql = "UPDATE customer SET name = ?, age = ?, height = ? WHERE id = ?";
        List args = buildArgs(customer);
        args.add(customer.getId());
        return Dbs.getTpl().update(sql, args.toArray()) > 0;
    }
    private List buildArgs(Customer customer) {
        List args = new ArrayList();
        args.add(customer.getName());
        args.add(customer.getAge());
        args.add(customer.getHeight());
        return args;
    }
}

7.Junit

Junit是Java中最常用的单元测试框架

所需jar包

junit.jar
hamcrest.jar
hamcrest-core.jar
建议单元测试类的命名规范为：XxTest

常用注解

@Test：正常的测试方法建议格式为public void testXx()
@Before：在每个@Test方法执行之前执行建议格式为public void before()
@After：在每个@Tes方法执行之后执行建议格式为public void after()
@BeforeClass：在第一个@Test方法执行之前执行建议格式为public static void beforeClass()
@AfterClass：在最后一个@Test方法执行之后执行建议格式为public static void afterClass()

断言类Assert的常用方法

assertTrue
assertFalse
assertEquals
assertNotEquals
assertNotNull
assertNull

测试类建议存放在Test(和src同级)目录下(你可以右击文件夹中mark directory as 选择test resources root 就可以达到绿色文件夹的效果了)

这个文件夹出现的目的在于测试类不用部署到服务器上运行所以说仅仅需要通过编译而不需要打包所以需要独立于src文件夹在设置一个新文件夹而且是专门为test设置的文件夹

测试用例

package com.axihh.test;
import com.axihh.bean.Customer;
import com.axihh.dao.CustomerDao;
import org.junit.*;
public class CustomerDaoTest {
    @BeforeClass
    public static void beforeClass() {
        System.out.println("beforeClass");
    }
    @AfterClass
    public static void afterClass() {
        System.out.println("afterClass");
    }
    @Before
    public void before() {
        System.out.println("before");
    }
    @After
    public void after() {
        System.out.println("after");
    }
    @Test
    public void testSave() {
        Customer customer = new Customer();
        customer.setName("张三");
        customer.setAge(11);
        customer.setHeight(1.1);
        CustomerDao cd = new CustomerDao();
        Assert.assertTrue(cd.save(customer));
    }
    @Test
    public void testSum() {
        int a = 1;
        int b = 2;
        Assert.assertEquals(a + b, 3);
    }
}

8.合并页面

对于add.html和edit.jsp两个页面来说其实存在着大量重复的代码我们可以将其合并为一个页面合并之后 servlet中的save和update两个方法以及dao中的save和update两个方法也要合并而且由于dao中的两方法合并所以说之前抽取出来的buildArgs方法可以推出使命了而且由于servlet中的save和update方法已然合并所以说edit中的表单数据提交地址也得改成合并之后的页面

注意1：在dao中合并以后的save方法中判断添加页面还是编辑页面的时候判断的依据主要是bean中的id是否为空但是数据库中的id至少都为1 所以在判断添加页面的时候除了判空以外还有一种情况也需要判断就是id值小于1的时候
注意2：在合并之后的save.jsp页面中我们判断添加页面还是编辑页面的时候主要是通过if-else/switch语句进行的但是呢在jstl标签库中并没有模拟Java中if-else的语法(仅有多个if的语法即) 而只有swtich的语法(即 > 、)
注意3：jstl标签库和el表达式是两种不一样的东西 jstl提供的是标签而el表达式的格式为${}
注意4：在修改/删除页面中可以获取id的原因在于：为编辑设置超链接时在地址后面拼接了id参数

代码实现

save.jsp





    
    
        
            添加页面
        
        
            编辑页面
        
    



    
    bean的自动转换时 将null值转换为0 而在数据库中 id这个主键的值至少都是1 --%>
    when、otherwise这个jstl标签 直接使用if标签即可 --%>
    
        
    
    姓名 
    年龄 
    身高 
    
        
            
                添加
                更新

CustomerServlet.java

package com.axihh.servlet;
import com.axihh.bean.Customer;
import com.axihh.dao.CustomerDao;
import org.apache.commons.beanutils.BeanUtils;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
import javax.servlet.http.HttpServletRequest;
import javax.servlet.http.HttpServletResponse;
import java.io.IOException;
import java.lang.reflect.InvocationTargetException;
import java.lang.reflect.Method;
@WebServlet("/customer/*")
public class CustomerServlet extends HttpServlet {
    // 定义一个CustomerDao对象 用于访问其中的save、list方法
    private final CustomerDao cd = new CustomerDao();
    protected void doPost(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        try {
            // 获取调用方法的名称
            String[] cmps = request.getRequestURI().split("/");
            String methodName = cmps[cmps.length - 1];
            // 第四步 利用Java中的反射技术 根据methodName调用该类中的对应方法
            Method method = getClass().getMethod(methodName, HttpServletRequest.class, HttpServletResponse.class);
            // 第五步 调用反射得到的结果
            method.invoke(this, request, response);
        }  catch (Exception e) {
            e.printStackTrace();
            String error = "路径错误";
            forwardError(request, response, error);
        }
    }
    protected void doGet(HttpServletRequest request, HttpServletResponse response) throws ServletException, IOException {
        doPost(request, response);
    }
    // 提供一个方法 用于模拟SaveServlet 由于请求路径中需要访问 所以直接公有化
    public void save(HttpServletRequest request, HttpServletResponse response) throws Exception {
        // 获取客户端发送的用户信息 并且封装为bean
        Customer customer = new Customer();
        BeanUtils.populate(customer, request.getParameterMap());
        // 如果保存成功的话 就跳转到展示页面 如果保存失败的话 那么就跳转到失败页面
        if(cd.save(customer)) {
            // 执行的是重定向操作
            response.sendRedirect("/crm6/customer/list");
        } else {
            String error = "保存客户信息失败";
            forwardError(request, response, error);
        }
    }
    // 提供一个方法 用于模拟ListServlet 由于请求路径中同样需要访问 所以直接公有化
    public void list(HttpServletRequest request, HttpServletResponse response) throws Exception {
        // 将返回值存入attribute中
        request.setAttribute("customers", cd.list());
        // 转发到展示页面
        request.getRequestDispatcher("/page/list.jsp").forward(request, response);
    }
    // 提供一个方法 用于删除客户表的某一条记录
    public void remove(HttpServletRequest request, HttpServletResponse response) throws Exception {
        // 获取当前记录的id
        Integer id = Integer.valueOf(request.getParameter("id"));
        // 如果成功删除 那么就跳转到展示页面
        if(cd.remove(id)) {
            response.sendRedirect("/crm6/customer/list");
        }else {
            String error = "删除客户信息失败";
            forwardError(request, response, error);
        }
    }
    // 提供一个方法 用于获取客户表某一条记录修改前的完整信息
    public void edit(HttpServletRequest request, HttpServletResponse response) throws Exception {
        // 获取当前记录的id
        Integer id = Integer.valueOf(request.getParameter("id"));
        // 获取id对应的这一行记录的完整信息
        Customer customer = cd.find(id);
        // 将customer储存到request中 然后转发到edit.jsp页面
        request.setAttribute("customer", customer);
        request.getRequestDispatcher("/page/edit.jsp").forward(request, response);
    }
    // 提供一个方法 用于跳转到失败页面
    private void forwardError(HttpServletRequest request, HttpServletResponse response, String error) throws ServletException, IOException {
        // 设置失败信息
        request.setAttribute("error", error);
        // 转发到失败页面
        request.getRequestDispatcher("/page/error.jsp").forward(request, response);
    }
}

CustomerDao.java

package com.axihh.dao;
import com.axihh.bean.Customer;
import com.axihh.util.Dbs;
import org.springframework.jdbc.core.BeanPropertyRowMapper;
import java.util.ArrayList;
import java.util.List;
public class CustomerDao {
    public boolean save(Customer customer){
        List args = new ArrayList();
        args.add(customer.getName());
        args.add(customer.getAge());
        args.add(customer.getHeight());
        Integer id = customer.getId();
        String sql;
        // 根据不同的页面做出不同的操作
        if(id == null || id  0;
    }
    public List list() {
        String sql = "SELECT id, name, age, height FROM customer";
//        return Dbs.getTpl().query(sql, (rs, row) -> {
//            Customer customer = new Customer();
//            customer.setId(rs.getInt("id"));
//            customer.setName(rs.getString("name"));
//            customer.setAge(rs.getInt("age"));
//            customer.setHeight(rs.getDouble("height"));
//            return customer;
//        });
        return Dbs.getTpl().query(sql, new BeanPropertyRowMapper(Customer.class));
    }
    public boolean remove(int id) {
        String sql = "DELETE FROM customer WHERE id = ?";
        return Dbs.getTpl().update(sql, id) > 0;
    }
    public Customer find(Integer id) {
        String sql = "SELECT id, name, age, height FROM customer WHERE id = ?";
        return Dbs.getTpl().queryForObject(sql, new BeanPropertyRowMapper(Customer.class), id);
    }
}

edit.jsp




    Title



    
    姓名 
    年龄 
    身高 
    更新

VPS购买请点击我

免责声明：我们致力于保护作者版权，注重分享，被刊用文章因无法核实真实出处，未能及时与作者取得联系，或有版权异议的，请联系管理员，我们会立即处理! 部分文章是来自自研大数据AI进行生成,内容摘自(百度百科,百度知道,头条百科,中国民法典,刑法,牛津词典,新华词典,汉语词典,国家院校,科普平台)等数据,内容仅供学习参考,不准确地方联系删除处理! 图片声明：本站部分配图来自人工智能系统AI生成,觅知网授权图片,PxHere摄影无版权图库和百度，360，搜狗等多加搜索引擎自动关键词搜索配图，如有侵权的图片，请第一时间联系我们，邮箱：ciyunidc@ciyunshuju.com。本站只作为美观性配图使用,无任何非法侵犯第三方意图,一切解释权归图片著作权方,本站不承担任何责任。如有恶意碰瓷者,必当奉陪到底严惩不贷!

SpringJDBC

1.前言

2.拷贝模块

3.Sprint JDBC的核心类：JdbcTemplate

4.删除功能的实现

5.修改功能的实现

6.重复代码抽取

7.Junit

8.合并页面

相关阅读

怎么把织梦的模板替换?

dedecms怎么调用特定的栏目文档?

怎么抓包一个网页?

wap怎么封装app?

目录[+]