2 /* This work is part of OpenLDAP Software <http://www.openldap.org/>.
4 * Copyright 1998-2013 The OpenLDAP Foundation.
5 * Portions Copyright 1998-2003 Kurt D. Zeilenga.
6 * Portions Copyright 2003 IBM Corporation.
9 * Redistribution and use in source and binary forms, with or without
10 * modification, are permitted only as authorized by the OpenLDAP
13 * A copy of this license is available in file LICENSE in the
14 * top-level directory of the distribution or, alternatively, at
15 * <http://www.OpenLDAP.org/license.html>.
18 * This work was initially developed by Pierangelo Masarati for inclusion
19 * in OpenLDAP Software.
26 #include "ac/stdlib.h"
29 #include "ac/string.h"
30 #include "ac/socket.h"
31 #include "ac/unistd.h"
36 #include "lutil_meter.h"
39 #include "slapcommon.h"
41 static char csnbuf[ LDAP_PVT_CSNSTR_BUFSIZE ];
44 slapmodify( int argc, char **argv )
48 char textbuf[SLAP_TEXT_BUFLEN] = { '\0' };
49 size_t textlen = sizeof textbuf;
50 const char *progname = "slapmodify";
56 OperationBuffer opbuf;
60 int lineno, nextline, ldifrc;
62 int rc = EXIT_SUCCESS;
71 if ( isatty (2) ) enable_meter = 1;
72 slap_tool_init( progname, SLAPMODIFY, argc, argv );
74 memset( &opbuf, 0, sizeof(opbuf) );
76 op->o_hdr = &opbuf.ob_hdr;
78 if ( !be->be_entry_open ||
79 !be->be_entry_close ||
83 !be->be_entry_modify )
85 fprintf( stderr, "%s: database doesn't support necessary operations.\n",
88 fprintf( stderr, "\t(dry) continuing...\n" );
95 checkvals = (slapMode & SLAP_TOOL_QUICK) ? 0 : 1;
100 /* enforce schema checking unless not disabled */
101 if ( (slapMode & SLAP_TOOL_NO_SCHEMA_CHECK) == 0) {
102 SLAP_DBFLAGS(be) &= ~(SLAP_DBFLAG_NO_SCHEMA_CHECK);
105 if( !dryrun && be->be_entry_open( be, 1 ) != 0 ) {
106 fprintf( stderr, "%s: could not open database.\n",
108 exit( EXIT_FAILURE );
111 (void)slap_tool_update_ctxcsn_init();
115 /* tools default to "none" */
116 && slap_debug == LDAP_DEBUG_NONE
118 && !fstat ( fileno ( ldiffp->fp ), &stat_buf )
119 && S_ISREG(stat_buf.st_mode) ) {
120 enable_meter = !lutil_meter_open(
122 &lutil_meter_text_display,
123 &lutil_meter_linear_estimator,
129 /* nextline is the line number of the end of the current entry */
130 for( lineno=1; ( ldifrc = ldif_read_record( ldiffp, &nextline, &buf, &lmax )) > 0;
142 char *request = "(unknown)";
144 ber_str2bv( buf, 0, 0, &rbuf );
146 if ( lineno < jumpline )
150 lutil_meter_update( &meter,
155 * Initialize text buffer
157 bvtext.bv_len = textlen;
158 bvtext.bv_val = textbuf;
159 bvtext.bv_val[0] = '\0';
161 local_rc = ldap_parse_ldif_record( &rbuf, lineno, &lr,
162 "slapmodify", LDIF_NO_CONTROLS );
164 if ( local_rc != LDAP_SUCCESS ) {
165 fprintf( stderr, "%s: could not parse entry (line=%d)\n",
168 if( continuemode ) continue;
172 switch ( lr.lr_op ) {
177 case LDAP_REQ_MODIFY:
181 case LDAP_REQ_MODRDN:
182 case LDAP_REQ_DELETE:
183 fprintf( stderr, "%s: request 0x%lx not supported (line=%d)\n",
184 progname, (unsigned long)lr.lr_op, lineno );
186 if( continuemode ) continue;
190 fprintf( stderr, "%s: unknown request 0x%lx (line=%d)\n",
191 progname, (unsigned long)lr.lr_op, lineno );
193 if( continuemode ) continue;
197 local_rc = dnNormalize( 0, NULL, NULL, &lr.lr_dn, &ndn, NULL );
198 if ( local_rc != LDAP_SUCCESS ) {
199 fprintf( stderr, "%s: DN=\"%s\" normalization failed (line=%d)\n",
200 progname, lr.lr_dn.bv_val, lineno );
202 if( continuemode ) continue;
206 /* make sure the DN is not empty */
207 if( BER_BVISEMPTY( &ndn ) &&
208 !BER_BVISEMPTY( be->be_nsuffix ))
210 fprintf( stderr, "%s: line %d: "
211 "%s entry with empty dn=\"\"",
212 progname, lineno, request );
213 bd = select_backend( &ndn, nosubordinates );
217 LDAP_STAILQ_FOREACH( bdtmp, &backendDB, be_next ) {
218 if ( bdtmp == bd ) break;
222 assert( bdtmp != NULL );
224 fprintf( stderr, "; did you mean to use database #%d (%s)?",
226 bd->be_suffix[0].bv_val );
229 fprintf( stderr, "\n" );
231 SLAP_FREE( ndn.bv_val );
232 ldap_ldif_record_done( &lr );
233 if( continuemode ) continue;
238 bd = select_backend( &ndn, nosubordinates );
240 fprintf( stderr, "%s: line %d: "
241 "database #%d (%s) not configured to hold \"%s\"",
244 be->be_suffix[0].bv_val,
249 LDAP_STAILQ_FOREACH( bdtmp, &backendDB, be_next ) {
250 if ( bdtmp == bd ) break;
254 assert( bdtmp != NULL );
256 fprintf( stderr, "; did you mean to use database #%d (%s)?",
258 bd->be_suffix[0].bv_val );
261 fprintf( stderr, "; no database configured for that naming context" );
263 fprintf( stderr, "\n" );
265 SLAP_FREE( ndn.bv_val );
266 ldap_ldif_record_done( &lr );
267 if( continuemode ) continue;
272 id = be->be_dn2id_get( be, &ndn );
273 e = be->be_entry_get( be, id );
275 Entry *e_tmp = entry_dup( e );
276 /* FIXME: release? */
280 for ( n = 0; lr.lrop_mods[ n ] != NULL; n++ ) {
281 LDAPMod *mod = lr.lrop_mods[ n ];
282 Modification mods = { 0 };
284 int bin = (mod->mod_op & LDAP_MOD_BVALUES);
288 local_rc = slap_str2ad( mod->mod_type, &mods.sm_desc, &text );
289 if ( local_rc != LDAP_SUCCESS ) {
290 fprintf( stderr, "%s: slap_str2ad(\"%s\") failed for entry \"%s\" (%d: %s, lineno=%d)\n",
291 progname, mod->mod_type, lr.lr_dn.bv_val, local_rc, text, lineno );
294 if( continuemode ) continue;
295 SLAP_FREE( ndn.bv_val );
296 ldap_ldif_record_done( &lr );
301 mods.sm_type = mods.sm_desc->ad_cname;
303 if ( mods.sm_desc->ad_type->sat_syntax->ssyn_pretty ) {
307 assert( mods.sm_desc->ad_type->sat_syntax->ssyn_validate != NULL );
310 if ( mods.sm_desc->ad_type->sat_equality &&
311 mods.sm_desc->ad_type->sat_equality->smr_normalize )
316 if ( bin && mod->mod_bvalues ) {
317 for ( i = 0; mod->mod_bvalues[ i ] != NULL; i++ )
320 } else if ( !bin && mod->mod_values ) {
321 for ( i = 0; mod->mod_values[ i ] != NULL; i++ )
325 mods.sm_values = SLAP_CALLOC( sizeof( struct berval ), i + 1 );
327 mods.sm_nvalues = SLAP_CALLOC( sizeof( struct berval ), i + 1 );
329 mods.sm_nvalues = NULL;
333 for ( i = 0; i < mods.sm_numvals; i++ ) {
337 bv = *mod->mod_bvalues[ i ];
339 ber_str2bv( mod->mod_values[ i ], 0, 0, &bv );
343 local_rc = ordered_value_pretty( mods.sm_desc,
344 &bv, &mods.sm_values[i], NULL );
347 local_rc = ordered_value_validate( mods.sm_desc,
351 if ( local_rc != LDAP_SUCCESS ) {
352 fprintf( stderr, "%s: DN=\"%s\": unable to %s attr=%s value #%d\n",
353 progname, e->e_dn, pretty ? "prettify" : "validate",
354 mods.sm_desc->ad_cname.bv_val, i );
358 ber_bvarray_free( mods.sm_values );
359 ber_bvarray_free( mods.sm_nvalues );
360 if( continuemode ) continue;
361 SLAP_FREE( ndn.bv_val );
362 ldap_ldif_record_done( &lr );
368 ber_dupbv( &mods.sm_values[i], &bv );
372 local_rc = ordered_value_normalize(
373 SLAP_MR_VALUE_OF_ATTRIBUTE_SYNTAX,
375 mods.sm_desc->ad_type->sat_equality,
376 &mods.sm_values[i], &mods.sm_nvalues[i],
378 if ( local_rc != LDAP_SUCCESS ) {
379 fprintf( stderr, "%s: DN=\"%s\": unable to normalize attr=%s value #%d\n",
380 progname, e->e_dn, mods.sm_desc->ad_cname.bv_val, i );
384 ber_bvarray_free( mods.sm_values );
385 ber_bvarray_free( mods.sm_nvalues );
386 if( continuemode ) continue;
387 SLAP_FREE( ndn.bv_val );
388 ldap_ldif_record_done( &lr );
395 mods.sm_op = (mod->mod_op & ~LDAP_MOD_BVALUES);
398 if ( mods.sm_desc == slap_schema.si_ad_objectClass ) {
402 switch ( mods.sm_op ) {
404 local_rc = modify_add_values( e, &mods,
405 0, &text, textbuf, textlen );
408 case LDAP_MOD_DELETE:
409 local_rc = modify_delete_values( e, &mods,
410 0, &text, textbuf, textlen );
413 case LDAP_MOD_REPLACE:
414 local_rc = modify_replace_values( e, &mods,
415 0, &text, textbuf, textlen );
418 case LDAP_MOD_INCREMENT:
419 local_rc = modify_increment_values( e, &mods,
420 0, &text, textbuf, textlen );
424 if ( local_rc != LDAP_SUCCESS ) {
425 fprintf( stderr, "%s: DN=\"%s\": unable to modify attr=%s\n",
426 progname, e->e_dn, mods.sm_desc->ad_cname.bv_val );
428 ber_bvarray_free( mods.sm_values );
429 ber_bvarray_free( mods.sm_nvalues );
430 if( continuemode ) continue;
431 SLAP_FREE( ndn.bv_val );
432 ldap_ldif_record_done( &lr );
438 rc = slap_tool_entry_check( progname, op, e, lineno, &text, textbuf, textlen );
439 if ( rc != LDAP_SUCCESS ) {
441 SLAP_FREE( ndn.bv_val );
442 ldap_ldif_record_done( &lr );
443 if( continuemode ) continue;
448 if ( SLAP_LASTMOD(be) ) {
449 time_t now = slap_get_time();
450 char uuidbuf[ LDAP_LUTIL_UUIDSTR_BUFSIZE ];
451 struct berval vals[ 2 ];
453 struct berval name, timestamp;
455 struct berval nvals[ 2 ];
457 char timebuf[ LDAP_LUTIL_GENTIME_BUFSIZE ];
462 vals[1].bv_val = NULL;
465 nvals[1].bv_val = NULL;
467 csn.bv_len = ldap_pvt_csnstr( csnbuf, sizeof( csnbuf ), csnsid, 0 );
470 timestamp.bv_val = timebuf;
471 timestamp.bv_len = sizeof(timebuf);
473 slap_timestamp( &now, ×tamp );
475 if ( BER_BVISEMPTY( &be->be_rootndn ) ) {
476 BER_BVSTR( &name, SLAPD_ANONYMOUS );
479 name = be->be_rootdn;
480 nname = be->be_rootndn;
483 a = attr_find( e->e_attrs, slap_schema.si_ad_entryUUID );
485 vals[0].bv_len = lutil_uuidstr( uuidbuf, sizeof( uuidbuf ) );
486 vals[0].bv_val = uuidbuf;
487 if ( a->a_vals != a->a_nvals ) {
488 SLAP_FREE( a->a_nvals[0].bv_val );
489 SLAP_FREE( a->a_nvals );
491 SLAP_FREE( a->a_vals[0].bv_val );
492 SLAP_FREE( a->a_vals );
497 attr_merge_normalize_one( e, slap_schema.si_ad_entryUUID, vals, NULL );
499 a = attr_find( e->e_attrs, slap_schema.si_ad_creatorsName );
503 attr_merge( e, slap_schema.si_ad_creatorsName, vals, nvals );
506 ber_bvreplace( &a->a_vals[0], &name );
507 ber_bvreplace( &a->a_nvals[0], &nname );
510 a = attr_find( e->e_attrs, slap_schema.si_ad_createTimestamp );
513 attr_merge( e, slap_schema.si_ad_createTimestamp, vals, NULL );
516 ber_bvreplace( &a->a_vals[0], ×tamp );
519 a = attr_find( e->e_attrs, slap_schema.si_ad_entryCSN );
522 attr_merge( e, slap_schema.si_ad_entryCSN, vals, NULL );
525 ber_bvreplace( &a->a_vals[0], &csn );
528 a = attr_find( e->e_attrs, slap_schema.si_ad_modifiersName );
532 attr_merge( e, slap_schema.si_ad_modifiersName, vals, nvals );
535 ber_bvreplace( &a->a_vals[0], &name );
536 ber_bvreplace( &a->a_nvals[0], &nname );
539 a = attr_find( e->e_attrs, slap_schema.si_ad_modifyTimestamp );
542 attr_merge( e, slap_schema.si_ad_modifyTimestamp, vals, NULL );
545 ber_bvreplace( &a->a_vals[0], ×tamp );
549 if ( mod_err ) break;
551 /* check schema, objectClass etc */
554 switch ( lr.lr_op ) {
556 id = be->be_entry_put( be, e, &bvtext );
559 case LDAP_REQ_MODIFY:
560 id = be->be_entry_modify( be, e, &bvtext );
566 fprintf( stderr, "%s: could not %s entry dn=\"%s\" "
567 "(line=%d): %s\n", progname, request, e->e_dn,
568 lineno, bvtext.bv_val );
571 if( continuemode ) continue;
575 sid = slap_tool_update_ctxcsn_check( progname, e );
578 fprintf( stderr, "%s: \"%s\" (%08lx)\n",
579 request, e->e_dn, (long) id );
582 fprintf( stderr, "%s: \"%s\"\n",
593 bvtext.bv_len = textlen;
594 bvtext.bv_val = textbuf;
595 bvtext.bv_val[0] = '\0';
597 if ( enable_meter ) {
598 lutil_meter_update( &meter, ftell( ldiffp->fp ), 1);
599 lutil_meter_close( &meter );
602 if ( rc == EXIT_SUCCESS ) {
603 rc = slap_tool_update_ctxcsn( progname, sid, &bvtext );
609 if ( enable_meter ) {
610 fprintf( stderr, "Closing DB..." );
612 if( be->be_entry_close( be ) ) {
619 if ( enable_meter ) {
620 fprintf( stderr, "\n" );
624 if ( slap_tool_destroy())