import org.ldaptive.SearchOperation; //导入依赖的package包/类
/**
 * Execute search operation.
 *
 * @param connectionFactory the connection factory
 * @param baseDn            the base dn
 * @param filter            the filter
 * @return the response
 * @throws LdapException the ldap exception
 */
public static Response<SearchResult> executeSearchOperation(final ConnectionFactory connectionFactory,
                                                            final String baseDn,
                                                            final SearchFilter filter)
        throws LdapException {
    try (Connection connection = createConnection(connectionFactory)) {
        final SearchOperation searchOperation = new SearchOperation(connection);
        final SearchRequest request = createSearchRequest(baseDn, filter);
        request.setReferralHandler(new SearchReferralHandler());
        return searchOperation.execute(request);
    }
}
 

import org.ldaptive.SearchOperation; //导入依赖的package包/类
/**
 * Searches the ldap instance for the attribute value.
 *
 * @param remoteIp the remote ip
 * @return the boolean
 */
protected boolean executeSearchForSpnegoAttribute(final String remoteIp) {
    Connection connection = null;
    final String remoteHostName = getRemoteHostName(remoteIp);
    logger.debug("Resolved remote hostname {} based on ip {}",
            remoteHostName, remoteIp);

    try {
        connection = createConnection();
        final Operation searchOperation = new SearchOperation(connection);
        this.searchRequest.getSearchFilter().setParameter(0, remoteHostName);

        logger.debug("Using search filter {} on baseDn {}",
                this.searchRequest.getSearchFilter().format(),
                this.searchRequest.getBaseDn());

        final Response<SearchResult> searchResult = searchOperation.execute(this.searchRequest);
        if (searchResult.getResultCode() == ResultCode.SUCCESS) {
            return processSpnegoAttribute(searchResult);
        }
        throw new RuntimeException("Failed to establish a connection ldap. "
                + searchResult.getMessage());

    } catch (final LdapException e) {
        logger.error(e.getMessage(), e);
        throw new RuntimeException(e);
    } finally {
        if (connection != null) {
            connection.close();
        }
    }
}
 

import org.ldaptive.SearchOperation; //导入依赖的package包/类
/**
 * Execute search operation.
 *
 * @param connection the connection
 * @param filter the filter
 * @return the response
 * @throws LdapException the ldap exception
 */
private Response<SearchResult> executeSearchOperation(final Connection connection, final SearchFilter filter)
        throws LdapException {

    final SearchOperation searchOperation = new SearchOperation(connection);
    final SearchRequest request = newRequest(filter);
    logger.debug("Using search request {}", request.toString());
    return searchOperation.execute(request);
}
 

import org.ldaptive.SearchOperation; //导入依赖的package包/类
/**
 * Execute search operation.
 *
 * @param connectionFactory the connection factory
 * @param baseDn            the base dn
 * @param filter            the filter
 * @param binaryAttributes  the binary attributes
 * @param returnAttributes  the return attributes
 * @return the response
 * @throws LdapException the ldap exception
 */
public static Response<SearchResult> executeSearchOperation(final ConnectionFactory connectionFactory,
                                                            final String baseDn,
                                                            final SearchFilter filter,
                                                            final String[] binaryAttributes,
                                                            final String[] returnAttributes) throws LdapException {
    try (Connection connection = createConnection(connectionFactory)) {
        final SearchOperation searchOperation = new SearchOperation(connection);
        final SearchRequest request = Beans.newLdaptiveSearchRequest(baseDn, filter, binaryAttributes, returnAttributes);
        request.setReferralHandler(new SearchReferralHandler());
        return searchOperation.execute(request);
    }
}
 

import org.ldaptive.SearchOperation; //导入依赖的package包/类
/**
 * Searches the ldap instance for the attribute value.
 *
 * @param remoteIp the remote ip
 * @return true/false
 */
protected boolean executeSearchForSpnegoAttribute(final String remoteIp) {
    Connection connection = null;
    final String remoteHostName = getRemoteHostName(remoteIp);
    LOGGER.debug("Resolved remote hostname [{}] based on ip [{}]", remoteHostName, remoteIp);

    try {
        connection = createConnection();
        final Operation searchOperation = new SearchOperation(connection);
        this.searchRequest.getSearchFilter().setParameter(0, remoteHostName);

        LOGGER.debug("Using search filter [{}] on baseDn [{}]",
                this.searchRequest.getSearchFilter().format(),
                this.searchRequest.getBaseDn());

        final Response<SearchResult> searchResult = searchOperation.execute(this.searchRequest);
        if (searchResult.getResultCode() == ResultCode.SUCCESS) {
            return processSpnegoAttribute(searchResult);
        }
        throw new RuntimeException("Failed to establish a connection ldap. " + searchResult.getMessage());
    } catch (final LdapException e) {
        LOGGER.error(e.getMessage(), e);
        throw Throwables.propagate(e);
    } finally {
        if (connection != null) {
            connection.close();
        }
    }
}
 

import org.ldaptive.SearchOperation; //导入依赖的package包/类
private Response<SearchResult> executeSearchOperation(final Connection connection, final SearchFilter filter)
        throws LdapException {

    final SearchOperation searchOperation = new SearchOperation(connection);
    final SearchRequest request = newRequest(filter);
    logger.debug("Using search request {}", request.toString());
    return searchOperation.execute(request);
}
 

import org.ldaptive.SearchOperation; //导入依赖的package包/类
@Override
public Iterable<LdapEntry> select(Connection connection) {
  final SearchRequest groupsSearch = new SearchRequest();
  groupsSearch.setBaseDn(baseDn);
  groupsSearch.setSearchFilter(new SearchFilter(groupsFilter));
  groupsSearch.setSearchScope(SUBTREE);
  groupsSearch.setReturnAttributes(membersAttr);
  groupsSearch.setSearchEntryHandlers(new RangeEntryHandler());
  try {
    final Response<SearchResult> response = new SearchOperation(connection).execute(groupsSearch);
    if (response.getResultCode() != SUCCESS) {
      throw new SyncException("Couldn't get groups, result code is " + response.getResultCode());
    }
    return new RequestEachEntryIterable(
        response
            .getResult()
            .getEntries()
            .stream()
            .flatMap(entry -> entry.getAttribute(membersAttr).getStringValues().stream())
            .collect(toSet()),
        connection,
        usersFilter,
        returnAttrs);
  } catch (LdapException x) {
    throw new SyncException(x.getLocalizedMessage(), x);
  }
}
 

import org.ldaptive.SearchOperation; //导入依赖的package包/类
private RequestEachEntryIterator(
    Iterator<String> dns,
    Connection connection,
    SearchFilter usersFilter,
    String[] returnAttrs) {
  this.dnsIterator = dns;
  this.usersFilter = usersFilter;
  this.returnAttrs = returnAttrs;
  this.searchOp = new SearchOperation(connection);
}