dbmng.java

java支持的短信平台

package com.khan.db;

import java.sql.*;
import javax.sql.*;
import javax.naming.*;
import java.io.*;


/**
 *
 * <p>Title: </p>
 * <p>Description: </p>
 * <p>Copyright: Copyright (c) 2005</p>
 * <p>Company: </p>
 * @author not attributable
 * @version 1.0
 */
public class DBMng {
  private DBMng() {}

//  public static String MURL = "jdbc:oracle:thin:@127.0.0.1:11010:o9i";
// public static String UURL = "jdbc:oracle:thin:@127.0.0.1:11010:o9i";
  // private static String mUSR = "smp";
  // private static String mPWD = "smp131445";

  /**
   * 取得jndi配置的连接池中的连接
   * @return Connection
   */
  public static Connection getConnection() {
    Connection con = null;
    try {
      Context env = (Context)new InitialContext().lookup("java:comp/env");
      DataSource source = (DataSource) env.lookup("jdbc/Sql");
      con = source.getConnection();
    }catch (Exception ex) {
      ex.printStackTrace();
    }
    return con;
  }


  public static Connection getBlogConnection() {
    Connection con = null;
    try {
      Context env = (Context)new InitialContext().lookup("java:comp/env");
      DataSource source = (DataSource) env.lookup("jdbc/blog");
      con = source.getConnection();

    } catch (Exception ex) {
      ex.printStackTrace();
    }
    return con;
  }


  public static Connection getConnection(String dbStr) {
      Connection con = null;
      try {
        Context env = (Context)new InitialContext().lookup("java:comp/env");
        DataSource source = (DataSource) env.lookup(dbStr);
        con = source.getConnection();
      }catch (Exception ex) {
        ex.printStackTrace();
      }
    return con;
  }

  public static Connection getConnection4ini() {
    String dbStr="";
    com.khan.file.LoadIni li = new  com.khan.file.LoadIni("conf/dbpool.ini");
    try {
        dbStr = li.readINI("jndi_name");
    } catch (IOException ex1) {
        return null;
    } catch (Exception ex1) {
        return null;
    }

    if (dbStr == null || dbStr.equals(""))
        return null;

    Connection con = null;
    try {
      Context env = (Context)new InitialContext().lookup("java:comp/env");
      DataSource source = (DataSource) env.lookup(dbStr);
      con = source.getConnection();
    }catch (Exception ex) {
      ex.printStackTrace();
    }
  return con;
}

}