先上配置文件
存放目录：META-INF/persistence.xml
<?xml version="1.0"?>
<persistence xmlns="/xml/ns/persistence"
xmlns:xsi="/2001/XMLSchema-instance"
xsi:schemaLocation="/xml/ns/persistence
/xml/ns/persistence/persistence_1_0.xsd" version="1.0" >
<persistence-unit name="xkEntity" transaction-type="JTA">
<jta-data-source>MySqlDS</jta-data-source>
<properties>
<property name="hibernate.hbm2ddl.auto" value="update" />
<property name="hibernate.jdbc.fetch_size" value="18" />
<property name="hibernate.jdbc.batch_size" value="10" />
<property name="hibernate.show_sql" value="true" />
<property name="hibernate.format_sql" value="true" />
</properties>
</persistence-unit>
</persistence>
建立EJBProject
package com.entity;import java.io.Serializable;import javax.persistence.Column;import javax.persistence.Entity;import javax.persistence.GeneratedValue;import javax.persistence.GenerationType;import javax.persistence.Id;import javax.persistence.Table;@Entity@Table(name="user_info")public class User implements Serializable{@Id@Column(name="user_id")private String id;@Column(name="user_name",length=30)private String name;public User() {}public String getId() {return this.id;}public void setId(String id) {this.id = id;}public int hashCode() {return (this.id == null) ? 0 : this.id.hashCode();}public boolean equals(Object object) {if (object instanceof User) {final User obj = (User) object;return (this.id != null) ? this.id.equals(obj.id): (obj.id == null);}return false;}public void setName(String name) {this.name = name;}public String getName() {return name;}}
package com;import javax.ejb.Remote;import com.entity.User;@Remotepublic interface UtilEntityDAORemote<T> {public User getEntity(String id);}
package com;import javax.ejb.Stateless;import javax.persistence.EntityManager;import javax.persistence.PersistenceContext;import javax.persistence.Query;import com.entity.User;@Statelesspublic class UtilEntityDAO<T> implements UtilEntityDAORemote {@PersistenceContext(name="xkEntity")EntityManager em;public User getEntity(String id) {// TODO Auto-generated method stubQuery query= em.createQuery("from User us where us.id=:id");
query.setParameter("id", id);
return (User) query.getSingleResult();}}
发布到jboss/server/all/deploy下面
测试
package com;import java.util.Properties;import javax.naming.InitialContext;import javax.naming.NamingException;import com.entity.User;public class test {public static void main(String[] args){Properties prop=new Properties();prop.setProperty("java.naming.factory.initial", "org.jnp.interfaces.NamingContextFactory");prop.setProperty("java.naming.provider.url", "localhost:1100");prop.setProperty("java.naming.factory.url.pkgs", "org.jboss.naming");InitialContext ctx;try {ctx=new InitialContext(prop);UtilEntityDAORemote util=(UtilEntityDAORemote) ctx.lookup("UtilEntityDAO/remote");User u= util.getEntity("1");System.out.println(u.getName());} catch (NamingException e) {// TODO Auto-generated catch blocke.printStackTrace();}}}
ok结束
下面说点问题 这个例子是在jboss6.0final下完成的。所以相关的jar包一定要用jboss6的。不然会报错。
贴上datasource配置
<?xml version="1.0" encoding="UTF-8"?>
<!-- See /community/wiki/Multiple1PC for information about local-tx-datasource -->
<!-- $Id: mysql-ds.xml 97536 -12-08 14:05:07Z jesper.pedersen $ -->
<!-- Datasource config for MySQL using 3.0.9 available from:
/downloads/api-jdbc-stable.html
-->
<datasources>
<local-tx-datasource>
<jndi-name>MySqlDS</jndi-name>
<use-java-context>false</use-java-context>
<connection-url>jdbc:mysql://127.0.0.1:3306/test</connection-url>
<driver-class>com.mysql.jdbc.Driver</driver-class>
<min-pool-size>30</min-pool-size>
<max-pool-size>50</max-pool-size>
<exception-sorter-class-name>org.jboss.resource.adapter.jdbc.vendor.MySQLExceptionSorter</exception-sorter-class-name>
<!-- should only be used on drivers after 3.22.1 with "ping" support
<valid-connection-checker-class-name>org.jboss.resource.adapter.jdbc.vendor.MySQLValidConnectionChecker</valid-connection-checker-class-name>
-->
<!-- sql to call when connection is created
<new-connection-sql>some arbitrary sql</new-connection-sql>
-->
<!-- sql to call on an existing pooled connection when it is obtained from pool - MySQLValidConnectionChecker is preferred for newer drivers-->
<check-valid-connection-sql>select * from user_info</check-valid-connection-sql>
<security-domain>MysqlDSRealm</security-domain>
<!-- corresponding type-mapping in the standardjbosscmp-jdbc.xml (optional) -->
<metadata>
<type-mapping>mySQL</type-mapping>
</metadata>
</local-tx-datasource>
</datasources>
当前配置文件中没有写用户名密码而是用<security-domain>MysqlDSRealm</security-domain>来验证。配置路径server/all/conf/login-config.xml
<application-policy name="MysqlDSRealm">
<authentication>
<login-module code="org.jboss.resource.security.ConfiguredIdentityLoginModule"
flag="required">
<module-option name="principal">root</module-option>
<module-option name="userName">root</module-option>
<module-option name="password">root</module-option>
<module-option name="managedConnectionFactoryName">jboss.jca:service=LocalTxCM,name=MySqlDS</module-option>
</login-module>
</authentication>
</application-policy>
ok完毕
