databaseaccess.java

移动彩信网关

package com.mengzhong.mms.publics;

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

public class DatabaseAccess
{
	private static Connection	con=null;

	public DatabaseAccess() {
        }

        public static   synchronized  DatabaseAccess instance() {
		if(X2spDB == null)
			X2spDB = new DatabaseAccess();
		return X2spDB;
	}
	/**
	 * 从T_SYS_CONFIG表获取配置参数
         * @return boolean
	 */
 	public static boolean getSYSPara() {
        	return true;
	}
        /**
         * 从T_SYS_CONFIG表获取单个配置参数
         * @param paraname
         * @param conn1orConn2 连接名
         * @return String para
         */
	public static String getOneSYSPara(String paraname)
        {
            Connection conn=connectDatabase(PublicConstants.CONNECTION_URL,PublicConstants.DB_USER,PublicConstants.DB_PASS);
            ResultSet rs = null;
	    PreparedStatement pstmt=null;
		String sQuery =
		    "select PARAM_VALUE "+
		    "from T_SYS_CONFIG where PARAM_NAME = ? ";
		try {
			pstmt = conn.prepareStatement(sQuery) ;
			pstmt.setString(1,paraname) ;
			rs = pstmt.executeQuery() ;
			if(rs.next()) {
				//System.out.println(paraname +" : "+rs.getString(1));
				String retstr = rs.getString(1) ;
				pstmt.close() ;
                disconnectDatabase(conn);
				return retstr ;
			} else {
				pstmt.close() ;
                disconnectDatabase(conn);
				return null;
			}
		} catch (Exception ex) {
			System.out.println("Read Para "+paraname+" :"+ex);

			disconnectDatabase(conn);
            return null;
		}
    }

    /**
     * 从T_SYS_CONFIG表获取单个配置参数
     * @param paraname
     * @param conn1orConn2 连接名
     * @return String para
     */
    public static String getTestPara(String paraname)
    {
        Connection conn=connectDatabase(PublicConstants.CONNECTION_URL,PublicConstants.DB_USER,PublicConstants.DB_PASS);
        ResultSet rs = null;
        PreparedStatement pstmt=null;
            String sQuery =
                "select PARAM_VALUE "+
                "from T_Test_Sms where PARAM_SEQ = ? ";
            try {
                    pstmt = conn.prepareStatement(sQuery) ;
                    pstmt.setString(1,paraname) ;
                    rs = pstmt.executeQuery() ;
                    if(rs.next()) {
                            //System.out.println(paraname +" : "+rs.getString(1));
                            String retstr = rs.getString(1) ;
                            pstmt.close() ;
                            disconnectDatabase(conn);
                            return retstr ;
                    } else {
                            pstmt.close() ;
                            disconnectDatabase(conn);
                            return null;
                    }
            } catch (Exception ex) {
                    System.out.println("Read TEST Para "+paraname+" :"+ex);

                    disconnectDatabase(conn);
        return null;
            }
}

        /**
         * 建立与数据库的连接
         * @param Conn1orConn2
         * @return Connection
         */
	public static Connection connectDatabase(String db_url,String db_user,String db_passwd) {
	    Connection	dbc = null;
                 // System.out.println("CONNECTION_URL"+PublicConstants.CONNECTION_URL);
                 // System.out.println("DB_USER"+PublicConstants.DB_USER);
                 // System.out.println("DB_PASS"+PublicConstants.DB_PASS);
                  try {
                          Class.forName(PublicConstants.DB_DRIVER).newInstance();
                          DriverManager.setLoginTimeout(5) ;
                          dbc = DriverManager.getConnection(db_url,
                                                            db_user, db_passwd);
                          //System.out.println("Connect DB "+db_url+"OK!");
                          return dbc ;
                  } catch (ClassNotFoundException cnfe) {
                        System.out.println(db_url+" Not Found Oracle Driver: "+cnfe);

                        return null;
                  }
                  catch (Exception e) {
                        System.out.println(db_url+" Connect Oracle: "+e);
                        return null;
                  }
	}

        /**
         * 断开与数据库之间的连接
         * @param conn
         */
	public static void disconnectDatabase(Connection conn) {
		if(conn == null)
			return ;
		try {
			conn.close();
		} catch (SQLException sqle) {
			// method.error("Database disconnecting failed") ;
		}
	}

	public static boolean isConnectDB(Connection dbc) {
		if(dbc == null )
			return false;

		ResultSet rs = null;
		String query = "select 1 from dual ";
		try {
			Statement stmt = dbc.createStatement();
			rs = stmt.executeQuery(query);
		} catch(SQLException e) {
			return false;
		}
		return true;
	}

       public static  DatabaseAccess X2spDB;
}