dbutil.java

wap短信发送

/*
 * Created on 2005-5-21
 *
 */
package net.mcool.www.util.db;

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

import javax.naming.Context;
import javax.naming.InitialContext;
import javax.naming.NamingException;
import javax.sql.DataSource;

/**
 * @author a
 *  
 */
public class DbUtil {
    public static Context initContext;

    public static Context ctx;

    public static DataSource ds;

    public static boolean hasInited = false;

    public static Connection conn = null;

    public static void init() {
        try {
            initContext = new InitialContext();
            ctx = (Context) initContext.lookup("java:comp/env");
            ds = (DataSource) ctx.lookup("jdbc/mcool");
            hasInited = true;
        } catch (NamingException e) {
            e.printStackTrace();
        }
    }

    /**
     * 取得数据库连接。
     * 
     * @return
     */
    public static Connection getConnection() {
        if (conn != null) {
            return conn;
        } else {
            return getDirectConnection();
        }
        //		try {
        //		    initContext = new InitialContext();
        //			ctx = (Context) initContext.lookup("java:comp/env");
        //			ds = (DataSource) ctx.lookup("jdbc/mcool");
        //			Connection conn = ds.getConnection();
        //			return conn;
        //		} catch (SQLException e) {
        //			e.printStackTrace();
        //		} catch (NamingException e) {
        //			e.printStackTrace();
        //		}
        //		return null;
    }

    public static Connection getDirectConnection() {
        try {
            Class.forName("com.mysql.jdbc.Driver").newInstance();
            conn = DriverManager.getConnection(
                    "jdbc:mysql://127.0.0.1:3306/mcoolwap", "root", "123456");
            return conn;
        } catch (InstantiationException e) {
            e.printStackTrace();
        } catch (IllegalAccessException e) {
            e.printStackTrace();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }
        return null;
    }
}