问题描述
基于这个例子JPA Multitenancy,我试图在 glassfish 4 + mssql + hibernate 中创建一个没有 persistence.xml 的 entitymanagerfactory。
我使用 HibernatePersistenceProvider 和 PersistenceUnitInfoBuilder 来实现它,如下所示:
@Singleton
@Startup
public class TenantRegistry {
private final Set<String> tenants2 = new HashSet<>();
private final Map<String,EntityManagerFactory> entityManagerFactories = new HashMap<>();
public void startTenant(String usuario,String pass){
final EntityManagerFactory emf = init(usuario,pass);
entityManagerFactories.put(usuario,emf);
this.tenants2.add(usuario);
}
private EntityManagerFactory init(String username,String pass){
Map<String,Object> properties = new HashMap<>();
EntityManagerFactory entityManagerFactory = null;
PersistenceUnitInfoBuilder pub = new PersistenceUnitInfoBuilder();
final PersistenceUnitInfo unitInfo = pub
.setExcludeUnlistedClasses( false )
.setJtaDataSource( getDS(username,pass) )
.setPersistenceProviderClassName( HibernatePersistenceProvider.class.getName() )
.setPersistenceUnitName( "test-jta" )
.setPersistenceXMLSchemaVersion( "2.0" )
.setTransactionType( PersistenceUnitTransactionType.JTA )
.addManagedClassNames( Notasventas.class.getName() )
.addManagedClassNames( NotasventasPK.class.getName() )
.addProperty( Environment.DIALECT,"org.hibernate.dialect.sqlServerDialect" )
.addProperty( Environment.SHOW_sql,"true" )
.addProperty( Environment.FORMAT_sql,"true" )
.addProperty( Environment.AUTOCOMMIT,"false" )
.addProperty( Environment.GENERATE_STATISTICS,"true" )
.addProperty( Environment.CURRENT_SESSION_CONTEXT_CLASS,"jta" )
.addProperty( Environment.JTA_PLATFORM,"org.hibernate.service.jta.platform.internal.SunOneJtaPlatform" )
.create();
final HibernatePersistenceProvider hp = new HibernatePersistenceProvider();
entityManagerFactory = hp.createContainerEntityManagerFactory( unitInfo,properties );
return entityManagerFactory;
}
private DataSource getDS(String username,String pass ) {
try{
sqlServerDataSource ds = new sqlServerDataSource();
ds.setUser(username);
ds.setPassword(pass);
ds.setServerName("localhost");
ds.setPortNumber(1433);
ds.setDatabaseName("VenlogDB");
return ds;
} catch (Exception e) {
e.printstacktrace();
}
return null;
}
public EntityManagerFactory getEntityManagerFactory(final String tenantName) {
return entityManagerFactories.get(tenantName);
}
到目前为止一切都很好,问题是当我尝试使用 usertransaction 时,它不会在出现错误时回滚事务 (userTransaction)。
这是我的豆子:
@Named
@ViewScoped
@TransactionManagement(TransactionManagementType.BEAN)
public class PedidosBean implements Serializable {
@Inject
private Entriesstorage storage;
@Resource
private UserTransaction userTransaction;
public void testTrx(){
try {
userTransaction.begin();
storage.persistCab();
storage.persisDet();
new Exception("Test for rollback");
} catch (Exception e) {
e.printstacktrace();
try{
userTransaction.rollback();
}catch (Exception ex) {
System.out.println("*********************Error al hacer rollback*********************");
ex.printstacktrace();
}
}
}
这是我的 EJB
@Stateless
public class EntriesstorageImpl implements Entriesstorage {
private EntityManager entityManager;
@Inject
private TenantRegistry tenantRegistry;
@Override
public EntityManager getEntityManager() {
if (entityManager == null) {
String currentTenant = TenantHolder.getCurrentTenant();
entityManager = tenantRegistry.getEntityManagerFactory(currentTenant).createEntityManager();
entityManager.joinTransaction();
}
return entityManager;
}
@Override
public void persistCab() {
String sql = "INSERT INTO dbo.notas_ventas (cod_empr,ctipo_docum,nro_nota,fdocum,xobs,mestado,cod_depo,cod_cliente,cconc,nrofact,fac_ctipo_docum,texentas,tgravadas,timpuestos,ttotal,isaldo,cod_entregador,NRO_PROMO,xnro_nota,ffactur) values ( 2,'NCV',1010027926,'20190520','','A',16,25703,'DES',1010001001,'FCO',11097,-528,null,'001-001-0027926','20130621' )";
Query q = getEntityManager().createNativeQuery(sql);
q.executeUpdate();
}
@Override
public void persisDet() {
String sql = "INSERT INTO dbo.notas_ventas_det(cod_empr,cod_merca,xdesc,pdesc,cant_cajas,cant_unid,iexentas,igravadas,impuestos,iprecio_caja,iprecio_unid,pimpues,fdocum) VALUES ( 2,10100279266666,'A550042','CAMPESINO MEZCLA MAESTRA 10*500 G ',5,10,3411,-162,6480.9000,5.00,'20190520')";
Query q = getEntityManager().createNativeQuery(sql);
q.executeUpdate();
}
解决方法
暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!
如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@)