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 class
PgResultSet.CursorResultHandler
-
Field Summary
Fields Modifier and Type Field Description protected BaseConnection
connection
protected int
currentRow
protected ResultCursor
cursor
protected int
fetchSize
protected Field[]
fields
protected int
maxFieldSize
protected int
maxRows
protected boolean
onInsertRow
protected Query
originalQuery
protected int
rowOffset
protected List<Tuple>
rows
protected BaseStatement
statement
protected Tuple
thisRow
protected SQLWarning
warnings
protected boolean
wasNullFlag
True 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 boolean
absolute(int index)
protected void
addWarning(SQLWarning warnings)
void
afterLast()
void
beforeFirst()
void
cancelRowUpdates()
protected void
checkClosed()
protected void
checkColumnIndex(int column)
void
clearWarnings()
void
close()
protected void
closeInternally()
static Map<String,Integer>
createColumnNameIndexMap(Field[] fields, boolean isSanitiserDisabled)
protected ResultSetMetaData
createMetaData()
void
deleteRow()
int
findColumn(String columnName)
boolean
first()
Array
getArray(int i)
Array
getArray(String colName)
InputStream
getAsciiStream(int columnIndex)
InputStream
getAsciiStream(String columnName)
BigDecimal
getBigDecimal(int columnIndex)
BigDecimal
getBigDecimal(int columnIndex, int scale)
BigDecimal
getBigDecimal(String columnName)
BigDecimal
getBigDecimal(String columnName, int scale)
InputStream
getBinaryStream(int columnIndex)
InputStream
getBinaryStream(String columnName)
Blob
getBlob(int i)
Blob
getBlob(String columnName)
boolean
getBoolean(int columnIndex)
Retrieves the value of the designated column in the current row of thisResultSet
object as aboolean
in the Java programming language.boolean
getBoolean(String columnName)
byte
getByte(int columnIndex)
byte
getByte(String columnName)
byte[]
getBytes(int columnIndex)
byte[]
getBytes(String columnName)
Reader
getCharacterStream(int i)
Reader
getCharacterStream(String columnName)
Clob
getClob(int i)
Clob
getClob(String columnName)
int
getColumnOID(int field)
Returns the OID of a field.int
getConcurrency()
String
getCursorName()
Date
getDate(int columnIndex)
Date
getDate(int i, Calendar cal)
Date
getDate(String columnName)
Date
getDate(String c, Calendar cal)
double
getDouble(int columnIndex)
double
getDouble(String columnName)
int
getFetchDirection()
int
getFetchSize()
String
getFixedString(int col)
This is used to fix get*() methods on Money fields.float
getFloat(int columnIndex)
float
getFloat(String columnName)
int
getHoldability()
int
getInt(int columnIndex)
int
getInt(String columnName)
long
getLong(int columnIndex)
long
getLong(String columnName)
ResultSetMetaData
getMetaData()
Reader
getNCharacterStream(int columnIndex)
Reader
getNCharacterStream(String columnName)
NClob
getNClob(int columnIndex)
NClob
getNClob(String columnName)
String
getNString(int columnIndex)
String
getNString(String columnName)
Object
getObject(int columnIndex)
<T> T
getObject(int columnIndex, Class<T> type)
Object
getObject(int i, Map<String,Class<?>> map)
Object
getObject(String columnName)
<T> T
getObject(String columnLabel, Class<T> type)
Object
getObject(String s, Map<String,Class<?>> map)
Object
getObjectImpl(int i, Map<String,Class<?>> map)
Object
getObjectImpl(String columnName, Map<String,Class<?>> map)
BaseStatement
getPGStatement()
protected String
getPGType(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.Ref
getRef(int i)
Ref
getRef(String columnName)
String
getRefCursor()
int
getRow()
RowId
getRowId(int columnIndex)
RowId
getRowId(String columnName)
short
getShort(int columnIndex)
short
getShort(String columnName)
protected int
getSQLType(int column)
SQLXML
getSQLXML(int columnIndex)
SQLXML
getSQLXML(String columnName)
Statement
getStatement()
String
getString(int columnIndex)
String
getString(String columnName)
Time
getTime(int columnIndex)
Time
getTime(int i, Calendar cal)
Time
getTime(String columnName)
Time
getTime(String c, Calendar cal)
Timestamp
getTimestamp(int columnIndex)
Timestamp
getTimestamp(int i, Calendar cal)
Timestamp
getTimestamp(String columnName)
Timestamp
getTimestamp(String c, Calendar cal)
int
getType()
InputStream
getUnicodeStream(int columnIndex)
InputStream
getUnicodeStream(String columnName)
URL
getURL(int columnIndex)
URL
getURL(String columnName)
protected Object
getUUID(byte[] data)
protected Object
getUUID(String data)
SQLWarning
getWarnings()
void
insertRow()
protected Object
internalGetObject(int columnIndex, Field field)
boolean
isAfterLast()
boolean
isBeforeFirst()
protected boolean
isBinary(int column)
Returns true if the value of the given column is in binary format.boolean
isClosed()
boolean
isFirst()
boolean
isLast()
protected boolean
isResultSetClosed()
boolean
isWrapperFor(Class<?> iface)
boolean
last()
protected Array
makeArray(int oid, byte[] value)
protected Array
makeArray(int oid, String value)
protected Blob
makeBlob(long oid)
protected Clob
makeClob(long oid)
void
moveToCurrentRow()
void
moveToInsertRow()
boolean
next()
boolean
previous()
static String[]
quotelessTableName(String fullname)
Cracks out the table name and schema (if it exists) from a fully qualified table name.void
refreshRow()
boolean
relative(int rows)
boolean
rowDeleted()
boolean
rowInserted()
boolean
rowUpdated()
void
setFetchDirection(int direction)
void
setFetchSize(int rows)
static BigDecimal
toBigDecimal(String s)
BigDecimal
toBigDecimal(String s, int scale)
static double
toDouble(String s)
static float
toFloat(String s)
static int
toInt(String s)
static long
toLong(String s)
static short
toShort(String s)
<T> T
unwrap(Class<T> iface)
void
updateArray(int columnIndex, Array x)
void
updateArray(String columnName, Array x)
void
updateAsciiStream(int columnIndex, InputStream inputStream)
void
updateAsciiStream(int columnIndex, InputStream x, int length)
void
updateAsciiStream(int columnIndex, InputStream inputStream, long length)
void
updateAsciiStream(String columnName, InputStream inputStream)
void
updateAsciiStream(String columnName, InputStream x, int length)
void
updateAsciiStream(String columnName, InputStream inputStream, long length)
void
updateBigDecimal(int columnIndex, BigDecimal x)
void
updateBigDecimal(String columnName, BigDecimal x)
void
updateBinaryStream(int columnIndex, InputStream inputStream)
void
updateBinaryStream(int columnIndex, InputStream x, int length)
void
updateBinaryStream(int columnIndex, InputStream inputStream, long length)
void
updateBinaryStream(String columnName, InputStream inputStream)
void
updateBinaryStream(String columnName, InputStream x, int length)
void
updateBinaryStream(String columnName, InputStream inputStream, long length)
void
updateBlob(int columnIndex, InputStream inputStream)
void
updateBlob(int columnIndex, InputStream inputStream, long length)
void
updateBlob(int columnIndex, Blob x)
void
updateBlob(String columnName, InputStream inputStream)
void
updateBlob(String columnName, InputStream inputStream, long length)
void
updateBlob(String columnName, Blob x)
void
updateBoolean(int columnIndex, boolean x)
void
updateBoolean(String columnName, boolean x)
void
updateByte(int columnIndex, byte x)
void
updateByte(String columnName, byte x)
void
updateBytes(int columnIndex, byte[] x)
void
updateBytes(String columnName, byte[] x)
void
updateCharacterStream(int columnIndex, Reader reader)
void
updateCharacterStream(int columnIndex, Reader x, int length)
void
updateCharacterStream(int columnIndex, Reader reader, long length)
void
updateCharacterStream(String columnName, Reader reader)
void
updateCharacterStream(String columnName, Reader reader, int length)
void
updateCharacterStream(String columnName, Reader reader, long length)
void
updateClob(int columnIndex, Reader reader)
void
updateClob(int columnIndex, Reader reader, long length)
void
updateClob(int columnIndex, Clob x)
void
updateClob(String columnName, Reader reader)
void
updateClob(String columnName, Reader reader, long length)
void
updateClob(String columnName, Clob x)
void
updateDate(int columnIndex, Date x)
void
updateDate(String columnName, Date x)
void
updateDouble(int columnIndex, double x)
void
updateDouble(String columnName, double x)
void
updateFloat(int columnIndex, float x)
void
updateFloat(String columnName, float x)
void
updateInt(int columnIndex, int x)
void
updateInt(String columnName, int x)
void
updateLong(int columnIndex, long x)
void
updateLong(String columnName, long x)
void
updateNCharacterStream(int columnIndex, Reader x)
void
updateNCharacterStream(int columnIndex, Reader x, int length)
void
updateNCharacterStream(int columnIndex, Reader x, long length)
void
updateNCharacterStream(String columnName, Reader x)
void
updateNCharacterStream(String columnName, Reader x, int length)
void
updateNCharacterStream(String columnName, Reader x, long length)
void
updateNClob(int columnIndex, Reader reader)
void
updateNClob(int columnIndex, Reader reader, long length)
void
updateNClob(int columnIndex, NClob nClob)
void
updateNClob(String columnName, Reader reader)
void
updateNClob(String columnName, Reader reader, long length)
void
updateNClob(String columnName, NClob nClob)
void
updateNString(int columnIndex, String nString)
void
updateNString(String columnName, String nString)
void
updateNull(int columnIndex)
void
updateNull(String columnName)
void
updateObject(int columnIndex, Object x)
void
updateObject(int columnIndex, Object x, int scale)
void
updateObject(int columnIndex, Object x, SQLType targetSqlType)
void
updateObject(int columnIndex, Object x, SQLType targetSqlType, int scaleOrLength)
void
updateObject(String columnName, Object x)
void
updateObject(String columnName, Object x, int scale)
void
updateObject(String columnLabel, Object x, SQLType targetSqlType)
void
updateObject(String columnLabel, Object x, SQLType targetSqlType, int scaleOrLength)
void
updateRef(int columnIndex, Ref x)
void
updateRef(String columnName, Ref x)
void
updateRow()
void
updateRowId(int columnIndex, RowId x)
void
updateRowId(String columnName, RowId x)
void
updateShort(int columnIndex, short x)
void
updateShort(String columnName, short x)
void
updateSQLXML(int columnIndex, SQLXML xmlObject)
void
updateSQLXML(String columnName, SQLXML xmlObject)
void
updateString(int columnIndex, String x)
void
updateString(String columnName, String x)
void
updateTime(int columnIndex, Time x)
void
updateTime(String columnName, Time x)
void
updateTimestamp(int columnIndex, Timestamp x)
void
updateTimestamp(String columnName, Timestamp x)
protected void
updateValue(int columnIndex, Object value)
boolean
wasNull()
-
-
-
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:
getMetaData
in interfaceResultSet
- Throws:
SQLException
-
getURL
public URL getURL(int columnIndex) throws SQLException
- Specified by:
getURL
in interfaceResultSet
- Throws:
SQLException
-
getURL
public URL getURL(String columnName) throws SQLException
- Specified by:
getURL
in 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:
absolute
in interfaceResultSet
- Throws:
SQLException
-
afterLast
public void afterLast() throws SQLException
- Specified by:
afterLast
in interfaceResultSet
- Throws:
SQLException
-
beforeFirst
public void beforeFirst() throws SQLException
- Specified by:
beforeFirst
in interfaceResultSet
- Throws:
SQLException
-
first
public boolean first() throws SQLException
- Specified by:
first
in interfaceResultSet
- Throws:
SQLException
-
getArray
public Array getArray(String colName) throws SQLException
- Specified by:
getArray
in 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:
getArray
in interfaceResultSet
- Throws:
SQLException
-
getBigDecimal
public BigDecimal getBigDecimal(int columnIndex) throws SQLException
- Specified by:
getBigDecimal
in interfaceResultSet
- Throws:
SQLException
-
getBigDecimal
public BigDecimal getBigDecimal(String columnName) throws SQLException
- Specified by:
getBigDecimal
in interfaceResultSet
- Throws:
SQLException
-
getBlob
public Blob getBlob(String columnName) throws SQLException
- Specified by:
getBlob
in interfaceResultSet
- Throws:
SQLException
-
makeBlob
protected Blob makeBlob(long oid) throws SQLException
- Throws:
SQLException
-
getBlob
public Blob getBlob(int i) throws SQLException
- Specified by:
getBlob
in interfaceResultSet
- Throws:
SQLException
-
getCharacterStream
public Reader getCharacterStream(String columnName) throws SQLException
- Specified by:
getCharacterStream
in interfaceResultSet
- Throws:
SQLException
-
getCharacterStream
public Reader getCharacterStream(int i) throws SQLException
- Specified by:
getCharacterStream
in interfaceResultSet
- Throws:
SQLException
-
getClob
public Clob getClob(String columnName) throws SQLException
- Specified by:
getClob
in interfaceResultSet
- Throws:
SQLException
-
makeClob
protected Clob makeClob(long oid) throws SQLException
- Throws:
SQLException
-
getClob
public Clob getClob(int i) throws SQLException
- Specified by:
getClob
in interfaceResultSet
- Throws:
SQLException
-
getConcurrency
public int getConcurrency() throws SQLException
- Specified by:
getConcurrency
in interfaceResultSet
- Throws:
SQLException
-
getDate
public Date getDate(int i, Calendar cal) throws SQLException
- Specified by:
getDate
in interfaceResultSet
- Throws:
SQLException
-
getTime
public Time getTime(int i, Calendar cal) throws SQLException
- Specified by:
getTime
in interfaceResultSet
- Throws:
SQLException
-
getTimestamp
public Timestamp getTimestamp(int i, Calendar cal) throws SQLException
- Specified by:
getTimestamp
in interfaceResultSet
- Throws:
SQLException
-
getDate
public Date getDate(String c, Calendar cal) throws SQLException
- Specified by:
getDate
in interfaceResultSet
- Throws:
SQLException
-
getTime
public Time getTime(String c, Calendar cal) throws SQLException
- Specified by:
getTime
in interfaceResultSet
- Throws:
SQLException
-
getTimestamp
public Timestamp getTimestamp(String c, Calendar cal) throws SQLException
- Specified by:
getTimestamp
in interfaceResultSet
- Throws:
SQLException
-
getFetchDirection
public int getFetchDirection() throws SQLException
- Specified by:
getFetchDirection
in 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:
getRef
in interfaceResultSet
- Throws:
SQLException
-
getRef
public Ref getRef(int i) throws SQLException
- Specified by:
getRef
in interfaceResultSet
- Throws:
SQLException
-
getRow
public int getRow() throws SQLException
- Specified by:
getRow
in interfaceResultSet
- Throws:
SQLException
-
getStatement
public Statement getStatement() throws SQLException
- Specified by:
getStatement
in interfaceResultSet
- Throws:
SQLException
-
getType
public int getType() throws SQLException
- Specified by:
getType
in interfaceResultSet
- Throws:
SQLException
-
isAfterLast
public boolean isAfterLast() throws SQLException
- Specified by:
isAfterLast
in interfaceResultSet
- Throws:
SQLException
-
isBeforeFirst
public boolean isBeforeFirst() throws SQLException
- Specified by:
isBeforeFirst
in interfaceResultSet
- Throws:
SQLException
-
isFirst
public boolean isFirst() throws SQLException
- Specified by:
isFirst
in interfaceResultSet
- Throws:
SQLException
-
isLast
public boolean isLast() throws SQLException
- Specified by:
isLast
in interfaceResultSet
- Throws:
SQLException
-
last
public boolean last() throws SQLException
- Specified by:
last
in interfaceResultSet
- Throws:
SQLException
-
previous
public boolean previous() throws SQLException
- Specified by:
previous
in interfaceResultSet
- Throws:
SQLException
-
relative
public boolean relative(int rows) throws SQLException
- Specified by:
relative
in interfaceResultSet
- Throws:
SQLException
-
setFetchDirection
public void setFetchDirection(int direction) throws SQLException
- Specified by:
setFetchDirection
in interfaceResultSet
- Throws:
SQLException
-
cancelRowUpdates
public void cancelRowUpdates() throws SQLException
- Specified by:
cancelRowUpdates
in interfaceResultSet
- Throws:
SQLException
-
deleteRow
public void deleteRow() throws SQLException
- Specified by:
deleteRow
in interfaceResultSet
- Throws:
SQLException
-
insertRow
public void insertRow() throws SQLException
- Specified by:
insertRow
in interfaceResultSet
- Throws:
SQLException
-
moveToCurrentRow
public void moveToCurrentRow() throws SQLException
- Specified by:
moveToCurrentRow
in interfaceResultSet
- Throws:
SQLException
-
moveToInsertRow
public void moveToInsertRow() throws SQLException
- Specified by:
moveToInsertRow
in interfaceResultSet
- Throws:
SQLException
-
rowDeleted
public boolean rowDeleted() throws SQLException
- Specified by:
rowDeleted
in interfaceResultSet
- Throws:
SQLException
-
rowInserted
public boolean rowInserted() throws SQLException
- Specified by:
rowInserted
in interfaceResultSet
- Throws:
SQLException
-
rowUpdated
public boolean rowUpdated() throws SQLException
- Specified by:
rowUpdated
in interfaceResultSet
- Throws:
SQLException
-
updateAsciiStream
public void updateAsciiStream(int columnIndex, InputStream x, int length) throws SQLException
- Specified by:
updateAsciiStream
in interfaceResultSet
- Throws:
SQLException
-
updateBigDecimal
public void updateBigDecimal(int columnIndex, BigDecimal x) throws SQLException
- Specified by:
updateBigDecimal
in interfaceResultSet
- Throws:
SQLException
-
updateBinaryStream
public void updateBinaryStream(int columnIndex, InputStream x, int length) throws SQLException
- Specified by:
updateBinaryStream
in interfaceResultSet
- Throws:
SQLException
-
updateBoolean
public void updateBoolean(int columnIndex, boolean x) throws SQLException
- Specified by:
updateBoolean
in interfaceResultSet
- Throws:
SQLException
-
updateByte
public void updateByte(int columnIndex, byte x) throws SQLException
- Specified by:
updateByte
in interfaceResultSet
- Throws:
SQLException
-
updateBytes
public void updateBytes(int columnIndex, byte[] x) throws SQLException
- Specified by:
updateBytes
in interfaceResultSet
- Throws:
SQLException
-
updateCharacterStream
public void updateCharacterStream(int columnIndex, Reader x, int length) throws SQLException
- Specified by:
updateCharacterStream
in interfaceResultSet
- Throws:
SQLException
-
updateDate
public void updateDate(int columnIndex, Date x) throws SQLException
- Specified by:
updateDate
in interfaceResultSet
- Throws:
SQLException
-
updateDouble
public void updateDouble(int columnIndex, double x) throws SQLException
- Specified by:
updateDouble
in interfaceResultSet
- Throws:
SQLException
-
updateFloat
public void updateFloat(int columnIndex, float x) throws SQLException
- Specified by:
updateFloat
in interfaceResultSet
- Throws:
SQLException
-
updateInt
public void updateInt(int columnIndex, int x) throws SQLException
- Specified by:
updateInt
in interfaceResultSet
- Throws:
SQLException
-
updateLong
public void updateLong(int columnIndex, long x) throws SQLException
- Specified by:
updateLong
in interfaceResultSet
- Throws:
SQLException
-
updateNull
public void updateNull(int columnIndex) throws SQLException
- Specified by:
updateNull
in interfaceResultSet
- Throws:
SQLException
-
updateObject
public void updateObject(int columnIndex, Object x) throws SQLException
- Specified by:
updateObject
in interfaceResultSet
- Throws:
SQLException
-
updateObject
public void updateObject(int columnIndex, Object x, int scale) throws SQLException
- Specified by:
updateObject
in interfaceResultSet
- Throws:
SQLException
-
refreshRow
public void refreshRow() throws SQLException
- Specified by:
refreshRow
in interfaceResultSet
- Throws:
SQLException
-
updateRow
public void updateRow() throws SQLException
- Specified by:
updateRow
in interfaceResultSet
- Throws:
SQLException
-
updateShort
public void updateShort(int columnIndex, short x) throws SQLException
- Specified by:
updateShort
in interfaceResultSet
- Throws:
SQLException
-
updateString
public void updateString(int columnIndex, String x) throws SQLException
- Specified by:
updateString
in interfaceResultSet
- Throws:
SQLException
-
updateTime
public void updateTime(int columnIndex, Time x) throws SQLException
- Specified by:
updateTime
in interfaceResultSet
- Throws:
SQLException
-
updateTimestamp
public void updateTimestamp(int columnIndex, Timestamp x) throws SQLException
- Specified by:
updateTimestamp
in interfaceResultSet
- Throws:
SQLException
-
updateNull
public void updateNull(String columnName) throws SQLException
- Specified by:
updateNull
in interfaceResultSet
- Throws:
SQLException
-
updateBoolean
public void updateBoolean(String columnName, boolean x) throws SQLException
- Specified by:
updateBoolean
in interfaceResultSet
- Throws:
SQLException
-
updateByte
public void updateByte(String columnName, byte x) throws SQLException
- Specified by:
updateByte
in interfaceResultSet
- Throws:
SQLException
-
updateShort
public void updateShort(String columnName, short x) throws SQLException
- Specified by:
updateShort
in interfaceResultSet
- Throws:
SQLException
-
updateInt
public void updateInt(String columnName, int x) throws SQLException
- Specified by:
updateInt
in interfaceResultSet
- Throws:
SQLException
-
updateLong
public void updateLong(String columnName, long x) throws SQLException
- Specified by:
updateLong
in interfaceResultSet
- Throws:
SQLException
-
updateFloat
public void updateFloat(String columnName, float x) throws SQLException
- Specified by:
updateFloat
in interfaceResultSet
- Throws:
SQLException
-
updateDouble
public void updateDouble(String columnName, double x) throws SQLException
- Specified by:
updateDouble
in interfaceResultSet
- Throws:
SQLException
-
updateBigDecimal
public void updateBigDecimal(String columnName, BigDecimal x) throws SQLException
- Specified by:
updateBigDecimal
in interfaceResultSet
- Throws:
SQLException
-
updateString
public void updateString(String columnName, String x) throws SQLException
- Specified by:
updateString
in interfaceResultSet
- Throws:
SQLException
-
updateBytes
public void updateBytes(String columnName, byte[] x) throws SQLException
- Specified by:
updateBytes
in interfaceResultSet
- Throws:
SQLException
-
updateDate
public void updateDate(String columnName, Date x) throws SQLException
- Specified by:
updateDate
in interfaceResultSet
- Throws:
SQLException
-
updateTime
public void updateTime(String columnName, Time x) throws SQLException
- Specified by:
updateTime
in interfaceResultSet
- Throws:
SQLException
-
updateTimestamp
public void updateTimestamp(String columnName, Timestamp x) throws SQLException
- Specified by:
updateTimestamp
in interfaceResultSet
- Throws:
SQLException
-
updateAsciiStream
public void updateAsciiStream(String columnName, InputStream x, int length) throws SQLException
- Specified by:
updateAsciiStream
in interfaceResultSet
- Throws:
SQLException
-
updateBinaryStream
public void updateBinaryStream(String columnName, InputStream x, int length) throws SQLException
- Specified by:
updateBinaryStream
in interfaceResultSet
- Throws:
SQLException
-
updateCharacterStream
public void updateCharacterStream(String columnName, Reader reader, int length) throws SQLException
- Specified by:
updateCharacterStream
in interfaceResultSet
- Throws:
SQLException
-
updateObject
public void updateObject(String columnName, Object x, int scale) throws SQLException
- Specified by:
updateObject
in interfaceResultSet
- Throws:
SQLException
-
updateObject
public void updateObject(String columnName, Object x) throws SQLException
- Specified by:
updateObject
in 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:
getRefCursor
in interfacePGRefCursorResultSet
- Returns:
- the name of the cursor.
-
setFetchSize
public void setFetchSize(int rows) throws SQLException
- Specified by:
setFetchSize
in interfaceResultSet
- Throws:
SQLException
-
getFetchSize
public int getFetchSize() throws SQLException
- Specified by:
getFetchSize
in interfaceResultSet
- Throws:
SQLException
-
next
public boolean next() throws SQLException
- Specified by:
next
in interfaceResultSet
- Throws:
SQLException
-
close
public void close() throws SQLException
- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceResultSet
- Throws:
SQLException
-
closeInternally
protected void closeInternally() throws SQLException
- Throws:
SQLException
-
wasNull
public boolean wasNull() throws SQLException
- Specified by:
wasNull
in interfaceResultSet
- Throws:
SQLException
-
getString
public String getString(int columnIndex) throws SQLException
- Specified by:
getString
in interfaceResultSet
- Throws:
SQLException
-
getBoolean
public boolean getBoolean(int columnIndex) throws SQLException
Retrieves the value of the designated column in the current row of this
ResultSet
object as aboolean
in 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
true
is 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 offalse
is 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
true
is returned. If the designated column has a Numeric datatype and is a 0, a value offalse
is returned.- Specified by:
getBoolean
in 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:
getByte
in interfaceResultSet
- Throws:
SQLException
-
getShort
public short getShort(int columnIndex) throws SQLException
- Specified by:
getShort
in interfaceResultSet
- Throws:
SQLException
-
getInt
public int getInt(int columnIndex) throws SQLException
- Specified by:
getInt
in interfaceResultSet
- Throws:
SQLException
-
getLong
public long getLong(int columnIndex) throws SQLException
- Specified by:
getLong
in interfaceResultSet
- Throws:
SQLException
-
getFloat
public float getFloat(int columnIndex) throws SQLException
- Specified by:
getFloat
in interfaceResultSet
- Throws:
SQLException
-
getDouble
public double getDouble(int columnIndex) throws SQLException
- Specified by:
getDouble
in interfaceResultSet
- Throws:
SQLException
-
getBigDecimal
public BigDecimal getBigDecimal(int columnIndex, int scale) throws SQLException
- Specified by:
getBigDecimal
in interfaceResultSet
- Throws:
SQLException
-
getBytes
public byte[] getBytes(int columnIndex) throws SQLException
In 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:
getBytes
in interfaceResultSet
- Throws:
SQLException
-
getDate
public Date getDate(int columnIndex) throws SQLException
- Specified by:
getDate
in interfaceResultSet
- Throws:
SQLException
-
getTime
public Time getTime(int columnIndex) throws SQLException
- Specified by:
getTime
in interfaceResultSet
- Throws:
SQLException
-
getTimestamp
public Timestamp getTimestamp(int columnIndex) throws SQLException
- Specified by:
getTimestamp
in interfaceResultSet
- Throws:
SQLException
-
getAsciiStream
public InputStream getAsciiStream(int columnIndex) throws SQLException
- Specified by:
getAsciiStream
in interfaceResultSet
- Throws:
SQLException
-
getUnicodeStream
public InputStream getUnicodeStream(int columnIndex) throws SQLException
- Specified by:
getUnicodeStream
in interfaceResultSet
- Throws:
SQLException
-
getBinaryStream
public InputStream getBinaryStream(int columnIndex) throws SQLException
- Specified by:
getBinaryStream
in interfaceResultSet
- Throws:
SQLException
-
getString
public String getString(String columnName) throws SQLException
- Specified by:
getString
in interfaceResultSet
- Throws:
SQLException
-
getBoolean
public boolean getBoolean(String columnName) throws SQLException
- Specified by:
getBoolean
in interfaceResultSet
- Throws:
SQLException
-
getByte
public byte getByte(String columnName) throws SQLException
- Specified by:
getByte
in interfaceResultSet
- Throws:
SQLException
-
getShort
public short getShort(String columnName) throws SQLException
- Specified by:
getShort
in interfaceResultSet
- Throws:
SQLException
-
getInt
public int getInt(String columnName) throws SQLException
- Specified by:
getInt
in interfaceResultSet
- Throws:
SQLException
-
getLong
public long getLong(String columnName) throws SQLException
- Specified by:
getLong
in interfaceResultSet
- Throws:
SQLException
-
getFloat
public float getFloat(String columnName) throws SQLException
- Specified by:
getFloat
in interfaceResultSet
- Throws:
SQLException
-
getDouble
public double getDouble(String columnName) throws SQLException
- Specified by:
getDouble
in interfaceResultSet
- Throws:
SQLException
-
getBigDecimal
public BigDecimal getBigDecimal(String columnName, int scale) throws SQLException
- Specified by:
getBigDecimal
in interfaceResultSet
- Throws:
SQLException
-
getBytes
public byte[] getBytes(String columnName) throws SQLException
- Specified by:
getBytes
in interfaceResultSet
- Throws:
SQLException
-
getDate
public Date getDate(String columnName) throws SQLException
- Specified by:
getDate
in interfaceResultSet
- Throws:
SQLException
-
getTime
public Time getTime(String columnName) throws SQLException
- Specified by:
getTime
in interfaceResultSet
- Throws:
SQLException
-
getTimestamp
public Timestamp getTimestamp(String columnName) throws SQLException
- Specified by:
getTimestamp
in interfaceResultSet
- Throws:
SQLException
-
getAsciiStream
public InputStream getAsciiStream(String columnName) throws SQLException
- Specified by:
getAsciiStream
in interfaceResultSet
- Throws:
SQLException
-
getUnicodeStream
public InputStream getUnicodeStream(String columnName) throws SQLException
- Specified by:
getUnicodeStream
in interfaceResultSet
- Throws:
SQLException
-
getBinaryStream
public InputStream getBinaryStream(String columnName) throws SQLException
- Specified by:
getBinaryStream
in interfaceResultSet
- Throws:
SQLException
-
getWarnings
public SQLWarning getWarnings() throws SQLException
- Specified by:
getWarnings
in interfaceResultSet
- Throws:
SQLException
-
clearWarnings
public void clearWarnings() throws SQLException
- Specified by:
clearWarnings
in interfaceResultSet
- Throws:
SQLException
-
addWarning
protected void addWarning(SQLWarning warnings)
-
getCursorName
public String getCursorName() throws SQLException
- Specified by:
getCursorName
in interfaceResultSet
- Throws:
SQLException
-
getObject
public Object getObject(int columnIndex) throws SQLException
- Specified by:
getObject
in interfaceResultSet
- Throws:
SQLException
-
getObject
public Object getObject(String columnName) throws SQLException
- Specified by:
getObject
in interfaceResultSet
- Throws:
SQLException
-
findColumn
public int findColumn(String columnName) throws SQLException
- Specified by:
findColumn
in 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 SQLException
Checks that the result set is not closed, it's positioned on a valid row and that the given column number is valid. Also updates thewasNullFlag
to 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:
updateRef
in interfaceResultSet
- Throws:
SQLException
-
updateRef
public void updateRef(String columnName, Ref x) throws SQLException
- Specified by:
updateRef
in interfaceResultSet
- Throws:
SQLException
-
updateBlob
public void updateBlob(int columnIndex, Blob x) throws SQLException
- Specified by:
updateBlob
in interfaceResultSet
- Throws:
SQLException
-
updateBlob
public void updateBlob(String columnName, Blob x) throws SQLException
- Specified by:
updateBlob
in interfaceResultSet
- Throws:
SQLException
-
updateClob
public void updateClob(int columnIndex, Clob x) throws SQLException
- Specified by:
updateClob
in interfaceResultSet
- Throws:
SQLException
-
updateClob
public void updateClob(String columnName, Clob x) throws SQLException
- Specified by:
updateClob
in interfaceResultSet
- Throws:
SQLException
-
updateArray
public void updateArray(int columnIndex, Array x) throws SQLException
- Specified by:
updateArray
in interfaceResultSet
- Throws:
SQLException
-
updateArray
public void updateArray(String columnName, Array x) throws SQLException
- Specified by:
updateArray
in interfaceResultSet
- Throws:
SQLException
-
getObject
public <T> T getObject(int columnIndex, Class<T> type) throws SQLException
- Specified by:
getObject
in interfaceResultSet
- Throws:
SQLException
-
getObject
public <T> T getObject(String columnLabel, Class<T> type) throws SQLException
- Specified by:
getObject
in interfaceResultSet
- Throws:
SQLException
-
getObject
public Object getObject(String s, Map<String,Class<?>> map) throws SQLException
- Specified by:
getObject
in interfaceResultSet
- Throws:
SQLException
-
getObject
public Object getObject(int i, Map<String,Class<?>> map) throws SQLException
- Specified by:
getObject
in interfaceResultSet
- Throws:
SQLException
-
updateObject
public void updateObject(int columnIndex, Object x, SQLType targetSqlType, int scaleOrLength) throws SQLException
- Specified by:
updateObject
in interfaceResultSet
- Throws:
SQLException
-
updateObject
public void updateObject(String columnLabel, Object x, SQLType targetSqlType, int scaleOrLength) throws SQLException
- Specified by:
updateObject
in interfaceResultSet
- Throws:
SQLException
-
updateObject
public void updateObject(int columnIndex, Object x, SQLType targetSqlType) throws SQLException
- Specified by:
updateObject
in interfaceResultSet
- Throws:
SQLException
-
updateObject
public void updateObject(String columnLabel, Object x, SQLType targetSqlType) throws SQLException
- Specified by:
updateObject
in interfaceResultSet
- Throws:
SQLException
-
getRowId
public RowId getRowId(int columnIndex) throws SQLException
- Specified by:
getRowId
in interfaceResultSet
- Throws:
SQLException
-
getRowId
public RowId getRowId(String columnName) throws SQLException
- Specified by:
getRowId
in interfaceResultSet
- Throws:
SQLException
-
updateRowId
public void updateRowId(int columnIndex, RowId x) throws SQLException
- Specified by:
updateRowId
in interfaceResultSet
- Throws:
SQLException
-
updateRowId
public void updateRowId(String columnName, RowId x) throws SQLException
- Specified by:
updateRowId
in interfaceResultSet
- Throws:
SQLException
-
getHoldability
public int getHoldability() throws SQLException
- Specified by:
getHoldability
in interfaceResultSet
- Throws:
SQLException
-
isClosed
public boolean isClosed() throws SQLException
- Specified by:
isClosed
in interfaceResultSet
- Throws:
SQLException
-
updateNString
public void updateNString(int columnIndex, String nString) throws SQLException
- Specified by:
updateNString
in interfaceResultSet
- Throws:
SQLException
-
updateNString
public void updateNString(String columnName, String nString) throws SQLException
- Specified by:
updateNString
in interfaceResultSet
- Throws:
SQLException
-
updateNClob
public void updateNClob(int columnIndex, NClob nClob) throws SQLException
- Specified by:
updateNClob
in interfaceResultSet
- Throws:
SQLException
-
updateNClob
public void updateNClob(String columnName, NClob nClob) throws SQLException
- Specified by:
updateNClob
in interfaceResultSet
- Throws:
SQLException
-
updateNClob
public void updateNClob(int columnIndex, Reader reader) throws SQLException
- Specified by:
updateNClob
in interfaceResultSet
- Throws:
SQLException
-
updateNClob
public void updateNClob(String columnName, Reader reader) throws SQLException
- Specified by:
updateNClob
in interfaceResultSet
- Throws:
SQLException
-
updateNClob
public void updateNClob(int columnIndex, Reader reader, long length) throws SQLException
- Specified by:
updateNClob
in interfaceResultSet
- Throws:
SQLException
-
updateNClob
public void updateNClob(String columnName, Reader reader, long length) throws SQLException
- Specified by:
updateNClob
in interfaceResultSet
- Throws:
SQLException
-
getNClob
public NClob getNClob(int columnIndex) throws SQLException
- Specified by:
getNClob
in interfaceResultSet
- Throws:
SQLException
-
getNClob
public NClob getNClob(String columnName) throws SQLException
- Specified by:
getNClob
in interfaceResultSet
- Throws:
SQLException
-
updateBlob
public void updateBlob(int columnIndex, InputStream inputStream, long length) throws SQLException
- Specified by:
updateBlob
in interfaceResultSet
- Throws:
SQLException
-
updateBlob
public void updateBlob(String columnName, InputStream inputStream, long length) throws SQLException
- Specified by:
updateBlob
in interfaceResultSet
- Throws:
SQLException
-
updateBlob
public void updateBlob(int columnIndex, InputStream inputStream) throws SQLException
- Specified by:
updateBlob
in interfaceResultSet
- Throws:
SQLException
-
updateBlob
public void updateBlob(String columnName, InputStream inputStream) throws SQLException
- Specified by:
updateBlob
in interfaceResultSet
- Throws:
SQLException
-
updateClob
public void updateClob(int columnIndex, Reader reader, long length) throws SQLException
- Specified by:
updateClob
in interfaceResultSet
- Throws:
SQLException
-
updateClob
public void updateClob(String columnName, Reader reader, long length) throws SQLException
- Specified by:
updateClob
in interfaceResultSet
- Throws:
SQLException
-
updateClob
public void updateClob(int columnIndex, Reader reader) throws SQLException
- Specified by:
updateClob
in interfaceResultSet
- Throws:
SQLException
-
updateClob
public void updateClob(String columnName, Reader reader) throws SQLException
- Specified by:
updateClob
in interfaceResultSet
- Throws:
SQLException
-
getSQLXML
public SQLXML getSQLXML(int columnIndex) throws SQLException
- Specified by:
getSQLXML
in interfaceResultSet
- Throws:
SQLException
-
getSQLXML
public SQLXML getSQLXML(String columnName) throws SQLException
- Specified by:
getSQLXML
in interfaceResultSet
- Throws:
SQLException
-
updateSQLXML
public void updateSQLXML(int columnIndex, SQLXML xmlObject) throws SQLException
- Specified by:
updateSQLXML
in interfaceResultSet
- Throws:
SQLException
-
updateSQLXML
public void updateSQLXML(String columnName, SQLXML xmlObject) throws SQLException
- Specified by:
updateSQLXML
in interfaceResultSet
- Throws:
SQLException
-
getNString
public String getNString(int columnIndex) throws SQLException
- Specified by:
getNString
in interfaceResultSet
- Throws:
SQLException
-
getNString
public String getNString(String columnName) throws SQLException
- Specified by:
getNString
in interfaceResultSet
- Throws:
SQLException
-
getNCharacterStream
public Reader getNCharacterStream(int columnIndex) throws SQLException
- Specified by:
getNCharacterStream
in interfaceResultSet
- Throws:
SQLException
-
getNCharacterStream
public Reader getNCharacterStream(String columnName) throws SQLException
- Specified by:
getNCharacterStream
in 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:
updateNCharacterStream
in interfaceResultSet
- Throws:
SQLException
-
updateNCharacterStream
public void updateNCharacterStream(String columnName, Reader x) throws SQLException
- Specified by:
updateNCharacterStream
in interfaceResultSet
- Throws:
SQLException
-
updateNCharacterStream
public void updateNCharacterStream(int columnIndex, Reader x, long length) throws SQLException
- Specified by:
updateNCharacterStream
in interfaceResultSet
- Throws:
SQLException
-
updateNCharacterStream
public void updateNCharacterStream(String columnName, Reader x, long length) throws SQLException
- Specified by:
updateNCharacterStream
in interfaceResultSet
- Throws:
SQLException
-
updateCharacterStream
public void updateCharacterStream(int columnIndex, Reader reader, long length) throws SQLException
- Specified by:
updateCharacterStream
in interfaceResultSet
- Throws:
SQLException
-
updateCharacterStream
public void updateCharacterStream(String columnName, Reader reader, long length) throws SQLException
- Specified by:
updateCharacterStream
in interfaceResultSet
- Throws:
SQLException
-
updateCharacterStream
public void updateCharacterStream(int columnIndex, Reader reader) throws SQLException
- Specified by:
updateCharacterStream
in interfaceResultSet
- Throws:
SQLException
-
updateCharacterStream
public void updateCharacterStream(String columnName, Reader reader) throws SQLException
- Specified by:
updateCharacterStream
in interfaceResultSet
- Throws:
SQLException
-
updateBinaryStream
public void updateBinaryStream(int columnIndex, InputStream inputStream, long length) throws SQLException
- Specified by:
updateBinaryStream
in interfaceResultSet
- Throws:
SQLException
-
updateBinaryStream
public void updateBinaryStream(String columnName, InputStream inputStream, long length) throws SQLException
- Specified by:
updateBinaryStream
in interfaceResultSet
- Throws:
SQLException
-
updateBinaryStream
public void updateBinaryStream(int columnIndex, InputStream inputStream) throws SQLException
- Specified by:
updateBinaryStream
in interfaceResultSet
- Throws:
SQLException
-
updateBinaryStream
public void updateBinaryStream(String columnName, InputStream inputStream) throws SQLException
- Specified by:
updateBinaryStream
in interfaceResultSet
- Throws:
SQLException
-
updateAsciiStream
public void updateAsciiStream(int columnIndex, InputStream inputStream, long length) throws SQLException
- Specified by:
updateAsciiStream
in interfaceResultSet
- Throws:
SQLException
-
updateAsciiStream
public void updateAsciiStream(String columnName, InputStream inputStream, long length) throws SQLException
- Specified by:
updateAsciiStream
in interfaceResultSet
- Throws:
SQLException
-
updateAsciiStream
public void updateAsciiStream(int columnIndex, InputStream inputStream) throws SQLException
- Specified by:
updateAsciiStream
in interfaceResultSet
- Throws:
SQLException
-
updateAsciiStream
public void updateAsciiStream(String columnName, InputStream inputStream) throws SQLException
- Specified by:
updateAsciiStream
in interfaceResultSet
- Throws:
SQLException
-
isWrapperFor
public boolean isWrapperFor(Class<?> iface) throws SQLException
- Specified by:
isWrapperFor
in interfaceWrapper
- Throws:
SQLException
-
unwrap
public <T> T unwrap(Class<T> iface) throws SQLException
- Specified by:
unwrap
in interfaceWrapper
- Throws:
SQLException
-
-