java - Hibernate 分片和 JNDI 问题

Question

我正在尝试运行 hibernate 分片的示例程序。我已经完成了，但是每当我运行测试程序时，我都会遇到异常

javax.naming.NoInitialContextException:需要在环境或系统属性中指定类名

谷歌搜索后我知道我必须设置 JNDI 属性。我确实喜欢这个

Hashtable env = new Hashtable();
env.put( Context.INITIAL_CONTEXT_FACTORY,"com.sun.enterprise.naming.SerialInitContextFactory");
env.put( Context.PROVIDER_URL, "<some-IP>:3306" );
Context initialContext = new InitialContext(env);

javax.naming.NoInitialContextException: Cannot instantiate class: com.sun.enterprise.naming.SerialInitContextFactory [Root exception is java.lang.ClassNotFoundException: com.sun.enterprise.naming.SerialInitContextFactory]
at javax.naming.spi.NamingManager.getInitialContext(NamingManager.java:657)
at javax.naming.InitialContext.getDefaultInitCtx(InitialContext.java:288)
at javax.naming.InitialContext.init(InitialContext.java:223)
at javax.naming.InitialContext.<init>(InitialContext.java:197)
at com.hibshards.test.JNDIProperties.setProperties(JNDIProperties.java:18)
at com.hibshards.test.SessionFactoryImpl.createSessionFactory(SessionFactoryImpl.java:32)
at com.hibshards.test.ShardTest.main(ShardTest.java:17)
Caused by: java.lang.ClassNotFoundException: com.sun.enterprise.naming.SerialInitContextFactory
at java.net.URLClassLoader$1.run(URLClassLoader.java:200)
at java.security.AccessController.doPrivileged(Native Method)
at java.net.URLClassLoader.findClass(URLClassLoader.java:188)
at java.lang.ClassLoader.loadClass(ClassLoader.java:307)
at sun.misc.Launcher$AppClassLoader.loadClass(Launcher.java:301)
at java.lang.ClassLoader.loadClass(ClassLoader.java:252)
at java.lang.ClassLoader.loadClassInternal(ClassLoader.java:320)
at java.lang.Class.forName0(Native Method)
at java.lang.Class.forName(Class.java:247)
at com.sun.naming.internal.VersionHelper12.loadClass(VersionHelper12.java:46)
at javax.naming.spi.NamingManager.getInitialContext(NamingManager.java:654)
... 6 more

但是事情仍然不起作用。:-(请帮忙。我缺少什么？

这是代码:

public class SessionFactoryImpl {

    private static final String SHARD_CFG_0 = "/com/hibshards/config/shard0.hibernate.cfg.xml";
    private static final String SHARD_CFG_1 = "/com/hibshards/config/shard1.hibernate.cfg.xml";
    private static final String SHARDED_TABLE = "com/hibshards/orm/weather.hbm.xml";

    public static SessionFactory createSessionFactory() throws NamingException {
        Configuration prototypeConfig = new Configuration().configure( SHARD_CFG_0 );
        prototypeConfig.addResource( SHARDED_TABLE );

        List<ShardConfiguration> shardConfigs = new ArrayList<ShardConfiguration>();
        shardConfigs.add( buildShardConfig( SHARD_CFG_0 ) );
        shardConfigs.add( buildShardConfig( SHARD_CFG_1 ) );

        ShardStrategyFactory shardStrategyFactory = buildShardStrategyFactory();
        ShardedConfiguration shardedConfig = new ShardedConfiguration(
                prototypeConfig,
                shardConfigs,
                shardStrategyFactory);
        return shardedConfig.buildShardedSessionFactory();
    }

    private static ShardStrategyFactory buildShardStrategyFactory() {

        ShardStrategyFactory shardStrategyFactory = new ShardStrategyFactory() {
            public ShardStrategy newShardStrategy(List<ShardId> shardIds) {
                RoundRobinShardLoadBalancer loadBalancer = new RoundRobinShardLoadBalancer( shardIds );
                ShardSelectionStrategy pss = new RoundRobinShardSelectionStrategy( loadBalancer );
                ShardResolutionStrategy prs = new AllShardsShardResolutionStrategy( shardIds );
                ShardAccessStrategy pas = new SequentialShardAccessStrategy();
                return new ShardStrategyImpl( pss, prs, pas );
            }
        };
        return shardStrategyFactory;
    }

    private static ShardConfiguration buildShardConfig( String configFile ) {
        Configuration config = new Configuration().configure( configFile );
        return new ConfigurationToShardConfigurationAdapter( config );
    }
}

<?xml version='1.0' encoding='utf-8'?>
 <!DOCTYPE hibernate-configuration PUBLIC
 "-//Hibernate/Hibernate Configuration DTD//EN"
 "http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd">

  <hibernate-configuration>
  <session-factory name="HibernateSessionFactory0"> 
<property name="dialect">org.hibernate.dialect.MySQLDialect</property>
<property name="connection.driver_class">com.mysql.jdbc.Driver</property>
    <property name="connection.url">jdbc:mysql://localhost:3306/shardDB</property>
   <property name="connection.username">root</property>
    <property name="connection.password">root</property>
   <property name="hibernate.connection.shard_id">0</property> 
    <property name="hibernate.shard.enable_cross_shard_relationship_checks">true</property> 
  </session-factory>
    </hibernate-configuration>


public class JNDIProperties { 
public static void setProperties() throws NamingException {
    Properties properties = new Properties();
    properties.put( Context.INITIAL_CONTEXT_FACTORY, "com.sun.enterprise.naming.SerialInitContextFactory");
    properties.put( Context.PROVIDER_URL, "file:///");
    Context initialContext = new InitialContext( properties );
  }
          }

Answer 1

在简单的 java 应用程序中，您不需要 session 工厂的名称。尝试删除 cfg.xml 文件中的名称并执行它