resultsetwrappingsqlrowset.java

spring的源代码

/*
 * Copyright 2002-2005 the original author or authors.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *      http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

package org.springframework.jdbc.support.rowset;

import java.math.BigDecimal;
import java.sql.Date;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Time;
import java.sql.Timestamp;
import java.util.Calendar;
import java.util.Map;

import org.springframework.jdbc.InvalidResultSetAccessException;

/**
 * Default implementation of Spring's SqlRowSet interface.
 *
 * <p>This implementation wraps a <code>javax.sql.ResultSet</code>,
 * catching any SQLExceptions and translating them to the
 * appropriate Spring DataAccessException.
 *
 * <p>The passed-in ResultSets should already be disconnected if the
 * SqlRowSet is supposed to be usable in a disconnected fashion.
 * This means that you will usually pass in a
 * <code>javax.sql.rowset.CachedRowSet</code>,
 * which implements the ResultSet interface.
 *
 * <p>Note: This class implements the <code>java.io.Serializable</code>
 * marker interface through the SqlRowSet interface, but is only actually
 * serializable if the disconnected ResultSet/RowSet contained in it is
 * serializable. Most CachedRowSet implementations are serializable.
 *
 * @author Thomas Risberg
 * @author Juergen Hoeller
 * @since 1.2
 * @see java.sql.ResultSet
 * @see javax.sql.rowset.CachedRowSet
 */
public class ResultSetWrappingSqlRowSet implements SqlRowSet {

	private final ResultSet resultSet;

	private final SqlRowSetMetaData rowSetMetaData;


	/**
	 * Create a new ResultSetWrappingSqlRowSet for the given ResultSet.
	 * @param resultSet a disconnected ResultSet to wrap
	 * (usually a <code>javax.sql.rowset.CachedRowSet</code>)
	 * @throws InvalidResultSetAccessException if extracting
	 * the ResultSetMetaData failed
	 * @see javax.sql.rowset.CachedRowSet
	 * @see java.sql.ResultSet#getMetaData
	 * @see ResultSetWrappingSqlRowSetMetaData
	 */
	public ResultSetWrappingSqlRowSet(ResultSet resultSet) throws InvalidResultSetAccessException {
		this.resultSet = resultSet;
		try {
			this.rowSetMetaData = new ResultSetWrappingSqlRowSetMetaData(resultSet.getMetaData());
		}
		catch (SQLException se) {
			throw new InvalidResultSetAccessException(se);
		}
	}
	
	/**
	 * Return the underlying ResultSet
	 * (usually a <code>javax.sql.rowset.CachedRowSet</code>).
	 * @see javax.sql.rowset.CachedRowSet
	 */
	public ResultSet getResultSet() {
		return this.resultSet;
	}

	/**
	 * @see java.sql.ResultSetMetaData#getCatalogName(int)
	 */
	public SqlRowSetMetaData getMetaData() {
		return this.rowSetMetaData;
	}
	
	/**
	 * @see java.sql.ResultSet#findColumn(String)
	 */
	public int findColumn(String columnName) throws InvalidResultSetAccessException {
		try {
			return this.resultSet.findColumn(columnName);
		}
		catch (SQLException se) {
			throw new InvalidResultSetAccessException(se);
		}
	}


	// RowSet methods for extracting data values

	/**
	 * @see java.sql.ResultSet#getBigDecimal(int)
	 */
	public BigDecimal getBigDecimal(int columnIndex) throws InvalidResultSetAccessException {
		try {
			return this.resultSet.getBigDecimal(columnIndex);
		}
		catch (SQLException se) {
			throw new InvalidResultSetAccessException(se);
		}
	}
	
	/**
	 * @see java.sql.ResultSet#getBigDecimal(String)
	 */
	public BigDecimal getBigDecimal(String columnName) throws InvalidResultSetAccessException {
		try {
			return this.resultSet.getBigDecimal(columnName);
		}
		catch (SQLException se) {
			throw new InvalidResultSetAccessException(se);
		}
	}

	/**
	 * @see java.sql.ResultSet#getBoolean(int)
	 */
	public boolean getBoolean(int columnIndex) throws InvalidResultSetAccessException {
		try {
			return this.resultSet.getBoolean(columnIndex);
		}
		catch (SQLException se) {
			throw new InvalidResultSetAccessException(se);
		}
	}

	/**
	 * @see java.sql.ResultSet#getBoolean(String)
	 */
	public boolean getBoolean(String columnName) throws InvalidResultSetAccessException {
		try {
			return this.resultSet.getBoolean(columnName);
		}
		catch (SQLException se) {
			throw new InvalidResultSetAccessException(se);
		}
	}
	
	/**
	 * @see java.sql.ResultSet#getByte(int)
	 */
	public byte getByte(int columnIndex) throws InvalidResultSetAccessException {
		try {
			return this.resultSet.getByte(columnIndex);
		}
		catch (SQLException se) {
			throw new InvalidResultSetAccessException(se);
		}
	}
	
	/**
	 * @see java.sql.ResultSet#getByte(String)
	 */
	public byte getByte(String columnName) throws InvalidResultSetAccessException {
		try {
			return this.resultSet.getByte(columnName);
		}
		catch (SQLException se) {
			throw new InvalidResultSetAccessException(se);
		}
	}
	
	/**
	 * @see java.sql.ResultSet#getDate(int, java.util.Calendar)
	 */
	public Date getDate(int columnIndex, Calendar cal) throws InvalidResultSetAccessException {
		try {
			return this.resultSet.getDate(columnIndex, cal);
		}
		catch (SQLException se) {
			throw new InvalidResultSetAccessException(se);
		}
	}
	
	/**
	 * @see java.sql.ResultSet#getDate(int)
	 */
	public Date getDate(int columnIndex) throws InvalidResultSetAccessException {
		try {
			return this.resultSet.getDate(columnIndex);
		}
		catch (SQLException se) {
			throw new InvalidResultSetAccessException(se);
		}
	}
	/**
	 * @see java.sql.ResultSet#getDate(String, java.util.Calendar)
	 */
	public Date getDate(String columnName, Calendar cal) throws InvalidResultSetAccessException {
		try {
			return this.resultSet.getDate(columnName, cal);
		}
		catch (SQLException se) {
			throw new InvalidResultSetAccessException(se);
		}
	}
	
	/**
	 * @see java.sql.ResultSet#getDate(String)
	 */
	public Date getDate(String columnName) throws InvalidResultSetAccessException {
		try {
			return this.resultSet.getDate(columnName);
		}
		catch (SQLException se) {
			throw new InvalidResultSetAccessException(se);
		}
	}
	
	/**
	 * @see java.sql.ResultSet#getDouble(int)
	 */
	public double getDouble(int columnIndex) throws InvalidResultSetAccessException {
		try {
			return this.resultSet.getDouble(columnIndex);
		}
		catch (SQLException se) {
			throw new InvalidResultSetAccessException(se);
		}
	}
	
	/**
	 * @see java.sql.ResultSet#getDouble(String)
	 */
	public double getDouble(String columnName) throws InvalidResultSetAccessException {
		try {
			return this.resultSet.getDouble(columnName);
		}
		catch (SQLException se) {
			throw new InvalidResultSetAccessException(se);
		}
	}
	
	/**
	 * @see java.sql.ResultSet#getFloat(int)
	 */
	public float getFloat(int columnIndex) throws InvalidResultSetAccessException {
		try {
			return this.resultSet.getFloat(columnIndex);
		}
		catch (SQLException se) {
			throw new InvalidResultSetAccessException(se);
		}
	}

	/**
	 * @see java.sql.ResultSet#getFloat(String)
	 */
	public float getFloat(String columnName) throws InvalidResultSetAccessException {
		try {
			return this.resultSet.getFloat(columnName);
		}
		catch (SQLException se) {
			throw new InvalidResultSetAccessException(se);
		}
	}
	/**
	 * @see java.sql.ResultSet#getInt(int)
	 */
	public int getInt(int columnIndex) throws InvalidResultSetAccessException {
		try {
			return this.resultSet.getInt(columnIndex);
		}
		catch (SQLException se) {
			throw new InvalidResultSetAccessException(se);
		}
	}

	/**
	 * @see java.sql.ResultSet#getInt(String)
	 */
	public int getInt(String columnName) throws InvalidResultSetAccessException {
		try {
			return this.resultSet.getInt(columnName);
		}
		catch (SQLException se) {
			throw new InvalidResultSetAccessException(se);
		}
	}
	
	/**
	 * @see java.sql.ResultSet#getLong(int)
	 */
	public long getLong(int columnIndex) throws InvalidResultSetAccessException {
		try {
			return this.resultSet.getLong(columnIndex);
		}
		catch (SQLException se) {
			throw new InvalidResultSetAccessException(se);
		}
	}
	
	/**
	 * @see java.sql.ResultSet#getLong(String)
	 */
	public long getLong(String columnName) throws InvalidResultSetAccessException {
		try {
			return this.resultSet.getLong(columnName);
		}
		catch (SQLException se) {
			throw new InvalidResultSetAccessException(se);
		}
	}
	
	/**
	 * @see java.sql.ResultSet#getObject(int, java.util.Map)
	 */
	public Object getObject(int i, Map map) throws InvalidResultSetAccessException {
		try {
			return this.resultSet.getObject(i, map);
		}
		catch (SQLException se) {
			throw new InvalidResultSetAccessException(se);
		}
	}
	
	/**
	 * @see java.sql.ResultSet#getObject(int)
	 */
	public Object getObject(int columnIndex) throws InvalidResultSetAccessException {
		try {
			return this.resultSet.getObject(columnIndex);
		}
		catch (SQLException se) {
			throw new InvalidResultSetAccessException(se);