import org.springframework.social.connect.NotConnectedException; //导入依赖的package包/类
@Override
@SuppressWarnings("unchecked")
public <A> Connection<A> getPrimaryConnection(final Class<A> apiType) {
    final String providerId = getProviderId(apiType);

    final Connection<A> connection = (Connection<A>) findPrimaryConnection(providerId);

    return Optional.ofNullable(connection)
            .orElseThrow(() -> new NotConnectedException(providerId));
}
 

import org.springframework.social.connect.NotConnectedException; //导入依赖的package包/类
@Override
public <A> Connection<A> getConnection(Class<A> apiType, String providerUserId) {
  ConnectionFactory<A> connectionFactory = getConnectionFactory(apiType);
  User user = getUser();
  String providerId = connectionFactory.getProviderId();
  if (providerId.equals(user.getAuthProviderId())
      && providerUserId.equals(user.getAuthProviderUserId())) {
    return connectionFactory.createConnection(connectionData(user));
  }
  throw new NotConnectedException(providerId);
}
 

import org.springframework.social.connect.NotConnectedException; //导入依赖的package包/类
@Override
public <A> Connection<A> getPrimaryConnection(Class<A> apiType) {
  Connection<A> connection = findPrimaryConnection(apiType);
  if (connection == null) {
    throw new NotConnectedException(getConnectionFactory(apiType).getProviderId());
  }
  return connection;
}
 

import org.springframework.social.connect.NotConnectedException; //导入依赖的package包/类
@Test(expected = NotConnectedException.class)
public void testGetConnectionByProviderClassNotFound() throws Exception {
  Connection connection = mock(Connection.class);
  ArgumentCaptor<ConnectionData> connectionDataCaptor =
      ArgumentCaptor.forClass(ConnectionData.class);
  when(connectionFactoryOne.createConnection(connectionDataCaptor.capture()))
      .thenReturn(connection);
  connectionRepository.getConnection(
      TestConnectionFactoryOne.class, PROVIDER_ONE + ":" + idProvider.getAndIncrement());
}
 

import org.springframework.social.connect.NotConnectedException; //导入依赖的package包/类
@Test(expected = NotConnectedException.class)
public void testGetConnectionByProviderClassWrongProvider() throws Exception {
  Connection connection = mock(Connection.class);
  ArgumentCaptor<ConnectionData> connectionDataCaptor =
      ArgumentCaptor.forClass(ConnectionData.class);
  when(connectionFactoryOne.createConnection(connectionDataCaptor.capture()))
      .thenReturn(connection);
  connectionRepository.getConnection(
      TestConnectionFactoryTwo.class, providerUserId());
}
 

import org.springframework.social.connect.NotConnectedException; //导入依赖的package包/类
@Test(expected = NotConnectedException.class)
public void testGetPrimaryConnectionNotFound() throws Exception {
  Connection connection = mock(Connection.class);
  ArgumentCaptor<ConnectionData> connectionDataCaptor =
      ArgumentCaptor.forClass(ConnectionData.class);
  when(connectionFactoryOne.createConnection(connectionDataCaptor.capture()))
      .thenReturn(connection);
  connectionRepository.getPrimaryConnection(TestConnectionFactoryTwo.class);
}
 

import org.springframework.social.connect.NotConnectedException; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public <A> Connection<A> getPrimaryConnection(Class<A> apiType) {
	String providerId = getProviderId(apiType);
	Connection<A> connection = (Connection<A>) findPrimaryConnection(providerId);
	if (connection == null) {
		throw new NotConnectedException(providerId);
	}
	return connection;
}
 

import org.springframework.social.connect.NotConnectedException; //导入依赖的package包/类
@Override
@SuppressWarnings("unchecked")
public <A> Connection<A> getPrimaryConnection(Class<A> apiType) {
  String providerId = getProviderId(apiType);
  Connection<A> connection = (Connection<A>) findPrimaryConnection(providerId);
  if (connection == null) {
    throw new NotConnectedException(providerId);
  }
  return connection;
}
 

import org.springframework.social.connect.NotConnectedException; //导入依赖的package包/类
@Override
@Transactional(readOnly = true)
public <A> Connection<A> getPrimaryConnection(final Class<A> apiType) {

    final Connection<A> primaryConnection = findPrimaryConnection(apiType);

    if (primaryConnection == null) {
        final String providerId = getProviderId(apiType);
        throw new NotConnectedException(providerId);
    }

    return primaryConnection;
}
 

import org.springframework.social.connect.NotConnectedException; //导入依赖的package包/类
/**
 * {@inheritDoc}
 */
public <A> Connection<A> getPrimaryConnection(Class<A> apiType) {
	Connection<A> connection = findPrimaryConnection(apiType);
	if (null == connection) {
		throw new NotConnectedException(getProviderId(apiType));
	}
	return connection;
}
 

import org.springframework.social.connect.NotConnectedException; //导入依赖的package包/类
@SuppressWarnings("unchecked")
public <A> Connection<A> getPrimaryConnection(Class<A> apiType) {
    String providerId = getProviderId(apiType);
    Connection<A> connection = (Connection<A>) findPrimaryConnection(providerId);
    if (connection == null) {
        throw new NotConnectedException(providerId);
    }
    return connection;
}
 

import org.springframework.social.connect.NotConnectedException; //导入依赖的package包/类
@SuppressWarnings("unchecked")
@Override
public <A> Connection<A> getPrimaryConnection(Class<A> apiType) {
	String providerId = getProviderId(apiType);
	Connection<A> connection = (Connection<A>) findPrimaryConnection(providerId);
	if (connection == null) {
		throw new NotConnectedException(providerId);
	}
	return connection;
}
 

import org.springframework.social.connect.NotConnectedException; //导入依赖的package包/类
@Test(expected = NotConnectedException.class)
public void findPrimaryConnectionNotConnected() {
    connectionRepository.getPrimaryConnection(TestFacebookApi.class);
}
 

import org.springframework.social.connect.NotConnectedException; //导入依赖的package包/类
@Test(expected = NotConnectedException.class)
public void findPrimaryConnectionNotConnected() {
  connectionRepository.getPrimaryConnection(TestFacebookApi.class);
}
 

import org.springframework.social.connect.NotConnectedException; //导入依赖的package包/类
@Test(expected = NotConnectedException.class)
public void testGetPrimaryConnectionWithNoConnection() throws Exception {
    subject.getPrimaryConnection(Facebook.class);
}