使用JNDI为Hibernate注册MySQL DataSource

2019年8月4日 192次阅读

我有通过JNDI数据源连接到数据库的hibernate.

我的目的：使用JNDI注册表DataSource来测试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,您的代码将起作用.此文件应位于类路径中.

这是工作示例：

服务器：

    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注意：datasource jndi名称应该与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();
    }
}
点赞