008_Spring Data JPA原生SQL

1. nativeQuery默认的是false, 表示不开启sql查询。表示是否对value中的语句做转义。使用原生sql, 需要开启它。

2. 原生sql中使用的是表名,这要和JPQL语句中使用的是实体类名区分开来。

3. 创建一个名为spring-data-jpa-sql的Java项目, 同时添加相关jar包, 并添加JUnit能力。

4. 新建User.java

package com.bjbs.pojo;import java.io.Serializable;
import java.util.Date;
import javax.persistence.Column;
import javax.persistence.Entity;
import javax.persistence.GeneratedValue;
import javax.persistence.GenerationType;
import javax.persistence.Id;
import javax.persistence.Table;
import org.springframework.format.annotation.DateTimeFormat;@Entity // 指定该类是实体类
@Table(name = "user") // 指定数据库表名(表名和实体类对应)
public class User implements Serializable {private static final long serialVersionUID = 1L;@Id // 指定为主键@GeneratedValue(strategy = GenerationType.IDENTITY) // 指定主键生成策略@Column(name = "id") // 指定表中列名(列名和属性名对应)private Integer id;@Column(name = "name")private String name;@Column(name = "sex")private String sex;@Column(name = "birthday")@DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")private Date birthday;@Column(name = "address")private String address;public User() {}public User(String name, String sex, Date birthday, String address) {this.name = name;this.sex = sex;this.birthday = birthday;this.address = address;}public User(Integer id, String name, String sex, Date birthday, String address) {this.id = id;this.name = name;this.sex = sex;this.birthday = birthday;this.address = address;}public Integer getId() {return id;}public void setId(Integer id) {this.id = id;}public String getName() {return name;}public void setName(String name) {this.name = name;}public String getSex() {return sex;}public void setSex(String sex) {this.sex = sex;}public Date getBirthday() {return birthday;}public void setBirthday(Date birthday) {this.birthday = birthday;}public String getAddress() {return address;}public void setAddress(String address) {this.address = address;}@Overridepublic String toString() {return "User [id=" + id + ", name=" + name + ", sex=" + sex + ", birthday=" + birthday + ", address=" + address+ "]";}
}

5. 新建UserRepository.java, 实现Repository

package com.bjbs.dao;import java.util.Date;
import java.util.List;
import org.springframework.data.jpa.repository.Modifying;
import org.springframework.data.jpa.repository.Query;
import org.springframework.data.repository.Repository;
import com.bjbs.pojo.User;/*** 参数一T: 当前需要映射的实体; 参数二 T: 当前映射的实体中的id的类型*/
public interface UserRepository extends Repository<User, Integer> {// nativeQuery: 默认的是false, 表示不开启sql查询。表示是否对value中的语句做转义。@Query(value="select * from user where name = ?", nativeQuery=true)public User queryUserByName(String name);@Query(value="select * from user where name like ?", nativeQuery=true)public List<User> queryUserByNameLike(String name);@Query(value="select * from user where name = ? and sex >= ?", nativeQuery=true)public User queryUserByNameAndSex(String name, String sex);@Query(value="update user set sex = ? where id = ?", nativeQuery=true)@Modifying //@Modifying当前语句是一个更新语句public Integer updateUserSexById(String sex, Integer id);@Query(value="insert into user(id, name, sex, birthday, address) values(null, ?, ?, ?, ?)", nativeQuery=true)@Modifying public Integer insertUser(String name, String sex, Date birthday, String address);@Query(value="delete from user where id = ?", nativeQuery=true)@Modifying public Integer deleteUserById(Integer id);
}

6. 新建UserService.java

package com.bjbs.service;import java.util.Date;
import java.util.List;
import com.bjbs.pojo.User;public interface UserService {public User queryUserByName(String name);public List<User> queryUserByNameLike(String name);public User queryUserByNameAndSex(String name, String sex);public Integer updateUserSexById(String sex, Integer id);public Integer insertUser(String name, String sex, Date birthday, String address);public Integer deleteUserById(Integer id);
}

7. 新建UserServiceImpl.java

package com.bjbs.service.impl;import java.util.Date;
import java.util.List;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import org.springframework.transaction.annotation.Transactional;
import com.bjbs.dao.UserRepository;
import com.bjbs.pojo.User;
import com.bjbs.service.UserService;@Service
@Transactional
public class UserServiceImpl implements UserService {@Autowiredprivate UserRepository userRepository;@Overridepublic User queryUserByName(String name) {return userRepository.queryUserByName(name);}@Overridepublic List<User> queryUserByNameLike(String name) {return userRepository.queryUserByNameLike(name);}@Overridepublic User queryUserByNameAndSex(String name, String sex) {return userRepository.queryUserByNameAndSex(name, sex);}@Overridepublic Integer updateUserSexById(String sex, Integer id) {return userRepository.updateUserSexById(sex, id);}@Overridepublic Integer insertUser(String name, String sex, Date birthday, String address) {return userRepository.insertUser(name, sex, birthday, address);}@Overridepublic Integer deleteUserById(Integer id) {return userRepository.deleteUserById(id);}
}

8. 新建TestUserRepository.java

package com.bjbs.test;import java.util.Date;
import java.util.List;
import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
import com.bjbs.pojo.User;
import com.bjbs.service.UserService;@RunWith(SpringJUnit4ClassRunner.class)
@ContextConfiguration("classpath:applicationContext.xml")
public class TestUserRepository {@Autowiredprivate UserService userService;/*** 查询名字叫'曹操'的用户*/@Testpublic void queryUserByName() {User userDb = userService.queryUserByName("曹操");System.out.println(userDb);}/*** 查询姓'李'的所有用户*/@Testpublic void queryUserByNameLike() {List<User> list = userService.queryUserByNameLike("李%");for (User user : list) {System.out.println(user);}}/*** 查询名字叫'曹操'并且性别为'男'的用户*/@Testpublic void queryUserByNameAndSex() {User userDb = userService.queryUserByNameAndSex("曹操", "男");System.out.println(userDb);}/*** 通过id更新用户性别*/@Testpublic void updateUserSexById() {int result = userService.updateUserSexById("男", 51);System.out.println("result = " + result);}/*** 通过id删除用户*/@Testpublic void deleteUserById() {int result = userService.deleteUserById(57);System.out.println("result = " + result);}/*** 添加用户*/@Testpublic void insertUser() {int result = userService.insertUser("曹铄", "男", new Date(), "安徽省亳州市");System.out.println("result = " + result);}
}

9. 在src下新建application.properties

spring.datasource.driverClassName=com.mysql.cj.jdbc.Driver
spring.datasource.url=jdbc:mysql://192.168.25.138:3306/StudyMybatis?useSSL=true&useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai
spring.datasource.username=root
spring.datasource.password=lyw123456

10. 在src下新建applicationContext.xml

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns="http://www.springframework.org/schema/beans"xmlns:context="http://www.springframework.org/schema/context"xmlns:tx="http://www.springframework.org/schema/tx"xmlns:jpa="http://www.springframework.org/schema/data/jpa"xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsdhttp://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context.xsdhttp://www.springframework.org/schema/data/jpa http://www.springframework.org/schema/data/jpa/spring-jpa.xsdhttp://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx.xsd"><!-- 配置读取properties文件的工具类 --><context:property-placeholder location="classpath:application.properties" /><!-- 配置c3p0数据库连接池 --><bean id="dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource"><property name="jdbcUrl" value="${spring.datasource.url}" /><property name="driverClass" value="${spring.datasource.driverClassName}" /><property name="user" value="${spring.datasource.username}" /><property name="password" value="${spring.datasource.password}" /></bean><!-- Spring整合JPA 配置EntityManagerFactory --><bean id="entityManagerFactory" class="org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean"><property name="dataSource" ref="dataSource" /><property name="jpaVendorAdapter"><bean class="org.springframework.orm.jpa.vendor.HibernateJpaVendorAdapter"><!-- hibernate相关的属性的注入 --><!-- 配置数据库类型 --><property name="database" value="MYSQL" /><!-- 正向工程 自动创建表 --><!-- <property name="generateDdl" value="true" /> --><!-- 显示执行的SQL --><property name="showSql" value="true" /></bean></property><!-- 扫描实体的包 --><property name="packagesToScan"><list><value>com.bjbs.pojo</value></list></property></bean><!-- 配置Hibernate的事务管理器 --><bean id="transactionManager" class="org.springframework.orm.jpa.JpaTransactionManager"><property name="entityManagerFactory" ref="entityManagerFactory" /></bean><!-- 配置开启注解事务处理 --><tx:annotation-driven transaction-manager="transactionManager" /><!-- 配置springIOC的注解扫描 --><context:component-scan base-package="com.bjbs.service" /><!-- Spring Data JPA 的配置 --><!-- base-package: 扫描dao接口所在的包 --><jpa:repositories base-package="com.bjbs.dao" />
</beans>

11. 数据库user表

12. 查询名字叫'曹操'的用户

13. 查询姓'李'的所有用户

14. 查询名字叫'曹操'并且性别为'男'的用户

15. 通过id更新用户性别

16. 通过id删除用户

17. 添加用户

008_Spring Data JPA原生SQL相关推荐

jpa原生query_Spring Data JPA原生SQL查询
package com.test.cms.dao.repository; import org.springframework.stereotype.Repository; import javax. ...
jpa 原生sql 查询返回一个实体_spring data系列之jpa
Springdata 系列之spring data jpa 背景:随着互联网技术的发展,现在的企业开发中用到的用于数据存储的产品,不再仅仅是关系型数据库,而是要根据场景需要选择不同的存储技术,比如用于 ...
Spring Data JPA 写SQL语句也可以如此简单
在使用 Spring Data JPA 的时候,通常我们只需要继承 JpaRepository 就能获得大部分常用的增删改查的方法.有时候我们需要自定义一些查询方法,可以写自定义 HQL 语句像这样 ...
spring data jpa 执行sql
Update.class,用于创建数据库表 import org.springframework.data.jpa.repository.*; import org.springframework.s ...
Spring Data JPA使用必备(三)：Spring Data JPA自定义SQL写法
Spring Data JPA的前两篇已经写了通过方法名格式自动生成SQL,也简单的提到了@Query注解.但是往往真正的业务逻辑里面,这些是完全不够用的,涉及到一些稍微复杂一点的查询就会有点问题,如 ...
JPA原生sql返回值转自定义实体类
有两个月没更新过CSDN了,裸辞了,半个月前刚入职了新下家,这里适应下新公司的项目技术. 持久层用的是之前没用过的jpa,还好平时多多少少也有学过,上手也快. 用jpa写原生sql的时候,真的想骂人, ...
jpa 原生sql 查询返回一个实体_JPA查询--使用原生sql 并且把查询结果转为实体对象...
这篇文章主要记录使用原生sql查询并且把查询结果转为实体对象, 注意:这儿使用的数据库是oracle数据库这儿记录了三种查询:精确查询,模糊查询,分页查询. 1.把原生sql查询的结果转为实体 ...
JPA原生sql多条件查询
// my_table 是表,MyTable是实体查询字段为name,comment public interface TabelDao extends PagingAndSortingReposi ...
jpa多表联查动态_Spring Data JPA 连表动态条件查询
多表查询在spring data jpa中有两种实现方式,第一种是利用hibernate的级联查询来实现(使用较为复杂,查询不够灵活),第二种是使用原生sql查询. JPA原生SQL连表查询 @Rep ...

008_Spring Data JPA原生SQL

008_Spring Data JPA原生SQL相关推荐

最新文章

热门文章