DBSource.java

 

package com.aspboy.base.database;

/*
 * 创建日期 2007-1-22
 *
 * TODO 要更改此生成的文件的模板，请转至
 * 窗口 － 首选项 － Java － 代码样式 － 代码模板
 */

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;

 

/**
数据库联系类，提供了取数据库联接的方法
*/
public class DBSource
{

        /**
                静态方法，取数据库联接
        */
        public static Connection getConnection() throws Exception
        {
          Connection conn = null;
          try
          {
            /*
            //start  连接池
           context = new InitialContext();
           InitialContext context = new InitialContext();
           ds = (DataSource)context.lookup("jdbc/OracleDS");
           conn = ds.getConnection();
            //end 连接池
            */

         /*
           //这是odbc方式连接方式
           String driver="sun.jdbc.odbc.JdbcOdbcDriver";
           String url="jdbc:odbc:newjchtdb";
           String username="sa";
           String password="";

           */

          //这里通过配置文件实现数据库连接参数的设置
          String url=(String)ConfigUtil.getConfigInfo().get("url");
          //System.out.println("url100="+url);
          String driver=(String)ConfigUtil.getConfigInfo().get("driver");
          //System.out.println("driver="+driver);
          String username=(String)ConfigUtil.getConfigInfo().get("user");
          //System.out.println("user="+username);
          String password=(String)ConfigUtil.getConfigInfo().get("password");
          //System.out.println("password="+password);

           Class.forName(driver);
           conn = DriverManager.getConnection(url,username,password);

          }
          catch(SQLException se)
          {
            //throw new ServletException(se);
          }

          catch (Exception e)
          {
                  e.printStackTrace();
                  conn = null;

          }
          return conn;
        }

        public static Connection getConnectionFromSession() throws Exception
        {
          Connection conn = null;
          try
          {
            /*
            //start  连接池
           context = new InitialContext();
           InitialContext context = new InitialContext();
           ds = (DataSource)context.lookup("jdbc/OracleDS");
           conn = ds.getConnection();
            //end 连接池
            */

         /*
           //这是odbc方式连接方式
           String driver="sun.jdbc.odbc.JdbcOdbcDriver";
           String url="jdbc:odbc:newjchtdb";
           String username="sa";
           String password="";

           */

          //这里通过配置文件实现数据库连接参数的设置
          String url=(String)ConfigUtil.getConfigInfo().get("url");
          //System.out.println("url100="+url);
          String driver=(String)ConfigUtil.getConfigInfo().get("driver");
          //System.out.println("driver="+driver);
          String username=(String)ConfigUtil.getConfigInfo().get("user");
          //System.out.println("user="+username);
          String password=(String)ConfigUtil.getConfigInfo().get("password");
          //System.out.println("password="+password);

           Class.forName(driver);
           conn = DriverManager.getConnection(url,username,password);
          
          
          

          }
          catch(SQLException se)
          {
            //throw new ServletException(se);
          }

          catch (Exception e)
          {
                  e.printStackTrace();
                  conn = null;

          }
          return conn;
        }

        public static Connection getConnectionFromPool() throws Exception
        {
          Connection conn = null;
          try
          {
           conn = DriverManager.getConnection("proxool.myweb2008");
          }
          catch(SQLException se)
          {
            //throw new ServletException(se);
          }

          catch (Exception e)
          {
                  e.printStackTrace();
                  conn = null;

          }
          return conn;
        }
       
       
       
        public static void main(String[] args)
        {
         
         try {
    System.out.println("conn="+DBSource.getConnectionFromPool());
   } catch (Exception e) {
    // TODO Auto-generated catch block
    e.printStackTrace();
   }
         
        }

   

}