Class PgResultSet
- java.lang.Object
-
- org.postgresql.jdbc.PgResultSet
-
- All Implemented Interfaces:
java.lang.AutoCloseable
,java.sql.ResultSet
,java.sql.Wrapper
,PGRefCursorResultSet
public class PgResultSet extends java.lang.Object implements java.sql.ResultSet, PGRefCursorResultSet
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description class
PgResultSet.CursorResultHandler
(package private) static class
PgResultSet.NullObject
private class
PgResultSet.PrimaryKey
-
Field Summary
Fields Modifier and Type Field Description protected boolean
adaptiveFetch
private static java.math.BigInteger
BYTEMAX
private static java.math.BigInteger
BYTEMIN
private java.util.Map<java.lang.String,java.lang.Integer>
columnNameIndexMap
protected BaseConnection
connection
protected int
currentRow
protected ResultCursor
cursor
private java.util.TimeZone
defaultTimeZone
private java.sql.PreparedStatement
deleteStatement
private boolean
doingUpdates
private static java.lang.NumberFormatException
FAST_NUMBER_FAILED
A dummy exception thrown when fast byte[] to number parsing fails and no value can be returned.private int
fetchdirection
protected int
fetchSize
protected Field[]
fields
private static java.math.BigInteger
INTMAX
private static java.math.BigInteger
INTMIN
protected int
lastUsedFetchSize
private static java.time.LocalDate
LOCAL_DATE_EPOCH
private static double
LONG_MAX_DOUBLE
private static float
LONG_MAX_FLOAT
private static double
LONG_MIN_DOUBLE
private static float
LONG_MIN_FLOAT
private static java.math.BigInteger
LONGMAX
private static java.math.BigInteger
LONGMIN
protected int
maxFieldSize
protected int
maxRows
protected boolean
onInsertRow
private java.lang.String
onlyTable
protected Query
originalQuery
private java.util.List<PgResultSet.PrimaryKey>
primaryKeys
private java.lang.String
refCursorName
private int
resultsetconcurrency
private int
resultsettype
private Tuple
rowBuffer
protected int
rowOffset
protected java.util.List<Tuple>
rows
private java.sql.ResultSetMetaData
rsMetaData
private static java.math.BigInteger
SHORTMAX
private static java.math.BigInteger
SHORTMIN
private boolean
singleTable
protected BaseStatement
statement
private java.lang.String
tableName
protected Tuple
thisRow
private TimestampUtils
timestampUtils
private boolean
updateable
private java.util.HashMap<java.lang.String,java.lang.Object>
updateValues
private boolean
usingOID
protected java.sql.SQLWarning
warnings
protected boolean
wasNullFlag
True if the last obtained column value was SQL NULL as specified bywasNull()
.
-
Constructor Summary
Constructors Constructor Description PgResultSet(Query originalQuery, BaseStatement statement, Field[] fields, java.util.List<Tuple> tuples, ResultCursor cursor, int maxRows, int maxFieldSize, int rsType, int rsConcurrency, int rsHoldability, boolean adaptiveFetch)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
absolute(int index)
(package private) void
addRows(java.util.List<Tuple> tuples)
Used to add rows to an already existing ResultSet that exactly match the existing rows.protected void
addWarning(java.sql.SQLWarning warnings)
void
afterLast()
void
beforeFirst()
void
cancelRowUpdates()
protected void
checkClosed()
protected void
checkColumnIndex(int column)
private void
checkScrollable()
private void
checkUpdateable()
private void
clearRowBuffer(boolean copyCurrentRow)
void
clearWarnings()
void
close()
protected void
closeInternally()
private void
closeRefCursor()
Closes<unnamed portal 1>
if no more fetch calls expected (cursor==null
)static java.util.Map<java.lang.String,java.lang.Integer>
createColumnNameIndexMap(Field[] fields, boolean isSanitiserDisabled)
protected java.sql.ResultSetMetaData
createMetaData()
void
deleteRow()
int
findColumn(java.lang.String columnName)
private int
findColumnIndex(java.lang.String columnName)
boolean
first()
boolean
getAdaptiveFetch()
Get state of adaptive fetch for resultSet.java.sql.Array
getArray(int i)
java.sql.Array
getArray(java.lang.String colName)
java.io.InputStream
getAsciiStream(int columnIndex)
java.io.InputStream
getAsciiStream(java.lang.String columnName)
java.math.BigDecimal
getBigDecimal(int columnIndex)
java.math.BigDecimal
getBigDecimal(int columnIndex, int scale)
java.math.BigDecimal
getBigDecimal(java.lang.String columnName)
java.math.BigDecimal
getBigDecimal(java.lang.String columnName, int scale)
java.io.InputStream
getBinaryStream(int columnIndex)
java.io.InputStream
getBinaryStream(java.lang.String columnName)
java.sql.Blob
getBlob(int i)
java.sql.Blob
getBlob(java.lang.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(java.lang.String columnName)
byte
getByte(int columnIndex)
byte
getByte(java.lang.String columnName)
byte[]
getBytes(int columnIndex)
byte[]
getBytes(java.lang.String columnName)
java.io.Reader
getCharacterStream(int i)
java.io.Reader
getCharacterStream(java.lang.String columnName)
java.sql.Clob
getClob(int i)
java.sql.Clob
getClob(java.lang.String columnName)
int
getColumnOID(int field)
Returns the OID of a field.int
getConcurrency()
java.lang.String
getCursorName()
java.sql.Date
getDate(int columnIndex)
java.sql.Date
getDate(int i, java.util.Calendar cal)
java.sql.Date
getDate(java.lang.String columnName)
java.sql.Date
getDate(java.lang.String c, java.util.Calendar cal)
private java.util.Calendar
getDefaultCalendar()
double
getDouble(int columnIndex)
double
getDouble(java.lang.String columnName)
private java.math.BigDecimal
getFastBigDecimal(byte[] bytes)
Optimised byte[] to number parser.private long
getFastLong(byte[] bytes, long minVal, long maxVal)
Optimised byte[] to number parser.int
getFetchDirection()
int
getFetchSize()
java.lang.String
getFixedString(int col)
This is used to fix get*() methods on Money fields.float
getFloat(int columnIndex)
float
getFloat(java.lang.String columnName)
int
getHoldability()
int
getInt(int columnIndex)
int
getInt(java.lang.String columnName)
int
getLastUsedFetchSize()
Get fetch size used during last fetch.private java.time.LocalDate
getLocalDate(int i)
private java.time.LocalDateTime
getLocalDateTime(int i)
private java.time.LocalTime
getLocalTime(int i)
long
getLong(int columnIndex)
long
getLong(java.lang.String columnName)
java.sql.ResultSetMetaData
getMetaData()
java.io.Reader
getNCharacterStream(int columnIndex)
java.io.Reader
getNCharacterStream(java.lang.String columnName)
java.sql.NClob
getNClob(int columnIndex)
java.sql.NClob
getNClob(java.lang.String columnName)
java.lang.String
getNString(int columnIndex)
java.lang.String
getNString(java.lang.String columnName)
private java.lang.Number
getNumeric(int columnIndex, int scale, boolean allowNaN)
java.lang.Object
getObject(int columnIndex)
<T> T
getObject(int columnIndex, java.lang.Class<T> type)
java.lang.Object
getObject(int i, java.util.Map<java.lang.String,java.lang.Class<?>> map)
java.lang.Object
getObject(java.lang.String columnName)
<T> T
getObject(java.lang.String columnLabel, java.lang.Class<T> type)
java.lang.Object
getObject(java.lang.String s, java.util.Map<java.lang.String,java.lang.Class<?>> map)
java.lang.Object
getObjectImpl(int i, java.util.Map<java.lang.String,java.lang.Class<?>> map)
java.lang.Object
getObjectImpl(java.lang.String columnName, java.util.Map<java.lang.String,java.lang.Class<?>> map)
private java.time.OffsetDateTime
getOffsetDateTime(int i)
private java.time.OffsetTime
getOffsetTime(int i)
BaseStatement
getPGStatement()
protected java.lang.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.java.sql.Ref
getRef(int i)
java.sql.Ref
getRef(java.lang.String columnName)
java.lang.String
getRefCursor()
int
getRow()
java.sql.RowId
getRowId(int columnIndex)
java.sql.RowId
getRowId(java.lang.String columnName)
short
getShort(int columnIndex)
short
getShort(java.lang.String columnName)
protected int
getSQLType(int column)
java.sql.SQLXML
getSQLXML(int columnIndex)
java.sql.SQLXML
getSQLXML(java.lang.String columnName)
java.sql.Statement
getStatement()
java.lang.String
getString(int columnIndex)
java.lang.String
getString(java.lang.String columnName)
java.sql.Time
getTime(int columnIndex)
java.sql.Time
getTime(int i, java.util.Calendar cal)
java.sql.Time
getTime(java.lang.String columnName)
java.sql.Time
getTime(java.lang.String c, java.util.Calendar cal)
java.sql.Timestamp
getTimestamp(int columnIndex)
java.sql.Timestamp
getTimestamp(int i, java.util.Calendar cal)
java.sql.Timestamp
getTimestamp(java.lang.String columnName)
java.sql.Timestamp
getTimestamp(java.lang.String c, java.util.Calendar cal)
private TimestampUtils
getTimestampUtils()
int
getType()
java.io.InputStream
getUnicodeStream(int columnIndex)
java.io.InputStream
getUnicodeStream(java.lang.String columnName)
java.net.URL
getURL(int columnIndex)
java.net.URL
getURL(java.lang.String columnName)
protected java.lang.Object
getUUID(byte[] data)
protected java.lang.Object
getUUID(java.lang.String data)
java.sql.SQLWarning
getWarnings()
private void
initRowBuffer()
private void
initSqlType(Field field)
void
insertRow()
protected java.lang.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()
private boolean
isColumnTrimmable(int columnIndex)
boolean
isFirst()
boolean
isLast()
protected boolean
isResultSetClosed()
(package private) boolean
isUpdateable()
Is this ResultSet updateable?boolean
isWrapperFor(java.lang.Class<?> iface)
boolean
last()
protected java.sql.Array
makeArray(int oid, byte[] value)
protected java.sql.Array
makeArray(int oid, java.lang.String value)
protected java.sql.Blob
makeBlob(long oid)
protected java.sql.Clob
makeClob(long oid)
void
moveToCurrentRow()
void
moveToInsertRow()
boolean
next()
private void
parseQuery()
boolean
previous()
static java.lang.String[]
quotelessTableName(java.lang.String fullname)
Cracks out the table name and schema (if it exists) from a fully qualified table name.private double
readDoubleValue(byte[] bytes, int oid, java.lang.String targetType)
Converts any numeric binary field to double value.private long
readLongValue(byte[] bytes, int oid, long minVal, long maxVal, java.lang.String targetType)
Converts any numeric binary field to long value.void
refreshRow()
boolean
relative(int rows)
boolean
rowDeleted()
boolean
rowInserted()
boolean
rowUpdated()
private java.math.BigDecimal
scaleBigDecimal(java.math.BigDecimal val, int scale)
void
setAdaptiveFetch(boolean adaptiveFetch)
Turn on/off adaptive fetch for ResultSet.void
setFetchDirection(int direction)
void
setFetchSize(int rows)
private void
setRefCursor(java.lang.String refCursorName)
private void
setRowBufferColumn(Tuple rowBuffer, int columnIndex, java.lang.Object valueObject)
static java.math.BigDecimal
toBigDecimal(java.lang.String s)
java.math.BigDecimal
toBigDecimal(java.lang.String s, int scale)
static double
toDouble(java.lang.String s)
static float
toFloat(java.lang.String s)
static int
toInt(java.lang.String s)
static long
toLong(java.lang.String s)
static short
toShort(java.lang.String s)
private byte[]
trimBytes(int columnIndex, byte[] bytes)
private java.lang.String
trimMoney(java.lang.String s)
private java.lang.String
trimString(int columnIndex, java.lang.String string)
<T> T
unwrap(java.lang.Class<T> iface)
void
updateArray(int columnIndex, java.sql.Array x)
void
updateArray(java.lang.String columnName, java.sql.Array x)
void
updateAsciiStream(int columnIndex, java.io.InputStream inputStream)
void
updateAsciiStream(int columnIndex, java.io.InputStream x, int length)
void
updateAsciiStream(int columnIndex, java.io.InputStream inputStream, long length)
void
updateAsciiStream(java.lang.String columnName, java.io.InputStream inputStream)
void
updateAsciiStream(java.lang.String columnName, java.io.InputStream x, int length)
void
updateAsciiStream(java.lang.String columnName, java.io.InputStream inputStream, long length)
void
updateBigDecimal(int columnIndex, java.math.BigDecimal x)
void
updateBigDecimal(java.lang.String columnName, java.math.BigDecimal x)
void
updateBinaryStream(int columnIndex, java.io.InputStream inputStream)
void
updateBinaryStream(int columnIndex, java.io.InputStream x, int length)
void
updateBinaryStream(int columnIndex, java.io.InputStream inputStream, long length)
void
updateBinaryStream(java.lang.String columnName, java.io.InputStream inputStream)
void
updateBinaryStream(java.lang.String columnName, java.io.InputStream x, int length)
void
updateBinaryStream(java.lang.String columnName, java.io.InputStream inputStream, long length)
void
updateBlob(int columnIndex, java.io.InputStream inputStream)
void
updateBlob(int columnIndex, java.io.InputStream inputStream, long length)
void
updateBlob(int columnIndex, java.sql.Blob x)
void
updateBlob(java.lang.String columnName, java.io.InputStream inputStream)
void
updateBlob(java.lang.String columnName, java.io.InputStream inputStream, long length)
void
updateBlob(java.lang.String columnName, java.sql.Blob x)
void
updateBoolean(int columnIndex, boolean x)
void
updateBoolean(java.lang.String columnName, boolean x)
void
updateByte(int columnIndex, byte x)
void
updateByte(java.lang.String columnName, byte x)
void
updateBytes(int columnIndex, byte[] x)
void
updateBytes(java.lang.String columnName, byte[] x)
void
updateCharacterStream(int columnIndex, java.io.Reader reader)
void
updateCharacterStream(int columnIndex, java.io.Reader x, int length)
void
updateCharacterStream(int columnIndex, java.io.Reader reader, long length)
void
updateCharacterStream(java.lang.String columnName, java.io.Reader reader)
void
updateCharacterStream(java.lang.String columnName, java.io.Reader reader, int length)
void
updateCharacterStream(java.lang.String columnName, java.io.Reader reader, long length)
void
updateClob(int columnIndex, java.io.Reader reader)
void
updateClob(int columnIndex, java.io.Reader reader, long length)
void
updateClob(int columnIndex, java.sql.Clob x)
void
updateClob(java.lang.String columnName, java.io.Reader reader)
void
updateClob(java.lang.String columnName, java.io.Reader reader, long length)
void
updateClob(java.lang.String columnName, java.sql.Clob x)
void
updateDate(int columnIndex, java.sql.Date x)
void
updateDate(java.lang.String columnName, java.sql.Date x)
void
updateDouble(int columnIndex, double x)
void
updateDouble(java.lang.String columnName, double x)
void
updateFloat(int columnIndex, float x)
void
updateFloat(java.lang.String columnName, float x)
void
updateInt(int columnIndex, int x)
void
updateInt(java.lang.String columnName, int x)
void
updateLong(int columnIndex, long x)
void
updateLong(java.lang.String columnName, long x)
void
updateNCharacterStream(int columnIndex, java.io.Reader x)
void
updateNCharacterStream(int columnIndex, java.io.Reader x, int length)
void
updateNCharacterStream(int columnIndex, java.io.Reader x, long length)
void
updateNCharacterStream(java.lang.String columnName, java.io.Reader x)
void
updateNCharacterStream(java.lang.String columnName, java.io.Reader x, int length)
void
updateNCharacterStream(java.lang.String columnName, java.io.Reader x, long length)
void
updateNClob(int columnIndex, java.io.Reader reader)
void
updateNClob(int columnIndex, java.io.Reader reader, long length)
void
updateNClob(int columnIndex, java.sql.NClob nClob)
void
updateNClob(java.lang.String columnName, java.io.Reader reader)
void
updateNClob(java.lang.String columnName, java.io.Reader reader, long length)
void
updateNClob(java.lang.String columnName, java.sql.NClob nClob)
void
updateNString(int columnIndex, java.lang.String nString)
void
updateNString(java.lang.String columnName, java.lang.String nString)
void
updateNull(int columnIndex)
void
updateNull(java.lang.String columnName)
void
updateObject(int columnIndex, java.lang.Object x)
void
updateObject(int columnIndex, java.lang.Object x, int scale)
void
updateObject(int columnIndex, java.lang.Object x, java.sql.SQLType targetSqlType)
void
updateObject(int columnIndex, java.lang.Object x, java.sql.SQLType targetSqlType, int scaleOrLength)
void
updateObject(java.lang.String columnName, java.lang.Object x)
void
updateObject(java.lang.String columnName, java.lang.Object x, int scale)
void
updateObject(java.lang.String columnLabel, java.lang.Object x, java.sql.SQLType targetSqlType)
void
updateObject(java.lang.String columnLabel, java.lang.Object x, java.sql.SQLType targetSqlType, int scaleOrLength)
private void
updateQueryInsideAdaptiveFetchCache(boolean newAdaptiveFetch)
Update adaptive fetch cache during changing state of adaptive fetch inside ResultSet.void
updateRef(int columnIndex, java.sql.Ref x)
void
updateRef(java.lang.String columnName, java.sql.Ref x)
void
updateRow()
private void
updateRowBuffer(java.sql.PreparedStatement insertStatement, Tuple rowBuffer, java.util.HashMap<java.lang.String,java.lang.Object> updateValues)
void
updateRowId(int columnIndex, java.sql.RowId x)
void
updateRowId(java.lang.String columnName, java.sql.RowId x)
void
updateShort(int columnIndex, short x)
void
updateShort(java.lang.String columnName, short x)
void
updateSQLXML(int columnIndex, java.sql.SQLXML xmlObject)
void
updateSQLXML(java.lang.String columnName, java.sql.SQLXML xmlObject)
void
updateString(int columnIndex, java.lang.String x)
void
updateString(java.lang.String columnName, java.lang.String x)
void
updateTime(int columnIndex, java.sql.Time x)
void
updateTime(java.lang.String columnName, java.sql.Time x)
void
updateTimestamp(int columnIndex, java.sql.Timestamp x)
void
updateTimestamp(java.lang.String columnName, java.sql.Timestamp x)
protected void
updateValue(int columnIndex, java.lang.Object value)
protected PgResultSet
upperCaseFieldLabels()
This is here to be used by metadata functions to make all column labels upper case.boolean
wasNull()
-
-
-
Field Detail
-
updateable
private boolean updateable
-
doingUpdates
private boolean doingUpdates
-
updateValues
private java.util.HashMap<java.lang.String,java.lang.Object> updateValues
-
usingOID
private boolean usingOID
-
primaryKeys
private java.util.List<PgResultSet.PrimaryKey> primaryKeys
-
singleTable
private boolean singleTable
-
onlyTable
private java.lang.String onlyTable
-
tableName
private java.lang.String tableName
-
deleteStatement
private java.sql.PreparedStatement deleteStatement
-
resultsettype
private final int resultsettype
-
resultsetconcurrency
private final int resultsetconcurrency
-
fetchdirection
private int fetchdirection
-
defaultTimeZone
private java.util.TimeZone defaultTimeZone
-
connection
protected final BaseConnection connection
-
statement
protected final BaseStatement statement
-
fields
protected final Field[] fields
-
originalQuery
protected final Query originalQuery
-
timestampUtils
private TimestampUtils timestampUtils
-
maxRows
protected final int maxRows
-
maxFieldSize
protected final int maxFieldSize
-
rows
protected java.util.List<Tuple> rows
-
currentRow
protected int currentRow
-
rowOffset
protected int rowOffset
-
thisRow
protected Tuple thisRow
-
warnings
protected java.sql.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
-
rowBuffer
private Tuple rowBuffer
-
fetchSize
protected int fetchSize
-
lastUsedFetchSize
protected int lastUsedFetchSize
-
adaptiveFetch
protected boolean adaptiveFetch
-
cursor
protected ResultCursor cursor
-
columnNameIndexMap
private java.util.Map<java.lang.String,java.lang.Integer> columnNameIndexMap
-
rsMetaData
private java.sql.ResultSetMetaData rsMetaData
-
LOCAL_DATE_EPOCH
private static final java.time.LocalDate LOCAL_DATE_EPOCH
-
refCursorName
private java.lang.String refCursorName
-
BYTEMAX
private static final java.math.BigInteger BYTEMAX
-
BYTEMIN
private static final java.math.BigInteger BYTEMIN
-
FAST_NUMBER_FAILED
private static final java.lang.NumberFormatException FAST_NUMBER_FAILED
A dummy exception thrown when fast byte[] to number parsing fails and no value can be returned. The exact stack trace does not matter because the exception is always caught and is not visible to users.
-
SHORTMAX
private static final java.math.BigInteger SHORTMAX
-
SHORTMIN
private static final java.math.BigInteger SHORTMIN
-
INTMAX
private static final java.math.BigInteger INTMAX
-
INTMIN
private static final java.math.BigInteger INTMIN
-
LONGMAX
private static final java.math.BigInteger LONGMAX
-
LONGMIN
private static final java.math.BigInteger LONGMIN
-
LONG_MAX_FLOAT
private static final float LONG_MAX_FLOAT
-
LONG_MIN_FLOAT
private static final float LONG_MIN_FLOAT
-
LONG_MAX_DOUBLE
private static final double LONG_MAX_DOUBLE
-
LONG_MIN_DOUBLE
private static final double LONG_MIN_DOUBLE
-
-
Constructor Detail
-
PgResultSet
PgResultSet(Query originalQuery, BaseStatement statement, Field[] fields, java.util.List<Tuple> tuples, ResultCursor cursor, int maxRows, int maxFieldSize, int rsType, int rsConcurrency, int rsHoldability, boolean adaptiveFetch) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
-
Method Detail
-
createMetaData
protected java.sql.ResultSetMetaData createMetaData() throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
getMetaData
public java.sql.ResultSetMetaData getMetaData() throws java.sql.SQLException
- Specified by:
getMetaData
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getURL
public java.net.URL getURL(int columnIndex) throws java.sql.SQLException
- Specified by:
getURL
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getURL
public java.net.URL getURL(java.lang.String columnName) throws java.sql.SQLException
- Specified by:
getURL
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
internalGetObject
protected java.lang.Object internalGetObject(int columnIndex, Field field) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
checkScrollable
private void checkScrollable() throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
absolute
public boolean absolute(int index) throws java.sql.SQLException
- Specified by:
absolute
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
afterLast
public void afterLast() throws java.sql.SQLException
- Specified by:
afterLast
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
beforeFirst
public void beforeFirst() throws java.sql.SQLException
- Specified by:
beforeFirst
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
first
public boolean first() throws java.sql.SQLException
- Specified by:
first
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getArray
public java.sql.Array getArray(java.lang.String colName) throws java.sql.SQLException
- Specified by:
getArray
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
makeArray
protected java.sql.Array makeArray(int oid, byte[] value) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
makeArray
protected java.sql.Array makeArray(int oid, java.lang.String value) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
getArray
public java.sql.Array getArray(int i) throws java.sql.SQLException
- Specified by:
getArray
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getBigDecimal
public java.math.BigDecimal getBigDecimal(int columnIndex) throws java.sql.SQLException
- Specified by:
getBigDecimal
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getBigDecimal
public java.math.BigDecimal getBigDecimal(java.lang.String columnName) throws java.sql.SQLException
- Specified by:
getBigDecimal
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getBlob
public java.sql.Blob getBlob(java.lang.String columnName) throws java.sql.SQLException
- Specified by:
getBlob
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
makeBlob
protected java.sql.Blob makeBlob(long oid) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
getBlob
public java.sql.Blob getBlob(int i) throws java.sql.SQLException
- Specified by:
getBlob
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getCharacterStream
public java.io.Reader getCharacterStream(java.lang.String columnName) throws java.sql.SQLException
- Specified by:
getCharacterStream
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getCharacterStream
public java.io.Reader getCharacterStream(int i) throws java.sql.SQLException
- Specified by:
getCharacterStream
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getClob
public java.sql.Clob getClob(java.lang.String columnName) throws java.sql.SQLException
- Specified by:
getClob
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
makeClob
protected java.sql.Clob makeClob(long oid) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
getClob
public java.sql.Clob getClob(int i) throws java.sql.SQLException
- Specified by:
getClob
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getConcurrency
public int getConcurrency() throws java.sql.SQLException
- Specified by:
getConcurrency
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getDate
public java.sql.Date getDate(int i, java.util.Calendar cal) throws java.sql.SQLException
- Specified by:
getDate
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getTime
public java.sql.Time getTime(int i, java.util.Calendar cal) throws java.sql.SQLException
- Specified by:
getTime
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getTimestamp
public java.sql.Timestamp getTimestamp(int i, java.util.Calendar cal) throws java.sql.SQLException
- Specified by:
getTimestamp
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getOffsetDateTime
private java.time.OffsetDateTime getOffsetDateTime(int i) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
getOffsetTime
private java.time.OffsetTime getOffsetTime(int i) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
getLocalDateTime
private java.time.LocalDateTime getLocalDateTime(int i) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
getLocalDate
private java.time.LocalDate getLocalDate(int i) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
getLocalTime
private java.time.LocalTime getLocalTime(int i) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
getDate
public java.sql.Date getDate(java.lang.String c, java.util.Calendar cal) throws java.sql.SQLException
- Specified by:
getDate
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getTime
public java.sql.Time getTime(java.lang.String c, java.util.Calendar cal) throws java.sql.SQLException
- Specified by:
getTime
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getTimestamp
public java.sql.Timestamp getTimestamp(java.lang.String c, java.util.Calendar cal) throws java.sql.SQLException
- Specified by:
getTimestamp
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getFetchDirection
public int getFetchDirection() throws java.sql.SQLException
- Specified by:
getFetchDirection
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getObjectImpl
public java.lang.Object getObjectImpl(java.lang.String columnName, java.util.Map<java.lang.String,java.lang.Class<?>> map) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
getObjectImpl
public java.lang.Object getObjectImpl(int i, java.util.Map<java.lang.String,java.lang.Class<?>> map) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
getRef
public java.sql.Ref getRef(java.lang.String columnName) throws java.sql.SQLException
- Specified by:
getRef
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getRef
public java.sql.Ref getRef(int i) throws java.sql.SQLException
- Specified by:
getRef
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getRow
public int getRow() throws java.sql.SQLException
- Specified by:
getRow
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getStatement
public java.sql.Statement getStatement() throws java.sql.SQLException
- Specified by:
getStatement
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getType
public int getType() throws java.sql.SQLException
- Specified by:
getType
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
isAfterLast
public boolean isAfterLast() throws java.sql.SQLException
- Specified by:
isAfterLast
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
isBeforeFirst
public boolean isBeforeFirst() throws java.sql.SQLException
- Specified by:
isBeforeFirst
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
isFirst
public boolean isFirst() throws java.sql.SQLException
- Specified by:
isFirst
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
isLast
public boolean isLast() throws java.sql.SQLException
- Specified by:
isLast
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
last
public boolean last() throws java.sql.SQLException
- Specified by:
last
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
previous
public boolean previous() throws java.sql.SQLException
- Specified by:
previous
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
relative
public boolean relative(int rows) throws java.sql.SQLException
- Specified by:
relative
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
setFetchDirection
public void setFetchDirection(int direction) throws java.sql.SQLException
- Specified by:
setFetchDirection
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
cancelRowUpdates
public void cancelRowUpdates() throws java.sql.SQLException
- Specified by:
cancelRowUpdates
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
deleteRow
public void deleteRow() throws java.sql.SQLException
- Specified by:
deleteRow
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
insertRow
public void insertRow() throws java.sql.SQLException
- Specified by:
insertRow
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
moveToCurrentRow
public void moveToCurrentRow() throws java.sql.SQLException
- Specified by:
moveToCurrentRow
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
moveToInsertRow
public void moveToInsertRow() throws java.sql.SQLException
- Specified by:
moveToInsertRow
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
clearRowBuffer
private void clearRowBuffer(boolean copyCurrentRow) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
rowDeleted
public boolean rowDeleted() throws java.sql.SQLException
- Specified by:
rowDeleted
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
rowInserted
public boolean rowInserted() throws java.sql.SQLException
- Specified by:
rowInserted
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
rowUpdated
public boolean rowUpdated() throws java.sql.SQLException
- Specified by:
rowUpdated
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateAsciiStream
public void updateAsciiStream(int columnIndex, java.io.InputStream x, int length) throws java.sql.SQLException
- Specified by:
updateAsciiStream
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateBigDecimal
public void updateBigDecimal(int columnIndex, java.math.BigDecimal x) throws java.sql.SQLException
- Specified by:
updateBigDecimal
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateBinaryStream
public void updateBinaryStream(int columnIndex, java.io.InputStream x, int length) throws java.sql.SQLException
- Specified by:
updateBinaryStream
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateBoolean
public void updateBoolean(int columnIndex, boolean x) throws java.sql.SQLException
- Specified by:
updateBoolean
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateByte
public void updateByte(int columnIndex, byte x) throws java.sql.SQLException
- Specified by:
updateByte
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateBytes
public void updateBytes(int columnIndex, byte[] x) throws java.sql.SQLException
- Specified by:
updateBytes
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateCharacterStream
public void updateCharacterStream(int columnIndex, java.io.Reader x, int length) throws java.sql.SQLException
- Specified by:
updateCharacterStream
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateDate
public void updateDate(int columnIndex, java.sql.Date x) throws java.sql.SQLException
- Specified by:
updateDate
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateDouble
public void updateDouble(int columnIndex, double x) throws java.sql.SQLException
- Specified by:
updateDouble
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateFloat
public void updateFloat(int columnIndex, float x) throws java.sql.SQLException
- Specified by:
updateFloat
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateInt
public void updateInt(int columnIndex, int x) throws java.sql.SQLException
- Specified by:
updateInt
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateLong
public void updateLong(int columnIndex, long x) throws java.sql.SQLException
- Specified by:
updateLong
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateNull
public void updateNull(int columnIndex) throws java.sql.SQLException
- Specified by:
updateNull
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateObject
public void updateObject(int columnIndex, java.lang.Object x) throws java.sql.SQLException
- Specified by:
updateObject
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateObject
public void updateObject(int columnIndex, java.lang.Object x, int scale) throws java.sql.SQLException
- Specified by:
updateObject
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
refreshRow
public void refreshRow() throws java.sql.SQLException
- Specified by:
refreshRow
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateRow
public void updateRow() throws java.sql.SQLException
- Specified by:
updateRow
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateShort
public void updateShort(int columnIndex, short x) throws java.sql.SQLException
- Specified by:
updateShort
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateString
public void updateString(int columnIndex, java.lang.String x) throws java.sql.SQLException
- Specified by:
updateString
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateTime
public void updateTime(int columnIndex, java.sql.Time x) throws java.sql.SQLException
- Specified by:
updateTime
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateTimestamp
public void updateTimestamp(int columnIndex, java.sql.Timestamp x) throws java.sql.SQLException
- Specified by:
updateTimestamp
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateNull
public void updateNull(java.lang.String columnName) throws java.sql.SQLException
- Specified by:
updateNull
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateBoolean
public void updateBoolean(java.lang.String columnName, boolean x) throws java.sql.SQLException
- Specified by:
updateBoolean
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateByte
public void updateByte(java.lang.String columnName, byte x) throws java.sql.SQLException
- Specified by:
updateByte
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateShort
public void updateShort(java.lang.String columnName, short x) throws java.sql.SQLException
- Specified by:
updateShort
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateInt
public void updateInt(java.lang.String columnName, int x) throws java.sql.SQLException
- Specified by:
updateInt
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateLong
public void updateLong(java.lang.String columnName, long x) throws java.sql.SQLException
- Specified by:
updateLong
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateFloat
public void updateFloat(java.lang.String columnName, float x) throws java.sql.SQLException
- Specified by:
updateFloat
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateDouble
public void updateDouble(java.lang.String columnName, double x) throws java.sql.SQLException
- Specified by:
updateDouble
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateBigDecimal
public void updateBigDecimal(java.lang.String columnName, java.math.BigDecimal x) throws java.sql.SQLException
- Specified by:
updateBigDecimal
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateString
public void updateString(java.lang.String columnName, java.lang.String x) throws java.sql.SQLException
- Specified by:
updateString
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateBytes
public void updateBytes(java.lang.String columnName, byte[] x) throws java.sql.SQLException
- Specified by:
updateBytes
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateDate
public void updateDate(java.lang.String columnName, java.sql.Date x) throws java.sql.SQLException
- Specified by:
updateDate
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateTime
public void updateTime(java.lang.String columnName, java.sql.Time x) throws java.sql.SQLException
- Specified by:
updateTime
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateTimestamp
public void updateTimestamp(java.lang.String columnName, java.sql.Timestamp x) throws java.sql.SQLException
- Specified by:
updateTimestamp
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateAsciiStream
public void updateAsciiStream(java.lang.String columnName, java.io.InputStream x, int length) throws java.sql.SQLException
- Specified by:
updateAsciiStream
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateBinaryStream
public void updateBinaryStream(java.lang.String columnName, java.io.InputStream x, int length) throws java.sql.SQLException
- Specified by:
updateBinaryStream
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateCharacterStream
public void updateCharacterStream(java.lang.String columnName, java.io.Reader reader, int length) throws java.sql.SQLException
- Specified by:
updateCharacterStream
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateObject
public void updateObject(java.lang.String columnName, java.lang.Object x, int scale) throws java.sql.SQLException
- Specified by:
updateObject
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateObject
public void updateObject(java.lang.String columnName, java.lang.Object x) throws java.sql.SQLException
- Specified by:
updateObject
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
isUpdateable
boolean isUpdateable() throws java.sql.SQLException
Is this ResultSet updateable?- Throws:
java.sql.SQLException
-
setAdaptiveFetch
public void setAdaptiveFetch(boolean adaptiveFetch) throws java.sql.SQLException
Turn on/off adaptive fetch for ResultSet.- Parameters:
adaptiveFetch
- desired state of adaptive fetch.- Throws:
java.sql.SQLException
- exception returned if ResultSet is closed
-
updateQueryInsideAdaptiveFetchCache
private void updateQueryInsideAdaptiveFetchCache(boolean newAdaptiveFetch)
Update adaptive fetch cache during changing state of adaptive fetch inside ResultSet. Update inside AdaptiveFetchCache is required to collect data about max result row length for that query to compute adaptive fetch size.- Parameters:
newAdaptiveFetch
- new state of adaptive fetch
-
getAdaptiveFetch
public boolean getAdaptiveFetch() throws java.sql.SQLException
Get state of adaptive fetch for resultSet.- Returns:
- state of adaptive fetch (turned on or off)
- Throws:
java.sql.SQLException
- exception returned if ResultSet is closed
-
quotelessTableName
public static java.lang.String[] quotelessTableName(java.lang.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.
-
parseQuery
private void parseQuery()
-
setRowBufferColumn
private void setRowBufferColumn(Tuple rowBuffer, int columnIndex, java.lang.Object valueObject) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
updateRowBuffer
private void updateRowBuffer(java.sql.PreparedStatement insertStatement, Tuple rowBuffer, java.util.HashMap<java.lang.String,java.lang.Object> updateValues) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
getPGStatement
public BaseStatement getPGStatement()
-
getRefCursor
public java.lang.String getRefCursor()
- Specified by:
getRefCursor
in interfacePGRefCursorResultSet
- Returns:
- the name of the cursor.
-
setRefCursor
private void setRefCursor(java.lang.String refCursorName)
-
setFetchSize
public void setFetchSize(int rows) throws java.sql.SQLException
- Specified by:
setFetchSize
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getFetchSize
public int getFetchSize() throws java.sql.SQLException
- Specified by:
getFetchSize
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getLastUsedFetchSize
public int getLastUsedFetchSize() throws java.sql.SQLException
Get fetch size used during last fetch. Returned value can be useful if using adaptive fetch.- Returns:
- fetch size used during last fetch.
- Throws:
java.sql.SQLException
- exception returned if ResultSet is closed
-
next
public boolean next() throws java.sql.SQLException
- Specified by:
next
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
close
public void close() throws java.sql.SQLException
- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
closeInternally
protected void closeInternally() throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
closeRefCursor
private void closeRefCursor() throws java.sql.SQLException
Closes<unnamed portal 1>
if no more fetch calls expected (cursor==null
)- Throws:
java.sql.SQLException
- if portal close fails
-
wasNull
public boolean wasNull() throws java.sql.SQLException
- Specified by:
wasNull
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getString
public java.lang.String getString(int columnIndex) throws java.sql.SQLException
- Specified by:
getString
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getBoolean
public boolean getBoolean(int columnIndex) throws java.sql.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 interfacejava.sql.ResultSet
- 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:
java.sql.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 java.sql.SQLException
- Specified by:
getByte
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getShort
public short getShort(int columnIndex) throws java.sql.SQLException
- Specified by:
getShort
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getInt
public int getInt(int columnIndex) throws java.sql.SQLException
- Specified by:
getInt
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getLong
public long getLong(int columnIndex) throws java.sql.SQLException
- Specified by:
getLong
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getFastLong
private long getFastLong(byte[] bytes, long minVal, long maxVal) throws java.lang.NumberFormatException
Optimised byte[] to number parser. This code does not handle null values, so the caller must do checkResultSet and handle null values prior to calling this function.- Parameters:
bytes
- integer represented as a sequence of ASCII bytes- Returns:
- The parsed number.
- Throws:
java.lang.NumberFormatException
- If the number is invalid or the out of range for fast parsing. The value must then be parsed bytoLong(String)
.
-
getFastBigDecimal
private java.math.BigDecimal getFastBigDecimal(byte[] bytes) throws java.lang.NumberFormatException
Optimised byte[] to number parser. This code does not handle null values, so the caller must do checkResultSet and handle null values prior to calling this function.- Parameters:
bytes
- integer represented as a sequence of ASCII bytes- Returns:
- The parsed number.
- Throws:
java.lang.NumberFormatException
- If the number is invalid or the out of range for fast parsing. The value must then be parsed bytoBigDecimal(String, int)
.
-
getFloat
public float getFloat(int columnIndex) throws java.sql.SQLException
- Specified by:
getFloat
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getDouble
public double getDouble(int columnIndex) throws java.sql.SQLException
- Specified by:
getDouble
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getBigDecimal
public java.math.BigDecimal getBigDecimal(int columnIndex, int scale) throws java.sql.SQLException
- Specified by:
getBigDecimal
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getNumeric
private java.lang.Number getNumeric(int columnIndex, int scale, boolean allowNaN) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
getBytes
public byte[] getBytes(int columnIndex) throws java.sql.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 interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getDate
public java.sql.Date getDate(int columnIndex) throws java.sql.SQLException
- Specified by:
getDate
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getTime
public java.sql.Time getTime(int columnIndex) throws java.sql.SQLException
- Specified by:
getTime
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getTimestamp
public java.sql.Timestamp getTimestamp(int columnIndex) throws java.sql.SQLException
- Specified by:
getTimestamp
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getAsciiStream
public java.io.InputStream getAsciiStream(int columnIndex) throws java.sql.SQLException
- Specified by:
getAsciiStream
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getUnicodeStream
public java.io.InputStream getUnicodeStream(int columnIndex) throws java.sql.SQLException
- Specified by:
getUnicodeStream
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getBinaryStream
public java.io.InputStream getBinaryStream(int columnIndex) throws java.sql.SQLException
- Specified by:
getBinaryStream
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getString
public java.lang.String getString(java.lang.String columnName) throws java.sql.SQLException
- Specified by:
getString
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getBoolean
public boolean getBoolean(java.lang.String columnName) throws java.sql.SQLException
- Specified by:
getBoolean
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getByte
public byte getByte(java.lang.String columnName) throws java.sql.SQLException
- Specified by:
getByte
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getShort
public short getShort(java.lang.String columnName) throws java.sql.SQLException
- Specified by:
getShort
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getInt
public int getInt(java.lang.String columnName) throws java.sql.SQLException
- Specified by:
getInt
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getLong
public long getLong(java.lang.String columnName) throws java.sql.SQLException
- Specified by:
getLong
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getFloat
public float getFloat(java.lang.String columnName) throws java.sql.SQLException
- Specified by:
getFloat
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getDouble
public double getDouble(java.lang.String columnName) throws java.sql.SQLException
- Specified by:
getDouble
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getBigDecimal
public java.math.BigDecimal getBigDecimal(java.lang.String columnName, int scale) throws java.sql.SQLException
- Specified by:
getBigDecimal
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getBytes
public byte[] getBytes(java.lang.String columnName) throws java.sql.SQLException
- Specified by:
getBytes
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getDate
public java.sql.Date getDate(java.lang.String columnName) throws java.sql.SQLException
- Specified by:
getDate
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getTime
public java.sql.Time getTime(java.lang.String columnName) throws java.sql.SQLException
- Specified by:
getTime
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getTimestamp
public java.sql.Timestamp getTimestamp(java.lang.String columnName) throws java.sql.SQLException
- Specified by:
getTimestamp
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getAsciiStream
public java.io.InputStream getAsciiStream(java.lang.String columnName) throws java.sql.SQLException
- Specified by:
getAsciiStream
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getUnicodeStream
public java.io.InputStream getUnicodeStream(java.lang.String columnName) throws java.sql.SQLException
- Specified by:
getUnicodeStream
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getBinaryStream
public java.io.InputStream getBinaryStream(java.lang.String columnName) throws java.sql.SQLException
- Specified by:
getBinaryStream
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getWarnings
public java.sql.SQLWarning getWarnings() throws java.sql.SQLException
- Specified by:
getWarnings
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
clearWarnings
public void clearWarnings() throws java.sql.SQLException
- Specified by:
clearWarnings
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
addWarning
protected void addWarning(java.sql.SQLWarning warnings)
-
getCursorName
public java.lang.String getCursorName() throws java.sql.SQLException
- Specified by:
getCursorName
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getObject
public java.lang.Object getObject(int columnIndex) throws java.sql.SQLException
- Specified by:
getObject
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getObject
public java.lang.Object getObject(java.lang.String columnName) throws java.sql.SQLException
- Specified by:
getObject
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
findColumn
public int findColumn(java.lang.String columnName) throws java.sql.SQLException
- Specified by:
findColumn
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
createColumnNameIndexMap
public static java.util.Map<java.lang.String,java.lang.Integer> createColumnNameIndexMap(Field[] fields, boolean isSanitiserDisabled)
-
findColumnIndex
private int findColumnIndex(java.lang.String columnName)
-
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 java.lang.String getFixedString(int col) throws java.sql.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:
java.sql.SQLException
- if something wrong happens
-
trimMoney
private java.lang.String trimMoney(java.lang.String s)
-
getPGType
protected java.lang.String getPGType(int column) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
getSQLType
protected int getSQLType(int column) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
initSqlType
private void initSqlType(Field field) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
checkUpdateable
private void checkUpdateable() throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
checkClosed
protected void checkClosed() throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
isResultSetClosed
protected boolean isResultSetClosed()
-
checkColumnIndex
protected void checkColumnIndex(int column) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
getRawValue
protected byte[] getRawValue(int column) throws java.sql.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:
java.sql.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(java.lang.String s) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
toInt
public static int toInt(java.lang.String s) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
toLong
public static long toLong(java.lang.String s) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
toBigDecimal
public static java.math.BigDecimal toBigDecimal(java.lang.String s) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
toBigDecimal
public java.math.BigDecimal toBigDecimal(java.lang.String s, int scale) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
scaleBigDecimal
private java.math.BigDecimal scaleBigDecimal(java.math.BigDecimal val, int scale) throws PSQLException
- Throws:
PSQLException
-
toFloat
public static float toFloat(java.lang.String s) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
toDouble
public static double toDouble(java.lang.String s) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
initRowBuffer
private void initRowBuffer()
-
isColumnTrimmable
private boolean isColumnTrimmable(int columnIndex) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
trimBytes
private byte[] trimBytes(int columnIndex, byte[] bytes) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
trimString
private java.lang.String trimString(int columnIndex, java.lang.String string) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
readDoubleValue
private double readDoubleValue(byte[] bytes, int oid, java.lang.String targetType) throws PSQLException
Converts any numeric binary field to double value. This method does no overflow checking.- Parameters:
bytes
- The bytes of the numeric field.oid
- The oid of the field.targetType
- The target type. Used for error reporting.- Returns:
- The value as double.
- Throws:
PSQLException
- If the field type is not supported numeric type.
-
readLongValue
private long readLongValue(byte[] bytes, int oid, long minVal, long maxVal, java.lang.String targetType) throws PSQLException
Converts any numeric binary field to long value.
This method is used by getByte,getShort,getInt and getLong. It must support a subset of the following java types that use Binary encoding. (fields that use text encoding use a different code path).
byte,short,int,long,float,double,BigDecimal,boolean,string
.- Parameters:
bytes
- The bytes of the numeric field.oid
- The oid of the field.minVal
- the minimum value allowed.maxVal
- the maximum value allowed.targetType
- The target type. Used for error reporting.- Returns:
- The value as long.
- Throws:
PSQLException
- If the field type is not supported numeric type or if the value is out of range.
-
updateValue
protected void updateValue(int columnIndex, java.lang.Object value) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
getUUID
protected java.lang.Object getUUID(java.lang.String data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
getUUID
protected java.lang.Object getUUID(byte[] data) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
addRows
void addRows(java.util.List<Tuple> tuples)
Used to add rows to an already existing ResultSet that exactly match the existing rows. Currently only used for assembling generated keys from batch statement execution.
-
updateRef
public void updateRef(int columnIndex, java.sql.Ref x) throws java.sql.SQLException
- Specified by:
updateRef
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateRef
public void updateRef(java.lang.String columnName, java.sql.Ref x) throws java.sql.SQLException
- Specified by:
updateRef
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateBlob
public void updateBlob(int columnIndex, java.sql.Blob x) throws java.sql.SQLException
- Specified by:
updateBlob
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateBlob
public void updateBlob(java.lang.String columnName, java.sql.Blob x) throws java.sql.SQLException
- Specified by:
updateBlob
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateClob
public void updateClob(int columnIndex, java.sql.Clob x) throws java.sql.SQLException
- Specified by:
updateClob
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateClob
public void updateClob(java.lang.String columnName, java.sql.Clob x) throws java.sql.SQLException
- Specified by:
updateClob
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateArray
public void updateArray(int columnIndex, java.sql.Array x) throws java.sql.SQLException
- Specified by:
updateArray
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateArray
public void updateArray(java.lang.String columnName, java.sql.Array x) throws java.sql.SQLException
- Specified by:
updateArray
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getObject
public <T> T getObject(int columnIndex, java.lang.Class<T> type) throws java.sql.SQLException
- Specified by:
getObject
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getObject
public <T> T getObject(java.lang.String columnLabel, java.lang.Class<T> type) throws java.sql.SQLException
- Specified by:
getObject
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getObject
public java.lang.Object getObject(java.lang.String s, java.util.Map<java.lang.String,java.lang.Class<?>> map) throws java.sql.SQLException
- Specified by:
getObject
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getObject
public java.lang.Object getObject(int i, java.util.Map<java.lang.String,java.lang.Class<?>> map) throws java.sql.SQLException
- Specified by:
getObject
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateObject
public void updateObject(int columnIndex, java.lang.Object x, java.sql.SQLType targetSqlType, int scaleOrLength) throws java.sql.SQLException
- Specified by:
updateObject
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateObject
public void updateObject(java.lang.String columnLabel, java.lang.Object x, java.sql.SQLType targetSqlType, int scaleOrLength) throws java.sql.SQLException
- Specified by:
updateObject
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateObject
public void updateObject(int columnIndex, java.lang.Object x, java.sql.SQLType targetSqlType) throws java.sql.SQLException
- Specified by:
updateObject
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateObject
public void updateObject(java.lang.String columnLabel, java.lang.Object x, java.sql.SQLType targetSqlType) throws java.sql.SQLException
- Specified by:
updateObject
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getRowId
public java.sql.RowId getRowId(int columnIndex) throws java.sql.SQLException
- Specified by:
getRowId
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getRowId
public java.sql.RowId getRowId(java.lang.String columnName) throws java.sql.SQLException
- Specified by:
getRowId
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateRowId
public void updateRowId(int columnIndex, java.sql.RowId x) throws java.sql.SQLException
- Specified by:
updateRowId
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateRowId
public void updateRowId(java.lang.String columnName, java.sql.RowId x) throws java.sql.SQLException
- Specified by:
updateRowId
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getHoldability
public int getHoldability() throws java.sql.SQLException
- Specified by:
getHoldability
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
isClosed
public boolean isClosed() throws java.sql.SQLException
- Specified by:
isClosed
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateNString
public void updateNString(int columnIndex, java.lang.String nString) throws java.sql.SQLException
- Specified by:
updateNString
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateNString
public void updateNString(java.lang.String columnName, java.lang.String nString) throws java.sql.SQLException
- Specified by:
updateNString
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateNClob
public void updateNClob(int columnIndex, java.sql.NClob nClob) throws java.sql.SQLException
- Specified by:
updateNClob
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateNClob
public void updateNClob(java.lang.String columnName, java.sql.NClob nClob) throws java.sql.SQLException
- Specified by:
updateNClob
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateNClob
public void updateNClob(int columnIndex, java.io.Reader reader) throws java.sql.SQLException
- Specified by:
updateNClob
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateNClob
public void updateNClob(java.lang.String columnName, java.io.Reader reader) throws java.sql.SQLException
- Specified by:
updateNClob
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateNClob
public void updateNClob(int columnIndex, java.io.Reader reader, long length) throws java.sql.SQLException
- Specified by:
updateNClob
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateNClob
public void updateNClob(java.lang.String columnName, java.io.Reader reader, long length) throws java.sql.SQLException
- Specified by:
updateNClob
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getNClob
public java.sql.NClob getNClob(int columnIndex) throws java.sql.SQLException
- Specified by:
getNClob
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getNClob
public java.sql.NClob getNClob(java.lang.String columnName) throws java.sql.SQLException
- Specified by:
getNClob
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateBlob
public void updateBlob(int columnIndex, java.io.InputStream inputStream, long length) throws java.sql.SQLException
- Specified by:
updateBlob
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateBlob
public void updateBlob(java.lang.String columnName, java.io.InputStream inputStream, long length) throws java.sql.SQLException
- Specified by:
updateBlob
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateBlob
public void updateBlob(int columnIndex, java.io.InputStream inputStream) throws java.sql.SQLException
- Specified by:
updateBlob
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateBlob
public void updateBlob(java.lang.String columnName, java.io.InputStream inputStream) throws java.sql.SQLException
- Specified by:
updateBlob
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateClob
public void updateClob(int columnIndex, java.io.Reader reader, long length) throws java.sql.SQLException
- Specified by:
updateClob
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateClob
public void updateClob(java.lang.String columnName, java.io.Reader reader, long length) throws java.sql.SQLException
- Specified by:
updateClob
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateClob
public void updateClob(int columnIndex, java.io.Reader reader) throws java.sql.SQLException
- Specified by:
updateClob
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateClob
public void updateClob(java.lang.String columnName, java.io.Reader reader) throws java.sql.SQLException
- Specified by:
updateClob
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getSQLXML
public java.sql.SQLXML getSQLXML(int columnIndex) throws java.sql.SQLException
- Specified by:
getSQLXML
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getSQLXML
public java.sql.SQLXML getSQLXML(java.lang.String columnName) throws java.sql.SQLException
- Specified by:
getSQLXML
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateSQLXML
public void updateSQLXML(int columnIndex, java.sql.SQLXML xmlObject) throws java.sql.SQLException
- Specified by:
updateSQLXML
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateSQLXML
public void updateSQLXML(java.lang.String columnName, java.sql.SQLXML xmlObject) throws java.sql.SQLException
- Specified by:
updateSQLXML
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getNString
public java.lang.String getNString(int columnIndex) throws java.sql.SQLException
- Specified by:
getNString
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getNString
public java.lang.String getNString(java.lang.String columnName) throws java.sql.SQLException
- Specified by:
getNString
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getNCharacterStream
public java.io.Reader getNCharacterStream(int columnIndex) throws java.sql.SQLException
- Specified by:
getNCharacterStream
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
getNCharacterStream
public java.io.Reader getNCharacterStream(java.lang.String columnName) throws java.sql.SQLException
- Specified by:
getNCharacterStream
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateNCharacterStream
public void updateNCharacterStream(int columnIndex, java.io.Reader x, int length) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
updateNCharacterStream
public void updateNCharacterStream(java.lang.String columnName, java.io.Reader x, int length) throws java.sql.SQLException
- Throws:
java.sql.SQLException
-
updateNCharacterStream
public void updateNCharacterStream(int columnIndex, java.io.Reader x) throws java.sql.SQLException
- Specified by:
updateNCharacterStream
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateNCharacterStream
public void updateNCharacterStream(java.lang.String columnName, java.io.Reader x) throws java.sql.SQLException
- Specified by:
updateNCharacterStream
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateNCharacterStream
public void updateNCharacterStream(int columnIndex, java.io.Reader x, long length) throws java.sql.SQLException
- Specified by:
updateNCharacterStream
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateNCharacterStream
public void updateNCharacterStream(java.lang.String columnName, java.io.Reader x, long length) throws java.sql.SQLException
- Specified by:
updateNCharacterStream
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateCharacterStream
public void updateCharacterStream(int columnIndex, java.io.Reader reader, long length) throws java.sql.SQLException
- Specified by:
updateCharacterStream
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateCharacterStream
public void updateCharacterStream(java.lang.String columnName, java.io.Reader reader, long length) throws java.sql.SQLException
- Specified by:
updateCharacterStream
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateCharacterStream
public void updateCharacterStream(int columnIndex, java.io.Reader reader) throws java.sql.SQLException
- Specified by:
updateCharacterStream
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateCharacterStream
public void updateCharacterStream(java.lang.String columnName, java.io.Reader reader) throws java.sql.SQLException
- Specified by:
updateCharacterStream
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateBinaryStream
public void updateBinaryStream(int columnIndex, java.io.InputStream inputStream, long length) throws java.sql.SQLException
- Specified by:
updateBinaryStream
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateBinaryStream
public void updateBinaryStream(java.lang.String columnName, java.io.InputStream inputStream, long length) throws java.sql.SQLException
- Specified by:
updateBinaryStream
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateBinaryStream
public void updateBinaryStream(int columnIndex, java.io.InputStream inputStream) throws java.sql.SQLException
- Specified by:
updateBinaryStream
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateBinaryStream
public void updateBinaryStream(java.lang.String columnName, java.io.InputStream inputStream) throws java.sql.SQLException
- Specified by:
updateBinaryStream
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateAsciiStream
public void updateAsciiStream(int columnIndex, java.io.InputStream inputStream, long length) throws java.sql.SQLException
- Specified by:
updateAsciiStream
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateAsciiStream
public void updateAsciiStream(java.lang.String columnName, java.io.InputStream inputStream, long length) throws java.sql.SQLException
- Specified by:
updateAsciiStream
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateAsciiStream
public void updateAsciiStream(int columnIndex, java.io.InputStream inputStream) throws java.sql.SQLException
- Specified by:
updateAsciiStream
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
updateAsciiStream
public void updateAsciiStream(java.lang.String columnName, java.io.InputStream inputStream) throws java.sql.SQLException
- Specified by:
updateAsciiStream
in interfacejava.sql.ResultSet
- Throws:
java.sql.SQLException
-
isWrapperFor
public boolean isWrapperFor(java.lang.Class<?> iface) throws java.sql.SQLException
- Specified by:
isWrapperFor
in interfacejava.sql.Wrapper
- Throws:
java.sql.SQLException
-
unwrap
public <T> T unwrap(java.lang.Class<T> iface) throws java.sql.SQLException
- Specified by:
unwrap
in interfacejava.sql.Wrapper
- Throws:
java.sql.SQLException
-
getDefaultCalendar
private java.util.Calendar getDefaultCalendar()
-
getTimestampUtils
private TimestampUtils getTimestampUtils()
-
upperCaseFieldLabels
protected PgResultSet upperCaseFieldLabels()
This is here to be used by metadata functions to make all column labels upper case. Because postgres folds columns to lower case in queries it will be easier to change the fields after the fact rather than try to coerce all the columns to upper case in the queries as this would require surrounding all columns with " and escaping them making them even harder to read than they are now.- Returns:
- PgResultSet
-
-