WEBLOGIC811下的MYSQL连接池配置及测试

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!

本文地址：http://com.8s8s.com/it/it15083.htm