Java 类org.hibernate.service.ServiceRegistry 实例源码

public static SessionFactory getSessionFactory() {
    if (null != sessionFactory)
        return sessionFactory;

    Configuration configuration = new Configuration();

    String jdbcUrl = "jdbc:mysql://"
            + System.getenv("RDS_HOSTNAME")
            + "/"
            + System.getenv("RDS_DB_NAME");

    configuration.setProperty("hibernate.connection.url", jdbcUrl);
    configuration.setProperty("hibernate.connection.username", System.getenv("RDS_USERNAME"));
    configuration.setProperty("hibernate.connection.password", System.getenv("RDS_PASSWORD"));

    configuration.configure();
    ServiceRegistry serviceRegistry = new StandardServiceRegistryBuilder().applySettings(configuration.getProperties()).build();
    try {
        sessionFactory = configuration.buildSessionFactory(serviceRegistry);
    } catch (HibernateException e) {
        System.err.println("Initial SessionFactory creation failed." + e);
        throw new ExceptionInInitializerError(e);
    }
    return sessionFactory;
}

/**
 * Create a {@link SessionFactory} using the properties and mappings in this configuration. The
 * {@link SessionFactory} will be immutable, so changes made to {@code this} {@link Configuration} after
 * building the {@link SessionFactory} will not affect it.
 *
 * @param serviceRegistry The registry of services to be used in creating this session factory.
 *
 * @return The built {@link SessionFactory}
 *
 * @throws HibernateException usually indicates an invalid configuration or invalid mapping information
 */
public SessionFactory buildSessionFactory(ServiceRegistry serviceRegistry) throws HibernateException {
    LOG.debugf( "Preparing to build session factory with filters : %s", filterDefinitions );

    buildTypeRegistrations( serviceRegistry );
    secondPassCompile();
    if ( !metadataSourceQueue.isEmpty() ) {
        LOG.incompleteMappingMetadataCacheProcessing();
    }

    validate();

    Environment.verifyProperties( properties );
    Properties copy = new Properties();
    copy.putAll( properties );
    ConfigurationHelper.resolvePlaceHolders( copy );
    Settings settings = buildSettings( copy, serviceRegistry );

    return new SessionFactoryImpl(
            this,
            mapping,
            serviceRegistry,
            settings,
            sessionFactoryObserver
        );
}

public MetadataSources(ServiceRegistry serviceRegistry, EntityResolver entityResolver, NamingStrategy namingStrategy) {
    this.serviceRegistry = serviceRegistry;
    this.entityResolver = entityResolver;
    this.namingStrategy = namingStrategy;

    this.jaxbHelper = new JaxbHelper( this );
    this.metadataBuilder = new MetadataBuilderImpl( this );

    // service registry really should be either BootstrapServiceRegistry or StandardServiceRegistry type...
    if ( ! isExpectedServiceRegistryType( serviceRegistry ) ) {
        LOG.debugf(
                "Unexpected ServiceRegistry type [%s] encountered during building of MetadataSources; may cause " +
                        "problems later attempting to construct MetadataBuilder",
                serviceRegistry.getClass().getName()
        );
    }
}

private static StandardServiceRegistry getStandardServiceRegistry(ServiceRegistry serviceRegistry) {
    if ( serviceRegistry == null ) {
        throw new HibernateException( "ServiceRegistry passed to MetadataBuilder cannot be null" );
    }

    if ( StandardServiceRegistry.class.isInstance( serviceRegistry ) ) {
        return ( StandardServiceRegistry ) serviceRegistry;
    }
    else if ( BootstrapServiceRegistry.class.isInstance( serviceRegistry ) ) {
        log.debugf(
                "ServiceRegistry passed to MetadataBuilder was a BootstrapServiceRegistry; this likely wont end well" +
                        "if attempt is made to build SessionFactory"
        );
        return new StandardServiceRegistryBuilder( (BootstrapServiceRegistry) serviceRegistry ).build();
    }
    else {
        throw new HibernateException(
                String.format(
                        "Unexpected type of ServiceRegistry [%s] encountered in attempt to build MetadataBuilder",
                        serviceRegistry.getClass().getName()
                )
        );
    }
}

public SchemaExport(ServiceRegistry serviceRegistry, Configuration configuration) {
    this.connectionHelper = new SuppliedConnectionProviderConnectionHelper(
            serviceRegistry.getService( ConnectionProvider.class )
    );
    this.sqlStatementLogger = serviceRegistry.getService( JdbcServices.class ).getSqlStatementLogger();
    this.formatter = ( sqlStatementLogger.isFormat() ? FormatStyle.DDL : FormatStyle.NONE ).getFormatter();
    this.sqlExceptionHelper = serviceRegistry.getService( JdbcServices.class ).getSqlExceptionHelper();

    this.importFiles = ConfigurationHelper.getString(
            AvailableSettings.HBM2DDL_IMPORT_FILES,
            configuration.getProperties(),
            DEFAULT_IMPORT_FILE
    );

    final Dialect dialect = serviceRegistry.getService( JdbcServices.class ).getDialect();
    this.dropSQL = configuration.generateDropSchemaScript( dialect );
    this.createSQL = configuration.generateSchemaCreationScript( dialect );
}

public SchemaExport(MetadataImplementor metadata) {
    ServiceRegistry serviceRegistry = metadata.getServiceRegistry();
    this.connectionHelper = new SuppliedConnectionProviderConnectionHelper(
            serviceRegistry.getService( ConnectionProvider.class )
    );
       JdbcServices jdbcServices = serviceRegistry.getService( JdbcServices.class );
    this.sqlStatementLogger = jdbcServices.getSqlStatementLogger();
    this.formatter = ( sqlStatementLogger.isFormat() ? FormatStyle.DDL : FormatStyle.NONE ).getFormatter();
    this.sqlExceptionHelper = jdbcServices.getSqlExceptionHelper();

    this.importFiles = ConfigurationHelper.getString(
            AvailableSettings.HBM2DDL_IMPORT_FILES,
            serviceRegistry.getService( ConfigurationService.class ).getSettings(),
            DEFAULT_IMPORT_FILE
    );

    final Dialect dialect = jdbcServices.getDialect();
    this.dropSQL = metadata.getDatabase().generateDropSchemaScript( dialect );
    this.createSQL = metadata.getDatabase().generateSchemaCreationScript( dialect );
}

private EntityCopyObserver createEntityCopyObserver(SessionFactoryImplementor sessionFactory) {
    final ServiceRegistry serviceRegistry = sessionFactory.getServiceRegistry();
    if ( entityCopyObserverStrategy == null ) {
        final ConfigurationService configurationService
                = serviceRegistry.getService( ConfigurationService.class );
        entityCopyObserverStrategy = configurationService.getSetting(
                "hibernate.event.merge.entity_copy_observer",
                new ConfigurationService.Converter<String>() {
                    @Override
                    public String convert(Object value) {
                        return value.toString();
                    }
                },
                EntityCopyNotAllowedObserver.SHORT_NAME
        );
        LOG.debugf( "EntityCopyObserver strategy: %s", entityCopyObserverStrategy );
    }
    final StrategySelector strategySelector = serviceRegistry.getService( StrategySelector.class );
    return strategySelector.resolveStrategy( EntityCopyObserver.class, entityCopyObserverStrategy );
}

@Override
public void contribute(TypeContributions typeContributions, ServiceRegistry serviceRegistry) {
    JsonType jtype;
    JavaTypeDescriptor jdesc;
    try {
        jtype = JsonType.INSTANCE;
        jdesc = JsonJavaTypeDescriptor.INSTANCE;
    }
    catch (Throwable t) {
        // Avoid logging system for a project so small
        System.err.println("JSON type contribution failed! Message: " + t.getMessage());
        t.printStackTrace(System.err);
        return;
    }
    JavaTypeDescriptorRegistry.INSTANCE.addDescriptor(jdesc);
    typeContributions.contributeType(jtype);
}

public static SessionFactory getSessionFactory() {
        if (sessionFactory == null || sessionFactory.isClosed()) {
            try {
                Configuration configuration = new Configuration().configure();
                StandardServiceRegistryBuilder serviceRegistryBuilder = new StandardServiceRegistryBuilder();
                serviceRegistryBuilder.applySettings(configuration.getProperties());
                ServiceRegistry serviceRegistry = serviceRegistryBuilder.build();
                sessionFactory = configuration.buildSessionFactory(serviceRegistry);
//            sessionFactory = new Configuration().configure().buildSessionFactory();
            } catch (HibernateException ex) {
                ex.printStackTrace();
                System.err.println("Initial SessionFactory creation failed." + ex);
                throw new ExceptionInInitializerError(ex);
            }
        }
        return sessionFactory;
    }

@Test
public void configureRunsBeforeSessionFactoryCreation(){
    final SessionFactoryFactory customFactory = new SessionFactoryFactory() {
        @Override
        protected void configure(final Configuration configuration, final ServiceRegistry registry) {
            super.configure(configuration, registry);
            configuration.setInterceptor(EmptyInterceptor.INSTANCE);
        }
    };
    this.sessionFactory = customFactory.build(this.bundle,
                                         this.environment,
                                         this.config,
                                         ImmutableList.<Class<?>>of(Person.class),
                                         RemoteCredentialHibernateBundle.DEFAULT_NAME);

    assertThat(this.sessionFactory.getSessionFactoryOptions().getInterceptor()).isSameAs(EmptyInterceptor.INSTANCE);
}

public static SessionFactory buildSessionFactory() {
    try {

        Configuration configuration = new Configuration();

        // Create properties file
        Properties properties = new Properties();

        properties.load(Thread.currentThread().getContextClassLoader().getResourceAsStream("Hibernate.properties"));

        configuration.setProperties(properties);

        ServiceRegistry serviceRegistry = new StandardServiceRegistryBuilder()
                .applySettings(configuration.getProperties()).build();
        configuration.addAnnotatedClass(Wordlist.class);

        sessionFactory = configuration.buildSessionFactory(serviceRegistry);

    } catch (Throwable ex) {
        ex.printStackTrace();
    }
    return sessionFactory;
}

private static SessionFactory buildSessionFactory() {
    try {
        Configuration configuration = new Configuration();

        Properties props = new Properties();
        props.put("hibernate.current_session_context_class", "thread");
        configuration.setProperties(props);

        for (Class<?> clazz : entityClasses) {
            configuration.addAnnotatedClass(clazz);
        }

        PluginHandler.get().getPlugin().addAnnotatedClass(configuration);

        ServiceRegistry serviceRegistry = new StandardServiceRegistryBuilder()
                .applySettings(configuration.getProperties())
                .addService(ConnectionProvider.class, new NomadConnectionProvider()).build();

        SessionFactory sessionFactory = configuration.buildSessionFactory(serviceRegistry);

        return sessionFactory;
    } catch (Throwable ex) {
        logger.error("Failed to build session factory.", ex);
        throw new ExceptionInInitializerError(ex);
    }
}

@Test
public void bootstrapping() {
    log.info("... bootstrapping ...");

    ServiceRegistry standardRegistry = new StandardServiceRegistryBuilder().configure().build();

    SessionFactory sessionFactory = new MetadataSources(standardRegistry)
        .addAnnotatedClass(Author.class).buildMetadata()
        .buildSessionFactory();
        Session session = sessionFactory.openSession();
    session.beginTransaction();

    Author a = new Author();
    a.setFirstName("Thorben");
    a.setLastName("Janssen");
    session.persist(a);

    session.getTransaction().commit();
    session.close();
}

public boolean addRegex(Regex regex) {
    Transaction tx = null;
    Configuration config = new Configuration().configure();

    config.addClass(Regex.class);

    ServiceRegistry serviceRegistry = new StandardServiceRegistryBuilder().applySettings(config.getProperties())
            .build();
    SessionFactory sessionFactory = config.buildSessionFactory(serviceRegistry);
    Session session        = sessionFactory.getCurrentSession();
    try{
        tx = session.beginTransaction();
        session.save(regex);
        tx.commit();
        return true;
    }catch (Exception ex){
        ex.printStackTrace();
        tx.commit();
        return false;
    }finally {
        if(tx != null){
            tx = null;
        }
        sessionFactory.close();
    }
}

public boolean updateRegex(Regex regex) {
    Transaction tx = null;
    Configuration config = new Configuration().configure();

    config.addClass(Regex.class);

    ServiceRegistry serviceRegistry = new StandardServiceRegistryBuilder().applySettings(config.getProperties())
            .build();
    SessionFactory sessionFactory = config.buildSessionFactory(serviceRegistry);
    Session session        = sessionFactory.getCurrentSession();
    try{
        tx = session.beginTransaction();
        session.update(regex);
        tx.commit();
        return true;
    }catch (Exception ex){
        ex.printStackTrace();
        tx.commit();
        return false;
    }finally {
        if(tx != null){
            tx = null;
        }
        sessionFactory.close();
    }
}

public boolean addData(Data data) {
    Transaction tx = null;
    Configuration config = new Configuration().configure();

    config.addClass(Data.class);

    ServiceRegistry serviceRegistry = new StandardServiceRegistryBuilder().applySettings(config.getProperties())
            .build();
    SessionFactory sessionFactory = config.buildSessionFactory(serviceRegistry);
    Session session        = sessionFactory.getCurrentSession();
    try{
        tx = session.beginTransaction();
        session.save(data);
        tx.commit();
        return true;
    }catch (Exception ex){
        ex.printStackTrace();
        tx.commit();
        return false;
    }finally {
        if(tx != null){
            tx = null;
        }
        sessionFactory.close();
    }
}

public boolean updateData(Data data) {
    Transaction tx = null;
    Configuration config = new Configuration().configure();

    config.addClass(Data.class);

    ServiceRegistry serviceRegistry = new StandardServiceRegistryBuilder().applySettings(config.getProperties())
            .build();
    SessionFactory sessionFactory = config.buildSessionFactory(serviceRegistry);
    Session session        = sessionFactory.getCurrentSession();
    try{
        tx = session.beginTransaction();
        session.update(data);
        tx.commit();
        return true;
    }catch (Exception ex){
        ex.printStackTrace();
        tx.commit();
        return false;
    }finally {
        if(tx != null){
            tx = null;
        }
        sessionFactory.close();
    }
}

public boolean addTask(Task task) {
    Transaction tx = null;
    Configuration config = new Configuration().configure();

    config.addClass(Task.class);

    ServiceRegistry serviceRegistry = new StandardServiceRegistryBuilder().applySettings(config.getProperties())
            .build();
    SessionFactory sessionFactory = config.buildSessionFactory(serviceRegistry);
    Session session        = sessionFactory.getCurrentSession();
    try{
        tx = session.beginTransaction();
        session.save(task);
        tx.commit();
        return true;
    }catch (Exception ex){
        ex.printStackTrace();
        tx.commit();
        return false;
    }finally {
        if(tx != null){
            tx = null;
        }
        sessionFactory.close();
    }
}

public boolean updateTask(Task task) {
    Transaction tx = null;
    Configuration config = new Configuration().configure();

    config.addClass(Task.class);

    ServiceRegistry serviceRegistry = new StandardServiceRegistryBuilder().applySettings(config.getProperties())
            .build();
    SessionFactory sessionFactory = config.buildSessionFactory(serviceRegistry);
    Session session        = sessionFactory.getCurrentSession();
    try{
        tx = session.beginTransaction();
        session.update(task);
        tx.commit();
        return true;
    }catch (Exception ex){
        ex.printStackTrace();
        tx.commit();
        return false;
    }finally {
        if(tx != null){
            tx = null;
        }
        sessionFactory.close();
    }
}

public boolean addWorkspace(Workspace wspace) {
    Transaction tx = null;
    Configuration config = new Configuration().configure();

    config.addClass(Workspace.class);

    ServiceRegistry serviceRegistry = new StandardServiceRegistryBuilder().applySettings(config.getProperties())
            .build();
    SessionFactory sessionFactory = config.buildSessionFactory(serviceRegistry);
    Session session        = sessionFactory.getCurrentSession();
    try{
        tx = session.beginTransaction();
        session.save(wspace);
        tx.commit();
        return true;
    }catch (Exception ex){
        ex.printStackTrace();
        tx.commit();
        return false;
    }finally {
        if(tx != null){
            tx = null;
        }
        sessionFactory.close();
    }
}

public boolean updateWorkspace(Workspace wspace) {
    Transaction tx = null;
    Configuration config = new Configuration().configure();

    config.addClass(Workspace.class);

    ServiceRegistry serviceRegistry = new StandardServiceRegistryBuilder().applySettings(config.getProperties())
            .build();
    SessionFactory sessionFactory = config.buildSessionFactory(serviceRegistry);
    Session session        = sessionFactory.getCurrentSession();
    try{
        tx = session.beginTransaction();
        session.update(wspace);
        tx.commit();
        return true;
    }catch (Exception ex){
        ex.printStackTrace();
        tx.commit();
        return false;
    }finally {
        if(tx != null){
            tx = null;
        }
        sessionFactory.close();
    }
}

public boolean updateTask(Task task) {
    Transaction tx = null;
    Configuration config = new Configuration().configure();

    config.addClass(Task.class);

    ServiceRegistry serviceRegistry = new StandardServiceRegistryBuilder().applySettings(config.getProperties())
            .build();
    SessionFactory sessionFactory = config.buildSessionFactory(serviceRegistry);
    Session session        = sessionFactory.getCurrentSession();
    try{
        tx = session.beginTransaction();
        session.update(task);
        tx.commit();
        return true;
    }catch (Exception ex){
        ex.printStackTrace();
        tx.commit();
        return false;
    }finally {
        if(tx != null){
            tx = null;
        }
        sessionFactory.close();
    }
}

public boolean addProject(Project p) {
    Transaction tx = null;
    Configuration config = new Configuration().configure();

    config.addClass(Project.class);

    ServiceRegistry serviceRegistry = new StandardServiceRegistryBuilder().applySettings(config.getProperties())
            .build();
    SessionFactory sessionFactory = config.buildSessionFactory(serviceRegistry);
    Session session        = sessionFactory.getCurrentSession();
    try{
        tx = session.beginTransaction();
        session.save(p);
        tx.commit();
        return true;
    }catch (Exception ex){
        ex.printStackTrace();
        tx.commit();
        return false;
    }finally {
        if(tx != null){
            tx = null;
        }
        sessionFactory.close();
    }
}

public boolean updateProject(Project p) {
    Transaction tx = null;
    Configuration config = new Configuration().configure();

    config.addClass(Project.class);

    ServiceRegistry serviceRegistry = new StandardServiceRegistryBuilder().applySettings(config.getProperties())
            .build();
    SessionFactory sessionFactory = config.buildSessionFactory(serviceRegistry);
    Session session        = sessionFactory.getCurrentSession();
    try{
        tx = session.beginTransaction();
        session.update(p);
        tx.commit();
        return true;
    }catch (Exception ex){
        ex.printStackTrace();
        tx.commit();
        return false;
    }finally {
        if(tx != null){
            tx = null;
        }
        sessionFactory.close();
    }
}

public static SessionFactory getSessionFactory() {
    log.info("+++ getSessionFactory");
    if (sf == null) {
        Configuration cfg = new Configuration();
        cfg.configure("hibernate.cfg.xml");
        // @formatter:off
        cfg.addPackage("pl.java.scalatech.domain")
          .addAnnotatedClass(Item.class)
          .addAnnotatedClass(GeneratorOne.class)
          .addAnnotatedClass(Note.class)
          .addAnnotatedClass(HiloEntity.class)
          .addAnnotatedClass(TableGeneratorEntity.class)
          ;
        // @formatter:on
        cfg.setProperty("hibernate.generate_statistics","true");
        ServiceRegistry serviceRegistry = new StandardServiceRegistryBuilder().applySettings(cfg.getProperties()).build();
        sf = cfg.buildSessionFactory(serviceRegistry);
    }

    return sf;

}

public static SessionFactory getSessionFactory(Class[] clazz) {
    log.info("+++ getConcreteEntitySessionFactory");
    if (sf == null) {
        Configuration cfg = new Configuration();
        cfg.configure("hibernate.cfg.xml");
        // @formatter:off
        for (Class cl : clazz) {
            log.info("+++     mapped entity => {}",cl);
            cfg.addPackage("pl.java.scalatech.domain").addAnnotatedClass(cl);
        }
        // @formatter:on
        cfg.setProperty("hibernate.generate_statistics","true");
        ServiceRegistry serviceRegistry = new StandardServiceRegistryBuilder().applySettings(cfg.getProperties()).build();
        sf = cfg.buildSessionFactory(serviceRegistry);
    }

    return sf;

}

public static SessionFactory getSessionFactory() {
    log.info("+++ getSessionFactory");
    if (sf == null) {
        Configuration cfg = new Configuration();
        cfg.configure("hibernate.cfg.xml");
        // @formatter:off
        cfg.addPackage("pl.java.scalatech.domain.mainPerson")
          .addAnnotatedClass(Person.class);
        // @formatter:on
        cfg.setProperty("hibernate.generate_statistics","true");

        ServiceRegistry serviceRegistry = 
                new StandardServiceRegistryBuilder().applySettings(cfg.getProperties()).build();

        sf = cfg.buildSessionFactory(serviceRegistry);
    }

    return sf;

}

public static SessionFactory getSessionFactory(Class[] clazz) {
    log.info("+++ getConcreteEntitySessionFactory");
    if (sf == null) {
        Configuration cfg = new Configuration();
        cfg.configure("hibernate.cfg.xml");
        // @formatter:off
        for (Class cl : clazz) {
            log.info("+++     mapped entity => {}",cl);
            cfg.addPackage("pl.java.scalatech.domain").addAnnotatedClass(cl);
        }
        // @formatter:on
        cfg.setProperty("hibernate.generate_statistics","true");
        ServiceRegistry serviceRegistry = new StandardServiceRegistryBuilder().applySettings(cfg.getProperties()).build();
        sf = cfg.buildSessionFactory(serviceRegistry);
    }

    return sf;

}

public static SessionFactory getSessionFactory() {
    if (null != sessionFactory)
        return sessionFactory;

    Configuration configuration = new Configuration();

    String jdbcUrl = "jdbc:mysql://"
            + System.getenv("RDS_HOSTNAME")
            + "/"
            + System.getenv("RDS_DB_NAME");

    configuration.setProperty("hibernate.connection.url", jdbcUrl);
    configuration.setProperty("hibernate.connection.username", System.getenv("RDS_USERNAME"));
    configuration.setProperty("hibernate.connection.password", System.getenv("RDS_PASSWORD"));

    configuration.configure();
    ServiceRegistry serviceRegistry = new StandardServiceRegistryBuilder().applySettings(configuration.getProperties()).build();
    try {
        sessionFactory = configuration.buildSessionFactory(serviceRegistry);
    } catch (HibernateException e) {
        System.err.println("Initial SessionFactory creation failed." + e);
        throw new ExceptionInInitializerError(e);
    }
    return sessionFactory;
}

/**
 * Inits the.
 */
private static void init() {
    //Change the path to your deployed config file !
    File configFile = new File("/Users/matthiasivantsits/git/AnSoMia/AnSoMnia/src/hibernate.cfg.xml");
    //File configFile = new File("/Users/matthiasivantsits/git/AnSoMia/AnSoMnia/src/hibernate.cfg.xml");

    Configuration configuration = new Configuration();

    //add all classes you want to annotate
    configuration.addAnnotatedClass(Index.class);
    configuration.addAnnotatedClass(Company.class);
    configuration.addAnnotatedClass(MarketValue.class);
    configuration.addAnnotatedClass(KeyPerformanceIndicator.class);
    configuration.addAnnotatedClass(News.class);
    configuration.addAnnotatedClass(NewsDetail.class);
    configuration.addAnnotatedClass(SentenceInformation.class);
    configuration.addAnnotatedClass(IndustrySector.class);
    configuration.addAnnotatedClass(CompanyInformation.class);
    configuration.addAnnotatedClass(EntityInformation.class);

    configuration.configure(configFile);

    ServiceRegistry serviceRegistry = new ServiceRegistryBuilder().applySettings(configuration.getProperties()).buildServiceRegistry();
    sessionFactory = configuration.buildSessionFactory(serviceRegistry);
}

public static void main(String[] args) throws Exception {
    // set up a Hibernate Session
    final Configuration configuration = new Configuration();
    configuration.addAnnotatedClass(PersonNst.class);
    configuration.configure();
    final ServiceRegistry serviceRegistry = new ServiceRegistryBuilder().applySettings(configuration.getProperties()).buildServiceRegistry();
    final SessionFactory sessionFactory = configuration.buildSessionFactory(serviceRegistry);
    final Session session = sessionFactory.openSession();
    session.beginTransaction();

    new HibernateSessionExample().run(new DbSessionHibernateImpl(session));

    session.getTransaction().commit();
    session.close();
    sessionFactory.close();
}

public static void main(String[] args) throws Exception {
    // set up a Hibernate Session
    final Configuration configuration = new Configuration();
    configuration.addAnnotatedClass(PersonCtt.class);
    configuration.addAnnotatedClass(PersonOrganisationalTreePath.class);
    configuration.addAnnotatedClass(PersonFunctionalTreePath.class);
    configuration.configure();
    final ServiceRegistry serviceRegistry = new ServiceRegistryBuilder().applySettings(configuration.getProperties()).buildServiceRegistry();
    final SessionFactory sessionFactory = configuration.buildSessionFactory(serviceRegistry);
    final Session session = sessionFactory.openSession();
    session.beginTransaction();

    new HibernateSessionExample().run(new DbSessionHibernateImpl(session));

    session.getTransaction().commit();
    session.close();
    sessionFactory.close();
}

/**
 * Abstract: Build SessionFactory object
 */
public static void rebuildSessionFactory() {
    try {
        // Initial application using configuration file
        configuration = new Configuration();
        configuration.configure(configFile);
        // Create SessionFactory object according to the configuration
        // Data model can be created in MySQL automatically after execute
        // this method
        ServiceRegistryBuilder serviceRegistryBuilder = new ServiceRegistryBuilder();
        ServiceRegistry serviceRegistry = serviceRegistryBuilder.applySettings(configuration.getProperties()).buildServiceRegistry();
        sessionFactory = configuration.configure().buildSessionFactory(serviceRegistry);
    } catch (Exception e) {
        e.printStackTrace();
    }
}

@BeforeClass
public static void setUpBeforeClass() throws Exception {
    // service
    commonServiceImpl = new CommonServiceImpl();
    // dao
    commonDaoImpl = new CommonDaoImpl();

    // 建構HibernateTemplate,因HibernateDaoSupporter需要
    HibernateTemplate hibernateTemplate = new HibernateTemplate();
    Configuration config = new Configuration().configure("hibernate.cfg.xml");
    // SessionFactory sessionFactory = config.buildSessionFactory();

    ServiceRegistry serviceRegistry = new ServiceRegistryBuilder().applySettings(config.getProperties())
            .buildServiceRegistry();
    SessionFactory sessionFactory = config.buildSessionFactory(serviceRegistry);
    hibernateTemplate.setSessionFactory(sessionFactory);
    commonDaoImpl.setHibernateTemplate(hibernateTemplate);
    //
    commonServiceImpl.setCommonDao(commonDaoImpl);
    commonServiceImpl.start();

}

@Test
public void openSession() throws Exception {
    Configuration config = new Configuration().configure("hibernate.cfg.xml");

    // SessionFactory sessionFactory = config.buildSessionFactory();
    ServiceRegistry serviceRegistry = new ServiceRegistryBuilder().applySettings(config.getProperties())
            .buildServiceRegistry();
    SessionFactory sessionFactory = config.buildSessionFactory(serviceRegistry);

    System.out.println("sessionFactory: " + sessionFactory);
    Session session = sessionFactory.openSession();
    session.doWork(new Work() {
        public void execute(Connection connection) throws SQLException {
            System.out.println("connection: " + connection);
            System.out.println("getAutoCommit: " + connection.getAutoCommit());
            System.out.println("getTransactionIsolation: " + connection.getTransactionIsolation());
        }
    });
}

/**
 * 生成一个新的SessionFactory,将模块的的model解析.
 * 这里将来可以做成从资源配置文件中动态解析生成.
 * @param entityClasses
 * @return
 */
private SessionFactory obtainSessionFactory(Collection<Class> entityClasses){
    LocalSessionFactoryBean localSessionFactoryBean =(LocalSessionFactoryBean) SpringContextUtil.getBean("&defaultSessionFactory");
    Configuration configuration = localSessionFactoryBean.getConfiguration();
    synchronized(configuration){//避免并发操作导致configuration重复添加相同的entityClass
        for(Class entityClass:entityClasses){
            if(configuration.getClassMapping(entityClass.getName())==null){
                configuration.addAnnotatedClass(entityClass);
            }
        }
    }
    Thread.currentThread().setContextClassLoader(this);//设置当前的Classloader不然会报找不到类的错误
    ServiceRegistry serviceRegistry = new ServiceRegistryBuilder().applySettings(configuration.getProperties()).buildServiceRegistry();
    SessionFactory newSessionFactory = configuration.buildSessionFactory(serviceRegistry);
    log.info("为模块中{}个类重新生成一个新的SessionFactory",entityClasses.size());
    Map<String,SessionFactory> sessionFactoryMap =(Map<String,SessionFactory>) SpringContextUtil.getBean("sessionFactoryMap");
    sessionFactoryMap.put(getModulesBean().getName(),newSessionFactory);
    return newSessionFactory;
}

public static SessionFactory buildSessionFactory(Class<?> testClass){
    Configuration configuration = new Configuration();
    configuration.setProperty("connection.driver_class","org.h2.Driver");
    configuration.setProperty("hibernate.connection.url", "jdbc:h2:mem:" + testClass.getSimpleName());
    configuration.setProperty("hibernate.connection.username", "sa");
    configuration.setProperty("hibernate.connection.password", "");
    configuration.setProperty("dialect", "org.hibernate.dialect.H2Dialect");
    configuration.setProperty("hibernate.hbm2ddl.auto", "update");
    configuration.setProperty("show_sql", "true");
    configuration.setProperty(" hibernate.connection.pool_size", "10");

    Reflections reflections = new Reflections("io.robe.hibernate.test.entity");

    Set<Class<?>> classes = reflections.getTypesAnnotatedWith(javax.persistence.Entity.class);

    for(Class<?> clazz : classes) {
        configuration.addAnnotatedClass(clazz);
    }

    ServiceRegistry serviceRegistry = new StandardServiceRegistryBuilder().applySettings(configuration.getProperties()).build();
    return configuration.buildSessionFactory(serviceRegistry);
}

private static SessionFactory buildSessionFactory() {
    try {
        Configuration configuration=new Configuration().configure();

        StandardServiceRegistryBuilder serviceRegistryBuilder = 
                new StandardServiceRegistryBuilder();

        serviceRegistryBuilder.applySettings(configuration.getProperties());

        ServiceRegistry serviceRegistry = serviceRegistryBuilder.build();
        return configuration.buildSessionFactory(serviceRegistry);
    } catch (Throwable ex) {
        System.err.println("Initial SessionFactory creation failed." + ex);
        throw new ExceptionInInitializerError(ex);
    }
}

private static SessionFactory buildSessionFactory() {
    /*
     * Load up the configuration using the hibernate.cfg.xml
     */
    Configuration configuration = new Configuration();
    configuration.configure("hibernate.cfg.xml");

    /*
     * Build the registry using the properties in the configuration
     */
    ServiceRegistry serviceRegistry = new StandardServiceRegistryBuilder().applySettings(
            configuration.getProperties()).build();

    /*
     * Now load the classes
     */
    for (Class<?> pojoClass : classList) {
        log.info("Adding annotated class : " + pojoClass.getCanonicalName());
        configuration.addAnnotatedClass(pojoClass);
    }

    /*
     * and finally buils the session factory
     */
    return configuration.buildSessionFactory(serviceRegistry);
}

@Override
public ServiceRegistry buildServiceRegistry() {
    if (connectionProviderBuilder == null || configurationPovider == null) {
        throw new IllegalArgumentException();
    }
    LOG.debug("Creating service registry");
    BootstrapServiceRegistry bootstrapServiceRegistry = buildBootstrapServiceRegistry();
    org.hibernate.service.ServiceRegistryBuilder builder = new org.hibernate.service.ServiceRegistryBuilder(
            bootstrapServiceRegistry).addService(ConnectionProvider.class, connectionProviderBuilder.buildConnectionProvider());
    if (sessionObserver != null) {
        builder.addService(SessionObserver.class, sessionObserver);
    }
    builder.applySettings(configurationPovider.getConfiguration().getProperties());
    return builder.buildServiceRegistry();

}