在glassfish中没有persistence.xml的JTA EntityManagerFactory

如何解决在glassfish中没有persistence.xml的JTA EntityManagerFactory

基于这个例子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();
}