2 * Copyright 1999, Dmitry Kovalev (zmit@mail.ru), All rights reserved.
4 * Redistribution and use in source and binary forms are permitted only
5 * as authorized by the OpenLDAP Public License. A copy of this
6 * license is available at http://www.OpenLDAP.org/license.html or
7 * in file LICENSE in the top-level directory of the distribution.
15 #include <sys/types.h>
20 #include "schema-map.h"
24 int backsql_attrlist_add(backsql_srch_info *bsi,char *at_name)
34 Debug(LDAP_DEBUG_TRACE,"==>backsql_attrlist_add(): attribute '%s' is in list\n",*p,0,0);
35 if (!strcasecmp(*p,at_name))
40 Debug(LDAP_DEBUG_TRACE,"==>backsql_attrlist_add(): adding '%s' to list\n",at_name,0,0);
41 bsi->attrs=(char**)ch_realloc(bsi->attrs,(n_attrs+2)*sizeof(char*));
42 bsi->attrs[n_attrs]=strdup(at_name);
43 bsi->attrs[n_attrs+1]=NULL;
47 void backsql_init_search(backsql_srch_info *bsi,backsql_info *bi,char *nbase,int scope,
48 int slimit,int tlimit,time_t stoptime,Filter *filter,
49 SQLHDBC dbh,Backend *be,Connection *conn,Operation *op,char **attrs)
63 bsi->attrs=(char**)ch_calloc(1,sizeof(char*));
65 for(p=attrs;*p!=NULL;p++)
66 backsql_attrlist_add(bsi,*p);
72 bsi->stoptime=stoptime;
74 bsi->sel=NULL; bsi->from=NULL; bsi->join_where=NULL; bsi->flt_where=NULL;
75 bsi->sel_len=0; bsi->from_len=0; bsi->jwhere_len=0; bsi->fwhere_len=0;
78 int backsql_process_filter_list(backsql_srch_info *bsi,Filter *f,int op)
80 char *sub_clause=NULL;
83 bsi->flt_where=backsql_strcat(bsi->flt_where,&bsi->fwhere_len,"(",NULL);
86 res=backsql_process_filter(bsi,f);
89 bsi->flt_where=backsql_strcat(bsi->flt_where,&bsi->fwhere_len," 1=0 ",NULL);
98 bsi->flt_where=backsql_strcat(bsi->flt_where,&bsi->fwhere_len," AND ",NULL);
101 bsi->flt_where=backsql_strcat(bsi->flt_where,&bsi->fwhere_len," OR ",NULL);
107 bsi->flt_where=backsql_strcat(bsi->flt_where,&bsi->fwhere_len,")",NULL);
111 int backsql_process_sub_filter(backsql_srch_info *bsi,Filter *f)
115 backsql_at_map_rec *at=backsql_at_with_name(bsi->oc,f->f_sub_type);
117 bsi->flt_where=backsql_strcat(bsi->flt_where,&bsi->fwhere_len,"(",at->sel_expr,
119 if (f->f_sub_initial!=NULL)
120 bsi->flt_where=backsql_strcat(bsi->flt_where,&bsi->fwhere_len,f->f_sub_initial,NULL);
122 bsi->flt_where=backsql_strcat(bsi->flt_where,&bsi->fwhere_len,"%",NULL);
124 if (f->f_sub_any!=NULL)
125 for(i=0;f->f_sub_any[i]!=NULL;i++)
126 bsi->flt_where=backsql_strcat(bsi->flt_where,&bsi->fwhere_len,f->f_sub_any[i],"%",NULL);
128 if (f->f_sub_final!=NULL)
129 bsi->flt_where=backsql_strcat(bsi->flt_where,&bsi->fwhere_len,f->f_sub_final,NULL);
131 bsi->flt_where=backsql_strcat(bsi->flt_where,&bsi->fwhere_len,"')",NULL);
136 int backsql_process_filter(backsql_srch_info *bsi,Filter *f)
138 backsql_at_map_rec *at;
139 backsql_at_map_rec oc_attr={"objectClass","","",NULL,NULL,NULL,NULL};
143 Debug(LDAP_DEBUG_TRACE,"==>backsql_process_filter()\n",0,0,0);
147 backsql_process_filter_list(bsi,f->f_or,LDAP_FILTER_OR);
150 case LDAP_FILTER_AND:
151 backsql_process_filter_list(bsi,f->f_and,LDAP_FILTER_AND);
154 case LDAP_FILTER_NOT:
155 bsi->flt_where=backsql_strcat(bsi->flt_where,&bsi->fwhere_len,"NOT (",NULL);
156 backsql_process_filter(bsi,f->f_not);
157 bsi->flt_where=backsql_strcat(bsi->flt_where,&bsi->fwhere_len,")",NULL);
160 case LDAP_FILTER_PRESENT:
171 if (strcasecmp(at_name,"objectclass"))
172 at=backsql_at_with_name(bsi->oc,at_name);
176 at->sel_expr=backsql_strcat(at->sel_expr,&len,"'",bsi->oc->name,"'",NULL);
180 Debug(LDAP_DEBUG_TRACE,"backsql_process_filter(): attribute '%s' is not defined for objectclass '%s'\n",
181 at_name,bsi->oc->name,0);
185 backsql_merge_from_clause(&bsi->from,&bsi->from_len,at->from_tbls);
186 //need to add this attribute to list of attrs to load, so that we could do test_filter() later
187 backsql_attrlist_add(bsi,at_name);
189 if (at->join_where != NULL && strstr(bsi->join_where,at->join_where)==NULL)
190 bsi->join_where=backsql_strcat(bsi->join_where,&bsi->jwhere_len," AND ",at->join_where,NULL);
193 // bsi->sel=backsql_strcat(bsi->sel,&bsi->sel_len,",",at->sel_expr," AS ",at->name,NULL);
197 case LDAP_FILTER_EQUALITY:
198 bsi->flt_where=backsql_strcat(bsi->flt_where,&bsi->fwhere_len,"(",at->sel_expr,"='",
199 f->f_avvalue.bv_val,"')",NULL);
202 bsi->flt_where=backsql_strcat(bsi->flt_where,&bsi->fwhere_len,"(",at->sel_expr,">=",
203 f->f_avvalue.bv_val,")",NULL);
206 bsi->flt_where=backsql_strcat(bsi->flt_where,&bsi->fwhere_len,"(",at->sel_expr,"<=",
207 f->f_avvalue.bv_val,")",NULL);
209 case LDAP_FILTER_PRESENT:
210 bsi->flt_where=backsql_strcat(bsi->flt_where,&bsi->fwhere_len,"NOT (",at->sel_expr,
213 case LDAP_FILTER_SUBSTRINGS:
214 backsql_process_sub_filter(bsi,f);
219 if (oc_attr.sel_expr!=NULL)
220 free(oc_attr.sel_expr);
221 Debug(LDAP_DEBUG_TRACE,"<==backsql_process_filter()\n",0,0,0);
225 char* backsql_srch_query(backsql_srch_info *bsi)
230 Debug(LDAP_DEBUG_TRACE,"==>backsql_srch_query()\n",0,0,0);
233 bsi->join_where=NULL;
235 bsi->sel_len=bsi->from_len=bsi->jwhere_len=bsi->fwhere_len=0;
237 bsi->sel=backsql_strcat(bsi->sel,&bsi->sel_len,
238 "SELECT ldap_entries.id,",bsi->oc->keytbl,".",bsi->oc->keycol,
239 ", '",bsi->oc->name,"' AS objectClass",
240 ", ldap_entries.dn AS dn",
242 bsi->from=backsql_strcat(bsi->from,&bsi->from_len," FROM ldap_entries,",bsi->oc->keytbl,NULL);
243 bsi->join_where=backsql_strcat(bsi->join_where,&bsi->jwhere_len," WHERE ",
244 bsi->oc->keytbl,".",bsi->oc->keycol,"=ldap_entries.keyval AND ",
245 "ldap_entries.objclass=? AND ",NULL);
249 case LDAP_SCOPE_BASE:
250 bsi->join_where=backsql_strcat(bsi->join_where,&bsi->jwhere_len,
251 "ldap_entries.dn=?",NULL);
253 case LDAP_SCOPE_ONELEVEL:
254 bsi->join_where=backsql_strcat(bsi->join_where,&bsi->jwhere_len,
255 "ldap_entries.parent=?",NULL);
257 case LDAP_SCOPE_SUBTREE:
258 bsi->join_where=backsql_strcat(bsi->join_where,&bsi->jwhere_len,
259 bsi->bi->subtree_cond,NULL);
262 if (backsql_process_filter(bsi,bsi->filter))
263 query=backsql_strcat(query,&q_len,bsi->sel,bsi->from,bsi->join_where," AND ",bsi->flt_where,NULL);
268 free(bsi->join_where);
269 free(bsi->flt_where);
270 bsi->sel_len=bsi->from_len=bsi->jwhere_len=bsi->fwhere_len=0;
271 Debug(LDAP_DEBUG_TRACE,"<==backsql_srch_query()\n",0,0,0);
275 int backsql_oc_get_candidates(backsql_oc_map_rec *oc,backsql_srch_info *bsi)
280 backsql_entryID base_id,*res,*c_id;
285 Debug(LDAP_DEBUG_TRACE,"==>backsql_oc_get_candidates(): oc='%s'\n",oc->name,0,0);
287 query=backsql_srch_query(bsi);
290 Debug(LDAP_DEBUG_TRACE,"backsql_oc_get_candidates(): could not construct query for objectclass\n",0,0,0);
294 Debug(LDAP_DEBUG_TRACE,"Constructed query: %s\n",query,0,0);
295 if ((rc=backsql_Prepare(bsi->dbh,&sth,query,0)) != SQL_SUCCESS)
297 Debug(LDAP_DEBUG_TRACE,"backsql_oc_get_candidates(): error preparing query\n",0,0,0);
298 backsql_PrintErrors(bsi->bi->db_env,bsi->dbh,sth,rc);
304 if (backsql_BindParamID(sth,1,&bsi->oc->id) != SQL_SUCCESS)
306 Debug(LDAP_DEBUG_TRACE,"backsql_oc_get_candidates(): error binding objectclass id parameter\n",0,0,0);
311 case LDAP_SCOPE_BASE:
312 case LDAP_SCOPE_SUBTREE:
313 if ((rc=backsql_BindParamStr(sth,2,bsi->base_dn,BACKSQL_MAX_DN_LEN)) != SQL_SUCCESS)
315 Debug(LDAP_DEBUG_TRACE,"backsql_oc_get_candidates(): error binding base_dn parameter\n",0,0,0);
316 backsql_PrintErrors(bsi->bi->db_env,bsi->dbh,sth,rc);
320 case LDAP_SCOPE_ONELEVEL:
321 res=backsql_dn2id(&base_id,bsi->dbh,bsi->base_dn);
324 Debug(LDAP_DEBUG_TRACE,"backsql_oc_get_candidates(): could not retrieve base_dn id - no such entry\n",0,0,0);
325 bsi->status=LDAP_NO_SUCH_OBJECT;
328 if (backsql_BindParamID(sth,2,&base_id.id) != SQL_SUCCESS)
330 Debug(LDAP_DEBUG_TRACE,"backsql_oc_get_candidates(): error binding base id parameter\n",0,0,0);
338 if ((rc=SQLExecute(sth)) != SQL_SUCCESS && rc!= SQL_SUCCESS_WITH_INFO)
340 Debug(LDAP_DEBUG_TRACE,"backsql_oc_get_candidates(): error executing query\n",0,0,0);
341 backsql_PrintErrors(bsi->bi->db_env,bsi->dbh,sth,rc);
342 SQLFreeStmt(sth,SQL_DROP);
346 backsql_BindRowAsStrings(sth,&row);
347 while ((rc=SQLFetch(sth)) == SQL_SUCCESS || rc==SQL_SUCCESS_WITH_INFO)
350 e=(Entry*)ch_calloc(1,sizeof(Entry));
351 for (i=1;i<row.ncols;i++)
353 if (row.is_null[i]>0)
355 backsql_entry_addattr(e,row.col_names[i],row.cols[i],row.col_prec[i]);
356 // Debug(LDAP_DEBUG_TRACE,"prec=%d\n",(int)row.col_prec[i],0,0);
359 // Debug(LDAP_DEBUG_TRACE,"NULL value in this row for attribute '%s'\n",row.col_names[i],0,0);
363 Debug(LDAP_DEBUG_TRACE,"backsql_oc_get_candidates(): adding entry id=%s, keyval=%s dn='%s'\n",
364 row.cols[0],row.cols[1],row.cols[3]);
365 c_id=(backsql_entryID*)ch_calloc(1,sizeof(backsql_entryID));
366 c_id->id=atoi(row.cols[0]);
367 c_id->keyval=atoi(row.cols[1]);
368 c_id->oc_id=bsi->oc->id;
369 c_id->dn=strdup(row.cols[3]);
370 c_id->next=bsi->id_list;
373 backsql_FreeRow(&row);
374 SQLFreeStmt(sth,SQL_DROP);
375 Debug(LDAP_DEBUG_TRACE,"<==backsql_oc_get_candidates()\n",0,0,0);
380 int backsql_search(Backend *be,Connection *conn,Operation *op,
381 char *base, char *nbase, int scope,int deref,int slimit,int tlimit,
382 Filter *filter, char *filterstr,char **attrs,int attrsonly)
384 backsql_info *bi=(backsql_info*)be->be_private;
389 int manageDSAit = get_manageDSAit( op );
390 struct berval **v2refs = NULL;
392 backsql_srch_info srch_info;
393 backsql_entryID *eid=NULL;
395 base=dn_validate(base);
396 Debug(LDAP_DEBUG_TRACE,"==>backsql_search(): base='%s', filter='%s', scope=%d,",
397 base,filterstr,scope);
398 Debug(LDAP_DEBUG_TRACE," deref=%d, attrsonly=%d, attributes to load: %s\n",
399 deref,attrsonly,attrs==NULL?"all":"custom list");
400 dbh=backsql_get_db_conn(be,conn);
404 Debug(LDAP_DEBUG_TRACE,"backsql_search(): could not get connection handle - exiting\n",0,0,0);
405 send_ldap_result(conn,op,LDAP_OTHER,"","SQL-backend error",NULL,NULL);
409 if (tlimit == 0 && be_isroot(be,op->o_dn))
411 tlimit = -1; /* allow root to set no limit */
415 tlimit = (tlimit > be->be_timelimit || tlimit < 1) ?
416 be->be_timelimit : tlimit;
417 stoptime = op->o_time + tlimit;
420 if (slimit == 0 && be_isroot(be,op->o_dn))
422 slimit = -1; /* allow root to set no limit */
426 slimit = (slimit > be->be_sizelimit || slimit < 1) ?
427 be->be_sizelimit : slimit;
430 //backsql_init_search(&srch_info,bi,nbase/*!!!!!!!!*/,scope,slimit,tlimit,stoptime,filter,dbh,
431 // be,conn,op,attrs);
432 backsql_init_search(&srch_info,bi,base/*don't know so far how to make Oracle do CIS search on VARCHAR2*/,
433 scope,slimit,tlimit,stoptime,filter,dbh,
436 //for each objectclass we try to construct query which gets IDs
437 //of entries matching LDAP query filter and scope (or at least candidates),
439 avl_apply(bi->oc_by_name,(AVL_APPLY)backsql_oc_get_candidates,&srch_info,0,AVL_INORDER);
442 //now we load candidate entries (only those attrubutes mentioned in attrs and filter),
443 //test it against full filter and then send to client
444 for(eid=srch_info.id_list;eid!=NULL;eid=eid->next)
446 /* check for abandon */
447 ldap_pvt_thread_mutex_lock(&op->o_abandonmutex);
450 ldap_pvt_thread_mutex_unlock(&op->o_abandonmutex);
453 ldap_pvt_thread_mutex_unlock(&op->o_abandonmutex);
455 /* check time limit */
456 if ( tlimit != -1 && slap_get_time() > stoptime)
458 send_search_result( conn, op, LDAP_TIMELIMIT_EXCEEDED,
459 NULL, NULL, v2refs, NULL, nentries );
464 Debug(LDAP_DEBUG_TRACE,"backsql_search(): loading data for entry id=%d, oc_id=%d, keyval=%d\n",
465 eid->id,eid->oc_id,eid->keyval);
467 res=backsql_id2entry(&srch_info,&entry,eid);
470 Debug(LDAP_DEBUG_TRACE,"backsql_search(): error in backsql_id2entry() - skipping entry\n",0,0,0);
474 if ( !manageDSAit && scope != LDAP_SCOPE_BASE &&
475 is_entry_referral( &entry ) )
477 struct berval **refs = get_entry_referrals(be,conn,op,&entry);
479 send_search_reference( be, conn, op, &entry, refs, scope, NULL, &v2refs );
480 ber_bvecfree( refs );
484 // if (test_filter(be,conn,op,&entry,filter)==0)
486 if ((sres=send_search_entry(be,conn,op,&entry,attrs,attrsonly,NULL))==-1)
488 Debug(LDAP_DEBUG_TRACE,"backsql_search(): connection lost\n",0,0,0);
495 for(eid=srch_info.id_list;eid!=NULL;eid=backsql_free_entryID(eid));
497 //free bsi->attrs!!!!!!!!!!!!!!!!!!!!!!!!!!!
500 send_search_result( conn, op,
501 v2refs == NULL ? LDAP_SUCCESS : LDAP_REFERRAL,
502 NULL, NULL, v2refs, NULL, nentries );
504 send_ldap_result(conn,op,LDAP_NO_SUCH_OBJECT,NULL,NULL,NULL,0);
506 Debug(LDAP_DEBUG_TRACE,"<==backsql_search()\n",0,0,0);
510 #endif /* SLAPD_SQL */