1 | /*
|
---|
2 | ldb database library
|
---|
3 |
|
---|
4 | Copyright (C) Andrew Tridgell 2004
|
---|
5 |
|
---|
6 | ** NOTE! The following LGPL license applies to the ldb
|
---|
7 | ** library. This does NOT imply that all of Samba is released
|
---|
8 | ** under the LGPL
|
---|
9 |
|
---|
10 | This library is free software; you can redistribute it and/or
|
---|
11 | modify it under the terms of the GNU Lesser General Public
|
---|
12 | License as published by the Free Software Foundation; either
|
---|
13 | version 3 of the License, or (at your option) any later version.
|
---|
14 |
|
---|
15 | This library is distributed in the hope that it will be useful,
|
---|
16 | but WITHOUT ANY WARRANTY; without even the implied warranty of
|
---|
17 | MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
---|
18 | Lesser General Public License for more details.
|
---|
19 |
|
---|
20 | You should have received a copy of the GNU Lesser General Public
|
---|
21 | License along with this library; if not, see <http://www.gnu.org/licenses/>.
|
---|
22 | */
|
---|
23 |
|
---|
24 | /*
|
---|
25 | * Name: ldb
|
---|
26 | *
|
---|
27 | * Component: ldbsearch
|
---|
28 | *
|
---|
29 | * Description: utility for ldb search - modelled on ldapsearch
|
---|
30 | *
|
---|
31 | * Author: Andrew Tridgell
|
---|
32 | */
|
---|
33 |
|
---|
34 | #include "replace.h"
|
---|
35 | #include "system/filesys.h"
|
---|
36 | #include "system/time.h"
|
---|
37 | #include "ldb.h"
|
---|
38 | #include "tools/cmdline.h"
|
---|
39 |
|
---|
40 | static void usage(struct ldb_context *ldb)
|
---|
41 | {
|
---|
42 | printf("Usage: ldbsearch <options> <expression> <attrs...>\n");
|
---|
43 | ldb_cmdline_help(ldb, "ldbsearch", stdout);
|
---|
44 | exit(LDB_ERR_OPERATIONS_ERROR);
|
---|
45 | }
|
---|
46 |
|
---|
47 | static int do_compare_msg(struct ldb_message **el1,
|
---|
48 | struct ldb_message **el2,
|
---|
49 | void *opaque)
|
---|
50 | {
|
---|
51 | return ldb_dn_compare((*el1)->dn, (*el2)->dn);
|
---|
52 | }
|
---|
53 |
|
---|
54 | struct search_context {
|
---|
55 | struct ldb_context *ldb;
|
---|
56 | struct ldb_control **req_ctrls;
|
---|
57 |
|
---|
58 | int sort;
|
---|
59 | unsigned int num_stored;
|
---|
60 | struct ldb_message **store;
|
---|
61 | unsigned int refs_stored;
|
---|
62 | char **refs_store;
|
---|
63 |
|
---|
64 | unsigned int entries;
|
---|
65 | unsigned int refs;
|
---|
66 |
|
---|
67 | unsigned int pending;
|
---|
68 | int status;
|
---|
69 | };
|
---|
70 |
|
---|
71 | static int store_message(struct ldb_message *msg, struct search_context *sctx) {
|
---|
72 |
|
---|
73 | sctx->store = talloc_realloc(sctx, sctx->store, struct ldb_message *, sctx->num_stored + 2);
|
---|
74 | if (!sctx->store) {
|
---|
75 | fprintf(stderr, "talloc_realloc failed while storing messages\n");
|
---|
76 | return -1;
|
---|
77 | }
|
---|
78 |
|
---|
79 | sctx->store[sctx->num_stored] = talloc_move(sctx->store, &msg);
|
---|
80 | sctx->num_stored++;
|
---|
81 | sctx->store[sctx->num_stored] = NULL;
|
---|
82 |
|
---|
83 | return 0;
|
---|
84 | }
|
---|
85 |
|
---|
86 | static int store_referral(char *referral, struct search_context *sctx) {
|
---|
87 |
|
---|
88 | sctx->refs_store = talloc_realloc(sctx, sctx->refs_store, char *, sctx->refs_stored + 2);
|
---|
89 | if (!sctx->refs_store) {
|
---|
90 | fprintf(stderr, "talloc_realloc failed while storing referrals\n");
|
---|
91 | return -1;
|
---|
92 | }
|
---|
93 |
|
---|
94 | sctx->refs_store[sctx->refs_stored] = talloc_move(sctx->refs_store, &referral);
|
---|
95 | sctx->refs_stored++;
|
---|
96 | sctx->refs_store[sctx->refs_stored] = NULL;
|
---|
97 |
|
---|
98 | return 0;
|
---|
99 | }
|
---|
100 |
|
---|
101 | static int display_message(struct ldb_message *msg, struct search_context *sctx) {
|
---|
102 | struct ldb_ldif ldif;
|
---|
103 |
|
---|
104 | sctx->entries++;
|
---|
105 | printf("# record %d\n", sctx->entries);
|
---|
106 |
|
---|
107 | ldif.changetype = LDB_CHANGETYPE_NONE;
|
---|
108 | ldif.msg = msg;
|
---|
109 |
|
---|
110 | if (sctx->sort) {
|
---|
111 | /*
|
---|
112 | * Ensure attributes are always returned in the same
|
---|
113 | * order. For testing, this makes comparison of old
|
---|
114 | * vs. new much easier.
|
---|
115 | */
|
---|
116 | ldb_msg_sort_elements(ldif.msg);
|
---|
117 | }
|
---|
118 |
|
---|
119 | ldb_ldif_write_file(sctx->ldb, stdout, &ldif);
|
---|
120 |
|
---|
121 | return 0;
|
---|
122 | }
|
---|
123 |
|
---|
124 | static int display_referral(char *referral, struct search_context *sctx)
|
---|
125 | {
|
---|
126 |
|
---|
127 | sctx->refs++;
|
---|
128 | printf("# Referral\nref: %s\n\n", referral);
|
---|
129 |
|
---|
130 | return 0;
|
---|
131 | }
|
---|
132 |
|
---|
133 | static int search_callback(struct ldb_request *req, struct ldb_reply *ares)
|
---|
134 | {
|
---|
135 | struct search_context *sctx;
|
---|
136 | int ret = LDB_SUCCESS;
|
---|
137 |
|
---|
138 | sctx = talloc_get_type(req->context, struct search_context);
|
---|
139 |
|
---|
140 | if (!ares) {
|
---|
141 | return ldb_request_done(req, LDB_ERR_OPERATIONS_ERROR);
|
---|
142 | }
|
---|
143 | if (ares->error != LDB_SUCCESS) {
|
---|
144 | return ldb_request_done(req, ares->error);
|
---|
145 | }
|
---|
146 |
|
---|
147 | switch (ares->type) {
|
---|
148 | case LDB_REPLY_ENTRY:
|
---|
149 | if (sctx->sort) {
|
---|
150 | ret = store_message(ares->message, sctx);
|
---|
151 | } else {
|
---|
152 | ret = display_message(ares->message, sctx);
|
---|
153 | }
|
---|
154 | break;
|
---|
155 |
|
---|
156 | case LDB_REPLY_REFERRAL:
|
---|
157 | if (sctx->sort) {
|
---|
158 | ret = store_referral(ares->referral, sctx);
|
---|
159 | } else {
|
---|
160 | ret = display_referral(ares->referral, sctx);
|
---|
161 | }
|
---|
162 | if (ret) {
|
---|
163 | return ldb_request_done(req, LDB_ERR_OPERATIONS_ERROR);
|
---|
164 | }
|
---|
165 | break;
|
---|
166 |
|
---|
167 | case LDB_REPLY_DONE:
|
---|
168 | if (ares->controls) {
|
---|
169 | if (handle_controls_reply(ares->controls, sctx->req_ctrls) == 1)
|
---|
170 | sctx->pending = 1;
|
---|
171 | }
|
---|
172 | talloc_free(ares);
|
---|
173 | return ldb_request_done(req, LDB_SUCCESS);
|
---|
174 | }
|
---|
175 |
|
---|
176 | talloc_free(ares);
|
---|
177 | if (ret != LDB_SUCCESS) {
|
---|
178 | return ldb_request_done(req, LDB_ERR_OPERATIONS_ERROR);
|
---|
179 | }
|
---|
180 |
|
---|
181 | return LDB_SUCCESS;
|
---|
182 | }
|
---|
183 |
|
---|
184 | static int do_search(struct ldb_context *ldb,
|
---|
185 | struct ldb_dn *basedn,
|
---|
186 | struct ldb_cmdline *options,
|
---|
187 | const char *expression,
|
---|
188 | const char * const *attrs)
|
---|
189 | {
|
---|
190 | struct ldb_request *req;
|
---|
191 | struct search_context *sctx;
|
---|
192 | int ret;
|
---|
193 |
|
---|
194 | req = NULL;
|
---|
195 |
|
---|
196 | sctx = talloc_zero(ldb, struct search_context);
|
---|
197 | if (!sctx) return LDB_ERR_OPERATIONS_ERROR;
|
---|
198 |
|
---|
199 | sctx->ldb = ldb;
|
---|
200 | sctx->sort = options->sorted;
|
---|
201 | sctx->req_ctrls = ldb_parse_control_strings(ldb, sctx, (const char **)options->controls);
|
---|
202 | if (options->controls != NULL && sctx->req_ctrls== NULL) {
|
---|
203 | printf("parsing controls failed: %s\n", ldb_errstring(ldb));
|
---|
204 | return LDB_ERR_OPERATIONS_ERROR;
|
---|
205 | }
|
---|
206 |
|
---|
207 | again:
|
---|
208 | /* free any previous requests */
|
---|
209 | if (req) talloc_free(req);
|
---|
210 |
|
---|
211 | ret = ldb_build_search_req(&req, ldb, ldb,
|
---|
212 | basedn, options->scope,
|
---|
213 | expression, attrs,
|
---|
214 | sctx->req_ctrls,
|
---|
215 | sctx, search_callback,
|
---|
216 | NULL);
|
---|
217 | if (ret != LDB_SUCCESS) {
|
---|
218 | talloc_free(sctx);
|
---|
219 | printf("allocating request failed: %s\n", ldb_errstring(ldb));
|
---|
220 | return ret;
|
---|
221 | }
|
---|
222 |
|
---|
223 | if (basedn == NULL) {
|
---|
224 | /*
|
---|
225 | we need to use a NULL base DN when doing a cross-ncs
|
---|
226 | search so we find results on all partitions in a
|
---|
227 | forest. When doing a domain-local search, default to
|
---|
228 | the default basedn
|
---|
229 | */
|
---|
230 | struct ldb_control *ctrl;
|
---|
231 | struct ldb_search_options_control *search_options = NULL;
|
---|
232 |
|
---|
233 | ctrl = ldb_request_get_control(req, LDB_CONTROL_SEARCH_OPTIONS_OID);
|
---|
234 | if (ctrl) {
|
---|
235 | search_options = talloc_get_type(ctrl->data, struct ldb_search_options_control);
|
---|
236 | }
|
---|
237 |
|
---|
238 | if (ctrl == NULL || search_options == NULL ||
|
---|
239 | !(search_options->search_options & LDB_SEARCH_OPTION_PHANTOM_ROOT)) {
|
---|
240 | struct ldb_dn *base = ldb_get_default_basedn(ldb);
|
---|
241 | if (base != NULL) {
|
---|
242 | req->op.search.base = base;
|
---|
243 | }
|
---|
244 | }
|
---|
245 | }
|
---|
246 |
|
---|
247 | sctx->pending = 0;
|
---|
248 |
|
---|
249 | ret = ldb_request(ldb, req);
|
---|
250 | if (ret != LDB_SUCCESS) {
|
---|
251 | printf("search failed - %s\n", ldb_errstring(ldb));
|
---|
252 | return ret;
|
---|
253 | }
|
---|
254 |
|
---|
255 | ret = ldb_wait(req->handle, LDB_WAIT_ALL);
|
---|
256 | if (ret != LDB_SUCCESS) {
|
---|
257 | printf("search error - %s\n", ldb_errstring(ldb));
|
---|
258 | return ret;
|
---|
259 | }
|
---|
260 |
|
---|
261 | if (sctx->pending)
|
---|
262 | goto again;
|
---|
263 |
|
---|
264 | if (sctx->sort && (sctx->num_stored != 0 || sctx->refs != 0)) {
|
---|
265 | unsigned int i;
|
---|
266 |
|
---|
267 | if (sctx->num_stored) {
|
---|
268 | LDB_TYPESAFE_QSORT(sctx->store, sctx->num_stored, ldb, do_compare_msg);
|
---|
269 | }
|
---|
270 | for (i = 0; i < sctx->num_stored; i++) {
|
---|
271 | display_message(sctx->store[i], sctx);
|
---|
272 | }
|
---|
273 |
|
---|
274 | for (i = 0; i < sctx->refs_stored; i++) {
|
---|
275 | display_referral(sctx->refs_store[i], sctx);
|
---|
276 | }
|
---|
277 | }
|
---|
278 |
|
---|
279 | printf("# returned %u records\n# %u entries\n# %u referrals\n",
|
---|
280 | sctx->entries + sctx->refs, sctx->entries, sctx->refs);
|
---|
281 |
|
---|
282 | talloc_free(sctx);
|
---|
283 | talloc_free(req);
|
---|
284 |
|
---|
285 | return LDB_SUCCESS;
|
---|
286 | }
|
---|
287 |
|
---|
288 | int main(int argc, const char **argv)
|
---|
289 | {
|
---|
290 | struct ldb_context *ldb;
|
---|
291 | struct ldb_dn *basedn = NULL;
|
---|
292 | const char * const * attrs = NULL;
|
---|
293 | struct ldb_cmdline *options;
|
---|
294 | int ret = -1;
|
---|
295 | const char *expression = "(|(objectClass=*)(distinguishedName=*))";
|
---|
296 | TALLOC_CTX *mem_ctx = talloc_new(NULL);
|
---|
297 |
|
---|
298 | ldb = ldb_init(mem_ctx, NULL);
|
---|
299 | if (ldb == NULL) {
|
---|
300 | return LDB_ERR_OPERATIONS_ERROR;
|
---|
301 | }
|
---|
302 |
|
---|
303 | options = ldb_cmdline_process(ldb, argc, argv, usage);
|
---|
304 |
|
---|
305 | /* the check for '=' is for compatibility with ldapsearch */
|
---|
306 | if (!options->interactive &&
|
---|
307 | options->argc > 0 &&
|
---|
308 | strpbrk(options->argv[0], "=<>~:")) {
|
---|
309 | expression = options->argv[0];
|
---|
310 | options->argv++;
|
---|
311 | options->argc--;
|
---|
312 | }
|
---|
313 |
|
---|
314 | if (options->argc > 0) {
|
---|
315 | attrs = (const char * const *)(options->argv);
|
---|
316 | }
|
---|
317 |
|
---|
318 | if (options->basedn != NULL) {
|
---|
319 | basedn = ldb_dn_new(ldb, ldb, options->basedn);
|
---|
320 | if (basedn == NULL) {
|
---|
321 | return LDB_ERR_OPERATIONS_ERROR;
|
---|
322 | }
|
---|
323 | }
|
---|
324 |
|
---|
325 | if (options->interactive) {
|
---|
326 | char line[1024];
|
---|
327 | while (fgets(line, sizeof(line), stdin)) {
|
---|
328 | ret = do_search(ldb, basedn, options, line, attrs);
|
---|
329 | }
|
---|
330 | } else {
|
---|
331 | ret = do_search(ldb, basedn, options, expression, attrs);
|
---|
332 | }
|
---|
333 |
|
---|
334 | talloc_free(mem_ctx);
|
---|
335 |
|
---|
336 | return ret;
|
---|
337 | }
|
---|