connectdb.java

J2ee开发的 人事管理系统 使用oracle数据库 myeclips平台开发

package com.galaxy.db;

/*import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;

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

import java.sql.*;

import javax.naming.*;
import javax.sql.*;


public class ConnectDB {

	/**
	 * @param args
	 */
	public Statement dbStatement = null;
	public ResultSet dbResultSet = null;
	protected Connection dbConnection = null;
	private String connStyle = "jndi";	
	
	public void openDBConnection()
	{
		try {
			if("jdbc".equals(connStyle))
			{
				Class.forName("oracle.jdbc.driver.OracleDriver");
				dbConnection = DriverManager.getConnection(
						"jdbc:oracle:thin: @10.0.6.15:1521:icss",
						"GALAXY","manager1");
				dbStatement = dbConnection.createStatement();
			}
			else if("jndi".equals(connStyle))
			{
				Context context = new InitialContext();
				DataSource dataSource  = (DataSource)context.lookup("java:comp/env/jdbc/oracle");
				
				dbConnection = dataSource.getConnection();
				dbStatement = dbConnection.createStatement();
			}
		} 
		catch (ClassNotFoundException e) {
			e.printStackTrace();	
		}catch (SQLException e) {
			e.printStackTrace();		
		} catch (NamingException e) {
			e.printStackTrace();
		}
		
	}
	
	public void closeDBConnection()
	{
		if(dbResultSet != null)
		{
			try {
				dbResultSet.close();
			} catch (SQLException e) {				
				e.printStackTrace();
			}
		}
		if(dbStatement != null)
		{
			try {
				dbStatement.close();
			} catch (SQLException e) {				
				e.printStackTrace();
			}
		}
		try {
			if(dbConnection != null && !dbConnection.isClosed())
			{
				dbConnection.close();
			}
		} catch (SQLException e) {			
			e.printStackTrace();
		}
	}
	public static void main(String[] args) {
	// TODO Auto-generated method stub
		ConnectDB cdb = new ConnectDB();
		cdb.openDBConnection();
		System.out.println("statement="+cdb.dbStatement);
		cdb.closeDBConnection();
	
	}

}