EJB中数据库操作技术（JPA）

Posted 2020-08-09

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了EJB中数据库操作技术（JPA）相关的知识，希望对你有一定的参考价值。

一、导言---- 什么是JPA
    Java Persistence API,规定使用注解或XML描述对象与数据表的映射，
实现将对象信息持久化到数据库。目前Hibernate\TopLink\OpenJPA等框架都支持JPA规范。
本例中，演示了通过JPA技术实现员工--部门多对一关系。

    二、JPA开发流程
   预先建立一个EJB工程
    a. 配置数据源DataSource，修改*-ds.xml文件，并放入服务器的deploy目录
   提示：在配置文件中指定了用那个数据源连接数据库：
mysql-ds.xml中封装了数据源有关的jndi-name的值（如 jMySqlDS）必须与persistence.xml中jta-data-source相对应如（java:MySqlDS）。
    b.创建工程，在src/META-INF下创建一个persistence.xml文件,引用java:DataSource名
   提示：在配置文件中指定持久化用那个持久化单元做（可以有多个）:
  persistence.xml中的<persistence-unit name="MysqlPU">必须与DAOImpl中注释   @PersistenceContext(unitName="MysqlPU") 向对应.
    c.编写EntityBean,实现序列化，setter/getter方法，equals/hashCode方法
    d.使用注解，描述与数据的映射信息
    e.编写SessionBean DAO组件操纵EntityBean
    f.在SessionBean中使用EntityManager对象的方法实现CRUP操作

   三、核心配置文件和代码
  mysql-ds.xml-----persistence.xml-------实体Bean(Emp员工类+Dept部门类)------会话 Bean（接口+时间类）------测试类

  3.1 mysql-ds.xml
//配置数据源，包括URL,密码，用户名等
  <?xml version="1.0" encoding="UTF-8"?>



<datasources>
  <local-tx-datasource>
    <jndi-name>MySqlDS</jndi-name>
    <connection-url>jdbc:mysql://localhost:3306/ejb</connection-url>
    <driver-class>com.mysql.jdbc.Driver</driver-class>
    <user-name>root</user-name>
    <password>sd100301</password>
    <max-pool-size>20</max-pool-size>
    <min-pool-size>1</min-pool-size>
    <exception-sorter-class-name>org.jboss.resource.adapter.jdbc.vendor.MySQLExceptionSorter</exception-sorter-class-name>
    
    
    
    
    <metadata>
       <type-mapping>mySQL</type-mapping>
    </metadata>
  </local-tx-datasource>
</datasources>

3.2  persistence.xml
//EJB配置文件,指定采用的数据源以及配置hibernate相应信息
<?xml version="1.0" encoding="UTF-8"?>
<persistence version="1.0"
    xmlns="http://java.sun.com/xml/ns/persistence"
    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
    xsi:schemaLocation="http://java.sun.com/xml/ns/persistence
    http://java.sun.com/xml/ns/persistence/persistence_1_0.xsd ">
    <persistence-unit name="MysqlUnit" transaction-type="JTA">
        <jta-data-source>java:MySqlDS</jta-data-source>
        <properties>
            <property name="hibernate.hbm2ddl.auto" value="update"/>
            <property name="hibernate.show_sql" value="true"/>
            <property name="hibernate.format_sql" value="true"/>
        </properties>
    </persistence-unit>
</persistence>

3.3 实体Bean
员工类Emp
//指定这是一个实体类，与之对应的表名，ID是哪个，各个属性对应的列名是哪个
@Entity
@Table(name = "emp")
public class Emp implements Serializable {
    @Id
    @GeneratedValue
    @Column(name = "id")
    private int id;
    @Column(name="ename",length=20,nullable=false)
    private String ename;
    @ManyToOne()
    @JoinColumn(name="dept_id")
    private Dept dept;
    public Emp() {
    }

    public Emp(int id, String ename) {
        super();
        this.id = id;
        this.ename = ename;
    }
//-------在此处添加各个属性的getter&setter方法-----

部门类Emp
//指定这是一个实体类，与之对应的表名，ID是哪个，各个属性对应的列名是哪个
@Entity
@Table(name="dept")
public class Dept implements Serializable {
@Id
@GeneratedValue
@Column(name="id")
private int id;
@Column(name="dname",nullable=false,length=20)
private String dname;
@OneToMany(mappedBy="dept")
private Set<Emp> emps=new HashSet<Emp>();
public Dept() {
}
public Dept( String dname) {
    super();
    this.dname = dname;
}
//-------在此处添加各个属性的getter&setter方法-----

3.4会话Bean (DAO接口+DAO接口的实现类)
DAO接口
import java.util.List;
public interface DeptDAO {
public void add(Dept dept);
public Dept findById(int id);
public List findAll();
public List showAll();
}

DAO接口的实现类
//指定这是一个无会话的SessionBean,
@Stateless
//声明该SessionBean的远程业务接口为DeptDAO
@Remote(DeptDAO.class)
public class DeptDAOImpl implements DeptDAO {
//指定EntityManager所采用的持久化单元
    @PersistenceContext(unitName="MysqlPU")
//EntityManager 封装了添加、查找、更新等各种数据库操作方法。
    private EntityManager em;
    public void add(Dept dept) {
        em.persist(dept);
    }
    public List findAll() {
    String jpql="select d from dept d";
    return em.createQuery(jpql).getResultList();
    }
    public Dept findById(int id) {
        Dept dept=em.find(Dept.class, id);
        return dept;
    }
    public List showAll() {
        String jpql="select d.id,d.dname,count(e)" +
                " from dept d left join d.emps e";
        return em.createQuery(jpql).getResultList();
    }
}

3.5调用类
//用于调用EJB中的SessionBean，来实现数据库操作
import java.util.*;
import java.util.Set;
import javax.naming.*;
import jpa.*;
public class TestDeptDAO {
    public static void main(String[] args) throws Exception {
        testSave();
    }
    public static void testSave() throws Exception {
//黑体部分：先设置环境参数，再用环境参数构造出上下文的一个对象。
//这些代码是基本固定的。在各种调用中都是必须的。
        Hashtable env = new Hashtable();
        env.put(Context.INITIAL_CONTEXT_FACTORY,
                "org.jnp.interfaces.NamingContextFactory");
        env.put(Context.PROVIDER_URL, "jnp://localhost:1099");
        InitialContext context = new InitialContext(env);
//通过context的lookup方法得到实现类的对象
        DeptDAO deptDAO = (DeptDAO) context.lookup("DeptDAOImpl/remote");
//简历新部门--新员工集合--新员工--设置各种关系--保存新部分（本应级联保存所有新员工信息）
        Dept dept = new Dept();
        dept.setDname("sale");
        Set<Emp> emps = new HashSet<Emp>();
        Emp emp1 = new Emp();
        emp1.setEname("徐亮");
        emp1.setDept(dept);
        emps.add(emp1);
        Emp emp2 = new Emp();
        emp2.setEname("小王");
        emp2.setDept(dept);
        emps.add(emp2);
        Emp emp3 = new Emp();
        emp3.setEname("小华");
        emp3.setDept(dept);
        emps.add(emp3);
        dept.setEmps(emps);
        deptDAO.add(dept);
    }
}

以上是关于EJB中数据库操作技术（JPA）的主要内容，如果未能解决你的问题，请参考以下文章

在 JPA / Hibernate 启动之前引导 EJB3 应用程序

使用 JPA/EJB3 进行批量插入

spring注解request和post的区别

JPA 中是不是可能进行 SQL 注入攻击？

JPA简介

如何使用 JPA/EJB3 和 WildFly 读取未提交的数据？