Java 类org.hibernate.ejb.HibernateEntityManager 实例源码

项目：metaworks_framework 文件：DynamicDaoHelperImpl.java

@Override
public Map<String, Object> getIdMetadata(Class<?> entityClass, HibernateEntityManager entityManager) {
    Map<String, Object> response = new HashMap<String, Object>();
    SessionFactory sessionFactory = entityManager.getSession().getSessionFactory();

    ClassMetadata metadata = sessionFactory.getClassMetadata(entityClass);
    if (metadata == null) {
        return null;
    }

    String idProperty = metadata.getIdentifierPropertyName();
    response.put("name", idProperty);
    Type idType = metadata.getIdentifierType();
    response.put("type", idType);

    return response;
}

项目：SparkCommerce 文件：DynamicDaoHelperImpl.java

@Override
public Map<String, Object> getIdMetadata(Class<?> entityClass, HibernateEntityManager entityManager) {
    Map<String, Object> response = new HashMap<String, Object>();
    SessionFactory sessionFactory = entityManager.getSession().getSessionFactory();

    ClassMetadata metadata = sessionFactory.getClassMetadata(entityClass);
    if (metadata == null) {
        return null;
    }

    String idProperty = metadata.getIdentifierPropertyName();
    response.put("name", idProperty);
    Type idType = metadata.getIdentifierType();
    response.put("type", idType);

    return response;
}

项目：blcdemo 文件：DynamicDaoHelperImpl.java

@Override
public Map<String, Object> getIdMetadata(Class<?> entityClass, HibernateEntityManager entityManager) {
    entityClass = getNonProxyImplementationClassIfNecessary(entityClass);
    Map<String, Object> response = new HashMap<String, Object>();
    SessionFactory sessionFactory = entityManager.getSession().getSessionFactory();

    ClassMetadata metadata = sessionFactory.getClassMetadata(entityClass);
    if (metadata == null) {
        return null;
    }

    String idProperty = metadata.getIdentifierPropertyName();
    response.put("name", idProperty);
    Type idType = metadata.getIdentifierType();
    response.put("type", idType);

    return response;
}

项目：sigmah 文件：SQLDialectProvider.java

private void init(HibernateEntityManager hem) {
    hem.getSession().doWork(new Work() {

        @Override
        public void execute(Connection connection) throws SQLException {
            String dbName = connection.getMetaData().getDatabaseProductName();
            if (dbName.equals(MSSQLDialect.PRODUCT_NAME)) {
                dialect = new MSSQLDialect();
            } else if (dbName.equals(PostgresDialect.PRODUCT_NAME)) {
                dialect = new PostgresDialect();
            } else if (dbName.equals(H2Dialect.PRODUCT_NAME)) {
                dialect = new H2Dialect();
            } else if (dbName.equals(MySQLDialect.PRODUCT_NAME)) {
                dialect = new MySQLDialect();
            } else {
                dialect = new DefaultDialect();
            }
        }
    });
}

项目：sigmah 文件：GetIndicatorsHandler.java

/**
 * {@inheritDoc}
 */
@Override
public IndicatorListResult execute(final GetIndicators cmd, final UserExecutionContext context) throws CommandException {
    final EntityManager entityManager = em();

    // Creates a new instance for every call.
    // Be careful, this must NOT be a singleton because the DAO is stateful.
    final IndicatorDAO indicatorDAO = new IndicatorHibernateDAO();

    if(entityManager instanceof HibernateEntityManager) {
        findIndicators((HibernateEntityManager)entityManager, indicatorDAO, cmd.getUserDatabaseId());
    } else {
        throw new UnsupportedOperationException("Entity manager type not supported. Required org.hibernate.ejb.HibernateEntityManager, found: " + entityManager.getClass().getName());
    }

    return indicatorDAO.getResult();
}

项目：kuali_rice 文件：BusinessObjectDaoJpa.java

/**
 * Saves a business object.
 * 
 * @see org.kuali.rice.krad.dao.BusinessObjectDao#save(org.kuali.rice.krad.bo.PersistableBusinessObject)
 */
public PersistableBusinessObject save(PersistableBusinessObject bo) throws DataAccessException {
    /* KC determined this is not needed for JPA
    // if collections exist on the BO, create a copy and use to process the
    // collections to ensure
    // that removed elements are deleted from the database
    Set<String> boCollections = getPersistenceStructureService().listCollectionObjectTypes(bo.getClass()).keySet();
    PersistableBusinessObject savedBo = null;
    if (!boCollections.isEmpty()) {
        // refresh bo to get db copy of collections
        savedBo = (PersistableBusinessObject) ObjectUtils.deepCopy(bo);
        for (String boCollection : boCollections) {
            if (getPersistenceStructureService().isCollectionUpdatable(savedBo.getClass(), boCollection)) {
                savedBo.refreshReferenceObject(boCollection);
            }
        }
    }
    */
    if (entityManager.contains(bo) && ((HibernateEntityManager)entityManager).getSession().isReadOnly(bo)) {
        ((HibernateEntityManager)entityManager).getSession().setReadOnly(bo, false); // are we read only?  turn that off...
    }
    return reattachAndSave(bo);
}

项目：metaworks_framework 文件：StaticAssetStorageDaoImpl.java

@Override
public Blob createBlob(MultipartFile uploadedFile) throws IOException {
    Long size = uploadedFile.getSize();
    InputStream inputStream = uploadedFile.getInputStream();
    //We'll work with Blob instances and streams so that the uploaded files are never read into memory
    return ((HibernateEntityManager) em).getSession().getLobHelper().createBlob(inputStream, size);
}

项目：metaworks_framework 文件：GenericEntityDaoImpl.java

@Override
@SuppressWarnings("rawtypes")
public Object readGenericEntity(Class<?> clazz, Object id) {
    Map<String, Object> md = daoHelper.getIdMetadata(clazz, (HibernateEntityManager) em);
    AbstractSingleColumnStandardBasicType type = (AbstractSingleColumnStandardBasicType) md.get("type");

    if (type instanceof LongType) {
        id = Long.parseLong(String.valueOf(id));
    } else if (type instanceof IntegerType) {
        id = Integer.parseInt(String.valueOf(id));
    }

    return em.find(clazz, id);
}

项目：metaworks_framework 文件：DynamicDaoHelperImpl.java

@Override
public List<String> getPropertyNames(Class<?> entityClass, HibernateEntityManager entityManager) {
    ClassMetadata metadata = getSessionFactory(entityManager).getClassMetadata(entityClass);
    List<String> propertyNames = new ArrayList<String>();
    Collections.addAll(propertyNames, metadata.getPropertyNames());
    return propertyNames;
}

项目：metaworks_framework 文件：DynamicDaoHelperImpl.java

@Override
public List<Type> getPropertyTypes(Class<?> entityClass, HibernateEntityManager entityManager) {
    ClassMetadata metadata = getSessionFactory(entityManager).getClassMetadata(entityClass);
    List<Type> propertyTypes = new ArrayList<Type>();
    Collections.addAll(propertyTypes, metadata.getPropertyTypes());
    return propertyTypes;
}

项目：metaworks_framework 文件：OfferDaoImpl.java

@Override
public List<Offer> readOffersByAutomaticDeliveryType() {
    //TODO change this to a JPA criteria
    Criteria criteria = ((HibernateEntityManager) em).getSession().createCriteria(OfferImpl.class);

    Date myDate = getCurrentDateAfterFactoringInDateResolution();

    Calendar c = Calendar.getInstance();
    c.setTime(myDate);
    c.add(Calendar.DATE, +1);
    criteria.add(Restrictions.lt("startDate", c.getTime()));
    c = Calendar.getInstance();
    c.setTime(myDate);
    c.add(Calendar.DATE, -1);
    criteria.add(Restrictions.or(Restrictions.isNull("endDate"), Restrictions.gt("endDate", c.getTime())));
    criteria.add(Restrictions.or(Restrictions.eq("archiveStatus.archived", 'N'),
            Restrictions.isNull("archiveStatus.archived")));

    // Automatically Added or (Automatically Added is null and deliveryType is Automatic)
    criteria.add(Restrictions.or(Restrictions.eq("automaticallyAdded", true),
            Restrictions.and(Restrictions.isNull("automaticallyAdded"),
                    Restrictions.eq("deliveryType", "AUTOMATIC"))));

    criteria.setCacheable(true);
    criteria.setCacheRegion("query.Offer");

    return criteria.list();
}

项目：SparkCommerce 文件：StaticAssetStorageDaoImpl.java

@Override
public Blob createBlob(MultipartFile uploadedFile) throws IOException {
    Long size = uploadedFile.getSize();
    InputStream inputStream = uploadedFile.getInputStream();
    //We'll work with Blob instances and streams so that the uploaded files are never read into memory
    return ((HibernateEntityManager) em).getSession().getLobHelper().createBlob(inputStream, size);
}

项目：SparkCommerce 文件：GenericEntityDaoImpl.java

@Override
@SuppressWarnings("rawtypes")
public Object readGenericEntity(Class<?> clazz, Object id) {
    Map<String, Object> md = daoHelper.getIdMetadata(clazz, (HibernateEntityManager) em);
    AbstractSingleColumnStandardBasicType type = (AbstractSingleColumnStandardBasicType) md.get("type");

    if (type instanceof LongType) {
        id = Long.parseLong(String.valueOf(id));
    } else if (type instanceof IntegerType) {
        id = Integer.parseInt(String.valueOf(id));
    }

    return em.find(clazz, id);
}

项目：SparkCommerce 文件：DynamicDaoHelperImpl.java

@Override
public List<String> getPropertyNames(Class<?> entityClass, HibernateEntityManager entityManager) {
    ClassMetadata metadata = getSessionFactory(entityManager).getClassMetadata(entityClass);
    List<String> propertyNames = new ArrayList<String>();
    Collections.addAll(propertyNames, metadata.getPropertyNames());
    return propertyNames;
}

项目：SparkCommerce 文件：DynamicDaoHelperImpl.java

@Override
public List<Type> getPropertyTypes(Class<?> entityClass, HibernateEntityManager entityManager) {
    ClassMetadata metadata = getSessionFactory(entityManager).getClassMetadata(entityClass);
    List<Type> propertyTypes = new ArrayList<Type>();
    Collections.addAll(propertyTypes, metadata.getPropertyTypes());
    return propertyTypes;
}

项目：SparkCommerce 文件：OfferDaoImpl.java

@Override
public List<Offer> readOffersByAutomaticDeliveryType() {
    //TODO change this to a JPA criteria
    Criteria criteria = ((HibernateEntityManager) em).getSession().createCriteria(OfferImpl.class);

    Date myDate = getCurrentDateAfterFactoringInDateResolution();

    Calendar c = Calendar.getInstance();
    c.setTime(myDate);
    c.add(Calendar.DATE, +1);
    criteria.add(Restrictions.lt("startDate", c.getTime()));
    c = Calendar.getInstance();
    c.setTime(myDate);
    c.add(Calendar.DATE, -1);
    criteria.add(Restrictions.or(Restrictions.isNull("endDate"), Restrictions.gt("endDate", c.getTime())));
    criteria.add(Restrictions.or(Restrictions.eq("archiveStatus.archived", 'N'),
            Restrictions.isNull("archiveStatus.archived")));

    // Automatically Added or (Automatically Added is null and deliveryType is Automatic)
    criteria.add(Restrictions.or(Restrictions.eq("automaticallyAdded", true),
            Restrictions.and(Restrictions.isNull("automaticallyAdded"),
                    Restrictions.eq("deliveryType", "AUTOMATIC"))));

    criteria.setCacheable(true);
    criteria.setCacheRegion("query.Offer");

    return criteria.list();
}

项目：SparkCore 文件：OfferDaoImpl.java

@Override
public List<Offer> readOffersByAutomaticDeliveryType() {
    //TODO change this to a JPA criteria
    Criteria criteria = ((HibernateEntityManager) em).getSession().createCriteria(OfferImpl.class);

    Date myDate = getCurrentDateAfterFactoringInDateResolution();

    Calendar c = Calendar.getInstance();
    c.setTime(myDate);
    c.add(Calendar.DATE, +1);
    criteria.add(Restrictions.lt("startDate", c.getTime()));
    c = Calendar.getInstance();
    c.setTime(myDate);
    c.add(Calendar.DATE, -1);
    criteria.add(Restrictions.or(Restrictions.isNull("endDate"), Restrictions.gt("endDate", c.getTime())));
    criteria.add(Restrictions.or(Restrictions.eq("archiveStatus.archived", 'N'),
            Restrictions.isNull("archiveStatus.archived")));

    // Automatically Added or (Automatically Added is null and deliveryType is Automatic)
    criteria.add(Restrictions.or(Restrictions.eq("automaticallyAdded", true),
            Restrictions.and(Restrictions.isNull("automaticallyAdded"),
                    Restrictions.eq("deliveryType", "AUTOMATIC"))));

    criteria.setCacheable(true);
    criteria.setCacheRegion("query.Offer");

    return criteria.list();
}

项目：blcdemo 文件：SkuCustomPersistenceHandler.java

protected String[] getPolymorphicClasses(Class<?> clazz) {
    DynamicDaoHelperImpl helper = new DynamicDaoHelperImpl();
    Class<?>[] classes = helper.getAllPolymorphicEntitiesFromCeiling(clazz,
            helper.getSessionFactory((HibernateEntityManager) em), 
            true,
            useCache());
    String[] result = new String[classes.length];
    for (int i = 0; i < classes.length; i++) {
        result[i] = classes[i].getName();
    }
    return result;
}

项目：blcdemo 文件：GenericEntityDaoImpl.java

@Override
public <T> T readGenericEntity(Class<T> clazz, Object id) {
    clazz = (Class<T>) DynamicDaoHelperImpl.getNonProxyImplementationClassIfNecessary(clazz);
    Map<String, Object> md = daoHelper.getIdMetadata(clazz, (HibernateEntityManager) em);
    AbstractSingleColumnStandardBasicType type = (AbstractSingleColumnStandardBasicType) md.get("type");

    if (type instanceof LongType) {
        id = Long.parseLong(String.valueOf(id));
    } else if (type instanceof IntegerType) {
        id = Integer.parseInt(String.valueOf(id));
    }

    return em.find(clazz, id);
}

项目：blcdemo 文件：DynamicDaoHelperImpl.java

@Override
public List<String> getPropertyNames(Class<?> entityClass, HibernateEntityManager entityManager) {
    entityClass = getNonProxyImplementationClassIfNecessary(entityClass);
    ClassMetadata metadata = getSessionFactory(entityManager).getClassMetadata(entityClass);
    List<String> propertyNames = new ArrayList<String>();
    Collections.addAll(propertyNames, metadata.getPropertyNames());
    return propertyNames;
}

项目：blcdemo 文件：DynamicDaoHelperImpl.java

@Override
public List<Type> getPropertyTypes(Class<?> entityClass, HibernateEntityManager entityManager) {
    entityClass = getNonProxyImplementationClassIfNecessary(entityClass);
    ClassMetadata metadata = getSessionFactory(entityManager).getClassMetadata(entityClass);
    List<Type> propertyTypes = new ArrayList<Type>();
    Collections.addAll(propertyTypes, metadata.getPropertyTypes());
    return propertyTypes;
}

项目：blcdemo 文件：IdentityExecutionUtils.java

private static void activateSession() {
    Map<Object, Object> resourceMap = TransactionSynchronizationManager.getResourceMap();
    for (Map.Entry<Object, Object> entry : resourceMap.entrySet()) {
        if (entry.getKey() instanceof EntityManagerFactory && entry.getValue() instanceof EntityManagerHolder) {
            ((HibernateEntityManager) ((EntityManagerHolder) entry.getValue()).getEntityManager()).getSession();
        }
    }
}

项目：blcdemo 文件：OfferDaoImpl.java

@Override
public List<Offer> readOffersByAutomaticDeliveryType() {
    //TODO change this to a JPA criteria
    Criteria criteria = ((HibernateEntityManager) em).getSession().createCriteria(OfferImpl.class);

    Date myDate = getCurrentDateAfterFactoringInDateResolution();

    Calendar c = Calendar.getInstance();
    c.setTime(myDate);
    c.add(Calendar.DATE, +1);
    criteria.add(Restrictions.lt("startDate", c.getTime()));
    c = Calendar.getInstance();
    c.setTime(myDate);
    c.add(Calendar.DATE, -1);
    criteria.add(Restrictions.or(Restrictions.isNull("endDate"), Restrictions.gt("endDate", c.getTime())));
    criteria.add(Restrictions.or(Restrictions.eq("archiveStatus.archived", 'N'),
            Restrictions.isNull("archiveStatus.archived")));

    // Automatically Added or (Automatically Added is null and deliveryType is Automatic)
    criteria.add(Restrictions.or(Restrictions.eq("automaticallyAdded", true),
            Restrictions.and(Restrictions.isNull("automaticallyAdded"),
                    Restrictions.eq("deliveryType", "AUTOMATIC"))));

    criteria.setCacheable(true);
    criteria.setCacheRegion("query.Offer");

    return criteria.list();
}

项目：SocialDataImporter 文件：EntityManagerProvider.java

/**
 * Retrieves the EntityManager with the given unit name.
 * <p>
 * @param aPersistenceUnit
 * @return
 */
public static HibernateEntityManager getEntityManager( String aPersistenceUnit )
{
    if ( myFactory == null )
    {
        myFactory = Persistence.createEntityManagerFactory( aPersistenceUnit );
    } // if myFactory == null

    EntityManager o =  myFactory.createEntityManager();
    return (HibernateEntityManager) o;

}

项目：SocialDataImporter 文件：OxSqlJobTest.java

/**
 *
 */
private void provideNewEntityManager()
{
    HibernateEntityManager em = Whitebox.getInternalState( myClassUnderTest,
                                                           HibernateEntityManager.class );
    if ( em != null )
    {
        em.close();
    } // if em != null
    EntityManager newEm = EntityManagerProvider.getEntityManager( "oxwall" );
    Assert.assertNotNull( newEm );
    Assert.assertTrue( em != newEm );
    Whitebox.setInternalState( myClassUnderTest, "myEntityManager", newEm );
}

项目：SocialDataImporter 文件：OxSqlJobTest.java

/**
 *
 */
private void addTestUser()
{
    HibernateEntityManager em = Whitebox.getInternalState( myClassUnderTest,
                                                           HibernateEntityManager.class );
    Assert.assertNotNull( em );
    em.getTransaction().begin();

    try
    {
        OxUser newUser = new OxUser();
        newUser.setUsername( "Heri22" );
        newUser.setAccountType( "accountType" );
        newUser.setActivityStamp( 1396986027L );
        newUser.setEmail( USER_EMAIL );
        newUser.setJoinIp( 1234L );
        newUser.setJoinStamp( 1396980000L );
        newUser.setPassword( "asdflkj" );

        em.persist( newUser );
        myLog.debug( "Persisted user: " + newUser );

        em.getTransaction().commit();;

    }
    catch ( Throwable t )
    {
        em.getTransaction().rollback();
        myLog.error( "Exception caught: ", t );
        throw t;
    }

}

项目：class-guard 文件：HibernateJpaDialect.java

protected Session getSession(EntityManager em) {
    if (em instanceof HibernateEntityManager) {
        return ((HibernateEntityManager) em).getSession();
    }
    else {
        Object delegate = em.getDelegate();
        if (delegate instanceof Session) {
            return (Session) delegate;
        }
        else {
            throw new IllegalStateException(
                    "Cannot obtain native Hibernate Session from given JPA EntityManager: " + em.getClass());
        }
    }
}

项目：sigmah 文件：GetIndicatorsHandler.java

/**
 * Find the requested indicators in a transaction.
 *
 * The transaction is required by IndicatorDAO.
 * 
 * @param entityManager An Hibernate entity manager.
 * @param indicatorDAO A new indicator DAO, dedicated for this use.
 * @param userDatabaseId Identifier of the database to query.
 * @throws HibernateException 
 */
@Transactional
protected void findIndicators(final HibernateEntityManager entityManager, final IndicatorDAO indicatorDAO, final int userDatabaseId) throws HibernateException {
    entityManager.getSession().doWork(new Work() {

        @Override
        public void execute(Connection connection) throws SQLException {
            indicatorDAO.queryIndicatorGroups(connection, userDatabaseId);
            indicatorDAO.queryIndicatorsByDatabaseWithCurrentValues(connection, userDatabaseId);
        }
    });
}

项目：kuali_rice 文件：BusinessObjectDaoJpa.java

/**
 * @see org.kuali.rice.krad.dao.BusinessObjectDao#manageReadOnly(org.kuali.rice.krad.bo.PersistableBusinessObject)
 */
public PersistableBusinessObject manageReadOnly(PersistableBusinessObject bo) {
    Session session = ((HibernateEntityManager)entityManager).getSession();
    FlushMode currentFlushMode = session.getFlushMode();
    session.setFlushMode(FlushMode.MANUAL); // make sure the merge doesn't flush what we're trying to make read only
    PersistableBusinessObject managedBO = entityManager.merge(bo);
    session.setReadOnly(managedBO, true);
    session.setFlushMode(currentFlushMode);
    return managedBO;
}

项目：spring4-understanding 文件：HibernateEntityManagerFactoryIntegrationTests.java

public void testCanCastSharedEntityManagerProxyToHibernateEntityManager() {
    assertTrue(sharedEntityManager instanceof HibernateEntityManager);
    HibernateEntityManager hibernateEntityManager = (HibernateEntityManager) sharedEntityManager;
    assertNotNull(hibernateEntityManager.getSession());
}