1. WIKI教程
2. 学习Spring JDBC
3. Spring JDBC - 快速指南

Spring JDBC - 快速指南

Spring JDBC - Overview

在使用普通旧JDBC处理数据库时，编写不必要的代码来处理异常，打开和关闭数据库连接等变得很麻烦。但是，Spring JDBC Framework从打开连接，准备和开始处理所有低级细节。执行SQL语句，处理异常，处理事务，最后关闭连接。

您所做的只是定义连接参数并指定要执行的SQL语句，并在从数据库获取数据时为每次迭代执行所需的工作。

Spring JDBC提供了几种方法和相应的不同类来与数据库进行交互。 在本教程中，我们将采用经典和最流行的方法，该方法使用框架的JDBC Template类。 这是管理所有数据库通信和异常处理的中央框架类。

JDBC模板类

JDBC Template类执行SQL查询，更新语句和存储过程调用，对ResultSet执行迭代并提取返回的参数值。 它还捕获JDBC异常并将它们转换为org.springframework.dao包中定义的通用的，更具信息性的异常层次结构。

配置后，JDBC Template类的实例是线程安全的。 因此，您可以配置JDBC模板的单个实例，然后将此共享引用安全地注入多个DAO。

使用JDBC Template类时的一个常见做法是在Spring配置文件中配置DataSource，然后将共享DataSource bean依赖注入到DAO类中。 JDBC模板是在DataSource的setter中创建的。

Data Access Object (DAO)

DAO代表Data Access Object ，它通常用于数据库交互。 存在DAO以提供向数据库读取和写入数据的方法，并且它们应该通过接口公开此功能，应用程序的其余部分将通过该接口访问它们。

Spring中的数据访问对象（DAO）支持使得以一致的方式使用JDBC，Hibernate，JPA或JDO等数据访问技术变得容易。

Spring JDBC - Environment Setup

本章将指导您完成在基于Windows和Linux的系统上设置Spring-AOP的过程。 Spring AOP可以通过几个简单的步骤轻松安装并与您当前的Java环境和MAVEN集成，而无需任何复杂的设置过程。 安装时需要用户管理。

系统需求 (System Requirements)

JDK	Java SE 2 JDK 1.5或以上版本
Memory	1 GB RAM（推荐）
磁盘空间	没有最低要求
操作系统版本	Windows XP或更高版本，Linux

现在让我们继续安装Spring AOP的步骤。

步骤1 - 验证Java安装

首先，您需要在系统上安装Java软件开发工具包（SDK）。 要验证这一点，请根据您正在使用的平台执行以下两个命令中的任何一个。

如果Java安装已正确完成，那么它将显示Java安装的当前版本和规范。 下表给出了示例输出。

平台	命令	样本输出
Windows	打开命令控制台并输入 - \》java -version	Java版“1.7.0_60” Java（TM）SE运行时环境（版本1.7.0_60-b19） Java Hotspot（TM）64位服务器VM（内置24.60-b09，混合模式）
Linux	打开命令终端并输入 - $java -version	java版“1.7.0_25” 打开JDK运行时环境（rhel-2.3.10.4.el6_4-x86_64） 打开JDK 64位服务器VM（内置23.7-b01，混合模式）

我们假设本教程的读者在i系统上安装了Java SDK版本1.7.0_60。 如果您没有Java SDK，请从https://www.oracle.com/technetwork/java/javase/downloads/index.html下载其当前版本并安装它。

第2步 - 设置Java环境

将环境变量JAVA_HOME设置为指向计算机上安装Java的基本目录位置。 例如，

平台	描述
Windows	将JAVA_HOME设置为C:\ProgramFiles\java\jdk1.7.0_60
Linux	导出JAVA_HOME =/usr/local/java-current

将Java编译器位置的完整路径附加到系统路径。

平台	描述
Windows	将字符串“C:\Program Files\Java\jdk1.7.0_60\bin”附加到系统变量PATH的末尾。
Linux	导出PATH = $ PATH:$ JAVA_HOME/bin/

如上所述，从命令提示符执行命令java -version 。

第3步 - 下载Maven存档

从https://maven.apache.org/download.cgi下载Maven 3.3.3

OS	存档名称
Windows	apache-maven-3.3.3-bin.zip
Linux	apache-maven-3.3.3-bin.tar.gz
Mac	apache-maven-3.3.3-bin.tar.gz

第4步 - 提取Maven存档

将存档解压缩到您要安装Maven 3.3.3的目录。 将从存档创建子目录apache-maven-3.3.3。

OS	位置（根据您的安装可能会有所不同）
Windows	C:\Program Files\Apache Software Foundation\apache-maven-3.3.3
Linux	/usr/local/apache-maven
Mac	/usr/local/apache-maven

第5步 - 设置Maven环境变量

将M2_HOME，M2，MAVEN_OPTS添加到环境变量中。

OS	output
Windows	使用系统属性设置环境变量。 M2_HOME=C:\Program Files\Apache Software Foundation\apachemaven-3.3.3 M2 = %M2_HOME%\bin MAVEN_OPTS = -Xms256m -Xmx512m
Linux	打开命令终端并设置环境变量。 export M2_HOME = /usr/local/apache-maven/apache-maven-3.3.3 export M2 = $M2_HOME/bin export MAVEN_OPTS = -Xms256m -Xmx512m
Mac	打开命令终端并设置环境变量。 export M2_HOME = /usr/local/apache-maven/apache-maven-3.3.3 export M2 = $M2_HOME/bin export MAVEN_OPTS = -Xms256m -Xmx512m

步骤6 - 将Maven Bin目录位置添加到系统路径

现在将M2变量附加到系统路径。

OS	output
Windows	将字符串;％M2％附加到系统变量Path的末尾。
Linux	export PATH = $ M2:$ PATH
Mac	export PATH = $ M2:$ PATH

第7步 - 验证Maven安装

现在打开控制台，执行以下mvn命令。

OS	任务	命令
Windows	打开命令控制台	c:\> mvn --version
Linux	打开命令终端	$ mvn --version
Mac	开放式终端	机器:

最后，验证上述命令的输出，该命令应如下所示 -

OS	output
Windows	Apache Maven 3.3.3（7994120775791599e205a5524ec3e0dfe41d4a06; 2015-04-22T17:27:37 + 05:30） Maven home:C:\Program Files\Apache Software Foundation\apache-maven-3.3.3 Java版本:1.7.0_75，供应商:Oracle Corporation Java home:C:\Program Files\Java\jdk1.7.0_75\jre 默认语言环境:en_US，平台编码:Cp1252
Linux	Apache Maven 3.3.3（7994120775791599e205a5524ec3e0dfe41d4a06; 2015-04-22T17:27:37 + 05:30） Maven home:/usr/local/apache-maven/apache-maven-3.3.3 Java版本:1.7.0_75，供应商:Oracle Corporation Java home:/usr/local/java-current/jdk1.7.0_75/jre
Mac	Apache Maven 3.3.3（7994120775791599e205a5524ec3e0dfe41d4a06; 2015-04-22T17:27:37 + 05:30） Maven home:/usr/local/apache-maven/apache-maven-3.3.3 Java版本:1.7.0_75，供应商:Oracle Corporation Java home:/Library/Java/Home/jdk1.7.0_75/jre

第8步 - 设置Eclipse IDE

本教程中的所有示例都是使用Eclipse IDE编写的。 所以，我建议你应该在你的机器上安装最新版本的Eclipse。

要安装Eclipse IDE，请从https://www.eclipse.org/downloads/下载最新的Eclipse二进制文件。 下载完安装后，将二进制分发包解压到一个方便的位置。 例如，在Windows上的C:\eclipse或Linux/Unix上的/ usr/local/eclipse。 最后，适当地设置PATH变量。

可以通过在Windows机器上执行以下命令来启动Eclipse，或者只需双击eclipse.exe即可。

%C:\eclipse\eclipse.exe

可以通过在Unix（Solaris，Linux等）机器上执行以下命令来启动Eclipse。

$/usr/local/eclipse/eclipse

成功启动后，如果一切正常，则应显示以下结果。

完成最后一步后，您就可以继续学习第一个JDBC示例，您将在下一章中看到它。

Spring JDBC - Configure Data Source

让我们在数据库TEST创建一个数据库表Student 。 我假设您正在使用MySQL数据库，如果您使用任何其他数据库，那么您可以相应地更改您的DDL和SQL查询。

CREATE TABLE Student(
   ID   INT NOT NULL AUTO_INCREMENT,
   NAME VARCHAR(20) NOT NULL,
   AGE  INT NOT NULL,
   PRIMARY KEY (ID)
);

现在我们需要向JDBC模板提供一个DataSource，以便它可以自行配置以获取数据库访问权限。 您可以使用如下所示的代码配置XML文件中的DataSource -

<bean id = "dataSource"
class = "org.springframework.jdbc.datasource.DriverManagerDataSource">
   <property name = "driverClassName" value = "com.mysql.jdbc.Driver"/>
   <property name = "url" value = "jdbc:mysql://localhost:3306/TEST"/>
   <property name = "username" value = "root"/>
   <property name = "password" value = "admin"/>
</bean>

在下一章中，我们将使用配置的数据库编写第一个应用程序。

Spring JDBC - First Application

要了解与JDBC模板类相关的Spring JDBC框架的概念，让我们编写一个简单的示例，它将在以下Student表上实现Insert和Read操作。

CREATE TABLE Student(
   ID   INT NOT NULL AUTO_INCREMENT,
   NAME VARCHAR(20) NOT NULL,
   AGE  INT NOT NULL,
   PRIMARY KEY (ID)
);

让我们继续编写一个简单的基于控制台的Spring JDBC Application，它将演示JDBC概念。

创建项目

让我们打开命令控制台，转到C:\MVN目录并执行以下mvn命令。

C:\MVN>mvn archetype:generate -DgroupId = com.iowiki -DartifactId = Student
   -DarchetypeArtifactId = maven-archetype-quickstart -DinteractiveMode = false

Maven将开始处理并将创建完整的Java应用程序项目结构。

[INFO] Scanning for projects...
[INFO]
[INFO] ------------------------------------------------------------------------
[INFO] Building Maven Stub Project (No POM) 1
[INFO] ------------------------------------------------------------------------
[INFO]
[INFO] >>> maven-archetype-plugin:2.4:generate (default-cli) > generate-sources
@ standalone-pom >>>
[INFO]
[INFO] <<< maven-archetype-plugin:2.4:generate (default-cli) < generate-sources
@ standalone-pom <<<
[INFO]
[INFO] --- maven-archetype-plugin:2.4:generate (default-cli) @ standalone-pom --
-
[INFO] Generating project in Batch mode
Downloading: https://repo.maven.apache.org/maven2/org/apache/maven/archetypes/ma
ven-archetype-quickstart/1.0/maven-archetype-quickstart-1.0.jar
Downloaded: https://repo.maven.apache.org/maven2/org/apache/maven/archetypes/mav
en-archetype-quickstart/1.0/maven-archetype-quickstart-1.0.jar (5 KB at 1.1 KB/s
ec)
Downloading: https://repo.maven.apache.org/maven2/org/apache/maven/archetypes/ma
ven-archetype-quickstart/1.0/maven-archetype-quickstart-1.0.pom
Downloaded: https://repo.maven.apache.org/maven2/org/apache/maven/archetypes/mav
en-archetype-quickstart/1.0/maven-archetype-quickstart-1.0.pom (703 B at 1.2 KB/
sec)
[INFO] -------------------------------------------------------------------------
---
[INFO] Using following parameters for creating project from Old (1.x) Archetype:
 maven-archetype-quickstart:1.0
[INFO] -------------------------------------------------------------------------
---
[INFO] Parameter: groupId, Value: com.iowiki
[INFO] Parameter: packageName, Value: com.iowiki
[INFO] Parameter: package, Value: com.iowiki
[INFO] Parameter: artifactId, Value: Student
[INFO] Parameter: basedir, Value: C:\MVN
[INFO] Parameter: version, Value: 1.0-SNAPSHOT
[INFO] project created from Old (1.x) Archetype in dir: C:\MVN\Student
[INFO] ------------------------------------------------------------------------
[INFO] BUILD SUCCESS
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 01:17 min
[INFO] Finished at: 2017-02-19T21:11:14+05:30
[INFO] Final Memory: 15M/114M
[INFO] ------------------------------------------------------------------------

现在转到C:/ MVN目录。 您将看到一个名为student的Java应用程序项目（在artifactId中指定）。 更新POM.xml以包含Spring JDBC依赖项。 添加Student.java，StudentMapper.java，MainApp.java，StudentDAO.java和StudentJDBCTemplate.java文件。

的pom.xml

<project xmlns = "http://maven.apache.org/POM/4.0.0" 
   xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance"
   xsi:schemaLocation = "http://maven.apache.org/POM/4.0.0 
   http://maven.apache.org/maven-v4_0_0.xsd">
   <modelVersion>4.0.0</modelVersion>
   <groupId>com.iowiki</groupId>
   <artifactId>Student</artifactId>
   <packaging>jar</packaging>
   <version>1.0-SNAPSHOT</version>
   <name>Student</name>
   <url>http://maven.apache.org</url>
   <dependencies>
      <dependency>
         <groupId>junit</groupId>
         <artifactId>junit</artifactId>
         <version>3.8.1</version>
         <scope>test</scope>
      </dependency>
      <dependency>
         <groupId>org.springframework</groupId>
         <artifactId>spring-jdbc</artifactId>
         <version>4.1.0.RELEASE</version>
      </dependency>
      <dependency>
         <groupId>org.springframework</groupId>
         <artifactId>spring-context</artifactId>
         <version>4.1.4.RELEASE</version>
      </dependency>
   </dependencies>
</project>

以下是数据访问对象接口文件StudentDAO.java.

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
public interface StudentDAO {
   /** 
      * This is the method to be used to initialize
      * database resources ie. connection.
   */
   public void setDataSource(DataSource ds);
   /** 
      * This is the method to be used to create
      * a record in the Student table.
   */
   public void create(String name, Integer age);
   public Student getStudent(Integer id);
   /** 
     * This is the method to be used to list down
     * all the records from the Student table.
   */
   public List<Student> listStudents();
}

以下是Student.java文件的内容。

package com.iowiki;
public class Student {
   private Integer age;
   private String name;
   private Integer id;
   public void setAge(Integer age) {
      this.age = age;
   }
   public Integer getAge() {
      return age;
   }
   public void setName(String name) {
      this.name = name;
   }
   public String getName() {
      return name;
   }
   public void setId(Integer id) {
      this.id = id;
   }
   public Integer getId() {
      return id;
   }
}

以下是StudentMapper.java文件的内容。

package com.iowiki;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.springframework.jdbc.core.RowMapper;
public class StudentMapper implements RowMapper<Student> {
   public Student mapRow(ResultSet rs, int rowNum) throws SQLException {
      Student student = new Student();
      student.setId(rs.getInt("id"));
      student.setName(rs.getString("name"));
      student.setAge(rs.getInt("age"));
      return student;
   }
}

以下是定义的DAO接口StudentJDBCTemplate.java的实现类文件StudentJDBCTemplate.java 。

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
import org.springframework.jdbc.core.JdbcTemplate;
public class StudentJDBCTemplate implements StudentDAO {
   private DataSource dataSource;
   private JdbcTemplate jdbcTemplateObject;
   public void setDataSource(DataSource dataSource) {
      this.dataSource = dataSource;
      this.jdbcTemplateObject = new JdbcTemplate(dataSource);
   }
   public void create(String name, Integer age) {
      String SQL = "insert into Student (name, age) values (?, ?)";
      jdbcTemplateObject.update( SQL, name, age);
      System.out.println("Created Record Name = " + name + " Age = " + age);
      return;
   }
   public List<Student> listStudents() {
      String SQL = "select * from Student";
      List <Student> students = jdbcTemplateObject.query(SQL, new StudentMapper());
      return students;
   }
}

以下是MainApp.java文件的内容。

package com.iowiki;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.iowiki.StudentJDBCTemplate;
public class MainApp {
   public static void main(String[] args) {
      ApplicationContext context = new ClassPathXmlApplicationContext("Beans.xml");
      StudentJDBCTemplate studentJDBCTemplate = (StudentJDBCTemplate)
         context.getBean("studentJDBCTemplate");
      System.out.println("------Records Creation--------" );
      studentJDBCTemplate.create("Zara", 11);
      studentJDBCTemplate.create("Nuha", 2);
      studentJDBCTemplate.create("Ayan", 15);
      System.out.println("------Listing Multiple Records--------" );
      List<Student> students = studentJDBCTemplate.listStudents();
      for (Student record : students) {
         System.out.print("ID : " + record.getId() );
         System.out.print(", Name : " + record.getName() );
         System.out.println(", Age : " + record.getAge());
      }  
   }
}

以下是配置文件Beans.xml 。

<?xml version = "1.0" encoding = "UTF-8"?>
<beans xmlns = "http://www.springframework.org/schema/beans"
   xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance" 
   xsi:schemaLocation = "http://www.springframework.org/schema/beans
   http://www.springframework.org/schema/beans/spring-beans-3.0.xsd ">
   <!-- Initialization for data source -->
   <bean id = "dataSource" 
      class = "org.springframework.jdbc.datasource.DriverManagerDataSource">
      <property name = "driverClassName" value = "com.mysql.jdbc.Driver"/>
      <property name = "url" value = "jdbc:mysql://localhost:3306/TEST"/>
      <property name = "username" value = "root"/>
      <property name = "password" value = "admin"/>
   </bean>
   <!-- Definition for studentJDBCTemplate bean -->
   <bean id = "studentJDBCTemplate" 
      class = "com.iowiki.StudentJDBCTemplate">
      <property name = "dataSource" ref = "dataSource" />    
   </bean>
</beans>

完成源和bean配置文件的创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

------Records Creation--------
Created Record Name = Zara Age = 11
Created Record Name = Nuha Age = 2
Created Record Name = Ayan Age = 15
------Listing Multiple Records--------
ID : 1, Name : Zara, Age : 11
ID : 2, Name : Nuha, Age : 2
ID : 3, Name : Ayan, Age : 15

Spring JDBC - Create Query

以下示例将演示如何在Spring JDBC的帮助下使用Insert查询创建查询。 我们将在学生表中插入一些记录。

语法 (Syntax)

String insertQuery = "insert into Student (name, age) values (?, ?)";
jdbcTemplateObject.update( insertQuery, name, age);

Where,

• insertQuery - 插入具有占位符的查询。

• jdbcTemplateObject - 要在数据库中插入学生对象的StudentJDBCTemplate对象。

要理解与Spring JDBC相关的上述概念，让我们编写一个插入查询的示例。 要编写我们的示例，让我们使用一个可用的Eclipse IDE，并使用以下步骤创建一个Spring应用程序。

步	描述
1	更新在Spring JDBC - First Application章节下创建的项目Student 。
2	更新bean配置并运行应用程序，如下所述。

以下是数据访问对象接口文件StudentDAO.java 。

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
public interface StudentDAO {
   /** 
      * This is the method to be used to initialize
      * database resources ie. connection.
   */
   public void setDataSource(DataSource ds);
   /** 
     * This is the method to be used to create
     * a record in the Student table.
   */
   public void create(String name, Integer age);
   /** 
      * This is the method to be used to list down
      * all the records from the Student table.
   */
   public List<Student> listStudents();   
}

以下是Student.java文件的内容。

package com.iowiki;
public class Student {
   private Integer age;
   private String name;
   private Integer id;
   public void setAge(Integer age) {
      this.age = age;
   }
   public Integer getAge() {
      return age;
   }
   public void setName(String name) {
      this.name = name;
   }
   public String getName() {
      return name;
   }
   public void setId(Integer id) {
      this.id = id;
   }
   public Integer getId() {
      return id;
   }
}

以下是StudentMapper.java文件的内容。

package com.iowiki;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.springframework.jdbc.core.RowMapper;
public class StudentMapper implements RowMapper<Student> {
   public Student mapRow(ResultSet rs, int rowNum) throws SQLException {
      Student student = new Student();
      student.setId(rs.getInt("id"));
      student.setName(rs.getString("name"));
      student.setAge(rs.getInt("age"));
      return student;
   }
}

以下是定义的DAO接口StudentJDBCTemplate.java的实现类文件StudentJDBCTemplate.java 。

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
import org.springframework.jdbc.core.JdbcTemplate;
public class StudentJDBCTemplate implements StudentDAO {
   private DataSource dataSource;
   private JdbcTemplate jdbcTemplateObject;
   public void setDataSource(DataSource dataSource) {
      this.dataSource = dataSource;
      this.jdbcTemplateObject = new JdbcTemplate(dataSource);
   }
   public void create(String name, Integer age) {
      String insertQuery = "insert into Student (name, age) values (?, ?)";
      jdbcTemplateObject.update( insertQuery, name, age);
      System.out.println("Created Record Name = " + name + " Age = " + age);
      return;
   }
   public List<Student> listStudents() {
      String SQL = "select * from Student";
      List <Student> students = jdbcTemplateObject.query(SQL, new StudentMapper());
      return students;
   }
}

以下是MainApp.java文件的内容。

package com.iowiki;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.iowiki.StudentJDBCTemplate;
public class MainApp {
   public static void main(String[] args) {
      ApplicationContext context = new ClassPathXmlApplicationContext("Beans.xml");
      StudentJDBCTemplate studentJDBCTemplate = 
         (StudentJDBCTemplate)context.getBean("studentJDBCTemplate");
      System.out.println("------Records Creation--------" );
      studentJDBCTemplate.create("Zara", 11);
      studentJDBCTemplate.create("Nuha", 2);
      studentJDBCTemplate.create("Ayan", 15);
      System.out.println("------Listing Multiple Records--------" );
      List<Student> students = studentJDBCTemplate.listStudents();
      for (Student record : students) {
         System.out.print("ID : " + record.getId() );
         System.out.print(", Name : " + record.getName() );
         System.out.println(", Age : " + record.getAge());
      }  
   }
}

以下是配置文件Beans.xml 。

<?xml version = "1.0" encoding = "UTF-8"?>
<beans xmlns = "http://www.springframework.org/schema/beans"
   xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance" 
   xsi:schemaLocation = "http://www.springframework.org/schema/beans
   http://www.springframework.org/schema/beans/spring-beans-3.0.xsd ">
   <!-- Initialization for data source -->
   <bean id = "dataSource" 
      class = "org.springframework.jdbc.datasource.DriverManagerDataSource">
      <property name = "driverClassName" value = "com.mysql.jdbc.Driver"/>
      <property name = "url" value = "jdbc:mysql://localhost:3306/TEST"/>
      <property name = "username" value = "root"/>
      <property name = "password" value = "admin"/>
   </bean>
   <!-- Definition for studentJDBCTemplate bean -->
   <bean id = "studentJDBCTemplate" 
      class = "com.iowiki.StudentJDBCTemplate">
      <property name = "dataSource" ref = "dataSource" />    
   </bean>
</beans>

完成源和bean配置文件的创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

------Records Creation--------
Created Record Name = Zara Age = 11
Created Record Name = Nuha Age = 2
Created Record Name = Ayan Age = 15
------Listing Multiple Records--------
ID : 1, Name : Zara, Age : 11
ID : 2, Name : Nuha, Age : 2
ID : 3, Name : Ayan, Age : 15

Spring JDBC - Read Query

以下示例将演示如何使用Spring JDBC读取查询。 我们将在学生表中阅读可用记录。

语法 (Syntax)

String selectQuery = "select * from Student";
List <Student> students = jdbcTemplateObject.query(selectQuery, new StudentMapper());

Where,

• selectQuery - 选择查询以阅读学生。

• jdbcTemplateObject - 用于从数据库中读取学生对象的StudentJDBCTemplate对象。

• StudentMapper - StudentMapper是一个RowMapper对象，用于将每个读取的记录映射到学生对象。

要理解与Spring JDBC相关的上述概念，让我们编写一个选择查询的示例。 要编写我们的示例，让我们使用一个可用的Eclipse IDE，并使用以下步骤创建一个Spring应用程序。

步	描述
1	更新在Spring JDBC - First Application章节下创建的项目Student 。
2	更新bean配置并运行应用程序，如下所述。

以下是数据访问对象接口文件StudentDAO.java 。

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
public interface StudentDAO {
   /** 
      * This is the method to be used to initialize
      * database resources ie. connection.
   */
   public void setDataSource(DataSource ds);
   /** 
      * This is the method to be used to list down
      * all the records from the Student table.
   */
   public List<Student> listStudents();   
}

以下是Student.java文件的内容。

package com.iowiki;
public class Student {
   private Integer age;
   private String name;
   private Integer id;
   public void setAge(Integer age) {
      this.age = age;
   }
   public Integer getAge() {
      return age;
   }
   public void setName(String name) {
      this.name = name;
   }
   public String getName() {
      return name;
   }
   public void setId(Integer id) {
      this.id = id;
   }
   public Integer getId() {
      return id;
   }
}

以下是StudentMapper.java文件的内容。

package com.iowiki;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.springframework.jdbc.core.RowMapper;
public class StudentMapper implements RowMapper<Student> {
   public Student mapRow(ResultSet rs, int rowNum) throws SQLException {
      Student student = new Student();
      student.setId(rs.getInt("id"));
      student.setName(rs.getString("name"));
      student.setAge(rs.getInt("age"));
      return student;
   }
}

以下是定义的DAO接口StudentJDBCTemplate.java的实现类文件StudentJDBCTemplate.java 。

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
import org.springframework.jdbc.core.JdbcTemplate;
public class StudentJDBCTemplate implements StudentDAO {
   private DataSource dataSource;
   private JdbcTemplate jdbcTemplateObject;
   public void setDataSource(DataSource dataSource) {
      this.dataSource = dataSource;
      this.jdbcTemplateObject = new JdbcTemplate(dataSource);
   }
   public List<Student> listStudents() {
      String SQL = "select * from Student";
      List <Student> students = jdbcTemplateObject.query(SQL, new StudentMapper());
      return students;
   }
}

以下是MainApp.java文件的内容。

package com.iowiki;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.iowiki.StudentJDBCTemplate;
public class MainApp {
   public static void main(String[] args) {
      ApplicationContext context = new ClassPathXmlApplicationContext("Beans.xml");
      StudentJDBCTemplate studentJDBCTemplate = 
         (StudentJDBCTemplate)context.getBean("studentJDBCTemplate");
      System.out.println("------Listing Multiple Records--------" );
      List<Student> students = studentJDBCTemplate.listStudents();
      for (Student record : students) {
         System.out.print("ID : " + record.getId() );
         System.out.print(", Name : " + record.getName() );
         System.out.println(", Age : " + record.getAge());
      }  
   }
}

以下是配置文件Beans.xml 。

<?xml version = "1.0" encoding = "UTF-8"?>
<beans xmlns = "http://www.springframework.org/schema/beans"
   xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance" 
   xsi:schemaLocation = "http://www.springframework.org/schema/beans
   http://www.springframework.org/schema/beans/spring-beans-3.0.xsd ">
   <!-- Initialization for data source -->
   <bean id = "dataSource" 
      class = "org.springframework.jdbc.datasource.DriverManagerDataSource">
      <property name = "driverClassName" value = "com.mysql.jdbc.Driver"/>
      <property name = "url" value = "jdbc:mysql://localhost:3306/TEST"/>
      <property name = "username" value = "root"/>
      <property name = "password" value = "admin"/>
   </bean>
   <!-- Definition for studentJDBCTemplate bean -->
   <bean id="studentJDBCTemplate" 
      class = "com.iowiki.StudentJDBCTemplate">
      <property name = "dataSource" ref = "dataSource" />    
   </bean>
</beans>

完成源和bean配置文件的创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

------Listing Multiple Records--------
ID : 1, Name : Zara, Age : 11
ID : 2, Name : Nuha, Age : 2
ID : 3, Name : Ayan, Age : 15

Spring JDBC - Update Query

以下示例将演示如何使用Spring JDBC更新查询。 我们将更新学生表中的可用记录。

语法 (Syntax)

String updateQuery = "update Student set age = ? where id = ?";
jdbcTemplateObject.update(updateQuery, age, id);

Where,

• updateQuery - 更新查询以使用占位符更新学生。

• jdbcTemplateObject - 用于更新数据库中student对象的StudentJDBCTemplate对象。

为了理解与Spring JDBC相关的上述概念，让我们编写一个更新查询的示例。 要编写我们的示例，让我们使用一个可用的Eclipse IDE，并使用以下步骤创建一个Spring应用程序。

步	描述
1	更新在Spring JDBC - First Application章节下创建的项目Student 。
2	更新bean配置并运行应用程序，如下所述。

以下是数据访问对象接口文件StudentDAO.java 。

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
public interface StudentDAO {
   /** 
      * This is the method to be used to initialize
      * database resources ie. connection.
   */
   public void setDataSource(DataSource ds);
   /** 
      * This is the method to be used to update
      * a record into the Student table.
   */
   public void update(Integer id, Integer age);
   /** 
      * This is the method to be used to list down
      * a record from the Student table corresponding
      * to a passed student id.
   */
   public Student getStudent(Integer id);   
}

以下是Student.java文件的内容。

package com.iowiki;
public class Student {
   private Integer age;
   private String name;
   private Integer id;
   public void setAge(Integer age) {
      this.age = age;
   }
   public Integer getAge() {
      return age;
   }
   public void setName(String name) {
      this.name = name;
   }
   public String getName() {
      return name;
   }
   public void setId(Integer id) {
      this.id = id;
   }
   public Integer getId() {
      return id;
   }
}

以下是StudentMapper.java文件的内容。

package com.iowiki;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.springframework.jdbc.core.RowMapper;
public class StudentMapper implements RowMapper<Student> {
   public Student mapRow(ResultSet rs, int rowNum) throws SQLException {
      Student student = new Student();
      student.setId(rs.getInt("id"));
      student.setName(rs.getString("name"));
      student.setAge(rs.getInt("age"));
      return student;
   }
}

以下是定义的DAO接口StudentJDBCTemplate.java的实现类文件StudentJDBCTemplate.java 。

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
import org.springframework.jdbc.core.JdbcTemplate;
public class StudentJDBCTemplate implements StudentDAO {
   private DataSource dataSource;
   private JdbcTemplate jdbcTemplateObject;
   public void setDataSource(DataSource dataSource) {
      this.dataSource = dataSource;
      this.jdbcTemplateObject = new JdbcTemplate(dataSource);
   }
   public void update(Integer id, Integer age){
      String SQL = "update Student set age = ? where id = ?";
      jdbcTemplateObject.update(SQL, age, id);
      System.out.println("Updated Record with ID = " + id );
      return;
   }
   public Student getStudent(Integer id) {
      String SQL = "select * from Student where id = ?";
      Student student = jdbcTemplateObject.queryForObject(
         SQL, new Object[]{id}, new StudentMapper());
      return student;
   }
}

以下是MainApp.java文件的内容。

package com.iowiki;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.iowiki.StudentJDBCTemplate;
public class MainApp {
   public static void main(String[] args) {
      ApplicationContext context = new ClassPathXmlApplicationContext("Beans.xml");
      StudentJDBCTemplate studentJDBCTemplate = 
         (StudentJDBCTemplate)context.getBean("studentJDBCTemplate");
      System.out.println("----Updating Record with ID = 2 -----" );
      studentJDBCTemplate.update(2, 20);
      System.out.println("----Listing Record with ID = 2 -----" );
      Student student = studentJDBCTemplate.getStudent(2);
      System.out.print("ID : " + student.getId() );
      System.out.print(", Name : " + student.getName() );
      System.out.println(", Age : " + student.getAge());  
   }
}

以下是配置文件Beans.xml 。

<?xml version = "1.0" encoding = "UTF-8"?>
<beans xmlns = "http://www.springframework.org/schema/beans"
   xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance" 
   xsi:schemaLocation = "http://www.springframework.org/schema/beans
   http://www.springframework.org/schema/beans/spring-beans-3.0.xsd ">
   <!-- Initialization for data source -->
   <bean id = "dataSource" 
      class = "org.springframework.jdbc.datasource.DriverManagerDataSource">
      <property name = "driverClassName" value = "com.mysql.jdbc.Driver"/>
      <property name = "url" value = "jdbc:mysql://localhost:3306/TEST"/>
      <property name = "username" value = "root"/>
      <property name = "password" value = "admin"/>
   </bean>
   <!-- Definition for studentJDBCTemplate bean -->
   <bean id = "studentJDBCTemplate" 
      class = "com.iowiki.StudentJDBCTemplate">
      <property name = "dataSource" ref = "dataSource" />    
   </bean>
</beans>

完成源和bean配置文件的创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

----Updating Record with ID = 2 -----
Updated Record with ID = 2
----Listing Record with ID = 2 -----
ID : 2, Name : Nuha, Age : 20

Spring JDBC - Delete Query

以下示例将演示如何使用Spring JDBC删除查询。 我们将删除学生表中的一个可用记录。

语法 (Syntax)

String deleteQuery = "delete from Student where id = ?";
jdbcTemplateObject.update(deleteQuery, id);

Where,

• deleteQuery - 删除查询以删除带占位符的学生。

• jdbcTemplateObject - 用于删除数据库中学生对象的StudentJDBCTemplate对象。

要理解与Spring JDBC相关的上述概念，让我们编写一个删除查询的示例。 要编写我们的示例，让我们使用一个可用的Eclipse IDE，并使用以下步骤创建一个Spring应用程序。

步	描述
1	更新在Spring JDBC - First Application章节下创建的项目Student 。
2	更新bean配置并运行应用程序，如下所述。

以下是数据访问对象接口文件StudentDAO.java 。

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
public interface StudentDAO {
   /** 
      * This is the method to be used to initialize
      * database resources ie. connection.
   */
   public void setDataSource(DataSource ds);
   /** 
      * This is the method to be used to list down
      * all the records from the Student table.
   */
   public List<Student> listStudents();
   /** 
      * This is the method to be used to delete
      * a record from the Student table corresponding
      * to a passed student id.
   */
   public void delete(Integer id); 
}

以下是Student.java文件的内容。

package com.iowiki;
public class Student {
   private Integer age;
   private String name;
   private Integer id;
   public void setAge(Integer age) {
      this.age = age;
   }
   public Integer getAge() {
      return age;
   }
   public void setName(String name) {
      this.name = name;
   }
   public String getName() {
      return name;
   }
   public void setId(Integer id) {
      this.id = id;
   }
   public Integer getId() {
      return id;
   }
}

以下是StudentMapper.java文件的内容。

package com.iowiki;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.springframework.jdbc.core.RowMapper;
public class StudentMapper implements RowMapper<Student> {
   public Student mapRow(ResultSet rs, int rowNum) throws SQLException {
      Student student = new Student();
      student.setId(rs.getInt("id"));
      student.setName(rs.getString("name"));
      student.setAge(rs.getInt("age"));
      return student;
   }
}

以下是定义的DAO接口StudentJDBCTemplate.java的实现类文件StudentJDBCTemplate.java 。

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
import org.springframework.jdbc.core.JdbcTemplate;
public class StudentJDBCTemplate implements StudentDAO {
   private DataSource dataSource;
   private JdbcTemplate jdbcTemplateObject;
   public void setDataSource(DataSource dataSource) {
      this.dataSource = dataSource;
      this.jdbcTemplateObject = new JdbcTemplate(dataSource);
   }
   public List<Student> listStudents() {
      String SQL = "select * from Student";
      List <Student> students = jdbcTemplateObject.query(SQL, new StudentMapper());
      return students;
   }
   public void delete(Integer id){
      String SQL = "delete from Student where id = ?";
      jdbcTemplateObject.update(SQL, id);
      System.out.println("Deleted Record with ID = " + id );
      return;
   }
}

以下是MainApp.java文件的内容。

package com.iowiki;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.iowiki.StudentJDBCTemplate;
public class MainApp {
   public static void main(String[] args) {
      ApplicationContext context = new ClassPathXmlApplicationContext("Beans.xml");
      StudentJDBCTemplate studentJDBCTemplate = 
         (StudentJDBCTemplate)context.getBean("studentJDBCTemplate");
      System.out.println("----Delete Record with ID = 2 -----" );
      studentJDBCTemplate.delete(2);
      System.out.println("------Listing Multiple Records--------" );
      List<Student> students = studentJDBCTemplate.listStudents();
      for (Student record : students) {
         System.out.print("ID : " + record.getId() );
         System.out.print(", Name : " + record.getName() );
         System.out.println(", Age : " + record.getAge());
      }     
   }
}

以下是配置文件Beans.xml 。

<?xml version = "1.0" encoding = "UTF-8"?>
<beans xmlns = "http://www.springframework.org/schema/beans"
   xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance" 
   xsi:schemaLocation = "http://www.springframework.org/schema/beans
   http://www.springframework.org/schema/beans/spring-beans-3.0.xsd ">
   <!-- Initialization for data source -->
   <bean id = "dataSource" 
      class = "org.springframework.jdbc.datasource.DriverManagerDataSource">
      <property name = "driverClassName" value = "com.mysql.jdbc.Driver"/>
      <property name = "url" value = "jdbc:mysql://localhost:3306/TEST"/>
      <property name = "username" value = "root"/>
      <property name = "password" value = "admin"/>
   </bean>
   <!-- Definition for studentJDBCTemplate bean -->
   <bean id = "studentJDBCTemplate" 
      class = "com.iowiki.StudentJDBCTemplate">
      <property name = "dataSource"  ref = "dataSource" />    
   </bean>
</beans>

完成源和bean配置文件的创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

----Updating Record with ID = 2 -----
Updated Record with ID = 2
----Listing Record with ID = 2 -----
ID : 2, Name : Nuha, Age : 20

Spring JDBC - Calling Stored Procedure

下面的示例将演示如何使用Spring JDBC调用存储过程。 我们将通过调用存储过程来读取学生表中的一个可用记录。 我们将通过身份证并收到学生记录。

语法 (Syntax)

SimpleJdbcCall jdbcCall = new SimpleJdbcCall(dataSource).withProcedureName("getRecord");
SqlParameterSource in = new MapSqlParameterSource().addValue("in_id", id);
Map<String, Object> out = jdbcCall.execute(in);
Student student = new Student();
student.setId(id);
student.setName((String) out.get("out_name"));
student.setAge((Integer) out.get("out_age"));

Where,

• jdbcCall - 表示存储过程的SimpleJdbcCall对象。

• in - SqlParameterSource对象，用于将参数传递给存储过程。

• student - 学生对象。

• out - 映射对象以表示存储过程调用结果的输出。

SimpleJdbcCall类可用于使用IN和OUT参数调用存储过程。 您可以在使用任何RDBMS（如Apache Derby，DB2，MySQL，Microsoft SQL Server，Oracle和Sybase）时使用此方法。

要了解该方法，请考虑以下MySQL存储过程，该过程接受学生ID并使用OUT参数返回相应学生的姓名和年龄。 让我们使用MySQL命令提示符在TEST数据库中创建此存储过程 -

DELIMITER $$
DROP PROCEDURE IF EXISTS `TEST`.`getRecord` $$
CREATE PROCEDURE `TEST`.`getRecord` (
IN in_id INTEGER,
OUT out_name VARCHAR(20),
OUT out_age  INTEGER)
BEGIN
   SELECT name, age
   INTO out_name, out_age
   FROM Student where id = in_id;
END $$
DELIMITER ;

为了理解与Spring JDBC相关的上述概念，让我们编写一个调用存储过程的示例。 要编写我们的示例，让我们使用一个可用的Eclipse IDE，并使用以下步骤创建一个Spring应用程序。

步	描述
1	更新在Spring JDBC - First Application章节下创建的项目Student 。
2	更新bean配置并运行应用程序，如下所述。

以下是数据访问对象接口文件StudentDAO.java 。

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
public interface StudentDAO {
   /** 
      * This is the method to be used to initialize
      * database resources ie. connection.
   */
   public void setDataSource(DataSource ds);
   /** 
      * This is the method to be used to list down
      * a record from the Student table corresponding
      * to a passed student id.
   */
   public Student getStudent(Integer id);  
}

以下是Student.java文件的内容。

package com.iowiki;
public class Student {
   private Integer age;
   private String name;
   private Integer id;
   public void setAge(Integer age) {
      this.age = age;
   }
   public Integer getAge() {
      return age;
   }
   public void setName(String name) {
      this.name = name;
   }
   public String getName() {
      return name;
   }
   public void setId(Integer id) {
      this.id = id;
   }
   public Integer getId() {
      return id;
   }
}

以下是StudentMapper.java文件的内容。

package com.iowiki;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.springframework.jdbc.core.RowMapper;
public class StudentMapper implements RowMapper<Student> {
   public Student mapRow(ResultSet rs, int rowNum) throws SQLException {
      Student student = new Student();
      student.setId(rs.getInt("id"));
      student.setName(rs.getString("name"));
      student.setAge(rs.getInt("age"));
      return student;
   }
}

以下是定义的DAO接口StudentJDBCTemplate.java的实现类文件StudentJDBCTemplate.java 。

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;
import org.springframework.jdbc.core.namedparam.SqlParameterSource;
import org.springframework.jdbc.core.simple.SimpleJdbcCall;
public class StudentJDBCTemplate implements StudentDAO {
   private DataSource dataSource;
   private JdbcTemplate jdbcTemplateObject;
   public void setDataSource(DataSource dataSource) {
      this.dataSource = dataSource;
      this.jdbcTemplateObject = new JdbcTemplate(dataSource);
   }
   public Student getStudent(Integer id) {
      SimpleJdbcCall jdbcCall = new 
         SimpleJdbcCall(dataSource).withProcedureName("getRecord");
      SqlParameterSource in = new MapSqlParameterSource().addValue("in_id", id);
      Map<String, Object> out = jdbcCall.execute(in);
      Student student = new Student();
      student.setId(id);
      student.setName((String) out.get("out_name"));
      student.setAge((Integer) out.get("out_age"));
      return student;      
   }
}

为执行调用而编写的代码涉及创建包含IN参数的SqlParameterSource。 将为输入值提供的名称与存储过程中声明的参数名称的名称相匹配非常重要。 execute方法接受IN参数并返回一个Map，该Map包含由存储过程中指定的名称键入的任何out参数。

以下是MainApp.java文件的内容。

package com.iowiki;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.iowiki.StudentJDBCTemplate;
public class MainApp {
   public static void main(String[] args) {
      ApplicationContext context = new ClassPathXmlApplicationContext("Beans.xml");
      StudentJDBCTemplate studentJDBCTemplate = 
         (StudentJDBCTemplate)context.getBean("studentJDBCTemplate");
      Student student = studentJDBCTemplate.getStudent(1);
      System.out.print("ID : " + student.getId() );
      System.out.print(", Name : " + student.getName() );
      System.out.println(", Age : " + student.getAge()); 
   }
}

以下是配置文件Beans.xml 。

<?xml version = "1.0" encoding = "UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
   xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance" 
   xsi:schemaLocation = "http://www.springframework.org/schema/beans
   http://www.springframework.org/schema/beans/spring-beans-3.0.xsd ">
   <!-- Initialization for data source -->
   <bean id = "dataSource" 
      class = "org.springframework.jdbc.datasource.DriverManagerDataSource">
      <property name = "driverClassName" value = "com.mysql.jdbc.Driver"/>
      <property name = "url" value = "jdbc:mysql://localhost:3306/TEST"/>
      <property name = "username" value = "root"/>
      <property name = "password" value = "admin"/>
   </bean>
   <!-- Definition for studentJDBCTemplate bean -->
   <bean id = "studentJDBCTemplate" 
      class = "com.iowiki.StudentJDBCTemplate">
      <property name = "dataSource" ref = "dataSource" />    
   </bean>
</beans>

完成源和bean配置文件的创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

ID : 1, Name : Zara, Age : 11

Spring JDBC - Calling Stored Function

下面的示例将演示如何使用Spring JDBC调用存储的函数。 我们将通过调用存储函数来读取学生表中的一个可用记录。 我们将通过身份证并获得学生姓名。

语法 (Syntax)

SimpleJdbcCall jdbcCall = new 
   SimpleJdbcCall(dataSource).withFunctionName("get_student_name");
SqlParameterSource in = new MapSqlParameterSource().addValue("in_id", id);
String name = jdbcCall.executeFunction(String.class, in);
Student student = new Student();
student.setId(id);
student.setName(name);

Where,

• in - SqlParameterSource对象将参数传递给存储的函数。

• jdbcCall - 表示存储函数的SimpleJdbcCall对象。

• jdbcTemplateObject - 从数据库调用存储函数的StudentJDBCTemplate对象。

• student - 学生对象。

SimpleJdbcCall类可用于使用IN参数和返回值调用存储的函数。 您可以在使用任何RDBMS（如Apache Derby，DB2，MySQL，Microsoft SQL Server，Oracle和Sybase）时使用此方法。

要了解该方法，请考虑以下MySQL存储过程，该过程接受学生ID并返回相应学生的姓名。 因此，让我们使用MySQL命令提示符在您的TEST数据库中创建此存储函数 -

DELIMITER $$
DROP FUNCTION IF EXISTS `TEST`.`get_student_name` $$
CREATE FUNCTION `get_student_name` (in_id INTEGER)
RETURNS varchar(200)
BEGIN
DECLARE out_name VARCHAR(200);
   SELECT name
   INTO out_name
   FROM Student where id = in_id;
RETURN out_name;
DELIMITER ;

为了理解与Spring JDBC相关的上述概念，让我们编写一个调用存储函数的示例。 要编写我们的示例，让我们使用一个可用的Eclipse IDE，并使用以下步骤创建一个Spring应用程序。

步	描述
1	更新在Spring JDBC - First Application章节下创建的项目Student 。
2	更新bean配置并运行应用程序，如下所述。

以下是数据访问对象接口文件StudentDAO.java 。

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
public interface StudentDAO {
   /** 
      * This is the method to be used to initialize
      * database resources ie. connection.
   */
   public void setDataSource(DataSource ds);
   /** 
      * This is the method to be used to list down
      * a record from the Student table corresponding
      * to a passed student id.
   */
   public Student getStudent(Integer id);  
}

以下是Student.java文件的内容。

package com.iowiki;
public class Student {
   private Integer age;
   private String name;
   private Integer id;
   public void setAge(Integer age) {
      this.age = age;
   }
   public Integer getAge() {
      return age;
   }
   public void setName(String name) {
      this.name = name;
   }
   public String getName() {
      return name;
   }
   public void setId(Integer id) {
      this.id = id;
   }
   public Integer getId() {
      return id;
   }
}

以下是StudentMapper.java文件的内容。

package com.iowiki;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.springframework.jdbc.core.RowMapper;
public class StudentMapper implements RowMapper<Student> {
   public Student mapRow(ResultSet rs, int rowNum) throws SQLException {
      Student student = new Student();
      student.setId(rs.getInt("id"));
      student.setName(rs.getString("name"));
      student.setAge(rs.getInt("age"));
      return student;
   }
}

以下是定义的DAO接口StudentJDBCTemplate.java的实现类文件StudentJDBCTemplate.java 。

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;
import org.springframework.jdbc.core.namedparam.SqlParameterSource;
import org.springframework.jdbc.core.simple.SimpleJdbcCall;
public class StudentJDBCTemplate implements StudentDAO {
   private DataSource dataSource;
   private JdbcTemplate jdbcTemplateObject;
   public void setDataSource(DataSource dataSource) {
      this.dataSource = dataSource;
      this.jdbcTemplateObject = new JdbcTemplate(dataSource);
   }
   public Student getStudent(Integer id) {
      SimpleJdbcCall jdbcCall = new 
         SimpleJdbcCall(dataSource).withFunctionName("get_student_name");
      SqlParameterSource in = new MapSqlParameterSource().addValue("in_id", id);
      String name = jdbcCall.executeFunction(String.class, in);
      Student student = new Student();
      student.setId(id);
      student.setName(name);
      return student;      
   }
}

为执行调用而编写的代码涉及创建包含IN参数的SqlParameterSource。 将为输入值提供的名称与存储函数中声明的参数名称的名称相匹配非常重要。 executeFunction方法接受IN参数并返回存储函数中指定的String。

以下是MainApp.java文件的内容

package com.iowiki;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.iowiki.StudentJDBCTemplate;
public class MainApp {
   public static void main(String[] args) {
      ApplicationContext context = new ClassPathXmlApplicationContext("Beans.xml");
      StudentJDBCTemplate studentJDBCTemplate = 
         (StudentJDBCTemplate)context.getBean("studentJDBCTemplate");
      Student student = studentJDBCTemplate.getStudent(1);
      System.out.print("ID : " + student.getId() );
      System.out.print(", Name : " + student.getName() );
   }
}

以下是配置文件Beans.xml 。

<?xml version = "1.0" encoding = "UTF-8"?>
<beans xmlns = "http://www.springframework.org/schema/beans"
   xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance" 
   xsi:schemaLocation = "http://www.springframework.org/schema/beans
   http://www.springframework.org/schema/beans/spring-beans-3.0.xsd ">
   <!-- Initialization for data source -->
   <bean id = "dataSource" 
      class = "org.springframework.jdbc.datasource.DriverManagerDataSource">
      <property name = "driverClassName" value = "com.mysql.jdbc.Driver"/>
      <property name = "url" value = "jdbc:mysql://localhost:3306/TEST"/>
      <property name = "username" value = "root"/>
      <property name = "password" value = "admin"/>
   </bean>
   <!-- Definition for studentJDBCTemplate bean -->
   <bean id = "studentJDBCTemplate" 
      class = "com.iowiki.StudentJDBCTemplate">
      <property name = "dataSource" ref = "dataSource" />    
   </bean>
</beans>

完成源和bean配置文件的创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

ID : 1, Name : Zara

Spring JDBC - Handling BLOB

下面的示例将演示如何在Spring JDBC的帮助下使用Update Query更新BLOB。 我们将更新学生表中的可用记录。

学生表

CREATE TABLE Student(
   ID INT NOT NULL AUTO_INCREMENT,
   NAME VARCHAR(20) NOT NULL,
   AGE INT NOT NULL,
   IMAGE BLOB,
   PRIMARY KEY (ID)
);

语法 (Syntax)

MapSqlParameterSource in = new MapSqlParameterSource();
in.addValue("id", id);
in.addValue("image",  new SqlLobValue(new ByteArrayInputStream(imageData), 
   imageData.length, new DefaultLobHandler()), Types.BLOB);
String SQL = "update Student set image = :image where id = :id";
NamedParameterJdbcTemplate jdbcTemplateObject = new NamedParameterJdbcTemplate(dataSource);
jdbcTemplateObject.update(SQL, in);

Where,

• in - SqlParameterSource对象，用于传递参数以更新查询。

• SqlLobValue - 表示SQL BLOB/CLOB值参数的对象。

• jdbcTemplateObject - 用于更新数据库中学生对象的NamedParameterJdbcTemplate对象。

为了理解与Spring JDBC相关的上述概念，让我们编写一个更新查询的示例。 要编写我们的示例，让我们使用一个可用的Eclipse IDE，并使用以下步骤创建一个Spring应用程序。

步	描述
1	更新在Spring JDBC - First Application章节下创建的项目Student 。
2	更新bean配置并运行应用程序，如下所述。

以下是数据访问对象接口文件StudentDAO.java 。

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
public interface StudentDAO {
   /** 
      * This is the method to be used to initialize
      * database resources ie. connection.
   */
   public void setDataSource(DataSource ds);
   /** 
      * This is the method to be used to update
      * a record into the Student table.
   */
   public void updateImage(Integer id, byte[] imageData);
}

以下是Student.java文件的内容。

package com.iowiki;
public class Student {
   private Integer age;
   private String name;
   private Integer id;
   private byte[] image;
   public void setAge(Integer age) {
      this.age = age;
   }
   public Integer getAge() {
      return age;
   }
   public void setName(String name) {
      this.name = name;
   }
   public String getName() {
      return name;
   }
   public void setId(Integer id) {
      this.id = id;
   }
   public Integer getId() {
      return id;
   }
   public byte[] getImage() {
      return image;
   }
   public void setImage(byte[] image) {
      this.image = image;
   }
}

以下是Student.java文件的内容。

package com.iowiki;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.springframework.jdbc.core.RowMapper;
public class StudentMapper implements RowMapper<Student> {
   public Student mapRow(ResultSet rs, int rowNum) throws SQLException {
      Student student = new Student();
      student.setId(rs.getInt("id"));
      student.setName(rs.getString("name"));
      student.setAge(rs.getInt("age"));
      student.setImage(rs.getBytes("image"));
      return student;
   }
}

以下是定义的DAO接口StudentJDBCTemplate.java的实现类文件StudentJDBCTemplate.java 。

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;
import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
import org.springframework.jdbc.core.namedparam.SqlParameterSource;
import org.springframework.jdbc.core.simple.SimpleJdbcCall;
import org.springframework.jdbc.core.support.SqlLobValue;
import org.springframework.jdbc.support.lob.DefaultLobHandler;
import java.io.ByteArrayInputStream;
import java.sql.Types;
public class StudentJDBCTemplate implements StudentDAO {
   private DataSource dataSource;
   private JdbcTemplate jdbcTemplateObject;
   public void setDataSource(DataSource dataSource) {
      this.dataSource = dataSource;
   }
   public void updateImage(Integer id, byte[] imageData) {
      MapSqlParameterSource in = new MapSqlParameterSource();
      in.addValue("id", id);
      in.addValue("image",  new SqlLobValue(new ByteArrayInputStream(imageData), 
         imageData.length, new DefaultLobHandler()), Types.BLOB);
      String SQL = "update Student set image = :image where id = :id";
      NamedParameterJdbcTemplate jdbcTemplateObject = new 
         NamedParameterJdbcTemplate(dataSource);
      jdbcTemplateObject.update(SQL, in);
      System.out.println("Updated Record with ID = " + id );
   }
}

以下是MainApp.java文件的内容。

package com.iowiki;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.iowiki.StudentJDBCTemplate;
public class MainApp {
   public static void main(String[] args) {
      ApplicationContext context = new ClassPathXmlApplicationContext("Beans.xml");
      StudentJDBCTemplate studentJDBCTemplate = 
         (StudentJDBCTemplate)context.getBean("studentJDBCTemplate");
      byte[] imageData = {0,1,0,8,20,40,95};
      studentJDBCTemplate.updateImage(1, imageData);  
   }
}

以下是配置文件Beans.xml 。

<?xml version = "1.0" encoding = "UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
   xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance" 
   xsi:schemaLocation = "http://www.springframework.org/schema/beans
   http://www.springframework.org/schema/beans/spring-beans-3.0.xsd ">
   <!-- Initialization for data source -->
   <bean id = "dataSource" 
      class = "org.springframework.jdbc.datasource.DriverManagerDataSource">
      <property name = "driverClassName" value = "com.mysql.jdbc.Driver"/>
      <property name = "url" value = "jdbc:mysql://localhost:3306/TEST"/>
      <property name = "username" value = "root"/>
      <property name = "password" value = "admin"/>
   </bean>
   <!-- Definition for studentJDBCTemplate bean -->
   <bean id = "studentJDBCTemplate" 
      class = "com.iowiki.StudentJDBCTemplate">
      <property name = "dataSource" ref = "dataSource" />    
   </bean>
</beans>

完成源和bean配置文件的创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

Updated Record with ID = 1

您可以通过查询数据库来检查存储的byte []。

Spring JDBC - Handling CLOB

下面的示例将演示如何在Spring JDBC的帮助下使用Update Query更新CLOB。 我们将更新学生表中的可用记录。

学生表

CREATE TABLE Student(
   ID   INT NOT NULL AUTO_INCREMENT,
   NAME VARCHAR(20) NOT NULL,
   AGE  INT NOT NULL,
   DESCRIPTION LONGTEXT,
   PRIMARY KEY (ID)
);

语法 (Syntax)

MapSqlParameterSource in = new MapSqlParameterSource();
in.addValue("id", id);
in.addValue("description",  new SqlLobValue(
   description, new DefaultLobHandler()), Types.CLOB);
String SQL = "update Student set description = :description where id = :id";
NamedParameterJdbcTemplate jdbcTemplateObject = new NamedParameterJdbcTemplate(dataSource);
jdbcTemplateObject.update(SQL, in);

Where,

• in - SqlParameterSource对象，用于传递参数以更新查询。

• SqlLobValue - 表示SQL BLOB/CLOB值参数的对象。

• jdbcTemplateObject - NamedParameterJdbcTemplate对象，用于更新数据库中的student对象。

为了理解与Spring JDBC相关的上述概念，让我们编写一个示例，它将更新查询。 要编写我们的示例，让我们使用一个可用的Eclipse IDE，并使用以下步骤创建一个Spring应用程序。

步	描述
1	更新在Spring JDBC - First Application章节下创建的项目Student 。
2	更新bean配置并运行应用程序，如下所述。

以下是数据访问对象接口文件StudentDAO.java 。

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
public interface StudentDAO {
   /** 
      * This is the method to be used to initialize
      * database resources ie. connection.
   */
   public void setDataSource(DataSource ds);
   /** 
      * This is the method to be used to update
      * a record into the Student table.
   */
   public void updateDescription(Integer id, String description);
}

以下是Student.java文件的内容。

package com.iowiki;
public class Student {
   private Integer age;
   private String name;
   private Integer id;
   private String description;
   public void setAge(Integer age) {
      this.age = age;
   }
   public Integer getAge() {
      return age;
   }
   public void setName(String name) {
      this.name = name;
   }
   public String getName() {
      return name;
   }
   public void setId(Integer id) {
      this.id = id;
   }
   public Integer getId() {
      return id;
   }
   public String getDescription() {
      return description;
   }
   public void setDescription(String description) {
      this.description = description;
   }
}

以下是StudentMapper.java文件的内容。

package com.iowiki;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.springframework.jdbc.core.RowMapper;
public class StudentMapper implements RowMapper<Student> {
   public Student mapRow(ResultSet rs, int rowNum) throws SQLException {
      Student student = new Student();
      student.setId(rs.getInt("id"));
      student.setName(rs.getString("name"));
      student.setAge(rs.getInt("age"));
      student.setDescription(rs.getString("description"));
      return student;
   }
}

以下是定义的DAO接口StudentJDBCTemplate.java的实现类文件StudentJDBCTemplate.java 。

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;
import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
import org.springframework.jdbc.core.namedparam.SqlParameterSource;
import org.springframework.jdbc.core.simple.SimpleJdbcCall;
import org.springframework.jdbc.core.support.SqlLobValue;
import org.springframework.jdbc.support.lob.DefaultLobHandler;
import java.io.ByteArrayInputStream;
import java.sql.Types;
public class StudentJDBCTemplate implements StudentDAO {
   private DataSource dataSource;
   private JdbcTemplate jdbcTemplateObject;
   public void setDataSource(DataSource dataSource) {
      this.dataSource = dataSource;
   }
   public void updateDescription(Integer id, String description) {
      MapSqlParameterSource in = new MapSqlParameterSource();
      in.addValue("id", id);
      in.addValue("description",  new SqlLobValue(description, 
         new DefaultLobHandler()), Types.CLOB);
      String SQL = "update Student set description = :description where id = :id";
      NamedParameterJdbcTemplate jdbcTemplateObject = new 
         NamedParameterJdbcTemplate(dataSource);
      jdbcTemplateObject.update(SQL, in);
      System.out.println("Updated Record with ID = " + id );
   }
}

以下是MainApp.java文件的内容。

package com.iowiki;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.iowiki.StudentJDBCTemplate;
public class MainApp {
   public static void main(String[] args) {
      ApplicationContext context = new ClassPathXmlApplicationContext("Beans.xml");
      StudentJDBCTemplate studentJDBCTemplate = 
         (StudentJDBCTemplate)context.getBean("studentJDBCTemplate");
      studentJDBCTemplate.updateDescription(1, 
         "This can be a very long text upto 4 GB of size."); 
   }
}

以下是配置文件Beans.xml 。

<?xml version = "1.0" encoding = "UTF-8"?>
<beans xmlns = "http://www.springframework.org/schema/beans"
   xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance" 
   xsi:schemaLocation = "http://www.springframework.org/schema/beans
   http://www.springframework.org/schema/beans/spring-beans-3.0.xsd ">
   <!-- Initialization for data source -->
   <bean id = "dataSource" 
      class = "org.springframework.jdbc.datasource.DriverManagerDataSource">
      <property name = "driverClassName" value = "com.mysql.jdbc.Driver"/>
      <property name = "url" value = "jdbc:mysql://localhost:3306/TEST"/>
      <property name = "username" value = "root"/>
      <property name = "password" value = "admin"/>
   </bean>
   <!-- Definition for studentJDBCTemplate bean -->
   <bean id = "studentJDBCTemplate" 
      class = "com.iowiki.StudentJDBCTemplate">
      <property name = "dataSource" ref = "dataSource" />    
   </bean>
</beans>

完成源和bean配置文件的创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

Updated Record with ID = 1

您可以通过查询数据库来检查存储的描述。

Spring JDBC - Batch Operation

以下示例将演示如何使用Spring JDBC进行批量更新。 我们将在单个批处理操作中更新Student表中的可用记录。

语法 (Syntax)

String SQL = "update Student set age = ? where id = ?";
int[] updateCounts = jdbcTemplateObject.batchUpdate(SQL,
   new BatchPreparedStatementSetter() {
   public void setValues(PreparedStatement ps, int i) throws SQLException {
      ps.setInt(1, students.get(i).getAge());						
      ps.setInt(2, students.get(i).getId());	
   }
   public int getBatchSize() {
      return students.size();
   }
}); 

Where,

• SQL - 更新查询以更新学生的年龄。

• jdbcTemplateObject - 用于更新数据库中学生对象的StudentJDBCTemplate对象。

• BatchPreparedStatementSetter - 批处理执行程序，在每个项目的PerparedStatement中设置值，由对象student和index i列表标识。 getBatchSize（）返回批处理的大小。

• updateCounts - 包含每个更新查询的更新行数的Int数组。

为了理解与Spring JDBC相关的上述概念，让我们编写一个更新批处理操作的示例。 要编写我们的示例，让我们使用一个可用的Eclipse IDE，并使用以下步骤创建一个Spring应用程序。

步	描述
1	更新在Spring JDBC - First Application章节下创建的项目Student 。
2	更新bean配置并运行应用程序，如下所述。

以下是数据访问对象接口文件StudentDAO.java 。

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
public interface StudentDAO {
   /** 
      * This is the method to be used to initialize
      * database resources ie. connection.
   */
   public void setDataSource(DataSource ds);
   /** 
      * This is the method to be used to list down
      * all the records from the Student table.
   */
   public List<Student> listStudents();  
   public void batchUpdate(final List<Student> students);
}

以下是Student.java文件的内容。

package com.iowiki;
public class Student {
   private Integer age;
   private String name;
   private Integer id;
   public void setAge(Integer age) {
      this.age = age;
   }
   public Integer getAge() {
      return age;
   }
   public void setName(String name) {
      this.name = name;
   }
   public String getName() {
      return name;
   }
   public void setId(Integer id) {
      this.id = id;
   }
   public Integer getId() {
      return id;
   }
}

以下是StudentMapper.java文件的内容。

package com.iowiki;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.springframework.jdbc.core.RowMapper;
public class StudentMapper implements RowMapper<Student> {
   public Student mapRow(ResultSet rs, int rowNum) throws SQLException {
      Student student = new Student();
      student.setId(rs.getInt("id"));
      student.setName(rs.getString("name"));
      student.setAge(rs.getInt("age"));
      return student;
   }
}

以下是定义的DAO接口StudentJDBCTemplate.java的实现类文件StudentJDBCTemplate.java 。

package com.iowiki;
import java.sql.PreparedStatement;
import java.util.List;
import javax.sql.DataSource;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.BatchPreparedStatementSetter;
import java.sql.SQLException;
public class StudentJDBCTemplate implements StudentDAO {
   private DataSource dataSource;
   private JdbcTemplate jdbcTemplateObject;
   public void setDataSource(DataSource dataSource) {
      this.dataSource = dataSource;
      this.jdbcTemplateObject = new JdbcTemplate(dataSource);
   }
   public List<Student> listStudents() {
      String SQL = "select * from Student";
      List <Student> students = jdbcTemplateObject.query(SQL, 
                                new StudentMapper());
      return students;
   }
   public void batchUpdate(final List<Student> students){
      String SQL = "update Student set age = ? where id = ?";
      int[] updateCounts = jdbcTemplateObject.batchUpdate(SQL,
         new BatchPreparedStatementSetter() {
         public void setValues(PreparedStatement ps, int i) throws SQLException {
            ps.setInt(1, students.get(i).getAge());						
            ps.setInt(2, students.get(i).getId());	
         }
         public int getBatchSize() {
            return students.size();
         }
      }); 
      System.out.println("Records updated!");
   }
}

以下是MainApp.java文件的内容。

package com.iowiki;
import java.util.ArrayList;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class MainApp {
   public static void main(String[] args) {
      ApplicationContext context = new ClassPathXmlApplicationContext("Beans.xml");
      StudentJDBCTemplate studentJDBCTemplate = 
         (StudentJDBCTemplate)context.getBean("studentJDBCTemplate");
      List<Student> initialStudents = studentJDBCTemplate.listStudents();
      System.out.println("Initial Students");
      for(Student student2: initialStudents){
         System.out.print("ID : " + student2.getId() );
         System.out.println(", Age : " + student2.getAge()); 
      }
      Student student = new Student();
      student.setId(1);
      student.setAge(10);
      Student student1 = new Student();
      student1.setId(3);
      student1.setAge(10);
      List<Student> students = new ArrayList<Student>();
      students.add(student);
      students.add(student1);
      studentJDBCTemplate.batchUpdate(students);
      List<Student> updatedStudents = studentJDBCTemplate.listStudents();
      System.out.println("Updated Students");
      for(Student student3: updatedStudents){
         System.out.print("ID : " + student3.getId() );
         System.out.println(", Age : " + student3.getAge()); 
      }
   }
}

以下是配置文件Beans.xml 。

<?xml version = "1.0" encoding = "UTF-8"?>
<beans xmlns = "http://www.springframework.org/schema/beans"
   xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance" 
   xsi:schemaLocation="http://www.springframework.org/schema/beans
   http://www.springframework.org/schema/beans/spring-beans-3.0.xsd ">
   <!-- Initialization for data source -->
   <bean id = "dataSource" 
      class = "org.springframework.jdbc.datasource.DriverManagerDataSource">
      <property name = "driverClassName" value = "com.mysql.jdbc.Driver"/>
      <property name = "url" value = "jdbc:mysql://localhost:3306/TEST"/>
      <property name = "username" value = "root"/>
      <property name = "password" value = "admin"/>
   </bean>
   <!-- Definition for studentJDBCTemplate bean -->
   <bean id = "studentJDBCTemplate" 
      class = "com.iowiki.StudentJDBCTemplate">
      <property name = "dataSource" ref = "dataSource" />    
   </bean>
</beans>

完成源和bean配置文件的创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

Initial Students
ID : 1, Age : 11
ID : 3, Age : 15
Records updated!
Updated Students
ID : 1, Age : 10
ID : 3, Age : 10

Spring JDBC - Objects Batch Operation

以下示例将演示如何使用Spring JDBC中的对象进行批量更新。 我们将在单个批处理操作中更新Student表中的可用记录。

语法 (Syntax)

String SQL = "update Student set age = :age where id = :id";
SqlParameterSource[] batch = SqlParameterSourceUtils.createBatch(students.toArray());
NamedParameterJdbcTemplate jdbcTemplateObject = new NamedParameterJdbcTemplate(dataSource);
int[] updateCounts = jdbcTemplateObject.batchUpdate(SQL,batch);
System.out.println("records updated!"); 

Where,

• SQL - 更新查询以更新学生的年龄。

• jdbcTemplateObject - 用于更新数据库中学生对象的StudentJDBCTemplate对象。

• batch - 表示一批对象的SqlParameterSource对象。

• updateCounts - 包含每个更新查询的更新行数的Int数组。

为了理解与Spring JDBC相关的上述概念，让我们编写一个更新批处理操作的示例。 要编写我们的示例，让我们使用一个可用的Eclipse IDE，并使用以下步骤创建一个Spring应用程序。

步	描述
1	更新在Spring JDBC - First Application章节下创建的项目Student 。
2	更新bean配置并运行应用程序，如下所述。

以下是数据访问对象接口文件StudentDAO.java 。

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
public interface StudentDAO {
   /** 
      * This is the method to be used to initialize
      * database resources ie. connection.
   */
   public void setDataSource(DataSource ds);
   /** 
      * This is the method to be used to list down
      * all the records from the Student table.
   */
   public List<Student> listStudents();  
   public void batchUpdate(final List<Student> students);
}

以下是Student.java文件的内容。

package com.iowiki;
public class Student {
   private Integer age;
   private String name;
   private Integer id;
   public void setAge(Integer age) {
      this.age = age;
   }
   public Integer getAge() {
      return age;
   }
   public void setName(String name) {
      this.name = name;
   }
   public String getName() {
      return name;
   }
   public void setId(Integer id) {
      this.id = id;
   }
   public Integer getId() {
      return id;
   }
}

以下是StudentMapper.java文件的内容。

package com.iowiki;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.springframework.jdbc.core.RowMapper;
public class StudentMapper implements RowMapper<Student> {
   public Student mapRow(ResultSet rs, int rowNum) throws SQLException {
      Student student = new Student();
      student.setId(rs.getInt("id"));
      student.setName(rs.getString("name"));
      student.setAge(rs.getInt("age"));
      return student;
   }
}

以下是定义的DAO接口StudentJDBCTemplate.java的实现类文件StudentJDBCTemplate.java 。

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.namedparam.SqlParameterSource;
import org.springframework.jdbc.core.namedparam.SqlParameterSourceUtils;
import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
public class StudentJDBCTemplate implements StudentDAO {
   private DataSource dataSource;
   private JdbcTemplate jdbcTemplateObject;
   public void setDataSource(DataSource dataSource) {
      this.dataSource = dataSource;
      this.jdbcTemplateObject = new JdbcTemplate(dataSource);
   }
   public List<Student> listStudents() {
      String SQL = "select * from Student";
      List <Student> students = jdbcTemplateObject.query(SQL, new StudentMapper());
      return students;
   }
   public void batchUpdate(final List<Student> students){
      String SQL = "update Student set age = :age where id = :id";
      SqlParameterSource[] batch = SqlParameterSourceUtils.createBatch(students.toArray());
      NamedParameterJdbcTemplate jdbcTemplateObject = new 
         NamedParameterJdbcTemplate(dataSource);
      int[] updateCounts = jdbcTemplateObject.batchUpdate(SQL,batch);
      System.out.println("Records updated!");
   }
}

以下是MainApp.java文件的内容。

package com.iowiki;
import java.util.ArrayList;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class MainApp {
   public static void main(String[] args) {
      ApplicationContext context = new ClassPathXmlApplicationContext("Beans.xml");
      StudentJDBCTemplate studentJDBCTemplate = 
         (StudentJDBCTemplate)context.getBean("studentJDBCTemplate");
      List<Student> initialStudents = studentJDBCTemplate.listStudents();
      System.out.println("Initial Students");
      for(Student student2: initialStudents){
         System.out.print("ID : " + student2.getId() );
         System.out.println(", Age : " + student2.getAge()); 
      }
      Student student = new Student();
      student.setId(1);
      student.setAge(15);
      Student student1 = new Student();
      student1.setId(3);
      student1.setAge(16);
      List<Student> students = new ArrayList<Student>();
      students.add(student);
      students.add(student1);
      studentJDBCTemplate.batchUpdate(students);
      List<Student> updatedStudents = studentJDBCTemplate.listStudents();
      System.out.println("Updated Students");
      for(Student student3: updatedStudents){
         System.out.print("ID : " + student3.getId() );
         System.out.println(", Age : " + student3.getAge()); 
      }
   }
}

以下是配置文件Beans.xml 。

<?xml version = "1.0" encoding = "UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
   xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance" 
   xsi:schemaLocation = "http://www.springframework.org/schema/beans
   http://www.springframework.org/schema/beans/spring-beans-3.0.xsd ">
   <!-- Initialization for data source -->
   <bean id = "dataSource" 
      class = "org.springframework.jdbc.datasource.DriverManagerDataSource">
      <property name = "driverClassName" value = "com.mysql.jdbc.Driver"/>
      <property name = "url" value = "jdbc:mysql://localhost:3306/TEST"/>
      <property name = "username" value = "root"/>
      <property name = "password" value = "admin"/>
   </bean>
   <!-- Definition for studentJDBCTemplate bean -->
   <bean id = "studentJDBCTemplate" 
      class = "com.iowiki.StudentJDBCTemplate">
      <property name = "dataSource" ref = "dataSource" />    
   </bean>
</beans>

完成源和bean配置文件的创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

Initial Students
ID : 1, Age : 10
ID : 3, Age : 10
Records updated!
Updated Students
ID : 1, Age : 15
ID : 3, Age : 16

Spring JDBC - Multiple Batches Operation

以下示例将演示如何使用Spring JDBC在单个调用中进行多个批处理更新。 我们将在批量大小为1的多批操作中更新Student表中的可用记录。

语法 (Syntax)

String SQL = "update Student set age = ? where id = ?";
int[][] updateCounts = jdbcTemplateObject.batchUpdate(SQL,students,1,
   new ParameterizedPreparedStatementSetter<Student>() {
   public void setValues(PreparedStatement ps, Student student)
      throws SQLException {
      ps.setInt(1, student.getAge());						
      ps.setInt(2, student.getId());	
   }
}); 

Where,

• SQL - 更新查询以更新学生的年龄。

• jdbcTemplateObject - 用于更新数据库中student对象的StudentJDBCTemplate对象。

• ParameterizedPreparedStatementSetter - 批处理执行程序，在每个项目的PerparedStatement中设置值由对象student列表标识。

• updateCounts - Int [] []数组，包含每批更新查询的更新行数。

要理解与Spring JDBC相关的上述概念，让我们编写一个更新多个批处理操作的示例。 要编写我们的示例，让我们使用一个可用的Eclipse IDE，并使用以下步骤创建一个Spring应用程序。

步	描述
1	更新在Spring JDBC - First Application章节下创建的项目Student 。
2	更新bean配置并运行应用程序，如下所述。

以下是数据访问对象接口文件StudentDAO.java 。

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
public interface StudentDAO {
   /** 
      * This is the method to be used to initialize
      * database resources ie. connection.
   */
   public void setDataSource(DataSource ds);
   /** 
      * This is the method to be used to list down
      * all the records from the Student table.
   */
   public List<Student> listStudents();  
   public void batchUpdate(final List<Student> students);
}

以下是Student.java文件的内容。

package com.iowiki;
public class Student {
   private Integer age;
   private String name;
   private Integer id;
   public void setAge(Integer age) {
      this.age = age;
   }
   public Integer getAge() {
      return age;
   }
   public void setName(String name) {
      this.name = name;
   }
   public String getName() {
      return name;
   }
   public void setId(Integer id) {
      this.id = id;
   }
   public Integer getId() {
      return id;
   }
}

以下是StudentMapper.java文件的内容。

package com.iowiki;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.springframework.jdbc.core.RowMapper;
public class StudentMapper implements RowMapper<Student> {
   public Student mapRow(ResultSet rs, int rowNum) throws SQLException {
      Student student = new Student();
      student.setId(rs.getInt("id"));
      student.setName(rs.getString("name"));
      student.setAge(rs.getInt("age"));
      return student;
   }
}

以下是定义的DAO接口StudentJDBCTemplate.java的实现类文件StudentJDBCTemplate.java 。

package com.iowiki;
import java.sql.PreparedStatement;
import java.util.List;
import javax.sql.DataSource;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.ParameterizedPreparedStatementSetter;
import java.sql.SQLException;
public class StudentJDBCTemplate implements StudentDAO {
   private DataSource dataSource;
   private JdbcTemplate jdbcTemplateObject;
   public void setDataSource(DataSource dataSource) {
      this.dataSource = dataSource;
      this.jdbcTemplateObject = new JdbcTemplate(dataSource);
   }
   public List<Student> listStudents() {
      String SQL = "select * from Student";
      List <Student> students = jdbcTemplateObject.query(SQL, new StudentMapper());
      return students;
   }
   public void batchUpdate(final List<Student> students){
      String SQL = "update Student set age = ? where id = ?";
      int[][] updateCounts = jdbcTemplateObject.batchUpdate(SQL,students,1,
         new ParameterizedPreparedStatementSetter<Student>() {
         public void setValues(PreparedStatement ps, Student student)
            throws SQLException {
            ps.setInt(1, student.getAge());						
            ps.setInt(2, student.getId());	
         }
      });
      System.out.println("Records updated!");
   }
}

以下是MainApp.java文件的内容。

package com.iowiki;
import java.util.ArrayList;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class MainApp {
   public static void main(String[] args) {
      ApplicationContext context = new ClassPathXmlApplicationContext("Beans.xml");
      StudentJDBCTemplate studentJDBCTemplate = 
         (StudentJDBCTemplate)context.getBean("studentJDBCTemplate");
      List<Student> initialStudents = studentJDBCTemplate.listStudents();
      System.out.println("Initial Students");
      for(Student student2: initialStudents){
         System.out.print("ID : " + student2.getId() );
         System.out.println(", Age : " + student2.getAge()); 
      }
      Student student = new Student();
      student.setId(1);
      student.setAge(17);
      Student student1 = new Student();
      student1.setId(3);
      student1.setAge(18);
      List<Student> students = new ArrayList<Student>();
      students.add(student);
      students.add(student1);
      studentJDBCTemplate.batchUpdate(students);
      List<Student> updatedStudents = studentJDBCTemplate.listStudents();
      System.out.println("Updated Students");
      for(Student student3: updatedStudents){
         System.out.print("ID : " + student3.getId() );
         System.out.println(", Age : " + student3.getAge()); 
      }
   }
}

以下是配置文件Beans.xml 。

<?xml version = "1.0" encoding = "UTF-8"?>
<beans xmlns = "http://www.springframework.org/schema/beans"
   xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance" 
   xsi:schemaLocation = "http://www.springframework.org/schema/beans
   http://www.springframework.org/schema/beans/spring-beans-3.0.xsd ">
   <!-- Initialization for data source -->
   <bean id = "dataSource" 
      class = "org.springframework.jdbc.datasource.DriverManagerDataSource">
      <property name = "driverClassName" value = "com.mysql.jdbc.Driver"/>
      <property name = "url" value = "jdbc:mysql://localhost:3306/TEST"/>
      <property name = "username" value = "root"/>
      <property name = "password" value = "admin"/>
   </bean>
   <!-- Definition for studentJDBCTemplate bean -->
   <bean id = "studentJDBCTemplate" 
      class = "com.iowiki.StudentJDBCTemplate">
      <property name = "dataSource" ref = "dataSource" />    
   </bean>
</beans>

完成源和bean配置文件的创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

Initial Students
ID : 1, Age : 15
ID : 3, Age : 16
records updated!
Updated Students
ID : 1, Age : 17
ID : 3, Age : 18

Spring JDBC - JdbcTemplate Class

org.springframework.jdbc.core.JdbcTemplate类是JDBC核心包中的中心类。 它简化了JDBC的使用，有助于避免常见错误。 它执行核心JDBC工作流，让应用程序代码提供SQL并提取结果。 此类执行SQL查询或更新，启动对ResultSet的迭代并捕获JDBC异常并将它们转换为org.springframework.dao包中定义的通用的，更具信息性的异常层次结构。

Class 声明 (Class Declaration)

以下是org.springframework.jdbc.core.JdbcTemplate类的声明 -

public class JdbcTemplate
   extends JdbcAccessor
      implements JdbcOperations

用法 (Usage)

Step 1 - 使用配置的数据源创建JdbcTemplate对象。

Step 2 - 使用JdbcTemplate对象方法进行数据库操作。

例子 (Example)

以下示例将演示如何使用JdbcTemplate类读取查询。 我们将阅读学生表中的可用记录。

语法 (Syntax)

String selectQuery = "select * from Student";
List <Student> students = jdbcTemplateObject.query(selectQuery, new StudentMapper());

Where,

• selectQuery - 选择查询以阅读学生。

• jdbcTemplateObject - 从数据库中读取student对象的StudentJDBCTemplate对象。

• StudentMapper - StudentMapper是一个RowMapper对象，用于将每个读取的记录映射到学生对象。

要理解与Spring JDBC相关的上述概念，让我们编写一个选择查询的示例。 要编写我们的示例，让我们使用一个可用的Eclipse IDE，并使用以下步骤创建一个Spring应用程序。

步	描述
1	更新在Spring JDBC - First Application章节下创建的项目Student 。
2	更新bean配置并运行应用程序，如下所述。

以下是数据访问对象接口文件StudentDAO.java 。

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
public interface StudentDAO {
   /** 
      * This is the method to be used to initialize
      * database resources ie. connection.
   */
   public void setDataSource(DataSource ds);
   /** 
      * This is the method to be used to list down
      * all the records from the Student table.
   */
   public List<Student> listStudents();   
}

以下是Student.java文件的内容。

package com.iowiki;
public class Student {
   private Integer age;
   private String name;
   private Integer id;
   public void setAge(Integer age) {
      this.age = age;
   }
   public Integer getAge() {
      return age;
   }
   public void setName(String name) {
      this.name = name;
   }
   public String getName() {
      return name;
   }
   public void setId(Integer id) {
      this.id = id;
   }
   public Integer getId() {
      return id;
   }
}

以下是StudentMapper.java文件的内容。

package com.iowiki;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.springframework.jdbc.core.RowMapper;
public class StudentMapper implements RowMapper<Student> {
   public Student mapRow(ResultSet rs, int rowNum) throws SQLException {
      Student student = new Student();
      student.setId(rs.getInt("id"));
      student.setName(rs.getString("name"));
      student.setAge(rs.getInt("age"));
      return student;
   }
}

以下是定义的DAO接口StudentJDBCTemplate.java的实现类文件StudentJDBCTemplate.java 。

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
import org.springframework.jdbc.core.JdbcTemplate;
public class StudentJDBCTemplate implements StudentDAO {
   private DataSource dataSource;
   private JdbcTemplate jdbcTemplateObject;
   public void setDataSource(DataSource dataSource) {
      this.dataSource = dataSource;
      this.jdbcTemplateObject = new JdbcTemplate(dataSource);
   }
   public List<Student> listStudents() {
      String SQL = "select * from Student";
      List <Student> students = jdbcTemplateObject.query(SQL, new StudentMapper());
      return students;
   }
}

以下是MainApp.java文件的内容。

package com.iowiki;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.iowiki.StudentJDBCTemplate;
public class MainApp {
   public static void main(String[] args) {
      ApplicationContext context = new ClassPathXmlApplicationContext("Beans.xml");
      StudentJDBCTemplate studentJDBCTemplate = 
         (StudentJDBCTemplate)context.getBean("studentJDBCTemplate");
      System.out.println("------Listing Multiple Records--------" );
      List<Student> students = studentJDBCTemplate.listStudents();
      for (Student record : students) {
         System.out.print("ID : " + record.getId() );
         System.out.print(", Name : " + record.getName() );
         System.out.println(", Age : " + record.getAge());
      }  
   }
}

以下是配置文件Beans.xml 。

<?xml version = "1.0" encoding = "UTF-8"?>
<beans xmlns = "http://www.springframework.org/schema/beans"
   xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance" 
   xsi:schemaLocation = "http://www.springframework.org/schema/beans
   http://www.springframework.org/schema/beans/spring-beans-3.0.xsd ">
   <!-- Initialization for data source -->
   <bean id="dataSource" 
      class = "org.springframework.jdbc.datasource.DriverManagerDataSource">
      <property name = "driverClassName" value = "com.mysql.jdbc.Driver"/>
      <property name = "url" value = "jdbc:mysql://localhost:3306/TEST"/>
      <property name = "username" value = "root"/>
      <property name = "password" value = "admin"/>
   </bean>
   <!-- Definition for studentJDBCTemplate bean -->
   <bean id="studentJDBCTemplate" 
      class = "com.iowiki.StudentJDBCTemplate">
      <property name = "dataSource" ref = "dataSource" />    
   </bean>
</beans>

完成源和bean配置文件的创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

------Listing Multiple Records--------
ID : 1, Name : Zara, Age : 11
ID : 2, Name : Nuha, Age : 2
ID : 3, Name : Ayan, Age : 15

PreparedStatementSetter Interface

org.springframework.jdbc.core.PreparedStatementSetter接口充当JdbcTemplate类使用的通用回调接口。 此接口为JdbcTemplate类提供的PreparedStatement设置值，对于使用相同SQL的批处理中的每个更新。

实现负责设置任何必要的参数。 已经提供了带占位符的SQL。 使用此接口比PreparedStatementCreator更容易。 JdbcTemplate将创建PreparedStatement，回调仅负责设置参数值。

接口声明 (Interface Declaration)

以下是org.springframework.jdbc.core.PreparedStatementSetter接口的声明 -

public interface PreparedStatementSetter

用法 (Usage)

Step 1 - 使用配置的数据源创建JdbcTemplate对象。

Step 2 - 使用JdbcTemplate对象方法进行数据库操作，同时传递PreparedStatementSetter对象以替换查询中的占位符。

例子 (Example)

下面的示例将演示如何使用JdbcTemplate类和PreparedStatementSetter接口读取查询。 我们将在学生表中阅读学生的可用记录。

语法 (Syntax)

final String SQL = "select * from Student where id = ? ";
List <Student> students = jdbcTemplateObject.query(
   SQL, new PreparedStatementSetter() {
   public void setValues(PreparedStatement preparedStatement) throws SQLException {
      preparedStatement.setInt(1, id);
   }
},
new StudentMapper());

Where,

• SQL - 选择查询以阅读学生。

• jdbcTemplateObject - 用于从数据库中读取学生对象的StudentJDBCTemplate对象。

• PreparedStatementSetter - PreparedStatementSetter对象，用于在查询中设置参数。

• StudentMapper - StudentMapper是一个RowMapper对象，用于将每个读取的记录映射到学生对象。

要理解与Spring JDBC相关的上述概念，让我们编写一个选择查询的示例。 要编写我们的示例，让我们使用一个可用的Eclipse IDE，并使用以下步骤创建一个Spring应用程序。

步	描述
1	更新在Spring JDBC - First Application章节下创建的项目Student 。
2	更新bean配置并运行应用程序，如下所述。

以下是数据访问对象接口文件StudentDAO.java 。

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
public interface StudentDAO {
   /** 
      * This is the method to be used to initialize
      * database resources ie. connection.
   */
   public void setDataSource(DataSource ds);
   /** 
      * This is the method to be used to list down
      * a record from the Student table corresponding
      * to a passed student id.
   */
   public Student getStudent(Integer id);
}

以下是Student.java文件的内容。

package com.iowiki;
public class Student {
   private Integer age;
   private String name;
   private Integer id;
   public void setAge(Integer age) {
      this.age = age;
   }
   public Integer getAge() {
      return age;
   }
   public void setName(String name) {
      this.name = name;
   }
   public String getName() {
      return name;
   }
   public void setId(Integer id) {
      this.id = id;
   }
   public Integer getId() {
      return id;
   }
}

以下是StudentMapper.java文件的内容。

package com.iowiki;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.springframework.jdbc.core.RowMapper;
public class StudentMapper implements RowMapper<Student> {
   public Student mapRow(ResultSet rs, int rowNum) throws SQLException {
      Student student = new Student();
      student.setId(rs.getInt("id"));
      student.setName(rs.getString("name"));
      student.setAge(rs.getInt("age"));
      return student;
   }
}

以下是定义的DAO接口StudentJDBCTemplate.java的实现类文件StudentJDBCTemplate.java 。

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
import org.springframework.jdbc.core.JdbcTemplate;
public class StudentJDBCTemplate implements StudentDAO {
   private DataSource dataSource;
   private JdbcTemplate jdbcTemplateObject;
   public void setDataSource(DataSource dataSource) {
      this.dataSource = dataSource;
      this.jdbcTemplateObject = new JdbcTemplate(dataSource);
   }
   public Student getStudent(final Integer id) {
      final String SQL = "select * from Student where id = ? ";
      List <Student> students = jdbcTemplateObject.query(
         SQL, new PreparedStatementSetter() {
         public void setValues(PreparedStatement preparedStatement) throws SQLException {
            preparedStatement.setInt(1, id);
         }
      },
      new StudentMapper());
      return students.get(0);
   }
}

以下是MainApp.java文件的内容。

package com.iowiki;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class MainApp {
   public static void main(String[] args) {
      ApplicationContext context = new ClassPathXmlApplicationContext("Beans.xml");
      StudentJDBCTemplate studentJDBCTemplate = 
         (StudentJDBCTemplate)context.getBean("studentJDBCTemplate");
      Student student = studentJDBCTemplate.getStudent(1);
      System.out.print("ID : " + student.getId() );
      System.out.println(", Age : " + student.getAge()); 
   }
}

以下是配置文件Beans.xml 。

<?xml version = "1.0" encoding = "UTF-8"?>
<beans xmlns = "http://www.springframework.org/schema/beans"
   xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance" 
   xsi:schemaLocation = "http://www.springframework.org/schema/beans
   http://www.springframework.org/schema/beans/spring-beans-3.0.xsd ">
   <!-- Initialization for data source -->
   <bean id = "dataSource" 
      class = "org.springframework.jdbc.datasource.DriverManagerDataSource">
      <property name = "driverClassName" value = "com.mysql.jdbc.Driver"/>
      <property name = "url" value = "jdbc:mysql://localhost:3306/TEST"/>
      <property name = "username" value = "root"/>
      <property name = "password" value = "admin"/>
   </bean>
   <!-- Definition for studentJDBCTemplate bean -->
   <bean id = "studentJDBCTemplate" 
      class = "com.iowiki.StudentJDBCTemplate">
      <property name = "dataSource" ref = "dataSource" />    
   </bean>
</beans>

完成源和bean配置文件的创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

ID : 1, Age : 17

Spring JDBC - ResultSetExtractor Interface

org.springframework.jdbc.core.ResultSetExtractor接口是JdbcTemplate的查询方法使用的回调接口。 此接口的实现执行从ResultSet中提取结果的实际工作，但不必担心异常处理。

调用JdbcTemplate将捕获并处理SQLExceptions。 该接口主要用于JDBC框架本身。 对于ResultSet处理，RowMapper通常是一个更简单的选择，每行映射一个结果对象，而不是整个ResultSet映射一个结果对象。

接口声明 (Interface Declaration)

以下是org.springframework.jdbc.core.ResultSetExtractor接口的声明 -

public interface ResultSetExtractor

用法 (Usage)

Step 1 - 使用配置的数据源创建JdbcTemplate对象。

Step 2 - 使用JBCcTemplate对象方法在使用ResultSetExtractor解析结果集时进行数据库操作。

例子 (Example)

下面的示例将演示如何使用JdbcTemplate类和ResultSetExtractor接口读取查询。 我们将在学生表中阅读学生的可用记录。

语法 (Syntax)

public List<Student> listStudents() {
   String SQL = "select * from Student";
      List <Student> students = jdbcTemplateObject.query(SQL, 
         new ResultSetExtractor<List<Student>>(){
         public List<Student> extractData(
            ResultSet rs) throws SQLException, DataAccessException {
            List<Student> list = new ArrayList<Student>();  
            while(rs.next()){  
               Student student = new Student();
               student.setId(rs.getInt("id"));
               student.setName(rs.getString("name"));
               student.setAge(rs.getInt("age"));
               student.setDescription(rs.getString("description"));
               student.setImage(rs.getBytes("image"));
               list.add(student);  
            }  
            return list;  
         }    	  
      });
   return students;
}

Where,

• SQL - 选择查询以阅读学生。

• jdbcTemplateObject - 用于从数据库中读取学生对象的StudentJDBCTemplate对象。

• ResultSetExtractor - 用于解析resultset对象的ResultSetExtractor对象。

要理解与Spring JDBC相关的上述概念，让我们编写一个选择查询的示例。 要编写我们的示例，让我们使用一个可用的Eclipse IDE，并使用以下步骤创建一个Spring应用程序。

步	描述
1	更新在Spring JDBC - First Application章节下创建的项目Student 。
2	更新bean配置并运行应用程序，如下所述。

以下是数据访问对象接口文件StudentDAO.java 。

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
public interface StudentDAO {
   /** 
      * This is the method to be used to initialize
      * database resources ie. connection.
   */
   public void setDataSource(DataSource ds);
   /** 
      * This is the method to be used to list down
      * all the records from the Student table.
   */
   public List<Student> listStudents();
}

以下是Student.java文件的内容。

package com.iowiki;
public class Student {
   private Integer age;
   private String name;
   private Integer id;
   public void setAge(Integer age) {
      this.age = age;
   }
   public Integer getAge() {
      return age;
   }
   public void setName(String name) {
      this.name = name;
   }
   public String getName() {
      return name;
   }
   public void setId(Integer id) {
      this.id = id;
   }
   public Integer getId() {
      return id;
   }
}

以下是定义的DAO接口StudentJDBCTemplate.java的实现类文件StudentJDBCTemplate.java 。

package com.iowiki;
import java.util.List;
import java.util.ArrayList;
import javax.sql.DataSource;
import org.springframework.jdbc.core.JdbcTemplate;
public class StudentJDBCTemplate implements StudentDAO {
   private DataSource dataSource;
   private JdbcTemplate jdbcTemplateObject;
   public void setDataSource(DataSource dataSource) {
      this.dataSource = dataSource;
      this.jdbcTemplateObject = new JdbcTemplate(dataSource);
   }
   public List<Student> listStudents() {
      String SQL = "select * from Student";
      List <Student> students = jdbcTemplateObject.query(SQL, 
         new ResultSetExtractor<List<Student>>(){
         public List<Student> extractData(
            ResultSet rs) throws SQLException, DataAccessException {
            List<Student> list = new ArrayList<Student>();  
            while(rs.next()){  
               Student student = new Student();
               student.setId(rs.getInt("id"));
               student.setName(rs.getString("name"));
               student.setAge(rs.getInt("age"));
               student.setDescription(rs.getString("description"));
               student.setImage(rs.getBytes("image"));
               list.add(student);  
            }  
            return list;  
         }    	  
      });
      return students;
   }
}

以下是MainApp.java文件的内容。

package com.iowiki;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
public class MainApp {
   public static void main(String[] args) {
      ApplicationContext context = 
         new ClassPathXmlApplicationContext("Beans.xml");
      StudentJDBCTemplate studentJDBCTemplate = 
         (StudentJDBCTemplate)context.getBean("studentJDBCTemplate");
      List<Student> students = studentJDBCTemplate.listStudents();
      for(Student student: students){
         System.out.print("ID : " + student.getId() );
         System.out.println(", Age : " + student.getAge()); 
      }
   }
}

以下是配置文件Beans.xml 。

<?xml version = "1.0" encoding = "UTF-8"?>
<beans xmlns = "http://www.springframework.org/schema/beans"
   xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance" 
   xsi:schemaLocation = "http://www.springframework.org/schema/beans
   http://www.springframework.org/schema/beans/spring-beans-3.0.xsd ">
   <!-- Initialization for data source -->
   <bean id = "dataSource" 
      class = "org.springframework.jdbc.datasource.DriverManagerDataSource">
      <property name = "driverClassName" value = "com.mysql.jdbc.Driver"/>
      <property name = "url" value = "jdbc:mysql://localhost:3306/TEST"/>
      <property name = "username" value = "root"/>
      <property name = "password" value = "admin"/>
   </bean>
   <!-- Definition for studentJDBCTemplate bean -->
   <bean id = "studentJDBCTemplate" 
      class = "com.iowiki.StudentJDBCTemplate">
      <property name = "dataSource" ref = "dataSource" />    
   </bean>
</beans>

完成源和bean配置文件的创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

ID : 1, Age : 17
ID : 3, Age : 18

Spring JDBC - RowMapper Interface

JdbcTemplate使用org.springframework.jdbc.core.RowMapper《T》接口以逐行映射ResultSet的行。 此接口的实现执行将每行映射到结果对象的实际工作。 如果抛出任何抛出的SQLExceptions将被调用JdbcTemplate捕获并处理。

接口声明 (Interface Declaration)

以下是org.springframework.jdbc.core.RowMapper《T》接口的声明 -

public interface RowMapper<T>

用法 (Usage)

Step 1 - 使用配置的数据源创建JdbcTemplate对象。

Step 2 - 创建实现RowMapper接口的StudentMapper对象。

Step 3 - 使用JdbcTemplate对象方法在使用StudentMapper对象时进行数据库操作。

下面的示例将演示如何使用spring jdbc读取查询。 我们将使用StudentMapper对象将读取记录从Student Table映射到Student对象。

语法 (Syntax)

String SQL = "select * from Student";
List <Student> students = jdbcTemplateObject.query(SQL, new StudentMapper());

哪里

• SQL - 读取查询以读取所有学生记录。

• jdbcTemplateObject - 用于从数据库中读取学生记录的StudentJDBCTemplate对象。

• StudentMapper - 用于将学生记录映射到学生对象的StudentMapper对象。

为了理解与Spring JDBC相关的上述概念，让我们编写一个示例，它将使用StudentMapper对象读取查询和映射结果。 要编写我们的示例，让我们使用一个可用的Eclipse IDE，并使用以下步骤创建一个Spring应用程序。

步	描述
1	更新在Spring JDBC - First Application章节下创建的项目Student 。
2	更新bean配置并运行应用程序，如下所述。

以下是数据访问对象接口文件StudentDao.java.

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
public interface StudentDao {
   /** 
      * This is the method to be used to initialize
      * database resources ie. connection.
   */
   public void setDataSource(DataSource ds);
   /** 
      * This is the method to be used to list down
      * all the records from the Student table.
   */
   public List<Student> listStudents();   
}

以下是Student.java文件的内容。

package com.iowiki;
public class Student {
   private Integer age;
   private String name;
   private Integer id;
   public void setAge(Integer age) {
      this.age = age;
   }
   public Integer getAge() {
      return age;
   }
   public void setName(String name) {
      this.name = name;
   }
   public String getName() {
      return name;
   }
   public void setId(Integer id) {
      this.id = id;
   }
   public Integer getId() {
      return id;
   }
}

以下是StudentMapper.java文件的内容。

package com.iowiki;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.springframework.jdbc.core.RowMapper;
public class StudentMapper implements RowMapper<Student> {
   public Student mapRow(ResultSet rs, int rowNum) throws SQLException {
      Student student = new Student();
      student.setId(rs.getInt("id"));
      student.setName(rs.getString("name"));
      student.setAge(rs.getInt("age"));
      return student;
   }
}

以下是定义的DAO接口StudentJDBCTemplate.java的实现类文件StudentJDBCTemplate.java 。

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
import org.springframework.jdbc.core.JdbcTemplate;
public class StudentJDBCTemplate implements StudentDao {
   private DataSource dataSource;
   private JdbcTemplate jdbcTemplateObject;
   public void setDataSource(DataSource dataSource) {
      this.dataSource = dataSource;
      this.jdbcTemplateObject = new JdbcTemplate(dataSource);
   }
   public List<Student> listStudents() {
      String SQL = "select * from Student";
      List <Student> students = jdbcTemplateObject.query(SQL, new StudentMapper());
      return students;
   }
}

以下是MainApp.java文件的内容

package com.iowiki;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.iowiki.StudentJDBCTemplate;
public class MainApp {
   public static void main(String[] args) {
      ApplicationContext context = new ClassPathXmlApplicationContext("Beans.xml");
      StudentJDBCTemplate studentJDBCTemplate = 
         (StudentJDBCTemplate)context.getBean("studentJDBCTemplate");
      System.out.println("------Listing Multiple Records--------" );
      List<Student> students = studentJDBCTemplate.listStudents();
      for (Student record : students) {
         System.out.print("ID : " + record.getId() );
         System.out.print(", Name : " + record.getName() );
         System.out.println(", Age : " + record.getAge());
      }  
   }
}

以下是配置文件Beans.xml 。

<?xml version = "1.0" encoding = "UTF-8"?>
<beans xmlns = "http://www.springframework.org/schema/beans"
   xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance" 
   xsi:schemaLocation = "http://www.springframework.org/schema/beans
   http://www.springframework.org/schema/beans/spring-beans-3.0.xsd ">
   <!-- Initialization for data source -->
   <bean id = "dataSource" 
      class = "org.springframework.jdbc.datasource.DriverManagerDataSource">
      <property name = "driverClassName" value = "com.mysql.jdbc.Driver"/>
      <property name = "url" value = "jdbc:mysql://localhost:3306/TEST"/>
      <property name = "username" value = "root"/>
      <property name = "password" value = "admin"/>
   </bean>
   <!-- Definition for studentJDBCTemplate bean -->
   <bean id = "studentJDBCTemplate" 
      class = "com.iowiki.StudentJDBCTemplate">
      <property name = "dataSource" ref = "dataSource" />    
   </bean>
</beans>

完成源和bean配置文件的创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

------Listing Multiple Records--------
ID : 1, Name : Zara, Age : 17
ID : 3, Name : Ayan, Age : 18

NamedParameterJdbcTemplate Class

org.springframework.jdbc.core.NamedParameterJdbcTemplate类是一个带有一组基本JDBC操作的模板类，允许使用命名参数而不是传统的'？' 占位符。 一旦从命名参数替换为JDBC样式'？'，此类将委托给包装好的JdbcTemplate 占位符在执行时完成。 它还允许将值列表扩展到适当数量的占位符。

接口声明 (Interface Declaration)

以下是org.springframework.jdbc.core.NamedParameterJdbcTemplate类的声明 -

public class NamedParameterJdbcTemplate
   extends Object
      implements NamedParameterJdbcOperations

语法 (Syntax)

MapSqlParameterSource in = new MapSqlParameterSource();
in.addValue("id", id);
in.addValue("description",  new SqlLobValue(description, new DefaultLobHandler()), Types.CLOB);
String SQL = "update Student set description = :description where id = :id";
NamedParameterJdbcTemplate jdbcTemplateObject = new NamedParameterJdbcTemplate(dataSource);
jdbcTemplateObject.update(SQL, in);

Where,

• in - SqlParameterSource对象，用于传递参数以更新查询。

• SqlLobValue - 表示SQL BLOB/CLOB值参数的对象。

• jdbcTemplateObject - NamedParameterJdbcTemplate对象，用于更新数据库中的student对象。

为了理解与Spring JDBC相关的上述概念，让我们编写一个更新查询的示例。 要编写我们的示例，让我们使用一个可用的Eclipse IDE，并使用以下步骤创建一个Spring应用程序。

步	描述
1	更新在Spring JDBC - First Application章节下创建的项目Student 。
2	更新bean配置并运行应用程序，如下所述。

以下是数据访问对象接口文件StudentDAO.java 。

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
public interface StudentDAO {
   /** 
      * This is the method to be used to initialize
      * database resources ie. connection.
   */
   public void setDataSource(DataSource ds);
   /** 
      * This is the method to be used to update
      * a record into the Student table.
   */
   public void updateDescription(Integer id, String description);
}

以下是Student.java文件的内容。

package com.iowiki;
public class Student {
   private Integer age;
   private String name;
   private Integer id;
   private String description;
   public void setAge(Integer age) {
      this.age = age;
   }
   public Integer getAge() {
      return age;
   }
   public void setName(String name) {
      this.name = name;
   }
   public String getName() {
      return name;
   }
   public void setId(Integer id) {
      this.id = id;
   }
   public Integer getId() {
      return id;
   }
   public String getDescription() {
      return description;
   }
   public void setDescription(String description) {
      this.description = description;
   }
}

以下是StudentMapper.java文件的内容。

package com.iowiki;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.springframework.jdbc.core.RowMapper;
public class StudentMapper implements RowMapper<Student> {
   public Student mapRow(ResultSet rs, int rowNum) throws SQLException {
      Student student = new Student();
      student.setId(rs.getInt("id"));
      student.setName(rs.getString("name"));
      student.setAge(rs.getInt("age"));
      student.setDescription(rs.getString("description"));
      return student;
   }
}

以下是定义的DAO接口StudentJDBCTemplate.java的实现类文件StudentJDBCTemplate.java 。

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;
import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
import org.springframework.jdbc.core.namedparam.SqlParameterSource;
import org.springframework.jdbc.core.simple.SimpleJdbcCall;
import org.springframework.jdbc.core.support.SqlLobValue;
import org.springframework.jdbc.support.lob.DefaultLobHandler;
import java.io.ByteArrayInputStream;
import java.sql.Types;
public class StudentJDBCTemplate implements StudentDAO {
   private DataSource dataSource;
   private JdbcTemplate jdbcTemplateObject;
   public void setDataSource(DataSource dataSource) {
      this.dataSource = dataSource;
   }
   public void updateDescription(Integer id, String description) {
      MapSqlParameterSource in = new MapSqlParameterSource();
      in.addValue("id", id);
      in.addValue("description",  new SqlLobValue(
         description, new DefaultLobHandler()), Types.CLOB);
      String SQL = "update Student set description = :description where id = :id";
      NamedParameterJdbcTemplate jdbcTemplateObject = 
         new NamedParameterJdbcTemplate(dataSource);
      jdbcTemplateObject.update(SQL, in);
      System.out.println("Updated Record with ID = " + id );
   }
}

以下是MainApp.java文件的内容。

package com.iowiki;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.iowiki.StudentJDBCTemplate;
public class MainApp {
   public static void main(String[] args) {
      ApplicationContext context = new ClassPathXmlApplicationContext("Beans.xml");
      StudentJDBCTemplate studentJDBCTemplate = 
         (StudentJDBCTemplate)context.getBean("studentJDBCTemplate");
      studentJDBCTemplate.updateDescription(1, 
         "This can be a very long text upto 4 GB of size."); 
   }
}

以下是配置文件Beans.xml 。

<?xml version = "1.0" encoding = "UTF-8"?>
<beans xmlns = "http://www.springframework.org/schema/beans"
   xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance" 
   xsi:schemaLocation = "http://www.springframework.org/schema/beans
   http://www.springframework.org/schema/beans/spring-beans-3.0.xsd ">
   <!-- Initialization for data source -->
   <bean id = "dataSource" 
      class = "org.springframework.jdbc.datasource.DriverManagerDataSource">
      <property name = "driverClassName" value = "com.mysql.jdbc.Driver"/>
      <property name = "url" value = "jdbc:mysql://localhost:3306/TEST"/>
      <property name = "username" value = "root"/>
      <property name = "password" value = "admin"/>
   </bean>
   <!-- Definition for studentJDBCTemplate bean -->
   <bean id = "studentJDBCTemplate" 
      class = "com.iowiki.StudentJDBCTemplate">
      <property name = "dataSource" ref = "dataSource" />    
   </bean>
</beans>

完成源和bean配置文件的创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

Updated Record with ID = 1

您可以通过查询数据库来检查存储的描述。

Spring JDBC - SimpleJdbcInsert Class

org.springframework.jdbc.core.SimpleJdbcInsert类是一个多线程，可重用的对象，为表提供了简单的插入功能。 它提供元数据处理，以简化构造基本插入语句所需的代码。 使用Spring的JdbcTemplate处理实际的插入

Class 声明 (Class Declaration)

以下是org.springframework.jdbc.core.SimpleJdbcInsert类的声明 -

public class SimpleJdbcInsert
   extends AbstractJdbcInsert
      implements SimpleJdbcInsertOperations

以下示例将演示如何使用Spring JDBC插入查询。 我们将使用SimpleJdbcInsert对象在Student Table中插入一条记录。

语法 (Syntax)

jdbcInsert = new SimpleJdbcInsert(dataSource).withTableName("Student");
Map<String,Object> parameters = new HashMap<String,Object>();
parameters.put("name", name);
parameters.put("age", age);
jdbcInsert.execute(parameters);

Where,

• jdbcInsert - 要在student表中插入记录的SimpleJdbcInsert对象。

• jdbcTemplateObject - 用于读取数据库中学生对象的StudentJDBCTemplate对象。

要理解与Spring JDBC相关的上述概念，让我们编写一个插入查询的示例。 要编写我们的示例，让我们使用一个可用的Eclipse IDE，并使用以下步骤创建一个Spring应用程序。

步	描述
1	更新在Spring JDBC - First Application章节下创建的项目Student 。
2	更新bean配置并运行应用程序，如下所述。

以下是数据访问对象接口文件StudentDAO.java 。

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
public interface StudentDAO {
   /** 
      * This is the method to be used to initialize
      * database resources ie. connection.
   */
   public void setDataSource(DataSource ds);
   /** 
      * This is the method to be used to create
      * a record in the Student table.
   */
   public void create(String name, Integer age);
   /** 
      * This is the method to be used to list down
      * all the records from the Student table.
   */
   public List<Student> listStudents();   
}

以下是Student.java文件的内容。

package com.iowiki;
public class Student {
   private Integer age;
   private String name;
   private Integer id;
   public void setAge(Integer age) {
      this.age = age;
   }
   public Integer getAge() {
      return age;
   }
   public void setName(String name) {
      this.name = name;
   }
   public String getName() {
      return name;
   }
   public void setId(Integer id) {
      this.id = id;
   }
   public Integer getId() {
      return id;
   }
}

以下是StudentMapper.java文件的内容。

package com.iowiki;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.springframework.jdbc.core.RowMapper;
public class StudentMapper implements RowMapper<Student> {
   public Student mapRow(ResultSet rs, int rowNum) throws SQLException {
      Student student = new Student();
      student.setId(rs.getInt("id"));
      student.setName(rs.getString("name"));
      student.setAge(rs.getInt("age"));
      return student;
   }
}

以下是定义的DAO接口StudentJDBCTemplate.java的实现类文件StudentJDBCTemplate.java 。

package com.iowiki;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
import javax.sql.DataSource;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.simple.SimpleJdbcInsert;
public class StudentJDBCTemplate implements StudentDao {
   private DataSource dataSource;
   private JdbcTemplate jdbcTemplateObject;
   SimpleJdbcInsert jdbcInsert;
   public void setDataSource(DataSource dataSource) {
      this.dataSource = dataSource;
      this.jdbcTemplateObject = new JdbcTemplate(dataSource);
      this.jdbcInsert = new SimpleJdbcInsert(dataSource).withTableName("Student");
   }
   public void create(String name, Integer age) {
      Map<String,Object> parameters = new HashMap<String,Object>();
      parameters.put("name", name);
      parameters.put("age", age);
      jdbcInsert.execute(parameters);
      System.out.println("Created Record Name = " + name + " Age = " + age);
      return;
   }
   public List<Student> listStudents() {
      String SQL = "select * from Student";
      List <Student> students = jdbcTemplateObject.query(SQL, new StudentMapper());
      return students;
   }
}

以下是MainApp.java文件的内容。

package com.iowiki;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.iowiki.StudentJDBCTemplate;
public class MainApp {
   public static void main(String[] args) {
      ApplicationContext context = new ClassPathXmlApplicationContext("Beans.xml");
      StudentJDBCTemplate studentJDBCTemplate = 
         (StudentJDBCTemplate)context.getBean("studentJDBCTemplate");
      System.out.println("------Records Creation--------" );
      studentJDBCTemplate.create("Nuha", 2);
      System.out.println("------Listing Multiple Records--------" );
      List<Student> students = studentJDBCTemplate.listStudents();
      for (Student record : students) {
         System.out.print("ID : " + record.getId() );
         System.out.print(", Name : " + record.getName() );
         System.out.println(", Age : " + record.getAge());
      }  
   }
}

以下是配置文件Beans.xml 。

<?xml version = "1.0" encoding = "UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
   xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance" 
   xsi:schemaLocation = "http://www.springframework.org/schema/beans
   http://www.springframework.org/schema/beans/spring-beans-3.0.xsd ">
   <!-- Initialization for data source -->
   <bean id = "dataSource" 
      class = "org.springframework.jdbc.datasource.DriverManagerDataSource">
      <property name = "driverClassName" value = "com.mysql.jdbc.Driver"/>
      <property name = "url" value = "jdbc:mysql://localhost:3306/TEST"/>
      <property name = "username" value = "root"/>
      <property name = "password" value = "admin"/>
   </bean>
   <!-- Definition for studentJDBCTemplate bean -->
   <bean id = "studentJDBCTemplate" 
      class = "com.iowiki.StudentJDBCTemplate">
      <property name = "dataSource" ref = "dataSource" />    
   </bean>
</beans>

完成源和bean配置文件的创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

------Records Creation--------
Created Record Name = Nuha Age = 12
------Listing Multiple Records--------
ID : 1, Name : Zara, Age : 17
ID : 3, Name : Ayan, Age : 18
ID : 4, Name : Nuha, Age : 12

Spring JDBC - SimpleJdbcCall Class

org.springframework.jdbc.core.SimpleJdbcCall类是一个多线程，可重用的对象，表示对存储过程或存储函数的调用。 它提供元数据处理，以简化访问基本存储过程/函数所需的代码。

您需要提供的只是过程/函数的名称以及执行调用时包含参数的映射。 提供的参数的名称将与创建存储过程时声明的in和out参数匹配。

Class 声明 (Class Declaration)

以下是org.springframework.jdbc.core.SimpleJdbcCall类的声明 -

public class SimpleJdbcCall
   extends AbstractJdbcCall
      implements SimpleJdbcCallOperations

下面的示例将演示如何使用Spring SimpleJdbcCall调用存储过程。 我们将通过调用存储过程来读取学生表中的一个可用记录。 我们将通过身份证并收到学生记录。

语法 (Syntax)

SimpleJdbcCall jdbcCall = new SimpleJdbcCall(dataSource).withProcedureName("getRecord");
SqlParameterSource in = new MapSqlParameterSource().addValue("in_id", id);
Map<String, Object> out = jdbcCall.execute(in);
Student student = new Student();
student.setId(id);
student.setName((String) out.get("out_name"));
student.setAge((Integer) out.get("out_age"));

Where,

• jdbcCall - 表示存储过程的SimpleJdbcCall对象。

• in - SqlParameterSource对象，用于将参数传递给存储过程。

• student - 学生对象。

• out - 映射对象以表示存储过程调用结果的输出。

为了理解与Spring JDBC相关的上述概念，让我们编写一个调用存储过程的示例。 要编写我们的示例，让我们使用一个可用的Eclipse IDE，并使用以下步骤创建一个Spring应用程序。

步	描述
1	更新在Spring JDBC - First Application章节下创建的项目Student 。
2	更新bean配置并运行应用程序，如下所述。

以下是数据访问对象接口文件StudentDAO.java 。

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
public interface StudentDAO {
   /** 
      * This is the method to be used to initialize
      * database resources ie. connection.
   */
   public void setDataSource(DataSource ds);
   /** 
      * This is the method to be used to list down
      * a record from the Student table corresponding
      * to a passed student id.
   */
   public Student getStudent(Integer id);  
}

以下是Student.java文件的内容。

package com.iowiki;
public class Student {
   private Integer age;
   private String name;
   private Integer id;
   public void setAge(Integer age) {
      this.age = age;
   }
   public Integer getAge() {
      return age;
   }
   public void setName(String name) {
      this.name = name;
   }
   public String getName() {
      return name;
   }
   public void setId(Integer id) {
      this.id = id;
   }
   public Integer getId() {
      return id;
   }
}

以下是StudentMapper.java文件的内容。

package com.iowiki;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.springframework.jdbc.core.RowMapper;
public class StudentMapper implements RowMapper<Student> {
   public Student mapRow(ResultSet rs, int rowNum) throws SQLException {
      Student student = new Student();
      student.setId(rs.getInt("id"));
      student.setName(rs.getString("name"));
      student.setAge(rs.getInt("age"));
      return student;
   }
}

以下是定义的DAO接口StudentJDBCTemplate.java的实现类文件StudentJDBCTemplate.java 。

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;
import org.springframework.jdbc.core.namedparam.SqlParameterSource;
import org.springframework.jdbc.core.simple.SimpleJdbcCall;
public class StudentJDBCTemplate implements StudentDAO {
   private DataSource dataSource;
   private JdbcTemplate jdbcTemplateObject;
   public void setDataSource(DataSource dataSource) {
      this.dataSource = dataSource;
      this.jdbcTemplateObject = new JdbcTemplate(dataSource);
   }
   public Student getStudent(Integer id) {
      SimpleJdbcCall jdbcCall = new 
         SimpleJdbcCall(dataSource).withProcedureName("getRecord");
      SqlParameterSource in = new MapSqlParameterSource().addValue("in_id", id);
      Map<String, Object> out = jdbcCall.execute(in);
      Student student = new Student();
      student.setId(id);
      student.setName((String) out.get("out_name"));
      student.setAge((Integer) out.get("out_age"));
      return student;      
   }
}

为执行调用而编写的代码涉及创建包含IN参数的SqlParameterSource。 将为输入值提供的名称与存储过程中声明的参数名称的名称相匹配非常重要。 execute方法接受IN参数并返回一个Map，该Map包含由存储过程中指定的名称键入的任何out参数。

以下是MainApp.java文件的内容。

package com.iowiki;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.iowiki.StudentJDBCTemplate;
public class MainApp {
   public static void main(String[] args) {
      ApplicationContext context = new ClassPathXmlApplicationContext("Beans.xml");
      StudentJDBCTemplate studentJDBCTemplate = 
         (StudentJDBCTemplate)context.getBean("studentJDBCTemplate");
      Student student = studentJDBCTemplate.getStudent(1);
      System.out.print("ID : " + student.getId() );
      System.out.print(", Name : " + student.getName() );
      System.out.println(", Age : " + student.getAge()); 
   }
}

以下是配置文件Beans.xml 。

<?xml version = "1.0" encoding = "UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
   xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance" 
   xsi:schemaLocation = "http://www.springframework.org/schema/beans
   http://www.springframework.org/schema/beans/spring-beans-3.0.xsd ">
   <!-- Initialization for data source -->
   <bean id = "dataSource" 
      class = "org.springframework.jdbc.datasource.DriverManagerDataSource">
      <property name = "driverClassName" value = "com.mysql.jdbc.Driver"/>
      <property name = "url" value = "jdbc:mysql://localhost:3306/TEST"/>
      <property name = "username" value = "root"/>
      <property name = "password" value = "admin"/>
   </bean>
   <!-- Definition for studentJDBCTemplate bean -->
   <bean id = "studentJDBCTemplate" 
      class = "com.iowiki.StudentJDBCTemplate">
      <property name = "dataSource" ref = "dataSource" />    
   </bean>
</beans>

完成源和bean配置文件的创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

ID : 1, Name : Zara, Age : 11

Spring JDBC - SqlQuery Class

org.springframework.jdbc.object.SqlQuery类提供表示SQL查询的可重用操作对象。

Class 声明 (Class Declaration)

以下是org.springframework.jdbc.object.SqlQuery类的声明 -

public abstract class SqlQuery<T>
   extends SqlOperation

用法 (Usage)

• Step 1 - 使用配置的数据源创建JdbcTemplate对象。

• Step 2 - 创建实现RowMapper接口的StudentMapper对象。

• Step 3 - 使用JdbcTemplate对象方法在使用SqlQuery对象时进行数据库操作。

下面的示例将演示如何使用SqlQuery Object读取Query。 我们将使用StudentMapper对象将读取记录从Student Table映射到Student对象。

语法 (Syntax)

String sql = "select * from Student";
SqlQuery<Student> sqlQuery = new SqlQuery<Student>() {
   @Override
   protected RowMapper<Student> newRowMapper(Object[] parameters,
      Map<?, ?> context) {
      return new StudentMapper();
   }
};
sqlQuery.setDataSource(dataSource);
sqlQuery.setSql(sql);
List <Student> students = sqlQuery.execute();

Where,

• SQL - 读取查询以读取所有学生记录。

• jdbcTemplateObject - StudentJDBCTemplate对象，用于从数据库中读取学生记录。

• StudentMapper - 用于将学生记录映射到学生对象的StudentMapper对象。

• SqlQuery - 用于查询学生记录并将其映射到学生对象的SqlQuery对象。

为了理解与Spring JDBC相关的上述概念，让我们编写一个示例，它将读取查询并使用StudentMapper对象映射结果。 要编写我们的示例，让我们使用一个可用的Eclipse IDE，并使用以下步骤创建一个Spring应用程序。

步	描述
1	更新在Spring JDBC - First Application章节下创建的项目Student 。
2	更新bean配置并运行应用程序，如下所述。

以下是数据访问对象接口文件StudentDao.java.

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
public interface StudentDao {
   /** 
      * This is the method to be used to initialize
      * database resources ie. connection.
   */
   public void setDataSource(DataSource ds);
   /** 
      * This is the method to be used to list down
      * all the records from the Student table.
   */
   public List<Student> listStudents();   
}

以下是Student.java文件的内容。

package com.iowiki;
public class Student {
   private Integer age;
   private String name;
   private Integer id;
   public void setAge(Integer age) {
      this.age = age;
   }
   public Integer getAge() {
      return age;
   }
   public void setName(String name) {
      this.name = name;
   }
   public String getName() {
      return name;
   }
   public void setId(Integer id) {
      this.id = id;
   }
   public Integer getId() {
      return id;
   }
}

以下是StudentMapper.java文件的内容。

package com.iowiki;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.springframework.jdbc.core.RowMapper;
public class StudentMapper implements RowMapper<Student> {
   public Student mapRow(ResultSet rs, int rowNum) throws SQLException {
      Student student = new Student();
      student.setId(rs.getInt("id"));
      student.setName(rs.getString("name"));
      student.setAge(rs.getInt("age"));
      return student;
   }
}

以下是定义的DAO接口StudentJDBCTemplate.java的实现类文件StudentJDBCTemplate.java 。

package com.iowiki;
import java.util.List;
import java.util.Map;
import javax.sql.DataSource;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.RowMapper;
import org.springframework.jdbc.object.SqlQuery;
public class StudentJDBCTemplate implements StudentDao {
   private DataSource dataSource;
   private JdbcTemplate jdbcTemplateObject;
   public void setDataSource(DataSource dataSource) {
      this.dataSource = dataSource;
      this.jdbcTemplateObject = new JdbcTemplate(dataSource);     
   }
   public List<Student> listStudents() {
      String sql = "select * from Student";
      SqlQuery<Student> sqlQuery = new SqlQuery<Student>() {
         @Override
         protected RowMapper<Student> newRowMapper(Object[] parameters, Map<?, ?> context){
            return new StudentMapper();
         }
      };
      sqlQuery.setDataSource(dataSource);
      sqlQuery.setSql(sql);
      List <Student> students = sqlQuery.execute();
      return students;
   }
}

以下是MainApp.java文件的内容。

package com.iowiki;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.iowiki.StudentJDBCTemplate;
public class MainApp {
   public static void main(String[] args) {
      ApplicationContext context = new ClassPathXmlApplicationContext("Beans.xml");
      StudentJDBCTemplate studentJDBCTemplate = 
         (StudentJDBCTemplate)context.getBean("studentJDBCTemplate");
      System.out.println("------Listing Multiple Records--------" );
      List<Student> students = studentJDBCTemplate.listStudents();
      for (Student record : students) {
         System.out.print("ID : " + record.getId() );
         System.out.print(", Name : " + record.getName() );
         System.out.println(", Age : " + record.getAge());
      }  
   }
}

以下是配置文件Beans.xml 。

<?xml version = "1.0" encoding = "UTF-8"?>
<beans xmlns = "http://www.springframework.org/schema/beans"
   xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance" 
   xsi:schemaLocation = "http://www.springframework.org/schema/beans
   http://www.springframework.org/schema/beans/spring-beans-3.0.xsd ">
   <!-- Initialization for data source -->
   <bean id = "dataSource" 
      class = "org.springframework.jdbc.datasource.DriverManagerDataSource">
      <property name = "driverClassName" value = "com.mysql.jdbc.Driver"/>
      <property name = "url" value = "jdbc:mysql://localhost:3306/TEST"/>
      <property name = "username" value = "root"/>
      <property name = "password" value = "admin"/>
   </bean>
   <!-- Definition for studentJDBCTemplate bean -->
   <bean id = "studentJDBCTemplate" 
      class = "com.iowiki.StudentJDBCTemplate">
      <property name = "dataSource" ref = "dataSource" />    
   </bean>
</beans>

完成源和bean配置文件的创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

------Listing Multiple Records--------
ID : 1, Name : Zara, Age : 17
ID : 3, Name : Ayan, Age : 18
ID : 4, Name : Nuha, Age : 12

Spring JDBC - SqlUpdate Class

org.springframework.jdbc.object.SqlUpdate类提供表示SQL更新的可重用操作对象。

Class 声明 (Class Declaration)

以下是org.springframework.jdbc.object.SqlUpdate类的声明 -

public abstract class SqlUpdate<T>
   extends SqlOperation

用法 (Usage)

Step 1 - 使用配置的数据源创建JdbcTemplate对象。

Step 2 - 创建实现RowMapper接口的StudentMapper对象。

Step 3 - 使用JdbcTemplate对象方法在使用SqlUpdate对象时执行数据库操作。

以下示例将演示如何使用SqlUpdate对象更新Query。 我们将使用StudentMapper对象将更新记录从Student Table映射到Student对象。

语法 (Syntax)

String SQL = "update Student set age = ? where id = ?";
SqlUpdate sqlUpdate = new SqlUpdate(dataSource,SQL);
sqlUpdate.declareParameter(new SqlParameter("age", Types.INTEGER));
sqlUpdate.declareParameter(new SqlParameter("id", Types.INTEGER));
sqlUpdate.compile();
sqlUpdate.update(age.intValue(),id.intValue());

Where,

• SQL - 更新查询以更新学生记录。

• jdbcTemplateObject - StudentJDBCTemplate对象，用于从数据库中读取学生记录。

• StudentMapper - 用于将学生记录映射到学生对象的StudentMapper对象。

• sqlUpdate - 用于更新学生记录的SqlUpdate对象。

为了理解与Spring JDBC相关的上述概念，让我们编写一个示例，它将使用StudentMapper对象读取查询和映射结果。 要编写我们的示例，让我们使用一个可用的Eclipse IDE，并使用以下步骤创建一个Spring应用程序。

步	描述
1	更新在Spring JDBC - First Application章节下创建的项目Student 。
2	更新bean配置并运行应用程序，如下所述。

以下是数据访问对象接口文件StudentDao.java.

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
public interface StudentDao {
   /** 
      * This is the method to be used to initialize
      * database resources ie. connection.
   */
   public void setDataSource(DataSource ds);
   /** 
      * This is the method to be used to update
      * a record into the Student table.
   */
   public void update(Integer id, Integer age);
   /** 
      * This is the method to be used to list down
      * a record from the Student table corresponding
      * to a passed student id.
   */
   public Student getStudent(Integer id);   
}

以下是Student.java文件的内容。

package com.iowiki;
public class Student {
   private Integer age;
   private String name;
   private Integer id;
   public void setAge(Integer age) {
      this.age = age;
   }
   public Integer getAge() {
      return age;
   }
   public void setName(String name) {
      this.name = name;
   }
   public String getName() {
      return name;
   }
   public void setId(Integer id) {
      this.id = id;
   }
   public Integer getId() {
      return id;
   }
}

以下是StudentMapper.java文件的内容。

package com.iowiki;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.springframework.jdbc.core.RowMapper;
public class StudentMapper implements RowMapper<Student> {
   public Student mapRow(ResultSet rs, int rowNum) throws SQLException {
      Student student = new Student();
      student.setId(rs.getInt("id"));
      student.setName(rs.getString("name"));
      student.setAge(rs.getInt("age"));
      return student;
   }
}

以下是定义的DAO接口StudentJDBCTemplate.java的实现类文件StudentJDBCTemplate.java 。

package com.iowiki;
import java.sql.Types;
import javax.sql.DataSource;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.SqlParameter;
import org.springframework.jdbc.object.SqlUpdate;
public class StudentJDBCTemplate implements StudentDao {
   private DataSource dataSource;
   private JdbcTemplate jdbcTemplateObject;
   public void setDataSource(DataSource dataSource) {
      this.dataSource = dataSource;
      this.jdbcTemplateObject = new JdbcTemplate(dataSource);
   }
   public void update(Integer id, Integer age){
      String SQL = "update Student set age = ? where id = ?";
      SqlUpdate sqlUpdate = new SqlUpdate(dataSource,SQL);
      sqlUpdate.declareParameter(new SqlParameter("age", Types.INTEGER));
      sqlUpdate.declareParameter(new SqlParameter("id", Types.INTEGER));
      sqlUpdate.compile();
      sqlUpdate.update(age.intValue(),id.intValue());
      System.out.println("Updated Record with ID = " + id );
      return;
   }
   public Student getStudent(Integer id) {
      String SQL = "select * from Student where id = ?";
      Student student = jdbcTemplateObject.queryForObject(
         SQL, new Object[]{id}, new StudentMapper());
      return student;
   }
}

以下是MainApp.java文件的内容。

package com.iowiki;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.iowiki.StudentJDBCTemplate;
public class MainApp {
   public static void main(String[] args) {
      ApplicationContext context = new ClassPathXmlApplicationContext("Beans.xml");
      StudentJDBCTemplate studentJDBCTemplate = 
         (StudentJDBCTemplate)context.getBean("studentJDBCTemplate");
      System.out.println("----Updating Record with ID = 1 -----" );
      studentJDBCTemplate.update(1, 10);
      System.out.println("----Listing Record with ID = 1 -----" );
      Student student = studentJDBCTemplate.getStudent(1);
      System.out.print("ID : " + student.getId() );
      System.out.print(", Name : " + student.getName() );
      System.out.println(", Age : " + student.getAge());  
   }
}

以下是配置文件Beans.xml 。

<?xml version = "1.0" encoding = "UTF-8"?>
<beans xmlns = "http://www.springframework.org/schema/beans"
   xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance" 
   xsi:schemaLocation = "http://www.springframework.org/schema/beans
   http://www.springframework.org/schema/beans/spring-beans-3.0.xsd ">
   <!-- Initialization for data source -->
   <bean id = "dataSource" 
      class = "org.springframework.jdbc.datasource.DriverManagerDataSource">
      <property name = "driverClassName" value = "com.mysql.jdbc.Driver"/>
      <property name = "url" value = "jdbc:mysql://localhost:3306/TEST"/>
      <property name = "username" value = "root"/>
      <property name = "password" value = "admin"/>
   </bean>
   <!-- Definition for studentJDBCTemplate bean -->
   <bean id = "studentJDBCTemplate" 
      class = "com.iowiki.StudentJDBCTemplate">
      <property name = "dataSource" ref = "dataSource" />    
   </bean>
</beans>

完成源和bean配置文件的创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

----Updating Record with ID = 1 -----
Updated Record with ID = 1
----Listing Record with ID = 1 -----
ID : 1, Name : Zara, Age : 10

Spring JDBC - StoredProcedure Class

org.springframework.jdbc.core.StoredProcedure类是RDBMS存储过程的对象抽象的超类。 这个类是抽象的，并且子类将提供一个类型化的调用方法，该方法委托给提供的execute（java.lang.Object ...）方法。 继承的SQL属性是RDBMS中存储过程的名称。

Class 声明 (Class Declaration)

以下是org.springframework.jdbc.core.StoredProcedure类的声明 -

public abstract class StoredProcedure
   extends SqlCall

下面的示例将演示如何使用Spring StoredProcedure调用存储过程。 我们将通过调用存储过程来读取学生表中的一个可用记录。 我们将通过身份证并收到学生记录。

语法 (Syntax)

class StudentProcedure extends StoredProcedure{
   public StudentProcedure(DataSource dataSource, String procedureName){
      super(dataSource,procedureName);
      declareParameter(new SqlParameter("in_id", Types.INTEGER));
      declareParameter(new SqlOutParameter("out_name", Types.VARCHAR));
      declareParameter(new SqlOutParameter("out_age", Types.INTEGER));
      compile();
   }
   public Student execute(Integer id){
      Map<String, Object> out = super.execute(id);
      Student student = new Student();
      student.setId(id);
      student.setName((String) out.get("out_name"));
      student.setAge((Integer) out.get("out_age"));
      return student;  	
   }
}

Where,

• StoredProcedure - StoredProcedure对象，表示存储过程。

• StudentProcedure - StudentProcedure对象扩展StoredProcedure以声明输入，输出变量和映射结果到Student对象。

• student - 学生对象。

为了理解与Spring JDBC相关的上述概念，让我们编写一个调用存储过程的示例。 要编写我们的示例，让我们使用一个可用的Eclipse IDE，并使用以下步骤创建一个Spring应用程序。

步	描述
1	更新在Spring JDBC - First Application章节下创建的项目Student 。
2	更新bean配置并运行应用程序，如下所述。

以下是数据访问对象接口文件StudentDAO.java 。

package com.iowiki;
import java.util.List;
import javax.sql.DataSource;
public interface StudentDAO {
   /** 
      * This is the method to be used to initialize
      * database resources ie. connection.
   */
   public void setDataSource(DataSource ds);
   /** 
      * This is the method to be used to list down
      * a record from the Student table corresponding
      * to a passed student id.
   */
   public Student getStudent(Integer id);  
}

以下是Student.java文件的内容。

package com.iowiki;
public class Student {
   private Integer age;
   private String name;
   private Integer id;
   public void setAge(Integer age) {
      this.age = age;
   }
   public Integer getAge() {
      return age;
   }
   public void setName(String name) {
      this.name = name;
   }
   public String getName() {
      return name;
   }
   public void setId(Integer id) {
      this.id = id;
   }
   public Integer getId() {
      return id;
   }
}

以下是StudentMapper.java文件的内容。

package com.iowiki;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.springframework.jdbc.core.RowMapper;
public class StudentMapper implements RowMapper<Student> {
   public Student mapRow(ResultSet rs, int rowNum) throws SQLException {
      Student student = new Student();
      student.setId(rs.getInt("id"));
      student.setName(rs.getString("name"));
      student.setAge(rs.getInt("age"));
      return student;
   }
}

以下是定义的DAO接口StudentJDBCTemplate.java的实现类文件StudentJDBCTemplate.java 。

package com.iowiki;
import java.sql.Types;
import java.util.List;
import java.util.Map;
import javax.sql.DataSource;
import org.springframework.jdbc.core.JdbcTemplate;
import org.springframework.jdbc.core.SqlOutParameter;
import org.springframework.jdbc.core.SqlParameter;
import org.springframework.jdbc.core.namedparam.MapSqlParameterSource;
import org.springframework.jdbc.core.namedparam.SqlParameterSource;
import org.springframework.jdbc.object.StoredProcedure;
public class StudentJDBCTemplate implements StudentDao {
   private DataSource dataSource;
   private JdbcTemplate jdbcTemplateObject;
   public void setDataSource(DataSource dataSource) {
      this.dataSource = dataSource;
      this.jdbcTemplateObject = new JdbcTemplate(dataSource);
   }
   public Student getStudent(Integer id) {    
      StudentProcedure studentProcedure = new StudentProcedure(dataSource, "getRecord");
      return studentProcedure.execute(id);      
   }    
}
class StudentProcedure extends StoredProcedure{
   public StudentProcedure(DataSource dataSource, String procedureName) {
      super(dataSource,procedureName);
      declareParameter(new SqlParameter("in_id", Types.INTEGER));
      declareParameter(new SqlOutParameter("out_name", Types.VARCHAR));
      declareParameter(new SqlOutParameter("out_age", Types.INTEGER));
      compile();
   }
   public Student execute(Integer id){
      Map<String, Object> out = super.execute(id);
      Student student = new Student();
      student.setId(id);
      student.setName((String) out.get("out_name"));
      student.setAge((Integer) out.get("out_age"));
      return student;  	
   }
}

为执行调用而编写的代码涉及创建包含IN参数的SqlParameterSource。 将为输入值提供的名称与存储过程中声明的参数名称的名称相匹配非常重要。 execute方法接受IN参数并返回一个Map，该Map包含由存储过程中指定的名称键入的任何out参数。

以下是MainApp.java文件的内容。

package com.iowiki;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.iowiki.StudentJDBCTemplate;
public class MainApp {
   public static void main(String[] args) {
      ApplicationContext context = new ClassPathXmlApplicationContext("Beans.xml");
      StudentJDBCTemplate studentJDBCTemplate = 
         (StudentJDBCTemplate)context.getBean("studentJDBCTemplate");
      Student student = studentJDBCTemplate.getStudent(1);
      System.out.print("ID : " + student.getId() );
      System.out.print(", Name : " + student.getName() );
      System.out.println(", Age : " + student.getAge()); 
   }
}

以下是配置文件Beans.xml.

<?xml version = "1.0" encoding = "UTF-8"?>
<beans xmlns = "http://www.springframework.org/schema/beans"
   xmlns:xsi = "http://www.w3.org/2001/XMLSchema-instance" 
   xsi:schemaLocation = "http://www.springframework.org/schema/beans
   http://www.springframework.org/schema/beans/spring-beans-3.0.xsd ">
   <!-- Initialization for data source -->
   <bean id = "dataSource" 
      class = "org.springframework.jdbc.datasource.DriverManagerDataSource">
      <property name = "driverClassName" value = "com.mysql.jdbc.Driver"/>
      <property name = "url" value = "jdbc:mysql://localhost:3306/TEST"/>
      <property name = "username" value = "root"/>
      <property name = "password" value = "admin"/>
   </bean>
   <!-- Definition for studentJDBCTemplate bean -->
   <bean id = "studentJDBCTemplate" 
      class = "com.iowiki.StudentJDBCTemplate">
      <property name = "dataSource" ref = "dataSource" />    
   </bean>
</beans>

完成源和bean配置文件的创建后，让我们运行应用程序。 如果您的应用程序一切正常，它将打印以下消息。

ID : 1, Name : Zara, Age : 10