| 连接LDAP数据库CRUD，包括分页查询的持久层代码 |
package com.scnu.ytxt.persistence.sqlmapdao.user;
import java.util.ArrayList;
import java.util.List;
import java.util.Map;
import javax.naming.directory.Attributes;
import javax.naming.directory.SearchControls;
import org.springframework.ldap.AttributesMapper;
import org.springframework.ldap.CollectingNameClassPairCallbackHandler;
import org.springframework.ldap.LdapTemplate;
import org.springframework.ldap.support.DistinguishedName;
import org.springframework.ldap.support.control.PagedResultsRequestControl;
import org.springframework.ldap.support.filter.AndFilter;
import org.springframework.ldap.support.filter.EqualsFilter;
import com.scnu.ytxt.attribute.AttributeBuilder;
import com.scnu.ytxt.attribute.AttributeFather;
import com.scnu.ytxt.attribute.AttributeMapper;
import com.scnu.ytxt.persistence.iface.user.UserManageDao;
/**
* 用户管理DaoImpl
*
* @author Ray
*/
public class UserManageDaoImpl implements UserManageDao {
private LdapTemplate ldapTemplate;
/** objectClass类型 */
private static final String OBJECT_NAME = "user";
/** 节点名 */
private static final String BASE = "ou=user";
/** 所需要的类名称 */
private static final String ENTITY_CLASSNAME
= "com.scnu.ytxt.persistence.sqlmapdao.user.UserForLDAP";
/** 主键 */
private static final String PRIMARY_KEY = "userUid";
/** 最大页数 */
private static final int MAX_PAGE = 10000;
AttributeFather father = null;
AttributeBuilder builder = null;
AttributeMapper mapper = null;
public void setLdapTemplate(LdapTemplate ldapTemplate)
{
this.ldapTemplate = ldapTemplate;
}
/** 构造函数 */
public UserManageDaoImpl()
{
father = new AttributeFather(ENTITY_CLASSNAME);
builder = new AttributeBuilder();
mapper = new AttributeMapper();
}
/** 创建条目对应的DN */
public DistinguishedName getDN(Object parameterObject, String primaryKey,
String ouBase)
{
UserForLDAP userForLDAP = (UserForLDAP) parameterObject;
// 设置在ou=user下查找对象
DistinguishedName newContactDN = new DistinguishedName(ouBase);
// 设置需要删除的条目的DN
newContactDN.add(primaryKey, userForLDAP.getUserUid());
return newContactDN;
}
/** 添加 */
public int addUser(final Object parameterObject)
{
try
{
// 获取用户传来的属性集
Attributes attri = builder.getUserAttrs(parameterObject,
OBJECT_NAME);
DistinguishedName newContactDN = getDN(parameterObject,
PRIMARY_KEY, BASE);
// 把新条目绑定到LDAP
ldapTemplate.bind(newContactDN, null, attri);
// 参数说明（"userUid=liling,ou=user" , null(绑定对象) , 要添加的字段集）
return 1;
}
catch (Exception e)
{
System.out.println("异常：" + e);
return 0;
}
}
/** 删除 */
public int delUser(final Object parameterObject)
{
DistinguishedName newContactDN
= getDN(parameterObject, PRIMARY_KEY,BASE);
try
{
// 进行删除，其中true表示同时删除其孩子结点
ldapTemplate.unbind(newContactDN, true);
return 1;
}
catch (Exception e)
{
return 0;
}
}
/** 修改 */
public int updateUserInfo(final Object parameterObject, String updateType)
{
// 获取用户传来的属性集
Attributes attri = builder.getUserAttrs(parameterObject,
OBJECT_NAME);
DistinguishedName newContactDN = getDN(parameterObject, PRIMARY_KEY,
BASE);
try
{
ldapTemplate.rebind(newContactDN, null, attri);
// 参数说明（"userUid=liling,ou=user" , null , 要添加的字段值）
return 1;
}
catch (Exception e)
{
return 0;
}
}
/** 查询 */
public List getUserInfo(final Object parameterObject, int curPage,
int pageSize)
{
// 用于存储条目列表
List list = new ArrayList();
long starTime = System.currentTimeMillis();
// 设置filter
String filter = "objectclass=" + OBJECT_NAME;
// 声明搜索控件
SearchControls searchControls = new SearchControls();
// 指定检索范围
searchControls.setSearchScope(SearchControls.SUBTREE_SCOPE);
/*
* 0:OBJECT_SCOPE,搜索指定的命名对象。
* 1:ONELEVEL_SCOPE,只搜索指定命名对象的一个级别，这是缺省值。
* 2:SUBTREE_SCOPE,搜索以指定命名对象为根结点的整棵树
*/
// 声明属性名集合，并由Map类型转换为String类型数组
Map attriMap = father.getAttriName();
String returnedAtts[] = new String[attriMap.size()];
for (int i = 0, size = attriMap.size(); i < size; i++)
{
returnedAtts[i] = (String) (attriMap.get(i));
}
// 设置要返回的属性，即所有
searchControls.setReturningAttributes(returnedAtts);
// 设置handler，handler里存储了条目的list
CollectingNameClassPairCallbackHandler handler
= ldapTemplate.new AttributesMapperCallbackHandler(mapper);
// 设置页面大小
PagedResultsRequestControl requestControl
= new PagedResultsRequestControl(pageSize);
// 分为两种情况，第一种只取第一页，第二种取其他页数
if (curPage == 1)
{
try
{
// 只获取第一页
ldapTemplate.search(BASE, filter, searchControls, handler,
requestControl);
list = handler.getList();
}
catch (Exception e)
{
System.out.println("分页查询异常1" + e);
}
}
else
{
try
{
// 按分页搜索，并将结果存进handler，这里获取第一页
ldapTemplate.search(BASE, filter, searchControls, handler,
requestControl);
// 循环获取其余的页数，直至目标页
for (int i = 0, cur_1 = curPage - 1, cur_2 = curPage - 2; i < cur_1; i++)
{
// 声明临时变量handlerTemp。用于每次存储该次搜索的页面信息
CollectingNameClassPairCallbackHandler handlerTemp
= ldapTemplate.new AttributesMapperCallbackHandler(mapper);
// 设置页面大小
requestControl = new PagedResultsRequestControl(pageSize,
requestControl.getCookie());
// 在上次查询的基础上继续往后查询
ldapTemplate.search(BASE, filter, searchControls,
handlerTemp, requestControl);
// 检测为当前页，获取当前页的条目列表
if (i == cur_2)
list = handlerTemp.getList();
}
long endTime = System.currentTimeMillis();
System.out.println("查询所用时间:" + (endTime - starTime));
}
catch (Exception e)
{
System.out.println("分页查询异常2" + e);
}
}
return list;
}
/** 查询表的行数 */
public int getUserTotal(final Object parameterObject) {
long starTime = System.currentTimeMillis();
// 条目列表
List list = null;
// 设置filter
String filter = "objectclass=" + OBJECT_NAME;
// 声明搜索控件
SearchControls searchControls = new SearchControls();
// 指定检索范围
searchControls.setSearchScope(SearchControls.SUBTREE_SCOPE);
// 0:OBJECT_SCOPE,搜索指定命名的对象。1:ONELEVEL_SCOPE,只搜索指定命名对象的一个级别，这是缺省值。2:SUBTREE_SCOPE,搜索指定命名对象的子树，包括指定的命名对象
// 声明属性名集合，并转换为String数组
// 不返回属性对
searchControls.setReturningAttributes(null);
// 设置handler，handler里存储了条目的list
CollectingNameClassPairCallbackHandler handler
= ldapTemplate.new AttributesMapperCallbackHandler(mapper);
// 设置页面大小
PagedResultsRequestControl requestControl
= new PagedResultsRequestControl(MAX_PAGE);
try
{
// 只获取第一页
ldapTemplate.search(BASE, filter, searchControls, handler,
requestControl);
list = handler.getList();
long endTime = System.currentTimeMillis();
System.out.println("获得记录数所用时间:" + (endTime - starTime));
}
catch (Exception e)
{
System.out.println("分页查询异常1" + e);
}
return list.size();
}
/** 查询指定记录 */
public Object getUserInfoById(final Object parameterObject) {
// 条目列表
List list = null;
try
{
UserForLDAP userForLDAP = (UserForLDAP) parameterObject;
// 过滤器
AndFilter andFilter = new AndFilter();
andFilter.and(new EqualsFilter("objectclass", OBJECT_NAME));
// 添加userUid的过滤器设置
if (userForLDAP.getUserUid() != "")
andFilter.and(new EqualsFilter(PRIMARY_KEY, userForLDAP.getUserUid()));
else
return null;
// 进行检索
list = ldapTemplate.search(BASE, andFilter.encode(),mapper);
}
catch (Exception e)
{
System.out.println("查询指定记录异常" + e);
}
return list;
}
}
分享到：
相关推荐
用perl操作LDAP数据库
NULL 博文链接：https://zhao-weigang.iteye.com/blog/2008377
jdbc连接ldap的jar包，很好用的，可以像操作oracle数据库一样对ldap进行查询、添加、修改或删除等等。
django-ldapdb, Django ldapdb，用于 Django的LDAP数据库后端 django-ldapdb django-ldapdb 是用于 Django的LDAP数据库后端，允许通过 Django 模型操作LDAP条目。它支持大多数与 Django 模型相同的api:MyModel.o
java连接和验证的ldap学习文档，密码的校验，通过jndi连接ldap服务
LDAP协议是Internet中用于数据查询访问的重要协议,在PKI基础设施中,LDAP可用于证书和CRL的查询下载,...结合了LDAP协议标准和PKI实现的具体要求,提出了一种基于关系数据库的LDAP服务器的实现方式,实现了LDAP的查询操作。
java连接LDAP实例和jar包，里面包含ssl连接和更改LDAP属性的例子，公参考
# LDAP连接工具 LDAP是一种轻量级目录访问协议，用于在网络中访问分布式目录服务。要连接到LDAP目录，需要一种LDAP连接工具。 以下是一些常用的LDAP连接工具： ## 1. Apache Directory Studio Apache Directory ...
一个使用Delphi连接LDAP服务器的控件及代码。仅供学习。
这是一个可以登录ldap服务器并取出想要的结果 的一个简单例子。..
ldap 目录数据库，能够很好提高查询速度，文本中有增删改查等各种操作，包括详细源码！
LdanAdmin工具，用户查询ldap数据库信息LdanAdmin工具，用户查询ldap数据库信息LdanAdmin工具，用户查询ldap数据库信息LdanAdmin工具，用户查询ldap数据库信息
NULL 博文链接：https://laodaobazi.iteye.com/blog/2093866
主要介绍了Spring Boot 连接LDAP的方法,仅仅涉及基本的使用ODM来快速实现LDAP增删改查操作。具有一定的参考价值，有兴趣的可以了解一下
连接Ldap小工具-ldapbrowser，非常的实用，用过才知道好
java 连接 ldap服务器源代码，大家可以下来看看。。。。。
有关ldap包的下载,很难找得到的,请不要随意转发, oracle连接数据库oracle9i的包,请不要随意传发, 本资料属于个人所上载. ldap是一种很不错的技术!
可以输入中文属性值 可以输入中文属性值 可以输入中文属性值可以输入中文属性值可以输入中文属性值 可以输入中文属性值 可以输入中文属性值
Open_LDAP安装配置
连接ldap工具试了好多，知道遇到她，ApacheDirectoryStudio~ 界面类似开发工具eclipse；目录结构清晰，图标也做了分类；好用！