• hibernate及SpringBoot集成Jpa实现对数据库操作

    首先使用Maven工程和junit完成hibernate对数据库的简单操作，完成之后在使用SpringBoot集成Jap完成hibernate对数据库的操作。本文仅供新手学习查看，具体线上使用需要对代码继续进行相关优化。

    1、先创建一个Maven工程，导入相关依赖。

    复制代码
     
        <dependency>
            <groupId>org.projectlombokgroupId>
            <artifactId>lombokartifactId>
            <version>1.18.16version>
        dependency>
        
        <dependency>
            <groupId>mysqlgroupId>
            <artifactId>mysql-connector-javaartifactId>
            <version>8.0.26version>
        dependency>
        
        <dependency>
            <groupId>junitgroupId>
            <artifactId>junitartifactId>
            <version>4.11version>
            <scope>testscope>
        dependency>
        
        <dependency>
            <groupId>org.hibernategroupId>
            <artifactId>hibernate-coreartifactId>
            <version>5.6.14.Finalversion>
        dependency>
    复制代码

    2、在resources目录下创建hibernate.cfg.xml

    复制代码
    xml version="1.0" encoding="UTF-8"?>
DOCTYPE hibernate-configuration PUBLIC "-//Hibernate/Hibernate Configuration DTD 3.0//EN"
        "http://www.hibernate.org/dtd/hibernate-configuration-3.0.dtd">
<hibernate-configuration>
    <session-factory>
        
        <property name="connection.driver_class">com.mysql.cj.jdbc.Driverproperty>
        <property name="connection.url">jdbc:mysql://localhost:3306/user-modeproperty>
        <property name="connection.username">rootproperty>
        <property name="connection.password">1234qwerproperty>
        
        <property name="dialect">org.hibernate.dialect.MySQLDialectproperty>
        
        <property name="show_sql">trueproperty>
        
        <property name="format_sql">trueproperty>
        
        <mapping resource="/mapper/User.hbm.xml" />
    session-factory>
hibernate-configuration>
    复制代码

    3、创建一个实体类

    复制代码
    @Datapublic class User {private Long id;
    private String name;
    private String password;
    private String account;
    private String email;private String secondName;
}
    复制代码

    4、在resources目录下创建一个mapper目录，在mapper目录下面创建User实体类的映射文件User.hbm.xml

    复制代码
    xml version='1.0' encoding='utf-8'?>
DOCTYPE hibernate-mapping PUBLIC
        "-//Hibernate/Hibernate Mapping DTD 3.0//EN"
        "http://www.hibernate.org/dtd/hibernate-mapping-3.0.dtd">
<hibernate-mapping>
    
    
    <class name="com.itmy.entity.User" table="tb_user">
        <id name="id" column="id" type="java.lang.Long">
            
            <generator class="native">generator>
        id>
        <property name="name" column="name" type="java.lang.String" not-null="false" length="50">property>
        <property name="account" column="account" type="java.lang.String">property>
        <property name="email" column="email" type="java.lang.String">property>
        <property name="password" column="password" type="java.lang.String">property>
        <property name="secondName" column="second_name" type="java.lang.String">property>
    class>
hibernate-mapping>
    复制代码

    配置完上述配置之后，接下来我们就可以使用junit进行测试了，先在test目录下面创建一个测试类UserTest。

    5、使用junit添加一个User用户

    复制代码
     @org.junit.Test
    public void TestSave(){
        //读取 hibernate.cfg.xml配置文件, 创建会话工厂 SessionFactory
        Configuration configuration = new Configuration().configure();
        SessionFactory sessionFactory = configuration.buildSessionFactory();
        // 获取 Session 对象
        Session openSession = sessionFactory.openSession();
        //开启事务
        openSession.beginTransaction();
        User user = new User();
        user.setAccount("hibernateTest01");
        user.setName("hibernateTest01");
        user.setPassword("ASWDEWSA");
        user.setEmail("hibernate02@hbm.com");
        user.setSecondName("hibernateTest01");
        openSession.save(user);
        //提交事务
        openSession.getTransaction().commit();
    }
    复制代码

    执行之后，控制台没有报红，说明添加成功了。可以给上述代码做下优化，帮助我们更方便的完成其他操作。

    复制代码
        private Session openSession;
    @Before
    public void before(){
        //读取 hibernate.cfg.xml配置文件, 创建会话工厂 SessionFactory
        Configuration configuration = new Configuration().configure();
        SessionFactory sessionFactory = configuration.buildSessionFactory();
        // 获取 Session 对象
        openSession = sessionFactory.openSession();
    }

    @org.junit.Test
    public void TestSave(){
//        //读取 hibernate.cfg.xml配置文件, 创建会话工厂 SessionFactory
  //      Configuration configuration = new Configuration().configure();
 //       SessionFactory sessionFactory = configuration.buildSessionFactory();
//        // 获取 Session 对象
 //       Session openSession = sessionFactory.openSession();
        //开启事务
        openSession.beginTransaction();
        User user = new User();
        user.setAccount("hibernateTest01");
        user.setName("hibernateTest01");
        user.setPassword("ASWDEWSA");
        user.setEmail("hibernate02@hbm.com");
        user.setSecondName("hibernateTest01");
        openSession.save(user);
        //提交事务
        openSession.getTransaction().commit();
    }
       @After
       public void after(){
          if (openSession != null){
              openSession.close();
          }
    }
    复制代码

    实现更新、删除、查询，查询有许多种方法，后面可以进行深入学习。

    复制代码
     @org.junit.Test
    public void testUpdate(){
        //开启事务
        openSession.beginTransaction();
        User user = new User();
        user.setId(8L);
        user.setAccount("hibernateTest03");
        user.setName("hibernateTest03");
        user.setPassword("ASWDEWSAW");
        user.setEmail("hibernate03@hbm.com");
        user.setSecondName("hibernateTest03");
        openSession.update(user);
        //提交事务
        openSession.getTransaction().commit();
    }
    @org.junit.Test
    public void testDelete(){
        //开启事务
        openSession.beginTransaction();
        User user = new User();
        user.setId(8L);
        openSession.delete(user);
        //提交事务
        openSession.getTransaction().commit();
    }
    @org.junit.Test
    public void testFind(){
        User user = new User();
        user.setId(8L);
        //已过时
        Criteria criteria = openSession.createCriteria(User.class);
        List list = criteria.list();
        for (Object o : list) {
            System.out.println(o);
        }
        List fromUser = openSession.createQuery("from User").list();
        fromUser.forEach(System.out::println);
    }
    复制代码

    到这里通过maven简单的使用hibernate的操作就完成了，后面我们使用SpringBoot集成Jpa。

    6、首先调整我们的maven项目，添加springboot相关依赖以及jpa依赖。

    复制代码
    <parent>
        <groupId>org.springframework.bootgroupId>
        <artifactId>spring-boot-starter-parentartifactId>
        <version>2.2.11.RELEASEversion>
    parent>

    <dependencies>
        <dependency>
            <groupId>org.springframework.bootgroupId>
            <artifactId>spring-boot-starter-webartifactId>
        dependency>
        <dependency>
            <groupId>org.springframework.bootgroupId>
            <artifactId>spring-boot-testartifactId>
            <scope>testscope>
        dependency>
        <dependency>
            <groupId>org.springframework.bootgroupId>
            <artifactId>spring-boot-starter-data-jpaartifactId>
        dependency>
        
        <dependency>
            <groupId>com.alibabagroupId>
            <artifactId>druidartifactId>
            <version>1.2.16version>
        dependency>
    复制代码

    7、创建Springboot启动类

    复制代码
    /**
 * @date: 2023-05-11 13:29
 */
@SpringBootApplication
public class HibernApplication {

    public static void main(String[] args) {
        SpringApplication.run(HibernApplication.class,args);
    }
}
    复制代码

    8、在resources目录下创建yml文件

    复制代码
    server:
  port: 8800
spring:
  application:
    name: hibernate
  profiles:
    active: prod
    复制代码
    复制代码
    spring:
  jpa:
    properties:
      hibernate:
        dialect: org.hibernate.dialect.MySQLDialect
        new_generator_mappings: false
        format_sql: true
        #show_sql: true
    database: mysql
    show-sql: true
    #当数据库表没有该属性字段，会根据实体类相关字段自动创建一个字段，如secondName在数据库创建的为second_name
    hibernate:
      ddl-auto: update
       # 生产环境设置成 none，避免程序运行时自动更新数据库结构
          #ddl-auto: none
      datasource:
   driver-class-name: com.mysql.cj.jdbc.Driver
   type: com.alibaba.druid.pool.DruidDataSource
   url: jdbc:mysql://localhost:3306/user-mode?serverTimezone=Asia/Shanghai
   username: root
   password: 1234qwer
    复制代码

    9、调整之前创建的实体类

    复制代码
    @Data
@Entity
@Table(name = "tb_user")
public class User {

    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    @Column(name = "id",nullable = false)
    private Long id;

    private String name;

    private String password;

    private String account;

    private String email;

    @Column(name = "second_name",nullable = false)
    private String secondName;

}
    复制代码

    10、创建一个dao层接口继承jpa接口

    public interface UserMapper extends JpaRepository {
   
}

    后面就跟正常调用方法一样，通过注入UserMapp接口，进行调用。

    复制代码
    @Service
public class UserServiceImpl implements IUserService {

    @Autowired
    private UserMapper userMapper;

    @Override
    public List findAll() {
        List userIterable = userMapper.findAll();
        return userIterable;
    }
    @Override
    public User save() {
        User user = new User();
        user.setAccount("hibernateJPa03");
        user.setName("hibernateJPa03");
        user.setPassword("ASWDEWSAW");
        user.setEmail("hibernateJPa03@hbm.com");
        user.setSecondName("hibernateJPa03");
        User save = userMapper.save(user);
        return save;
    }
    @Override
    public User update() {
        User user = new User();
        user.setId(5L);
        user.setAccount("hibernateJPa03");
        user.setName("hibernateJPa03");
        user.setPassword("ASWDEWSAW");
        user.setEmail("hibernateJPa03@hbm.com");
        user.setSecondName("hibernateJPa03");
        User save = userMapper.save(user);
        return save;
    }
    @Override
    public User delete() {
        User user = new User();
        user.setId(10L);
        userMapper.delete(user);
        return null;
    }
    @Override
    public User userById() {
       // Iterable allById = userMapper.findAllById(Arrays.asList(1L));
        Optional userOptional = userMapper.findById(4L);
        if (!userOptional.isPresent()){
            return null;
        }
        User user = userOptional.get();

        return user;
    }
}
    复制代码

    创建controller类编写一个接口进行测试。

    复制代码
    @RestController
@RequestMapping("/admin/user")
public class UserController {

    @Autowired
    private IUserService userService;

    @GetMapping
    public String crudUser(){
        List userList = userService.findAll();
        userList.forEach(System.out::println);
        User user = userService.userById();
        System.out.println(user);
        return "操作执行成功！！！";
    }
}
    复制代码

    调用接口执行过后，查看控制台输出。

    数据查询成功。至此springboot集成JPA就完成了。里面有很多方法，时间充足可以试试不同的方法。

     补充：

    通过JPA使用原生sql进行模糊查询，在Mapper接口增加一个接口方法，使用jpa的@query注解进行sql语句编写

    复制代码
    public interface UserMapper extends JpaRepository , JpaSpecificationExecutor {
　　#nativeQuery = true 说明启动mysql本身的sql语句进行查询 默认为false
    @Query(value = "select * from tb_user where name like concat('%',?1,'%')",nativeQuery = true)
    List findOneByName(@Param("name") String name);
}
    复制代码

     

  • 相关阅读:
    LightDB中的表
    Facebook最全进阶使用攻略
    vue+vscode 快速搭建运行调试环境与发布
    【数据库系统概论】实验六 完整性控制
    云原生Kubernetes：Pod控制器
    R语言检验时间序列中是否存在自相关性：使用box.test函数执行box-pierce检验验证时间序列中是否存在自相关性
    Java 输入输出流简介和应用 (Java实现序列化工具类)
    js new Date实例化种类
    C/C++数据结构之中缀表达式转换为后缀表达式，删除堆栈元素
    基于 Flink CDC 实现海量数据的实时同步和转换
  • 原文地址：https://www.cnblogs.com/eternality/p/17391141.html