package cn.netjava.cngpclient.publics;

import java.sql.*;
import java.util.*;

import cn.netjava.cngpclient.connection.IsmgInfo;

/**
 * 數(shù)據(jù)庫(kù)連結(jié)工具
 * 中國(guó)網(wǎng)通短信網(wǎng)關(guān)客戶端--藍(lán)杰實(shí)訓(xùn)項(xiàng)目
 * @author www.NetJava.cn
 *
 */
public class DatabaseAccess {

	public static DatabaseAccess instance() {
		if (FoxspDB == null) {
			FoxspDB = new DatabaseAccess();
		}
		return FoxspDB;
	}

	public static Connection connectDatabase(String db_url, String db_user,
			String db_passwd) throws Exception {

		// Connection dbc = null;
		String DBURL = "jdbc:microsoft:sqlserver://" + db_url; // +";SelectMethod=cursor";
		// System.out.println("*****PublicConstants.DB_DRIVER:
		// "+PublicConstants.DB_DRIVER);
		System.out.println("*****CONNECTION_URL: " + db_url);

		// try {
		Connection conn = null;
		Class.forName(PublicConstants.DB_DRIVER).newInstance();
		conn = DriverManager.getConnection(DBURL, db_user, db_passwd);
		System.out.println("           conn DB OK::::: ");
		return conn;
		// }
		// catch (ClassNotFoundException cnfe) {
		// System.out.println(" Not Found DB_Driver: " +
		// PublicConstants.DB_DRIVER + cnfe);
		// PublicConstants.writeLog.info( " Not Found DB_Driver: " + cnfe, 0);
		// return null;
		// }
		// catch (Exception e) {
		// System.out.println( " Connect DB erro: " + e);
		// PublicConstants.writeLog.info(db_url + " Connect DB erro: " + e,
		// 0);
		// return null;
		// }
	}

	/**
	 * 斷開(kāi)與數(shù)據(jù)庫(kù)之間的連接
	 * 
	 * @param conn
	 */
	public static void disconnectDatabase(Connection conn) {
		if (conn == null) {
			return;
		}
		try {
			conn.close();
		} catch (SQLException sqle) {
			// method.error("Database disconnecting failed") ;
		}
	}

	/**
	 * desc:連結(jié)是否正常
	 * 
	 * @param dbc
	 * @return true:正常 false:失敗
	 */
	public static boolean isConnectDB(Connection dbc) {
		if (dbc == null) {
			return false;
		}
		try {
			if (dbc.isClosed()) {
				return false;
			} else {
				Statement pstmt = null;
				pstmt = (Statement) dbc.createStatement();
				pstmt.close();
				return true;
			}
		} catch (SQLException ex) {
			return false;
		}

	}

	private DatabaseAccess() {
	}

	/** DB類實(shí)例 */
	public static DatabaseAccess FoxspDB;
}