首页 > Java开发 > JBoss + EJB3 + MySql : 开发第一个EJB

JBoss + EJB3 + MySql : 开发第一个EJB

孤风一剑 7月 15, 2013 284 0

JBoss开发Bean并不困难，而对于不知道的人来说，数据库配置才是比较棘手的问题。现在我们就来一步一步开发一个EJB3 + MySql的Bean。

 

一、MySql数据库的配置

1. 配置数据源

在 %JBOSS_HOME%/docs/examples/jca 目录下找到一个名叫 “mysql-db.xml” 的文件，这个是官方为我们写好的针对mysql的数据源配置文件，我们改改它就行了。

将 mysql-db.xml 复制到 /server/default/deploy 目录下，并将文件内容修改为：

 

[html][/html] view plaincopyprint?

  1. <?xml version=”1.0″ encoding=”UTF-8″?>
  3. <!– $Id: mysql-ds.xml 41017 2006-02-07 14:26:14Z acoliver $ –>
  4. <!–  Datasource config for MySQL using 3.0.9 available from:
  5. http://www.mysql.com/downloads/api-jdbc-stable.html
  6. –>
  8. <datasources>
  9.   <local-tx-datasource>
  10.     <jndi-name>MySqlDS</jndi-name>
  11.     <connection-url>jdbc:mysql://localhost:3306/ejb</connection-url>
  12.     <driver-class>com.mysql.jdbc.Driver</driver-class>
  13.     <user-name>root</user-name>
  14.     <password>0000</password>
  15.     <exception-sorter-class-name>org.jboss.resource.adapter.jdbc.vendor.MySQLExceptionSorter</exception-sorter-class-name>
  16.     <metadata>
  17.        <type-mapping>mySQL</type-mapping>
  18.     </metadata>
  19.   </local-tx-datasource>
  20. </datasources>

<user-name>是你的mysql数据库用户名，同理<password>是连接密码。

 

2. 配置persistence.xml

persistence.xml 是 Java Persistence 规范要求我们定义的一个部署描述文件，作用是配置一些基本信息，如EntityManager服务的名称。我们在项目目录的 METAINF/ 目录下创建这个文件：

 

[html][/html] view plaincopyprint?

  1. <?xml version=”1.0″ encoding=”UTF-8″?>
  2. <persistence xmlns=”http://java.sun.com/xml/ns/persistence”
  3.     xmlns:xsi=”http://www.w3.org/2001/XMLSchema-instance”
  4.     xsi:schemaLocation=”http://java.sun.com/xml/ns/persistence
  5.     http://java.sun.com/xml/ns/persistence/persistence_1_0.xsd” version=”1.0″>
  7.  <!– entity就是EntityManager服务名 –>
  8.  <persistence-unit name=”entity” transaction-type=”JTA”>
  9.     <!– 这里必须跟mysql-db.xml文件中的<jndi-name>一样，即MySqlDs –>
  10.     <jta-data-source>java:/MySqlDS</jta-data-source>
  11.     <!– 以下是hibernate的相关配置，可省略 –>
  12.     <properties>
  13.              <property name=”hibernate.dialect” value=”org.hibernate.dialect.MySQLDialect”/>
  14.              <property name=”hibernate.hbm2ddl.auto” value=”update”/>
  15.              <property name=”hibernate.connection.characterEncoding” value=”UTF-8″ />
  16.     </properties>
  17.  </persistence-unit>
  19. </persistence>

 

 

至此数据库配置完毕。

 

二、开发Bean

1. 开发Entity Bean

我们创建一个名为 User 的实体Bean, 用来保存一个用户的基本信息，如用户名，密码。

 

[java][/java] view plaincopyprint?

  1. package dev.entity;
  3. import java.io.Serializable;
  5. import javax.persistence.Column;
  6. import javax.persistence.Entity;
  7. import javax.persistence.Id;
  8. import javax.persistence.Table;
  10. @Entity
  11. @Table(name = “DB_USER”)
  12. public class User implements Serializable {
  13.     @Id
  14.     @Column(name = “C_ID”)
  15.     private int id;
  16.     @Column(name = “C_NAME”)
  17.     private String name;
  18.     @Column(name = “C_PASSWORD”)
  19.     private String pwd;
  21.     //get() and set()
  22. }

 

然后编写以下语句创建数据表 DB_USER:

 

[sql][/sql] view plaincopyprint?

  1. create table DB_USER(
  2. C_ID int key,
  3. C_NAME varchar(40),
  4. C_PASSWORD varchar(40)
  5. );

 

 

 

2. 开发Session Bean

我们的Session Bean将包括2个功用：一是创建并持久化一个User类，二是从数据库中取回一个User对象。

首先创建远程接口 UserBeanRemote :

 

[java][/java] view plaincopyprint?

  1. package dev.bean;
  3. import javax.ejb.Remote;
  4. import dev.entity.*;
  6. @Remote
  7. public interface UserBeanRemote {
  8.     void createUser(User user); //创建User
  9.     User getUser(int id); //查询并获取User
  10. }

然后创建会话Bean : UserBean

 

 

[java][/java] view plaincopyprint?

  1. package dev.bean;
  3. import javax.ejb.Stateless;
  4. import javax.persistence.EntityManager;
  5. import javax.persistence.PersistenceContext;
  7. import dev.entity.*;
  8. @Stateless
  9. public class UserBean implements UserBeanRemote {
  10.     @PersistenceContext(unitName = “entity”)
  11.     private EntityManager manager;
  13.     public void createUser(User user) {
  14.     manager.persist(user);
  15.     }
  17.     public User getUser(int id) {
  18.     return manager.find(User.class, id);
  19.     }
  20. }

至此 Bean开发完毕。

 

 

三、部署 EJB

Eclipse中，在项目名上右击，选择 Export. 在弹出的向导中选择 EJB JAR file. 然后按照提示即可完成部署。

 

四、编写测试代码

 

[java][/java] view plaincopyprint?

  1. public class Client {
  2.     public static void main(String[] args) {
  3.     try {
  4.         Context context = initContext();
  5.         UserBeanRemote ubr = (UserBeanRemote)context.lookup(“UserBean/remote”);
  7.         User user = new User();
  8.         user.setId(4);
  9.         user.setName(“bruce lee”);
  10.         user.setPwd(“123456”);
  12.         ubr.createUser(user);
  14.         /*User user = (User)ubr.getUser(2);
  15.         System.out.println(user.getName());*/
  17.         System.out.println(“success!”);
  18.     }
  19.     catch (Exception ex) {
  20.         ex.printStackTrace();
  21.     }
  22.     }
  24.     /*
  25.      * 这一部分是写死的
  26.      * 固定写法
  27.      */
  28.     public static Context initContext() throws javax.naming.NamingException {
  29.     Properties prop = new Properties();
  30.     prop.put(Context.INITIAL_CONTEXT_FACTORY,”org.jnp.interfaces.NamingContextFactory”);
  31.     prop.put(Context.URL_PKG_PREFIXES,”org.jboss.naming:org.jnp.interfaces”);
  32.     prop.put(Context.PROVIDER_URL, “jnp://localhost:1099”);
  34.     return new javax.naming.InitialContext(prop);
  35.     }
  37. }

至此一个简单的EJB3已经开发完成。

标签

相关推荐

标签

.NET (32) ActiveMQ (34) AJAX (29) android (463) android开发 (34) ASP.NET (58) C# (153) CSS (21) eclipse (50) Hadoop (23) Hibernate (51) HTML (30) html5 (29) IOS (48) JAVA (378) JavaScript (87) JQuery (85) js (53) json (26) jsp (28) Linux (70) ListView (28) mvc (28) myeclipse (25) MySQL (151) oracle (181) PHP (158) spring (84) SQL (62) SQL Server (28) string (20) Struts2 (39) Tomcat (39) Ubuntu (20) WEB (28) webservice (29) Windows (27) XML (36) 多线程 (21) 存储过程 (22) 实例 (24) 数据库 (89) 服务器 (31) 算法 (34) 设计模式 (23)

文章归档