JPA的入门案例

JPA的入门案例

1 案例说明
案例是客户的相关操作（增删改查）
客户：就是一家公司
创建客户表的代码如下：

CREATE DATABASE jpa;      -- 创建数据库
USE jpa;     -- 使用数据库
/*创建客户表*/
CREATE TABLE cst_customer (
  cust_id BIGINT(32) NOT NULL AUTO_INCREMENT COMMENT '客户编号(主键)',
  cust_name VARCHAR(32) NOT NULL COMMENT '客户名称(公司名称)',
  cust_source VARCHAR(32) DEFAULT NULL COMMENT '客户信息来源',
  cust_industry VARCHAR(32) DEFAULT NULL COMMENT '客户所属行业',
  cust_level VARCHAR(32) DEFAULT NULL COMMENT '客户级别',
  cust_address VARCHAR(128) DEFAULT NULL COMMENT '客户联系地址',
  cust_phone VARCHAR(64) DEFAULT NULL COMMENT '客户联系电话',
  PRIMARY KEY (`cust_id`)
 ) ENGINE=INNODB AUTO_INCREMENT=1 DEFAULT CHARSET=utf8;
 -- 查询数据
 SELECT * FROM cst_customer;

2 搭建环境
搭建环境步骤如下：
1.打开IDEA如图所示，点击Create New Project。
2.现在Maven工程和JDK的版本。并点击Next。如图所示：
3.填写项目名称和保存的地址，点击Finish。如图所示：
4.导入相应的依赖jar包的代码如下：

<?xml version="1.0" encoding="UTF-8"?>
<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/xsd/maven-4.0.0.xsd">
    <modelVersion>4.0.0</modelVersion>
    <groupId>com.txw</groupId>
    <artifactId>jpa_day01</artifactId>
    <version>1.0-SNAPSHOT</version>
    <!--打包的方式-->
    <packaging>jar</packaging>
    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.hibernate.version>5.0.7.Final</project.hibernate.version>
    </properties>
    <dependencies>
        <!-- junit单元测试 -->
        <dependency>
            <groupId>junit</groupId>
            <artifactId>junit</artifactId>
            <version>4.12</version>
            <!--作用域测试范围-->
            <scope>test</scope>
        </dependency>
        <!-- hibernate对jpa的支持包 -->
        <dependency>
            <groupId>org.hibernate</groupId>
            <artifactId>hibernate-entitymanager</artifactId>
            <version>${project.hibernate.version}</version>
        </dependency>
        <!-- c3p0 数据库连接处 -->
        <dependency>
            <groupId>org.hibernate</groupId>
            <artifactId>hibernate-c3p0</artifactId>
            <version>${project.hibernate.version}</version>
        </dependency>
        <!-- log日志 -->
        <dependency>
            <groupId>log4j</groupId>
            <artifactId>log4j</artifactId>
            <version>1.2.17</version>
        </dependency>
        <!-- Mysql and MariaDB -->
        <dependency>
            <groupId>mysql</groupId>
            <artifactId>mysql-connector-java</artifactId>
            <version>5.1.6</version>
        </dependency>
        <!--lombok依赖jar包-->
        <dependency>
            <groupId>org.projectlombok</groupId>
            <artifactId>lombok</artifactId>
            <version>1.18.12</version>
        </dependency>
    </dependencies>
</project>

5.在resources下创建META-INF目录，并在META-INF目录创建persistence.xml的配置jpa的核心配置文件的代码如下：

<?xml version="1.0" encoding="UTF-8"?>
<persistence xmlns="http://java.sun.com/xml/ns/persistence" version="2.0">
    <!--需要配置persistence-unit节点
        持久化单元：
            name：持久化单元名称
            transaction-type：事务管理的方式
                    JTA：分布式事务管理
                    RESOURCE_LOCAL：本地事务管理
    -->
    <persistence-unit name="myJpa" transaction-type="RESOURCE_LOCAL">
        <!--jpa的实现方式 -->
        <provider>org.hibernate.jpa.HibernatePersistenceProvider</provider>

        <!--可选配置：配置jpa实现方的配置信息-->
        <properties>
            <!-- 数据库信息
                用户名，javax.persistence.jdbc.user
                密码，  javax.persistence.jdbc.password
                驱动，  javax.persistence.jdbc.driver
                数据库地址   javax.persistence.jdbc.url
            -->
            <property name="javax.persistence.jdbc.user" value="root"/>
            <property name="javax.persistence.jdbc.password" value="123456"/>
            <property name="javax.persistence.jdbc.driver" value="com.mysql.jdbc.Driver"/>
            <property name="javax.persistence.jdbc.url" value="jdbc:mysql:///jpa?characterEncoding=utf-8"/>

            <!--配置jpa实现方(hibernate)的配置信息
                显示sql           ：   false|true
                自动创建数据库表    ：  hibernate.hbm2ddl.auto
                        create      : 程序运行时创建数据库表（如果有表，先删除表再创建）
                        update      ：程序运行时创建表（如果有表，不会创建表）
                        none        ：不会创建表
            -->
            <property name="hibernate.show_sql" value="true" />
            <property name="hibernate.hbm2ddl.auto" value="create" />
        </properties>
    </persistence-unit>
</persistence>

6.编写客户的实体类的代码如下：

package com.txw.domain;

import lombok.Data;
import lombok.ToString;
/**
 * 客户的实体类
 * @author: Adair
 */
@Data   // 自动生成set和get方法
@ToString    // 重写toString方法
@SuppressWarnings("all")         // 注解警告信息
public class Customer {
    private Long custId;          // 客户的主键
    private String custName;        // 客户名称
    private String custSource;     // 客户来源
    private String custLevel;        // 客户级别
    private String custIndustry;    // 客户所属行业
    private String custPhone;       // 客户的联系方式
    private String custAddress;       // 客户地址
}

7.使用jpa注解配置映射关系的代码如下：

package com.txw.domain;

import lombok.Data;
import lombok.ToString;
import javax.persistence.*;
/**
 * 客户的实体类
 *   配置映射关系
 *     1.实体类和表的映射关系
 *        @Entity:声明实体类
 *        @Table : 配置实体类和表的映射关系
 *            name : 配置数据库表的名称
 *     2.实体类中属性和表中字段的映射关系
 * @author: Adair
 */
@Entity
@Table(name = "cst_customer")
@Data   // 自动生成set和get方法
@ToString    // 重写toString方法
@SuppressWarnings("all")         // 注解警告信息
public class Customer {
    /**
     * @Id：声明主键的配置
     * @GeneratedValue:配置主键的生成策略
     *      strategy
     *          GenerationType.IDENTITY ：自增，mysql
     *                 * 底层数据库必须支持自动增长（底层数据库支持的自动增长方式，对id自增）
     *          GenerationType.SEQUENCE : 序列，oracle
     *                  * 底层数据库必须支持序列
     *          GenerationType.TABLE : jpa提供的一种机制，通过一张数据库表的形式帮助我们完成主键自增
     *          GenerationType.AUTO ： 由程序自动的帮助我们选择主键生成策略
     * @Column:配置属性和字段的映射关系
     *      name：数据库表中字段的名称
     */
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    @Column(name = "cust_id")
    private Long custId;          // 客户的主键
    @Column(name = "cust_name")
    private String custName;        // 客户名称
    @Column(name="cust_source")
    private String custSource;     // 客户来源
    @Column(name="cust_level")
    private String custLevel;        // 客户级别
    @Column(name="cust_industry")
    private String custIndustry;    // 客户所属行业
    @Column(name="cust_phone")
    private String custPhone;       // 客户的联系方式
    @Column(name="cust_address")
    private String custAddress;       // 客户地址
}

8.测试jpa的保存的代码如下：

package com.txw.test;

import com.txw.domain.Customer;
import org.junit.Test;
import javax.persistence.EntityManager;
import javax.persistence.EntityManagerFactory;
import javax.persistence.EntityTransaction;
import javax.persistence.Persistence;
/**
 * 测试jqa
 * @author: Adair
 */
@SuppressWarnings("all")         // 注解警告信息
public class JpaTest {
    /**
     * 测试jpa的保存
     *      案例：保存一个客户到数据库中
     *  Jpa的操作步骤
     *     1.加载配置文件创建工厂（实体管理器工厂）对象
     *     2.通过实体管理器工厂获取实体管理器
     *     3.获取事务对象，开启事务
     *     4.完成增删改查操作
     *     5.提交事务（回滚事务）
     *     6.释放资源
     */
    @Test
    public void testSave(){
        // 1.加载配置文件创建工厂（实体管理器工厂）对象
        EntityManagerFactory factory = Persistence.createEntityManagerFactory("myJpa");
       // 2.通过实体管理器工厂获取实体管理器
        EntityManager em = factory.createEntityManager();
        // 3.获取事务对象，开启事务
        EntityTransaction tx = em.getTransaction();     // 获取事务对象
        tx.begin();     // 开启事务
        // 4.完成增删改查操作：保存一个客户到数据库中
        Customer customer = new Customer();
        customer.setCustName("学无止路");
        customer.setCustSource("微信公众号");
        customer.setCustIndustry("笔记");
        customer.setCustLevel("1及");
        customer.setCustAddress("贵州省六盘水市");
        customer.setCustPhone("15788533828*");
        //保存，
        em.persist(customer);   //保存操作
        // 5.提交事务
        tx.commit();
        // 6.释放资源
        em.close();
        factory.close();
    }
}

运行结果如图所示：
使用 SELECT * FROM cst_customer;在数据库运行结果如图所示：