Java 类org.hibernate.event.PostInsertEvent 实例源码

private void postInsert() {
    PostInsertEventListener[] postListeners = getSession().getListeners()
            .getPostInsertEventListeners();
    if ( postListeners.length > 0 ) {
        PostInsertEvent postEvent = new PostInsertEvent(
                getInstance(),
                getId(),
                state,
                getPersister(),
                (EventSource) getSession()
        );
        for ( int i = 0; i < postListeners.length; i++ ) {
            postListeners[i].onPostInsert(postEvent);
        }
    }
}

private void postCommitInsert() {
    PostInsertEventListener[] postListeners = getSession().getListeners()
            .getPostCommitInsertEventListeners();
    if ( postListeners.length > 0 ) {
        PostInsertEvent postEvent = new PostInsertEvent(
                getInstance(),
                getId(),
                state,
                getPersister(),
                (EventSource) getSession() 
        );
        for ( int i = 0; i < postListeners.length; i++ ) {
            postListeners[i].onPostInsert(postEvent);
        }
    }
}

private void postInsert() {
    if ( isDelayed ) {
        getSession().getPersistenceContext().replaceDelayedEntityIdentityInsertKeys( delayedEntityKey, generatedId );
    }
    PostInsertEventListener[] postListeners = getSession().getListeners()
            .getPostInsertEventListeners();
    if (postListeners.length>0) {
        PostInsertEvent postEvent = new PostInsertEvent(
                getInstance(),
                generatedId,
                state,
                getPersister(),
                (EventSource) getSession()
        );
        for ( int i = 0; i < postListeners.length; i++ ) {
            postListeners[i].onPostInsert(postEvent);
        }
    }
}

private void postCommitInsert() {
    PostInsertEventListener[] postListeners = getSession().getListeners()
            .getPostCommitInsertEventListeners();
    if (postListeners.length>0) {
        PostInsertEvent postEvent = new PostInsertEvent(
                getInstance(),
                generatedId,
                state,
                getPersister(),
                (EventSource) getSession() 
        );
        for ( int i = 0; i < postListeners.length; i++ ) {
            postListeners[i].onPostInsert(postEvent);
        }
    }
}

public void onPostInsert(PostInsertEvent event) {
    EntityPersister entityPersister = event.getPersister();
    String entityName = entityPersister.getEntityName();
    String id = String.valueOf(event.getId());

    if (entityName.equals(NAVIGATION_ENTITY_NAME)) {
        jobService.buildIndexHtml();
        jobService.buildLoginHtml();
        jobService.buildArticleContentHtml();
        jobService.buildGoodsContentHtml();
    } else if (entityName.equals(FRIEND_LINK_ENTITY_NAME)) {
        jobService.buildIndexHtml();
        jobService.buildLoginHtml();
        jobService.buildArticleContentHtml();
        jobService.buildGoodsContentHtml();
    } else if (entityName.equals(ARTICLE_CATEGORY_ENTITY_NAME)) {
        jobService.buildIndexHtml();
        jobService.buildArticleContentHtml();
    } else if (entityName.equals(GOODS_CATEGORY_ENTITY_NAME)) {
        jobService.buildIndexHtml();
        jobService.buildGoodsContentHtml();
    } else if (entityName.equals(ARTICLE_ENTITY_NAME)) {
        jobService.buildArticleContentHtml(id);
        jobService.buildIndexHtml();
    } else if (entityName.equals(GOODS_ENTITY_NAME)) {
        jobService.buildGoodsContentHtml(id);
        jobService.buildIndexHtml();
    } else if (entityName.equals(PRODUCT_ENTITY_NAME)) {
        Product product = (Product) event.getEntity();
        jobService.buildGoodsContentHtml(product.getGoods().getId());
    } else if (entityName.equals(COMMENT_ENTITY_NAME)) {
        Comment comment = (Comment) event.getEntity();
        jobService.buildGoodsContentHtml(comment.getGoods().getId());
    } else if (entityName.equals(INSTANT_MESSAGING_ENTITY_NAME)) {
        jobService.buildShopJs();
    }
}

public static AbstractWork forEvent(AbstractEvent event, Object entity) {
    if(event instanceof PostInsertEvent) {
        return new AddWork(entity);
    } else if (event instanceof PostUpdateEvent) {
        return new UpdateWork(entity);
    } else if (event instanceof PostDeleteEvent) {
        return new DeleteWork(entity);
    } else {
        return new LoadWork(entity);
    }
}

@Override
public void onPostInsert(PostInsertEvent arg0) {
    Object obj = arg0.getEntity();
    if (obj instanceof Notifierprofiles) {
        postSaveOrUpdateNotifierProfile((Notifierprofiles) obj);
    } else if (obj instanceof Properties) {
        postSaveOrUpdateproperties((Properties) obj);
    }

}

@Override
public void onPostInsert(PostInsertEvent event) {
    if(Searchable.class.isAssignableFrom(event.getEntity().getClass())) {
        indexObject((Searchable) event.getEntity());
    }
}

public void onPostInsert(PostInsertEvent event) {
invoke(CommonUtil.POST_INSERT, event.getEntity());
  }

public void onPostInsert(PostInsertEvent event) {
invoke(CommonUtil.POST_INSERT, event.getEntity());
  }

@Override
public void onPostInsert(final PostInsertEvent event) {
    markWrite();
}