import org.apache.calcite.avatica.QueryState; //导入依赖的package包/类
public boolean syncResults(StatementHandle sh, QueryState state, long offset)
    throws NoSuchStatementException {
  try {
    final Connection conn = getConnection(sh.connectionId);
    final StatementInfo info = statementCache.getIfPresent(sh.id);
    if (null == info) {
      throw new NoSuchStatementException(sh);
    }
    final Statement statement = info.statement;
    // Let the state recreate the necessary ResultSet on the Statement
    info.setResultSet(state.invoke(conn, statement));

    if (null != info.getResultSet()) {
      // If it is non-null, try to advance to the requested offset.
      return info.advanceResultSetToOffset(info.getResultSet(), offset);
    }

    // No results, nothing to do. Client can move on.
    return false;
  } catch (SQLException e) {
    throw propagate(e);
  }
}
 

import org.apache.calcite.avatica.QueryState; //导入依赖的package包/类
@Override public ResultSet create(AvaticaType elementType, Iterable<Object> elements) {
  // The ColumnMetaData for offset "1" in the ResultSet for an Array.
  ScalarType arrayOffsetType = ColumnMetaData.scalar(Types.INTEGER, "INTEGER", Rep.PRIMITIVE_INT);
  // Two columns (types) in the ResultSet we will create
  List<ColumnMetaData> types = Arrays.asList(ColumnMetaData.dummy(arrayOffsetType, false),
      ColumnMetaData.dummy(elementType, true));
  List<List<Object>> rows = createResultSetRowsForArrayData(elements);
  // `(List<Object>) rows` is a compile error.
  @SuppressWarnings({ "unchecked", "rawtypes" })
  List<Object> untypedRows = (List<Object>) ((List) rows);
  try (ListIteratorCursor cursor = new ListIteratorCursor(rows.iterator())) {
    final String sql = "MOCKED";
    QueryState state = new QueryState(sql);
    Meta.Signature signature = new Meta.Signature(types, sql,
        Collections.<AvaticaParameter>emptyList(), Collections.<String, Object>emptyMap(),
        Meta.CursorFactory.LIST, Meta.StatementType.SELECT);
    AvaticaResultSetMetaData resultSetMetaData = new AvaticaResultSetMetaData(null, sql,
        signature);
    Meta.Frame frame = new Meta.Frame(0, true, untypedRows);
    AvaticaResultSet resultSet = new AvaticaResultSet(null, state, signature, resultSetMetaData,
        timeZone, frame);
    resultSet.execute2(cursor, types);
    return resultSet;
  }
}
 

import org.apache.calcite.avatica.QueryState; //导入依赖的package包/类
@Override public boolean syncResults(final StatementHandle h, final QueryState state,
    final long offset) throws NoSuchStatementException {
  try {
    return connection.invokeWithRetries(
        new CallableWithoutException<Boolean>() {
          public Boolean call() {
            final Service.SyncResultsResponse response =
                service.apply(
                    new Service.SyncResultsRequest(h.connectionId, h.id, state, offset));
            if (response.missingStatement) {
              throw new RuntimeException(new NoSuchStatementException(h));
            }
            return response.moreResults;
          }
        });
  } catch (RuntimeException e) {
    Throwable cause = e.getCause();
    if (cause instanceof NoSuchStatementException) {
      throw (NoSuchStatementException) cause;
    }
    throw e;
  }
}
 

import org.apache.calcite.avatica.QueryState; //导入依赖的package包/类
public SyncResultsRequest(@JsonProperty("connectionId") String connectionId,
    @JsonProperty("statementId") int statementId, @JsonProperty("state") QueryState state,
    @JsonProperty("offset") long offset) {
  this.connectionId = connectionId;
  this.statementId = statementId;
  this.state = state;
  this.offset = offset;
}
 

import org.apache.calcite.avatica.QueryState; //导入依赖的package包/类
Request deserialize(Message genericMsg) {
  final Requests.SyncResultsRequest msg = ProtobufService.castProtobufMessage(genericMsg,
      Requests.SyncResultsRequest.class);

  String connectionId = null;
  if (msg.hasField(CONNECTION_ID_DESCRIPTOR)) {
    connectionId = msg.getConnectionId();
  }

  int statementId = 0;
  if (msg.hasField(STATEMENT_ID_DESCRIPTOR)) {
    statementId = msg.getStatementId();
  }

  Common.QueryState state = null;
  if (msg.hasField(STATE_DESCRIPTOR)) {
    state = msg.getState();
  }

  long offset = 0;
  if (msg.hasField(OFFSET_DESCRIPTOR)) {
    offset = msg.getOffset();
  }

  return new SyncResultsRequest(connectionId, statementId,
      null == state ? null : QueryState.fromProto(msg.getState()), offset);
}
 

import org.apache.calcite.avatica.QueryState; //导入依赖的package包/类
private static QueryState getMetadataQueryState1() {
  return new QueryState(MetaDataOperation.GET_COLUMNS, new Object[] {
    "",
    null,
    "%",
    "%"
  });
}
 

import org.apache.calcite.avatica.QueryState; //导入依赖的package包/类
DremioResultSetImpl(AvaticaStatement statement, QueryState state,
                   Meta.Signature signature, ResultSetMetaData resultSetMetaData,
                   TimeZone timeZone, Meta.Frame firstFrame) {
  super(statement, state, signature, resultSetMetaData, timeZone, firstFrame);
  connection = (DremioConnectionImpl) statement.getConnection();
  client = connection.getClient();
  final int batchQueueThrottlingThreshold =
      client.getConfig().getInt(
          ExecConstants.JDBC_BATCH_QUEUE_THROTTLING_THRESHOLD );
  resultsListener = new ResultsListener(batchQueueThrottlingThreshold);
  batchLoader = new RecordBatchLoader(client.getAllocator());
  cursor = new DremioCursor(connection, statement, signature);
}
 

import org.apache.calcite.avatica.QueryState; //导入依赖的package包/类
@Override
public DremioResultSetImpl newResultSet(AvaticaStatement statement,
                                       QueryState state,
                                       Meta.Signature signature,
                                       TimeZone timeZone,
                                       Meta.Frame firstFrame) {
  final ResultSetMetaData metaData =
      newResultSetMetaData(statement, signature);
  return new DremioResultSetImpl(statement, state, signature, metaData, timeZone, firstFrame);
}
 

import org.apache.calcite.avatica.QueryState; //导入依赖的package包/类
public AtsdResultSet(AvaticaStatement statement, QueryState state, Signature signature,
					 ResultSetMetaData resultSetMetaData, TimeZone timeZone, Frame firstFrame) {
	super(statement, state, signature, resultSetMetaData, timeZone, firstFrame);
	final AtsdConnection connection = (AtsdConnection) statement.connection;
	this.meta = connection.getMeta();
	this.handle = statement.handle;
	this.context = meta.getContextFromMap(statement.handle);
	logger.trace("[ctor] {}", this.handle.id);
}
 

import org.apache.calcite.avatica.QueryState; //导入依赖的package包/类
public CalciteResultSet newResultSet(AvaticaStatement statement, QueryState state,
                                     Meta.Signature signature, TimeZone timeZone, Meta.Frame firstFrame) {
    final ResultSetMetaData metaData =
            newResultSetMetaData(statement, signature);
    final CalcitePrepare.CalciteSignature calciteSignature =
            (CalcitePrepare.CalciteSignature) signature;
    return new CalciteResultSet(statement, calciteSignature, metaData, timeZone,
            firstFrame);
}
 

import org.apache.calcite.avatica.QueryState; //导入依赖的package包/类
@Override
public AvaticaResultSet newResultSet(AvaticaStatement statement,
                                     QueryState state,
                                     Meta.Signature signature,
                                     TimeZone timeZone,
                                     Meta.Frame firstFrame) {
  final ResultSetMetaData metaData =
      newResultSetMetaData(statement, signature);
  return new QuarkResultSet(statement, signature, metaData, timeZone,
      firstFrame);
}
 

import org.apache.calcite.avatica.QueryState; //导入依赖的package包/类
public CalciteResultSet newResultSet(AvaticaStatement statement, QueryState state,
    Meta.Signature signature, TimeZone timeZone, Meta.Frame firstFrame) {
  final ResultSetMetaData metaData =
      newResultSetMetaData(statement, signature);
  final CalcitePrepare.CalciteSignature calciteSignature =
      (CalcitePrepare.CalciteSignature) signature;
  return new CalciteResultSet(statement, calciteSignature, metaData, timeZone,
      firstFrame);
}
 

import org.apache.calcite.avatica.QueryState; //导入依赖的package包/类
public Iterable<Object> createIterable(StatementHandle handle, QueryState state,
    Signature signature, List<TypedValue> parameterValues, Frame firstFrame) {
  return null;
}
 

import org.apache.calcite.avatica.QueryState; //导入依赖的package包/类
private static QueryState getSqlQueryState() {
  return new QueryState("SELECT * from TABLE");
}
 

import org.apache.calcite.avatica.QueryState; //导入依赖的package包/类
private static QueryState getMetadataQueryState2() {
  return new QueryState(MetaDataOperation.GET_CATALOGS, new Object[0]);
}
 

import org.apache.calcite.avatica.QueryState; //导入依赖的package包/类
@Override
public boolean syncResults(StatementHandle sh, QueryState state, long offset) throws NoSuchStatementException {
  throw new UnsupportedOperationException();
}
 

import org.apache.calcite.avatica.QueryState; //导入依赖的package包/类
@Override
public void queryCompleted(QueryResult.QueryState state) {
  logger.debug( "[#{}] Received query completion: {}.", instanceId, state );
  releaseIfFirst();
  completed = true;
}
 

import org.apache.calcite.avatica.QueryState; //导入依赖的package包/类
@Override
public Iterable<Object> createIterable(StatementHandle handle, QueryState state,
                                       Signature signature, List<TypedValue> parameterValues, Frame firstFrame) {
    // Drop QueryState
    return createIterableImpl(handle, signature, parameterValues, firstFrame);
}
 

import org.apache.calcite.avatica.QueryState; //导入依赖的package包/类
public boolean syncResults(StatementHandle h, QueryState state, long offset)
        throws NoSuchStatementException {
    // Doesn't have application in Calcite itself.
    throw new UnsupportedOperationException();
}
 

import org.apache.calcite.avatica.QueryState; //导入依赖的package包/类
public boolean syncResults(StatementHandle h, QueryState state, long offset)
    throws NoSuchStatementException {
  // Doesn't have application in Calcite itself.
  throw new UnsupportedOperationException();
}