持久化API(JPA)系列(三)实体Bean的开发技术-建立与数据库的连接

本文涉及的产品
云数据库 RDS MySQL,集群系列 2核4GB
推荐场景:
搭建个人博客
RDS MySQL Serverless 基础系列,0.5-2RCU 50GB
云数据库 RDS PostgreSQL,集群系列 2核4GB
简介:

    在EJB 2.x中。EJB有3种类型的Bean。各自是会话Bean(Session Bean)、消息驱动Bean(Message-Driven Bean)和实体Bean(Entity Bean)。

        随着EJB 3的推出,EJB2.x中的实体Bean逐渐被JPA规范所替代,JPA不仅能在EJB环境中使用,并且能在Java SE、Java EE环境中使用。相对于EJB 2.x中的实体Bean,它的使用范围更广。

        但这里我们仍然将其称做实体Bean。

        与会话Bean和消息驱动Bean类似,新的实体Bean也是一个加了凝视符(@Entity)的简单Java对象(POJO),实体关系和O/R映射也是通过凝视符来定义的,并提供几种不同的数据库操作规范。

        一旦被EntityManager訪问,它就成为了一个持久化对象。而且成为了持久化上下文的一部分。此时我们就能够像使用Hibernate、iBATIS、MYBATIS一样来使用实体对象了。



        本文主要将具体解说实体Bean的开发技术。

1、建立与数据库的连接,演示实体Bean的开发与调用过程。


2、实体管理器:运行数据库更新的方法。
3、生命周期:实体Bean的监听和回调。


4、关系实体映射:开发实体的方法。
5、JPQL查询语言:运行数据库实体查询。
6、原生SQL查询:运行原生SQL语句。


        它们之间的关系如图所看到的,通过实体管理器操作实体Bean。来实现对数据库的更新、JPQL查询和原生SQL查询。

实体管理器是工具。实体Bean是数据。

以下首先来解说实体Bean的调用过程。然后通过开发第一个实体Bean。演示该配置与开发的过程,包含以下内容:

1、配置数据源。


2、指定数据源。
3、开发第一个实体Bean--Student.java。
4、开发会话Bean进行调用--StudentDAORemote.java和StudentDAO.java。


5、打包并部署到JBossserver。
6、开发client进行測试--StudentDAOClient.java。


终于实现,通过实体Bean的建立与MySQL数据库的连接。往数据表中插入一条记录。

一、实体Bean的工作原理

实体Bean是作为持久化类被EJB容器管理的,要实现对该持久化类的调用,必须经过下面步骤。
(1)配置数据源连接。


(2)在配置文件persistence.xml中指定数据源。


(3)开发实体Bean。
(4)在会话Bean、Java SE或Java EE中调用实体Bean。


        实体Bean不仅能够被会话Bean调用。还能够被不论什么的Java类、JSP和Servlet调用,调用的目的是实现对数据库的操作。它的意义与Hibernate、iBATIS全然同样。就是作为系统的DAO层,实现对数据库的訪问。
        以下我们就依照从底层到上层的顺序,来演示创建与数据库的连接的过程。


二、配置数据源


jndi-name:指定JNDI命名。


connection-url:数据库连接URL。
driver:数据库驱动类。


user-name:数据库登录username。


password:数据库登陆password。


我们仅仅须要通过引用JNDI命令KsMysqlDS来引用该数据源。引用的方法非常easy。仅仅须要在persistence.xml中指定该别名就可以


三、指定数据源--persistence.xml
以上配置的数据源由JBossserver载入和管理。要使用这些数据源,还须要在我们的应用中指定引用哪一个数据源。引用的方法非常easy,仅仅须要在应用的/项目/META-INF文件夹下加入一个配置文件persistence.xml就可以。并在该文件里指定引用的数据源JNDI名称,同一时候能够设置该数据源的相关操作属性。


配置文件persistence.xml



当中包括3个配置元素,分别例如以下。


persistence-unit元素:能够有一个或多个。每一个persistence-unit元素定义了持久化内容名称、使用的数据源名称及Hibernate属性。当中的name属性用于设置持久化名称。
jta-data-source元素:用于指定实体Bean使用的数据源名称KsMysqlDS。当指定数据源名称时java:/前缀不能缺少,并注意数据源名称的大写和小写。
properties元素:用于指定Hibernate的各项属性。假设hibernate.hbm2ddl.auto的值设为update,这样实体Bean加入一个属性时能同一时候在数据表添加对应字段。
(1)properties元素属性在各个应用server使用的持久化产品中都不一样。如JBoss使用Hibernate。WebLogic10使用Kodo,GlassFish/Sun Application Server/Oralce使用Toplink。


(2)JBossserver在启动或关闭时会引发实体Bean的公布及卸载。



四、开发第一个实体
实体Bean实际上相应了数据库中的表,它是数据库中表在Java类中的表现,通常为最普通的POJO类。EJB容器可以依据实体Bean自己主动在数据库中创建数据表,这就须要将实体类与数据表的结构进行相应,包含表名、字段名、字段长度、字段类型、主键等信息。
为了开发一个与数据库表相应的单表实体Bean,我们首先设计一个学生表student的数据结构,该表共包含7个字段。如表6-1所看到的。
学生表student
当中的字段类型相应了MySQL数据库中的字段类型,Java类型为相应的POJO类中的字段类型,即实体Bean中的变量类型。
要开发一个与该表相应的实体Bean非常easy,仅仅须要新建一个POJO类,加入7个与表的字段同名的变量。同一时候使用一些凝视符来表示该实体Bean与数据表student的相应映射关系就可以。
Bean类Student.java。首先我们来看看这个完整的实体类的代码,例如以下所看到的:

实体Bean类Student.java
package com.ejb.entitybean;  
 
import java.io.Serializable;  
import java.util.Date;  
import javax.persistence.Column;  
import javax.persistence.Entity;  
import javax.persistence.GeneratedValue;  
import javax.persistence.Id;  
import javax.persistence.Table;  
 
@SuppressWarnings("serial")  
@Entity 
@Table(name = "Student")  
public class Student implements Serializable {  
    private Integer studentid;      //学号  
    private String name;        //姓名  
    private boolean sex;            //性别  
    private Short age;          //年龄  
    private Date birthday;      //出生日期  
    private String address;     //地址  
    private String telephone        //电话  
 
    @Id 
    @GeneratedValue 
    public Integer getStudentid() {  
        return studentid;  
    }  
 
    public void setStudentid(Integer studentid) {  
        this.studentid = studentid;  
    }  
 
    @Column(name = "name", length = 50)  
    public String getName() {  
        return name;  
    }  
 
    public void setName(String name) {  
        this.name = name;  
    }  
 
    @Column(nullable = false)  
    public boolean getSex() {  
        return sex;  
    }  
 
    public void setSex(boolean sex) {  
        this.sex = sex;  
    }  
 
    @Column(nullable = false)  
    public Short getAge() {  
        return age;  
    }  
 
    public void setAge(Short age) {  
        this.age = age;  
    }  
 
    public Date getBirthday() {  
        return birthday;  
    }  
 
    public void setBirthday(Date birthday) {  
        this.birthday = birthday;  
    }  
 
    @Column(name = "address", length = 100)  
    public String getAddress() {  
        return address;  
    }  
 
    public void setAddress(String address) {  
        this.address = address;  
    }  
 
    @Column(name = "telephone", length = 20)  
    public String getTelephone() {  
        return telephone;  
    }  
 
    public void setTelephone(String telephone) {  
        this.telephone = telephone;  
    }  
} 

实体Bean通常须要实现Serializable接口。这样就能够有EJBclient创建该对象,并将该对象传送到服务端,否则将引发java.io.InvalidClassException例外。



该类是一个Java POJO类,当中包括了7个变量,并为每一个变量加入了getter/setter函数。

为了将该POJO类表现为一个实体Bean,加入了一些凝视符。来与数据表student进行相应。这些凝视例如以下。



@Entity凝视指明这是一个实体Bean,每一个实体Bean类映射数据库中的一个表。


@Table凝视的name属性指定映射的数据表名称,Student类映射的数据表为Student。
@Column凝视定义了映射到列的全部属性,如列名是否唯一,是否同意为空,是否同意更新等,其属性介绍例如以下。



name:映射的列名。如映射Student表的name列,能够在name属性的getName()方法上面增加@Column(name = "name"),假设不指定映射列名,则容器会将属性名称作为默认的映射列名。


unique:是否唯一。

nullable:是否同意为空。
length:对于字符型列,length属性指定列的最大字符长度。
insertable:是否同意插入。
updatable:是否同意更新。
columnDefinition:定义建表时创建此列的DDL。
secondaryTable:从表名。假设此列不建在主表上(默认建在主表上),则该属性定义该列所在的从表的名字。
@Lob凝视指定某一个字段为大的文本字段类型。
@Id凝视指定studentid属性为表的主键。


@GeneratedValue凝视定义了标识字段的生成方式,本例中的studentid的值由MySQL数据库自己主动生成。它能够有下面多种生成方式。



TABLE:容器指定用底层的数据表确保唯一。
SEQUENCE:使用数据库的SEQUENCE 列来保证唯一。


IDENTITY:使用数据库的INDENTIT列来保证唯一。


AUTO:由容器挑选一个合适的方式来保证唯一。


NONE:容器不负责主键的生成,由调用程序来完毕。

比如:

@Id 
@GeneratedValue(strategy = GenerationType.IDENTITY)  
public Integer getId() {  
    return this.id;  
} 

这样就开发完实体Bean了。它除了在POJO上加入了一些凝视外。与普通的POJO类没有不论什么差别。



五、开发会话Bean进行调用

1、开发会话Bean进行调用--StudentDAORemote.java和StudentDAO.java       。


        以下我们来开发一个远程的会话Bean组件,通过调用实体Bean类Student.java,来实现往数据表student中插入一条记录。
        首先在项目EntityBeanTest中新建一个包com.ejb.dao,然后依照会话Bean的开发方法。在该包中新建一个远程的会话Bean组件StudentDAO。新建完后会产生一个远程接口类StudentDAORemote.java和实现类StudentDAO.java。



1)远程接口类StudentDAORemote.java

        通过凝视符@Remote进行标识。

        函数insert()运行插入student功能

远程接口类StudentDAORemote.java

<span style="font-family:SimSun;">package com.ejb.dao;  
 
import java.util.List;  
import javax.ejb.Remote;  
import com.ejb.entitybean.Student;  
 
@Remote 
public interface StudentDAORemote {  
    public boolean insert(Student student);  
} </span>

2)实现类StudentDAO.java
        实现了远程接口StudentDAORemote.java,并通过@Stateless标识为无状态会话Bean。


        首先它包括了一个EntityManager类型的变量em。EntityManager是实体管理器。顾名思义。它是实体Bean的管理容器。通过该对象,我们可以实现与数据库的各种交互,包括增、删、改、查等。
        该实体变量em还通过凝视@PersistenceContext来实现动态注入EntityManager对象,假设persistence.xml文件里配置了多个不同的持久化内容。则还须要指定持久化名称注入EntityManager 对象,能够通过@PersistenceContext凝视的unitName属性进行指定,比如:

@PersistenceContext(unitName="exam-entity")  
EntityManager em; 

假设仅仅有一个持久化内容配置。则不须要明白指定。
        然后开发该类实现接口中的函数insert(),仅仅须要调用em的persist()函数。就行将Student对象持久化到数据库中。即往数据库中新增一条记录。
实现类StudentDAO.java

package com.ejb.dao;  
 
import java.util.List;  
import javax.ejb.Stateless;  
import javax.persistence.EntityManager;  
import javax.persistence.PersistenceContext;  
import javax.persistence.Query;  
import com.ejb.entitybean.Student;  
 
@Stateless 
public class StudentDAO implements StudentDAORemote {  
    @PersistenceContext 
    protected EntityManager em;  
 
    public boolean insert(Student student) {  
        try {  
            em.persist(student);  
        } catch (Exception e) {  
            e.printStackTrace();  
            return false;  
        }  
        return true;  
    }  
}


六、打包并部署到JBOSSserver

打成jar包并部署到JBossserver。JBossserver就会自己主动载入该服务。形成JNDI服务供外部訪问了。

该公布步骤例如以下:

1、载入persistence.xml文件。

2、创建数据库表student,此时查看MySQL数据库就会看到新建的表student。

3、公布JNDI服务StudentDAO/remote。

这样我们就能够通过client訪问JNDI服务StudentDAO/remote了。


七、开发client进行測试-StudentDAOClient.java

        开发client进行測试--StudentDAOClient.java
        以上我们开发了实体Bean和会话Bean组件,并公布到了JBossserver中,以下我们来开发一个Javaclient程序,在该client创建一个实体对象,然后调用会话Bean组件插入该对象,往数据表中插入一条记录。


        首先将实体类Student.java和接口类StudentDAORemote.java复制加入到測试项目EJBTestJava的相应包中,然后新建測试类


測试类StudentDAOClient.java

import java.text.ParseException;  
import java.text.SimpleDateFormat;  
import java.util.Properties;  
 
import javax.naming.InitialContext;  
import javax.naming.NamingException;  
 
import com.ejb.dao.StudentDAORemote;  
import com.ejb.entitybean.Student;  
 
public class StudentDAOClient {  
    public static void main(String[] args) throws NamingException {  
        Properties props = new Properties();  
        props.setProperty("java.naming.factory.initial",  
                "org.jnp.interfaces.NamingContextFactory");  
        props.setProperty("java.naming.provider.url", "localhost:1099");  
        props.setProperty("java.naming.factory.url.pkgs", "org.jboss.naming");  
        try {  
            InitialContext ctx = new InitialContext(props);  
            StudentDAORemote studentDAO = (StudentDAORemote) ctx.lookup("StudentDAO/remote");  
              
            Student student = new Student();  
            student.setName("刘中兵");  
            student.setSex(true);  
            student.setAge((short)25);  
            SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd");  
            student.setBirthday(format.parse("1981-05-04"));  
            student.setTelephone("12345678");  
            student.setAddress("北京");  
              
            studentDAO.insert(student);  
            System.out.println("已经插入一个学生记录!");  
              
        } catch (NamingException e) {  
            e.printStackTrace();  
        } catch (ParseException e) {  
            e.printStackTrace();  
        }  
    }  
} 
        该类通过訪问远程JNDI服务StudentDAO/remote,取得了远程会话Bean实例studentDAO。然后创建了一个Student实体对象。调用insert()函数插入该对象。

执行该程序后,会在控制台中输出例如以下信息:
        已经插入一个学生记录!
        这就表明client的Java类已正确地将Student对象提交到远程会话Bean组件中了。

        经过第一次载入后的实体Bean对象已经被实体管理器EntityManager缓存了,再次訪问时,就会直接从缓存中取得该实体对象。





本文转自mfrbuaa博客园博客,原文链接:http://www.cnblogs.com/mfrbuaa/p/5271309.html,如需转载请自行联系原作者

相关实践学习
如何快速连接云数据库RDS MySQL
本场景介绍如何通过阿里云数据管理服务DMS快速连接云数据库RDS MySQL,然后进行数据表的CRUD操作。
全面了解阿里云能为你做什么
阿里云在全球各地部署高效节能的绿色数据中心,利用清洁计算为万物互联的新世界提供源源不断的能源动力,目前开服的区域包括中国(华北、华东、华南、香港)、新加坡、美国(美东、美西)、欧洲、中东、澳大利亚、日本。目前阿里云的产品涵盖弹性计算、数据库、存储与CDN、分析与搜索、云通信、网络、管理与监控、应用服务、互联网中间件、移动服务、视频服务等。通过本课程,来了解阿里云能够为你的业务带来哪些帮助 &nbsp; &nbsp; 相关的阿里云产品:云服务器ECS 云服务器 ECS(Elastic Compute Service)是一种弹性可伸缩的计算服务,助您降低 IT 成本,提升运维效率,使您更专注于核心业务创新。产品详情: https://www.aliyun.com/product/ecs
相关文章
|
6天前
|
存储 JSON NoSQL
学习 MongoDB:打开强大的数据库技术大门
MongoDB 是一个基于分布式文件存储的文档数据库,由 C++ 编写,旨在为 Web 应用提供可扩展的高性能数据存储解决方案。它与 MySQL 类似,但使用文档结构而非表结构。核心概念包括:数据库(Database)、集合(Collection)、文档(Document)和字段(Field)。MongoDB 使用 BSON 格式存储数据,支持多种数据类型,如字符串、整数、数组等,并通过二进制编码实现高效存储和传输。BSON 文档结构类似 JSON,但更紧凑,适合网络传输。
31 15
|
2天前
|
存储 JSON 测试技术
【HarmonyOS Next开发】云开发-云数据库(二)
实现了云侧和端侧的云数据库创建、更新、修改等操作。这篇文章实现调用云函数对云数据库进行增删改查。
19 9
|
1天前
|
API 数据安全/隐私保护 UED
探索鸿蒙的蓝牙A2DP与访问API:从学习到实现的开发之旅
在掌握了鸿蒙系统的开发基础后,我挑战了蓝牙功能的开发。通过Bluetooth A2DP和Access API,实现了蓝牙音频流传输、设备连接和权限管理。具体步骤包括:理解API作用、配置环境与权限、扫描并连接设备、实现音频流控制及动态切换设备。最终,我构建了一个简单的蓝牙音频播放器,具备设备扫描、连接、音频播放与停止、切换输出设备等功能。这次开发让我对蓝牙技术有了更深的理解,也为未来的复杂项目打下了坚实的基础。
77 58
探索鸿蒙的蓝牙A2DP与访问API:从学习到实现的开发之旅
|
7天前
|
监控 供应链 搜索推荐
阿里妈妈商品详情API接口:开发、应用与收益的深度剖析
阿里妈妈是阿里巴巴旗下的数字营销平台,其商品详情API接口为开发者提供了获取淘宝、天猫等电商平台商品详细信息的工具。本文介绍了该接口的开发流程、应用场景及带来的收益,揭示了其在电商生态中的重要地位。
54 6
|
7天前
|
供应链 搜索推荐 API
1688APP原数据API接口的开发、应用与收益(一篇文章全明白)
1688作为全球知名的B2B电商平台,通过开放的原数据API接口,为开发者提供了丰富的数据资源,涵盖商品信息、交易数据、店铺信息、物流信息和用户信息等。本文将深入探讨1688 APP原数据API接口的开发、应用及其带来的商业收益,包括提升流量、优化库存管理、增强用户体验等方面。
44 6
|
9天前
|
监控 搜索推荐 API
京东商品详情API接口的开发、应用与收益探索
在数字化和互联网高速发展的时代,京东通过开放商品详情API接口,为开发者、企业和商家提供了丰富的数据源和创新空间。本文将探讨该API接口的开发背景、流程、应用场景及带来的多重收益,包括促进生态系统建设、提升数据利用效率和推动数字化转型等。
33 3
|
14天前
|
供应链 搜索推荐 API
探索1688榜单商品详细信息API接口:开发、应用与收益
本文深入探讨了1688榜单商品详细信息API接口的开发与应用,涵盖接口概述、开发条件、调用方法及数据处理等内容。该API帮助企业高效获取1688平台商品信息,应用于商品信息采集、校验、同步与数据分析等领域,有效提升了企业的运营效率、库存管理、销售转化率及市场策略制定能力,降低了采购成本,提升了客户满意度。
37 9
|
17天前
|
算法 Java API
如何使用Java开发获得淘宝商品描述API接口?
本文详细介绍如何使用Java开发调用淘宝商品描述API接口,涵盖从注册淘宝开放平台账号、阅读平台规则、创建应用并申请接口权限,到安装开发工具、配置开发环境、获取访问令牌,以及具体的Java代码实现和注意事项。通过遵循这些步骤,开发者可以高效地获取商品详情、描述及图片等信息,为项目和业务增添价值。
52 10
|
17天前
|
存储 API 数据库
使用Python开发获取商品销量详情API接口
本文介绍了使用Python开发获取商品销量详情的API接口方法,涵盖API接口概述、技术选型(Flask与FastAPI)、环境准备、API接口创建及调用淘宝开放平台API等内容。通过示例代码,详细说明了如何构建和调用API,以及开发过程中需要注意的事项,如数据库连接、API权限、错误处理、安全性和性能优化等。
69 5
|
16天前
|
数据可视化 搜索推荐 API
速卖通获得aliexpress商品详情API接口的开发、应用与收益。
速卖通(AliExpress)作为阿里巴巴旗下的跨境电商平台,为全球消费者提供丰富商品。其开放平台提供的API接口支持开发者获取商品详情等信息,本文探讨了速卖通商品详情API的开发流程、应用场景及潜在收益,包括提高运营效率、降低成本、增加收入和提升竞争力等方面。
35 1