基于spring boot 1.5.4 集成 jpa+hibernate+jdbcTemplate(详解)
发布时间 - 2026-01-11 01:56:06 点击率:次1.pom添加依赖
<!-- spring data jpa,会注入tomcat jdbc pool/hibernate等 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-jpa</artifactId>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.42</version>
</dependency>
2.添加数据源配置(DataSource啥的,一系列对象spring boot 都会给你注入的,配置配置即可!)
spring.datasource.url=jdbc:mysql://localhost/test?characterEncoding=utf8&useSSL=true spring.datasource.username=root spring.datasource.password=123456 spring.datasource.driver-class-name=com.mysql.jdbc.Driver #database pool config # Number of ms to wait before throwing an exception if no connection is available. spring.datasource.tomcat.max-wait=10000 # Maximum number of active connections that can be allocated from this pool at the same time. spring.datasource.tomcat.max-active=300 # Validate the connection before borrowing it from the pool. spring.datasource.tomcat.test-on-borrow=true # initial pool size spring.datasource.tomcat.initial-size=20 #=====================jpa config================================ #实体类维护数据库表结构的具体行为:update/create/create-drop/validate/none spring.jpa.hibernate.ddl-auto=none #打印sql语句 spring.jpa.show-sql=true #格式化输出的json字符串 spring.jackson.serialization.indent_output=true
3.新建实体
@Entity
@Table(name="user")
public class User {
@Id
@Column(name="id")
@GeneratedValue(strategy = GenerationType.IDENTITY)
private Integer id;
@Column(name="number")
private String number;
@Column(name="name")
private String name;
public Integer getId() {
return id;
}
public void setId(Integer id) {
this.id = id;
}
public String getNumber() {
return number;
}
public void setNumber(String number) {
this.number = number;
}
public String getName() {
return name;
}
public void setName(String name) {
this.name = name;
}
}
4.dao层
public interface UserDao{
User getById(int id);
User getByNumber(String number);
int addUser(User user);
void deleteUserById(int id);
User updateUser(User user);
}
@Repository
public class UserDaoImpl implements UserDao {
@PersistenceContext
private EntityManager entityManager;
@Override
public User getById(int id) {
//find by primary key
return this.entityManager.find(User.class,id);
}
@Override
public User getByNumber(String number) {
Query query = this.entityManager.createQuery("from User u where u.number=:number",User.class);
query.setParameter("number",number);
User user = (User)query.getSingleResult();
return user;
}
@Override
public int addUser(User user) {
this.entityManager.persist(user);
//print the id
System.out.println(user.getId());
return user.getId();
}
@Override
public void deleteUserById(int id) {
User user = this.entityManager.find(User.class,id); //关联到记录,方可删除
this.entityManager.remove(user);
}
@Override
public User updateUser(User user) {
User userNew = this.entityManager.merge(user);
return userNew;
}
}
5.service层
public interface UserService {
User getById(int id);
User getByNumber(String number);
int addUser(User user,boolean throwEx);
void deleteUserById(int id);
User updateUser(User user);
}
@Service
@Transactional
public class UserServiceImpl implements UserService {
@Autowired
private UserDao userDao;
@Override
@Transactional(readOnly = true)
public User getById(int id) {
return userDao.getById(id);
}
@Override
@Transactional(readOnly = true)
public User getByNumber(String number) {
return userDao.getByNumber(number);
}
@Override
public int addUser(User user,boolean throwEx) {
int id= this.userDao.addUser(user);
if(throwEx){
throw new RuntimeException("throw a ex");
}
return id;
}
@Override
public void deleteUserById(int id) {
this.userDao.deleteUserById(id);
}
@Override
public User updateUser(User user) {
return this.userDao.updateUser(user);
}
}
6.controller层
@Controller("user1")
@RequestMapping("/jpa/user")
public class UserController {
/**
* 日志(slf4j->logback)
*/
private static final Logger logger = LoggerFactory.getLogger(UserController.class);
@Autowired
private UserService userService;
/**
* 返回text格式数据
* @param id 主键id
* @return 用户json字符串
*/
@RequestMapping("/get/id/{id}")
@ResponseBody
public String getUserById(@PathVariable("id")String id){
logger.info("request /user/get/id/{id}, parameter is "+id);
User user = userService.getById(Integer.parseInt(id));
return JSONObject.toJSONString(user);
}
/**
* 返回json格式数据
* @param number 编号
* @return 用户
*/
@RequestMapping("/get/number/{number}")
@ResponseBody
public User getUserByNumber(@PathVariable("number")String number){
User user = userService.getByNumber(number);
return user;
}
@RequestMapping("/add/{number}/{name}")
@ResponseBody
public String addUser(@PathVariable("number")String number,@PathVariable("name")String name,boolean throwEx){
User user = new User();
user.setNumber(number);
user.setName(name);
int id = -1;
try{
id = userService.addUser(user,throwEx);
}catch (RuntimeException ex){
System.out.println(ex.getMessage());
}
return String.valueOf(id);
}
@RequestMapping("/delete/{id}")
@ResponseBody
public void getUserById(@PathVariable("id")int id){
this.userService.deleteUserById(id);
}
@RequestMapping("/update/{id}/{number}/{name}")
@ResponseBody
public User addUser(@PathVariable("id")int id, @PathVariable("number")String number, @PathVariable("name")String name){
User user = new User();
user.setId(id);
user.setNumber(number);
user.setName(name);
return userService.updateUser(user);
}
}
7. spring data jpa新使用方式,更高级
1.dao
@Repository
public interface UserRepository extends JpaRepository<User, Integer> {
/**
* spring data jpa 会自动注入实现(根据方法命名规范)
* @return
*/
User findByNumber(String number);
@Modifying
@Query("delete from User u where u.id = :id")
void deleteUser(@Param("id")int id);
}
2.service
public interface UserService {
User findById(int id);
User findByNumber(String number);
List<User> findAllUserByPage(int page,int size);
User updateUser(User user,boolean throwEx);
void deleteUser(int id);
}
@Service
@Transactional
public class UserServiceImpl implements UserService {
@Autowired
private UserRepository userRepository;
@Override
public User findById(int id) {
return this.userRepository.findOne(id);
}
@Override
public User findByNumber(String number) {
return this.userRepository.findByNumber(number);
}
@Override
public List<User> findAllUserByPage(int page,int size) {
Pageable pageable = new PageRequest(page, size);
Page<User> users = this.userRepository.findAll(pageable);
return users.getContent();
}
@Override
public User updateUser(User user,boolean throwEx) {
User userNew = this.userRepository.save(user);
if(throwEx){
throw new RuntimeException("throw a ex");
}
return userNew;
}
@Override
public void deleteUser(int id) {
this.userRepository.deleteUser(id);
}
}
3.controller
@Controller("user2")
@RequestMapping("/datajpa/user")
public class UserController {
/**
* 日志(slf4j->logback)
*/
private static final Logger logger = LoggerFactory.getLogger(UserController.class);
@Autowired
private UserService userService;
/**
* 返回text格式数据
* @param id 主键id
* @return 用户json字符串
*/
@RequestMapping("/get/id/{id}")
@ResponseBody
public String getUserById(@PathVariable("id")String id){
logger.info("request /user/get/id/{id}, parameter is "+id);
User user = userService.findById(Integer.parseInt(id));
return JSONObject.toJSONString(user);
}
/**
* 返回json格式数据
* @param number 编号
* @return 用户
*/
@RequestMapping("/get/number/{number}")
@ResponseBody
public User getUserByNumber(@PathVariable("number")String number){
User user = userService.findByNumber(number);
return user;
}
@RequestMapping("/get/all/{page}/{size}")
@ResponseBody
public List<User> getAllUserByPage(@PathVariable("page")int page,@PathVariable("size")int size){
return this.userService.findAllUserByPage(page,size);
}
@RequestMapping("/update/{id}/{number}/{name}")
@ResponseBody
public User addUser(@PathVariable("id")int id, @PathVariable("number")String number, @PathVariable("name")String name,boolean throwEx){
User user = new User();
user.setId(id);
user.setNumber(number);
user.setName(name);
User userNew = null;
try{
userService.updateUser(user,throwEx);
}catch (RuntimeException ex){
System.out.println(ex.getMessage());
}
return userNew;
}
@RequestMapping("/delete/{id}")
@ResponseBody
public void getUserById(@PathVariable("id")int id){
this.userService.deleteUser(id);
}
}
8.注入jdbcTemplate和transactionTemplate,使用传统方式操作数据库,更加灵活,方法如下
@Autowired
private JdbcTemplate jdbcTemplate;
@Autowired
private TransactionTemplate transactionTemplate;
/**
* 手动控制事物测试
* @param throwEx
*/
@Override
public void testTransactionManually(boolean throwEx) {
try {
transactionTemplate.execute(new TransactionCallback<Boolean>() {
/**
* 事物代码
*
* @param transactionStatus 事物状态
* @return 是否成功
*/
@Override
public Boolean doInTransaction(TransactionStatus transactionStatus) {
User user = new User();
user.setId(1);
int a = new Random().nextInt(10); //0-9
user.setNumber("10000u" + a);
jdbcTemplate.update("UPDATE USER SET NUMBER=? WHERE ID=?", new Object[]{user.getNumber(), user.getId()}, new int[]{Types.VARCHAR, Types.INTEGER});
if (throwEx) {
throw new RuntimeException("try throw exception"); //看看会不会回滚
}
return true;
}
});
}catch (RuntimeException ex){
System.out.println(ex.getMessage());
}
}
/**
* 手动执行jdbc测试
*/
@Override
public void testJdbcTemplate() {
User user = new User();
int a = new Random().nextInt(10); //0-9
user.setNumber("10000i"+ a );
user.setName("name"+a);
this.jdbcTemplate.update("INSERT into USER(NUMBER,NAME )VALUES (?,?)",user.getNumber(),user.getName());
}
至此,我已经讲了三种方式(jpa两种+jdbcTemplate)如何操作数据库了,你爱怎么用就怎么用,上述代码均是实践证明可行的!
以上这篇基于spring boot 1.5.4 集成 jpa+hibernate+jdbcTemplate(详解)就是小编分享给大家的全部内容了,希望能给大家一个参考,也希望大家多多支持。
# spring
# boot
# 集成jpa
# SpringBoot 2.0 整合sharding-jdbc中间件实现数据分库分表
# 详解Spring Boot中整合Sharding-JDBC读写分离示例
# SpringBoot JdbcTemplate批量操作的示例代码
# spring boot使用sharding jdbc的配置方式
# Spring Boot JDBC 连接数据库示例
# 关于Spring Boot对jdbc的支持问题
# 给大家
# 主键
# 给你
# 两种
# 会不会
# 希望能
# 三种
# 这篇
# 讲了
# 你爱
# 小编
# 大家多多
# 方法如下
# 我已经
# 实体类
# auto
# show
# sql
# drop
# validate
相关栏目:
【
网站优化151355 】
【
网络推广146373 】
【
网络技术251813 】
【
AI营销90571 】
相关推荐:
Laravel全局作用域是什么_Laravel Eloquent Global Scopes应用指南
Win10如何卸载预装Edge扩展_Win10卸载Edge扩展教程【方法】
如何确认建站备案号应放置的具体位置?
jQuery 常见小例汇总
Linux系统命令中tree命令详解
php中::能调用final静态方法吗_final修饰静态方法调用规则【解答】
手机软键盘弹出时影响布局的解决方法
谷歌Google入口永久地址_Google搜索引擎官网首页永久入口
PHP 实现电台节目表的智能时间匹配与今日/明日轮播逻辑
高端企业智能建站程序:SEO优化与响应式模板定制开发
Win11搜索栏无法输入_解决Win11开始菜单搜索没反应问题【技巧】
公司门户网站制作流程,华为官网怎么做?
Laravel如何实现一对一模型关联?(Eloquent示例)
国美网站制作流程,国美电器蒸汽鍋怎么用官方网站?
如何挑选高效建站主机与优质域名?
JavaScript Ajax实现异步通信
HTML5空格和nbsp有啥关系_nbsp的作用及使用场景【说明】
QQ浏览器网页版登录入口 个人中心在线进入
Laravel如何监控和管理失败的队列任务_Laravel失败任务处理与监控
个人网站制作流程图片大全,个人网站如何注销?
Laravel如何与Pusher实现实时通信?(WebSocket示例)
如何在阿里云购买域名并搭建网站?
logo在线制作免费网站在线制作好吗,DW网页制作时,如何在网页标题前加上logo?
如何在服务器上配置二级域名建站?
Linux虚拟化技术教程_KVMQEMU虚拟机安装与调优
SQL查询语句优化的实用方法总结
网站建设整体流程解析,建站其实很容易!
昵图网官网入口 昵图网素材平台官方入口
Laravel如何安装Breeze扩展包_Laravel用户注册登录功能快速实现【流程】
Javascript中的事件循环是如何工作的_如何利用Javascript事件循环优化异步代码?
如何利用DOS批处理实现定时关机操作详解
Laravel如何创建自定义Facades?(详细步骤)
小米17系列还有一款新机?主打6.9英寸大直屏和旗舰级影像
网站广告牌制作方法,街上的广告牌,横幅,用PS还是其他软件做的?
Laravel如何实现全文搜索功能?(Scout和Algolia示例)
Laravel如何配置.env文件管理环境变量_Laravel环境变量使用与安全管理
Laravel API资源类怎么用_Laravel API Resource数据转换
Laravel如何实现文件上传和存储?(本地与S3配置)
高端网站建设与定制开发一站式解决方案 中企动力
Laravel如何理解并使用服务容器(Service Container)_Laravel依赖注入与容器绑定说明
如何快速搭建高效香港服务器网站?
高防服务器:AI智能防御DDoS攻击与数据安全保障
如何在局域网内绑定自建网站域名?
如何自定义建站之星网站的导航菜单样式?
Laravel如何使用集合(Collections)进行数据处理_Laravel Collection常用方法与技巧
如何用AI一键生成爆款短视频文案?小红书AI文案写作指令【教程】
Laravel怎么判断请求类型_Laravel Request isMethod用法
Laravel Blade组件怎么用_Laravel可复用视图组件的创建与使用
如何在腾讯云免费申请建站?
佐糖AI抠图怎样调整抠图精度_佐糖AI精度调整与放大细化操作【攻略】

