Metacat

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.ResultSetMetaData;

import java.sql.SQLException;

import java.sql.Statement;

import java.util.HashMap;

import java.util.Hashtable;

import java.util.Vector;

import org.apache.commons.httpclient.HttpClient;

import edu.ucsb.nceas.metacat.DBConnection;

import edu.ucsb.nceas.metacat.DBConnectionPool;

import edu.ucsb.nceas.metacat.util.RequestUtil;

	protected static HttpClient httpClient = null;

	protected static Vector<Hashtable<String, Object>> dbSelect(String sqlStatement,

			String methodName) throws SQLException {

		Vector<Hashtable<String, Object>> resultVector = new Vector<Hashtable<String, Object>>();

		DBConnectionPool connPool = DBConnectionPool.getInstance();

		DBConnection dbconn = DBConnectionPool.getDBConnection(methodName);

		int serialNumber = dbconn.getCheckOutSerialNumber();

		PreparedStatement pstmt = null;

		debug("Selecting from db: " + sqlStatement);

		pstmt = dbconn.prepareStatement(sqlStatement);

		pstmt.execute();

		ResultSet resultSet = pstmt.getResultSet();

		ResultSetMetaData rsMetaData = resultSet.getMetaData();

		int numColumns = rsMetaData.getColumnCount();

		debug("Number of data columns: " + numColumns);

		while (resultSet.next()) {

			Hashtable<String, Object> hashTable = new Hashtable<String, Object>();

			for (int i = 1; i <= numColumns; i++) {

				if (resultSet.getObject(i) != null) {

					hashTable.put(rsMetaData.getColumnName(i), resultSet.getObject(i));

				}

			}

			debug("adding data row to result vector");

			resultVector.add(hashTable);

		}

		resultSet.close();

		pstmt.close();

		DBConnectionPool.returnDBConnection(dbconn, serialNumber);

		return resultVector;

	}

	protected static void dbQuery(String sqlStatement, String methodName)

			throws SQLException {

		DBConnectionPool connPool = DBConnectionPool.getInstance();

		DBConnection dbconn = DBConnectionPool.getDBConnection(methodName);

		int serialNumber = dbconn.getCheckOutSerialNumber();

		Statement statement = dbconn.createStatement();

		debug("Executing against db: " + sqlStatement);

		statement.executeQuery(sqlStatement);

		statement.close();

		DBConnectionPool.returnDBConnection(dbconn, serialNumber);

	}

	protected static void dbUpdate(String sqlStatement, String methodName)

			throws SQLException {

		DBConnectionPool connPool = DBConnectionPool.getInstance();

		DBConnection dbconn = DBConnectionPool.getDBConnection(methodName);

		int serialNumber = dbconn.getCheckOutSerialNumber();

		Statement statement = dbconn.createStatement();

		debug("Executing against db: " + sqlStatement);

		statement.executeUpdate(sqlStatement);

		statement.close();

		DBConnectionPool.returnDBConnection(dbconn, serialNumber);

	}

	protected static void httpPost(String url, HashMap<String,String> paramMap)  throws IOException {

		debug("Posting to: " + url);

		if (httpClient == null) {

			httpClient = new HttpClient();

		}

		String postResponse = RequestUtil.post(httpClient, url, paramMap);

		debug("Post response: " + postResponse);

		if (postResponse.contains("<error>")) {

			fail("Error posting to metacat: " + postResponse);

		}

	}

	protected static void resetHttpClient() {

		httpClient = null;

	}