oracleconnection.java

具备多表组合查询组件功能。通过将表字段与表间关系映射到对象关系及属性

package cn.edu.buaa.ieguam.logmanage;

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

import oracle.jdbc.pool.OracleDataSource;

public class OracleConnection implements DBConnection {

	private Connection connection = null;
	private Statement statement = null;
	private ResultSet resultSet = null;
	
/**
	public Connection getConnection() {
		// TODO Auto-generated method stub
		return this.connection;
	}

	public void setConnection(Connection connection) {
		// TODO Auto-generated method stub
        this.connection = connection;
	}

	public Statement getStatement() {
		// TODO Auto-generated method stub
		return this.statement;
	}

	public void setStatement(Statement statement) {
		// TODO Auto-generated method stub
        this.statement = statement;
	}

*/
	public ResultSet getResultSet() {
		// TODO Auto-generated method stub
		return this.resultSet;
	}

	public void setResultSet(ResultSet resultSet) {
		// TODO Auto-generated method stub
		this.resultSet = resultSet;

	}

	public void connect() throws Exception {
		// TODO Auto-generated method stub
		Connection con = null;
				
		String connString = "jdbc:oracle:thin:@192.1.0.199:1521:iegora";
		OracleDataSource ods = new OracleDataSource();
		ods.setURL(connString);
		ods.setUser("ieguam");
		ods.setPassword("7541");	
		con = ods.getConnection();		
		this.connection = con;
		this.statement = this.connection.createStatement();
		this.statement = this.connection.createStatement();
		
	}

	public void closeConnec() throws SQLException
	{
		this.connection.close();
	}
	
	public void executeQuery(String querySql) throws Exception {
		// TODO Auto-generated method stub
		/***************************************/
		//System.out.println("********  test 1 ****");
		/****************************************/
		
		ResultSet rst = this.statement.executeQuery(querySql);
		
		/***************************************/
		//System.out.println("********  test 2 ****");
		/****************************************/		
		this.resultSet = rst;
		
		

	}

	public int executeInsert(String insertSql) throws Exception {
		// TODO Auto-generated method stub
		int result = 0;		
		result = this.statement.executeUpdate(insertSql);	
		return result;

	}

	public int executeDelete(String deleteSql) throws Exception {
		// TODO Auto-generated method stub
		return 0;

	}

	public int executeUpdate(String updateSql) throws Exception {
		// TODO Auto-generated method stub
		return 0;

	}
	
	public static void main(String[] args) throws Exception
	{
		OracleConnection sqlServer = new OracleConnection();
		ResultSet rst = null;
		String usr = null;
		int num = 0;
		sqlServer.connect();
		sqlServer.executeQuery("select main.id,main.usr,logType.id from main,logType;");	
		rst = sqlServer.getResultSet();
		if(rst != null)
		{
			while(rst.next())
			{
								
				usr = rst.getString("usr");
				System.out.println("usr : " + usr);
				
				String logTypeId = rst.getString(3);
				System.out.println("logType id : "+logTypeId);
			
			}
		}
		sqlServer.closeConnec();
		
	}

}