• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    迪恩网络公众号

Java Meta类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中org.apache.calcite.avatica.Meta的典型用法代码示例。如果您正苦于以下问题:Java Meta类的具体用法?Java Meta怎么用?Java Meta使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



Meta类属于org.apache.calcite.avatica包,在下文中一共展示了Meta类的20个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: create

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
public static JdbcResultSet create(String connectionId, int statementId,
    ResultSet resultSet, int maxRowCount, Meta.Signature signature) {
  try {
    final Calendar calendar = DateTimeUtils.calendar();
    final int fetchRowCount;
    if (maxRowCount == JdbcMeta.UNLIMITED_COUNT) {
      fetchRowCount = -1;
    } else if (maxRowCount < 0L) {
      fetchRowCount = AvaticaStatement.DEFAULT_FETCH_SIZE;
    } else if (maxRowCount > AvaticaStatement.DEFAULT_FETCH_SIZE) {
      fetchRowCount = AvaticaStatement.DEFAULT_FETCH_SIZE;
    } else {
      fetchRowCount = maxRowCount;
    }
    final Meta.Frame firstFrame = frame(null, resultSet, 0, fetchRowCount, calendar,
        Optional.of(signature));
    if (firstFrame.done) {
      resultSet.close();
    }
    return new JdbcResultSet(connectionId, statementId, true, signature,
        firstFrame);
  } catch (SQLException e) {
    throw new RuntimeException(e);
  }
}
 
开发者ID:apache,项目名称:calcite-avatica,代码行数:26,代码来源:JdbcResultSet.java


示例2: fetch

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
public Frame fetch(StatementHandle h, long offset, int fetchMaxRowCount) throws
    NoSuchStatementException, MissingResultsException {
  LOG.trace("fetching {} offset:{} fetchMaxRowCount:{}", h, offset, fetchMaxRowCount);
  try {
    final StatementInfo statementInfo = statementCache.getIfPresent(h.id);
    if (null == statementInfo) {
      // Statement might have expired, or never existed on this server.
      throw new NoSuchStatementException(h);
    }

    if (!statementInfo.isResultSetInitialized()) {
      // The Statement exists, but the results are missing. Need to call syncResults(...)
      throw new MissingResultsException(h);
    }
    if (statementInfo.getResultSet() == null) {
      return Frame.EMPTY;
    } else {
      return JdbcResultSet.frame(statementInfo, statementInfo.getResultSet(), offset,
          fetchMaxRowCount, calendar, Optional.<Meta.Signature>absent());
    }
  } catch (SQLException e) {
    throw propagate(e);
  }
}
 
开发者ID:apache,项目名称:calcite-avatica,代码行数:25,代码来源:JdbcMeta.java


示例3: create

import org.apache.calcite.avatica.Meta; //导入依赖的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;
  }
}
 
开发者ID:apache,项目名称:calcite-avatica,代码行数:26,代码来源:ArrayFactoryImpl.java


示例4: ResultSetResponse

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
@JsonCreator
public ResultSetResponse(
    @JsonProperty("connectionId") String connectionId,
    @JsonProperty("statementId") int statementId,
    @JsonProperty("ownStatement") boolean ownStatement,
    @JsonProperty("signature") Meta.Signature signature,
    @JsonProperty("firstFrame") Meta.Frame firstFrame,
    @JsonProperty("updateCount") long updateCount,
    @JsonProperty("rpcMetadata") RpcMetadataResponse rpcMetadata) {
  this.connectionId = connectionId;
  this.statementId = statementId;
  this.ownStatement = ownStatement;
  this.signature = signature;
  this.firstFrame = firstFrame;
  this.updateCount = updateCount;
  this.rpcMetadata = rpcMetadata;
}
 
开发者ID:apache,项目名称:calcite-avatica,代码行数:18,代码来源:Service.java


示例5: fromProto

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
static ResultSetResponse fromProto(Responses.ResultSetResponse msg) {
  String connectionId = null;
  if (msg.hasField(CONNECTION_ID_DESCRIPTOR)) {
    connectionId = msg.getConnectionId();
  }

  Meta.Signature signature = null;
  if (msg.hasField(SIGNATURE_DESCRIPTOR)) {
    signature = Meta.Signature.fromProto(msg.getSignature());
  }

  Meta.Frame frame = null;
  if (msg.hasField(FIRST_FRAME_DESCRIPTOR)) {
    frame = Meta.Frame.fromProto(msg.getFirstFrame());
  }

  RpcMetadataResponse metadata = null;
  if (msg.hasField(METADATA_DESCRIPTOR)) {
    metadata = RpcMetadataResponse.fromProto(msg.getMetadata());
  }

  return new ResultSetResponse(connectionId, msg.getStatementId(), msg.getOwnStatement(),
      signature, frame, msg.getUpdateCount(), metadata);
}
 
开发者ID:apache,项目名称:calcite-avatica,代码行数:25,代码来源:Service.java


示例6: deserialize

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

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

  Meta.ConnectionProperties connProps = null;
  if (msg.hasField(CONN_PROPS_DESCRIPTOR)) {
    connProps = ConnectionPropertiesImpl.fromProto(msg.getConnProps());
  }

  return new ConnectionSyncRequest(connectionId, connProps);
}
 
开发者ID:apache,项目名称:calcite-avatica,代码行数:17,代码来源:Service.java


示例7: apply

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
public ExecuteResponse apply(ExecuteRequest request) {
  try (final Context ignore = executeTimer.start()) {
    try {
      final Meta.ExecuteResult executeResult = meta.execute(request.statementHandle,
          request.parameterValues, AvaticaUtils.toSaturatedInt(request.maxRowCount));

      final List<ResultSetResponse> results = new ArrayList<>(executeResult.resultSets.size());
      for (Meta.MetaResultSet metaResultSet : executeResult.resultSets) {
        results.add(toResponse(metaResultSet));
      }
      return new ExecuteResponse(results, false, serverLevelRpcMetadata);
    } catch (NoSuchStatementException e) {
      return new ExecuteResponse(null, true, serverLevelRpcMetadata);
    }
  }
}
 
开发者ID:apache,项目名称:calcite-avatica,代码行数:17,代码来源:LocalService.java


示例8: toResultSet

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
private MetaResultSet toResultSet(Class clazz,
    Service.ResultSetResponse response) {
  if (response.updateCount != -1) {
    return MetaResultSet.count(response.connectionId, response.statementId,
        response.updateCount);
  }
  Signature signature0 = response.signature;
  if (signature0 == null) {
    final List<ColumnMetaData> columns =
        clazz == null
            ? Collections.<ColumnMetaData>emptyList()
            : fieldMetaData(clazz).columns;
    signature0 = Signature.create(columns,
        "?", Collections.<AvaticaParameter>emptyList(), CursorFactory.ARRAY,
        Meta.StatementType.SELECT);
  }
  return MetaResultSet.create(response.connectionId, response.statementId,
      response.ownStatement, signature0, response.firstFrame);
}
 
开发者ID:apache,项目名称:calcite-avatica,代码行数:20,代码来源:RemoteMeta.java


示例9: apply

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
@Override public ExecuteResponse apply(ExecuteRequest request) {
  expectedParameterValues.addAll(request.parameterValues);

  final Meta.Signature signature =
      new Meta.Signature(Collections.<ColumnMetaData>emptyList(),
          "SELECT 1 FROM VALUE()",
          Collections.<AvaticaParameter>emptyList(),
          Collections.<String, Object>emptyMap(),
          CursorFactory.LIST, Meta.StatementType.SELECT);

  final Service.ResultSetResponse resultSetResponse =
      new Service.ResultSetResponse(UUID.randomUUID().toString(),
          RANDOM.nextInt(), false, signature, Meta.Frame.EMPTY, -1L, null);

  return new Service.ExecuteResponse(
      Collections.singletonList(resultSetResponse), false, null);
}
 
开发者ID:apache,项目名称:calcite-avatica,代码行数:18,代码来源:JsonHandlerTest.java


示例10: newPreparedStatement

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
@Override
public DremioJdbc41PreparedStatement newPreparedStatement(AvaticaConnection connection,
                                                     StatementHandle h,
                                                     Meta.Signature signature,
                                                     int resultSetType,
                                                     int resultSetConcurrency,
                                                     int resultSetHoldability)
    throws SQLException {
  DremioConnectionImpl dremioConnection = (DremioConnectionImpl) connection;
  DremioClient client = dremioConnection.getClient();
  if (dremioConnection.getConfig().isServerPreparedStatementDisabled() || !client.getSupportedMethods().contains(ServerMethod.PREPARED_STATEMENT)) {
    // fallback to client side prepared statement
    return new DremioJdbc41PreparedStatement(dremioConnection, h, signature, null, resultSetType, resultSetConcurrency, resultSetHoldability);
  }
  return newServerPreparedStatement(dremioConnection, h, signature, resultSetType,
      resultSetConcurrency, resultSetHoldability);
}
 
开发者ID:dremio,项目名称:dremio-oss,代码行数:18,代码来源:DremioJdbc41Factory.java


示例11: newPreparedStatement

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
@Override
public DrillJdbc41PreparedStatement newPreparedStatement(AvaticaConnection connection,
                                                     StatementHandle h,
                                                     Meta.Signature signature,
                                                     int resultSetType,
                                                     int resultSetConcurrency,
                                                     int resultSetHoldability)
    throws SQLException {
  DrillConnectionImpl drillConnection = (DrillConnectionImpl) connection;
  DrillClient client = drillConnection.getClient();
  if (drillConnection.getConfig().isServerPreparedStatementDisabled() || !client.getSupportedMethods().contains(ServerMethod.PREPARED_STATEMENT)) {
    // fallback to client side prepared statement
    return new DrillJdbc41PreparedStatement(drillConnection, h, signature, null, resultSetType, resultSetConcurrency, resultSetHoldability);
  }
  return newServerPreparedStatement(drillConnection, h, signature, resultSetType,
      resultSetConcurrency, resultSetHoldability);
}
 
开发者ID:axbaretto,项目名称:drill,代码行数:18,代码来源:DrillJdbc41Factory.java


示例12: DataProvider

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
public DataProvider(AtsdConnectionInfo connectionInfo, String query, StatementContext context,
					Meta.StatementType statementType) {
	final String endpoint;
	switch (statementType) {
		case SELECT: {
			if (context.isEncodeTags()) {
				endpoint = Location.SQL_ENDPOINT.getUrl(connectionInfo) + "?encodeTags=true";
			} else {
				endpoint = Location.SQL_ENDPOINT.getUrl(connectionInfo);
			}
			break;
		}
		case INSERT:
		case UPDATE: {
               endpoint = Location.COMMAND_ENDPOINT.getUrl(connectionInfo);
			break;
		}
		default: throw new IllegalArgumentException("Unsupported statement type: " + statementType);
	}
	this.contentDescription = new ContentDescription(endpoint, connectionInfo, query, context);
	logger.trace("Endpoint: {}", contentDescription.getEndpoint());
	this.contentProtocol = ProtocolFactory.create(SdkProtocolImpl.class, contentDescription);
	this.context = context;
}
 
开发者ID:axibase,项目名称:atsd-jdbc,代码行数:25,代码来源:DataProvider.java


示例13: testConverUpdateToSeriesWithLikeComparison

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
@Test
public void testConverUpdateToSeriesWithLikeComparison() throws SQLException {
    AtsdSqlUpdateConverter converter = (AtsdSqlUpdateConverter) AtsdSqlConverterFactory.getConverter(Meta.StatementType.UPDATE, false);
    String sql = "update atsd_series set time=123456789, value=24.5, tags.unit='celcius' where entity='sensor-1' and " +
            "metric like 'jvm_memory_free'";
    List<String> commands = converter.convertToCommands(sql);
    Assert.assertEquals(1, commands.size());
    String expected = "series e:sensor-1 ms:123456789 t:unit=celcius m:jvm_memory_free=24.5";
    Assert.assertEquals(expected, commands.get(0));

    sql = "update atsd_series set time=123456789, value=24.5, tags.unit='celcius' where entity='sensor-1' and " +
            "metric like 'jvm#_memory#_free' escape '#'";
    commands = converter.convertToCommands(sql);
    Assert.assertEquals(1, commands.size());
    Assert.assertEquals(expected, commands.get(0));

    sql = "update atsd_series set time=123456789, value=24.5, tags.unit='celcius' where entity='sensor-1' and " +
            "metric like ? escape '#'";
    commands = converter.convertToCommands(sql, Arrays.<Object>asList("jvm#_memory#_free"));
    Assert.assertEquals(1, commands.size());
    Assert.assertEquals(expected, commands.get(0));
}
 
开发者ID:axibase,项目名称:atsd-jdbc,代码行数:23,代码来源:AtsdSqlConverterTest.java


示例14: testConvertInsertToSeriesWithTimestamp

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
@Test
public void testConvertInsertToSeriesWithTimestamp() throws SQLException, ParseException {
    final String sql = "INSERT INTO 'test.temperature' (entity, datetime, value, text, tags.unit) VALUES ('sensor-01', '2017-07-12 04:05:00.34567', " +
            "24.5, null, 'Celcius')";

    AtsdSqlInsertConverter converter = (AtsdSqlInsertConverter) AtsdSqlConverterFactory.getConverter(Meta.StatementType.INSERT, true);
    List<String> commands = converter.convertToCommands(sql);
    Assert.assertEquals(1, commands.size());
    String expected = "series e:sensor-01 d:2017-07-12T04:05:00.345Z t:unit=Celcius m:test.temperature=24.5";
    Assert.assertEquals(expected, commands.get(0));

    converter = (AtsdSqlInsertConverter) AtsdSqlConverterFactory.getConverter(Meta.StatementType.INSERT, false);
    commands = converter.convertToCommands(sql);
    Assert.assertEquals(1, commands.size());
    SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd'T'HH:mm:ss.SSS'Z'");
    Date date = sdf.parse("2017-07-12T04:05:00.345Z");
    sdf.setTimeZone(TimeZone.getTimeZone("UTC"));
    expected = "series e:sensor-01 d:" + sdf.format(date) + " t:unit=Celcius m:test.temperature=24.5";
    Assert.assertEquals(expected, commands.get(0));
}
 
开发者ID:axibase,项目名称:atsd-jdbc,代码行数:21,代码来源:AtsdSqlConverterTest.java


示例15: testConvertInsertToSeriesAndMetricCommands

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
@Test
public void testConvertInsertToSeriesAndMetricCommands() throws SQLException {
    String sql = "INSERT INTO 'm-local-1' (entity, value, datetime, tags.test1, metric.tags.test1, metric.label, metric.enabled, metric.interpolate" +
            ", metric.timeZone, metric.description, metric.filter, metric.versioning, metric.units, metric.invalidValueAction, metric.maxValue" +
            ", metric.minValue) VALUES ('e-local-1', 123.0, '2017-07-12T08:05:02Z', 'S1', 'M1', 'label1', true, 'linear', 'UTC', 'description 1'" +
            ", 'filter 1', false, 'unit1', 'none', 12345, 123)";

    AtsdSqlInsertConverter converter = (AtsdSqlInsertConverter) AtsdSqlConverterFactory.getConverter(Meta.StatementType.INSERT, true);
    List<String> commands = converter.convertToCommands(sql);
    Assert.assertEquals(2, commands.size());
    String expectedSeries = "series e:e-local-1 d:2017-07-12T08:05:02Z t:test1=S1 m:m-local-1=123.0";
    Assert.assertEquals(expectedSeries, commands.get(0));
    String expectedMetric = "metric m:m-local-1 b:true l:label1 d:\"description 1\" i:linear u:unit1 f:\"filter 1\" z:UTC v:false a:none min:123.0 " +
            "max:12345.0 t:test1=M1";
    Assert.assertEquals(expectedMetric, commands.get(1));
}
 
开发者ID:axibase,项目名称:atsd-jdbc,代码行数:17,代码来源:AtsdSqlConverterTest.java


示例16: testConvertUpdateToSeriesAndMetricCommands

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
@Test
public void testConvertUpdateToSeriesAndMetricCommands() throws SQLException {
    String sql = "UPDATE 'm-local-1' SET value=123, datetime='2017-07-12T08:05:02Z', tags.test1='S1', metric.tags.test1='M1', metric.label='label1'" +
            ", metric.enabled=true, metric.interpolate='linear', metric.timeZone='UTC', metric.description='description 1', metric.filter='filter 1'" +
            ", metric.versioning=false, metric.units='unit1', metric.invalidValueAction='none', metric.maxValue=12345, metric.minValue=123" +
            " WHERE entity='e-local-1'";

    AtsdSqlUpdateConverter converter = (AtsdSqlUpdateConverter) AtsdSqlConverterFactory.getConverter(Meta.StatementType.UPDATE, true);
    List<String> commands = converter.convertToCommands(sql);
    Assert.assertEquals(2, commands.size());
    String expectedSeries = "series e:e-local-1 d:2017-07-12T08:05:02Z t:test1=S1 m:m-local-1=123.0";
    Assert.assertEquals(expectedSeries, commands.get(0));
    String expectedMetric = "metric m:m-local-1 b:true l:label1 d:\"description 1\" i:linear u:unit1 f:\"filter 1\" z:UTC v:false a:none min:123.0 " +
            "max:12345.0 t:test1=M1";
    Assert.assertEquals(expectedMetric, commands.get(1));
}
 
开发者ID:axibase,项目名称:atsd-jdbc,代码行数:17,代码来源:AtsdSqlConverterTest.java


示例17: data

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
@Parameterized.Parameters
public static Collection<Object[]> data() {
	return Arrays.asList(new Object[][]{
			{"SELECT * FROM jvm_memory_used", Meta.StatementType.SELECT},
			{"SELECT\n *\n  FROM jvm_memory_used", Meta.StatementType.SELECT},
			{"SELECT\t*\tFROM\tjvm_memory_used", Meta.StatementType.SELECT},
			{"SELECT * FROM jvm_memory_used", Meta.StatementType.SELECT},
			{"INSERT INTO test_table (entity, datetime, value) VALUES ('test_entity', '2017-01-01T00:00:00Z', 42.0)", Meta.StatementType.INSERT},
			{"INSERT\nINTO\ntest_table\n(entity, datetime, value)\nVALUES\n('test_entity', '2017-01-01T00:00:00Z', 42.0)", Meta.StatementType.INSERT},
			{"INSERT\tINTO\ttest_table\t(entity, datetime, value)\nVALUES\n('test_entity', '2017-01-01T00:00:00Z', 42.0)", Meta.StatementType.INSERT},
			{" INSERT INTO test_table (entity, datetime, value) VALUES ('test_entity', '2017-01-01T00:00:00Z', 42.0)", Meta.StatementType.INSERT},
			{"INSERT INTO \"test_table\" (entity, datetime, value) VALUES ('test_entity', '2017-01-01T00:00:00Z', 42.0)", Meta.StatementType.INSERT},
			{"UPDATE test_table SET value = -1 WHERE entity ='test_entity' AND datetime = '2017-01-01T00:00:00Z'", Meta.StatementType.UPDATE},
			{"UPDATE\ntest_table\nSET value = -1\nWHERE entity ='test_entity' AND datetime = '2017-01-01T00:00:00Z'", Meta.StatementType.UPDATE},
			{"UPDATE\ttest_table\tSET value = -1\tWHERE entity ='test_entity' AND datetime = '2017-01-01T00:00:00Z'", Meta.StatementType.UPDATE},
			{" UPDATE test_table SET value = -1 WHERE entity ='test_entity' AND datetime = '2017-01-01T00:00:00Z'", Meta.StatementType.UPDATE},
			{"UPDATE \"test_table\" SET value = -1 WHERE entity ='test_entity' AND datetime = '2017-01-01T00:00:00Z'", Meta.StatementType.UPDATE},
	});
}
 
开发者ID:axibase,项目名称:atsd-jdbc,代码行数:20,代码来源:StatementTypeByQueryRecognizerTest.java


示例18: createResultSet

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
protected MetaResultSet createResultSet(
        Map<String, Object> internalParameters, List<ColumnMetaData> columns,
        CursorFactory cursorFactory, final Frame firstFrame) {
    try {
        final CalciteConnectionImpl connection = getConnection();
        final AvaticaStatement statement = connection.createStatement();
        final CalcitePrepare.CalciteSignature<Object> signature =
                new CalcitePrepare.CalciteSignature<Object>("",
                        ImmutableList.<AvaticaParameter>of(), internalParameters, null,
                        columns, cursorFactory, ImmutableList.<RelCollation>of(), -1,
                        null, Meta.StatementType.SELECT) {
                    @Override
                    public Enumerable<Object> enumerable(
                            DataContext dataContext) {
                        return Linq4j.asEnumerable(firstFrame.rows);
                    }
                };
        return MetaResultSet.create(connection.id, statement.getId(), true,
                signature, firstFrame);
    } catch (SQLException e) {
        throw new RuntimeException(e);
    }
}
 
开发者ID:bitnine-oss,项目名称:octopus,代码行数:24,代码来源:CalciteMetaImpl.java


示例19: fetch

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
@Override
public Frame fetch(StatementHandle h, long offset, int fetchMaxRowCount) {
    final CalciteConnectionImpl calciteConnection = getConnection();
    CalciteServerStatement stmt = calciteConnection.getServer().getStatement(h);
    final Signature signature = stmt.getSignature();
    final Iterator<Object> iterator;
    if (stmt.getResultSet() == null) {
        final Iterable<Object> iterable =
                createIterableImpl(h, signature, null, null);
        iterator = iterable.iterator();
        stmt.setResultSet(iterator);
    } else {
        iterator = stmt.getResultSet();
    }
    final List<List<Object>> list = new ArrayList<>();
    List<List<Object>> rows =
            MetaImpl.collect(signature.cursorFactory,
                    LimitIterator.of(iterator, fetchMaxRowCount), list);
    boolean done = fetchMaxRowCount == 0 || list.size() < fetchMaxRowCount;
    return new Meta.Frame(offset, done, (List<Object>) (List) rows);
}
 
开发者ID:bitnine-oss,项目名称:octopus,代码行数:22,代码来源:CalciteMetaImpl.java


示例20: CalciteSignature

import org.apache.calcite.avatica.Meta; //导入依赖的package包/类
CalciteSignature(String sql,
                 List<AvaticaParameter> parameterList,
                 Map<String, Object> internalParameters,
                 RelDataType rowType,
                 List<ColumnMetaData> columns,
                 Meta.CursorFactory cursorFactory,
                 List<RelCollation> collationList,
                 long maxRowCount,
                 Bindable<T> bindable,
                 Meta.StatementType statementType) {
    super(columns, sql, parameterList, internalParameters, cursorFactory,
            statementType);
    this.rowType = rowType;
    this.collationList = collationList;
    this.maxRowCount = maxRowCount;
    this.bindable = bindable;
}
 
开发者ID:bitnine-oss,项目名称:octopus,代码行数:18,代码来源:CalcitePrepare.java



注:本文中的org.apache.calcite.avatica.Meta类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java CacheEntryFactory类代码示例发布时间:2022-05-22
下一篇:
Java PATHCONF3Response类代码示例发布时间:2022-05-22
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap