@@ -546,13 +546,12 @@ public IndexRequest<?> documentIndexRequest(IndexQuery query, IndexCoordinates i
546
546
Object queryObject = query .getObject ();
547
547
548
548
if (queryObject != null ) {
549
- String id = StringUtils .hasText (query .getId ()) ? query .getId () : getPersistentEntityId (queryObject );
550
- builder //
551
- .id (id ) //
549
+ builder
550
+ .id (StringUtils .hasText (query .getId ()) ? query .getId () : getPersistentEntityId (queryObject ))
552
551
.document (elasticsearchConverter .mapObject (queryObject ));
553
552
} else if (query .getSource () != null ) {
554
- builder //
555
- .id (query .getId ()) //
553
+ builder
554
+ .id (query .getId ())
556
555
.document (new DefaultStringObjectMap <>().fromJson (query .getSource ()));
557
556
} else {
558
557
throw new InvalidDataAccessApiUsageException (
@@ -598,12 +597,13 @@ private IndexOperation<?> bulkIndexOperation(IndexQuery query, IndexCoordinates
598
597
Object queryObject = query .getObject ();
599
598
600
599
if (queryObject != null ) {
601
- String id = StringUtils .hasText (query .getId ()) ? query .getId () : getPersistentEntityId (queryObject );
602
- builder //
603
- .id (id ) //
600
+ builder
601
+ .id (StringUtils .hasText (query .getId ()) ? query .getId () : getPersistentEntityId (queryObject ))
604
602
.document (elasticsearchConverter .mapObject (queryObject ));
605
603
} else if (query .getSource () != null ) {
606
- builder .document (new DefaultStringObjectMap <>().fromJson (query .getSource ()));
604
+ builder
605
+ .id (query .getId ())
606
+ .document (new DefaultStringObjectMap <>().fromJson (query .getSource ()));
607
607
} else {
608
608
throw new InvalidDataAccessApiUsageException (
609
609
"object or source is null, failed to index the document [id: " + query .getId () + ']' );
@@ -639,12 +639,13 @@ private CreateOperation<?> bulkCreateOperation(IndexQuery query, IndexCoordinate
639
639
Object queryObject = query .getObject ();
640
640
641
641
if (queryObject != null ) {
642
- String id = StringUtils .hasText (query .getId ()) ? query .getId () : getPersistentEntityId (queryObject );
643
- builder //
644
- .id (id ) //
642
+ builder
643
+ .id (StringUtils .hasText (query .getId ()) ? query .getId () : getPersistentEntityId (queryObject ))
645
644
.document (elasticsearchConverter .mapObject (queryObject ));
646
645
} else if (query .getSource () != null ) {
647
- builder .document (new DefaultStringObjectMap <>().fromJson (query .getSource ()));
646
+ builder
647
+ .id (query .getId ())
648
+ .document (new DefaultStringObjectMap <>().fromJson (query .getSource ()));
648
649
} else {
649
650
throw new InvalidDataAccessApiUsageException (
650
651
"object or source is null, failed to index the document [id: " + query .getId () + ']' );
0 commit comments