一、在WebLogic新建针对Oracle数据库的JNDI数据源
进入weblogic管理控制台,此处是远程访问:http://192.168.1.144:7001/console
点击左侧【域结构】→【base domain】→【服务】→【数据源】然后点击右侧【新建】→【般数据源】,如下图所示:
填写JDBC数据源的【名称】、【jndi名称】,选择数据库类型,如选择【oracle】,下一步
选择Oracle数据库的驱动程序,如下图所示:
这里选择【Oracle' s Driver (Thin)for Instance connections;Version:Any】,点击【下一步】按钮,进入下一个配置步骤:
这里使用默认配置即可 ,点击【下一步】按钮,进入下一个配置步骤:如下图所示:
填写数据库的连接信息:要连接的数据库,数据库的IP地址,连接数据库时使用的端口号,登录数据库时使用的用户名和密码
点击【下一步】按钮,进入下一个配置步骤:如下图所示:
连接测试结果如下:
点击【下一步】按钮,进入下一个配置步骤:如下图所示:
点击【完成】,这样WebLogic就会创建一个新的JDBC数据源,如下图所示:
到此,在WebLogic新建针对Oracle数据库的JNDI数据源就算是全部完成了。数据源创建之后,我们就可以在应用程序中使用数据源了。
二、在WebLogic新建针对MysqL数据库的JNDI数据源
上面我们已经配置好了一个针对Oracle数据库的JNDI数据源,这里我们在新建一个针对MysqL数据库的数据源,配置步骤和上述针对Oracle数据库创建的JDBC数据源大部分是一样的,针对不一样的地方给出如下的截图说明:
到此,在WebLogic新建针对MysqL数据库的JNDI数据源就算是全部完成了。查看jndi树,可以看到JNDI树上面挂载了两个数据源,如下图所示:
三、在应用程序中使用WebLogic配置JNDI数据源
3.1、创建测试项目
新建一个测试项目,如下图所示:
3.2、编写测试代码
编写一个WebLogicJndiUtil工具类,用于从WebLogic的JNDI容器中取出数据源。
WebLogicJndiUtil工具类代码如下:
- /**
- *
- */
- package me.gacl.util;
- import java.sql.Connection;
- import java.sql.sqlException;
- import java.util.Properties;
- import javax.naming.Context;
- import javax.naming.InitialContext;
- import javax.sql.DataSource;
- /**
- * <p>ClassName: WebLogicJndiUtil<p>
- * <p>Description: 获取WebLogic服务器中的JNDI数据源工具类<p>
- * @author xudp
- * @version 1.0 V
- * @createTime 2015-1-4 下午03:54:39
- */
- public class WebLogicJndiUtil {
- //初始化上下文需要用到的工厂类
- private final static String INITIAL_CONTEXT_FACTORY="weblogic.jndi.WLInitialContextFactory";
- //WebLogic服务器的访问地址
- private final static String PROVIDER_URL="t3://192.168.1.144:7001";
- //WebLogic服务器中的JNDI数据源名称
- private final static String ORACLE_JNDI_NAME="JNDI/OracleDataSource";
- private final static String MysqL_JNDI_NAME="JNDI/MysqLDataSource";
- //存储从JNDI容器中取出来的数据源
- private static DataSource dsOracle = null;
- private static DataSource dsMysqL = null;
- static {
- try {
- //初始化WebLogic Server的JNDI上下文信息
- Context context = getInitialContext();
- //获取数据源对象
- dsOracle = (DataSource) context.lookup(ORACLE_JNDI_NAME);
- dsMysqL = (DataSource) context.lookup(MysqL_JNDI_NAME);
- } catch (Exception e) {
- e.printStackTrace();
- }
- }
- /**
- * MethodName: getInitialContext
- * Description: 获得WebLogic ServerJNDI初始上下文信息
- * @author xudp
- * @return
- * @throws Exception
- */
- private static Context getInitialContext() throws Exception {
- Properties properties = new Properties();
- properties.put(Context.INITIAL_CONTEXT_FACTORY,INITIAL_CONTEXT_FACTORY);
- properties.put(Context.PROVIDER_URL,PROVIDER_URL);
- return new InitialContext(properties);
- }
- /**
- * MethodName: getOracleConnection
- * Description: 获取Oracle数据库连接
- * @author xudp
- * @return
- * @throws sqlException
- */
- public static Connection getOracleConnection() throws sqlException {
- return dsOracle.getConnection();
- }
- /**
- * MethodName: getMysqLConnection
- * Description: 获取MysqL数据库连接
- * @author xudp
- * @return
- * @throws sqlException
- */
- public static Connection getMysqLConnection() throws sqlException {
- return dsMysqL.getConnection();
- }
- }
编写一个测试Servlet,JndiTestServlet的代码如下:
- package me.gacl.test;
- import java.io.IOException;
- import java.sql.Connection;
- import java.sql.ResultSet;
- import java.sql.sqlException;
- import java.sql.Statement;
- import javax.servlet.ServletException;
- import javax.servlet.http.HttpServlet;
- import javax.servlet.http.HttpServletRequest;
- import javax.servlet.http.HttpServletResponse;
- import me.gacl.util.WebLogicJndiUtil;
- /**
- * <p>ClassName: JndiTestServlet<p>
- * <p>Description: <p>
- * @author xudp
- * @version 1.0 V
- * @createTime 2015-1-4 下午03:37:53
- */
- public class JndiTestServlet extends HttpServlet {
- public void doGet(HttpServletRequest request,HttpServletResponse response)
- throws ServletException,IOException {
- //Oracle数据库连接对象
- Connection oracleConn = null;
- //MysqL数据库连接对象
- Connection MysqLConn = null;
- Statement stmt = null;
- ResultSet rs = null;
- try {
- String sqlOracle = "SELECT * FROM LEAD_OAMS_APPLICATIONS";
- //获取数据库连接对象
- oracleConn = WebLogicJndiUtil.getOracleConnection();
- stmt = oracleConn.createStatement();
- rs = stmt.executeQuery(sqlOracle);
- while (rs.next()) {
- System.out.println(rs.getString("RESOURCEID")+"---"+rs.getString("APP_NAME"));
- }
- System.out.println("-----------------------------分割线-------------------------------------");
- String sqlMysqL = "SELECT * FROM LEAD_OAMS_DBSOURCES";
- //获取数据库连接对象
- MysqLConn = WebLogicJndiUtil.getMysqLConnection();
- stmt = MysqLConn.createStatement();
- rs = stmt.executeQuery(sqlMysqL);
- while (rs.next()) {
- System.out.println(rs.getString("RESOURCEID")+"---"+rs.getString("DBSOURCE_NAME"));
- }
- } catch (sqlException e) {
- e.printStackTrace();
- }finally{
- try {
- rs.close();
- stmt.close();
- oracleConn.close();
- } catch (sqlException e) {
- e.printStackTrace();
- }
- }
- }
- public void doPost(HttpServletRequest request,IOException {
- doGet(request,response);
- }
- }
在Web.xml文件中注册JndiTestServlet,如下:
- <servlet>
- <servlet-name>JndiTestServlet</servlet-name>
- <servlet-class>me.gacl.test.JndiTestServlet</servlet-class>
- </servlet>
- <servlet-mapping>
- <servlet-name>JndiTestServlet</servlet-name>
- <url-pattern>/servlet/JndiTestServlet</url-pattern>
- </servlet-mapping>
将测试项目部署到WebLogic服务器中运行,如下图所示:
输入JndiTestServlet的访问地址:http://localhost:7001/WebLogic_Jndi_Test/servlet/JndiTestServlet进行测试,如下图所示:
访问JndiTestServlet的过程中没有出现任何错误,后台的控制台中输出了从数据库中取出来的数据,如下图所示:
这就证明了我们已经成功地从WebLogic服务器中的JNDI树中取出了JDBC数据源,再通过数据源获取到了数据库连接,执行sql从数据库中查询出数据。
以上就是关于在WebLogic配置JNDI数据源以及如何在应用程序中使用配置好的JNDI数据源的全部内容。