+
−package nl.cwi.monetdb.mcl.responses;
+
−
+
−import nl.cwi.monetdb.mcl.protocol.AbstractProtocol;
+
−import nl.cwi.monetdb.mcl.protocol.MCLParseException;
+
−import nl.cwi.monetdb.mcl.protocol.ServerResponses;
+
−
+
−import java.sql.SQLException;
+
−
+
−/**
+
− * The DataBlockResponse is tabular data belonging to a
+
− * ResultSetResponse.  Tabular data from the server typically looks
+
− * like:
+
− * <pre>
+
− * [ "value",	56	]
+
− * </pre>
+
− * where each column is separated by ",\t" and each tuple surrounded
+
− * by brackets ("[" and "]").  A DataBlockResponse object holds the
+
− * raw data as read from the server, in a parsed manner, ready for
+
− * easy retrieval.
+
− *
+
− * This object is not intended to be queried by multiple threads
+
− * synchronously. It is designed to work for one thread retrieving
+
− * rows from it.  When multiple threads will retrieve rows from this
+
− * object, it is possible for threads to get the same data.
+
− */
+
−public class DataBlockResponse implements IIncompleteResponse {
+
−
+
−    /** The array to keep the data in */
+
−    private final Object[][] data;
+
−    /** The counter which keeps the current position in the data array */
+
−    private int pos;
+
−    /** Whether we can discard lines as soon as we have read them */
+
−    private boolean forwardOnly;
+
−    /** The connection protocol to parse the tuple lines */
+
−    private final AbstractProtocol<?> protocol;
+
−    /** The JdbcSQLTypes mapping */
+
−    private final int[] jdbcSQLTypes;
+
−
+
−    /**
+
−     * Constructs a DataBlockResponse object
+
−     * @param rowcount the number of rows
+
−     * @param columncount the number of columns
+
−     * @param forward whether this is a forward only result
+
−     */
+
−    DataBlockResponse(int rowcount, int columncount, boolean forward, AbstractProtocol<?> protocol, int[] JdbcSQLTypes) {
+
−        this.pos = -1;
+
−        this.forwardOnly = forward;
+
−        this.data = new Object[rowcount][columncount];
+
−        this.protocol = protocol;
+
−        this.jdbcSQLTypes = JdbcSQLTypes;
+
−    }
+
−
+
−    /**
+
−     * addLine adds a String of data to this object's data array. Note that an IndexOutOfBoundsException can be thrown
+
−     * when an attempt is made to add more than the original construction size specified.
+
−     *
+
−     * @param line the header line as String
+
−     * @param response the line type according to the MAPI protocol
+
−     * @throws MCLParseException If the result line is not expected
+
−     */
+
−    public void addLine(ServerResponses response, Object line) throws MCLParseException {
+
−        if (response != ServerResponses.RESULT)
+
−            throw new MCLParseException("protocol violation: unexpected line in data block: " + line.toString());
+
−        // add to the backing array
+
−        Object[] next = this.data[++this.pos];
+
−        this.protocol.parseTupleLine(line, next, this.jdbcSQLTypes);
+
−    }
+
−
+
−    /**
+
−     * Returns whether this Response expects more lines to be added to it.
+
−     *
+
−     * @return true if a next line should be added, false otherwise
+
−     */
+
−    @Override
+
−    public boolean wantsMore() {
+
−        // remember: pos is the value already stored
+
−        return pos + 1 < data.length;
+
−    }
+
−
+
−    /**
+
−     * Indicates that no more header lines will be added to this Response implementation. In most cases this is a
+
−     * redundant operation because the data array is full.  However... it can happen that this is NOT the case!
+
−     *
+
−     * @throws SQLException if not all rows are filled
+
−     */
+
−    @Override
+
−    public void complete() throws SQLException {
+
−        if ((pos + 1) != data.length)
+
−            throw new SQLException("Inconsistent state detected!  Current block capacity: " + data.length +
+
−                    ", block usage: " + (pos + 1) + ".  Did MonetDB send what it promised to?", "M0M10");
+
−    }
+
−
+
−    /**
+
−     * Instructs the Response implementation to close and do the necessary clean up procedures.
+
−     */
+
−    @Override
+
−    public void close() {
+
−        // feed all rows to the garbage collector
+
−        for (int i = 0; i < data.length; i++) {
+
−            data[i] = null;
+
−        }
+
−    }
+
−
+
−    /**
+
−     * Retrieves the required row.  Warning: if the requested rows is out of bounds, an IndexOutOfBoundsException will
+
−     * be thrown.
+
−     *
+
−     * @param line the row to retrieve
+
−     * @return the requested row as String
+
−     */
+
−    Object[] getRow(int line) {
+
−        if (forwardOnly) {
+
−            Object[] ret = data[line];
+
−            data[line] = null;
+
−            return ret;
+
−        } else {
+
−            return data[line];
+
−        }
+
−    }
+
−}