Package org.hibernate.stat

Examples of org.hibernate.stat.Statistics


    Item item = new Item( "Mouse", "Micro$oft mouse" );
    Distributor res = new Distributor();
    res.setName( "Bruce" );
    item.setDistributors( new HashSet<Distributor>() );
    item.getDistributors().add( res );
    Statistics stats = ( (HibernateEntityManagerFactory) factory ).getSessionFactory().getStatistics();
    stats.clear();
    stats.setStatisticsEnabled( true );

    EntityManager em = getOrCreateEntityManager();
    em.getTransaction().begin();

    em.persist( res );
    em.persist( item );
    assertTrue( em.contains( item ) );

    em.getTransaction().commit();
    em.close();

    assertEquals( 1, stats.getSecondLevelCachePutCount() );
    assertEquals( 0, stats.getSecondLevelCacheHitCount() );

    em = getOrCreateEntityManager();
    em.getTransaction().begin();
    Item second = em.find( Item.class, item.getName() );
    assertEquals( 1, second.getDistributors().size() );
    assertEquals( 1, stats.getSecondLevelCacheHitCount() );
    em.getTransaction().commit();
    em.close();

    em = getOrCreateEntityManager();
    em.getTransaction().begin();
    second = em.find( Item.class, item.getName() );
    assertEquals( 1, second.getDistributors().size() );
    assertEquals( 3, stats.getSecondLevelCacheHitCount() );
    for (Distributor distro : second.getDistributors()) {
      em.remove( distro );
    }
    em.remove( second );
    em.getTransaction().commit();
    em.close();

    stats.clear();
    stats.setStatisticsEnabled( false );
  }
View Full Code Here


      if ( anotherB2.getId() == 1 ) {
        anotherB2.getC2List().add( c2 );
        c2.setB2( anotherB2 );
      }
    }
    Statistics statistics = ( (Session) em.getDelegate() ).getSessionFactory().getStatistics();
    statistics.setStatisticsEnabled( true );
    statistics.clear();
    em.persist( c2 );
    long loaded = statistics.getEntityLoadCount();
    assertEquals( 0, loaded );
    em.flush();
    em.getTransaction().rollback();
    em.close();
  }
View Full Code Here

   *
   * @see HibernateStats#getQueryStats()
   */
  public TabularData getQueryStats() {
    List<CompositeData> result = new ArrayList<CompositeData>();
    Statistics statistics = getStatistics();
    for ( String query : statistics.getQueries() ) {
      QueryStats queryStats = new QueryStats( query, statistics.getQueryStatistics( query ) );
      result.add( queryStats.toCompositeData() );
    }
    TabularData td = QueryStats.newTabularDataInstance();
    td.putAll( result.toArray( new CompositeData[result.size()] ) );
    return td;
View Full Code Here

  /**
   * {@inheritDoc}
   */
  public TabularData getCacheRegionStats() {
    List<CompositeData> list = new ArrayList<CompositeData>();
    Statistics statistics = getStatistics();
    for ( String region : statistics.getSecondLevelCacheRegionNames() ) {
      CacheRegionStats l2CacheStats = new CacheRegionStats(
          region,
          statistics.getSecondLevelCacheStatistics( region )
      );
      list.add( l2CacheStats.toCompositeData() );
    }
    TabularData td = CacheRegionStats.newTabularDataInstance();
    td.putAll( list.toArray( new CompositeData[list.size()] ) );
View Full Code Here

   *
   * @see HibernateStats#getEntityStats()
   */
  public TabularData getEntityStats() {
    List<CompositeData> result = new ArrayList<CompositeData>();
    Statistics statistics = getStatistics();
    for ( String entity : statistics.getEntityNames() ) {
      EntityStats entityStats = new EntityStats( entity, statistics.getEntityStatistics( entity ) );
      result.add( entityStats.toCompositeData() );
    }
    TabularData td = EntityStats.newTabularDataInstance();
    td.putAll( result.toArray( new CompositeData[result.size()] ) );
    return td;
View Full Code Here

   *
   * @see HibernateStats#getCollectionStats()
   */
  public TabularData getCollectionStats() {
    List<CompositeData> result = new ArrayList<CompositeData>();
    Statistics statistics = getStatistics();
    for ( String roleName : statistics.getCollectionRoleNames() ) {
      CollectionStats collectionStats = new CollectionStats(
          roleName,
          statistics.getCollectionStatistics( roleName )
      );
      result.add( collectionStats.toCompositeData() );
    }
    TabularData td = CollectionStats.newTabularDataInstance();
    td.putAll( result.toArray( new CompositeData[result.size()] ) );
View Full Code Here

          Settings settings,
          EventListeners listeners,
      SessionFactoryObserver observer) throws HibernateException {
    log.info("building session factory");

    Statistics concurrentStatistics = null;
    try {
      Class concurrentStatsClass = ReflectHelper.classForName("org.hibernate.stat.ConcurrentStatisticsImpl");
      Constructor constructor = concurrentStatsClass.getConstructor(new Class[]{SessionFactoryImplementor.class});
      concurrentStatistics = (Statistics) constructor.newInstance(new Object[]{this});
      log.trace("JDK 1.5 concurrent classes present");
View Full Code Here

      });
   }

  @Test
  public void testCollectionCache() throws Exception {
    final Statistics stats = sessionFactory().getStatistics();
    stats.clear();

    final Item item = new Item( "chris", "Chris's Item" );
    final Item another = new Item( "another", "Owned Item" );
    item.addItem( another );

      withTx(tm, new Callable<Void>() {
         @Override
         public Void call() throws Exception {
            Session s = openSession();
            s.getTransaction().begin();
            s.persist( item );
            s.persist( another );
            s.getTransaction().commit();
            s.close();
            return null;
         }
      });

      withTx(tm, new Callable<Void>() {
         @Override
         public Void call() throws Exception {
            Session s = openSession();
            Item loaded = (Item) s.load( Item.class, item.getId() );
            assertEquals( 1, loaded.getItems().size() );
            s.close();
            return null;
         }
      });

      withTx(tm, new Callable<Void>() {
         @Override
         public Void call() throws Exception {
            Session s = openSession();
            s.getTransaction().begin();
            SecondLevelCacheStatistics cStats = stats.getSecondLevelCacheStatistics( Item.class.getName() + ".items" );
            Item loadedWithCachedCollection = (Item) s.load( Item.class, item.getId() );
            stats.logSummary();
            assertEquals( item.getName(), loadedWithCachedCollection.getName() );
            assertEquals( item.getItems().size(), loadedWithCachedCollection.getItems().size() );
            assertEquals( 1, cStats.getHitCount() );
            Map cacheEntries = cStats.getEntries();
            assertEquals( 1, cacheEntries.size() );
View Full Code Here

  }

  @Test
  @TestForIssue( jiraKey = "HHH-9231" )
  public void testAddNewOneToManyElementInitFlushLeaveCacheConsistent() throws Exception {
    Statistics stats = sessionFactory().getStatistics();
    stats.clear();
    SecondLevelCacheStatistics cStats = stats.getSecondLevelCacheStatistics( Item.class.getName() + ".items" );

    Item item = null;
    Transaction txn = null;
    Session s = null;
View Full Code Here

  }

  @Test
  @TestForIssue( jiraKey = "HHH-9231" )
  public void testAddNewOneToManyElementNoInitFlushLeaveCacheConsistent() throws Exception {
    Statistics stats = sessionFactory().getStatistics();
    stats.clear();
    SecondLevelCacheStatistics cStats = stats.getSecondLevelCacheStatistics( Item.class.getName() + ".items" );

    Item item = null;
    Transaction txn = null;
    Session s = null;
View Full Code Here

TOP

Related Classes of org.hibernate.stat.Statistics

Copyright © 2018 www.massapicom. All rights reserved.
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.