在Java的Spring框架的程序中使用JDBC API操作数据库-eolink官网

在Java的Spring框架的程序中使用JDBC API操作数据库

同时与数据库使用普通的旧JDBC的工作，它变得繁琐写不必要的代码来处理异常，打开和关闭数据库连接等，但Spring的JDBC框架需要的所有低层次细节从打开连接，准备和执行SQL语句，过程异常，处理事务，最后关闭连接。

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

Spring JDBC提供了一些方法和相应不同的类与数据库进行交互。我要采取经典和最流行的做法，利用JdbcTemplateclass框架。这是管理的所有数据库的通信和异常处理中心框架类。

JdbcTemplate 类

JdbcTemplate类执行SQL查询，更新语句和存储过程调用，在结果集和提取返回参数值进行迭代。它还捕捉JDBC的异常并将其转换为通用的，信息更丰富，除了在org.springframework.dao包中定义的层次结构。

JdbcTemplate类的实例是一次配置的线程。所以，你可以配置一个JdbcTemplate的一个实例，然后安全地注入这种共享引用到多个DAO。

使用JdbcTemplate类时，通常的做法是配置一个DataSource在Spring配置文件，然后依赖关系注入该共享数据源豆到DAO类，JdbcTemplate或者是在setter数据源创建。

配置数据源

让我们一起创造数据库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)

);

现在，我们需要提供一个数据源给JdbcTemplate类，因此它可以自行配置，以获得数据库访问。您可以配置数据源的XML文件中有一段代码，如下图所示：

class="org.springframework.jdbc.datasource.DriverManagerDataSource">

数据访问对象 (DAO)

DAO表示这是通常用于数据库交互的数据访问对象。 DAO的存在是为ZdbfRNx了提供读取和写入数据到数据库中，他们应该通过该应用程序的其余部分将访问它们的接口公开此功能的一种手段。

在Spring的数据访问对象（DAO）的支持使得它很容易与如JDBC，Hibernate，JPA和JDO以一致的方式进行数据访问技术。

执行SQL语句

让我们来看看如何使用SQL和的JdbcTemplate对象数据库中的表执行CRUD（创建，读取，更新和删除）操作。

查询一个整数：

String SQL = "select count(*) from Student";

int rowCount = jdbcTemplateObject.queryForInt( SQL );

查询长整数：

String SQL = "select count(*) from Student";

long rowCount = jdbcTemplateObject.queryForLong( SQL );

使用绑定变量的简单查询：

String SQL = "select age from Student where id = ?";

int age = jdbcTemplateObject.queryForInt(SQL, new Object[]{10});

在查询字符串：

String SQL = "select name from Student where id = ?";

String name = jdbcTemplateObject.queryForObject(SQL, new Object[]{10}, String.class);

查询并返回一个对象：

String SQL = "select * from Student where id = ?";

Student student = jdbcTemplateObject.queryForObject(SQL,

new Object[]{10}, new StudentMapper());

public class StudentMapper implements RowMapper {

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;

}

查询并返回多个对象：

String SQL = "select * from Student";

List students = jdbcTemplateObject.query(SQL,

new StudentMapper());

public class StudentMapper implements RowMapper {

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;

}

插入一行到表：

String SQL = "insert into Student (name, age) values (?, ?)";

jdbcTemplateObject.update( SQL, new Object[]{"Zara", 11} );

更新一行到表：

String SQL = "update Student set name = ? where id = ?";

jdbcTemplateObject.update( SQL, new Object[]{"Zara", 10} );

从表中删除行：

String SQL = "delete Student where id = ?";

jdbcTemplateObject.update( SQL, new Object[]{20} );

执行DDL语句

您可以使用execute(...)方法的JdbcTemplate来执行任何SQL语句或DDL语句。下面是一个示例使用CREATE语句创建一个表：

String SQL = "CREATE TABLE Student( " +

"ID INT NOT NULL AUTO_INCREMENT, " +

"NAME VARCHAR(20) NOT NULL, " +

"AGE INT NOT NULL, " +

"PRIMARY KEY (ID));"

jdbcTemplateObject.execute( SQL );

SQL存储过程

SimpleJdbcCall的类可以用来调用带有IN和OUT参数的存储过程。你可以使用这种方法，而与任何喜欢的Apache Derby，DB2，MySQL和微软SQL服务器，Oracle和Sybase RDBMS中的工作。

其次，考虑以下的MySQL存储过程这需要学生证和用OUT参数对应的学生的姓名和年龄的回报。因此，让我们使用MySQL命令提示符下在测试数据库中创建该存储过程：

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应用程序，将执行我们的学生桌简单的创建和读取操作。

来创建一个Spring应用程序：

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

package com.yiibai;

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

* a record from the Student table corresponding

* to a passed student id.

public Student getStudent(Integer id);

/**

* This is the method to be used to list down

* all the records from the Student table.

public List listStudents();

}

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

package com.yiibai;

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.yiibai;

import java.sql.ResultSet;

import java.sql.SQLException;

import org.springframework.jdbc.core.RowMapper;

public class StudentMapper implements RowMapper {

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;

}

下面是实现类文件StudentJDBCTemplate.java定义DAO接口StudentDAO：

package com.yiibai;

import java.util.Map;

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 SimpleJdbcCall jdbcCall;

public void setDataSource(DataSource dataSource) {

this.dataSource = dataSource;

this.jdbcCall = new SimpleJdbcCall(dataSource).

withProcedureName("getRecord");

}

public void create(String name, Integer age) {

JdbcTemplate jdbcTemplateObject = new JdbcTemplate(dataSource);

String SQL = "insert into Student (name, age) values (?, ?)";

jdbcTemplateObject.update( SQL, name, age);

System.out.println("Created Record Name = " + name + " Age = " + age);

return;

}

public Student getStudent(Integer id) {

SqlParameterSource in = new MapSqlParameterSource().

addValue("in_id", id);

Map out = jdbcCall.execute(in);

Student student = new StudZdbfRNxent();

student.setId(id);

student.setName((String) out.get("out_name"));

student.setAge((Integer) out.get("out_age"));

return student;

}

public List listStudents() {

String SQL = "select * from Student";

List students = jdbcTemplateObject.query(SQL,

new StudentMapper());

return students;

}

关于上面的程序几句话：你写的调用的执行代码时，需要创建包含IN参数的一个SqlParameterSource。重要的是要配合提供与存储过程中声明的参数名的输入值的名称。 execute方法接收传入的参数，并返回包含任何列在存储过程中指定的名称键入参数的映射。现在让我们修改主应用程序文件MainApp.java，这是如下：

package com.yiibai;

import java.util.List;

import org.springframework.context.ApplicationContext;

import org.springframework.context.support.ClassPathXmlApplicationContext;

import com.yiibai.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 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());

}

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文件：

xmlns:xsi="http://w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://springframework.org/schema/beans

http://springframework.org/schema/beans/spring-beans-3.0.xsd ">

class="org.springframework.jdbc.datasource.DriverManagerDataSource">

class="com.yiibai.StudentJDBCTemplate">

xmlns:xsi="http://w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://springframework.org/schema/beans

http://springframework.org/schema/beans/spring-beans-3.0.xsd ">

class="org.springframework.jdbc.datasource.DriverManagerDataSource">

class="com.yiibai.StudentJDBCTemplate">

创建源代码和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

----Listing Record with ID = 2 -----

ID : 2, Name : Nuha, Age : 2

Iterator与LIstIterator接口在java中的区别有哪些

196 2023-07-25

在Java的Spring框架的程序中使用JDBC API操作数据库

多平台统一管理软件接口，如何实现多平台统一管理软件接口

Iterator与LIstIterator接口在java中的区别有哪些

hdml指的是什么接口

推荐文章

接口调用是什么意思？几种常用接口调用方式

接口设计原则

8款在线 API 接口文档管理工具

api管理系统是什么？

什么是接口调试？接口调试的步骤有哪些？

api 接口管理系统有哪些？

接口测试有几种测试方法

API文档生成工具有哪些？

微服务和api网关区别

交换机配置步骤

最近发表

热评文章

在线接口文档管理工具推荐，支持在线测试，HTTP接口

开源的在线接口文档wiki工具Mindoc的介绍与使

如何优雅的进行接口设计？接口设计的六大原则是什么？

什么是API测试,api检测公司

软件接口设计怎么做？前后端分离软件接口设计思路

接口管理平台推荐，几大接口管理平台总有一款适合你！