Spring JDBC — Обзор
При работе с базой данных с использованием старого старого JDBC становится трудоемким писать ненужный код для обработки исключений, открывать и закрывать соединения с базой данных и т. Д. Однако Spring JDBC Framework заботится обо всех низкоуровневых деталях, начиная с открытия соединения, подготовки и выполнение оператора SQL, обработка исключений, обработка транзакций и, наконец, закрытие соединения.
Что вам нужно сделать, это просто определить параметры соединения и указать оператор SQL, который будет выполняться, и выполнять необходимую работу для каждой итерации при извлечении данных из базы данных.
Spring JDBC предоставляет несколько подходов и соответственно разные классы для взаимодействия с базой данных. В этом уроке мы возьмем классический и самый популярный подход, использующий класс JDBC Template платформы. Это центральный базовый класс, который управляет всеми коммуникациями базы данных и обработкой исключений.
Шаблонный класс JDBC
Класс JDBC Template выполняет запросы SQL, обновляет операторы и вызовы хранимых процедур, выполняет итерацию по ResultSets и извлечение значений возвращаемых параметров. Он также перехватывает исключения JDBC и переводит их в общую, более информативную иерархию исключений, определенную в пакете org.springframework.dao.
Экземпляры класса JDBC Template являются поточно-ориентированными после настройки. Таким образом, вы можете настроить один экземпляр шаблона JDBC и затем безопасно внедрить эту общую ссылку в несколько DAO.
Обычной практикой при использовании класса Template JDBC является конфигурирование DataSource в вашем файле конфигурации Spring, а затем добавление зависимостей в общий компонент DataSource в ваши классы DAO. Шаблон JDBC создается в установщике для источника данных.
Объект доступа к данным (DAO)
DAO означает объект доступа к данным, который обычно используется для взаимодействия с базой данных. DAO существуют для предоставления средств для чтения и записи данных в базу данных, и они должны предоставлять эту функциональность через интерфейс, через который остальные приложения будут получать к ним доступ.
Поддержка объектов доступа к данным (DAO) в Spring упрощает совместную работу с такими технологиями доступа к данным, как JDBC, Hibernate, JPA или JDO.
Spring JDBC — настройка среды
В этой главе описан процесс настройки Spring-AOP в системах на базе Windows и Linux. Spring AOP можно легко установить и интегрировать в текущую среду Java и MAVEN, выполнив несколько простых шагов без каких-либо сложных процедур настройки. Администрация пользователя требуется при установке.
Системные Требования
| JDK | Java SE 2 JDK 1.5 или выше |
| объем памяти | 1 ГБ ОЗУ (рекомендуется) |
| Дисковое пространство | Нет минимальных требований |
| Версия операционной системы | Windows XP или выше, Linux |
Давайте теперь перейдем к этапам установки Spring AOP.
Шаг 1 — Проверьте вашу установку Java
Прежде всего, вам необходимо установить Java Software Development Kit (SDK) в вашей системе. Чтобы убедиться в этом, выполните любую из следующих двух команд в зависимости от платформы, на которой вы работаете.
Если установка Java была выполнена правильно, то на ней отобразится текущая версия и спецификация вашей установки Java. Пример вывода приведен в следующей таблице.
| Платформа | команда | Пример вывода |
|---|---|---|
| Windows |
Откройте командную консоль и введите — \> Java-версия |
Java версия «1.7.0_60» Среда выполнения Java (TM) SE (сборка 1.7.0_60-b19) 64-разрядная серверная виртуальная машина Java Hotspot (TM) (сборка 24.60-b09, смешанный режим) |
| Linux |
Откройте командный терминал и введите — $ java-версия |
Java-версия «1.7.0_25» Открытая среда выполнения JDK (rhel-2.3.10.4.el6_4-x86_64) Откройте виртуальную машину 64-разрядного сервера JDK (сборка 23.7-b01, смешанный режим) |
Откройте командную консоль и введите —
\> Java-версия
Java версия «1.7.0_60»
Среда выполнения Java (TM) SE (сборка 1.7.0_60-b19)
64-разрядная серверная виртуальная машина Java Hotspot (TM) (сборка 24.60-b09, смешанный режим)
Откройте командный терминал и введите —
$ java-версия
Java-версия «1.7.0_25»
Открытая среда выполнения JDK (rhel-2.3.10.4.el6_4-x86_64)
Откройте виртуальную машину 64-разрядного сервера JDK (сборка 23.7-b01, смешанный режим)
Мы предполагаем, что читатели этого руководства установили 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
Загрузите Maven 3.3.3 с https://maven.apache.org/download.cgi
| Операционные системы | Название архива |
|---|---|
| Windows | apache-maven-3.3.3-bin.zip |
| Linux | апач-Maven-3.3.3-bin.tar.gz |
| макинтош | апач-Maven-3.3.3-bin.tar.gz |
Шаг 4 — Распакуйте архив Maven
Распакуйте архив в каталог, в который вы хотите установить Maven 3.3.3. Подкаталог apache-maven-3.3.3 будет создан из архива.
| Операционные системы | Местоположение (может отличаться в зависимости от вашей установки) |
|---|---|
| Windows | C: \ Program Files \ Apache Software Foundation \ apache-maven-3.3.3 |
| Linux | / USR / местные / Apache-Maven |
| макинтош | / USR / местные / Apache-Maven |
Шаг 5 — Установите переменные окружения Maven
Добавьте M2_HOME, M2, MAVEN_OPTS к переменным среды.
| Операционные системы | Выход |
|---|---|
| Windows |
Установите переменные среды, используя системные свойства. M2_HOME = C: \ Program Files \ Apache Software Foundation \ apachemaven-3.3.3 M2 =% M2_HOME% \ bin MAVEN_OPTS = -Xms256m -Xmx512m |
| Linux |
Откройте командный терминал и установите переменные среды. экспорт M2_HOME = /usr/local/apache-maven/apache-maven-3.3.3 экспорт M2 = $ M2_HOME / bin экспорт MAVEN_OPTS = -Xms256m -Xmx512m |
| макинтош |
Откройте командный терминал и установите переменные среды. экспорт M2_HOME = /usr/local/apache-maven/apache-maven-3.3.3 экспорт M2 = $ M2_HOME / bin экспорт MAVEN_OPTS = -Xms256m -Xmx512m |
Установите переменные среды, используя системные свойства.
M2_HOME = C: \ Program Files \ Apache Software Foundation \ apachemaven-3.3.3
M2 =% M2_HOME% \ bin
MAVEN_OPTS = -Xms256m -Xmx512m
Откройте командный терминал и установите переменные среды.
экспорт M2_HOME = /usr/local/apache-maven/apache-maven-3.3.3
экспорт M2 = $ M2_HOME / bin
экспорт MAVEN_OPTS = -Xms256m -Xmx512m
Откройте командный терминал и установите переменные среды.
экспорт M2_HOME = /usr/local/apache-maven/apache-maven-3.3.3
экспорт M2 = $ M2_HOME / bin
экспорт MAVEN_OPTS = -Xms256m -Xmx512m
Шаг 6 — добавьте каталог Maven Bin в системный путь
Теперь добавьте переменную M2 к системному пути.
| Операционные системы | Выход |
|---|---|
| Windows | Добавьте строку;% M2% в конец системной переменной Path. |
| Linux | экспорт PATH = $ M2: $ PATH |
| макинтош | экспорт PATH = $ M2: $ PATH |
Шаг 7 — Проверьте установку Maven
Теперь откройте консоль и выполните следующую команду mvn .
| Операционные системы | задача | команда |
|---|---|---|
| Windows | Открытая командная консоль | c: \> mvn —version |
| Linux | Открытый командный терминал | $ mvn —version |
| макинтош | Открытый терминал | машина: <Джозеф $ mvn —version |
Наконец, проверьте вывод приведенных выше команд, который должен выглядеть примерно так:
| Операционные системы | Выход |
|---|---|
| Windows |
Apache Maven 3.3.3 (7994120775791599e205a5524ec3e0dfe41d4a06; 2015-04-22T17: 27: 37 + 05: 30) Дом Maven: C: \ Program Files \ Apache Software Foundation \ apache-maven-3.3.3 Версия Java: 1.7.0_75, поставщик: корпорация Oracle Домашняя страница Java: 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: /usr/local/apache-maven/apache-maven-3.3.3 Версия Java: 1.7.0_75, поставщик: корпорация Oracle Домашняя страница Java: /usr/local/java-current/jdk1.7.0_75/jre |
| макинтош |
Apache Maven 3.3.3 (7994120775791599e205a5524ec3e0dfe41d4a06; 2015-04-22T17: 27: 37 + 05: 30) Дом Maven: /usr/local/apache-maven/apache-maven-3.3.3 Версия Java: 1.7.0_75, поставщик: корпорация Oracle Домашняя страница Java: /Library/Java/Home/jdk1.7.0_75/jre |
Apache Maven 3.3.3 (7994120775791599e205a5524ec3e0dfe41d4a06; 2015-04-22T17: 27: 37 + 05: 30)
Дом Maven: C: \ Program Files \ Apache Software Foundation \ apache-maven-3.3.3
Версия Java: 1.7.0_75, поставщик: корпорация Oracle
Домашняя страница Java: C: \ Program Files \ Java \ jdk1.7.0_75 \ jre
Локаль по умолчанию: en_US, кодировка платформы: Cp1252
Apache Maven 3.3.3 (7994120775791599e205a5524ec3e0dfe41d4a06; 2015-04-22T17: 27: 37 + 05: 30)
Дом Maven: /usr/local/apache-maven/apache-maven-3.3.3
Версия Java: 1.7.0_75, поставщик: корпорация Oracle
Домашняя страница Java: /usr/local/java-current/jdk1.7.0_75/jre
Apache Maven 3.3.3 (7994120775791599e205a5524ec3e0dfe41d4a06; 2015-04-22T17: 27: 37 + 05: 30)
Дом Maven: /usr/local/apache-maven/apache-maven-3.3.3
Версия Java: 1.7.0_75, поставщик: корпорация Oracle
Домашняя страница Java: /Library/Java/Home/jdk1.7.0_75/jre
Шаг 8 — Настройка Eclipse IDE
Все примеры в этом руководстве написаны с использованием Eclipse IDE. Итак, я бы посоветовал вам установить последнюю версию Eclipse на ваш компьютер.
Чтобы установить Eclipse IDE, загрузите последние двоичные файлы Eclipse со страницы https://www.eclipse.org/downloads/ . После загрузки установки распакуйте бинарный дистрибутив в удобное место. Например, в C: \ eclipse в Windows или / usr / local / eclipse в Linux / Unix. Наконец, установите переменную PATH соответствующим образом.
Eclipse можно запустить, выполнив следующие команды на компьютере с Windows, или вы можете просто дважды щелкнуть файл eclipse.exe.
%C:\eclipse\eclipse.exe
Eclipse можно запустить, выполнив следующие команды на компьютере Unix (Solaris, Linux и т. Д.).
$/usr/local/eclipse/eclipse
После успешного запуска, если все в порядке, должен отобразиться следующий результат.
Как только вы закончите с этим последним шагом, вы готовы приступить к первому примеру JDBC, который вы увидите в следующей главе.
Spring JDBC — настройка источника данных
Давайте создадим таблицу базы данных Student в нашей базе данных TEST . Я предполагаю, что вы работаете с базой данных 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-файле с помощью фрагмента кода, показанного ниже:
<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 — первое приложение
Чтобы понять концепции, связанные с Spring JDBC Framework с классом JDBC Template, давайте напишем простой пример, который будет реализовывать операции вставки и чтения в следующей таблице Student.
CREATE TABLE Student( ID INT NOT NULL AUTO_INCREMENT, NAME VARCHAR(20) NOT NULL, AGE INT NOT NULL, PRIMARY KEY (ID) );
Перейдем к написанию простого консольного Spring JDBC-приложения, которое продемонстрирует концепции JDBC.
Создать проект
Давайте откроем командную консоль, перейдем в каталог C: \ MVN и выполним следующую команду mvn .
C:\MVN>mvn archetype:generate -DgroupId = com.tutorialspoint -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.tutorialspoint [INFO] Parameter: packageName, Value: com.tutorialspoint [INFO] Parameter: package, Value: com.tutorialspoint [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. Вы увидите проект приложения Java, созданный с именем student (как указано в 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.tutorialspoint</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.tutorialspoint;
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.tutorialspoint;
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.tutorialspoint;
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;
}
}
Ниже приведен файл класса реализации StudentJDBCTemplate.java для определенного интерфейса DAO StudentDAO.
package com.tutorialspoint;
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.tutorialspoint;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.tutorialspoint.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.tutorialspoint.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 — Создать запрос
В следующем примере будет показано, как создать запрос с помощью запроса вставки с помощью Spring JDBC. Мы вставим несколько записей в таблицу учеников.
Синтаксис
String insertQuery = "insert into Student (name, age) values (?, ?)"; jdbcTemplateObject.update( insertQuery, name, age);
Куда,
-
insertQuery — вставляет запрос с заполнителями.
-
jdbcTemplateObject — объект StudentJDBCTemplate для вставки объекта ученика в базу данных.
insertQuery — вставляет запрос с заполнителями.
jdbcTemplateObject — объект StudentJDBCTemplate для вставки объекта ученика в базу данных.
Чтобы понять вышеупомянутые концепции, связанные с Spring JDBC, давайте напишем пример, который вставит запрос. Чтобы написать наш пример, давайте создадим рабочую среду Eclipse и используем следующие шаги для создания приложения Spring.
| шаг | Описание |
|---|---|
| 1 | Обновление проекта Student создано в главе Spring JDBC — First Application . |
| 2 | Обновите конфигурацию компонента и запустите приложение, как описано ниже. |
Ниже приводится содержимое файла интерфейса объекта доступа к данным StudentDAO.java .
package com.tutorialspoint;
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.tutorialspoint;
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.tutorialspoint;
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;
}
}
Ниже приведен файл класса реализации StudentJDBCTemplate.java для определенного интерфейса DAO StudentDAO.
package com.tutorialspoint;
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.tutorialspoint;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.tutorialspoint.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.tutorialspoint.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 — чтение запроса
Следующий пример покажет, как читать запрос с использованием Spring JDBC. Мы будем читать доступные записи в таблице учеников.
Синтаксис
String selectQuery = "select * from Student"; List <Student> students = jdbcTemplateObject.query(selectQuery, new StudentMapper());
Куда,
-
selectQuery — Выберите запрос для чтения студентов.
-
jdbcTemplateObject — объект StudentJDBCTemplate для чтения объекта ученика из базы данных.
-
StudentMapper — StudentMapper — это объект RowMapper для сопоставления каждой извлеченной записи с объектом ученика.
selectQuery — Выберите запрос для чтения студентов.
jdbcTemplateObject — объект StudentJDBCTemplate для чтения объекта ученика из базы данных.
StudentMapper — StudentMapper — это объект RowMapper для сопоставления каждой извлеченной записи с объектом ученика.
Чтобы понять вышеупомянутые концепции, относящиеся к Spring JDBC, давайте напишем пример, который выберет запрос. Чтобы написать наш пример, давайте создадим рабочую среду Eclipse и используем следующие шаги для создания приложения Spring.
| шаг | Описание |
|---|---|
| 1 | Обновление проекта Student создано в главе Spring JDBC — First Application . |
| 2 | Обновите конфигурацию компонента и запустите приложение, как описано ниже. |
Ниже приводится содержимое файла интерфейса объекта доступа к данным StudentDAO.java .
package com.tutorialspoint;
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.tutorialspoint;
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.tutorialspoint;
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;
}
}
Ниже приведен файл класса реализации StudentJDBCTemplate.java для определенного интерфейса DAO StudentDAO.
package com.tutorialspoint;
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.tutorialspoint;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.tutorialspoint.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.tutorialspoint.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 — обновление запроса
В следующем примере будет показано, как обновить запрос с помощью Spring JDBC. Мы обновим доступные записи в таблице учеников.
Синтаксис
String updateQuery = "update Student set age = ? where id = ?"; jdbcTemplateObject.update(updateQuery, age, id);
Куда,
-
updateQuery — Обновить запрос, чтобы обновить студента с заполнителями .
-
jdbcTemplateObject — объект StudentJDBCTemplate для обновления объекта ученика в базе данных.
updateQuery — Обновить запрос, чтобы обновить студента с заполнителями .
jdbcTemplateObject — объект StudentJDBCTemplate для обновления объекта ученика в базе данных.
Чтобы понять вышеупомянутые концепции, связанные с Spring JDBC, давайте напишем пример, который обновит запрос. Чтобы написать наш пример, давайте создадим рабочую среду Eclipse и используем следующие шаги для создания приложения Spring.
| шаг | Описание |
|---|---|
| 1 | Обновление проекта Student создано в главе Spring JDBC — First Application . |
| 2 | Обновите конфигурацию компонента и запустите приложение, как описано ниже. |
Ниже приводится содержимое файла интерфейса объекта доступа к данным StudentDAO.java .
package com.tutorialspoint;
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.tutorialspoint;
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.tutorialspoint;
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;
}
}
Ниже приведен файл класса реализации StudentJDBCTemplate.java для определенного интерфейса DAO StudentDAO.
package com.tutorialspoint;
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.tutorialspoint;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.tutorialspoint.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.tutorialspoint.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 — Удалить запрос
В следующем примере будет показано, как удалить запрос с помощью Spring JDBC. Мы удалим одну из доступных записей в таблице учеников.
Синтаксис
String deleteQuery = "delete from Student where id = ?"; jdbcTemplateObject.update(deleteQuery, id);
Куда,
-
deleteQuery — Удалить запрос на удаление студента с заполнителями.
-
jdbcTemplateObject — объект StudentJDBCTemplate для удаления объекта ученика в базе данных.
deleteQuery — Удалить запрос на удаление студента с заполнителями.
jdbcTemplateObject — объект StudentJDBCTemplate для удаления объекта ученика в базе данных.
Чтобы понять вышеупомянутые концепции, относящиеся к Spring JDBC, давайте напишем пример, который удалит запрос. Чтобы написать наш пример, давайте создадим рабочую среду Eclipse и используем следующие шаги для создания приложения Spring.
| шаг | Описание |
|---|---|
| 1 | Обновление проекта Student создано в главе Spring JDBC — First Application . |
| 2 | Обновите конфигурацию компонента и запустите приложение, как описано ниже. |
Ниже приводится содержимое файла интерфейса объекта доступа к данным StudentDAO.java .
package com.tutorialspoint;
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.tutorialspoint;
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.tutorialspoint;
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;
}
}
Ниже приведен файл класса реализации StudentJDBCTemplate.java для определенного интерфейса DAO StudentDAO.
package com.tutorialspoint;
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.tutorialspoint;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.tutorialspoint.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.tutorialspoint.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 — вызов хранимой процедуры
В следующем примере будет показано, как вызвать хранимую процедуру с помощью Spring JDBC. Мы прочитаем одну из доступных записей в таблице учеников, вызвав хранимую процедуру. Мы передадим идентификатор и получим студенческий билет.
Синтаксис
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"));
Куда,
-
jdbcCall — объект SimpleJdbcCall для представления хранимой процедуры.
-
in — объект SqlParameterSource для передачи параметра хранимой процедуре.
-
студент — объект студента.
-
out — Объект Map для представления результата результата вызова хранимой процедуры.
jdbcCall — объект SimpleJdbcCall для представления хранимой процедуры.
in — объект SqlParameterSource для передачи параметра хранимой процедуре.
студент — объект студента.
out — Объект Map для представления результата результата вызова хранимой процедуры.
Класс SimpleJdbcCall может использоваться для вызова хранимой процедуры с параметрами IN и OUT. Вы можете использовать этот подход при работе с любой СУБД, такой как Apache Derby, DB2, MySQL, Microsoft SQL Server, Oracle и Sybase.
Чтобы понять подход, рассмотрим следующую хранимую процедуру MySQL, которая берет идентификатор студента и возвращает имя и возраст соответствующего студента с использованием параметров OUT. Давайте создадим эту хранимую процедуру в базе данных TEST с помощью командной строки 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, давайте напишем пример, который будет вызывать хранимую процедуру. Чтобы написать наш пример, давайте создадим рабочую среду Eclipse и используем следующие шаги для создания приложения Spring.
| шаг | Описание |
|---|---|
| 1 | Обновление проекта Student создано в главе Spring JDBC — First Application . |
| 2 | Обновите конфигурацию компонента и запустите приложение, как описано ниже. |
Ниже приводится содержимое файла интерфейса объекта доступа к данным StudentDAO.java .
package com.tutorialspoint;
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.tutorialspoint;
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.tutorialspoint;
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;
}
}
Ниже приведен файл класса реализации StudentJDBCTemplate.java для определенного интерфейса DAO StudentDAO.
package com.tutorialspoint;
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;
}
}
Код, который вы пишете для выполнения вызова, включает в себя создание SqlParameterSource, содержащего параметр IN. Важно сопоставить имя, указанное для входного значения, с именем параметра, объявленного в хранимой процедуре. Метод execute принимает параметры IN и возвращает карту, содержащую любые параметры out, введенные по имени, как указано в хранимой процедуре.
Ниже приводится содержание файла MainApp.java .
package com.tutorialspoint;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.tutorialspoint.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.tutorialspoint.StudentJDBCTemplate">
<property name = "dataSource" ref = "dataSource" />
</bean>
</beans>
Как только вы закончили создавать файлы конфигурации исходного кода и bean-компонента, давайте запустим приложение Если с вашим приложением все в порядке, оно напечатает следующее сообщение.
ID : 1, Name : Zara, Age : 11
Spring JDBC — вызов сохраненной функции
В следующем примере будет показано, как вызвать хранимую функцию с помощью Spring JDBC. Мы прочитаем одну из доступных записей в таблице учеников, вызвав хранимую функцию. Мы передадим идентификатор и получим имя студента.
Синтаксис
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);
Куда,
-
in — объект SqlParameterSource для передачи параметра хранимой функции.
-
jdbcCall — объект SimpleJdbcCall для представления хранимой функции.
-
jdbcTemplateObject — объект StudentJDBCTemplate для вызываемой хранимой функции из базы данных.
-
студент — объект студента.
in — объект SqlParameterSource для передачи параметра хранимой функции.
jdbcCall — объект SimpleJdbcCall для представления хранимой функции.
jdbcTemplateObject — объект StudentJDBCTemplate для вызываемой хранимой функции из базы данных.
студент — объект студента.
Класс SimpleJdbcCall может использоваться для вызова хранимой функции с параметром IN и возвращаемым значением. Вы можете использовать этот подход при работе с любой СУБД, такой как Apache Derby, DB2, MySQL, Microsoft SQL Server, Oracle и Sybase.
Чтобы понять подход, рассмотрим следующую хранимую процедуру MySQL, которая принимает идентификатор студента и возвращает имя соответствующего студента. Итак, давайте создадим эту сохраненную функцию в вашей базе данных TEST с помощью командной строки MySQL —
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 и используем следующие шаги для создания приложения Spring.
| шаг | Описание |
|---|---|
| 1 | Обновление проекта Student создано в главе Spring JDBC — First Application . |
| 2 | Обновите конфигурацию компонента и запустите приложение, как описано ниже. |
Ниже приводится содержимое файла интерфейса объекта доступа к данным StudentDAO.java .
package com.tutorialspoint;
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.tutorialspoint;
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.tutorialspoint;
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;
}
}
Ниже приведен файл класса реализации StudentJDBCTemplate.java для определенного интерфейса DAO StudentDAO.
package com.tutorialspoint;
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;
}
}
Код, который вы пишете для выполнения вызова, включает в себя создание SqlParameterSource, содержащего параметр IN. Важно сопоставить имя, указанное для входного значения, с именем параметра, объявленного в хранимой функции. Метод executeFunction принимает параметры IN и возвращает строку, указанную в сохраненной функции.
Ниже приводится содержание файла MainApp.java
package com.tutorialspoint;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.tutorialspoint.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.tutorialspoint.StudentJDBCTemplate">
<property name = "dataSource" ref = "dataSource" />
</bean>
</beans>
Как только вы закончили создавать файлы конфигурации исходного кода и bean-компонента, давайте запустим приложение Если с вашим приложением все в порядке, оно напечатает следующее сообщение.
ID : 1, Name : Zara
Spring JDBC — Обработка BLOB
В следующем примере показано, как обновить BLOB с помощью запроса на обновление с помощью Spring JDBC. Мы обновим доступные записи в таблице учеников.
Студенческий стол
CREATE TABLE Student( ID INT NOT NULL AUTO_INCREMENT, NAME VARCHAR(20) NOT NULL, AGE INT NOT NULL, IMAGE BLOB, PRIMARY KEY (ID) );
Синтаксис
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);
Куда,
-
in — объект SqlParameterSource для передачи параметра для обновления запроса.
-
SqlLobValue — Объект для представления параметра значения SQL BLOB / CLOB.
-
jdbcTemplateObject — объект NamedParameterJdbcTemplate для обновления объекта ученика в базе данных.
in — объект SqlParameterSource для передачи параметра для обновления запроса.
SqlLobValue — Объект для представления параметра значения SQL BLOB / CLOB.
jdbcTemplateObject — объект NamedParameterJdbcTemplate для обновления объекта ученика в базе данных.
Чтобы понять вышеупомянутые концепции, связанные с Spring JDBC, давайте напишем пример, который обновит запрос. Чтобы написать наш пример, давайте создадим рабочую среду Eclipse и используем следующие шаги для создания приложения Spring.
| шаг | Описание |
|---|---|
| 1 | Обновление проекта Student создано в главе Spring JDBC — First Application . |
| 2 | Обновите конфигурацию компонента и запустите приложение, как описано ниже. |
Ниже приводится содержимое файла интерфейса объекта доступа к данным StudentDAO.java .
package com.tutorialspoint;
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.tutorialspoint;
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.tutorialspoint;
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;
}
}
Ниже приведен файл класса реализации StudentJDBCTemplate.java для определенного интерфейса DAO StudentDAO.
package com.tutorialspoint;
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.tutorialspoint;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.tutorialspoint.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.tutorialspoint.StudentJDBCTemplate">
<property name = "dataSource" ref = "dataSource" />
</bean>
</beans>
Как только вы закончили создавать файлы конфигурации исходного кода и bean-компонента, давайте запустим приложение Если с вашим приложением все в порядке, оно напечатает следующее сообщение.
Updated Record with ID = 1
Вы можете проверить сохраненный байт [], запросив базу данных.
Spring JDBC — Обработка CLOB
В следующем примере показано, как обновить CLOB с помощью запроса на обновление с помощью Spring JDBC. Мы обновим доступные записи в таблице учеников.
Студенческий стол
CREATE TABLE Student( ID INT NOT NULL AUTO_INCREMENT, NAME VARCHAR(20) NOT NULL, AGE INT NOT NULL, DESCRIPTION LONGTEXT, PRIMARY KEY (ID) );
Синтаксис
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);
Куда,
-
in — объект SqlParameterSource для передачи параметра для обновления запроса.
-
SqlLobValue — Объект для представления параметра значения SQL BLOB / CLOB.
-
jdbcTemplateObject — объект NamedParameterJdbcTemplate для обновления объекта ученика в базе данных.
in — объект SqlParameterSource для передачи параметра для обновления запроса.
SqlLobValue — Объект для представления параметра значения SQL BLOB / CLOB.
jdbcTemplateObject — объект NamedParameterJdbcTemplate для обновления объекта ученика в базе данных.
Чтобы понять вышеупомянутые концепции, связанные с Spring JDBC, давайте напишем пример, который обновит запрос. Чтобы написать наш пример, давайте создадим рабочую среду Eclipse и используем следующие шаги для создания приложения Spring.
| шаг | Описание |
|---|---|
| 1 | Обновление проекта Student создано в главе Spring JDBC — First Application . |
| 2 | Обновите конфигурацию компонента и запустите приложение, как описано ниже. |
Ниже приводится содержимое файла интерфейса объекта доступа к данным StudentDAO.java .
package com.tutorialspoint;
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.tutorialspoint;
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.tutorialspoint;
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;
}
}
Ниже приведен файл класса реализации StudentJDBCTemplate.java для определенного интерфейса DAO StudentDAO.
package com.tutorialspoint;
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.tutorialspoint;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.tutorialspoint.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.tutorialspoint.StudentJDBCTemplate">
<property name = "dataSource" ref = "dataSource" />
</bean>
</beans>
Как только вы закончили создавать файлы конфигурации исходного кода и bean-компонента, давайте запустим приложение Если с вашим приложением все в порядке, оно напечатает следующее сообщение.
Updated Record with ID = 1
Вы можете проверить сохраненное описание, запросив базу данных.
Spring JDBC — пакетная операция
В следующем примере показано, как выполнить пакетное обновление с использованием Spring JDBC. Мы обновим доступные записи в таблице Student за одну пакетную операцию.
Синтаксис
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();
}
});
Куда,
-
SQL — Обновить запрос, чтобы обновить возраст ученика.
-
jdbcTemplateObject — объект StudentJDBCTemplate для обновления объекта ученика в базе данных.
-
BatchPreparedStatementSetter — Исполнитель пакета, задайте значения в PerparedStatement для элемента, определенного списком объектов ученика и индексом i. getBatchSize () возвращает размер пакета.
-
updateCounts — массив Int, содержащий обновленное количество строк для каждого запроса на обновление.
SQL — Обновить запрос, чтобы обновить возраст ученика.
jdbcTemplateObject — объект StudentJDBCTemplate для обновления объекта ученика в базе данных.
BatchPreparedStatementSetter — Исполнитель пакета, задайте значения в PerparedStatement для элемента, определенного списком объектов ученика и индексом i. getBatchSize () возвращает размер пакета.
updateCounts — массив Int, содержащий обновленное количество строк для каждого запроса на обновление.
Чтобы понять вышеупомянутые концепции, относящиеся к Spring JDBC, давайте напишем пример, который обновит пакетную операцию. Чтобы написать наш пример, давайте создадим рабочую среду Eclipse и используем следующие шаги для создания приложения Spring.
| шаг | Описание |
|---|---|
| 1 | Обновление проекта Student создано в главе Spring JDBC — First Application . |
| 2 | Обновите конфигурацию компонента и запустите приложение, как описано ниже. |
Ниже приводится содержимое файла интерфейса объекта доступа к данным StudentDAO.java .
package com.tutorialspoint;
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.tutorialspoint;
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.tutorialspoint;
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;
}
}
Ниже приведен файл класса реализации StudentJDBCTemplate.java для определенного интерфейса DAO StudentDAO.
package com.tutorialspoint;
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.tutorialspoint;
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.tutorialspoint.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 — пакетная операция с объектами
В следующем примере показано, как выполнить пакетное обновление с использованием объектов в Spring JDBC. Мы обновим доступные записи в таблице Student за одну пакетную операцию.
Синтаксис
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!");
Куда,
-
SQL — Обновить запрос, чтобы обновить возраст ученика.
-
jdbcTemplateObject — объект StudentJDBCTemplate для обновления объекта ученика в базе данных.
-
batch — объект SqlParameterSource для представления пакета объекта.
-
updateCounts — массив Int, содержащий обновленное количество строк для каждого запроса на обновление.
SQL — Обновить запрос, чтобы обновить возраст ученика.
jdbcTemplateObject — объект StudentJDBCTemplate для обновления объекта ученика в базе данных.
batch — объект SqlParameterSource для представления пакета объекта.
updateCounts — массив Int, содержащий обновленное количество строк для каждого запроса на обновление.
Чтобы понять вышеупомянутые концепции, относящиеся к Spring JDBC, давайте напишем пример, который обновит пакетную операцию. Чтобы написать наш пример, давайте создадим рабочую среду Eclipse и используем следующие шаги для создания приложения Spring.
| шаг | Описание |
|---|---|
| 1 | Обновление проекта Student создано в главе Spring JDBC — First Application . |
| 2 | Обновите конфигурацию компонента и запустите приложение, как описано ниже. |
Ниже приводится содержимое файла интерфейса объекта доступа к данным StudentDAO.java .
package com.tutorialspoint;
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.tutorialspoint;
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.tutorialspoint;
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;
}
}
Ниже приведен файл класса реализации StudentJDBCTemplate.java для определенного интерфейса DAO StudentDAO.
package com.tutorialspoint;
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.tutorialspoint;
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.tutorialspoint.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 — операция с несколькими партиями
В следующем примере будет показано, как сделать несколько пакетных обновлений за один вызов с помощью Spring JDBC. Мы обновим доступные записи в таблице Student в многократной пакетной операции, где размер пакета равен 1.
Синтаксис
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());
}
});
Куда,
-
SQL — Обновить запрос, чтобы обновить возраст ученика.
-
jdbcTemplateObject — объект StudentJDBCTemplate для обновления объекта ученика в базе данных.
-
ParameterizedPreparedStatementSetter — Пакетный исполнитель, задающий значения в PerparedStatement для каждого элемента, идентифицируемого списком объектов ученика.
-
updateCounts — Int [] [] массив, содержащий обновленное количество строк на запрос на обновление для пакета.
SQL — Обновить запрос, чтобы обновить возраст ученика.
jdbcTemplateObject — объект StudentJDBCTemplate для обновления объекта ученика в базе данных.
ParameterizedPreparedStatementSetter — Пакетный исполнитель, задающий значения в PerparedStatement для каждого элемента, идентифицируемого списком объектов ученика.
updateCounts — Int [] [] массив, содержащий обновленное количество строк на запрос на обновление для пакета.
Чтобы понять вышеупомянутые концепции, связанные с Spring JDBC, давайте напишем пример, который обновит многократную пакетную операцию. Чтобы написать наш пример, давайте создадим рабочую среду Eclipse и используем следующие шаги для создания приложения Spring.
| шаг | Описание |
|---|---|
| 1 | Обновление проекта Student создано в главе Spring JDBC — First Application . |
| 2 | Обновите конфигурацию компонента и запустите приложение, как описано ниже. |
Ниже приводится содержимое файла интерфейса объекта доступа к данным StudentDAO.java .
package com.tutorialspoint;
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.tutorialspoint;
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.tutorialspoint;
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;
}
}
Ниже приведен файл класса реализации StudentJDBCTemplate.java для определенного интерфейса DAO StudentDAO.
package com.tutorialspoint;
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.tutorialspoint;
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.tutorialspoint.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
Класс org.springframework.jdbc.core.JdbcTemplate является центральным классом в базовом пакете JDBC. Это упрощает использование JDBC и помогает избежать распространенных ошибок. Он выполняет основной рабочий процесс JDBC, оставляя код приложения для предоставления SQL и извлечения результатов. Этот класс выполняет запросы или обновления SQL, инициируя итерацию по ResultSets и перехватывая исключения JDBC и переводя их в общую, более информативную иерархию исключений, определенную в пакете org.springframework.dao .
Декларация класса
Ниже приводится объявление для класса org.springframework.jdbc.core.JdbcTemplate —
public class JdbcTemplate
extends JdbcAccessor
implements JdbcOperations
использование
Шаг 1 — Создайте объект JdbcTemplate, используя настроенный источник данных.
Шаг 2 — Используйте объектные методы JdbcTemplate для выполнения операций с базой данных.
пример
В следующем примере будет показано, как прочитать запрос с использованием класса JdbcTemplate. Мы будем читать доступные записи в таблице учеников.
Синтаксис
String selectQuery = "select * from Student"; List <Student> students = jdbcTemplateObject.query(selectQuery, new StudentMapper());
Куда,
-
selectQuery — Выберите запрос для чтения студентов.
-
jdbcTemplateObject — объект StudentJDBCTemplate для чтения объекта ученика из базы данных.
-
StudentMapper — StudentMapper — это объект RowMapper для сопоставления каждой извлеченной записи с объектом ученика.
selectQuery — Выберите запрос для чтения студентов.
jdbcTemplateObject — объект StudentJDBCTemplate для чтения объекта ученика из базы данных.
StudentMapper — StudentMapper — это объект RowMapper для сопоставления каждой извлеченной записи с объектом ученика.
Чтобы понять вышеупомянутые концепции, связанные с Spring JDBC, давайте напишем пример, который выберет запрос. Чтобы написать наш пример, давайте создадим рабочую среду Eclipse и используем следующие шаги для создания приложения Spring.
| шаг | Описание |
|---|---|
| 1 | Обновление проекта Student создано в главе Spring JDBC — First Application . |
| 2 | Обновите конфигурацию компонента и запустите приложение, как описано ниже. |
Ниже приводится содержимое файла интерфейса объекта доступа к данным StudentDAO.java .
package com.tutorialspoint;
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.tutorialspoint;
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.tutorialspoint;
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;
}
}
Ниже приведен файл класса реализации StudentJDBCTemplate.java для определенного интерфейса DAO StudentDAO.
package com.tutorialspoint;
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.tutorialspoint;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.tutorialspoint.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.tutorialspoint.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
Интерфейс org.springframework.jdbc.core.PreparedStatementSetter действует как общий интерфейс обратного вызова, используемый классом JdbcTemplate. Этот интерфейс устанавливает значения для PreparedStatement, предоставляемого классом JdbcTemplate, для каждого из нескольких обновлений в пакете, использующих один и тот же SQL.
Реализации несут ответственность за установку любых необходимых параметров. SQL с заполнителями уже будет предоставлен. Этот интерфейс проще использовать, чем PreparedStatementCreator. JdbcTemplate создаст PreparedStatement с обратным вызовом, отвечающим только за установку значений параметров.
Декларация интерфейса
Ниже приводится объявление для интерфейса org.springframework.jdbc.core.PreparedStatementSetter —
public interface PreparedStatementSetter
использование
Шаг 1 — Создайте объект JdbcTemplate, используя настроенный источник данных.
Шаг 2. Использование методов объекта JdbcTemplate для выполнения операций с базой данных при передаче объекта PreparedStatementSetter для замены заполнителей в запросе.
пример
В следующем примере будет показано, как прочитать запрос, используя класс JdbcTemplate и интерфейс PreparedStatementSetter. Мы прочтем доступную запись студента в таблице учеников.
Синтаксис
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());
Куда,
-
SQL — Выберите запрос для чтения студентов.
-
jdbcTemplateObject — объект StudentJDBCTemplate для чтения объекта ученика из базы данных.
-
PreparedStatementSetter — PreparedStatementSetter объект для установки параметров в запросе.
-
StudentMapper — StudentMapper — это объект RowMapper для сопоставления каждой извлеченной записи с объектом ученика.
SQL — Выберите запрос для чтения студентов.
jdbcTemplateObject — объект StudentJDBCTemplate для чтения объекта ученика из базы данных.
PreparedStatementSetter — PreparedStatementSetter объект для установки параметров в запросе.
StudentMapper — StudentMapper — это объект RowMapper для сопоставления каждой извлеченной записи с объектом ученика.
Чтобы понять вышеупомянутые концепции, связанные с Spring JDBC, давайте напишем пример, который выберет запрос. Чтобы написать наш пример, давайте создадим рабочую среду Eclipse и используем следующие шаги для создания приложения Spring.
| шаг | Описание |
|---|---|
| 1 | Обновление проекта Student создано в главе Spring JDBC — First Application . |
| 2 | Обновите конфигурацию компонента и запустите приложение, как описано ниже. |
Ниже приводится содержимое файла интерфейса объекта доступа к данным StudentDAO.java .
package com.tutorialspoint;
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.tutorialspoint;
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.tutorialspoint;
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;
}
}
Ниже приведен файл класса реализации StudentJDBCTemplate.java для определенного интерфейса DAO StudentDAO.
package com.tutorialspoint;
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.tutorialspoint;
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.tutorialspoint.StudentJDBCTemplate">
<property name = "dataSource" ref = "dataSource" />
</bean>
</beans>
Как только вы закончили создавать файлы конфигурации исходного кода и bean-компонента, давайте запустим приложение Если с вашим приложением все в порядке, оно напечатает следующее сообщение.
ID : 1, Age : 17
Spring JDBC — интерфейс ResultSetExtractor
Интерфейс org.springframework.jdbc.core.ResultSetExtractor — это интерфейс обратного вызова, используемый методами запросов JdbcTemplate. Реализации этого интерфейса выполняют фактическую работу по извлечению результатов из ResultSet, но не нужно беспокоиться об обработке исключений.
SQLExceptions будет перехвачен и обработан вызывающим JdbcTemplate. Этот интерфейс в основном используется в самой структуре JDBC. RowMapper обычно является более простым выбором для обработки ResultSet, отображая один результирующий объект на строку вместо одного результирующего объекта для всего ResultSet.
Декларация интерфейса
Ниже приводится объявление для интерфейса org.springframework.jdbc.core.ResultSetExtractor —
public interface ResultSetExtractor
использование
Шаг 1 — Создайте объект JdbcTemplate, используя настроенный источник данных.
Шаг 2. Используйте методы объекта JdbcTemplate для выполнения операций с базой данных при анализе результирующего набора с помощью ResultSetExtractor.
пример
В следующем примере будет показано, как прочитать запрос, используя класс JdbcTemplate и интерфейс ResultSetExtractor. Мы прочтем доступную запись студента в таблице учеников.
Синтаксис
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;
}
Куда,
-
SQL — Выберите запрос для чтения студентов.
-
jdbcTemplateObject — объект StudentJDBCTemplate для чтения объекта ученика из базы данных.
-
ResultSetExtractor — ResultSetExtractor объект для анализа объекта набора результатов.
SQL — Выберите запрос для чтения студентов.
jdbcTemplateObject — объект StudentJDBCTemplate для чтения объекта ученика из базы данных.
ResultSetExtractor — ResultSetExtractor объект для анализа объекта набора результатов.
Чтобы понять вышеупомянутые концепции, связанные с Spring JDBC, давайте напишем пример, который выберет запрос. Чтобы написать наш пример, давайте создадим рабочую среду Eclipse и используем следующие шаги для создания приложения Spring.
| шаг | Описание |
|---|---|
| 1 | Обновление проекта Student создано в главе Spring JDBC — First Application . |
| 2 | Обновите конфигурацию компонента и запустите приложение, как описано ниже. |
Ниже приводится содержимое файла интерфейса объекта доступа к данным StudentDAO.java .
package com.tutorialspoint;
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.tutorialspoint;
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;
}
}
Ниже приведен файл класса реализации StudentJDBCTemplate.java для определенного интерфейса DAO StudentDAO.
package com.tutorialspoint;
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.tutorialspoint;
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.tutorialspoint.StudentJDBCTemplate">
<property name = "dataSource" ref = "dataSource" />
</bean>
</beans>
Как только вы закончили создавать файлы конфигурации исходного кода и bean-компонента, давайте запустим приложение Если с вашим приложением все в порядке, оно напечатает следующее сообщение.
ID : 1, Age : 17 ID : 3, Age : 18
Spring JDBC — интерфейс RowMapper
Интерфейс org.springframework.jdbc.core.RowMapper <T> используется JdbcTemplate для отображения строк ResultSet для каждой строки. Реализации этого интерфейса выполняют фактическую работу по отображению каждой строки в объект результата. SQLExceptions, если какой-либо бросок будет перехвачен вызывающей JdbcTemplate.
Декларация интерфейса
Ниже приводится объявление для интерфейса org.springframework.jdbc.core.RowMapper <T> —
public interface RowMapper<T>
использование
Шаг 1 — Создайте объект JdbcTemplate, используя настроенный источник данных.
Шаг 2 — Создайте объект StudentMapper, реализующий интерфейс RowMapper.
Шаг 3 — Используйте методы объекта JdbcTemplate для выполнения операций с базой данных при использовании объекта StudentMapper.
Следующий пример продемонстрирует, как прочитать запрос с помощью Spring JDBC. Мы отобразим прочитанные записи из таблицы Student в объект Student с помощью объекта StudentMapper.
Синтаксис
String SQL = "select * from Student"; List <Student> students = jdbcTemplateObject.query(SQL, new StudentMapper());
куда
-
SQL — чтение запроса, чтобы прочитать все студенческие записи.
-
jdbcTemplateObject — объект StudentJDBCTemplate для чтения студенческих записей из базы данных.
-
StudentMapper — объект StudentMapper для сопоставления записей учащихся с объектами учащихся.
SQL — чтение запроса, чтобы прочитать все студенческие записи.
jdbcTemplateObject — объект StudentJDBCTemplate для чтения студенческих записей из базы данных.
StudentMapper — объект StudentMapper для сопоставления записей учащихся с объектами учащихся.
Чтобы понять вышеупомянутые концепции, относящиеся к Spring JDBC, давайте напишем пример, который будет читать запрос и отображать результат с использованием объекта StudentMapper. Чтобы написать наш пример, давайте создадим рабочую среду Eclipse и используем следующие шаги для создания приложения Spring.
| шаг | Описание |
|---|---|
| 1 | Обновление проекта Student создано в главе Spring JDBC — First Application . |
| 2 | Обновите конфигурацию компонента и запустите приложение, как описано ниже. |
Ниже приводится содержимое файла интерфейса объекта доступа к данным StudentDao.java.
package com.tutorialspoint;
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.tutorialspoint;
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.tutorialspoint;
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;
}
}
Ниже приведен файл класса реализации StudentJDBCTemplate.java для определенного интерфейса DAO StudentDAO.
package com.tutorialspoint;
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.tutorialspoint;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.tutorialspoint.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.tutorialspoint.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, позволяющий использовать именованные параметры, а не традиционный ‘?’ заполнители. Этот класс делегирует обернутую JdbcTemplate после замены именованных параметров на стиль JDBC ‘?’ заполнители делается во время исполнения. Это также позволяет расширить список значений до соответствующего количества заполнителей.
Декларация интерфейса
Ниже приводится объявление для класса org.springframework.jdbc.core.NamedParameterJdbcTemplate —
public class NamedParameterJdbcTemplate
extends Object
implements NamedParameterJdbcOperations
Синтаксис
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);
Куда,
-
in — объект SqlParameterSource для передачи параметра для обновления запроса.
-
SqlLobValue — Объект для представления параметра значения SQL BLOB / CLOB.
-
jdbcTemplateObject — объект NamedParameterJdbcTemplate для обновления объекта ученика в базе данных.
in — объект SqlParameterSource для передачи параметра для обновления запроса.
SqlLobValue — Объект для представления параметра значения SQL BLOB / CLOB.
jdbcTemplateObject — объект NamedParameterJdbcTemplate для обновления объекта ученика в базе данных.
Чтобы понять вышеупомянутые концепции, связанные с Spring JDBC, давайте напишем пример, который обновит запрос. Чтобы написать наш пример, давайте создадим рабочую среду Eclipse и используем следующие шаги для создания приложения Spring.
| шаг | Описание |
|---|---|
| 1 | Обновление проекта Student создано в главе Spring JDBC — First Application . |
| 2 | Обновите конфигурацию компонента и запустите приложение, как описано ниже. |
Ниже приводится содержимое файла интерфейса объекта доступа к данным StudentDAO.java .
package com.tutorialspoint;
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.tutorialspoint;
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.tutorialspoint;
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;
}
}
Ниже приведен файл класса реализации StudentJDBCTemplate.java для определенного интерфейса DAO StudentDAO.
package com.tutorialspoint;
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.tutorialspoint;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.tutorialspoint.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.tutorialspoint.StudentJDBCTemplate">
<property name = "dataSource" ref = "dataSource" />
</bean>
</beans>
Как только вы закончили создавать файлы конфигурации исходного кода и bean-компонента, давайте запустим приложение Если с вашим приложением все в порядке, оно напечатает следующее сообщение.
Updated Record with ID = 1
Вы можете проверить сохраненное описание, запросив базу данных.
Spring JDBC — класс SimpleJdbcInsert
Класс org.springframework.jdbc.core.SimpleJdbcInsert является многопоточным, многократно используемым объектом, обеспечивающим легкие возможности вставки для таблицы. Он обеспечивает обработку метаданных для упрощения кода, необходимого для создания базового оператора вставки. Фактическая вставка обрабатывается с использованием Spring JdbcTemplate
Декларация класса
Ниже приводится объявление для класса org.springframework.jdbc.core.SimpleJdbcInsert —
public class SimpleJdbcInsert
extends AbstractJdbcInsert
implements SimpleJdbcInsertOperations
Следующий пример продемонстрирует, как вставить запрос с помощью Spring JDBC. Мы вставим одну запись в таблицу учеников, используя объект SimpleJdbcInsert.
Синтаксис
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);
Куда,
-
jdbcInsert — объект SimpleJdbcInsert для вставки записи в таблицу ученика.
-
jdbcTemplateObject — объект StudentJDBCTemplate для чтения объекта ученика в базе данных.
jdbcInsert — объект SimpleJdbcInsert для вставки записи в таблицу ученика.
jdbcTemplateObject — объект StudentJDBCTemplate для чтения объекта ученика в базе данных.
Чтобы понять вышеупомянутые концепции, связанные с Spring JDBC, давайте напишем пример, который вставит запрос. Чтобы написать наш пример, давайте создадим рабочую среду Eclipse и используем следующие шаги для создания приложения Spring.
| шаг | Описание |
|---|---|
| 1 | Обновление проекта Student создано в главе Spring JDBC — First Application . |
| 2 | Обновите конфигурацию компонента и запустите приложение, как описано ниже. |
Ниже приводится содержимое файла интерфейса объекта доступа к данным StudentDAO.java .
package com.tutorialspoint;
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.tutorialspoint;
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.tutorialspoint;
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;
}
}
Ниже приведен файл класса реализации StudentJDBCTemplate.java для определенного интерфейса DAO StudentDAO.
package com.tutorialspoint;
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.tutorialspoint;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.tutorialspoint.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.tutorialspoint.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
Класс org.springframework.jdbc.core.SimpleJdbcCall — это многопоточный, многократно используемый объект, представляющий вызов хранимой процедуры или хранимой функции. Он обеспечивает обработку метаданных для упрощения кода, необходимого для доступа к основным хранимым процедурам / функциям.
Все, что вам нужно предоставить, — это имя процедуры / функции и карту, содержащую параметры при выполнении вызова. Имена предоставленных параметров будут сопоставляться с параметрами входа и выхода, объявленными при создании хранимой процедуры.
Декларация класса
Ниже приводится объявление для класса org.springframework.jdbc.core.SimpleJdbcCall —
public class SimpleJdbcCall
extends AbstractJdbcCall
implements SimpleJdbcCallOperations
В следующем примере будет показано, как вызвать хранимую процедуру с помощью Spring SimpleJdbcCall. Мы прочитаем одну из доступных записей в таблице учеников, вызвав хранимую процедуру. Мы передадим идентификатор и получим студенческий билет.
Синтаксис
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"));
Куда,
-
jdbcCall — объект SimpleJdbcCall для представления хранимой процедуры.
-
in — объект SqlParameterSource для передачи параметра хранимой процедуре.
-
студент — объект студента.
-
out — сопоставить объект для отображения результата вызова хранимой процедуры.
jdbcCall — объект SimpleJdbcCall для представления хранимой процедуры.
in — объект SqlParameterSource для передачи параметра хранимой процедуре.
студент — объект студента.
out — сопоставить объект для отображения результата вызова хранимой процедуры.
Чтобы понять вышеупомянутые концепции, относящиеся к Spring JDBC, давайте напишем пример, который будет вызывать хранимую процедуру. Чтобы написать наш пример, давайте создадим рабочую среду Eclipse и используем следующие шаги для создания приложения Spring.
| шаг | Описание |
|---|---|
| 1 | Обновление проекта Student создано в главе Spring JDBC — First Application . |
| 2 | Обновите конфигурацию компонента и запустите приложение, как описано ниже. |
Ниже приводится содержимое файла интерфейса объекта доступа к данным StudentDAO.java .
package com.tutorialspoint;
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.tutorialspoint;
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.tutorialspoint;
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;
}
}
Ниже приведен файл класса реализации StudentJDBCTemplate.java для определенного интерфейса DAO StudentDAO.
package com.tutorialspoint;
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;
}
}
Код, который вы пишете для выполнения вызова, включает в себя создание SqlParameterSource, содержащего параметр IN. Важно сопоставить имя, указанное для входного значения, с именем параметра, объявленного в хранимой процедуре. Метод execute принимает параметры IN и возвращает карту, содержащую любые параметры out, введенные по имени, как указано в хранимой процедуре.
Ниже приводится содержание файла MainApp.java .
package com.tutorialspoint;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.tutorialspoint.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.tutorialspoint.StudentJDBCTemplate">
<property name = "dataSource" ref = "dataSource" />
</bean>
</beans>
Как только вы закончили создавать файлы конфигурации исходного кода и bean-компонента, давайте запустим приложение Если с вашим приложением все в порядке, оно напечатает следующее сообщение.
ID : 1, Name : Zara, Age : 11
Spring JDBC — класс SqlQuery
Класс org.springframework.jdbc.object.SqlQuery предоставляет многократно используемый объект операции, представляющий запрос SQL.
Декларация класса
Ниже приводится объявление для класса org.springframework.jdbc.object.SqlQuery —
public abstract class SqlQuery<T> extends SqlOperation
использование
-
Шаг 1 — Создайте объект JdbcTemplate, используя настроенный источник данных.
-
Шаг 2 — Создайте объект StudentMapper, реализующий интерфейс RowMapper.
-
Шаг 3 — Используйте методы объекта JdbcTemplate для выполнения операций с базой данных при использовании объекта SqlQuery.
Шаг 1 — Создайте объект JdbcTemplate, используя настроенный источник данных.
Шаг 2 — Создайте объект StudentMapper, реализующий интерфейс RowMapper.
Шаг 3 — Используйте методы объекта JdbcTemplate для выполнения операций с базой данных при использовании объекта SqlQuery.
Следующий пример продемонстрирует, как читать Query, используя SqlQuery Object. Мы отобразим прочитанные записи из таблицы Student в объект Student с помощью объекта StudentMapper.
Синтаксис
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();
Куда,
-
SQL — чтение запроса, чтобы прочитать все студенческие записи.
-
jdbcTemplateObject — объект StudentJDBCTemplate для чтения студенческих записей из базы данных.
-
StudentMapper — объект StudentMapper для сопоставления записей учащихся с объектами учащихся.
-
SqlQuery — объект SqlQuery для запроса записей о студентах и сопоставления их с объектами студентов.
SQL — чтение запроса, чтобы прочитать все студенческие записи.
jdbcTemplateObject — объект StudentJDBCTemplate для чтения студенческих записей из базы данных.
StudentMapper — объект StudentMapper для сопоставления записей учащихся с объектами учащихся.
SqlQuery — объект SqlQuery для запроса записей о студентах и сопоставления их с объектами студентов.
Чтобы понять вышеупомянутые концепции, связанные с Spring JDBC, давайте напишем пример, который будет читать запрос и отображать результат с помощью объекта StudentMapper. Чтобы написать наш пример, давайте создадим рабочую среду Eclipse и используем следующие шаги для создания приложения Spring.
| шаг | Описание |
|---|---|
| 1 | Обновление проекта Student создано в главе Spring JDBC — First Application . |
| 2 | Обновите конфигурацию компонента и запустите приложение, как описано ниже. |
Ниже приводится содержимое файла интерфейса объекта доступа к данным StudentDao.java.
package com.tutorialspoint;
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.tutorialspoint;
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.tutorialspoint;
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;
}
}
Ниже приведен файл класса реализации StudentJDBCTemplate.java для определенного интерфейса DAO StudentDAO.
package com.tutorialspoint;
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.tutorialspoint;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.tutorialspoint.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.tutorialspoint.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
Класс org.springframework.jdbc.object.SqlUpdate предоставляет повторно используемый объект операции, представляющий обновление SQL.
Декларация класса
Ниже приводится объявление для класса org.springframework.jdbc.object.SqlUpdate —
public abstract class SqlUpdate<T> extends SqlOperation
использование
Шаг 1 — Создайте объект JdbcTemplate, используя настроенный источник данных.
Шаг 2 — Создайте объект StudentMapper, реализующий интерфейс RowMapper.
Шаг 3 — Используйте методы объекта JdbcTemplate для выполнения операций с базой данных при использовании объекта SqlUpdate.
В следующем примере будет показано, как обновить запрос с помощью объекта SqlUpdate. Мы отобразим записи обновления из таблицы Student в объект Student с помощью объекта StudentMapper.
Синтаксис
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());
Куда,
-
SQL — Обновить запрос для обновления студенческих записей.
-
jdbcTemplateObject — объект StudentJDBCTemplate для чтения студенческих записей из базы данных.
-
StudentMapper — объект StudentMapper для сопоставления записей учащихся с объектами учащихся.
-
sqlUpdate — объект SqlUpdate для обновления студенческих записей.
SQL — Обновить запрос для обновления студенческих записей.
jdbcTemplateObject — объект StudentJDBCTemplate для чтения студенческих записей из базы данных.
StudentMapper — объект StudentMapper для сопоставления записей учащихся с объектами учащихся.
sqlUpdate — объект SqlUpdate для обновления студенческих записей.
Чтобы понять вышеупомянутые концепции, относящиеся к Spring JDBC, давайте напишем пример, который будет читать запрос и отображать результат с использованием объекта StudentMapper. Чтобы написать наш пример, давайте создадим рабочую среду Eclipse и используем следующие шаги для создания приложения Spring.
| шаг | Описание |
|---|---|
| 1 | Обновление проекта Student создано в главе Spring JDBC — First Application . |
| 2 | Обновите конфигурацию компонента и запустите приложение, как описано ниже. |
Ниже приводится содержимое файла интерфейса объекта доступа к данным StudentDao.java.
package com.tutorialspoint;
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.tutorialspoint;
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.tutorialspoint;
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;
}
}
Ниже приведен файл класса реализации StudentJDBCTemplate.java для определенного интерфейса DAO StudentDAO.
package com.tutorialspoint;
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.tutorialspoint;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.tutorialspoint.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.tutorialspoint.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
Класс org.springframework.jdbc.core.StoredProcedure является суперклассом для абстракций объектов хранимых процедур RDBMS. Этот класс является абстрактным, и предполагается, что подклассы будут предоставлять типизированный метод для вызова, который делегирует предоставленному методу execute (java.lang.Object …). Унаследованное свойство SQL — это имя хранимой процедуры в СУБД.
Декларация класса
Ниже приводится объявление для класса org.springframework.jdbc.core.StoredProcedure —
public abstract class StoredProcedure extends SqlCall
В следующем примере будет показано, как вызвать хранимую процедуру с помощью Spring StoredProcedure. Мы прочитаем одну из доступных записей в таблице учеников, вызвав хранимую процедуру. Мы передадим идентификатор и получим студенческий билет.
Синтаксис
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;
}
}
Куда,
-
StoredProcedure — объект StoredProcedure для представления хранимой процедуры.
-
StudentProcedure — объект StudentProcedure расширяет StoredProcedure для объявления ввода, выходной переменной и сопоставления результата с объектом Student.
-
студент — объект студента.
StoredProcedure — объект StoredProcedure для представления хранимой процедуры.
StudentProcedure — объект StudentProcedure расширяет StoredProcedure для объявления ввода, выходной переменной и сопоставления результата с объектом Student.
студент — объект студента.
Чтобы понять вышеупомянутые концепции, относящиеся к Spring JDBC, давайте напишем пример, который будет вызывать хранимую процедуру. Чтобы написать наш пример, давайте создадим рабочую среду Eclipse и используем следующие шаги для создания приложения Spring.
| шаг | Описание |
|---|---|
| 1 | Обновление проекта Student создано в главе Spring JDBC — First Application . |
| 2 | Обновите конфигурацию компонента и запустите приложение, как описано ниже. |
Ниже приводится содержимое файла интерфейса объекта доступа к данным StudentDAO.java .
package com.tutorialspoint;
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.tutorialspoint;
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.tutorialspoint;
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;
}
}
Ниже приведен файл класса реализации StudentJDBCTemplate.java для определенного интерфейса DAO StudentDAO.
package com.tutorialspoint;
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;
}
}
Код, который вы пишете для выполнения вызова, включает в себя создание SqlParameterSource, содержащего параметр IN. Важно сопоставить имя, указанное для входного значения, с именем параметра, объявленного в хранимой процедуре. Метод execute принимает параметры IN и возвращает карту, содержащую любые параметры out, введенные по имени, как указано в хранимой процедуре.
Ниже приводится содержание файла MainApp.java .
package com.tutorialspoint;
import java.util.List;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import com.tutorialspoint.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.tutorialspoint.StudentJDBCTemplate">
<property name = "dataSource" ref = "dataSource" />
</bean>
</beans>
Как только вы закончили создавать файлы конфигурации исходного кода и bean-компонента, давайте запустим приложение Если с вашим приложением все в порядке, оно напечатает следующее сообщение.