Class PgResultSet
- java.lang.Object
-
- org.postgresql.jdbc.PgResultSet
-
- All Implemented Interfaces:
AutoCloseable,ResultSet,Wrapper,PGRefCursorResultSet
public class PgResultSet extends Object implements ResultSet, PGRefCursorResultSet
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description classPgResultSet.CursorResultHandler
-
Field Summary
Fields Modifier and Type Field Description protected BaseConnectionconnectionprotected intcurrentRowprotected ResultCursorcursorprotected intfetchSizeprotected Field[]fieldsprotected intmaxFieldSizeprotected intmaxRowsprotected booleanonInsertRowprotected QueryoriginalQueryprotected introwOffsetprotected List<Tuple>rowsprotected BaseStatementstatementprotected TuplethisRowprotected SQLWarningwarningsprotected booleanwasNullFlagTrue if the last obtained column value was SQL NULL as specified bywasNull().-
Fields inherited from interface java.sql.ResultSet
CLOSE_CURSORS_AT_COMMIT, CONCUR_READ_ONLY, CONCUR_UPDATABLE, FETCH_FORWARD, FETCH_REVERSE, FETCH_UNKNOWN, HOLD_CURSORS_OVER_COMMIT, TYPE_FORWARD_ONLY, TYPE_SCROLL_INSENSITIVE, TYPE_SCROLL_SENSITIVE
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description booleanabsolute(int index)protected voidaddWarning(SQLWarning warnings)voidafterLast()voidbeforeFirst()voidcancelRowUpdates()protected voidcheckClosed()protected voidcheckColumnIndex(int column)voidclearWarnings()voidclose()protected voidcloseInternally()static Map<String,Integer>createColumnNameIndexMap(Field[] fields, boolean isSanitiserDisabled)protected ResultSetMetaDatacreateMetaData()voiddeleteRow()intfindColumn(String columnName)booleanfirst()ArraygetArray(int i)ArraygetArray(String colName)InputStreamgetAsciiStream(int columnIndex)InputStreamgetAsciiStream(String columnName)BigDecimalgetBigDecimal(int columnIndex)BigDecimalgetBigDecimal(int columnIndex, int scale)BigDecimalgetBigDecimal(String columnName)BigDecimalgetBigDecimal(String columnName, int scale)InputStreamgetBinaryStream(int columnIndex)InputStreamgetBinaryStream(String columnName)BlobgetBlob(int i)BlobgetBlob(String columnName)booleangetBoolean(int columnIndex)Retrieves the value of the designated column in the current row of thisResultSetobject as abooleanin the Java programming language.booleangetBoolean(String columnName)bytegetByte(int columnIndex)bytegetByte(String columnName)byte[]getBytes(int columnIndex)byte[]getBytes(String columnName)ReadergetCharacterStream(int i)ReadergetCharacterStream(String columnName)ClobgetClob(int i)ClobgetClob(String columnName)intgetColumnOID(int field)Returns the OID of a field.intgetConcurrency()StringgetCursorName()DategetDate(int columnIndex)DategetDate(int i, Calendar cal)DategetDate(String columnName)DategetDate(String c, Calendar cal)doublegetDouble(int columnIndex)doublegetDouble(String columnName)intgetFetchDirection()intgetFetchSize()StringgetFixedString(int col)This is used to fix get*() methods on Money fields.floatgetFloat(int columnIndex)floatgetFloat(String columnName)intgetHoldability()intgetInt(int columnIndex)intgetInt(String columnName)longgetLong(int columnIndex)longgetLong(String columnName)ResultSetMetaDatagetMetaData()ReadergetNCharacterStream(int columnIndex)ReadergetNCharacterStream(String columnName)NClobgetNClob(int columnIndex)NClobgetNClob(String columnName)StringgetNString(int columnIndex)StringgetNString(String columnName)ObjectgetObject(int columnIndex)<T> TgetObject(int columnIndex, Class<T> type)ObjectgetObject(int i, Map<String,Class<?>> map)ObjectgetObject(String columnName)<T> TgetObject(String columnLabel, Class<T> type)ObjectgetObject(String s, Map<String,Class<?>> map)ObjectgetObjectImpl(int i, Map<String,Class<?>> map)ObjectgetObjectImpl(String columnName, Map<String,Class<?>> map)BaseStatementgetPGStatement()protected StringgetPGType(int column)protected byte[]getRawValue(int column)Checks that the result set is not closed, it's positioned on a valid row and that the given column number is valid.RefgetRef(int i)RefgetRef(String columnName)StringgetRefCursor()intgetRow()RowIdgetRowId(int columnIndex)RowIdgetRowId(String columnName)shortgetShort(int columnIndex)shortgetShort(String columnName)protected intgetSQLType(int column)SQLXMLgetSQLXML(int columnIndex)SQLXMLgetSQLXML(String columnName)StatementgetStatement()StringgetString(int columnIndex)StringgetString(String columnName)TimegetTime(int columnIndex)TimegetTime(int i, Calendar cal)TimegetTime(String columnName)TimegetTime(String c, Calendar cal)TimestampgetTimestamp(int columnIndex)TimestampgetTimestamp(int i, Calendar cal)TimestampgetTimestamp(String columnName)TimestampgetTimestamp(String c, Calendar cal)intgetType()InputStreamgetUnicodeStream(int columnIndex)InputStreamgetUnicodeStream(String columnName)URLgetURL(int columnIndex)URLgetURL(String columnName)protected ObjectgetUUID(byte[] data)protected ObjectgetUUID(String data)SQLWarninggetWarnings()voidinsertRow()protected ObjectinternalGetObject(int columnIndex, Field field)booleanisAfterLast()booleanisBeforeFirst()protected booleanisBinary(int column)Returns true if the value of the given column is in binary format.booleanisClosed()booleanisFirst()booleanisLast()protected booleanisResultSetClosed()booleanisWrapperFor(Class<?> iface)booleanlast()protected ArraymakeArray(int oid, byte[] value)protected ArraymakeArray(int oid, String value)protected BlobmakeBlob(long oid)protected ClobmakeClob(long oid)voidmoveToCurrentRow()voidmoveToInsertRow()booleannext()booleanprevious()static String[]quotelessTableName(String fullname)Cracks out the table name and schema (if it exists) from a fully qualified table name.voidrefreshRow()booleanrelative(int rows)booleanrowDeleted()booleanrowInserted()booleanrowUpdated()voidsetFetchDirection(int direction)voidsetFetchSize(int rows)static BigDecimaltoBigDecimal(String s)BigDecimaltoBigDecimal(String s, int scale)static doubletoDouble(String s)static floattoFloat(String s)static inttoInt(String s)static longtoLong(String s)static shorttoShort(String s)<T> Tunwrap(Class<T> iface)voidupdateArray(int columnIndex, Array x)voidupdateArray(String columnName, Array x)voidupdateAsciiStream(int columnIndex, InputStream inputStream)voidupdateAsciiStream(int columnIndex, InputStream x, int length)voidupdateAsciiStream(int columnIndex, InputStream inputStream, long length)voidupdateAsciiStream(String columnName, InputStream inputStream)voidupdateAsciiStream(String columnName, InputStream x, int length)voidupdateAsciiStream(String columnName, InputStream inputStream, long length)voidupdateBigDecimal(int columnIndex, BigDecimal x)voidupdateBigDecimal(String columnName, BigDecimal x)voidupdateBinaryStream(int columnIndex, InputStream inputStream)voidupdateBinaryStream(int columnIndex, InputStream x, int length)voidupdateBinaryStream(int columnIndex, InputStream inputStream, long length)voidupdateBinaryStream(String columnName, InputStream inputStream)voidupdateBinaryStream(String columnName, InputStream x, int length)voidupdateBinaryStream(String columnName, InputStream inputStream, long length)voidupdateBlob(int columnIndex, InputStream inputStream)voidupdateBlob(int columnIndex, InputStream inputStream, long length)voidupdateBlob(int columnIndex, Blob x)voidupdateBlob(String columnName, InputStream inputStream)voidupdateBlob(String columnName, InputStream inputStream, long length)voidupdateBlob(String columnName, Blob x)voidupdateBoolean(int columnIndex, boolean x)voidupdateBoolean(String columnName, boolean x)voidupdateByte(int columnIndex, byte x)voidupdateByte(String columnName, byte x)voidupdateBytes(int columnIndex, byte[] x)voidupdateBytes(String columnName, byte[] x)voidupdateCharacterStream(int columnIndex, Reader reader)voidupdateCharacterStream(int columnIndex, Reader x, int length)voidupdateCharacterStream(int columnIndex, Reader reader, long length)voidupdateCharacterStream(String columnName, Reader reader)voidupdateCharacterStream(String columnName, Reader reader, int length)voidupdateCharacterStream(String columnName, Reader reader, long length)voidupdateClob(int columnIndex, Reader reader)voidupdateClob(int columnIndex, Reader reader, long length)voidupdateClob(int columnIndex, Clob x)voidupdateClob(String columnName, Reader reader)voidupdateClob(String columnName, Reader reader, long length)voidupdateClob(String columnName, Clob x)voidupdateDate(int columnIndex, Date x)voidupdateDate(String columnName, Date x)voidupdateDouble(int columnIndex, double x)voidupdateDouble(String columnName, double x)voidupdateFloat(int columnIndex, float x)voidupdateFloat(String columnName, float x)voidupdateInt(int columnIndex, int x)voidupdateInt(String columnName, int x)voidupdateLong(int columnIndex, long x)voidupdateLong(String columnName, long x)voidupdateNCharacterStream(int columnIndex, Reader x)voidupdateNCharacterStream(int columnIndex, Reader x, int length)voidupdateNCharacterStream(int columnIndex, Reader x, long length)voidupdateNCharacterStream(String columnName, Reader x)voidupdateNCharacterStream(String columnName, Reader x, int length)voidupdateNCharacterStream(String columnName, Reader x, long length)voidupdateNClob(int columnIndex, Reader reader)voidupdateNClob(int columnIndex, Reader reader, long length)voidupdateNClob(int columnIndex, NClob nClob)voidupdateNClob(String columnName, Reader reader)voidupdateNClob(String columnName, Reader reader, long length)voidupdateNClob(String columnName, NClob nClob)voidupdateNString(int columnIndex, String nString)voidupdateNString(String columnName, String nString)voidupdateNull(int columnIndex)voidupdateNull(String columnName)voidupdateObject(int columnIndex, Object x)voidupdateObject(int columnIndex, Object x, int scale)voidupdateObject(int columnIndex, Object x, SQLType targetSqlType)voidupdateObject(int columnIndex, Object x, SQLType targetSqlType, int scaleOrLength)voidupdateObject(String columnName, Object x)voidupdateObject(String columnName, Object x, int scale)voidupdateObject(String columnLabel, Object x, SQLType targetSqlType)voidupdateObject(String columnLabel, Object x, SQLType targetSqlType, int scaleOrLength)voidupdateRef(int columnIndex, Ref x)voidupdateRef(String columnName, Ref x)voidupdateRow()voidupdateRowId(int columnIndex, RowId x)voidupdateRowId(String columnName, RowId x)voidupdateShort(int columnIndex, short x)voidupdateShort(String columnName, short x)voidupdateSQLXML(int columnIndex, SQLXML xmlObject)voidupdateSQLXML(String columnName, SQLXML xmlObject)voidupdateString(int columnIndex, String x)voidupdateString(String columnName, String x)voidupdateTime(int columnIndex, Time x)voidupdateTime(String columnName, Time x)voidupdateTimestamp(int columnIndex, Timestamp x)voidupdateTimestamp(String columnName, Timestamp x)protected voidupdateValue(int columnIndex, Object value)booleanwasNull()
-
-
-
Field Detail
-
connection
protected final BaseConnection connection
-
statement
protected final BaseStatement statement
-
fields
protected final Field[] fields
-
originalQuery
protected final Query originalQuery
-
maxRows
protected final int maxRows
-
maxFieldSize
protected final int maxFieldSize
-
currentRow
protected int currentRow
-
rowOffset
protected int rowOffset
-
thisRow
protected Tuple thisRow
-
warnings
protected SQLWarning warnings
-
wasNullFlag
protected boolean wasNullFlag
True if the last obtained column value was SQL NULL as specified bywasNull(). The value is always updated by thegetRawValue(int)method.
-
onInsertRow
protected boolean onInsertRow
-
fetchSize
protected int fetchSize
-
cursor
protected ResultCursor cursor
-
-
Method Detail
-
createMetaData
protected ResultSetMetaData createMetaData() throws SQLException
- Throws:
SQLException
-
getMetaData
public ResultSetMetaData getMetaData() throws SQLException
- Specified by:
getMetaDatain interfaceResultSet- Throws:
SQLException
-
getURL
public URL getURL(int columnIndex) throws SQLException
- Specified by:
getURLin interfaceResultSet- Throws:
SQLException
-
getURL
public URL getURL(String columnName) throws SQLException
- Specified by:
getURLin interfaceResultSet- Throws:
SQLException
-
internalGetObject
protected Object internalGetObject(int columnIndex, Field field) throws SQLException
- Throws:
SQLException
-
absolute
public boolean absolute(int index) throws SQLException- Specified by:
absolutein interfaceResultSet- Throws:
SQLException
-
afterLast
public void afterLast() throws SQLException- Specified by:
afterLastin interfaceResultSet- Throws:
SQLException
-
beforeFirst
public void beforeFirst() throws SQLException- Specified by:
beforeFirstin interfaceResultSet- Throws:
SQLException
-
first
public boolean first() throws SQLException- Specified by:
firstin interfaceResultSet- Throws:
SQLException
-
getArray
public Array getArray(String colName) throws SQLException
- Specified by:
getArrayin interfaceResultSet- Throws:
SQLException
-
makeArray
protected Array makeArray(int oid, byte[] value) throws SQLException
- Throws:
SQLException
-
makeArray
protected Array makeArray(int oid, String value) throws SQLException
- Throws:
SQLException
-
getArray
public Array getArray(int i) throws SQLException
- Specified by:
getArrayin interfaceResultSet- Throws:
SQLException
-
getBigDecimal
public BigDecimal getBigDecimal(int columnIndex) throws SQLException
- Specified by:
getBigDecimalin interfaceResultSet- Throws:
SQLException
-
getBigDecimal
public BigDecimal getBigDecimal(String columnName) throws SQLException
- Specified by:
getBigDecimalin interfaceResultSet- Throws:
SQLException
-
getBlob
public Blob getBlob(String columnName) throws SQLException
- Specified by:
getBlobin interfaceResultSet- Throws:
SQLException
-
makeBlob
protected Blob makeBlob(long oid) throws SQLException
- Throws:
SQLException
-
getBlob
public Blob getBlob(int i) throws SQLException
- Specified by:
getBlobin interfaceResultSet- Throws:
SQLException
-
getCharacterStream
public Reader getCharacterStream(String columnName) throws SQLException
- Specified by:
getCharacterStreamin interfaceResultSet- Throws:
SQLException
-
getCharacterStream
public Reader getCharacterStream(int i) throws SQLException
- Specified by:
getCharacterStreamin interfaceResultSet- Throws:
SQLException
-
getClob
public Clob getClob(String columnName) throws SQLException
- Specified by:
getClobin interfaceResultSet- Throws:
SQLException
-
makeClob
protected Clob makeClob(long oid) throws SQLException
- Throws:
SQLException
-
getClob
public Clob getClob(int i) throws SQLException
- Specified by:
getClobin interfaceResultSet- Throws:
SQLException
-
getConcurrency
public int getConcurrency() throws SQLException- Specified by:
getConcurrencyin interfaceResultSet- Throws:
SQLException
-
getDate
public Date getDate(int i, Calendar cal) throws SQLException
- Specified by:
getDatein interfaceResultSet- Throws:
SQLException
-
getTime
public Time getTime(int i, Calendar cal) throws SQLException
- Specified by:
getTimein interfaceResultSet- Throws:
SQLException
-
getTimestamp
public Timestamp getTimestamp(int i, Calendar cal) throws SQLException
- Specified by:
getTimestampin interfaceResultSet- Throws:
SQLException
-
getDate
public Date getDate(String c, Calendar cal) throws SQLException
- Specified by:
getDatein interfaceResultSet- Throws:
SQLException
-
getTime
public Time getTime(String c, Calendar cal) throws SQLException
- Specified by:
getTimein interfaceResultSet- Throws:
SQLException
-
getTimestamp
public Timestamp getTimestamp(String c, Calendar cal) throws SQLException
- Specified by:
getTimestampin interfaceResultSet- Throws:
SQLException
-
getFetchDirection
public int getFetchDirection() throws SQLException- Specified by:
getFetchDirectionin interfaceResultSet- Throws:
SQLException
-
getObjectImpl
public Object getObjectImpl(String columnName, Map<String,Class<?>> map) throws SQLException
- Throws:
SQLException
-
getObjectImpl
public Object getObjectImpl(int i, Map<String,Class<?>> map) throws SQLException
- Throws:
SQLException
-
getRef
public Ref getRef(String columnName) throws SQLException
- Specified by:
getRefin interfaceResultSet- Throws:
SQLException
-
getRef
public Ref getRef(int i) throws SQLException
- Specified by:
getRefin interfaceResultSet- Throws:
SQLException
-
getRow
public int getRow() throws SQLException- Specified by:
getRowin interfaceResultSet- Throws:
SQLException
-
getStatement
public Statement getStatement() throws SQLException
- Specified by:
getStatementin interfaceResultSet- Throws:
SQLException
-
getType
public int getType() throws SQLException- Specified by:
getTypein interfaceResultSet- Throws:
SQLException
-
isAfterLast
public boolean isAfterLast() throws SQLException- Specified by:
isAfterLastin interfaceResultSet- Throws:
SQLException
-
isBeforeFirst
public boolean isBeforeFirst() throws SQLException- Specified by:
isBeforeFirstin interfaceResultSet- Throws:
SQLException
-
isFirst
public boolean isFirst() throws SQLException- Specified by:
isFirstin interfaceResultSet- Throws:
SQLException
-
isLast
public boolean isLast() throws SQLException- Specified by:
isLastin interfaceResultSet- Throws:
SQLException
-
last
public boolean last() throws SQLException- Specified by:
lastin interfaceResultSet- Throws:
SQLException
-
previous
public boolean previous() throws SQLException- Specified by:
previousin interfaceResultSet- Throws:
SQLException
-
relative
public boolean relative(int rows) throws SQLException- Specified by:
relativein interfaceResultSet- Throws:
SQLException
-
setFetchDirection
public void setFetchDirection(int direction) throws SQLException- Specified by:
setFetchDirectionin interfaceResultSet- Throws:
SQLException
-
cancelRowUpdates
public void cancelRowUpdates() throws SQLException- Specified by:
cancelRowUpdatesin interfaceResultSet- Throws:
SQLException
-
deleteRow
public void deleteRow() throws SQLException- Specified by:
deleteRowin interfaceResultSet- Throws:
SQLException
-
insertRow
public void insertRow() throws SQLException- Specified by:
insertRowin interfaceResultSet- Throws:
SQLException
-
moveToCurrentRow
public void moveToCurrentRow() throws SQLException- Specified by:
moveToCurrentRowin interfaceResultSet- Throws:
SQLException
-
moveToInsertRow
public void moveToInsertRow() throws SQLException- Specified by:
moveToInsertRowin interfaceResultSet- Throws:
SQLException
-
rowDeleted
public boolean rowDeleted() throws SQLException- Specified by:
rowDeletedin interfaceResultSet- Throws:
SQLException
-
rowInserted
public boolean rowInserted() throws SQLException- Specified by:
rowInsertedin interfaceResultSet- Throws:
SQLException
-
rowUpdated
public boolean rowUpdated() throws SQLException- Specified by:
rowUpdatedin interfaceResultSet- Throws:
SQLException
-
updateAsciiStream
public void updateAsciiStream(int columnIndex, InputStream x, int length) throws SQLException- Specified by:
updateAsciiStreamin interfaceResultSet- Throws:
SQLException
-
updateBigDecimal
public void updateBigDecimal(int columnIndex, BigDecimal x) throws SQLException- Specified by:
updateBigDecimalin interfaceResultSet- Throws:
SQLException
-
updateBinaryStream
public void updateBinaryStream(int columnIndex, InputStream x, int length) throws SQLException- Specified by:
updateBinaryStreamin interfaceResultSet- Throws:
SQLException
-
updateBoolean
public void updateBoolean(int columnIndex, boolean x) throws SQLException- Specified by:
updateBooleanin interfaceResultSet- Throws:
SQLException
-
updateByte
public void updateByte(int columnIndex, byte x) throws SQLException- Specified by:
updateBytein interfaceResultSet- Throws:
SQLException
-
updateBytes
public void updateBytes(int columnIndex, byte[] x) throws SQLException- Specified by:
updateBytesin interfaceResultSet- Throws:
SQLException
-
updateCharacterStream
public void updateCharacterStream(int columnIndex, Reader x, int length) throws SQLException- Specified by:
updateCharacterStreamin interfaceResultSet- Throws:
SQLException
-
updateDate
public void updateDate(int columnIndex, Date x) throws SQLException- Specified by:
updateDatein interfaceResultSet- Throws:
SQLException
-
updateDouble
public void updateDouble(int columnIndex, double x) throws SQLException- Specified by:
updateDoublein interfaceResultSet- Throws:
SQLException
-
updateFloat
public void updateFloat(int columnIndex, float x) throws SQLException- Specified by:
updateFloatin interfaceResultSet- Throws:
SQLException
-
updateInt
public void updateInt(int columnIndex, int x) throws SQLException- Specified by:
updateIntin interfaceResultSet- Throws:
SQLException
-
updateLong
public void updateLong(int columnIndex, long x) throws SQLException- Specified by:
updateLongin interfaceResultSet- Throws:
SQLException
-
updateNull
public void updateNull(int columnIndex) throws SQLException- Specified by:
updateNullin interfaceResultSet- Throws:
SQLException
-
updateObject
public void updateObject(int columnIndex, Object x) throws SQLException- Specified by:
updateObjectin interfaceResultSet- Throws:
SQLException
-
updateObject
public void updateObject(int columnIndex, Object x, int scale) throws SQLException- Specified by:
updateObjectin interfaceResultSet- Throws:
SQLException
-
refreshRow
public void refreshRow() throws SQLException- Specified by:
refreshRowin interfaceResultSet- Throws:
SQLException
-
updateRow
public void updateRow() throws SQLException- Specified by:
updateRowin interfaceResultSet- Throws:
SQLException
-
updateShort
public void updateShort(int columnIndex, short x) throws SQLException- Specified by:
updateShortin interfaceResultSet- Throws:
SQLException
-
updateString
public void updateString(int columnIndex, String x) throws SQLException- Specified by:
updateStringin interfaceResultSet- Throws:
SQLException
-
updateTime
public void updateTime(int columnIndex, Time x) throws SQLException- Specified by:
updateTimein interfaceResultSet- Throws:
SQLException
-
updateTimestamp
public void updateTimestamp(int columnIndex, Timestamp x) throws SQLException- Specified by:
updateTimestampin interfaceResultSet- Throws:
SQLException
-
updateNull
public void updateNull(String columnName) throws SQLException
- Specified by:
updateNullin interfaceResultSet- Throws:
SQLException
-
updateBoolean
public void updateBoolean(String columnName, boolean x) throws SQLException
- Specified by:
updateBooleanin interfaceResultSet- Throws:
SQLException
-
updateByte
public void updateByte(String columnName, byte x) throws SQLException
- Specified by:
updateBytein interfaceResultSet- Throws:
SQLException
-
updateShort
public void updateShort(String columnName, short x) throws SQLException
- Specified by:
updateShortin interfaceResultSet- Throws:
SQLException
-
updateInt
public void updateInt(String columnName, int x) throws SQLException
- Specified by:
updateIntin interfaceResultSet- Throws:
SQLException
-
updateLong
public void updateLong(String columnName, long x) throws SQLException
- Specified by:
updateLongin interfaceResultSet- Throws:
SQLException
-
updateFloat
public void updateFloat(String columnName, float x) throws SQLException
- Specified by:
updateFloatin interfaceResultSet- Throws:
SQLException
-
updateDouble
public void updateDouble(String columnName, double x) throws SQLException
- Specified by:
updateDoublein interfaceResultSet- Throws:
SQLException
-
updateBigDecimal
public void updateBigDecimal(String columnName, BigDecimal x) throws SQLException
- Specified by:
updateBigDecimalin interfaceResultSet- Throws:
SQLException
-
updateString
public void updateString(String columnName, String x) throws SQLException
- Specified by:
updateStringin interfaceResultSet- Throws:
SQLException
-
updateBytes
public void updateBytes(String columnName, byte[] x) throws SQLException
- Specified by:
updateBytesin interfaceResultSet- Throws:
SQLException
-
updateDate
public void updateDate(String columnName, Date x) throws SQLException
- Specified by:
updateDatein interfaceResultSet- Throws:
SQLException
-
updateTime
public void updateTime(String columnName, Time x) throws SQLException
- Specified by:
updateTimein interfaceResultSet- Throws:
SQLException
-
updateTimestamp
public void updateTimestamp(String columnName, Timestamp x) throws SQLException
- Specified by:
updateTimestampin interfaceResultSet- Throws:
SQLException
-
updateAsciiStream
public void updateAsciiStream(String columnName, InputStream x, int length) throws SQLException
- Specified by:
updateAsciiStreamin interfaceResultSet- Throws:
SQLException
-
updateBinaryStream
public void updateBinaryStream(String columnName, InputStream x, int length) throws SQLException
- Specified by:
updateBinaryStreamin interfaceResultSet- Throws:
SQLException
-
updateCharacterStream
public void updateCharacterStream(String columnName, Reader reader, int length) throws SQLException
- Specified by:
updateCharacterStreamin interfaceResultSet- Throws:
SQLException
-
updateObject
public void updateObject(String columnName, Object x, int scale) throws SQLException
- Specified by:
updateObjectin interfaceResultSet- Throws:
SQLException
-
updateObject
public void updateObject(String columnName, Object x) throws SQLException
- Specified by:
updateObjectin interfaceResultSet- Throws:
SQLException
-
quotelessTableName
public static String[] quotelessTableName(String fullname)
Cracks out the table name and schema (if it exists) from a fully qualified table name.- Parameters:
fullname- string that we are trying to crack. Test cases:Table: table () "Table": Table () Schema.Table: table (schema) "Schema"."Table": Table (Schema) "Schema"."Dot.Table": Dot.Table (Schema) Schema."Dot.Table": Dot.Table (schema)- Returns:
- String array with element zero always being the tablename and element 1 the schema name which may be a zero length string.
-
getPGStatement
public BaseStatement getPGStatement()
-
getRefCursor
public String getRefCursor()
- Specified by:
getRefCursorin interfacePGRefCursorResultSet- Returns:
- the name of the cursor.
-
setFetchSize
public void setFetchSize(int rows) throws SQLException- Specified by:
setFetchSizein interfaceResultSet- Throws:
SQLException
-
getFetchSize
public int getFetchSize() throws SQLException- Specified by:
getFetchSizein interfaceResultSet- Throws:
SQLException
-
next
public boolean next() throws SQLException- Specified by:
nextin interfaceResultSet- Throws:
SQLException
-
close
public void close() throws SQLException- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceResultSet- Throws:
SQLException
-
closeInternally
protected void closeInternally() throws SQLException- Throws:
SQLException
-
wasNull
public boolean wasNull() throws SQLException- Specified by:
wasNullin interfaceResultSet- Throws:
SQLException
-
getString
public String getString(int columnIndex) throws SQLException
- Specified by:
getStringin interfaceResultSet- Throws:
SQLException
-
getBoolean
public boolean getBoolean(int columnIndex) throws SQLExceptionRetrieves the value of the designated column in the current row of this
ResultSetobject as abooleanin the Java programming language.If the designated column has a Character datatype and is one of the following values: "1", "true", "t", "yes", "y" or "on", a value of
trueis returned. If the designated column has a Character datatype and is one of the following values: "0", "false", "f", "no", "n" or "off", a value offalseis returned. Leading or trailing whitespace is ignored, and case does not matter.If the designated column has a Numeric datatype and is a 1, a value of
trueis returned. If the designated column has a Numeric datatype and is a 0, a value offalseis returned.- Specified by:
getBooleanin interfaceResultSet- Parameters:
columnIndex- the first column is 1, the second is 2, ...- Returns:
- the column value; if the value is SQL
NULL, the value returned isfalse - Throws:
SQLException- if the columnIndex is not valid; if a database access error occurs; if this method is called on a closed result set or is an invalid cast to boolean type.- See Also:
- PostgreSQL Boolean Type
-
getByte
public byte getByte(int columnIndex) throws SQLException- Specified by:
getBytein interfaceResultSet- Throws:
SQLException
-
getShort
public short getShort(int columnIndex) throws SQLException- Specified by:
getShortin interfaceResultSet- Throws:
SQLException
-
getInt
public int getInt(int columnIndex) throws SQLException- Specified by:
getIntin interfaceResultSet- Throws:
SQLException
-
getLong
public long getLong(int columnIndex) throws SQLException- Specified by:
getLongin interfaceResultSet- Throws:
SQLException
-
getFloat
public float getFloat(int columnIndex) throws SQLException- Specified by:
getFloatin interfaceResultSet- Throws:
SQLException
-
getDouble
public double getDouble(int columnIndex) throws SQLException- Specified by:
getDoublein interfaceResultSet- Throws:
SQLException
-
getBigDecimal
public BigDecimal getBigDecimal(int columnIndex, int scale) throws SQLException
- Specified by:
getBigDecimalin interfaceResultSet- Throws:
SQLException
-
getBytes
public byte[] getBytes(int columnIndex) throws SQLExceptionIn normal use, the bytes represent the raw values returned by the backend. However, if the column is an OID, then it is assumed to refer to a Large Object, and that object is returned as a byte array.
Be warned If the large object is huge, then you may run out of memory.
- Specified by:
getBytesin interfaceResultSet- Throws:
SQLException
-
getDate
public Date getDate(int columnIndex) throws SQLException
- Specified by:
getDatein interfaceResultSet- Throws:
SQLException
-
getTime
public Time getTime(int columnIndex) throws SQLException
- Specified by:
getTimein interfaceResultSet- Throws:
SQLException
-
getTimestamp
public Timestamp getTimestamp(int columnIndex) throws SQLException
- Specified by:
getTimestampin interfaceResultSet- Throws:
SQLException
-
getAsciiStream
public InputStream getAsciiStream(int columnIndex) throws SQLException
- Specified by:
getAsciiStreamin interfaceResultSet- Throws:
SQLException
-
getUnicodeStream
public InputStream getUnicodeStream(int columnIndex) throws SQLException
- Specified by:
getUnicodeStreamin interfaceResultSet- Throws:
SQLException
-
getBinaryStream
public InputStream getBinaryStream(int columnIndex) throws SQLException
- Specified by:
getBinaryStreamin interfaceResultSet- Throws:
SQLException
-
getString
public String getString(String columnName) throws SQLException
- Specified by:
getStringin interfaceResultSet- Throws:
SQLException
-
getBoolean
public boolean getBoolean(String columnName) throws SQLException
- Specified by:
getBooleanin interfaceResultSet- Throws:
SQLException
-
getByte
public byte getByte(String columnName) throws SQLException
- Specified by:
getBytein interfaceResultSet- Throws:
SQLException
-
getShort
public short getShort(String columnName) throws SQLException
- Specified by:
getShortin interfaceResultSet- Throws:
SQLException
-
getInt
public int getInt(String columnName) throws SQLException
- Specified by:
getIntin interfaceResultSet- Throws:
SQLException
-
getLong
public long getLong(String columnName) throws SQLException
- Specified by:
getLongin interfaceResultSet- Throws:
SQLException
-
getFloat
public float getFloat(String columnName) throws SQLException
- Specified by:
getFloatin interfaceResultSet- Throws:
SQLException
-
getDouble
public double getDouble(String columnName) throws SQLException
- Specified by:
getDoublein interfaceResultSet- Throws:
SQLException
-
getBigDecimal
public BigDecimal getBigDecimal(String columnName, int scale) throws SQLException
- Specified by:
getBigDecimalin interfaceResultSet- Throws:
SQLException
-
getBytes
public byte[] getBytes(String columnName) throws SQLException
- Specified by:
getBytesin interfaceResultSet- Throws:
SQLException
-
getDate
public Date getDate(String columnName) throws SQLException
- Specified by:
getDatein interfaceResultSet- Throws:
SQLException
-
getTime
public Time getTime(String columnName) throws SQLException
- Specified by:
getTimein interfaceResultSet- Throws:
SQLException
-
getTimestamp
public Timestamp getTimestamp(String columnName) throws SQLException
- Specified by:
getTimestampin interfaceResultSet- Throws:
SQLException
-
getAsciiStream
public InputStream getAsciiStream(String columnName) throws SQLException
- Specified by:
getAsciiStreamin interfaceResultSet- Throws:
SQLException
-
getUnicodeStream
public InputStream getUnicodeStream(String columnName) throws SQLException
- Specified by:
getUnicodeStreamin interfaceResultSet- Throws:
SQLException
-
getBinaryStream
public InputStream getBinaryStream(String columnName) throws SQLException
- Specified by:
getBinaryStreamin interfaceResultSet- Throws:
SQLException
-
getWarnings
public SQLWarning getWarnings() throws SQLException
- Specified by:
getWarningsin interfaceResultSet- Throws:
SQLException
-
clearWarnings
public void clearWarnings() throws SQLException- Specified by:
clearWarningsin interfaceResultSet- Throws:
SQLException
-
addWarning
protected void addWarning(SQLWarning warnings)
-
getCursorName
public String getCursorName() throws SQLException
- Specified by:
getCursorNamein interfaceResultSet- Throws:
SQLException
-
getObject
public Object getObject(int columnIndex) throws SQLException
- Specified by:
getObjectin interfaceResultSet- Throws:
SQLException
-
getObject
public Object getObject(String columnName) throws SQLException
- Specified by:
getObjectin interfaceResultSet- Throws:
SQLException
-
findColumn
public int findColumn(String columnName) throws SQLException
- Specified by:
findColumnin interfaceResultSet- Throws:
SQLException
-
createColumnNameIndexMap
public static Map<String,Integer> createColumnNameIndexMap(Field[] fields, boolean isSanitiserDisabled)
-
getColumnOID
public int getColumnOID(int field)
Returns the OID of a field. It is used internally by the driver.- Parameters:
field- field index- Returns:
- OID of a field
-
getFixedString
public String getFixedString(int col) throws SQLException
This is used to fix get*() methods on Money fields. It should only be used by those methods!
It converts ($##.##) to -##.## and $##.## to ##.##
- Parameters:
col- column position (1-based)- Returns:
- numeric-parsable representation of money string literal
- Throws:
SQLException- if something wrong happens
-
getPGType
protected String getPGType(int column) throws SQLException
- Throws:
SQLException
-
getSQLType
protected int getSQLType(int column) throws SQLException- Throws:
SQLException
-
checkClosed
protected void checkClosed() throws SQLException- Throws:
SQLException
-
isResultSetClosed
protected boolean isResultSetClosed()
-
checkColumnIndex
protected void checkColumnIndex(int column) throws SQLException- Throws:
SQLException
-
getRawValue
protected byte[] getRawValue(int column) throws SQLExceptionChecks that the result set is not closed, it's positioned on a valid row and that the given column number is valid. Also updates thewasNullFlagto correct value.- Parameters:
column- The column number to check. Range starts from 1.- Returns:
- raw value or null
- Throws:
SQLException- If state or column is invalid.
-
isBinary
protected boolean isBinary(int column)
Returns true if the value of the given column is in binary format.- Parameters:
column- The column to check. Range starts from 1.- Returns:
- True if the column is in binary format.
-
toShort
public static short toShort(String s) throws SQLException
- Throws:
SQLException
-
toInt
public static int toInt(String s) throws SQLException
- Throws:
SQLException
-
toLong
public static long toLong(String s) throws SQLException
- Throws:
SQLException
-
toBigDecimal
public static BigDecimal toBigDecimal(String s) throws SQLException
- Throws:
SQLException
-
toBigDecimal
public BigDecimal toBigDecimal(String s, int scale) throws SQLException
- Throws:
SQLException
-
toFloat
public static float toFloat(String s) throws SQLException
- Throws:
SQLException
-
toDouble
public static double toDouble(String s) throws SQLException
- Throws:
SQLException
-
updateValue
protected void updateValue(int columnIndex, Object value) throws SQLException- Throws:
SQLException
-
getUUID
protected Object getUUID(String data) throws SQLException
- Throws:
SQLException
-
getUUID
protected Object getUUID(byte[] data) throws SQLException
- Throws:
SQLException
-
updateRef
public void updateRef(int columnIndex, Ref x) throws SQLException- Specified by:
updateRefin interfaceResultSet- Throws:
SQLException
-
updateRef
public void updateRef(String columnName, Ref x) throws SQLException
- Specified by:
updateRefin interfaceResultSet- Throws:
SQLException
-
updateBlob
public void updateBlob(int columnIndex, Blob x) throws SQLException- Specified by:
updateBlobin interfaceResultSet- Throws:
SQLException
-
updateBlob
public void updateBlob(String columnName, Blob x) throws SQLException
- Specified by:
updateBlobin interfaceResultSet- Throws:
SQLException
-
updateClob
public void updateClob(int columnIndex, Clob x) throws SQLException- Specified by:
updateClobin interfaceResultSet- Throws:
SQLException
-
updateClob
public void updateClob(String columnName, Clob x) throws SQLException
- Specified by:
updateClobin interfaceResultSet- Throws:
SQLException
-
updateArray
public void updateArray(int columnIndex, Array x) throws SQLException- Specified by:
updateArrayin interfaceResultSet- Throws:
SQLException
-
updateArray
public void updateArray(String columnName, Array x) throws SQLException
- Specified by:
updateArrayin interfaceResultSet- Throws:
SQLException
-
getObject
public <T> T getObject(int columnIndex, Class<T> type) throws SQLException- Specified by:
getObjectin interfaceResultSet- Throws:
SQLException
-
getObject
public <T> T getObject(String columnLabel, Class<T> type) throws SQLException
- Specified by:
getObjectin interfaceResultSet- Throws:
SQLException
-
getObject
public Object getObject(String s, Map<String,Class<?>> map) throws SQLException
- Specified by:
getObjectin interfaceResultSet- Throws:
SQLException
-
getObject
public Object getObject(int i, Map<String,Class<?>> map) throws SQLException
- Specified by:
getObjectin interfaceResultSet- Throws:
SQLException
-
updateObject
public void updateObject(int columnIndex, Object x, SQLType targetSqlType, int scaleOrLength) throws SQLException- Specified by:
updateObjectin interfaceResultSet- Throws:
SQLException
-
updateObject
public void updateObject(String columnLabel, Object x, SQLType targetSqlType, int scaleOrLength) throws SQLException
- Specified by:
updateObjectin interfaceResultSet- Throws:
SQLException
-
updateObject
public void updateObject(int columnIndex, Object x, SQLType targetSqlType) throws SQLException- Specified by:
updateObjectin interfaceResultSet- Throws:
SQLException
-
updateObject
public void updateObject(String columnLabel, Object x, SQLType targetSqlType) throws SQLException
- Specified by:
updateObjectin interfaceResultSet- Throws:
SQLException
-
getRowId
public RowId getRowId(int columnIndex) throws SQLException
- Specified by:
getRowIdin interfaceResultSet- Throws:
SQLException
-
getRowId
public RowId getRowId(String columnName) throws SQLException
- Specified by:
getRowIdin interfaceResultSet- Throws:
SQLException
-
updateRowId
public void updateRowId(int columnIndex, RowId x) throws SQLException- Specified by:
updateRowIdin interfaceResultSet- Throws:
SQLException
-
updateRowId
public void updateRowId(String columnName, RowId x) throws SQLException
- Specified by:
updateRowIdin interfaceResultSet- Throws:
SQLException
-
getHoldability
public int getHoldability() throws SQLException- Specified by:
getHoldabilityin interfaceResultSet- Throws:
SQLException
-
isClosed
public boolean isClosed() throws SQLException- Specified by:
isClosedin interfaceResultSet- Throws:
SQLException
-
updateNString
public void updateNString(int columnIndex, String nString) throws SQLException- Specified by:
updateNStringin interfaceResultSet- Throws:
SQLException
-
updateNString
public void updateNString(String columnName, String nString) throws SQLException
- Specified by:
updateNStringin interfaceResultSet- Throws:
SQLException
-
updateNClob
public void updateNClob(int columnIndex, NClob nClob) throws SQLException- Specified by:
updateNClobin interfaceResultSet- Throws:
SQLException
-
updateNClob
public void updateNClob(String columnName, NClob nClob) throws SQLException
- Specified by:
updateNClobin interfaceResultSet- Throws:
SQLException
-
updateNClob
public void updateNClob(int columnIndex, Reader reader) throws SQLException- Specified by:
updateNClobin interfaceResultSet- Throws:
SQLException
-
updateNClob
public void updateNClob(String columnName, Reader reader) throws SQLException
- Specified by:
updateNClobin interfaceResultSet- Throws:
SQLException
-
updateNClob
public void updateNClob(int columnIndex, Reader reader, long length) throws SQLException- Specified by:
updateNClobin interfaceResultSet- Throws:
SQLException
-
updateNClob
public void updateNClob(String columnName, Reader reader, long length) throws SQLException
- Specified by:
updateNClobin interfaceResultSet- Throws:
SQLException
-
getNClob
public NClob getNClob(int columnIndex) throws SQLException
- Specified by:
getNClobin interfaceResultSet- Throws:
SQLException
-
getNClob
public NClob getNClob(String columnName) throws SQLException
- Specified by:
getNClobin interfaceResultSet- Throws:
SQLException
-
updateBlob
public void updateBlob(int columnIndex, InputStream inputStream, long length) throws SQLException- Specified by:
updateBlobin interfaceResultSet- Throws:
SQLException
-
updateBlob
public void updateBlob(String columnName, InputStream inputStream, long length) throws SQLException
- Specified by:
updateBlobin interfaceResultSet- Throws:
SQLException
-
updateBlob
public void updateBlob(int columnIndex, InputStream inputStream) throws SQLException- Specified by:
updateBlobin interfaceResultSet- Throws:
SQLException
-
updateBlob
public void updateBlob(String columnName, InputStream inputStream) throws SQLException
- Specified by:
updateBlobin interfaceResultSet- Throws:
SQLException
-
updateClob
public void updateClob(int columnIndex, Reader reader, long length) throws SQLException- Specified by:
updateClobin interfaceResultSet- Throws:
SQLException
-
updateClob
public void updateClob(String columnName, Reader reader, long length) throws SQLException
- Specified by:
updateClobin interfaceResultSet- Throws:
SQLException
-
updateClob
public void updateClob(int columnIndex, Reader reader) throws SQLException- Specified by:
updateClobin interfaceResultSet- Throws:
SQLException
-
updateClob
public void updateClob(String columnName, Reader reader) throws SQLException
- Specified by:
updateClobin interfaceResultSet- Throws:
SQLException
-
getSQLXML
public SQLXML getSQLXML(int columnIndex) throws SQLException
- Specified by:
getSQLXMLin interfaceResultSet- Throws:
SQLException
-
getSQLXML
public SQLXML getSQLXML(String columnName) throws SQLException
- Specified by:
getSQLXMLin interfaceResultSet- Throws:
SQLException
-
updateSQLXML
public void updateSQLXML(int columnIndex, SQLXML xmlObject) throws SQLException- Specified by:
updateSQLXMLin interfaceResultSet- Throws:
SQLException
-
updateSQLXML
public void updateSQLXML(String columnName, SQLXML xmlObject) throws SQLException
- Specified by:
updateSQLXMLin interfaceResultSet- Throws:
SQLException
-
getNString
public String getNString(int columnIndex) throws SQLException
- Specified by:
getNStringin interfaceResultSet- Throws:
SQLException
-
getNString
public String getNString(String columnName) throws SQLException
- Specified by:
getNStringin interfaceResultSet- Throws:
SQLException
-
getNCharacterStream
public Reader getNCharacterStream(int columnIndex) throws SQLException
- Specified by:
getNCharacterStreamin interfaceResultSet- Throws:
SQLException
-
getNCharacterStream
public Reader getNCharacterStream(String columnName) throws SQLException
- Specified by:
getNCharacterStreamin interfaceResultSet- Throws:
SQLException
-
updateNCharacterStream
public void updateNCharacterStream(int columnIndex, Reader x, int length) throws SQLException- Throws:
SQLException
-
updateNCharacterStream
public void updateNCharacterStream(String columnName, Reader x, int length) throws SQLException
- Throws:
SQLException
-
updateNCharacterStream
public void updateNCharacterStream(int columnIndex, Reader x) throws SQLException- Specified by:
updateNCharacterStreamin interfaceResultSet- Throws:
SQLException
-
updateNCharacterStream
public void updateNCharacterStream(String columnName, Reader x) throws SQLException
- Specified by:
updateNCharacterStreamin interfaceResultSet- Throws:
SQLException
-
updateNCharacterStream
public void updateNCharacterStream(int columnIndex, Reader x, long length) throws SQLException- Specified by:
updateNCharacterStreamin interfaceResultSet- Throws:
SQLException
-
updateNCharacterStream
public void updateNCharacterStream(String columnName, Reader x, long length) throws SQLException
- Specified by:
updateNCharacterStreamin interfaceResultSet- Throws:
SQLException
-
updateCharacterStream
public void updateCharacterStream(int columnIndex, Reader reader, long length) throws SQLException- Specified by:
updateCharacterStreamin interfaceResultSet- Throws:
SQLException
-
updateCharacterStream
public void updateCharacterStream(String columnName, Reader reader, long length) throws SQLException
- Specified by:
updateCharacterStreamin interfaceResultSet- Throws:
SQLException
-
updateCharacterStream
public void updateCharacterStream(int columnIndex, Reader reader) throws SQLException- Specified by:
updateCharacterStreamin interfaceResultSet- Throws:
SQLException
-
updateCharacterStream
public void updateCharacterStream(String columnName, Reader reader) throws SQLException
- Specified by:
updateCharacterStreamin interfaceResultSet- Throws:
SQLException
-
updateBinaryStream
public void updateBinaryStream(int columnIndex, InputStream inputStream, long length) throws SQLException- Specified by:
updateBinaryStreamin interfaceResultSet- Throws:
SQLException
-
updateBinaryStream
public void updateBinaryStream(String columnName, InputStream inputStream, long length) throws SQLException
- Specified by:
updateBinaryStreamin interfaceResultSet- Throws:
SQLException
-
updateBinaryStream
public void updateBinaryStream(int columnIndex, InputStream inputStream) throws SQLException- Specified by:
updateBinaryStreamin interfaceResultSet- Throws:
SQLException
-
updateBinaryStream
public void updateBinaryStream(String columnName, InputStream inputStream) throws SQLException
- Specified by:
updateBinaryStreamin interfaceResultSet- Throws:
SQLException
-
updateAsciiStream
public void updateAsciiStream(int columnIndex, InputStream inputStream, long length) throws SQLException- Specified by:
updateAsciiStreamin interfaceResultSet- Throws:
SQLException
-
updateAsciiStream
public void updateAsciiStream(String columnName, InputStream inputStream, long length) throws SQLException
- Specified by:
updateAsciiStreamin interfaceResultSet- Throws:
SQLException
-
updateAsciiStream
public void updateAsciiStream(int columnIndex, InputStream inputStream) throws SQLException- Specified by:
updateAsciiStreamin interfaceResultSet- Throws:
SQLException
-
updateAsciiStream
public void updateAsciiStream(String columnName, InputStream inputStream) throws SQLException
- Specified by:
updateAsciiStreamin interfaceResultSet- Throws:
SQLException
-
isWrapperFor
public boolean isWrapperFor(Class<?> iface) throws SQLException
- Specified by:
isWrapperForin interfaceWrapper- Throws:
SQLException
-
unwrap
public <T> T unwrap(Class<T> iface) throws SQLException
- Specified by:
unwrapin interfaceWrapper- Throws:
SQLException
-
-