Spring – RowMapper 接口与示例

Spring 是最流行的Java EE 框架之一。它是一个开源轻量级框架，允许Java EE 7 开发人员构建简单、可靠且可扩展的企业应用程序。该框架主要侧重于提供各种方法来帮助您管理业务对象。与Java数据库连接 (JDBC)、JavaServer Pages (JSP) 和Java Servlet 等经典Java框架和应用程序编程接口 (API) 相比，它使 Web 应用程序的开发更加容易。该框架使用各种新技术，如面向方面编程 (AOP)、普通Java对象 (POJO) 和依赖注入 (DI) 来开发企业应用程序。在 Spring 中， RowMapper接口用于使用JdbcTemplate类的query()方法从数据库中获取记录。

JdbcTemplate 类的 query() 方法的语法：

public T query(String sqlQuery, RowMapper rowMapper)

RowMapper 是为每一行调用的回调接口，并将与实例的关系行映射到模型（用户定义）类。与 ResultSetExtractor 不同，RowMapper 在内部迭代 ResultSet 并将提取的数据添加到集合中，并且我们不需要像在 ResultSetExtractor 中那样为集合编写代码。它只有一个方法 mapRow()，它分别接受两个参数 ResultSet 和 rowNumber。为了使用 RowMapper，我们需要实现这个接口并提供 mapRow() 方法的定义。

rowMapper() 方法的语法：

public T mapRow(ResultSet resultSet, int rowNumber)throws SQLException

例子

在此示例中，我们将使用 RowMapper 从 Student 表中提取所有记录。对于本教程，我们将为 Student 表使用以下模式。

Student(id INT, name VARCHAR(45), department VARCHAR(45))

分步实施

第 1 步：创建表

在这一步中，我们将创建一个学生表来存储学生的信息。对于本教程，我们将假设您已在数据库中创建了下表。

CREATE TABLE STUDENT(
id INT,
name VARCHAR(45),
department VARCHAR(45));

创建表后，我们将在表中插入以下数据。

INSERT INTO STUDENT VALUES(1, "geek", "computer science");

第 2 步：添加依赖项

在这一步中，我们会将 maven 依赖项添加到我们的应用程序中。将以下依赖项添加到您的 pom.xml

XML

  4.0.0
  com.geeksforgeeks
  RowMapper
  0.0.1-SNAPSHOT
    
  
      
   
   
            org.springframework
            spring-jdbc
            5.3.16
    
          
    
    
            org.springframework
            spring-context
            5.0.8.RELEASE
    
      
    
        mysql
        mysql-connector-java
        5.1.44
    
          
  
    

第三步：创建模型类

现在，我们将为我们的学生创建一个模型班。此类将具有三个成员变量 id、name 和部门。我们还将定义它的 getters 和 setters 方法以及 toString() 方法。

Java

package com.geeksforgeeks.model;
  
public class Student {
    // member variables
    private int id;
    private String name;
    private String department;
      
    // getters and setters method
    public int getId() {
        return id;
    }
    public void setId(int id) {
        this.id = id;
    }
    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public String getDepartment() {
        return department;
    }
    public void setDepartment(String department) {
        this.department = department;
    }
      
    // toString() method
    @Override
    public String toString() {
        return "Student [id=" + id + ", name=" + name + ", department=" + department + "]";
    }    
}

第四步：创建 Dao 接口

现在，我们将创建一个接口并将其命名为StudentDao ，我们将使用它来访问数据存储数据库中的数据。我们需要定义getAllStudentDetails()方法，该方法将返回学生的所有详细信息。

Java

import java.util.List;
  
import com.geeksforgeeks.model.Student;
  
public interface StudentDao {
    // this method will return all
    // the details of the students
    public List getAllStudentDetails();
  
}

步骤 5：为 Dao 接口创建一个实现类

在这一步中，我们将创建一个实现类StudentDaoImpl。Java该类实现了StudentDao接口，并为 StudentDao 接口的getAllStudentDetails()方法提供了定义。在这个类中，我们还将实现RowMapper接口并提供其mapRow()方法的定义。

Java

import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.List;
  
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;
  
import com.geeksforgeeks.model.Student;
  
public class StudentDaoImpl implements StudentDao{
      
    // Defining JdbcTemplate as member variable in order
    // to use the query() method of the JdbcTemplate's class
    private JdbcTemplate jdbcTemplate;
      
    public JdbcTemplate getJdbcTemplate() {
        return jdbcTemplate;
    }
  
    public void setJdbcTemplate(JdbcTemplate jdbcTemplate) {
        this.jdbcTemplate = jdbcTemplate;
    }
  
    // This method will return the list 
    // of all the details of student
    public List getAllStudentDetails() {
          
        // Implementation of RowMapper interface
        return jdbcTemplate.query("SELECT * FROM student", new RowMapper() {
  
            public Student mapRow(ResultSet rs, int rowNum) throws SQLException {
                Student student = new Student();
                student.setId(rs.getInt(1));
                student.setName(rs.getString(2));
                student.setDepartment(rs.getString(3));
                return student;
            }
        });
    }
}

第 6 步：Bean 配置

在这一步中，我们将创建 spring 配置文件并将其命名为application-contex.xml 。我们将配置我们的 bean 并使用 factory-method 属性来创建 bean。为了与数据库建立连接，我们需要以下信息用户名、密码、数据库连接、URL 和驱动程序类名称。所有这些信息都包含在DriverManagerDataSource类中，它具有返回Java类型连接的getConnection()方法。我们在 StudentDao 类中使用 JdbcTemplate 的实例，并使用 setter 注入方法传递它。

Note: In application context, you need to define the whole path of your dao class

第 7 步：创建实用程序类

现在，我们将创建一个 Utility 类来测试我们的应用程序。为此创建一个新类并将其命名为TestRowMapper。 Java并将以下代码添加到其中。

Java

import java.util.List;
  
import org.springframework.context.support.AbstractApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
  
import com.geeksforgeeks.dao.StudentDaoImpl;
import com.geeksforgeeks.model.Student;
  
public class TestRowMapper {
  
    public static void main(String[] args) {
          
        // Reading the application-context file using
        // class path of spring context xml file
        AbstractApplicationContext context = new ClassPathXmlApplicationContext("application-context.xml");
          
        // Spring check the blueprint for studentDao bean 
        // from application-context.xml file and return it
        StudentDaoImpl studentDaoImpl = (StudentDaoImpl)context.getBean("studentDao");
          
        // Getting student data
        List studentDetailList = studentDaoImpl.getAllStudentDetails();
          
        for(Student index : studentDetailList) {
            System.out.println(index);
        }
                  
  
    }
}

第 8 步：输出

现在，我们将运行我们的应用程序。