Examples of javax.persistence.EntityManager.unwrap()

javax.persistence.EntityManager.unwrap()
Return an object of the specified type to allow access to the provider-specific API. If the provider's EntityManager implementation does not support the specified class, the PersistenceException is thrown. @param cls the class of the object to be returned. This isnormally either the underlying EntityManager implementation class or an interface that it implements. @return an instance of the specified class @throws PersistenceException if the provider does notsupport the call.

   * @param id Employee's id in the query
   */
  public String queryCacheCheck(String id){
    
    EntityManager em = emf.createEntityManager();
    Statistics stats = em.unwrap(Session.class).getSessionFactory().getStatistics();
    stats.clear();


    try{
          // the nextTimestamp from infinispan is "return System.currentTimeMillis() / 100;"
          Thread.sleep(1000);

View Full Code Here

    
    EntityManager em = emf.createEntityManager();
    
    try{
      // this should evict query cache 
      em.unwrap(Session.class).getSessionFactory().getCache().evictQueryRegions();


    }catch (Exception e) {
      e.printStackTrace();
    }  finally{
      em.close();

View Full Code Here

         ArrayList<Object> batch = new ArrayList<Object>((int) configuration.batchSize());
         EntityTransaction txStream = emStream.getTransaction();
         txStream.begin();
         try {
            log.trace("Clearing JPA Store");
            Session session = emStream.unwrap(Session.class);
            Criteria criteria = session.createCriteria(configuration.entityClass()).setReadOnly(true)
                  .setProjection(Projections.id());
            if (setFetchSizeMinInteger) {
               criteria.setFetchSize(Integer.MIN_VALUE);
            }

View Full Code Here

      try {
         EntityTransaction txStream = emStream.getTransaction();
         ScrollableResults keys = null;
         txStream.begin();
         try {
            Session session = emStream.unwrap(Session.class);
            Criteria criteria = session.createCriteria(configuration.entityClass()).setReadOnly(true)
                  .setProjection(Projections.id());
            if (setFetchSizeMinInteger) {
               criteria.setFetchSize(Integer.MIN_VALUE);
            }

View Full Code Here

         EntityTransaction txStream = emStream.getTransaction();
         ScrollableResults metadataKeys = null;
         txStream.begin();
         try {
            long currentTime = timeService.wallClockTime();
            Session session = emStream.unwrap(Session.class);
            Criteria criteria = session.createCriteria(MetadataEntity.class).setReadOnly(true)
                  .add(Restrictions.le(MetadataEntity.EXPIRATION, currentTime)).setProjection(Projections.id());
            if (setFetchSizeMinInteger) {
               criteria.setFetchSize(Integer.MIN_VALUE);
            }

View Full Code Here

         ArrayList<Object> batch = new ArrayList<Object>((int) configuration.batchSize());
         EntityTransaction txStream = emStream.getTransaction();
         txStream.begin();
         try {
            log.trace("Clearing JPA Store");
            Session session = emStream.unwrap(Session.class);
            Criteria criteria = session.createCriteria(configuration.entityClass()).setReadOnly(true)
                  .setProjection(Projections.id());
            if (setFetchSizeMinInteger) {
               criteria.setFetchSize(Integer.MIN_VALUE);
            }

View Full Code Here

      try {
         EntityTransaction txStream = emStream.getTransaction();
         ScrollableResults results = null;
         txStream.begin();
         try {
            Session session = emStream.unwrap(Session.class);
            Criteria criteria = strategy.getCriteria(session).setReadOnly(true);
            if (setFetchSizeMinInteger) {
               criteria.setFetchSize(Integer.MIN_VALUE);
            }
            results = criteria.scroll(ScrollMode.FORWARD_ONLY);

View Full Code Here

         EntityTransaction txStream = emStream.getTransaction();
         ScrollableResults metadataKeys = null;
         txStream.begin();
         try {
            long currentTime = timeService.wallClockTime();
            Session session = emStream.unwrap(Session.class);
            Criteria criteria = session.createCriteria(MetadataEntity.class).setReadOnly(true)
                  .add(Restrictions.le(MetadataEntity.EXPIRATION, currentTime)).setProjection(Projections.id());
            if (setFetchSizeMinInteger) {
               criteria.setFetchSize(Integer.MIN_VALUE);
            }

View Full Code Here

    book.setName( "kitty kid" );
    em.merge( book );
    em.flush();
    em.clear();
    book.setName( "kitty kid2" ); //non updated version
    em.unwrap( Session.class ).update( book );
    try {
      em.getTransaction().commit();
      fail( "Commit should be rollbacked" );
    }
    catch ( RollbackException e ) {

View Full Code Here

      if ( anotherB2.getId() == 1 ) {
        anotherB2.getC2List().add( c2 );
        c2.setB2( anotherB2 );
      }
    }
    Statistics statistics = em.unwrap(Session.class).getSessionFactory().getStatistics();
    statistics.setStatisticsEnabled( true );
    statistics.clear();
    em.persist( c2 );
    long loaded = statistics.getEntityLoadCount();
    assertEquals( 0, loaded );

View Full Code Here

0 1 2 3 4 5

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.