Java TupleType类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

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

本文整理汇总了Java中com.datastax.driver.core.TupleType类的典型用法代码示例。如果您正苦于以下问题：Java TupleType类的具体用法？Java TupleType怎么用？Java TupleType使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

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

示例1: bindTuple

import com.datastax.driver.core.TupleType; //导入依赖的package包/类
/**
 * Bind Tuple to BoundStatement.
 * 
 * @param bs
 * @param inList
 * @throws Exception
 */
public void bindTuple(Session session, BoundStatement bs,
		List<Object> inList) throws Exception {
	if (!isCollection()) {
		throw new Exception(
				"attempting to bind non-collection as collection");
	}
	LOG.trace("bindTuple: entered with {}", inList.toString());
	LOG.trace("bindTuple: first object's type {}", inList.get(0).getClass()
			.getCanonicalName());
	TupleType tupleType = Utils.getTupleType(session.getCluster()
			.getMetadata(), inList);
	TupleValue tv = tupleType.newValue(inList.toArray(new Object[inList
			.size()]));
	for (Integer pos : getPositions())
		bs.setTupleValue(pos, tv);
}

开发者ID:joef551，项目名称:camel-cql，代码行数:24，代码来源:CqlToken.java

示例2: doCreateCluster

import com.datastax.driver.core.TupleType; //导入依赖的package包/类
private Cluster doCreateCluster(CassandraProperties properties) {
    Cluster cluster = Cluster.builder()
            .withClusterName(properties.getCluster())
            .withPort(properties.getPort())
            .addContactPoints(properties.getContactPoints())
            .withTimestampGenerator(getTimestampGenerator())
            .withPoolingOptions(
                    //TODO some default options - move to config
                    new PoolingOptions()
                            .setConnectionsPerHost(HostDistance.LOCAL, 4, 4)
                            .setConnectionsPerHost(HostDistance.REMOTE, 2, 2)
                            .setMaxRequestsPerConnection(HostDistance.LOCAL, 1024)
                            .setMaxRequestsPerConnection(HostDistance.REMOTE, 256)
            )
            .build();
    //almost all queries are idempotent except counter updates, so it's easier to mark them as idempotent
    cluster.getConfiguration().getQueryOptions().setDefaultIdempotence(true);
    
    CodecRegistry codecRegistry = cluster.getConfiguration().getCodecRegistry();

    TupleType tupleType = cluster.getMetadata()
            .newTupleType(DataType.timestamp(), DataType.varchar());
    codecRegistry.register(new ZonedDateTimeCodec(tupleType));

    QueryLogger queryLogger = QueryLogger.builder()
            .withConstantThreshold(100)
            .withMaxQueryStringLength(200)
            .build();
    cluster.register(queryLogger);

    return cluster;
}

开发者ID:papyrusglobal，项目名称:state-channels，代码行数:33，代码来源:CassandraConfiguration.java

示例3: getCql3Type

import com.datastax.driver.core.TupleType; //导入依赖的package包/类
private static CQL3Type.Raw getCql3Type(DataType dt) throws Exception {
    CQL3Type.Raw type;
    switch (dt.getName()) {
    case LIST:
        type = CQL3Type.Raw.list(getCql3Type(dt.getTypeArguments().get(0)));
        break;
    case MAP:
        type = CQL3Type.Raw.map(getCql3Type(dt.getTypeArguments().get(0)),
                getCql3Type(dt.getTypeArguments().get(1)));
        break;
    case SET:
        type = CQL3Type.Raw.set(getCql3Type(dt.getTypeArguments().get(0)));
        break;
    case TUPLE:
        ArrayList<CQL3Type.Raw> tupleTypes = new ArrayList<CQL3Type.Raw>();
        for (DataType arg : ((TupleType) dt).getComponentTypes()) {
            tupleTypes.add(getCql3Type(arg));
        }
        type = CQL3Type.Raw.tuple(tupleTypes);
        break;
    case UDT: // Requires this UDT to already be loaded
        UserType udt = (UserType) dt;
        type = CQL3Type.Raw.userType(new UTName(new ColumnIdentifier(udt.getKeyspace(), true),
                new ColumnIdentifier(udt.getTypeName(), true)));
        break;
    default:
        type = CQL3Type.Raw.from(
                Enum.<CQL3Type.Native> valueOf(CQL3Type.Native.class, dt.getName().toString().toUpperCase()));
        break;
    }
    if (dt.isFrozen()) {
        type = CQL3Type.Raw.frozen(type);
    }
    return type;
}

开发者ID:scylladb，项目名称:scylla-tools-java，代码行数:36，代码来源:BulkLoader.java

示例4: newTupleMapper

import com.datastax.driver.core.TupleType; //导入依赖的package包/类
public static <P extends Tuple2<?, ?>> Mapper<GettableByIndexData, P> newTupleMapper(Type target, TupleType tt, DatastaxMapperFactory factory) {
    ConstantSourceMapperBuilder<GettableByIndexData, P, DatastaxColumnKey> builder =
            DatastaxUDTGetter.newFieldMapperBuilder(factory, target);

    List<DataType> componentTypes = tt.getComponentTypes();
    for(int i = 0; i < componentTypes.size(); i++) {
        FieldMapperColumnDefinition<DatastaxColumnKey> identity = FieldMapperColumnDefinition.identity();
        builder.addMapping(new DatastaxColumnKey("elt" + i, i, componentTypes.get(i)),
                identity);
    }

    return builder.mapper();
}

开发者ID:arnaudroger，项目名称:SimpleFlatMapper，代码行数:14，代码来源:DatastaxTupleGetter.java

示例5: newTupleMapper

import com.datastax.driver.core.TupleType; //导入依赖的package包/类
public static <T extends Tuple2<?, ?>> Mapper<T, SettableByIndexData> newTupleMapper(Type target, TupleType tt,
                                                                                     MapperConfig<DatastaxColumnKey, FieldMapperColumnDefinition<DatastaxColumnKey>> config,
                                                                                     ReflectionService reflectionService) {
    SettableDataMapperBuilder<T> builder = newFieldMapperBuilder(config, reflectionService, target);
    List<DataType> componentTypes = tt.getComponentTypes();
    for(int i = 0; i < componentTypes.size(); i++) {
        builder.addColumn(new DatastaxColumnKey("elt" + i, i, componentTypes.get(i)));
    }
    return builder.mapper();
}

开发者ID:arnaudroger，项目名称:SimpleFlatMapper，代码行数:11，代码来源:TupleValueSettableDataSetter.java

示例6: testCasscadingUnssuportedInsert

import com.datastax.driver.core.TupleType; //导入依赖的package包/类
@Test
public void testCasscadingUnssuportedInsert() throws Exception {   
    
    DaoManager daoManager = new DaoManager(cassandra.getSession());
   
    Dao keyByAccountDao = daoManager.getKeyByAccountDao();

    
    String id = "act334345345344";
    byte[] key = new byte[] { 34, 56, 87, 88 };
    String email = "[email protected]";
    long time = System.currentTimeMillis(); 
    
    
    //////////////////////////////////////
    // insert
    // 3.x API change
    //TupleType idxType = TupleType.of(DataType.text(), DataType.bigint());
    TupleType idxType = TupleType.of(protocolVersion, codecRegistry,DataType.text(), DataType.bigint());
    try {
        keyByAccountDao.writeWhere(QueryBuilder.in(KeyByAccountColumns.ACCOUNT_ID.getName(), id))
                       .value(KeyByAccountColumns.KEY, key)
                       .addSetValue(KeyByAccountColumns.EMAIL_IDX, idxType.newValue(email, time))
                       .withConsistency(ConsistencyLevel.QUORUM)
                       .execute();
        Assert.fail("InvalidQueryException expected");
    } catch (InvalidQueryException expected) {}        

}

开发者ID:1and1，项目名称:Troilus，代码行数:30，代码来源:CascadingTest.java

示例7: testCasscadingInsertError

import com.datastax.driver.core.TupleType; //导入依赖的package包/类
@Test
public void testCasscadingInsertError() throws Exception {   
   
    Dao keyByAccountDao = new DaoImpl(cassandra.getSession(), KeyByAccountColumns.TABLE).withInterceptor(new ErroneousCascadeOnWriteInterceptor());
   
    
    String id = "act3354455445544";
    byte[] key = new byte[] { 34, 56, 87, 88 };
    String email = "[email protected]";
    long time = System.currentTimeMillis(); 
    
    
    //////////////////////////////////////
    // insert 
    try {
    	// 3.x API change
        //TupleType idxType = TupleType.of(DataType.text(), DataType.bigint());
    	TupleType idxType = TupleType.of(protocolVersion, codecRegistry,DataType.text(), DataType.bigint());
        keyByAccountDao.writeWithKey(KeyByAccountColumns.ACCOUNT_ID, id)
                       .value(KeyByAccountColumns.KEY, key)
                       .addSetValue(KeyByAccountColumns.EMAIL_IDX, idxType.newValue(email, time))
                       .withConsistency(ConsistencyLevel.QUORUM)
                       .execute();
        
        Assert.fail("ClassCastException exepcted");
    } catch (ClassCastException exepcted) { }
}

开发者ID:1and1，项目名称:Troilus，代码行数:28，代码来源:CascadingTest.java

示例8: isBuildInType

import com.datastax.driver.core.TupleType; //导入依赖的package包/类
static boolean isBuildInType(DataType dataType) {        
    if (dataType.isCollection()) {
        for (DataType type : dataType.getTypeArguments()) {
            if (!isBuildInType(type)) {
                return false;
            }
        }
        return true;

    } else {
        return DataType.allPrimitiveTypes().contains(dataType) || (TupleType.class.isAssignableFrom(dataType.getClass()));
    }
}

开发者ID:1and1，项目名称:Troilus，代码行数:14，代码来源:UDTValueMapper.java

示例9: newInstance

import com.datastax.driver.core.TupleType; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public static <P extends  Tuple2<?, ?>> Getter<GettableByIndexData, P> newInstance(DatastaxMapperFactory factory, Type target,  TupleType tt, int index) {
    Mapper<GettableByIndexData, P> mapper = newTupleMapper(target, tt, factory);
    return new DatastaxTupleGetter<P>(mapper, index);
}

开发者ID:arnaudroger，项目名称:SimpleFlatMapper，代码行数:6，代码来源:DatastaxTupleGetter.java

示例10: ConverterToTupleValueMapper

import com.datastax.driver.core.TupleType; //导入依赖的package包/类
public ConverterToTupleValueMapper(Mapper<I, TupleValue> mapper, TupleType tupleType) {
    this.mapper = mapper;
    this.tupleType = tupleType;
}

开发者ID:arnaudroger，项目名称:SimpleFlatMapper，代码行数:5，代码来源:ConverterToTupleValueMapper.java

示例11: testCasscadingLwtDelete

import com.datastax.driver.core.TupleType; //导入依赖的package包/类
@Test
public void testCasscadingLwtDelete() throws Exception {   
    
    DaoManager daoManager = new DaoManager(cassandra.getSession());
   
    Dao keyByAccountDao = daoManager.getKeyByAccountDao();
    Dao keyByEmailDao = daoManager.getKeyByEmailDao();

    
    String id = "act3344";
    byte[] key = new byte[] { 34, 56, 87, 88 };
    String email = "[email protected]";
    long time = System.currentTimeMillis(); 
    
    
    //////////////////////////////////////
    // insert 
    // 3.x API change
    //TupleType idxType = TupleType.of(DataType.text(), DataType.bigint());    
    TupleType idxType = TupleType.of(protocolVersion, codecRegistry,DataType.text(), DataType.bigint());
    keyByAccountDao.writeWithKey(KeyByAccountColumns.ACCOUNT_ID, id)
                   .value(KeyByAccountColumns.KEY, key)
                   .addSetValue(KeyByAccountColumns.EMAIL_IDX, idxType.newValue(email, time))
                   .withConsistency(ConsistencyLevel.QUORUM)
                   .execute();
    
    
    
    // test 
    Record record = keyByEmailDao.readWithKey(KeyByEmailColumns.EMAIL, email, KeyByEmailColumns.CREATED, time)
                                 .withConsistency(ConsistencyLevel.QUORUM)
                                 .execute()
                                 .get();
    Assert.assertEquals(id, record.getValue(KeyByEmailColumns.ACCOUNT_ID));
    Assert.assertArrayEquals(key, record.getValue(KeyByEmailColumns.KEY));
    
    record = keyByAccountDao.readWithKey(KeyByAccountColumns.ACCOUNT_ID, id)
                            .withConsistency(ConsistencyLevel.QUORUM)
                            .execute()
                            .get();
    Assert.assertEquals(id, record.getValue(KeyByAccountColumns.ACCOUNT_ID));
    Assert.assertEquals(email, record.getValue(KeyByAccountColumns.EMAIL_IDX).iterator().next().getString(0));
    Assert.assertEquals(time, record.getValue(KeyByAccountColumns.EMAIL_IDX).iterator().next().getLong(1));
    
    
    
    
    
    
    ///////////////////////////////////////////////////////
    // Delete
    try {
        keyByAccountDao.deleteWithKey(KeyByAccountColumns.ACCOUNT_ID, id)
                       .withConsistency(ConsistencyLevel.QUORUM)
                       .ifExists()
                       .execute();
        Assert.fail("InvalidQueryException expected");
    } catch (InvalidQueryException expected) {}        

    
}

开发者ID:1and1，项目名称:Troilus，代码行数:62，代码来源:CascadingTest.java

示例12: testCasscadingUnsupportedDeleteQuery

import com.datastax.driver.core.TupleType; //导入依赖的package包/类
@Test
public void testCasscadingUnsupportedDeleteQuery() throws Exception {   
    
    DaoManager daoManager = new DaoManager(cassandra.getSession());
   
    Dao keyByAccountDao = daoManager.getKeyByAccountDao();
    Dao keyByEmailDao = daoManager.getKeyByEmailDao();

    
    String id = "act3345445544";
    byte[] key = new byte[] { 34, 56, 87, 88 };
    String email = "[email protected]";
    long time = System.currentTimeMillis(); 
    
    
    //////////////////////////////////////
    // insert 
    // 3.x API change
    //TupleType idxType = TupleType.of(DataType.text(), DataType.bigint());     
    TupleType idxType = TupleType.of(protocolVersion, codecRegistry,DataType.text(), DataType.bigint());
    keyByAccountDao.writeWithKey(KeyByAccountColumns.ACCOUNT_ID, id)
                   .value(KeyByAccountColumns.KEY, key)
                   .addSetValue(KeyByAccountColumns.EMAIL_IDX, idxType.newValue(email, time))
                   .withConsistency(ConsistencyLevel.QUORUM)
                   .execute();
    
    
    
    // test 
    Record record = keyByEmailDao.readWithKey(KeyByEmailColumns.EMAIL, email, KeyByEmailColumns.CREATED, time)
                                 .withConsistency(ConsistencyLevel.QUORUM)
                                 .execute()
                                 .get();
    Assert.assertEquals(id, record.getValue(KeyByEmailColumns.ACCOUNT_ID));
    Assert.assertArrayEquals(key, record.getValue(KeyByEmailColumns.KEY));
    
    record = keyByAccountDao.readWithKey(KeyByAccountColumns.ACCOUNT_ID, id)
                            .withConsistency(ConsistencyLevel.QUORUM)
                            .execute()
                            .get();
    Assert.assertEquals(id, record.getValue(KeyByAccountColumns.ACCOUNT_ID));
    Assert.assertEquals(email, record.getValue(KeyByAccountColumns.EMAIL_IDX).iterator().next().getString(0));
    Assert.assertEquals(time, record.getValue(KeyByAccountColumns.EMAIL_IDX).iterator().next().getLong(1));

    
    
    
    
    
    
    ///////////////////////////////////////////////////////
    // Delete
    
    try {
        keyByAccountDao.deleteWhere(QueryBuilder.in(KeyByAccountColumns.ACCOUNT_ID.getName(), id))
                       .withConsistency(ConsistencyLevel.QUORUM)
                       .execute();
        Assert.fail("InvalidQueryException expected");
    } catch (InvalidQueryException expected) {}        
}

开发者ID:1and1，项目名称:Troilus，代码行数:61，代码来源:CascadingTest.java

示例13: testCasscadingDeleteError

import com.datastax.driver.core.TupleType; //导入依赖的package包/类
@Test
public void testCasscadingDeleteError() throws Exception {   
   
    Dao keyByAccountDao = new DaoImpl(cassandra.getSession(), KeyByAccountColumns.TABLE).withInterceptor(new ErroneousCascadeOnDeleteInterceptor());

    
    String id = "act3343343454544";
    byte[] key = new byte[] { 34, 56, 87, 88 };
    String email = "[email protected]";
    long time = System.currentTimeMillis(); 
    

    //////////////////////////////////////
    // insert 
    // 3.x API change
    //TupleType idxType = TupleType.of(DataType.text(), DataType.bigint());        
    TupleType idxType = TupleType.of(protocolVersion, codecRegistry,DataType.text(), DataType.bigint());
    keyByAccountDao.writeWithKey(KeyByAccountColumns.ACCOUNT_ID, id)
                   .value(KeyByAccountColumns.KEY, key)
                   .addSetValue(KeyByAccountColumns.EMAIL_IDX, idxType.newValue(email, time))
                   .withConsistency(ConsistencyLevel.QUORUM)
                   .execute();
    
    
    
    // test 
    
    Record record = keyByAccountDao.readWithKey(KeyByAccountColumns.ACCOUNT_ID, id)
                                   .withConsistency(ConsistencyLevel.QUORUM)
                                   .execute()
                                   .get();
    Assert.assertEquals(id, record.getValue(KeyByAccountColumns.ACCOUNT_ID));
    Assert.assertEquals(email, record.getValue(KeyByAccountColumns.EMAIL_IDX).iterator().next().getString(0));
    Assert.assertEquals(time, record.getValue(KeyByAccountColumns.EMAIL_IDX).iterator().next().getLong(1));

    
    
    
    
    ///////////////////////////////////////////////////////
    // Delete
    try {
        keyByAccountDao.deleteWithKey(KeyByAccountColumns.ACCOUNT_ID, id)
                       .withConsistency(ConsistencyLevel.QUORUM)
                       .execute();
        
        Assert.fail("ClassCastException exepcted");
    } catch (ClassCastException exepcted) { }
}

开发者ID:1and1，项目名称:Troilus，代码行数:50，代码来源:CascadingTest.java

示例14: getTupleType

import com.datastax.driver.core.TupleType; //导入依赖的package包/类
/**
 * Creates a Cassandra TupleType based on the given list of Objects. The
 * TupleType can then be used to create a TupleValue.
 * 
 * @param values
 * @return
 */
public static TupleType getTupleType(Metadata clusterMetaData,
		List<Object> values) throws IllegalArgumentException {
	List<DataType> dataTypes = new ArrayList<DataType>();
	for (Object value : values) {
		LOG.trace("getTupleType: Object type = "
				+ value.getClass().getCanonicalName());
		if (value instanceof ByteBuffer) {
			dataTypes.add(DataType.blob());
		} else if (value instanceof BigDecimal) {
			dataTypes.add(DataType.decimal());
		} else if (value instanceof BigInteger) {
			dataTypes.add(DataType.varint());
		} else if (value instanceof Boolean) {
			dataTypes.add(DataType.cboolean());
		} else if (value instanceof InetAddress) {
			dataTypes.add(DataType.inet());
		} else if (value instanceof Integer) {
			dataTypes.add(DataType.cint());
		} else if (value instanceof Short) {
			dataTypes.add(DataType.smallint());
		} else if (value instanceof Long) {
			dataTypes.add(DataType.counter());
		} else if (value instanceof Float) {
			dataTypes.add(DataType.cfloat());
		} else if (value instanceof Double) {
			dataTypes.add(DataType.cdouble());
		} else if (value instanceof Date) {
			dataTypes.add(DataType.timestamp());
		} else if (value instanceof String) {
			dataTypes.add(DataType.text());
		} else {
			throw new IllegalArgumentException("unknown data type of "
					+ value.getClass().getCanonicalName());
		}
	}
	return clusterMetaData.newTupleType(dataTypes
			.toArray(new DataType[dataTypes.size()]));
	// return TupleType.of(dataTypes.toArray(new
	// DataType[dataTypes.size()]));
}

开发者ID:joef551，项目名称:camel-cql，代码行数:48，代码来源:Utils.java

示例15: testCasscading

import com.datastax.driver.core.TupleType; //导入依赖的package包/类
@Test
public void testCasscading() throws Exception {   
    
    DaoManager daoManager = new DaoManager(cassandra.getSession());
   
    Dao keyByAccountDao = daoManager.getKeyByAccountDao();
    Dao keyByEmailDao = daoManager.getKeyByEmailDao();

    
    String id = "act3344";
    byte[] key = new byte[] { 34, 56, 87, 88 };
    String email = "[email protected]";
    long time = System.currentTimeMillis(); 
    
    
    //////////////////////////////////////
    // insert 
   // TupleType idxType = TupleType.of(DataType.text(), DataType.bigint());
    TupleType idxType = TupleType.of(protocolVersion, codecRegistry,DataType.text(), DataType.bigint());
    keyByAccountDao.writeWithKey(KeyByAccountColumns.ACCOUNT_ID, id)
                   .value(KeyByAccountColumns.KEY, key)
                   .addSetValue(KeyByAccountColumns.EMAIL_IDX, idxType.newValue(email, time))
                   .withConsistency(ConsistencyLevel.QUORUM)
                   .execute();
    
    
    
    // test 
    Record record = keyByEmailDao.readWithKey(KeyByEmailColumns.EMAIL, email, KeyByEmailColumns.CREATED, time)
                                 .withConsistency(ConsistencyLevel.QUORUM)
                                 .execute()
                                 .get();
    Assert.assertEquals(id, record.getValue(KeyByEmailColumns.ACCOUNT_ID));
    Assert.assertArrayEquals(key, record.getValue(KeyByEmailColumns.KEY));
    
    record = keyByAccountDao.readWithKey(KeyByAccountColumns.ACCOUNT_ID, id)
                            .withConsistency(ConsistencyLevel.QUORUM)
                            .execute()
                            .get();
    Assert.assertEquals(id, record.getValue(KeyByAccountColumns.ACCOUNT_ID));
    Assert.assertEquals(email, record.getValue(KeyByAccountColumns.EMAIL_IDX).iterator().next().getString(0));
    Assert.assertEquals(time, record.getValue(KeyByAccountColumns.EMAIL_IDX).iterator().next().getLong(1));
    
    
    
    
    
    
    
    ///////////////////////////////////////////////////////
    // Delete
    
    keyByAccountDao.deleteWithKey(KeyByAccountColumns.ACCOUNT_ID, id)
                   .withConsistency(ConsistencyLevel.QUORUM)
                   .execute();
    
    
    
    Assert.assertEquals(Optional.empty(), keyByEmailDao.readWithKey(KeyByEmailColumns.EMAIL, email, KeyByEmailColumns.CREATED, time)
                                                       .withConsistency(ConsistencyLevel.QUORUM)
                                                       .execute());

    Assert.assertEquals(Optional.empty(), keyByAccountDao.readWithKey(KeyByAccountColumns.ACCOUNT_ID, id)
                                                         .withConsistency(ConsistencyLevel.QUORUM)
                                                         .execute());        
}

开发者ID:1and1，项目名称:Troilus，代码行数:67，代码来源:CascadingTest.java

示例16: testCasscading2

import com.datastax.driver.core.TupleType; //导入依赖的package包/类
@Test
public void testCasscading2() throws Exception {   
    
    DaoManager daoManager = new DaoManager(cassandra.getSession());
   
    Dao keyByAccountDao = daoManager.getKeyByAccountDao();
    Dao keyByEmailDao = daoManager.getKeyByEmailDao();

    
    String id = "act3344";
    byte[] key = new byte[] { 34, 56, 87, 88 };
    String email = "[email protected]";
    long time = System.currentTimeMillis(); 
    
    
    //////////////////////////////////////
    // insert 
    // 3.x API change
    //TupleType idxType = TupleType.of(DataType.text(), DataType.bigint());
    TupleType idxType = TupleType.of(protocolVersion, codecRegistry,DataType.text(), DataType.bigint());
    keyByAccountDao.writeWithKey(KeyByAccountColumns.ACCOUNT_ID, id)
                   .value(KeyByAccountColumns.KEY, key)
                   .value(KeyByAccountColumns.EMAIL_IDX, ImmutableSet.of(idxType.newValue(email, time)))
                   .withConsistency(ConsistencyLevel.QUORUM)
                   .execute();
    
    
    
    // test 
    Record record = keyByEmailDao.readWithKey(KeyByEmailColumns.EMAIL, email, KeyByEmailColumns.CREATED, time)
                                 .withConsistency(ConsistencyLevel.QUORUM)
                                 .execute()
                                 .get();
    Assert.assertEquals(id, record.getValue(KeyByEmailColumns.ACCOUNT_ID));
    Assert.assertArrayEquals(key, record.getValue(KeyByEmailColumns.KEY));
    
    record = keyByAccountDao.readWithKey(KeyByAccountColumns.ACCOUNT_ID, id)
                            .withConsistency(ConsistencyLevel.QUORUM)
                            .execute()
                            .get();
    Assert.assertEquals(id, record.getValue(KeyByAccountColumns.ACCOUNT_ID));
    Assert.assertEquals(email, record.getValue(KeyByAccountColumns.EMAIL_IDX).iterator().next().getString(0));
    Assert.assertEquals(time, record.getValue(KeyByAccountColumns.EMAIL_IDX).iterator().next().getLong(1));
    
    
    
    
    
    
    
    ///////////////////////////////////////////////////////
    // Delete
    
    keyByAccountDao.deleteWithKey(KeyByAccountColumns.ACCOUNT_ID, id)
                   .withConsistency(ConsistencyLevel.QUORUM)
                   .execute();
    
    
    
    Assert.assertEquals(Optional.empty(), keyByEmailDao.readWithKey(KeyByEmailColumns.EMAIL, email, KeyByEmailColumns.CREATED, time)
                                                       .withConsistency(ConsistencyLevel.QUORUM)
                                                       .execute());

    Assert.assertEquals(Optional.empty(), keyByAccountDao.readWithKey(KeyByAccountColumns.ACCOUNT_ID, id)
                                                         .withConsistency(ConsistencyLevel.QUORUM)
                                                         .execute());        
}

开发者ID:1and1，项目名称:Troilus，代码行数:68，代码来源:CascadingTest.java

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

鲜花

握手

雷人

路过

鸡蛋

该文章已有0人参与评论

请发表评论

全部评论

专题导读

More+

10-27 六六分期app的软件客服如何联系？(六六分期

11-06 可心卡盟:win10系统火狐flash插件崩溃怎么

11-06 亲亲特价:怎么删除回收站图标

11-06 济南大学虚拟社区:鲁大师节能降温的具体办

11-06 xlueops.exe:无线网络安装向导

11-06 女斗合众国:win7系统cf与主机连接不稳定怎

11-06 0xc000022-[cf烟雾头]cf怎么调烟雾头

11-06 qizideyouhuo:应用程序无法正常启动0xc0000

11-06 ipz-185:win7系统vcf文件怎么打开

11-06 傻哥蹦迪:win10系统s4怎么打开usb调试

11-06 八神浩树gtaste:回收站清空了怎么恢复

11-06 妖尾之黑色守护:win10系统电脑没有1440x900

11-06 校园至尊魔王小说:win7系统浏览网页时字体

11-06 女斗合众国:win10系统访问共享文件夹提示请

11-06 tokyo hot n0654:恢复win7系统默认字体一招

11-06 雨酷仙境:设置win7系统转移临时文件夹腾出

11-06 阿穆纳伊之杖:win7系统开始菜单在右边还原

11-06 tunespotting:win10系统火狐flash插件总是

11-06 甘尔葛分析师：计谋网站seo关键词暴涨有什

11-06 蔡贵霖: 计谋网站seo关键词暴涨有什么秘密

11-06 博益网首页:ao3网页版进入不了解决方法

11-06 漏斗子专栏: 网站数据分析小白易懂精华篇

11-06 见证双虹怎么做:win7系统开启telnet命令的

11-06 颾狐蝶蜋:系统资源不足无法完成请求的服务

11-06 国光中学校歌:提交网站到alexa查询详细步骤

11-06 西安有情天:静态网页和动态网页的区别

11-06 红木雅尚斋:外部链接构造对网站的好处

11-06 前官礼遇：防止域名劫持–增强域安全性的10

11-06 密传二转答案: 中文分词算法有哪些

11-06 金泉家园邮编:百度快照劫持的表现及应对方

Java Log4jContextFactory类代码示例发布时间：2022-05-23

Java PropertiesUtil类代码示例发布时间：2022-05-23

剪的笔顺,诠释剪的笔画,认识剪的部首

1 六六分期app的软件客服如何联系？(六六分期

六六分期app的软件客服如何联系？不知道吗？加qq群【895510560】即可！标题：六六分期

阅读：18011|2023-10-27

2 可心卡盟:win10系统火狐flash插件崩溃怎么

今天小编告诉大家如何处理win10系统火狐flash插件总是崩溃的问题，可能很多用户都不知

阅读：9588|2022-11-06

3 亲亲特价:怎么删除回收站图标

今天小编告诉大家如何对win10系统删除桌面回收站图标进行设置，可能很多用户都不知道

阅读：8136|2022-11-06

4 济南大学虚拟社区:鲁大师节能降温的具体办

今天小编告诉大家如何对win10系统电脑设置节能降温的设置方法，想必大家都遇到过需要

阅读：8520|2022-11-06

5 xlueops.exe:无线网络安装向导

我们在使用xp系统的过程中,经常需要对xp系统无线网络安装向导设置进行设置，可能很多

阅读：8424|2022-11-06

6 女斗合众国:win7系统cf与主机连接不稳定怎

今天小编告诉大家如何处理win7系统玩cf老是与主机连接不稳定的问题，可能很多用户都不

阅读：9323|2022-11-06

7 0xc000022-[cf烟雾头]cf怎么调烟雾头

电脑对日常生活的重要性小编就不多说了，可是一旦碰到win7系统设置cf烟雾头的问题，很

阅读：8387|2022-11-06

8 qizideyouhuo:应用程序无法正常启动0xc0000

我们在日常使用电脑的时候，有的小伙伴们可能在打开应用的时候会遇见提示应用程序无法

阅读：7820|2022-11-06

9 ipz-185:win7系统vcf文件怎么打开

今天小编告诉大家如何对win7系统打开vcf文件进行设置，可能很多用户都不知道怎么对win

阅读：8375|2022-11-06

10 傻哥蹦迪:win10系统s4怎么打开usb调试

今天小编告诉大家如何对win10系统s4开启USB调试模式进行设置，可能很多用户都不知道怎

阅读：7369|2022-11-06

客服电话

电子邮件

Java TupleType类代码示例

示例1: bindTuple

示例2: doCreateCluster

示例3: getCql3Type

示例4: newTupleMapper

示例5: newTupleMapper

示例6: testCasscadingUnssuportedInsert

示例7: testCasscadingInsertError

示例8: isBuildInType

示例9: newInstance

示例10: ConverterToTupleValueMapper

示例11: testCasscadingLwtDelete

示例12: testCasscadingUnsupportedDeleteQuery

示例13: testCasscadingDeleteError

示例14: getTupleType

示例15: testCasscading

示例16: testCasscading2

请发表评论

全部评论

上一篇：

下一篇：

dphi-official/Machine_Learning_Bootcamp

juven/maven-bash-completion: Maven Bash

win7系统注册表编辑器打开的操作方法

route101/mastoinker: Quick image view as

CVE-2022-21509

剪的笔顺,诠释剪的笔画,认识剪的部首

六六分期app的软件客服如何联系？(六六分期

florent37/ViewAnimator: A fluent Android

florent37/Shrine-MaterialDesign2: implem

CVE-2020-36276

SimpleSoftwareIO/simple-sms: Send and re

关于我们

产品与服务

解决方案

139-2527-9053