1、在WL建立一个Connection Pools,可以测试的 2、再建立一个DataSource,其Pool Name指向刚才配置的Connection Pools,给这个DataSource的JNDI名指定为“MysqlPool“ 3、建立客户端测试程序
package com.catmiw.testmysql;
import javax.naming.*; import javax.sql.DataSource; import java.sql.*; import java.util.Properties;
public class MysqlPool { private static Context getInitialContext() throws Exception { String url = "t3://localhost:7001"; String user = null; String password = null; Properties properties = null; try { properties = new Properties(); properties.put(Context.INITIAL_CONTEXT_FACTORY, "weblogic.jndi.WLInitialContextFactory"); properties.put(Context.PROVIDER_URL, url); if (user != null) { properties.put(Context.SECURITY_PRINCIPAL, user); properties.put(Context.SECURITY_CREDENTIALS, password == null ? "" : password); }
return new InitialContext(properties); } catch (Exception e) { System.out.println("Unable to connect to WebLogic server at " + url); System.out.println("Please make sure that the server is running."); throw e; } }
public static void main(String args[]) throws Exception { Context ctx = getInitialContext(); //得到初始化上下文 Object obj = ctx.lookup("MysqlPool");//查找连接池 DataSource ds = (DataSource) obj;//转换成DataSource
try { Connection connect = ds.getConnection();//从连接池中得到一个连接 System.out.println("Success connect Mysql Connection Pool!");
Statement stmt = connect.createStatement(); ResultSet rs = stmt.executeQuery("select * from pet"); while (rs.next()) { System.out.println(rs.getString("name"));
} } catch (Exception e) { System.out.print("get data error!"); e.printStackTrace(); }
} }
运行结果: Success connect Mysql Connection Pool! 
|