| Package | Description |
|---|---|
| com.mysql.cj | |
| com.mysql.cj.jdbc | |
| com.mysql.cj.jdbc.result | |
| com.mysql.cj.protocol | |
| com.mysql.cj.protocol.a.result | |
| com.mysql.cj.protocol.result | |
| com.mysql.cj.protocol.x | |
| com.mysql.cj.result | |
| com.mysql.cj.xdevapi |
Java classes for X DevAPI support.
|
| Modifier and Type | Method and Description |
|---|---|
default <M extends Message,R,RES> |
Session.query(M message,
java.util.function.Predicate<Row> rowFilter,
java.util.function.Function<Row,R> rowMapper,
java.util.stream.Collector<R,?,RES> collector)
Synchronously query database with applying rows filtering and mapping.
|
default <M extends Message,R,RES> |
Session.query(M message,
java.util.function.Predicate<Row> rowFilter,
java.util.function.Function<Row,R> rowMapper,
java.util.stream.Collector<R,?,RES> collector)
Synchronously query database with applying rows filtering and mapping.
|
<M extends Message,R,RES> |
MysqlxSession.query(M message,
java.util.function.Predicate<Row> rowFilter,
java.util.function.Function<Row,R> rowMapper,
java.util.stream.Collector<R,?,RES> collector) |
<M extends Message,R,RES> |
MysqlxSession.query(M message,
java.util.function.Predicate<Row> rowFilter,
java.util.function.Function<Row,R> rowMapper,
java.util.stream.Collector<R,?,RES> collector) |
| Modifier and Type | Field and Description |
|---|---|
protected java.util.ArrayList<Row> |
StatementImpl.batchedGeneratedKeys |
| Modifier and Type | Method and Description |
|---|---|
private Row |
DatabaseMetaData.convertTypeDescriptorToProcedureRow(byte[] procNameAsBytes,
byte[] procCatAsBytes,
java.lang.String paramName,
boolean isOutParam,
boolean isInParam,
boolean isReturnParam,
DatabaseMetaData.TypeDescriptor typeDesc,
boolean forGetFunctionColumns,
int ordinal) |
| Modifier and Type | Method and Description |
|---|---|
java.util.List<Row> |
DatabaseMetaData.extractForeignKeyForTable(java.util.ArrayList<Row> rows,
java.sql.ResultSet rs,
java.lang.String dbName)
Extracts foreign key info for one table.
|
| Modifier and Type | Method and Description |
|---|---|
protected void |
DatabaseMetaData.convertToJdbcFunctionList(java.sql.ResultSet proceduresRs,
java.util.List<DatabaseMetaData.ComparableWrapper<java.lang.String,Row>> procedureRows,
Field[] fields) |
protected void |
DatabaseMetaData.convertToJdbcProcedureList(boolean fromSelect,
java.sql.ResultSet proceduresRs,
java.util.List<DatabaseMetaData.ComparableWrapper<java.lang.String,Row>> procedureRows) |
java.util.List<Row> |
DatabaseMetaData.extractForeignKeyForTable(java.util.ArrayList<Row> rows,
java.sql.ResultSet rs,
java.lang.String dbName)
Extracts foreign key info for one table.
|
private void |
DatabaseMetaData.getCallStmtParameterTypes(java.lang.String db,
java.lang.String quotedProcName,
DatabaseMetaData.ProcedureType procType,
java.lang.String parameterNamePattern,
java.util.List<Row> resultRows,
boolean forGetFunctionColumns) |
(package private) void |
DatabaseMetaData.populateKeyResults(java.lang.String db,
java.lang.String table,
java.lang.String keysComment,
java.util.List<Row> resultRows,
java.lang.String fkTableName,
boolean isExport)
Populates the resultRows list with the imported or exported keys of given table
based on the keysComment from the 'show table status' sql command.
|
| Modifier and Type | Field and Description |
|---|---|
private Row |
UpdatableResultSet.savedCurrentRow
The binary data for the 'current' row
|
| Modifier and Type | Method and Description |
|---|---|
private void |
UpdatableResultSet.refreshRow(ClientPreparedStatement updateInsertStmt,
Row rowToRefresh) |
private void |
UpdatableResultSet.setParamValue(ClientPreparedStatement ps,
int psIdx,
Row row,
int rsIdx,
Field field) |
| Modifier and Type | Interface and Description |
|---|---|
interface |
ResultsetRow
Classes that implement this interface represent one row of data from the MySQL server that might be stored in different ways depending on whether the result
set was streaming (so they wrap a reusable packet), or whether the result set was cached or via a server-side cursor (so they represent a byte[][]).
|
| Modifier and Type | Method and Description |
|---|---|
default void |
ResultsetRows.addRow(Row row)
Adds a row.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractBufferRow
A ResultSetRow implementation that holds one row packet (which is re-used by the driver, and thus saves memory allocations), and tries when possible to avoid
allocations to break out the results as individual byte[]s.
|
class |
BinaryBufferRow
A BufferRow implementation that holds one row packet from a server-side prepared statement (which is re-used by the driver,
and thus saves memory allocations), and tries when possible to avoid allocations to break out the results as individual byte[]s.
|
class |
ByteArrayRow
A RowHolder implementation that is for cached results (a-la mysql_store_result()).
|
class |
TextBufferRow
A ResultSetRow implementation that holds one row packet (which is re-used by the driver, and thus saves memory allocations), and tries when possible to avoid
allocations to break out the results as individual byte[]s.
|
| Modifier and Type | Field and Description |
|---|---|
private Row |
ResultsetRowsStreaming.nextRow |
protected Row |
NativeResultset.thisRow
Pointer to current row data
|
| Modifier and Type | Field and Description |
|---|---|
private java.util.List<Row> |
ResultsetRowsCursor.fetchedRows
The cache of rows we have retrieved from the server.
|
private java.util.List<Row> |
ResultsetRowsStatic.rows |
| Modifier and Type | Method and Description |
|---|---|
Row |
ResultsetRowsStatic.get(int atIndex) |
Row |
ResultsetRowsStreaming.next() |
Row |
ResultsetRowsCursor.next() |
Row |
ResultsetRowsStatic.next() |
Row |
BinaryBufferRow.setMetadata(ColumnDefinition f) |
Row |
TextBufferRow.setMetadata(ColumnDefinition f) |
| Modifier and Type | Method and Description |
|---|---|
void |
ResultsetRowsCursor.addRow(Row row) |
void |
ResultsetRowsStatic.addRow(Row row) |
| Constructor and Description |
|---|
ResultsetRowsStatic(java.util.List<? extends Row> rows,
ColumnDefinition columnDefinition)
Creates a new RowDataStatic object.
|
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractResultsetRow |
| Modifier and Type | Method and Description |
|---|---|
Row |
AbstractResultsetRow.setMetadata(ColumnDefinition f) |
| Modifier and Type | Class and Description |
|---|---|
class |
XProtocolRow
ProtocolEntity representing an X Protocol result row.
|
| Modifier and Type | Field and Description |
|---|---|
private Row |
XProtocolRowInputStream.next
XProtocolRow
|
| Modifier and Type | Method and Description |
|---|---|
Row |
XProtocolRowInputStream.next() |
Row |
XProtocolRowInputStream.readRow() |
Row |
XProtocolRow.setMetadata(ColumnDefinition columnDefinition) |
| Constructor and Description |
|---|
XProtocolRowInputStream(ColumnDefinition metadata,
Row row,
XProtocol protocol,
java.util.function.Consumer<Notice> noticeConsumer) |
| Modifier and Type | Field and Description |
|---|---|
private java.util.List<Row> |
BufferedRowList.rowList |
| Modifier and Type | Method and Description |
|---|---|
default Row |
RowList.get(int n)
Optionally retrieve Row at index n.
|
Row |
BufferedRowList.get(int n) |
Row |
BufferedRowList.next() |
default Row |
RowList.previous()
Optionally iterate backwards on the list.
|
Row |
BufferedRowList.previous() |
default Row |
Row.setMetadata(ColumnDefinition columnDefinition)
Set metadata to enable getValue functionality.
|
| Constructor and Description |
|---|
BufferedRowList(java.util.Iterator<Row> ris)
Create a new instance by filling the internal buffer by draining the row stream.
|
BufferedRowList(java.util.List<Row> rowList) |
| Modifier and Type | Field and Description |
|---|---|
private Row |
RowImpl.row |
| Modifier and Type | Field and Description |
|---|---|
private java.util.List<Row> |
DocResultBuilder.rows |
private java.util.List<Row> |
RowResultBuilder.rows |
private java.util.List<Row> |
SqlResultBuilder.rows |
| Constructor and Description |
|---|
RowImpl(Row row,
ColumnDefinition metadata,
java.util.TimeZone defaultTimeZone,
PropertySet pset)
Constructor.
|