不依赖于Web容器也可以自己创建JNDI
package com.hy.recommender.test.engine;import java.io.IOException;import java.io.InputStream;import java.rmi.Remote;import java.rmi.registry.LocateRegistry;import java.sql.Connection;import jav
·
我的在利用mahout来做一个推荐系统,需要利用mahout提供的MySQLJDBCDataModel类来产生JDBCDataModel,在这过程中需要datasource,由于我的工程是java工程,所以没办法依赖web容器,只能在main方法里创建JNDI,然后将自己所需要的对象放进去。
package com.hy.recommender.test.engine;
import java.io.IOException;
import java.io.InputStream;
import java.rmi.Remote;
import java.rmi.registry.LocateRegistry;
import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.Statement;
import java.util.Date;
import java.util.Properties;
import javax.naming.Context;
import javax.naming.InitialContext;
import com.mysql.jdbc.jdbc2.optional.MysqlDataSource;
public class T {
public static void main(String[] args) throws Exception{
LocateRegistry.createRegistry(1099);
System.setProperty(Context.INITIAL_CONTEXT_FACTORY, "com.sun.jndi.rmi.registry.RegistryContextFactory");
System.setProperty(Context.PROVIDER_URL, "rmi://localhost:1099");
InitialContext ctx = new InitialContext();
//class RemoteDate extends Date implements Remote {};
//ctx.bind("java:comp/env/systemStartTime", new RemoteDate());
MysqlDataSource myds=new MysqlDataSource();
//设置参数
myds.setUser("root");
myds.setPassword("123456");
myds.setDatabaseName("recommendersystem");
myds.setUrl("jdbc:mysql://localhost:3306/dbname");
//用JNDI绑定DataSource
myds.setPortNumber(3306);
myds.setServerName("localhost");
ctx.bind("mydatasource",myds);
MysqlDataSource ods=(MysqlDataSource)ctx.lookup("mydatasource");
Connection con=ods.getConnection();
Statement st=con.createStatement();
ResultSet rs=st.executeQuery("select * from ratings limit 10 ");
while(rs.next()){
System.out.println(rs.getString("movieID"));
}
ctx.close();
//LocateRegistry.getRegistry(1099).unbind("mydatasource");
}
}
更多推荐
已为社区贡献2条内容
所有评论(0)