public class PgResultSet extends java.lang.Object implements java.sql.ResultSet, PGRefCursorResultSet
| Modifier and Type | Class and Description |
|---|---|
class |
PgResultSet.CursorResultHandler |
(package private) static class |
PgResultSet.NullObject |
private class |
PgResultSet.PrimaryKey |
| Modifier and Type | Field and Description |
|---|---|
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 java.sql.PreparedStatement |
insertStatement |
private static java.math.BigInteger |
INTMAX |
private static java.math.BigInteger |
INTMIN |
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 java.sql.PreparedStatement |
selectStatement |
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 boolean |
updateable |
private java.sql.PreparedStatement |
updateStatement |
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 by
wasNull(). |
| Constructor and 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) |
| Modifier and Type | Method and 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) |
protected void |
checkResultSet(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.
|
private void |
checkScrollable() |
private void |
checkUpdateable() |
private void |
clearRowBuffer(boolean copyCurrentRow) |
void |
clearWarnings() |
void |
close() |
protected void |
closeInternally() |
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() |
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 this
ResultSet
object as a boolean 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(int columnIndex)
Optimised byte[] to number parser.
|
private int |
getFastInt(int columnIndex)
Optimised byte[] to number parser.
|
private long |
getFastLong(int columnIndex)
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) |
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) |
BaseStatement |
getPGStatement() |
protected java.lang.String |
getPGType(int column) |
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) |
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 |
setFetchDirection(int direction) |
void |
setFetchSize(int rows) |
private void |
setRefCursor(java.lang.String refCursorName) |
private void |
setRowBufferColumn(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.sql.Blob x) |
void |
updateBlob(int columnIndex,
java.io.InputStream inputStream) |
void |
updateBlob(int columnIndex,
java.io.InputStream inputStream,
long length) |
void |
updateBlob(java.lang.String columnName,
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 |
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.sql.Clob x) |
void |
updateClob(int columnIndex,
java.io.Reader reader) |
void |
updateClob(int columnIndex,
java.io.Reader reader,
long length) |
void |
updateClob(java.lang.String columnName,
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 |
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.sql.NClob nClob) |
void |
updateNClob(int columnIndex,
java.io.Reader reader) |
void |
updateNClob(int columnIndex,
java.io.Reader reader,
long length) |
void |
updateNClob(java.lang.String columnName,
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 |
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) |
void |
updateRef(int columnIndex,
java.sql.Ref x) |
void |
updateRef(java.lang.String columnName,
java.sql.Ref x) |
void |
updateRow() |
private void |
updateRowBuffer(boolean isInsert) |
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) |
boolean |
wasNull() |
private boolean updateable
private boolean doingUpdates
private java.util.HashMap<java.lang.String,java.lang.Object> updateValues
private boolean usingOID
private java.util.List<PgResultSet.PrimaryKey> primaryKeys
private boolean singleTable
private java.lang.String onlyTable
private java.lang.String tableName
private java.sql.PreparedStatement updateStatement
private java.sql.PreparedStatement insertStatement
private java.sql.PreparedStatement deleteStatement
private java.sql.PreparedStatement selectStatement
private final int resultsettype
private final int resultsetconcurrency
private int fetchdirection
private java.util.TimeZone defaultTimeZone
protected final BaseConnection connection
protected final BaseStatement statement
protected final Field[] fields
protected final Query originalQuery
protected final int maxRows
protected final int maxFieldSize
protected java.util.List<Tuple> rows
protected int currentRow
protected int rowOffset
protected Tuple thisRow
protected java.sql.SQLWarning warnings
protected boolean wasNullFlag
wasNull(). The value
is always updated by the checkResultSet(int) method.protected boolean onInsertRow
private Tuple rowBuffer
protected int fetchSize
protected ResultCursor cursor
private java.util.Map<java.lang.String,java.lang.Integer> columnNameIndexMap
private java.sql.ResultSetMetaData rsMetaData
private java.lang.String refCursorName
private static final java.math.BigInteger BYTEMAX
private static final java.math.BigInteger BYTEMIN
private static final java.lang.NumberFormatException FAST_NUMBER_FAILED
private static final java.math.BigInteger SHORTMAX
private static final java.math.BigInteger SHORTMIN
private static final java.math.BigInteger INTMAX
private static final java.math.BigInteger INTMIN
private static final java.math.BigInteger LONGMAX
private static final java.math.BigInteger LONGMIN
PgResultSet(Query originalQuery, BaseStatement statement, Field[] fields, java.util.List<Tuple> tuples, ResultCursor cursor, int maxRows, int maxFieldSize, int rsType, int rsConcurrency, int rsHoldability) throws java.sql.SQLException
java.sql.SQLExceptionprotected java.sql.ResultSetMetaData createMetaData()
throws java.sql.SQLException
java.sql.SQLExceptionpublic java.sql.ResultSetMetaData getMetaData()
throws java.sql.SQLException
getMetaData in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.net.URL getURL(int columnIndex)
throws java.sql.SQLException
getURL in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.net.URL getURL(java.lang.String columnName)
throws java.sql.SQLException
getURL in interface java.sql.ResultSetjava.sql.SQLExceptionprotected java.lang.Object internalGetObject(int columnIndex,
Field field)
throws java.sql.SQLException
java.sql.SQLExceptionprivate void checkScrollable()
throws java.sql.SQLException
java.sql.SQLExceptionpublic boolean absolute(int index)
throws java.sql.SQLException
absolute in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void afterLast()
throws java.sql.SQLException
afterLast in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void beforeFirst()
throws java.sql.SQLException
beforeFirst in interface java.sql.ResultSetjava.sql.SQLExceptionpublic boolean first()
throws java.sql.SQLException
first in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.sql.Array getArray(java.lang.String colName)
throws java.sql.SQLException
getArray in interface java.sql.ResultSetjava.sql.SQLExceptionprotected java.sql.Array makeArray(int oid,
byte[] value)
throws java.sql.SQLException
java.sql.SQLExceptionprotected java.sql.Array makeArray(int oid,
java.lang.String value)
throws java.sql.SQLException
java.sql.SQLExceptionpublic java.sql.Array getArray(int i)
throws java.sql.SQLException
getArray in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.math.BigDecimal getBigDecimal(int columnIndex)
throws java.sql.SQLException
getBigDecimal in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.math.BigDecimal getBigDecimal(java.lang.String columnName)
throws java.sql.SQLException
getBigDecimal in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.sql.Blob getBlob(java.lang.String columnName)
throws java.sql.SQLException
getBlob in interface java.sql.ResultSetjava.sql.SQLExceptionprotected java.sql.Blob makeBlob(long oid)
throws java.sql.SQLException
java.sql.SQLExceptionpublic java.sql.Blob getBlob(int i)
throws java.sql.SQLException
getBlob in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.io.Reader getCharacterStream(java.lang.String columnName)
throws java.sql.SQLException
getCharacterStream in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.io.Reader getCharacterStream(int i)
throws java.sql.SQLException
getCharacterStream in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.sql.Clob getClob(java.lang.String columnName)
throws java.sql.SQLException
getClob in interface java.sql.ResultSetjava.sql.SQLExceptionprotected java.sql.Clob makeClob(long oid)
throws java.sql.SQLException
java.sql.SQLExceptionpublic java.sql.Clob getClob(int i)
throws java.sql.SQLException
getClob in interface java.sql.ResultSetjava.sql.SQLExceptionpublic int getConcurrency()
throws java.sql.SQLException
getConcurrency in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.sql.Date getDate(int i,
java.util.Calendar cal)
throws java.sql.SQLException
getDate in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.sql.Time getTime(int i,
java.util.Calendar cal)
throws java.sql.SQLException
getTime in interface java.sql.ResultSetjava.sql.SQLExceptionprivate java.time.LocalTime getLocalTime(int i)
throws java.sql.SQLException
java.sql.SQLExceptionpublic java.sql.Timestamp getTimestamp(int i,
java.util.Calendar cal)
throws java.sql.SQLException
getTimestamp in interface java.sql.ResultSetjava.sql.SQLExceptionprivate java.time.OffsetDateTime getOffsetDateTime(int i)
throws java.sql.SQLException
java.sql.SQLExceptionprivate java.time.LocalDateTime getLocalDateTime(int i)
throws java.sql.SQLException
java.sql.SQLExceptionpublic java.sql.Date getDate(java.lang.String c,
java.util.Calendar cal)
throws java.sql.SQLException
getDate in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.sql.Time getTime(java.lang.String c,
java.util.Calendar cal)
throws java.sql.SQLException
getTime in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.sql.Timestamp getTimestamp(java.lang.String c,
java.util.Calendar cal)
throws java.sql.SQLException
getTimestamp in interface java.sql.ResultSetjava.sql.SQLExceptionpublic int getFetchDirection()
throws java.sql.SQLException
getFetchDirection in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.lang.Object getObjectImpl(java.lang.String columnName,
java.util.Map<java.lang.String,java.lang.Class<?>> map)
throws java.sql.SQLException
java.sql.SQLExceptionpublic java.lang.Object getObjectImpl(int i,
java.util.Map<java.lang.String,java.lang.Class<?>> map)
throws java.sql.SQLException
java.sql.SQLExceptionpublic java.sql.Ref getRef(java.lang.String columnName)
throws java.sql.SQLException
getRef in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.sql.Ref getRef(int i)
throws java.sql.SQLException
getRef in interface java.sql.ResultSetjava.sql.SQLExceptionpublic int getRow()
throws java.sql.SQLException
getRow in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.sql.Statement getStatement()
throws java.sql.SQLException
getStatement in interface java.sql.ResultSetjava.sql.SQLExceptionpublic int getType()
throws java.sql.SQLException
getType in interface java.sql.ResultSetjava.sql.SQLExceptionpublic boolean isAfterLast()
throws java.sql.SQLException
isAfterLast in interface java.sql.ResultSetjava.sql.SQLExceptionpublic boolean isBeforeFirst()
throws java.sql.SQLException
isBeforeFirst in interface java.sql.ResultSetjava.sql.SQLExceptionpublic boolean isFirst()
throws java.sql.SQLException
isFirst in interface java.sql.ResultSetjava.sql.SQLExceptionpublic boolean isLast()
throws java.sql.SQLException
isLast in interface java.sql.ResultSetjava.sql.SQLExceptionpublic boolean last()
throws java.sql.SQLException
last in interface java.sql.ResultSetjava.sql.SQLExceptionpublic boolean previous()
throws java.sql.SQLException
previous in interface java.sql.ResultSetjava.sql.SQLExceptionpublic boolean relative(int rows)
throws java.sql.SQLException
relative in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void setFetchDirection(int direction)
throws java.sql.SQLException
setFetchDirection in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void cancelRowUpdates()
throws java.sql.SQLException
cancelRowUpdates in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void deleteRow()
throws java.sql.SQLException
deleteRow in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void insertRow()
throws java.sql.SQLException
insertRow in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void moveToCurrentRow()
throws java.sql.SQLException
moveToCurrentRow in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void moveToInsertRow()
throws java.sql.SQLException
moveToInsertRow in interface java.sql.ResultSetjava.sql.SQLExceptionprivate void clearRowBuffer(boolean copyCurrentRow)
throws java.sql.SQLException
java.sql.SQLExceptionpublic boolean rowDeleted()
throws java.sql.SQLException
rowDeleted in interface java.sql.ResultSetjava.sql.SQLExceptionpublic boolean rowInserted()
throws java.sql.SQLException
rowInserted in interface java.sql.ResultSetjava.sql.SQLExceptionpublic boolean rowUpdated()
throws java.sql.SQLException
rowUpdated in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateAsciiStream(int columnIndex,
java.io.InputStream x,
int length)
throws java.sql.SQLException
updateAsciiStream in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateBigDecimal(int columnIndex,
java.math.BigDecimal x)
throws java.sql.SQLException
updateBigDecimal in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateBinaryStream(int columnIndex,
java.io.InputStream x,
int length)
throws java.sql.SQLException
updateBinaryStream in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateBoolean(int columnIndex,
boolean x)
throws java.sql.SQLException
updateBoolean in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateByte(int columnIndex,
byte x)
throws java.sql.SQLException
updateByte in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateBytes(int columnIndex,
byte[] x)
throws java.sql.SQLException
updateBytes in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateCharacterStream(int columnIndex,
java.io.Reader x,
int length)
throws java.sql.SQLException
updateCharacterStream in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateDate(int columnIndex,
java.sql.Date x)
throws java.sql.SQLException
updateDate in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateDouble(int columnIndex,
double x)
throws java.sql.SQLException
updateDouble in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateFloat(int columnIndex,
float x)
throws java.sql.SQLException
updateFloat in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateInt(int columnIndex,
int x)
throws java.sql.SQLException
updateInt in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateLong(int columnIndex,
long x)
throws java.sql.SQLException
updateLong in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateNull(int columnIndex)
throws java.sql.SQLException
updateNull in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateObject(int columnIndex,
java.lang.Object x)
throws java.sql.SQLException
updateObject in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateObject(int columnIndex,
java.lang.Object x,
int scale)
throws java.sql.SQLException
updateObject in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void refreshRow()
throws java.sql.SQLException
refreshRow in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateRow()
throws java.sql.SQLException
updateRow in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateShort(int columnIndex,
short x)
throws java.sql.SQLException
updateShort in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateString(int columnIndex,
java.lang.String x)
throws java.sql.SQLException
updateString in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateTime(int columnIndex,
java.sql.Time x)
throws java.sql.SQLException
updateTime in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateTimestamp(int columnIndex,
java.sql.Timestamp x)
throws java.sql.SQLException
updateTimestamp in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateNull(java.lang.String columnName)
throws java.sql.SQLException
updateNull in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateBoolean(java.lang.String columnName,
boolean x)
throws java.sql.SQLException
updateBoolean in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateByte(java.lang.String columnName,
byte x)
throws java.sql.SQLException
updateByte in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateShort(java.lang.String columnName,
short x)
throws java.sql.SQLException
updateShort in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateInt(java.lang.String columnName,
int x)
throws java.sql.SQLException
updateInt in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateLong(java.lang.String columnName,
long x)
throws java.sql.SQLException
updateLong in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateFloat(java.lang.String columnName,
float x)
throws java.sql.SQLException
updateFloat in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateDouble(java.lang.String columnName,
double x)
throws java.sql.SQLException
updateDouble in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateBigDecimal(java.lang.String columnName,
java.math.BigDecimal x)
throws java.sql.SQLException
updateBigDecimal in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateString(java.lang.String columnName,
java.lang.String x)
throws java.sql.SQLException
updateString in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateBytes(java.lang.String columnName,
byte[] x)
throws java.sql.SQLException
updateBytes in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateDate(java.lang.String columnName,
java.sql.Date x)
throws java.sql.SQLException
updateDate in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateTime(java.lang.String columnName,
java.sql.Time x)
throws java.sql.SQLException
updateTime in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateTimestamp(java.lang.String columnName,
java.sql.Timestamp x)
throws java.sql.SQLException
updateTimestamp in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateAsciiStream(java.lang.String columnName,
java.io.InputStream x,
int length)
throws java.sql.SQLException
updateAsciiStream in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateBinaryStream(java.lang.String columnName,
java.io.InputStream x,
int length)
throws java.sql.SQLException
updateBinaryStream in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateCharacterStream(java.lang.String columnName,
java.io.Reader reader,
int length)
throws java.sql.SQLException
updateCharacterStream in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateObject(java.lang.String columnName,
java.lang.Object x,
int scale)
throws java.sql.SQLException
updateObject in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateObject(java.lang.String columnName,
java.lang.Object x)
throws java.sql.SQLException
updateObject in interface java.sql.ResultSetjava.sql.SQLExceptionboolean isUpdateable()
throws java.sql.SQLException
java.sql.SQLExceptionpublic static java.lang.String[] quotelessTableName(java.lang.String fullname)
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)
private void parseQuery()
private void setRowBufferColumn(int columnIndex,
java.lang.Object valueObject)
throws java.sql.SQLException
java.sql.SQLExceptionprivate void updateRowBuffer(boolean isInsert)
throws java.sql.SQLException
java.sql.SQLExceptionpublic BaseStatement getPGStatement()
public java.lang.String getRefCursor()
getRefCursor in interface PGRefCursorResultSetprivate void setRefCursor(java.lang.String refCursorName)
public void setFetchSize(int rows)
throws java.sql.SQLException
setFetchSize in interface java.sql.ResultSetjava.sql.SQLExceptionpublic int getFetchSize()
throws java.sql.SQLException
getFetchSize in interface java.sql.ResultSetjava.sql.SQLExceptionpublic boolean next()
throws java.sql.SQLException
next in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void close()
throws java.sql.SQLException
close in interface java.lang.AutoCloseableclose in interface java.sql.ResultSetjava.sql.SQLExceptionprotected void closeInternally()
throws java.sql.SQLException
java.sql.SQLExceptionpublic boolean wasNull()
throws java.sql.SQLException
wasNull in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.lang.String getString(int columnIndex)
throws java.sql.SQLException
getString in interface java.sql.ResultSetjava.sql.SQLExceptionpublic boolean getBoolean(int columnIndex)
throws java.sql.SQLException
Retrieves the value of the designated column in the current row of this ResultSet
object as a boolean 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 of false 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 of
false is returned.
getBoolean in interface java.sql.ResultSetcolumnIndex - the first column is 1, the second is 2, ...NULL, the value returned is
falsejava.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.public byte getByte(int columnIndex)
throws java.sql.SQLException
getByte in interface java.sql.ResultSetjava.sql.SQLExceptionpublic short getShort(int columnIndex)
throws java.sql.SQLException
getShort in interface java.sql.ResultSetjava.sql.SQLExceptionpublic int getInt(int columnIndex)
throws java.sql.SQLException
getInt in interface java.sql.ResultSetjava.sql.SQLExceptionpublic long getLong(int columnIndex)
throws java.sql.SQLException
getLong in interface java.sql.ResultSetjava.sql.SQLExceptionprivate long getFastLong(int columnIndex)
throws java.sql.SQLException,
java.lang.NumberFormatException
columnIndex - The column to parse.java.sql.SQLException - If an error occurs while fetching column.java.lang.NumberFormatException - If the number is invalid or the out of range for fast parsing.
The value must then be parsed by toLong(String).private int getFastInt(int columnIndex)
throws java.sql.SQLException,
java.lang.NumberFormatException
columnIndex - The column to parse.java.sql.SQLException - If an error occurs while fetching column.java.lang.NumberFormatException - If the number is invalid or the out of range for fast parsing.
The value must then be parsed by toInt(String).private java.math.BigDecimal getFastBigDecimal(int columnIndex)
throws java.sql.SQLException,
java.lang.NumberFormatException
columnIndex - The column to parse.java.sql.SQLException - If an error occurs while fetching column.java.lang.NumberFormatException - If the number is invalid or the out of range for fast parsing.
The value must then be parsed by toBigDecimal(String, int).public float getFloat(int columnIndex)
throws java.sql.SQLException
getFloat in interface java.sql.ResultSetjava.sql.SQLExceptionpublic double getDouble(int columnIndex)
throws java.sql.SQLException
getDouble in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.math.BigDecimal getBigDecimal(int columnIndex,
int scale)
throws java.sql.SQLException
getBigDecimal in interface java.sql.ResultSetjava.sql.SQLExceptionprivate java.lang.Number getNumeric(int columnIndex,
int scale,
boolean allowNaN)
throws java.sql.SQLException
java.sql.SQLExceptionpublic 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.
getBytes in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.sql.Date getDate(int columnIndex)
throws java.sql.SQLException
getDate in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.sql.Time getTime(int columnIndex)
throws java.sql.SQLException
getTime in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.sql.Timestamp getTimestamp(int columnIndex)
throws java.sql.SQLException
getTimestamp in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.io.InputStream getAsciiStream(int columnIndex)
throws java.sql.SQLException
getAsciiStream in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.io.InputStream getUnicodeStream(int columnIndex)
throws java.sql.SQLException
getUnicodeStream in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.io.InputStream getBinaryStream(int columnIndex)
throws java.sql.SQLException
getBinaryStream in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.lang.String getString(java.lang.String columnName)
throws java.sql.SQLException
getString in interface java.sql.ResultSetjava.sql.SQLExceptionpublic boolean getBoolean(java.lang.String columnName)
throws java.sql.SQLException
getBoolean in interface java.sql.ResultSetjava.sql.SQLExceptionpublic byte getByte(java.lang.String columnName)
throws java.sql.SQLException
getByte in interface java.sql.ResultSetjava.sql.SQLExceptionpublic short getShort(java.lang.String columnName)
throws java.sql.SQLException
getShort in interface java.sql.ResultSetjava.sql.SQLExceptionpublic int getInt(java.lang.String columnName)
throws java.sql.SQLException
getInt in interface java.sql.ResultSetjava.sql.SQLExceptionpublic long getLong(java.lang.String columnName)
throws java.sql.SQLException
getLong in interface java.sql.ResultSetjava.sql.SQLExceptionpublic float getFloat(java.lang.String columnName)
throws java.sql.SQLException
getFloat in interface java.sql.ResultSetjava.sql.SQLExceptionpublic double getDouble(java.lang.String columnName)
throws java.sql.SQLException
getDouble in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.math.BigDecimal getBigDecimal(java.lang.String columnName,
int scale)
throws java.sql.SQLException
getBigDecimal in interface java.sql.ResultSetjava.sql.SQLExceptionpublic byte[] getBytes(java.lang.String columnName)
throws java.sql.SQLException
getBytes in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.sql.Date getDate(java.lang.String columnName)
throws java.sql.SQLException
getDate in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.sql.Time getTime(java.lang.String columnName)
throws java.sql.SQLException
getTime in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.sql.Timestamp getTimestamp(java.lang.String columnName)
throws java.sql.SQLException
getTimestamp in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.io.InputStream getAsciiStream(java.lang.String columnName)
throws java.sql.SQLException
getAsciiStream in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.io.InputStream getUnicodeStream(java.lang.String columnName)
throws java.sql.SQLException
getUnicodeStream in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.io.InputStream getBinaryStream(java.lang.String columnName)
throws java.sql.SQLException
getBinaryStream in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.sql.SQLWarning getWarnings()
throws java.sql.SQLException
getWarnings in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void clearWarnings()
throws java.sql.SQLException
clearWarnings in interface java.sql.ResultSetjava.sql.SQLExceptionprotected void addWarning(java.sql.SQLWarning warnings)
public java.lang.String getCursorName()
throws java.sql.SQLException
getCursorName in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.lang.Object getObject(int columnIndex)
throws java.sql.SQLException
getObject in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.lang.Object getObject(java.lang.String columnName)
throws java.sql.SQLException
getObject in interface java.sql.ResultSetjava.sql.SQLExceptionpublic int findColumn(java.lang.String columnName)
throws java.sql.SQLException
findColumn in interface java.sql.ResultSetjava.sql.SQLExceptionpublic static java.util.Map<java.lang.String,java.lang.Integer> createColumnNameIndexMap(Field[] fields, boolean isSanitiserDisabled)
private int findColumnIndex(java.lang.String columnName)
public int getColumnOID(int field)
field - field indexpublic 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 ##.##
col - column position (1-based)java.sql.SQLException - if something wrong happensprivate java.lang.String trimMoney(java.lang.String s)
protected java.lang.String getPGType(int column)
throws java.sql.SQLException
java.sql.SQLExceptionprotected int getSQLType(int column)
throws java.sql.SQLException
java.sql.SQLExceptionprivate void initSqlType(Field field) throws java.sql.SQLException
java.sql.SQLExceptionprivate void checkUpdateable()
throws java.sql.SQLException
java.sql.SQLExceptionprotected void checkClosed()
throws java.sql.SQLException
java.sql.SQLExceptionprotected boolean isResultSetClosed()
protected void checkColumnIndex(int column)
throws java.sql.SQLException
java.sql.SQLExceptionprotected void checkResultSet(int column)
throws java.sql.SQLException
wasNullFlag to correct value.column - The column number to check. Range starts from 1.java.sql.SQLException - If state or column is invalid.protected boolean isBinary(int column)
column - The column to check. Range starts from 1.public static short toShort(java.lang.String s)
throws java.sql.SQLException
java.sql.SQLExceptionpublic static int toInt(java.lang.String s)
throws java.sql.SQLException
java.sql.SQLExceptionpublic static long toLong(java.lang.String s)
throws java.sql.SQLException
java.sql.SQLExceptionpublic static java.math.BigDecimal toBigDecimal(java.lang.String s)
throws java.sql.SQLException
java.sql.SQLExceptionpublic java.math.BigDecimal toBigDecimal(java.lang.String s,
int scale)
throws java.sql.SQLException
java.sql.SQLExceptionprivate java.math.BigDecimal scaleBigDecimal(java.math.BigDecimal val,
int scale)
throws PSQLException
PSQLExceptionpublic static float toFloat(java.lang.String s)
throws java.sql.SQLException
java.sql.SQLExceptionpublic static double toDouble(java.lang.String s)
throws java.sql.SQLException
java.sql.SQLExceptionprivate void initRowBuffer()
private boolean isColumnTrimmable(int columnIndex)
throws java.sql.SQLException
java.sql.SQLExceptionprivate byte[] trimBytes(int columnIndex,
byte[] bytes)
throws java.sql.SQLException
java.sql.SQLExceptionprivate java.lang.String trimString(int columnIndex,
java.lang.String string)
throws java.sql.SQLException
java.sql.SQLExceptionprivate double readDoubleValue(byte[] bytes,
int oid,
java.lang.String targetType)
throws PSQLException
bytes - The bytes of the numeric field.oid - The oid of the field.targetType - The target type. Used for error reporting.PSQLException - If the field type is not supported numeric type.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.
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.PSQLException - If the field type is not supported numeric type or if the value is out of
range.protected void updateValue(int columnIndex,
java.lang.Object value)
throws java.sql.SQLException
java.sql.SQLExceptionprotected java.lang.Object getUUID(java.lang.String data)
throws java.sql.SQLException
java.sql.SQLExceptionprotected java.lang.Object getUUID(byte[] data)
throws java.sql.SQLException
java.sql.SQLExceptionvoid addRows(java.util.List<Tuple> tuples)
public void updateRef(int columnIndex,
java.sql.Ref x)
throws java.sql.SQLException
updateRef in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateRef(java.lang.String columnName,
java.sql.Ref x)
throws java.sql.SQLException
updateRef in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateBlob(int columnIndex,
java.sql.Blob x)
throws java.sql.SQLException
updateBlob in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateBlob(java.lang.String columnName,
java.sql.Blob x)
throws java.sql.SQLException
updateBlob in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateClob(int columnIndex,
java.sql.Clob x)
throws java.sql.SQLException
updateClob in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateClob(java.lang.String columnName,
java.sql.Clob x)
throws java.sql.SQLException
updateClob in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateArray(int columnIndex,
java.sql.Array x)
throws java.sql.SQLException
updateArray in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateArray(java.lang.String columnName,
java.sql.Array x)
throws java.sql.SQLException
updateArray in interface java.sql.ResultSetjava.sql.SQLExceptionpublic <T> T getObject(int columnIndex,
java.lang.Class<T> type)
throws java.sql.SQLException
getObject in interface java.sql.ResultSetjava.sql.SQLExceptionpublic <T> T getObject(java.lang.String columnLabel,
java.lang.Class<T> type)
throws java.sql.SQLException
getObject in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.lang.Object getObject(java.lang.String s,
java.util.Map<java.lang.String,java.lang.Class<?>> map)
throws java.sql.SQLException
getObject in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.lang.Object getObject(int i,
java.util.Map<java.lang.String,java.lang.Class<?>> map)
throws java.sql.SQLException
getObject in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateObject(int columnIndex,
java.lang.Object x,
java.sql.SQLType targetSqlType,
int scaleOrLength)
throws java.sql.SQLException
updateObject in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateObject(java.lang.String columnLabel,
java.lang.Object x,
java.sql.SQLType targetSqlType,
int scaleOrLength)
throws java.sql.SQLException
updateObject in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateObject(int columnIndex,
java.lang.Object x,
java.sql.SQLType targetSqlType)
throws java.sql.SQLException
updateObject in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateObject(java.lang.String columnLabel,
java.lang.Object x,
java.sql.SQLType targetSqlType)
throws java.sql.SQLException
updateObject in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.sql.RowId getRowId(int columnIndex)
throws java.sql.SQLException
getRowId in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.sql.RowId getRowId(java.lang.String columnName)
throws java.sql.SQLException
getRowId in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateRowId(int columnIndex,
java.sql.RowId x)
throws java.sql.SQLException
updateRowId in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateRowId(java.lang.String columnName,
java.sql.RowId x)
throws java.sql.SQLException
updateRowId in interface java.sql.ResultSetjava.sql.SQLExceptionpublic int getHoldability()
throws java.sql.SQLException
getHoldability in interface java.sql.ResultSetjava.sql.SQLExceptionpublic boolean isClosed()
throws java.sql.SQLException
isClosed in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateNString(int columnIndex,
java.lang.String nString)
throws java.sql.SQLException
updateNString in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateNString(java.lang.String columnName,
java.lang.String nString)
throws java.sql.SQLException
updateNString in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateNClob(int columnIndex,
java.sql.NClob nClob)
throws java.sql.SQLException
updateNClob in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateNClob(java.lang.String columnName,
java.sql.NClob nClob)
throws java.sql.SQLException
updateNClob in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateNClob(int columnIndex,
java.io.Reader reader)
throws java.sql.SQLException
updateNClob in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateNClob(java.lang.String columnName,
java.io.Reader reader)
throws java.sql.SQLException
updateNClob in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateNClob(int columnIndex,
java.io.Reader reader,
long length)
throws java.sql.SQLException
updateNClob in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateNClob(java.lang.String columnName,
java.io.Reader reader,
long length)
throws java.sql.SQLException
updateNClob in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.sql.NClob getNClob(int columnIndex)
throws java.sql.SQLException
getNClob in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.sql.NClob getNClob(java.lang.String columnName)
throws java.sql.SQLException
getNClob in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateBlob(int columnIndex,
java.io.InputStream inputStream,
long length)
throws java.sql.SQLException
updateBlob in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateBlob(java.lang.String columnName,
java.io.InputStream inputStream,
long length)
throws java.sql.SQLException
updateBlob in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateBlob(int columnIndex,
java.io.InputStream inputStream)
throws java.sql.SQLException
updateBlob in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateBlob(java.lang.String columnName,
java.io.InputStream inputStream)
throws java.sql.SQLException
updateBlob in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateClob(int columnIndex,
java.io.Reader reader,
long length)
throws java.sql.SQLException
updateClob in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateClob(java.lang.String columnName,
java.io.Reader reader,
long length)
throws java.sql.SQLException
updateClob in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateClob(int columnIndex,
java.io.Reader reader)
throws java.sql.SQLException
updateClob in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateClob(java.lang.String columnName,
java.io.Reader reader)
throws java.sql.SQLException
updateClob in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.sql.SQLXML getSQLXML(int columnIndex)
throws java.sql.SQLException
getSQLXML in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.sql.SQLXML getSQLXML(java.lang.String columnName)
throws java.sql.SQLException
getSQLXML in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateSQLXML(int columnIndex,
java.sql.SQLXML xmlObject)
throws java.sql.SQLException
updateSQLXML in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateSQLXML(java.lang.String columnName,
java.sql.SQLXML xmlObject)
throws java.sql.SQLException
updateSQLXML in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.lang.String getNString(int columnIndex)
throws java.sql.SQLException
getNString in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.lang.String getNString(java.lang.String columnName)
throws java.sql.SQLException
getNString in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.io.Reader getNCharacterStream(int columnIndex)
throws java.sql.SQLException
getNCharacterStream in interface java.sql.ResultSetjava.sql.SQLExceptionpublic java.io.Reader getNCharacterStream(java.lang.String columnName)
throws java.sql.SQLException
getNCharacterStream in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateNCharacterStream(int columnIndex,
java.io.Reader x,
int length)
throws java.sql.SQLException
java.sql.SQLExceptionpublic void updateNCharacterStream(java.lang.String columnName,
java.io.Reader x,
int length)
throws java.sql.SQLException
java.sql.SQLExceptionpublic void updateNCharacterStream(int columnIndex,
java.io.Reader x)
throws java.sql.SQLException
updateNCharacterStream in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateNCharacterStream(java.lang.String columnName,
java.io.Reader x)
throws java.sql.SQLException
updateNCharacterStream in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateNCharacterStream(int columnIndex,
java.io.Reader x,
long length)
throws java.sql.SQLException
updateNCharacterStream in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateNCharacterStream(java.lang.String columnName,
java.io.Reader x,
long length)
throws java.sql.SQLException
updateNCharacterStream in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateCharacterStream(int columnIndex,
java.io.Reader reader,
long length)
throws java.sql.SQLException
updateCharacterStream in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateCharacterStream(java.lang.String columnName,
java.io.Reader reader,
long length)
throws java.sql.SQLException
updateCharacterStream in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateCharacterStream(int columnIndex,
java.io.Reader reader)
throws java.sql.SQLException
updateCharacterStream in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateCharacterStream(java.lang.String columnName,
java.io.Reader reader)
throws java.sql.SQLException
updateCharacterStream in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateBinaryStream(int columnIndex,
java.io.InputStream inputStream,
long length)
throws java.sql.SQLException
updateBinaryStream in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateBinaryStream(java.lang.String columnName,
java.io.InputStream inputStream,
long length)
throws java.sql.SQLException
updateBinaryStream in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateBinaryStream(int columnIndex,
java.io.InputStream inputStream)
throws java.sql.SQLException
updateBinaryStream in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateBinaryStream(java.lang.String columnName,
java.io.InputStream inputStream)
throws java.sql.SQLException
updateBinaryStream in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateAsciiStream(int columnIndex,
java.io.InputStream inputStream,
long length)
throws java.sql.SQLException
updateAsciiStream in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateAsciiStream(java.lang.String columnName,
java.io.InputStream inputStream,
long length)
throws java.sql.SQLException
updateAsciiStream in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateAsciiStream(int columnIndex,
java.io.InputStream inputStream)
throws java.sql.SQLException
updateAsciiStream in interface java.sql.ResultSetjava.sql.SQLExceptionpublic void updateAsciiStream(java.lang.String columnName,
java.io.InputStream inputStream)
throws java.sql.SQLException
updateAsciiStream in interface java.sql.ResultSetjava.sql.SQLExceptionpublic boolean isWrapperFor(java.lang.Class<?> iface)
throws java.sql.SQLException
isWrapperFor in interface java.sql.Wrapperjava.sql.SQLExceptionpublic <T> T unwrap(java.lang.Class<T> iface)
throws java.sql.SQLException
unwrap in interface java.sql.Wrapperjava.sql.SQLExceptionprivate java.util.Calendar getDefaultCalendar()