本文整理汇总了Java中com.datastax.driver.mapping.Result类的典型用法代码示例。如果您正苦于以下问题：Java Result类的具体用法？Java Result怎么用？Java Result使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
Result类属于com.datastax.driver.mapping包，在下文中一共展示了Result类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: findListByStatementAsync
import com.datastax.driver.mapping.Result; //导入依赖的package包/类
protected ListenableFuture<List<D>> findListByStatementAsync(Statement statement) {
if (statement != null) {
statement.setConsistencyLevel(cluster.getDefaultReadConsistencyLevel());
ResultSetFuture resultSetFuture = getSession().executeAsync(statement);
return Futures.transform(resultSetFuture, new Function<ResultSet, List<D>>() {
@Nullable
@Override
public List<D> apply(@Nullable ResultSet resultSet) {
Result<E> result = getMapper().map(resultSet);
if (result != null) {
List<E> entities = result.all();
return DaoUtil.convertDataList(entities);
} else {
return Collections.emptyList();
}
}
});
}
return Futures.immediateFuture(Collections.emptyList());
}
开发者ID:osswangxining，项目名称:iotplatform，代码行数:21，代码来源:CassandraAbstractModelDao.java
示例2: findOneByStatementAsync
import com.datastax.driver.mapping.Result; //导入依赖的package包/类
protected ListenableFuture<D> findOneByStatementAsync(Statement statement) {
if (statement != null) {
statement.setConsistencyLevel(cluster.getDefaultReadConsistencyLevel());
ResultSetFuture resultSetFuture = getSession().executeAsync(statement);
return Futures.transform(resultSetFuture, new Function<ResultSet, D>() {
@Nullable
@Override
public D apply(@Nullable ResultSet resultSet) {
Result<E> result = getMapper().map(resultSet);
if (result != null) {
E entity = result.one();
return DaoUtil.getData(entity);
} else {
return null;
}
}
});
}
return Futures.immediateFuture(null);
}
开发者ID:osswangxining，项目名称:iotplatform，代码行数:21，代码来源:CassandraAbstractModelDao.java
示例3: findTenantDeviceTypesAsync
import com.datastax.driver.mapping.Result; //导入依赖的package包/类
@Override
public ListenableFuture<List<EntitySubtype>> findTenantDeviceTypesAsync(UUID tenantId) {
Select select = select().from(ENTITY_SUBTYPE_COLUMN_FAMILY_NAME);
Select.Where query = select.where();
query.and(eq(ENTITY_SUBTYPE_TENANT_ID_PROPERTY, tenantId));
query.and(eq(ENTITY_SUBTYPE_ENTITY_TYPE_PROPERTY, EntityType.DEVICE));
query.setConsistencyLevel(cluster.getDefaultReadConsistencyLevel());
ResultSetFuture resultSetFuture = getSession().executeAsync(query);
return Futures.transform(resultSetFuture, new Function<ResultSet, List<EntitySubtype>>() {
@Nullable
@Override
public List<EntitySubtype> apply(@Nullable ResultSet resultSet) {
Result<EntitySubtypeEntity> result = cluster.getMapper(EntitySubtypeEntity.class).map(resultSet);
if (result != null) {
List<EntitySubtype> entitySubtypes = new ArrayList<>();
result.all().forEach((entitySubtypeEntity) ->
entitySubtypes.add(entitySubtypeEntity.toEntitySubtype())
);
return entitySubtypes;
} else {
return Collections.emptyList();
}
}
});
}
开发者ID:thingsboard，项目名称:thingsboard，代码行数:26，代码来源:CassandraDeviceDao.java
示例4: findTenantAssetTypesAsync
import com.datastax.driver.mapping.Result; //导入依赖的package包/类
@Override
public ListenableFuture<List<EntitySubtype>> findTenantAssetTypesAsync(UUID tenantId) {
Select select = select().from(ENTITY_SUBTYPE_COLUMN_FAMILY_NAME);
Select.Where query = select.where();
query.and(eq(ENTITY_SUBTYPE_TENANT_ID_PROPERTY, tenantId));
query.and(eq(ENTITY_SUBTYPE_ENTITY_TYPE_PROPERTY, EntityType.ASSET));
query.setConsistencyLevel(cluster.getDefaultReadConsistencyLevel());
ResultSetFuture resultSetFuture = getSession().executeAsync(query);
return Futures.transform(resultSetFuture, new Function<ResultSet, List<EntitySubtype>>() {
@Nullable
@Override
public List<EntitySubtype> apply(@Nullable ResultSet resultSet) {
Result<EntitySubtypeEntity> result = cluster.getMapper(EntitySubtypeEntity.class).map(resultSet);
if (result != null) {
List<EntitySubtype> entitySubtypes = new ArrayList<>();
result.all().forEach((entitySubtypeEntity) ->
entitySubtypes.add(entitySubtypeEntity.toEntitySubtype())
);
return entitySubtypes;
} else {
return Collections.emptyList();
}
}
});
}
开发者ID:thingsboard，项目名称:thingsboard，代码行数:26，代码来源:CassandraAssetDao.java
示例5: generateSpecificGet
import com.datastax.driver.mapping.Result; //导入依赖的package包/类
private static MethodSpec generateSpecificGet(TableMetadata table, ClassName entityTable, int desiredColumns) {
String query = getBaseQuery(table) + " WHERE ";
MethodSpec.Builder builder = MethodSpec.methodBuilder("getAll");
List<ColumnMetadata> columns = table.getPrimaryKey();
for(int i = 0; i < desiredColumns; i++) {
ColumnMetadata column = columns.get(i);
String name = column.getName();
String newClause = name + "=:" + name;
if(i != 0) {
newClause = " AND " + newClause;
}
query += newClause;
builder.addParameter(getSpec(column, true));
}
return builder.addModifiers(Modifier.ABSTRACT).addModifiers(Modifier.PUBLIC)
.returns(ParameterizedTypeName.get(ClassName.get(ListenableFuture.class),
ParameterizedTypeName.get(ClassName.get(Result.class), entityTable)))
.addAnnotation(AnnotationSpec.builder(Query.class).addMember("value", "$S", query).build())
.build();
}
开发者ID:jtruelove，项目名称:exovert，代码行数:24，代码来源:AccessorGenerator.java
示例6: getGetAllResultCallback
import com.datastax.driver.mapping.Result; //导入依赖的package包/类
private static TypeSpec getGetAllResultCallback(List<ParameterSpec> params, ClassName entityTable) {
MethodSpec.Builder failureHandler = MethodSpec.methodBuilder("onFailure");
addParamLogging("error", failureHandler, params);
failureHandler.addStatement("$L.accept(new $T(error, $S))", "onComplete", ResultContext.class, "Failed to get all.");
// setup the callback
TypeSpec.Builder resultCallback = TypeSpec.anonymousClassBuilder("")
.addSuperinterface(ParameterizedTypeName.get(ClassName.get(FutureCallback.class),
ParameterizedTypeName.get(ClassName.get(Result.class), entityTable)))
.addMethod(MethodSpec.methodBuilder("onSuccess")
.addAnnotation(Override.class)
.addModifiers(Modifier.PUBLIC)
.addParameter(ParameterizedTypeName.get(ClassName.get(Result.class), entityTable), "result")
.addStatement("$L.accept(new ResultContext(true, result.all()))", "onComplete")
.build());
return resultCallback.addMethod(failureHandler
.addAnnotation(Override.class)
.addModifiers(Modifier.PUBLIC)
.addParameter(Throwable.class, "error")
.build())
.build();
}
开发者ID:jtruelove，项目名称:exovert，代码行数:25，代码来源:DalGenerator.java
示例7: findListByStatement
import com.datastax.driver.mapping.Result; //导入依赖的package包/类
protected List<T> findListByStatement(Statement statement) {
List<T> list = Collections.emptyList();
if (statement != null) {
statement.setConsistencyLevel(getReadConsistencyLevel());
ResultSet resultSet = getSession().execute(statement);
Result<T> result = getMapper().map(resultSet);
if (result != null) {
list = result.all();
}
}
return list;
}
开发者ID:kaaproject，项目名称:kaa，代码行数:13，代码来源:AbstractCassandraDao.java
示例8: get
import com.datastax.driver.mapping.Result; //导入依赖的package包/类
/**
* {@inheritDoc}
*
* @param key
* @param fields
* @return
*/
@Override
public Persistent get(Object key, String[] fields) {
if (fields == null) {
fields = getFields();
}
String cqlQuery = CassandraQueryFactory.getSelectObjectWithFieldsQuery(mapping, fields);
SimpleStatement statement = new SimpleStatement(cqlQuery, key);
if (readConsistencyLevel != null) {
statement.setConsistencyLevel(ConsistencyLevel.valueOf(readConsistencyLevel));
}
ResultSet results = client.getSession().execute(statement);
Result<T> objects = mapper.map(results);
List<T> objectList = objects.all();
if (objectList != null) {
LOG.debug("Object is found for key : {}", key);
return objectList.get(0);
}
LOG.debug("Object is not found for key : {}", key);
return null;
}
开发者ID:apache，项目名称:gora，代码行数:28，代码来源:NativeSerializer.java
示例9: listeneableFutureResult
import com.datastax.driver.mapping.Result; //导入依赖的package包/类
@SuppressWarnings({"unchecked", "rawtypes" })
@Test
public void listeneableFutureResult() throws Exception {
CountDownLatch latch = new CountDownLatch(1);
new MockUnit(Request.class, ListenableFuture.class, Result.class, Row.class)
.expect(futureCallback)
.expect(unit -> {
Result rs = unit.get(Result.class);
expect(rs.all()).andReturn(ImmutableList.of(unit.get(Row.class)));
})
.run(unit -> {
Deferred deferred = (Deferred) new CassandraMapper()
.map(unit.get(ListenableFuture.class));
deferred.handler(unit.get(Request.class), (result, x) -> {
assertEquals(ImmutableList.of(unit.get(Row.class)), result.get());
latch.countDown();
});
}, unit -> {
unit.captured(FutureCallback.class).iterator().next()
.onSuccess(unit.get(Result.class));
});
latch.await();
}
开发者ID:jooby-project，项目名称:jooby，代码行数:24，代码来源:CassandraMapperTest.java
示例10: getAllResultSet
import com.datastax.driver.mapping.Result; //导入依赖的package包/类
private String getAllResultSet() {
Preconditions.checkNotNull(dataModelService, "Data Model Service!");
Result<M> results = dataModelService.getDataModel().getAccessor().findAll(selectLimit);
StringBuilder sb = new StringBuilder();
sb.append("-----------------------------------------------\r\n");
for (M entity : results) {
sb.append(entity.toString() + "\r\n");
}
sb.append("\r\n");
return sb.toString();
}
开发者ID:mcfongtw，项目名称:flink-cassandra-connector-examples，代码行数:14，代码来源:CQLPrintSinkFunction.java
示例11: findListByStatement
import com.datastax.driver.mapping.Result; //导入依赖的package包/类
protected List<E> findListByStatement(Statement statement) {
List<E> list = Collections.emptyList();
if (statement != null) {
statement.setConsistencyLevel(cluster.getDefaultReadConsistencyLevel());
ResultSet resultSet = getSession().execute(statement);
Result<E> result = getMapper().map(resultSet);
if (result != null) {
list = result.all();
}
}
return list;
}
开发者ID:osswangxining，项目名称:iotplatform，代码行数:13，代码来源:CassandraAbstractModelDao.java
示例12: findOneByStatement
import com.datastax.driver.mapping.Result; //导入依赖的package包/类
protected E findOneByStatement(Statement statement) {
E object = null;
if (statement != null) {
statement.setConsistencyLevel(cluster.getDefaultReadConsistencyLevel());
ResultSet resultSet = getSession().execute(statement);
Result<E> result = getMapper().map(resultSet);
if (result != null) {
object = result.one();
}
}
return object;
}
开发者ID:osswangxining，项目名称:iotplatform，代码行数:13，代码来源:CassandraAbstractModelDao.java
示例13: generateAll
import com.datastax.driver.mapping.Result; //导入依赖的package包/类
private static MethodSpec generateAll(TableMetadata table, ClassName entityTable) {
String query = getBaseQuery(table);
return MethodSpec.methodBuilder("getAll")
.addModifiers(Modifier.ABSTRACT).addModifiers(Modifier.PUBLIC)
.returns(ParameterizedTypeName.get(ClassName.get(ListenableFuture.class),
ParameterizedTypeName.get(ClassName.get(Result.class), entityTable)))
.addAnnotation(AnnotationSpec.builder(Query.class).addMember("value", "$S", query).build())
.build();
}
开发者ID:jtruelove，项目名称:exovert，代码行数:11，代码来源:AccessorGenerator.java
示例14: findOneByStatement
import com.datastax.driver.mapping.Result; //导入依赖的package包/类
protected T findOneByStatement(Statement statement) {
T object = null;
if (statement != null) {
statement.setConsistencyLevel(getReadConsistencyLevel());
ResultSet resultSet = getSession().execute(statement);
Result<T> result = getMapper().map(resultSet);
if (result != null) {
object = result.one();
}
}
return object;
}
开发者ID:kaaproject，项目名称:kaa，代码行数:13，代码来源:AbstractCassandraDao.java
示例15: queryAsync
import com.datastax.driver.mapping.Result; //导入依赖的package包/类
/**
* Execute a query and map result to entityClass.
*
* @param entityClass Entity class.
* @param statement Statement to execute.
* @return A listenable future holding the result.
*/
public <T> ListenableFuture<Result<T>> queryAsync(final Class<T> entityClass,
final Statement statement) {
Mapper<T> mapper = mapper(entityClass);
Session session = mapper.getManager().getSession();
ResultSetFuture rs = session.executeAsync(statement);
return Futures.transformAsync(rs, rs1 -> Futures.immediateFuture(mapper.map(rs1)));
}
开发者ID:jooby-project，项目名称:jooby，代码行数:15，代码来源:Datastore.java
示例16: resultSet
import com.datastax.driver.mapping.Result; //导入依赖的package包/类
private static Object resultSet(final Object value) {
if (value instanceof ResultSet) {
return ((ResultSet) value).all();
} else if (value instanceof Result) {
return ((Result) value).all();
}
return value;
}
开发者ID:jooby-project，项目名称:jooby，代码行数:9，代码来源:CassandraMapper.java
示例17: ignored
import com.datastax.driver.mapping.Result; //导入依赖的package包/类
@Test
public void ignored() throws Exception {
Object value = new Object();
new MockUnit(Request.class, Result.class, Row.class)
.run(unit -> {
Object result = new CassandraMapper()
.map(value);
assertEquals(value, result);
});
}
开发者ID:jooby-project，项目名称:jooby，代码行数:11，代码来源:CassandraMapperTest.java
示例18: findAll
import com.datastax.driver.mapping.Result; //导入依赖的package包/类
@Query("SELECT * FROM " + WordCount.CQL_KEYSPACE_NAME + "." + WordCount.CQL_TABLE_NAME + " limit :max")
Result<WordCount> findAll(@Param("max") int max);
开发者ID:mcfongtw，项目名称:flink-cassandra-connector-examples，代码行数:3，代码来源:WordCountAccessor.java
示例19: findAll
import com.datastax.driver.mapping.Result; //导入依赖的package包/类
@Query("SELECT * FROM " + WikiEditRecord.CQL_KEYSPACE_NAME + "." + WikiEditRecord.CQL_TABLE_NAME + " limit :max")
Result<WikiEditRecord> findAll(@Param("max") int max);
开发者ID:mcfongtw，项目名称:flink-cassandra-connector-examples，代码行数:3，代码来源:WikiEditRecordAccessor.java
示例20: fetch
import com.datastax.driver.mapping.Result; //导入依赖的package包/类
@Query("SELECT * FROM " + KEY_SPACE + "." + ObjectEntity.TABLE)
Result<ObjectEntity> fetch();
开发者ID:mnemonic-no，项目名称:act-platform，代码行数:3，代码来源:ObjectAccessor.java
注：本文中的com.datastax.driver.mapping.Result类示例整理自Github/MSDocs等源码及文档管理平台，相关代码片段筛选自各路编程大神贡献的开源项目，源码版权归原作者所有，传播和使用请参考对应项目的License；未经允许，请勿转载。 |
客服电话
APP下载
官方微信
请发表评论