import org.springframework.social.connect.NoSuchConnectionException; //导入依赖的package包/类
@Override
@Transactional(readOnly = true)
public Connection<?> getConnection(final ConnectionKey connectionKey) {

    final String providerId = connectionKey.getProviderId();
    final String providerUserId = connectionKey.getProviderUserId();

    final UserConnection userConnection = userConnectionRepository.findOne(user, providerId, providerUserId);

    if (userConnection == null) {
        throw new NoSuchConnectionException(connectionKey);
    }

    final ConnectionData connectionData = Functions.toConnectionData(textEncryptor)
                                                   .apply(userConnection);

    return connectionFactoryLocator.getConnectionFactory(userConnection.getProviderId())
                                   .createConnection(connectionData);
}
 

import org.springframework.social.connect.NoSuchConnectionException; //导入依赖的package包/类
@Override
public Connection<?> getConnection(ConnectionKey connectionKey) {
	final CompositeFilter filter = CompositeFilterOperator.and(
		FilterOperator.EQUAL.of("providerId", connectionKey.getProviderId()),
		FilterOperator.EQUAL.of("providerUserId", connectionKey.getProviderUserId())
	);
	final Query query = new Query(getKind())
		.setAncestor(userKey)
		.setFilter(filter);
	Entity singleEntity;
	try {
		singleEntity = datastore.prepare(query).asSingleEntity();			
	} catch (TooManyResultsException ex) {
		log.warning("Too many results were found for query " + query.toString());
		throw new NoSuchConnectionException(connectionKey);
	}
	if (singleEntity == null) throw new NoSuchConnectionException(connectionKey);
	return connectionMapper.mapEntity(singleEntity);
}
 

import org.springframework.social.connect.NoSuchConnectionException; //导入依赖的package包/类
@Override
public Connection<?> getConnection(final ConnectionKey connectionKey) {
    final SocialUserConnection socialUserConnection
            = socialUserConnectionRepository.findOneByUserIdAndProviderIdAndProviderUserId(userId,
            connectionKey.getProviderId(), connectionKey.getProviderUserId());

    return Optional.ofNullable(socialUserConnection)
            .map(this::socialUserConnectionToConnection)
            .orElseThrow(() -> new NoSuchConnectionException(connectionKey));
}
 

import org.springframework.social.connect.NoSuchConnectionException; //导入依赖的package包/类
@Override
public Connection<?> getConnection(ConnectionKey key) {
  User user = userRepository.findOneByAuthProviderUserId(
      key.getProviderId(), key.getProviderUserId());
  if (user.getId() == userId) {
    ConnectionFactory<?> connectionFactory = connectionFactoryLocator
        .getConnectionFactory(key.getProviderId());
    return connectionFactory.createConnection(connectionData(user));
  }
  throw new NoSuchConnectionException(key);
}
 

import org.springframework.social.connect.NoSuchConnectionException; //导入依赖的package包/类
@Test(expected = NoSuchConnectionException.class)
public void testGetConnectionNonMatchingUser() throws Exception {
  Connection connection = mock(Connection.class);
  ArgumentCaptor<ConnectionData> connectionDataCaptor =
      ArgumentCaptor.forClass(ConnectionData.class);
  when(connectionFactoryOne.createConnection(connectionDataCaptor.capture()))
      .thenReturn(connection);
  User wrongUser = user();
  wrongUser.setId(idProvider.getAndIncrement());
  when(userRepository.findOneByAuthProviderUserId(PROVIDER_ONE, providerUserId()))
      .thenReturn(wrongUser);
  connectionRepository.getConnection(new ConnectionKey(PROVIDER_ONE, providerUserId()));
}
 

import org.springframework.social.connect.NoSuchConnectionException; //导入依赖的package包/类
private Connection<?> getConnection(String providerId, String providerUserId) {
    List<SocialAuthentication> socialAuthentications = userDao.getSocialAuthentications(providerId, providerUserId);
    if (socialAuthentications.isEmpty()) {
        throw new NoSuchConnectionException(new ConnectionKey(providerId, providerUserId));
    }
    return authToConnection(socialAuthentications.get(0));
}
 

import org.springframework.social.connect.NoSuchConnectionException; //导入依赖的package包/类
public Connection<?> getConnection(ConnectionKey connectionKey) {
	final String sql = selectFromUserConnection() + " where userId = ? and providerId = ? and providerUserId = ? order by rank";
	final String[] selectionArgs = { userId, connectionKey.getProviderId(), connectionKey.getProviderUserId() };
	Connection<?> connection = queryForConnection(sql, selectionArgs);

	if (connection == null) {
		throw new NoSuchConnectionException(connectionKey);
	}

	return connection;
}
 

import org.springframework.social.connect.NoSuchConnectionException; //导入依赖的package包/类
@Override
public Connection<?> getConnection(ConnectionKey connectionKey) {
  SocialUserConnection socialUserConnection = socialUserConnectionRepository
    .findOneByUserIdAndProviderIdAndProviderUserId(userId, connectionKey.getProviderId(), connectionKey.getProviderUserId());
  return Optional.ofNullable(socialUserConnection)
    .map(this::socialUserConnectionToConnection)
    .orElseThrow(() -> new NoSuchConnectionException(connectionKey));
}
 

import org.springframework.social.connect.NoSuchConnectionException; //导入依赖的package包/类
@Test(expected = NoSuchConnectionException.class)
public void testGetConnectionWithConnectionKeyWithUnknownConnection() throws Exception {

    final ConnectionKey connectionKey = new ConnectionKey("twitter",
                                                          "unknown provider user id");
    subject.getConnection(connectionKey);
}
 

import org.springframework.social.connect.NoSuchConnectionException; //导入依赖的package包/类
public Connection<?> getConnection(ConnectionKey connectionKey) {
    UserSocialConnection userSocialConnection = this.userSocialConnectionRepository
            .findByUserIdAndProviderIdAndProviderUserId(userId, connectionKey.getProviderId(),
                    connectionKey.getProviderUserId());
    if (userSocialConnection != null) {
        return buildConnection(userSocialConnection);
    }
    throw new NoSuchConnectionException(connectionKey);
}
 

import org.springframework.social.connect.NoSuchConnectionException; //导入依赖的package包/类
@Test(expected = NoSuchConnectionException.class)
public void findConnectionByKeyNoSuchConnection() {
    connectionRepository.getConnection(new ConnectionKey("facebook", "bogus"));
}
 

import org.springframework.social.connect.NoSuchConnectionException; //导入依赖的package包/类
@Test(expected = NoSuchConnectionException.class)
public void findConnectionByApiToUserNoSuchConnection() {
    assertFacebookConnection(connectionRepository.getConnection(TestFacebookApi.class, "9"));
}
 

import org.springframework.social.connect.NoSuchConnectionException; //导入依赖的package包/类
@Test(expected = NoSuchConnectionException.class)
public void findConnectionByKeyNoSuchConnection() {
  connectionRepository.getConnection(new ConnectionKey("facebook", "bogus"));
}
 

import org.springframework.social.connect.NoSuchConnectionException; //导入依赖的package包/类
@Test(expected = NoSuchConnectionException.class)
public void findConnectionByApiToUserNoSuchConnection() {
  assertFacebookConnection(connectionRepository.getConnection(TestFacebookApi.class, "9"));
}