本文整理汇总了Java中org.apache.calcite.avatica.Meta.Signature类的典型用法代码示例。如果您正苦于以下问题:Java Signature类的具体用法?Java Signature怎么用?Java Signature使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
Signature类属于org.apache.calcite.avatica.Meta包,在下文中一共展示了Signature类的18个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: testPrepareAndExecuteSetsMaxRows
import org.apache.calcite.avatica.Meta.Signature; //导入依赖的package包/类
@Test public void testPrepareAndExecuteSetsMaxRows() throws Exception {
final String id = UUID.randomUUID().toString();
final int statementId = 12345;
final String sql = "SELECT * FROM FOO";
final int maxRows = 500;
JdbcMeta meta = Mockito.mock(JdbcMeta.class);
PreparedStatement statement = Mockito.mock(PreparedStatement.class);
@SuppressWarnings("unchecked")
Cache<Integer, StatementInfo> statementCache =
(Cache<Integer, StatementInfo>) Mockito.mock(Cache.class);
Signature signature = Mockito.mock(Signature.class);
final StatementInfo statementInfo = new StatementInfo(statement);
final StatementHandle statementHandle = new StatementHandle(id, statementId, signature);
Mockito.when(meta.getStatementCache()).thenReturn(statementCache);
Mockito.when(statementCache.getIfPresent(statementId)).thenReturn(statementInfo);
Mockito.when(statement.getResultSet()).thenReturn(null);
// The real methods
Mockito.when(meta.prepareAndExecute(statementHandle, sql, maxRows, 50, null)).
thenCallRealMethod();
Mockito.doCallRealMethod().when(meta).setMaxRows(statement, maxRows);
// Call our method
meta.prepareAndExecute(statementHandle, sql, maxRows, 50, null);
// Verify we called setMaxRows with the right value
Mockito.verify(statement).setMaxRows(maxRows);
}
开发者ID:apache,项目名称:calcite-avatica,代码行数:31,代码来源:JdbcMetaTest.java
示例2: AvaticaPreparedStatement
import org.apache.calcite.avatica.Meta.Signature; //导入依赖的package包/类
/**
* Creates an AvaticaPreparedStatement.
*
* @param connection Connection
* @param h Statement handle
* @param signature Result of preparing statement
* @param resultSetType Result set type
* @param resultSetConcurrency Result set concurrency
* @param resultSetHoldability Result set holdability
* @throws SQLException If fails due to underlying implementation reasons.
*/
protected AvaticaPreparedStatement(AvaticaConnection connection,
Meta.StatementHandle h,
Meta.Signature signature,
int resultSetType,
int resultSetConcurrency,
int resultSetHoldability) throws SQLException {
super(connection, h, resultSetType, resultSetConcurrency,
resultSetHoldability, signature);
this.slots = new TypedValue[signature.parameters.size()];
this.resultSetMetaData =
connection.factory.newResultSetMetaData(this, signature);
this.parameterValueBatch = new ArrayList<>();
}
开发者ID:apache,项目名称:calcite-avatica,代码行数:25,代码来源:AvaticaPreparedStatement.java
示例3: DremioCursor
import org.apache.calcite.avatica.Meta.Signature; //导入依赖的package包/类
/**
*
* @param statement
* @param signature
*/
DremioCursor(DremioConnectionImpl connection, AvaticaStatement statement, Signature signature) {
this.connection = connection;
this.statement = statement;
this.signature = signature;
DremioClient client = connection.getClient();
final int batchQueueThrottlingThreshold =
client.getConfig().getInt(
ExecConstants.JDBC_BATCH_QUEUE_THROTTLING_THRESHOLD );
resultsListener = new ResultsListener(batchQueueThrottlingThreshold);
currentBatchHolder = new RecordBatchLoader(client.getAllocator());
}
开发者ID:dremio,项目名称:dremio-oss,代码行数:18,代码来源:DremioCursor.java
示例4: DrillCursor
import org.apache.calcite.avatica.Meta.Signature; //导入依赖的package包/类
/**
*
* @param statement
* @param signature
*/
DrillCursor(DrillConnectionImpl connection, AvaticaStatement statement, Signature signature) {
this.connection = connection;
this.statement = statement;
this.signature = signature;
DrillClient client = connection.getClient();
final int batchQueueThrottlingThreshold =
client.getConfig().getInt(
ExecConstants.JDBC_BATCH_QUEUE_THROTTLING_THRESHOLD );
resultsListener = new ResultsListener(batchQueueThrottlingThreshold);
currentBatchHolder = new RecordBatchLoader(client.getAllocator());
}
开发者ID:axbaretto,项目名称:drill,代码行数:18,代码来源:DrillCursor.java
示例5: ContentMetadata
import org.apache.calcite.avatica.Meta.Signature; //导入依赖的package包/类
public ContentMetadata(String scheme, String sql, String catalog, String connectionId, int statementId, boolean assignColumnNames, boolean odbcCompatible)
throws AtsdException, IOException {
this.metadataList = StringUtils.isNotEmpty(scheme) ? buildMetadataList(scheme, catalog, assignColumnNames, odbcCompatible)
: Collections.<ColumnMetaData>emptyList();
this.sign = new Signature(metadataList, sql, Collections.<AvaticaParameter>emptyList(), null, CursorFactory.LIST,
StatementType.SELECT);
this.list = Collections.unmodifiableList(
Collections.singletonList(MetaResultSet.create(connectionId, statementId, false, sign, null)));
}
开发者ID:axibase,项目名称:atsd-jdbc,代码行数:10,代码来源:ContentMetadata.java
示例6: AtsdResultSet
import org.apache.calcite.avatica.Meta.Signature; //导入依赖的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);
}
开发者ID:axibase,项目名称:atsd-jdbc,代码行数:10,代码来源:AtsdResultSet.java
示例7: mockPreparedSignature
import org.apache.calcite.avatica.Meta.Signature; //导入依赖的package包/类
Signature mockPreparedSignature(String sql) {
List<AvaticaParameter> params = new ArrayList<AvaticaParameter>();
int startIndex = 0;
while (sql.indexOf("?", startIndex) >= 0) {
AvaticaParameter param = new AvaticaParameter(false, 0, 0, 0, null, null, null);
params.add(param);
startIndex = sql.indexOf("?", startIndex) + 1;
}
ArrayList<ColumnMetaData> columns = new ArrayList<ColumnMetaData>();
Map<String, Object> internalParams = Collections.<String, Object> emptyMap();
return new Meta.Signature(columns, sql, params, internalParams, CursorFactory.ARRAY, Meta.StatementType.SELECT);
}
开发者ID:apache,项目名称:kylin,代码行数:15,代码来源:KylinConnection.java
示例8: executeQuery
import org.apache.calcite.avatica.Meta.Signature; //导入依赖的package包/类
public ResultSet executeQuery() throws SQLException {
this.updateCount = -1;
final Signature sig = getSignature();
return getConnection().executeQueryInternal(this, sig, null,
new QueryState(sig.sql), false);
}
开发者ID:apache,项目名称:calcite-avatica,代码行数:7,代码来源:AvaticaPreparedStatement.java
示例9: getRequests
import org.apache.calcite.avatica.Meta.Signature; //导入依赖的package包/类
/**
* Generates a collection of Requests whose serialization will be tested.
*/
private static List<Request> getRequests() {
LinkedList<Request> requests = new LinkedList<>();
requests.add(new CatalogsRequest());
requests.add(new DatabasePropertyRequest());
requests.add(new SchemasRequest("connectionId", "catalog", "schemaPattern"));
requests.add(
new TablesRequest("connectionId", "catalog", "schemaPattern", "tableNamePattern",
Arrays.asList("STRING", "BOOLEAN", "INT")));
requests.add(new TableTypesRequest());
requests.add(
new ColumnsRequest("connectionId", "catalog", "schemaPattern", "tableNamePattern",
"columnNamePattern"));
requests.add(new TypeInfoRequest());
requests.add(
new PrepareAndExecuteRequest("connectionId", Integer.MAX_VALUE, "sql",
Long.MAX_VALUE));
requests.add(new PrepareRequest("connectionId", "sql", Long.MAX_VALUE));
List<TypedValue> paramValues =
Arrays.asList(TypedValue.create(Rep.BOOLEAN.name(), Boolean.TRUE),
TypedValue.create(Rep.STRING.name(), "string"));
FetchRequest fetchRequest = new FetchRequest("connectionId", Integer.MAX_VALUE,
Long.MAX_VALUE, Integer.MAX_VALUE);
requests.add(fetchRequest);
requests.add(new CreateStatementRequest("connectionId"));
requests.add(new CloseStatementRequest("connectionId", Integer.MAX_VALUE));
Map<String, String> info = new HashMap<>();
info.put("param1", "value1");
info.put("param2", "value2");
requests.add(new OpenConnectionRequest("connectionId", info));
requests.add(new CloseConnectionRequest("connectionId"));
requests.add(
new ConnectionSyncRequest("connectionId",
new ConnectionPropertiesImpl(Boolean.FALSE, Boolean.FALSE,
Integer.MAX_VALUE, "catalog", "schema")));
requests.add(new SyncResultsRequest("connectionId", 12345, getSqlQueryState(), 150));
requests.add(new SyncResultsRequest("connectionId2", 54321, getMetadataQueryState1(), 0));
requests.add(new SyncResultsRequest("connectionId3", 5, getMetadataQueryState2(), 10));
requests.add(new CommitRequest("connectionId"));
requests.add(new RollbackRequest("connectionId"));
// ExecuteBatchRequest omitted because of the special protobuf conversion it does
List<String> commands = Arrays.asList("command1", "command2", "command3");
requests.add(new PrepareAndExecuteBatchRequest("connectionId", 12345, commands));
List<ColumnMetaData> columns = Collections.emptyList();
List<AvaticaParameter> params = Collections.emptyList();
Meta.CursorFactory cursorFactory = Meta.CursorFactory.create(Style.LIST, Object.class,
Collections.<String>emptyList());
Signature signature = Signature.create(columns, "sql", params, cursorFactory,
Meta.StatementType.SELECT);
Meta.StatementHandle handle = new Meta.StatementHandle("1234", 1, signature);
requests.add(new ExecuteRequest(handle, Arrays.<TypedValue>asList((TypedValue) null), 10));
requests.add(new ExecuteRequest(handle, Arrays.asList(TypedValue.EXPLICIT_NULL), 10));
return requests;
}
开发者ID:apache,项目名称:calcite-avatica,代码行数:67,代码来源:ProtobufTranslationImplTest.java
示例10: getSignature
import org.apache.calcite.avatica.Meta.Signature; //导入依赖的package包/类
private Signature getSignature() {
return null;
}
开发者ID:apache,项目名称:calcite-avatica,代码行数:4,代码来源:ProtobufSerializationTest.java
示例11: AtsdPreparedStatement
import org.apache.calcite.avatica.Meta.Signature; //导入依赖的package包/类
protected AtsdPreparedStatement(AvaticaConnection connection, StatementHandle h, Signature signature,
int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException {
super(connection, h, signature, resultSetType, resultSetConcurrency, resultSetHoldability);
logger.trace("[new] {}", this.handle.id);
}
开发者ID:axibase,项目名称:atsd-jdbc,代码行数:6,代码来源:AtsdPreparedStatement.java
示例12: AtsdStatement
import org.apache.calcite.avatica.Meta.Signature; //导入依赖的package包/类
protected AtsdStatement(AvaticaConnection connection, StatementHandle statementHandle, int resultSetType,
int resultSetConcurrency, int resultSetHoldability, Signature signature) {
super(connection, statementHandle, resultSetType, resultSetConcurrency, resultSetHoldability, signature);
logger.trace("[AtsdStatement#new] {}", this.handle.id);
}
开发者ID:axibase,项目名称:atsd-jdbc,代码行数:6,代码来源:AtsdStatement.java
示例13: KylinPreparedStatement
import org.apache.calcite.avatica.Meta.Signature; //导入依赖的package包/类
protected KylinPreparedStatement(AvaticaConnection connection, StatementHandle h, Signature signature, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException {
super(connection, h, signature, resultSetType, resultSetConcurrency, resultSetHoldability);
if (this.handle.signature == null)
this.handle.signature = signature;
}
开发者ID:apache,项目名称:kylin,代码行数:6,代码来源:KylinPreparedStatement.java
示例14: newPreparedStatement
import org.apache.calcite.avatica.Meta.Signature; //导入依赖的package包/类
@Override
public AvaticaPreparedStatement newPreparedStatement(AvaticaConnection connection, StatementHandle h, Signature signature, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException {
return new KylinPreparedStatement((KylinConnection) connection, h, signature, resultSetType, resultSetConcurrency, resultSetHoldability);
}
开发者ID:apache,项目名称:kylin,代码行数:5,代码来源:KylinJdbcFactory.java
示例15: newResultSet
import org.apache.calcite.avatica.Meta.Signature; //导入依赖的package包/类
@Override
public AvaticaResultSet newResultSet(AvaticaStatement statement, QueryState state, Signature signature, TimeZone timeZone, Frame firstFrame) throws SQLException {
AvaticaResultSetMetaData resultSetMetaData = new AvaticaResultSetMetaData(statement, null, signature);
return new KylinResultSet(statement, state, signature, resultSetMetaData, timeZone, firstFrame);
}
开发者ID:apache,项目名称:kylin,代码行数:6,代码来源:KylinJdbcFactory.java
示例16: newResultSetMetaData
import org.apache.calcite.avatica.Meta.Signature; //导入依赖的package包/类
@Override
public ResultSetMetaData newResultSetMetaData(AvaticaStatement statement, Signature signature) throws SQLException {
return new AvaticaResultSetMetaData(statement, null, signature);
}
开发者ID:apache,项目名称:kylin,代码行数:5,代码来源:KylinJdbcFactory.java
示例17: KylinResultSet
import org.apache.calcite.avatica.Meta.Signature; //导入依赖的package包/类
public KylinResultSet(AvaticaStatement statement, QueryState state, Signature signature, ResultSetMetaData resultSetMetaData, TimeZone timeZone, Frame firstFrame) {
super(statement, state, signature, resultSetMetaData, timeZone, firstFrame);
}
开发者ID:apache,项目名称:kylin,代码行数:4,代码来源:KylinResultSet.java
示例18: prepareStatement
import org.apache.calcite.avatica.Meta.Signature; //导入依赖的package包/类
@Override
public PreparedStatement prepareStatement(String sql, int resultSetType, int resultSetConcurrency, int resultSetHoldability) throws SQLException {
Meta.Signature sig = mockPreparedSignature(sql);
return factory().newPreparedStatement(this, null, sig, resultSetType, resultSetConcurrency, resultSetHoldability);
}
开发者ID:apache,项目名称:kylin,代码行数:6,代码来源:KylinConnection.java
注:本文中的org.apache.calcite.avatica.Meta.Signature类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论