我有hibernate通过JNDI数据源连接到数据库。
我的目的:使用JNDI注册数据源以测试DAO层。
例
hibernate配置
<hibernate-configuration> <session-factory name="MySessionFactory"> <property name="hibernate.connection.datasource">java:jdbc/MysqlMyDS</property> <property name="hibernate.connection.driver_class">com.mysql.jdbc.Driver</property> <!-- mappings .... -> </hibernate-configuration>
在测试类中获取SessionFactory:
Configuration cgf = new Configuration().configure("/META-INF/hibernate.cfg.xml"); SessionFactory iceleadsSessionFactory = cgf.buildSessionFactory();
作为结果:
16:04:37,753 ERROR DatasourceConnectionProvider:78 - Could not find datasource: java:jdbc/MysqlIceleadsDS javax.naming.NoInitialContextException: Need to specify class name in environment or system property, or as an applet parameter, or in an application resource file: java.naming.factory.initial
要注册JNOI,我使用示例(http://www.roseindia.net/tutorial/java/jdbc/registeringthedatasourcewithjndi.html)
import java.rmi.RemoteException; import java.rmi.registry.LocateRegistry; import java.util.Properties; import javax.naming.Context; import javax.naming.InitialContext; import javax.naming.NamingException; import javax.sql.ConnectionPoolDataSource; import com.mysql.jdbc.jdbc2.optional.MysqlConnectionPoolDataSource; import com.mysql.jdbc.jdbc2.optional.MysqlDataSource; public class RegisteringJNDIWithDataSource { private static void startRegistry() throws RemoteException { System.out.println(LocateRegistry.getRegistry()); LocateRegistry.createRegistry(1059); System.out.println("RMI registry Stared."); } private static InitialContext createInitialContextContext() throws NamingException { Properties properties = new Properties(); properties.put(Context.INITIAL_CONTEXT_FACTORY, "com.sun.jndi.rmi.registry.RegistryContextFactory"); properties.put(Context.PROVIDER_URL, "rmi://localhost:1059"); InitialContext initialContextcontext = new InitialContext(properties); return initialContextcontext; } public static void main(String args[]) { try { startRegistry(); ConnectionPoolDataSource dataSource = new MysqlConnectionPoolDataSource(); ((MysqlDataSource) dataSource).setUser("root"); ((MysqlDataSource) dataSource).setPassword("root"); ((MysqlDataSource) dataSource).setServerName("192.168.10.13"); ((MysqlDataSource) dataSource).setPort(3306); ((MysqlDataSource) dataSource).setDatabaseName("student"); InitialContext context = createInitialContextContext(); context.rebind("Source", dataSource); } catch (Exception e) { System.out.println(e.getMessage()); } } }
请提出解决方案。谢谢!
如果设置正确,您的代码将起作用jndi.properties。该文件应位于类路径中。
jndi.properties
这是工作示例:
服务器:
public static void main(String[] args) throws Exception{ LocateRegistry.createRegistry(1099); ConnectionPoolDataSource dataSource = createDataSource("root", ""); InitialContext context = createContext(); context.bind("MysqlMyDS", dataSource); System.out.println("context created!"); } private static InitialContext createContext() throws NamingException { Properties env = new Properties(); env.put(Context.INITIAL_CONTEXT_FACTORY, "com.sun.jndi.rmi.registry.RegistryContextFactory"); env.put(Context.PROVIDER_URL, "rmi://localhost:1099"); InitialContext context = new InitialContext(env); return context; } private static ConnectionPoolDataSource createDataSource(String username, String password) { MysqlConnectionPoolDataSource dataSource = new MysqlConnectionPoolDataSource(); dataSource.setUser(username); dataSource.setPassword(password); dataSource.setServerName("localhost"); dataSource.setPort(3306); dataSource.setDatabaseName("test"); return dataSource; }
客户:
hibernate.cfg.xml注意:数据源jndi名称应与您设置的名称完全相同 context.bind()
context.bind()
<?xml version='1.0' encoding='utf-8'?> <!DOCTYPE hibernate-configuration PUBLIC "-//Hibernate/Hibernate Configuration DTD 3.0//EN" "http://hibernate.sourceforge.net/hibernate-configuration-3.0.dtd"> <hibernate-configuration> <session-factory> <property name="hibernate.connection.datasource">MysqlMyDS</property> <property name="hibernate.connection.driver_class">com.mysql.jdbc.Driver</property> </session-factory> </hibernate-configuration>
jndi.properties(如果需要,可以在代码中或使用-D选项进行设置)
java.naming.factory.initial=com.sun.jndi.rmi.registry.RegistryContextFactory java.naming.provider.url=rmi://localhost:1099
单元测试
public class TestClient { @Test public void testCfg() throws Exception { Configuration cgf = new Configuration().configure("/hibernate.cfg.xml"); cgf.buildSessionFactory(); } }