/*
 * Created on 2006-6-18
 *
 * To change the template for this generated file go to
 * Window>Preferences>Java>Code Generation>Code and Comments
 */
package com.ahbay.commenMgr;

import com.ahbay.DataBaseMgr.*;
import java.sql.*;
import java.util.*;
import java.io.*;
/**
 * @author: Wangrc
 * @Date: 2006-6-18 20:49:14
 * @Method Name: 
 */
public class InterfDataBaseCommMgr 
{
	public InterfDataBaseCommMgr(){}
	private String strQuery;
	private Connection ConnectionHandle;
	/** 
	 * Returns the rsrv_str4.
	 * @return String
	 */
	public String getStrQuery()
	{
		return strQuery;
	}
	/** 
	 * Set the rsrv_str4.
	 * @param rsrv_str4 The rsrv_str4 to set
	 */
	public void setStrQuery(String strQuery)
	{
		this.strQuery = strQuery;
	}	
	
	
	/**
	 * 
	 * @author: Wangrc
	 * @Date: 2006-6-18 20:44:46
	 * @Method Name: ExecInsert
	 */
	public String ExecBizQuery()
	{
		this.ConnectionHandle=null; 
		InterfDataBaseConn ThisConn=new InterfDataBaseConn();
		this.ConnectionHandle =ThisConn.GetConnection();	
		Statement stm;	
		try
		{			 
			stm=this.ConnectionHandle.createStatement();
			stm.executeUpdate(this.strQuery);
			this.ConnectionHandle.commit();			 
		}
		catch (SQLException e)
		{		
			return e.getMessage()+"||"+this.strQuery;		
		}
		catch (Exception e)
		{		
			return e.getMessage()+"||"+this.strQuery;		
		}
		CloseConn();			
		return "1";
	}
	/**
	 * @author: 王仁超
	 * @Date: 2005-7-13
	 * @Method Name: CloseConn
	 */
	public void CloseConn()
	{
		try
		{
			this.ConnectionHandle.close();
		}
		catch (SQLException e)
		{	
			System.out.println("SQLERROR:"+e.getMessage());		
		}
	}
	/**
	 * 
	 * @author: Wangrc
	 * @Date: 2006-6-18 20:44:46
	 * @Method Name: SelBizQuery
	 */
	public ArrayList SelBizQuery()
	{
		this.ConnectionHandle=null; 
		InterfDataBaseConn ThisConn=new InterfDataBaseConn();
		this.ConnectionHandle =ThisConn.getInterfConnection();	
		Statement stm;
		ResultSet rst = null;	
		ResultSetMetaData  rstMetaDate = null;	
		ArrayList dataArray = new ArrayList();
		int columnCount = 0;
		try
		{			 
			stm = this.ConnectionHandle.createStatement();
			rst = stm.executeQuery(this.strQuery);
			rstMetaDate = rst.getMetaData();
			columnCount = rstMetaDate.getColumnCount();		 
		}
		catch (SQLException e)
		{		
			System.out.println("SQLERROR:"+e.getMessage());		
		}
		try
		{
			while (rst.next())
			{	
				HashMap row = new HashMap();
		        for (int i = 1; i <= columnCount; i++) 
		        {
		          String strFieldName = rstMetaDate.getColumnName(i).toLowerCase();
		         
		          if (rstMetaDate.getColumnTypeName(i) == "VARCHAR2" || rstMetaDate.getColumnTypeName(i) == "CHAR"
		        	  || rstMetaDate.getColumnTypeName(i) == "DATE")
		          {		        	 
		        	  if (rst.getObject(i) != null) 
		        	  {
		        		  row.put(strFieldName, rst.getObject(i).toString());
		        	  }
		        	  else
		        	  {
		        		  row.put(strFieldName, rst.getObject(i));
		        	  }		        		  
		          }		          
		          else
		          {
		        	  row.put(strFieldName, rst.getObject(i));
		          }
		        }
				dataArray.add(row);
			}
		}
		catch (SQLException e)
		{
			CloseConn();	
			throw new RuntimeException(e);
		}		
		CloseConn();	
		return dataArray;
	}
	
}