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;在数据库运行结果如图所示：