public final class EmbeddedProtocol
extends nl.cwi.monetdb.mcl.protocol.AbstractProtocol
JDBCEmbeddedConnection
instance.Modifier and Type | Method and Description |
---|---|
void |
fetchNextResponseData()
On an embedded connection, the server response is immediately set, so this method does nothing :)
|
nl.cwi.monetdb.mcl.responses.AbstractDataBlockResponse |
getAnEmptyDataBlockResponse(int rowcount,
int columncount,
nl.cwi.monetdb.mcl.protocol.AbstractProtocol protocol,
int[] JdbcSQLTypes) |
int |
getCurrentServerResponse()
Gets the current server response, obtained immediately after a query is performed.
|
nl.cwi.monetdb.mcl.responses.AutoCommitResponse |
getNextAutoCommitResponse()
Gets the next AutoCommitResponse response from the server.
|
nl.cwi.monetdb.mcl.responses.AbstractDataBlockResponse |
getNextDatablockResponse(Map<Integer,nl.cwi.monetdb.mcl.responses.ResultSetResponse> rsresponses)
Gets the next DataBlockResponse response from the server, belonging to a ResultSetResponse
|
nl.cwi.monetdb.mcl.responses.ResultSetResponse |
getNextResultSetResponse(nl.cwi.monetdb.jdbc.MonetConnection con,
nl.cwi.monetdb.jdbc.MonetConnection.ResponseList list,
int seqnr,
int maxrows)
Gets the next ResultSet response from the server, belonging to a ResponseList.
|
int |
getNextStarterHeader()
Gets the next starter header of a server response.
|
int |
getNextTableHeader(String[] columnNames,
int[] columnLengths,
String[] types,
String[] tableNames)
Gets the next Table Header for a ResultSetResponse.
|
nl.cwi.monetdb.mcl.responses.UpdateResponse |
getNextUpdateResponse()
Gets the next UpdateResponse response from the server.
|
String |
getRemainingStringLine(int startIndex)
Gets the remaining response line from the underlying connection as a Java String.
|
void |
waitUntilPrompt()
On an embedded connection, there is no need to wait for prompt, so this method does nothing :)
|
void |
writeNextQuery(String prefix,
String query,
String suffix)
Writes a user query to the server, while providing the respective prefixes and suffixes depending on the current
language and connection used.
|
getMonetDate, getMonetParserPosition, getMonetTime, getMonetTimePrinter, getMonetTimestamp, getMonetTimestampPrinter, getMonetTimestampTz, getMonetTimestampTzPrinter, getMonetTimeTz, getMonetTimeTzPrinter, getNextSchemaResponse
public int getCurrentServerResponse()
getCurrentServerResponse
in class nl.cwi.monetdb.mcl.protocol.AbstractProtocol
ServerResponses
public void waitUntilPrompt() throws IOException
waitUntilPrompt
in class nl.cwi.monetdb.mcl.protocol.AbstractProtocol
IOException
- Never thrown :)public void fetchNextResponseData() throws IOException
fetchNextResponseData
in class nl.cwi.monetdb.mcl.protocol.AbstractProtocol
IOException
- Never thrown :)public int getNextStarterHeader()
getNextStarterHeader
in class nl.cwi.monetdb.mcl.protocol.AbstractProtocol
StarterHeaders
public nl.cwi.monetdb.mcl.responses.ResultSetResponse getNextResultSetResponse(nl.cwi.monetdb.jdbc.MonetConnection con, nl.cwi.monetdb.jdbc.MonetConnection.ResponseList list, int seqnr, int maxrows) throws nl.cwi.monetdb.mcl.protocol.ProtocolException
getNextResultSetResponse
in class nl.cwi.monetdb.mcl.protocol.AbstractProtocol
con
- The current MonetDB's JDBC connectionlist
- The Response List this result set will belong toseqnr
- The sequence number of this result set on the Response Listmaxrows
- A maxrows to set if so (not used)nl.cwi.monetdb.mcl.protocol.ProtocolException
- If an error in the underlying connection happened.public nl.cwi.monetdb.mcl.responses.UpdateResponse getNextUpdateResponse() throws nl.cwi.monetdb.mcl.protocol.ProtocolException
getNextUpdateResponse
in class nl.cwi.monetdb.mcl.protocol.AbstractProtocol
nl.cwi.monetdb.mcl.protocol.ProtocolException
- If an error in the underlying connection happened.public nl.cwi.monetdb.mcl.responses.AutoCommitResponse getNextAutoCommitResponse() throws nl.cwi.monetdb.mcl.protocol.ProtocolException
getNextAutoCommitResponse
in class nl.cwi.monetdb.mcl.protocol.AbstractProtocol
nl.cwi.monetdb.mcl.protocol.ProtocolException
- If an error in the underlying connection happened.public nl.cwi.monetdb.mcl.responses.AbstractDataBlockResponse getAnEmptyDataBlockResponse(int rowcount, int columncount, nl.cwi.monetdb.mcl.protocol.AbstractProtocol protocol, int[] JdbcSQLTypes)
getAnEmptyDataBlockResponse
in class nl.cwi.monetdb.mcl.protocol.AbstractProtocol
public nl.cwi.monetdb.mcl.responses.AbstractDataBlockResponse getNextDatablockResponse(Map<Integer,nl.cwi.monetdb.mcl.responses.ResultSetResponse> rsresponses) throws nl.cwi.monetdb.mcl.protocol.ProtocolException
getNextDatablockResponse
in class nl.cwi.monetdb.mcl.protocol.AbstractProtocol
rsresponses
- A map of ResultSetResponse, in which this Block will belong to one of them, by checking its id
against the keys of the Map.nl.cwi.monetdb.mcl.protocol.ProtocolException
- If an error in the underlying connection happened.public int getNextTableHeader(String[] columnNames, int[] columnLengths, String[] types, String[] tableNames) throws nl.cwi.monetdb.mcl.protocol.ProtocolException
getNextTableHeader
in class nl.cwi.monetdb.mcl.protocol.AbstractProtocol
columnNames
- The column names arraycolumnLengths
- The column lengths arraytypes
- The columns SQL names arraytableNames
- The columns schemas and names in format schema.tablenl.cwi.monetdb.mcl.protocol.ProtocolException
- If an error in the underlying connection happened.public String getRemainingStringLine(int startIndex)
getRemainingStringLine
in class nl.cwi.monetdb.mcl.protocol.AbstractProtocol
startIndex
- The first index in the response line to retrieve the String (ignored)public void writeNextQuery(String prefix, String query, String suffix) throws IOException
writeNextQuery
in class nl.cwi.monetdb.mcl.protocol.AbstractProtocol
prefix
- The prefix to append at the beginning of the query string (ignored)query
- The user query to submit to the serversuffix
- The suffix to append at the end of the query string (ignored)IOException
- If an error in the underlying connection happened.Copyright © 2018. All rights reserved.