org.pentaho.di.trans.steps.ldapinput

Class LDAPConnection

java.lang.Object

org.pentaho.di.trans.steps.ldapinput.LDAPConnection

public class LDAPConnection
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static String	DEFAUL_FILTER_STRING
static int	DEFAULT_PORT
static int	SEARCH_SCOPE_OBJECT_SCOPE
static int	SEARCH_SCOPE_ONELEVEL_SCOPE
static int	SEARCH_SCOPE_SUBTREE_SCOPE
static int	STATUS_ADDED
static int	STATUS_DELETED
static int	STATUS_INSERTED
static int	STATUS_SKIPPED
static int	STATUS_UPDATED

Constructor Summary

Constructors

Constructor and Description
LDAPConnection(LogChannelInterface logInterface, VariableSpace variableSpace, LdapMeta meta, Collection<String> binaryAttributes) Construct a new LDAP Connection

Method Summary

Modifier and Type	Method and Description
int	add(String dn, String[] attributes, String[] values, String multValuedSeparator, boolean checkEntry)
void	addSortingAttributes(String value)
void	close() Close the LDAP connection
void	connect() Connect to LDAP server
void	connect(String username, String password) Connect to LDAP server
int	delete(String dn, boolean checkEntry)
static String	extractBytesAndConvertToString(Attribute attr, boolean isSID)
Attributes	getAttributes()
RowMeta	getFields(String searchBase)
List<String>	getSortingAttributes()
int	getTimeLimit()
void	insert(String dn, String[] attributes, String[] values, String multValuedSeparator) Insert record in LDAP based on DN
void	rename(String oldDn, String newDn, boolean deleteRDN) Rename an entry
void	search(String searchBase, String filter, int limitRows, String[] attributeReturned, int searchScope)
void	SetPagingSize(int value)
void	setSortingAttributesKeys(String[] value)
void	setTimeLimit(int timeLimit)
int	update(String dn, String[] attributes, String[] values, boolean checkEntry)
int	upsert(String dn, String[] attributes, String[] values, String[] attributesToUpdate, String[] valuesToUpdate, String multValuedSeparator) Upsert record in LDAP First we will check if the entry exist based on DN If we can not find it, we will create it otherwise, we will perform an update

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

SEARCH_SCOPE_OBJECT_SCOPE

public static final int SEARCH_SCOPE_OBJECT_SCOPE

See Also:

Constant Field Values

SEARCH_SCOPE_ONELEVEL_SCOPE

public static final int SEARCH_SCOPE_ONELEVEL_SCOPE

See Also:

Constant Field Values

SEARCH_SCOPE_SUBTREE_SCOPE

public static final int SEARCH_SCOPE_SUBTREE_SCOPE

See Also:

Constant Field Values

DEFAULT_PORT

public static final int DEFAULT_PORT

See Also:

Constant Field Values

DEFAUL_FILTER_STRING

public static final String DEFAUL_FILTER_STRING

See Also:

Constant Field Values

STATUS_SKIPPED

public static final int STATUS_SKIPPED

See Also:

Constant Field Values

STATUS_INSERTED

public static final int STATUS_INSERTED

See Also:

Constant Field Values

STATUS_UPDATED

public static final int STATUS_UPDATED

See Also:

Constant Field Values

STATUS_DELETED

public static final int STATUS_DELETED

See Also:

Constant Field Values

STATUS_ADDED

public static final int STATUS_ADDED

See Also:

Constant Field Values

Constructor Detail

LDAPConnection

public LDAPConnection(LogChannelInterface logInterface,
                      VariableSpace variableSpace,
                      LdapMeta meta,
                      Collection<String> binaryAttributes)
               throws KettleException

Construct a new LDAP Connection

Throws:

KettleException

Method Detail

connect

public void connect()
             throws KettleException

Connect to LDAP server

Throws:

KettleException

connect

public void connect(String username,
                    String password)
             throws KettleException

Connect to LDAP server

Parameters:

username - : username

password - : password

Throws:

KettleException

setSortingAttributesKeys

public void setSortingAttributesKeys(String[] value)

addSortingAttributes

public void addSortingAttributes(String value)

getSortingAttributes

public List<String> getSortingAttributes()

setTimeLimit

public void setTimeLimit(int timeLimit)

getTimeLimit

public int getTimeLimit()

SetPagingSize

public void SetPagingSize(int value)

search

public void search(String searchBase,
                   String filter,
                   int limitRows,
                   String[] attributeReturned,
                   int searchScope)
            throws KettleException

Throws:

KettleException

delete

public int delete(String dn,
                  boolean checkEntry)
           throws KettleException

Throws:

KettleException

update

public int update(String dn,
                  String[] attributes,
                  String[] values,
                  boolean checkEntry)
           throws KettleException

Throws:

KettleException

add

public int add(String dn,
               String[] attributes,
               String[] values,
               String multValuedSeparator,
               boolean checkEntry)
        throws KettleException

Throws:

KettleException

insert

public void insert(String dn,
                   String[] attributes,
                   String[] values,
                   String multValuedSeparator)
            throws KettleException

Insert record in LDAP based on DN

Parameters:

dn - : Distinguished Name (Key for lookup)

attributes - : contains all the attributes to set for insert

values - : contains all the values for attributes

multValuedSeparator - : multi-valued attributes separator

Throws:

KettleException

upsert

public int upsert(String dn,
                  String[] attributes,
                  String[] values,
                  String[] attributesToUpdate,
                  String[] valuesToUpdate,
                  String multValuedSeparator)
           throws KettleException

Upsert record in LDAP First we will check if the entry exist based on DN If we can not find it, we will create it otherwise, we will perform an update

Parameters:

dn - : Distinguished Name (Key for lookup)

attributes - : contains all the attributes to set for insert

values - : contains all the values for attributes

attributesToUpdate - : contains attributes to update

valuesToUpdate - : contains values for attributes to update

multValuedSeparator - : multi-valued attributes separator

Returns:

status : STATUS_INSERTED, STATUS_UPDATED or STATUS_SKIPPED

Throws:

KettleException

rename

public void rename(String oldDn,
                   String newDn,
                   boolean deleteRDN)
            throws KettleException

Rename an entry

Parameters:

oldDn - Distinguished name of the entry to rename

newDn - target Distinguished name (new)

deleteRDN - To specify whether you want to keep the old name attribute when you use rename entry true : do not keep the old value (defaut) false : keep the old value as an attribute

Throws:

KettleException

close

public void close()
           throws KettleException

Close the LDAP connection

Throws:

KettleException

getAttributes

public Attributes getAttributes()
                         throws KettleException

Throws:

KettleException

extractBytesAndConvertToString

public static String extractBytesAndConvertToString(Attribute attr,
                                                    boolean isSID)
                                             throws Exception

Throws:

Exception

getFields

public RowMeta getFields(String searchBase)
                  throws KettleException

Throws:

KettleException