import me.prettyprint.hector.api.query.ColumnQuery; //导入依赖的package包/类
/**
 * Checks if the role is existing the role store.
 */
@Override
protected boolean doCheckExistingRole(String roleNameWithTenantDomain) throws UserStoreException {

    RoleContext roleContext = createRoleContext(roleNameWithTenantDomain);
    boolean isExisting = false;

    String roleName = roleContext.getRoleName();

    Composite key = new Composite();
    key.addComponent(roleName, stringSerializer);
    key.addComponent(tenantIdString, stringSerializer);

    ColumnQuery<Composite, String, String> getCredentialQuery = HFactory.createColumnQuery(keyspace,
            CompositeSerializer.get(), stringSerializer, stringSerializer);

    getCredentialQuery.setColumnFamily(CFConstants.UM_ROLES).setKey(key).setName(CFConstants.UM_ROLE_NAME);

    HColumn<String, String> result = getCredentialQuery.execute().get();
    if (result != null && result.getValue() != null) {
        isExisting = true;
    }

    return isExisting;
}
 

import me.prettyprint.hector.api.query.ColumnQuery; //导入依赖的package包/类
/**
 * Checks if the user is existing in the user store.
 */
@Override
protected boolean doCheckExistingUser(String userName) throws UserStoreException {

    Boolean isExist = false;

    Composite key = new Composite();
    key.addComponent(userName, stringSerializer);
    key.addComponent(tenantIdString, stringSerializer);

    ColumnQuery<Composite, String, String> getCredentialQuery = HFactory.createColumnQuery(keyspace,
            CompositeSerializer.get(), stringSerializer, stringSerializer);

    getCredentialQuery.setColumnFamily(CFConstants.UM_USER).setKey(key).setName(CFConstants.UM_USER_NAME);

    HColumn<String, String> result = getCredentialQuery.execute().get();
    if (result != null && result.getValue() != null) {
        isExist = true;
    }

    return isExist;

}
 

import me.prettyprint.hector.api.query.ColumnQuery; //导入依赖的package包/类
/**
 * Read a column value.
 *
 * @param rowKey     the row key of type K
 * @param columnName the column name
 * @return the column value or null if not found
 */
@Override
public V readColumnValue(K rowKey, N columnName) {
    ColumnQuery<K,N,V> query = HFactory.createColumnQuery(getKeyspace(),
                                                          getKeySerializer(),
                                                          getColumnNameSerializer(),
                                                          getValueSerializer());
    QueryResult<HColumn<N,V>> result = query.
            setKey(rowKey).
            setColumnFamily(getColumnFamily()).
            setName(columnName).
            execute();
    HColumn<N,V> column = result.get();
    return column != null ? column.getValue() : null;
    // we used to translate hector exceptions into spring exceptions here, but spring dependency was removed
}
 

import me.prettyprint.hector.api.query.ColumnQuery; //导入依赖的package包/类
private void insertSingleColumnData() {

        Mutator<String> mutator = HFactory.createMutator(keyspace, stringSerializer);

        mutator.addInsertion("jsmith0", COLUMN_FAMILY_NAME_1, HFactory.createStringColumn("first", "John"))
                .addInsertion("jsmith0", COLUMN_FAMILY_NAME_1, HFactory.createStringColumn("last", "Smith"))
                .addInsertion("jsmith0", COLUMN_FAMILY_NAME_1, HFactory.createStringColumn("middle", "Q"));
        mutator.execute();

        mutator.insert("jsmith", COLUMN_FAMILY_NAME_1, HFactory.createStringColumn("first", "John"));

        ColumnQuery<String, String, String> columnQuery = HFactory.createStringColumnQuery(keyspace);
        columnQuery.setColumnFamily(COLUMN_FAMILY_NAME_1).setKey("jsmith").setName("first");
        QueryResult<HColumn<String, String>> result = columnQuery.execute();
        System.out.println("Read HColumn from cassandra: " + result.get());
        System.out.println("Verify on CLI with:  get DynamicKeyspace1.Keyspace1['jsmith'] ");

    }
 

import me.prettyprint.hector.api.query.ColumnQuery; //导入依赖的package包/类
@Override
public V get(final K key) throws DataAccessLayerException {

	final ColumnQuery<K, byte[], V> q = createColumnQuery(_keyspace, _serializer_k, BYTE_SERIALIZER, _serializer_v);
	final QueryResult<HColumn<byte[], V>> r = q.setKey(key).setName(COLUMN_NAME).setColumnFamily(_cf_name).execute();
	final HColumn<byte[], V> c = r.get();

	if (c == null) {
		return (_default_value != null) ? _default_value : null;
	} else {
		return c.getValue();
	}
}
 

import me.prettyprint.hector.api.query.ColumnQuery; //导入依赖的package包/类
/**
 * Gets the column.
 *
 * @param ko the keyspace
 * @param columnFamily the column family
 * @param key the key
 * @param column the column
 *
 * @return column
 *
 * @throws Exception the exception
 */
public <N, V> HColumn<N, V> getColumn( Keyspace ko, Object columnFamily, Object key, N column,
                                       Serializer<N> nameSerializer, Serializer<V> valueSerializer )
        throws Exception {

    if ( db_logger.isTraceEnabled() ) {
        db_logger.trace( "getColumn cf={} key={} column={}", columnFamily, key, column );
    }

/*
 * ByteBuffer column_bytes = null; if (column instanceof List) {
 * column_bytes = Composite.serializeToByteBuffer((List<?>) column); } else
 * { column_bytes = bytebuffer(column); }
 */

    ColumnQuery<ByteBuffer, N, V> q = HFactory.createColumnQuery( ko, be, nameSerializer, valueSerializer );
    QueryResult<HColumn<N, V>> r =
            q.setKey( bytebuffer( key ) ).setName( column ).setColumnFamily( columnFamily.toString() ).execute();
    HColumn<N, V> result = r.get();

    if ( db_logger.isTraceEnabled() ) {
        if ( result == null ) {
            db_logger.trace( "getColumn returned null" );
        }
    }

    return result;
}
 

import me.prettyprint.hector.api.query.ColumnQuery; //导入依赖的package包/类
private void mutateValues(String key, String columnName) {

            String value = key;

            columnName = columnName + "_" + new Integer(new Random().nextInt(1000)).toString();

            Mutator<String> mutator = HFactory.createMutator(keyspace, STRING_SERIALIZER);
            mutator.addInsertion(key, columnFamilyName,
                    HFactory.createColumn(columnName, value, STRING_SERIALIZER, STRING_SERIALIZER));

            long start = Calendar.getInstance().getTimeInMillis();
            MutationResult mutationResult = mutator.execute();
            long end = Calendar.getInstance().getTimeInMillis();
            // System.out.println(columnName +
            // ": Write Computed time in millisecond: "
            // + (end - start));

            count++;

            ColumnQuery<String, String, String> columnQuery = HFactory.createStringColumnQuery(keyspace);
            columnQuery.setColumnFamily(columnFamilyName).setKey(key).setName(columnName);

            start = Calendar.getInstance().getTimeInMillis();
            QueryResult<HColumn<String, String>> result = columnQuery.execute();
            end = Calendar.getInstance().getTimeInMillis();
            // System.out.println(columnName +
            // ": Read Computed time in millisecond: "
            // + (end - start));

            if (!result.get().getValue().equals(value)) {
                throw new RuntimeException();
            }

            count++;

        }
 

import me.prettyprint.hector.api.query.ColumnQuery; //导入依赖的package包/类
/**
 * Get a string value.
 *
 * @return The string value; null if no value exists for the given key.
 */
public String get(final String key, final String columnName) throws HectorException {
  ColumnQuery<String, String, String> q = HFactory.createColumnQuery(keyspace,
      serializer, serializer, serializer);
  QueryResult<HColumn<String, String>> r = q.setKey(key).
      setName(columnName).
      setColumnFamily(columnFamilyName).
      execute();
  HColumn<String, String> c = r.get();
  return c != null ? c.getValue() : null;
}
 

import me.prettyprint.hector.api.query.ColumnQuery; //导入依赖的package包/类
private void testResultDetail() {

        Mutator<String> mutator = HFactory.createMutator(keyspace, stringSerializer);
        // add 10 rows
        for (int i = 0; i < 10; i++) {
            mutator.addInsertion("fake_key_" + i, COLUMN_FAMILY_NAME_1,
                    HFactory.createStringColumn("fake_column_0", "fake_value_0_" + i))
                    .addInsertion("fake_key_" + i, COLUMN_FAMILY_NAME_1,
                            HFactory.createStringColumn("fake_column_1", "fake_value_1_" + i))
                    .addInsertion("fake_key_" + i, COLUMN_FAMILY_NAME_1,
                            HFactory.createStringColumn("fake_column_2", "fake_value_2_" + i));
        }
        MutationResult me = mutator.execute();
        System.out.println("MutationResult from 10 row insertion: " + me);

        RangeSlicesQuery<String, String, String> rangeSlicesQuery = HFactory.createRangeSlicesQuery(keyspace,
                stringSerializer, stringSerializer, stringSerializer);
        rangeSlicesQuery.setColumnFamily(COLUMN_FAMILY_NAME_1);
        rangeSlicesQuery.setKeys("", "");
        rangeSlicesQuery.setRange("", "", false, 3);

        rangeSlicesQuery.setRowCount(10);
        QueryResult<OrderedRows<String, String, String>> result = rangeSlicesQuery.execute();
        System.out.println("Result from rangeSlices query: " + result.toString());

        ColumnQuery<String, String, String> columnQuery = HFactory.createStringColumnQuery(keyspace);
        columnQuery.setColumnFamily(COLUMN_FAMILY_NAME_1).setKey("fake_key_0").setName("fake_column_0");
        QueryResult<HColumn<String, String>> colResult = columnQuery.execute();
        System.out.println("Execution time: " + colResult.getExecutionTimeMicro());
        System.out.println("CassandraHost used: " + colResult.getHostUsed());
        System.out.println("Query Execute: " + colResult.getQuery());

    }
 

import me.prettyprint.hector.api.query.ColumnQuery; //导入依赖的package包/类
public static String getExistingUserId(String credentialTypeName, String identifier, Keyspace keyspace) {

        identifier = createRowKeyForReverseLookup(identifier, credentialTypeName);
        ColumnQuery<String, String, String> usernameIndexQuery = HFactory.createColumnQuery(keyspace, stringSerializer,
                stringSerializer, stringSerializer);

        usernameIndexQuery.setColumnFamily(CFConstants.USERNAME_INDEX).setKey(identifier).setName(CFConstants.USER_ID);

        QueryResult<HColumn<String, String>> result = usernameIndexQuery.execute();

        HColumn<String, String> userIdCol = result.get();

        if (userIdCol == null) {
            return null;
        }

        return userIdCol.getValue();
    }
 

import me.prettyprint.hector.api.query.ColumnQuery; //导入依赖的package包/类
@Override
public boolean contains(final K key) {
	final ColumnQuery<K, byte[], byte[]> q = createColumnQuery(_keyspace, _serializer_k, BYTE_SERIALIZER, BYTE_SERIALIZER);
	final QueryResult<HColumn<byte[], byte[]>> r = q.setKey(key).setName(COLUMN_NAME).setColumnFamily(_cf_name).execute();
	return r.get() != null;
}