EJB(Enterprise JavaBeans)是Java EE(Java Enterprise Edition)平台中的重要标准,用于构建分布式应用程序。MySQL是一种开源的关系型数据库管理系统,常用于作为企业级应用数据存储。这篇文章将介绍如何在EJB中使用MySQL数据库。
首先,我们需要添加MySQL的驱动程序作为Maven依赖项:
<dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>8.0.13</version> </dependency>
接下来,我们需要在EJB中创建与MySQL数据库连接的数据源。我们可以在Wildfly应用服务器的管理控制台中创建一个JDBC数据源。一旦创建了数据源,我们就可以在EJB的persistence.xml文件中引用它,并定义我们的持久性单元:
<persistence xmlns="http://xmlns.jcp.org/xml/ns/persistence" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://xmlns.jcp.org/xml/ns/persistence http://xmlns.jcp.org/xml/ns/persistence/persistence_2_2.xsd" version="2.2"> <persistence-unit name="MyPersistenceUnit"> <jta-data-source>jdbc/MyDataSource</jta-data-source> <class>com.example.myapp.MyEntity</class> <exclude-unlisted-classes>true</exclude-unlisted-classes> <properties> <property name="hibernate.show_sql" value="true"/> <property name="hibernate.format_sql" value="true"/> </properties> </persistence-unit> </persistence>
现在我们已经创建了持久性单元并与MySQL数据库建立了连接。接下来,我们可以在我们的 EJB 中使用 Java Persistence API(JPA)来操作 MySQL 数据库:
@Stateless public class MyEjb { @PersistenceContext(unitName = "MyPersistenceUnit") private EntityManager em; public void save(MyEntity entity) { em.persist(entity); } public List<MyEntity> findAll() { TypedQuery<MyEntity> query = em.createQuery( "SELECT e FROM MyEntity e",MyEntity.class); return query.getResultList(); } }
在上面的代码中,我们使用了注解@PersistenceContext来注入EntityManager。我们还定义了两个方法:save()方法用于将实体保存到数据库中,findAll()方法用于查询数据库并返回所有 MyEntity 对象的列表。
在这篇文章中,我们讨论了如何在EJB中使用MySQL数据库。我们了解了如何添加MySQL依赖项,创建数据源并定义持久性单元。最后,我们在我们的EJB中使用JPA操作MySQL数据库。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。