db2.java

呼叫中心自助语声音

package com.bean;

import java.sql.Connection;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.sql.Timestamp;
import java.util.Properties;

import javax.sql.DataSource;
import org.apache.commons.pool.ObjectPool;
import org.apache.commons.pool.impl.GenericObjectPool;
import org.apache.commons.dbcp.ConnectionFactory;
import org.apache.commons.dbcp.PoolingDataSource;
import org.apache.commons.dbcp.PoolableConnectionFactory;
import org.apache.commons.dbcp.DriverManagerConnectionFactory;
import javax.sql.DataSource;
import java.io.*;

public class DB2 {  
	private  Connection conn = null;
    private   Statement stmt = null;    
    private   DataSource gDataSource = null;
    private   String gPathConfig    = "";    
    private   String gPath = "";
    private   ResultSet rs = null;
    private   String gErrorMessage = "";
    public DB2(String path)
    {    	
    	gPath  =  path;
    	 try {
             Class.forName("oracle.jdbc.driver.OracleDriver");
             gDataSource = setupDataSource("jdbc:oracle:thin:"+getAttribute("User")+"/"+getAttribute("Password")+"@"+getAttribute("Service"));
         } catch (ClassNotFoundException e) {
             e.printStackTrace();
         }
    }   
    public void setErrorMsg(String msg)
    {
    	this.gErrorMessage  =  msg ;
    }
    public String getErrorMsg()
    {
    	return this.gErrorMessage;
    }
    public  boolean executeUpdate(String sql)
    {
    	try {
            conn = gDataSource.getConnection();
            stmt = conn.createStatement();
            stmt.executeUpdate(sql);                
            return true;
        } catch(SQLException e) {        	
            e.printStackTrace();
            setErrorMsg(e.getMessage());
            return false;
        }
    }
    public ResultSet executeQuery(String sql)
    {
    	try {    		
            conn = gDataSource.getConnection();            
            stmt = conn.createStatement();
            rs   = stmt.executeQuery(sql);  
            return rs;           
        } 
    	catch(SQLException e) {        	
            e.printStackTrace();
            return null; 
        }	
    	
    }
    public void close()
    {
    	try
    	{
    	if (stmt != null)
    		stmt.close();
    	}
    	catch(Exception e) {}

    	try
    	{
    	if (conn != null)
    	conn.close();
    	}
    	catch (Exception e){}
    	try
    	{
    	if (rs != null)
    	conn.close();
    	}
    	catch (Exception e){}
    }
    public  DataSource setupDataSource(String connectURI) {
        ObjectPool connectionPool = new GenericObjectPool(null);
        ConnectionFactory connectionFactory = new DriverManagerConnectionFactory(connectURI,null);
        PoolableConnectionFactory poolableConnectionFactory = new PoolableConnectionFactory(connectionFactory,connectionPool,null,null,false,true);
        PoolingDataSource dataSource = new PoolingDataSource(connectionPool);
        return dataSource;
    }
    public   String formatTime(String time) {
		return ( time == null || time.length() < 14) ? "null" : "TO_TIMESTAMP( '" + time.trim() + "','YYYYMMDDHH24MISS.FF')";
	}
	public   Timestamp formateTimeStamp(long time)
	{
		Timestamp timestamp = new Timestamp(time);		
		return timestamp;
		
	}
	public   String isNull(String str) {
		return ( str == null || str.length() == 0 || str.equals("null")) ? "''" : "'"+str.trim()+"'";
	}
	public  int isNumNull(String number) {		
		try{
			return  (number == null || number.length() == 0 || number.equals("null")) ? 0 : Integer.valueOf(number).intValue();			
		}catch(Exception ex)
		{
			return 0;
		}			
	}
	public  float isNumLongNull(String number) {
		float temp = 0;
		try{
			  return (number == null || number.length() == 0 || number.equals("null")) ? 0  : Float.valueOf(number).floatValue();
		}catch(Exception ex)
		{
			return 0 ;
		}		
	}
	public String getAttribute(String name)
	{   
	    
	    Properties pt = null; 
	    String attri  = "";  
	    try{                
	        File      file  = new File(gPath);	        
	        InputStream is  = new FileInputStream(file);
	        pt              = new Properties();
	        pt.load(is);                            
	        attri           = pt.getProperty(name).trim();          
	        is.close();
	    }catch(Exception ex){
	    	System.out.println("Parameter "+name+" not exist in config file,check out your config files make sure the specify parameter exisit in it!");
	    	ex.printStackTrace();
	    }
	    return  attri;
	}	
//	public static void main(String[] args)
//	{
//		DB2 db = new DB2("WebRoot/sys.properties");
//		ResultSet rs = db.executeQuery("SELECT COUNT(*) FROM TB_CHANNEL_MONITOR");
//		try 
//		{
//			System.out.println("Out:"+rs.getRow());
//		} 
//		catch (SQLException e) 
//		{
//			e.printStackTrace();
//		}		
//	}
}