|
|
|
@ -370,8 +370,8 @@ public class MongoTemplateUnitTests extends MongoOperationsUnitTests { |
|
|
|
@Test |
|
|
|
@Test |
|
|
|
public void aggregateShouldHonorReadPreferenceWhenSet() { |
|
|
|
public void aggregateShouldHonorReadPreferenceWhenSet() { |
|
|
|
|
|
|
|
|
|
|
|
when(db.command(Mockito.any(DBObject.class), Mockito.any(ReadPreference.class))).thenReturn( |
|
|
|
when(db.command(Mockito.any(DBObject.class), Mockito.any(ReadPreference.class))) |
|
|
|
mock(CommandResult.class)); |
|
|
|
.thenReturn(mock(CommandResult.class)); |
|
|
|
when(db.command(Mockito.any(DBObject.class))).thenReturn(mock(CommandResult.class)); |
|
|
|
when(db.command(Mockito.any(DBObject.class))).thenReturn(mock(CommandResult.class)); |
|
|
|
template.setReadPreference(ReadPreference.secondary()); |
|
|
|
template.setReadPreference(ReadPreference.secondary()); |
|
|
|
|
|
|
|
|
|
|
|
@ -386,8 +386,8 @@ public class MongoTemplateUnitTests extends MongoOperationsUnitTests { |
|
|
|
@Test |
|
|
|
@Test |
|
|
|
public void aggregateShouldIgnoreReadPreferenceWhenNotSet() { |
|
|
|
public void aggregateShouldIgnoreReadPreferenceWhenNotSet() { |
|
|
|
|
|
|
|
|
|
|
|
when(db.command(Mockito.any(DBObject.class), Mockito.any(ReadPreference.class))).thenReturn( |
|
|
|
when(db.command(Mockito.any(DBObject.class), Mockito.any(ReadPreference.class))) |
|
|
|
mock(CommandResult.class)); |
|
|
|
.thenReturn(mock(CommandResult.class)); |
|
|
|
when(db.command(Mockito.any(DBObject.class))).thenReturn(mock(CommandResult.class)); |
|
|
|
when(db.command(Mockito.any(DBObject.class))).thenReturn(mock(CommandResult.class)); |
|
|
|
|
|
|
|
|
|
|
|
template.aggregate(Aggregation.newAggregation(Aggregation.unwind("foo")), "collection-1", Wrapper.class); |
|
|
|
template.aggregate(Aggregation.newAggregation(Aggregation.unwind("foo")), "collection-1", Wrapper.class); |
|
|
|
@ -401,8 +401,8 @@ public class MongoTemplateUnitTests extends MongoOperationsUnitTests { |
|
|
|
@Test |
|
|
|
@Test |
|
|
|
public void geoNearShouldHonorReadPreferenceWhenSet() { |
|
|
|
public void geoNearShouldHonorReadPreferenceWhenSet() { |
|
|
|
|
|
|
|
|
|
|
|
when(db.command(Mockito.any(DBObject.class), Mockito.any(ReadPreference.class))).thenReturn( |
|
|
|
when(db.command(Mockito.any(DBObject.class), Mockito.any(ReadPreference.class))) |
|
|
|
mock(CommandResult.class)); |
|
|
|
.thenReturn(mock(CommandResult.class)); |
|
|
|
when(db.command(Mockito.any(DBObject.class))).thenReturn(mock(CommandResult.class)); |
|
|
|
when(db.command(Mockito.any(DBObject.class))).thenReturn(mock(CommandResult.class)); |
|
|
|
template.setReadPreference(ReadPreference.secondary()); |
|
|
|
template.setReadPreference(ReadPreference.secondary()); |
|
|
|
|
|
|
|
|
|
|
|
@ -418,8 +418,8 @@ public class MongoTemplateUnitTests extends MongoOperationsUnitTests { |
|
|
|
@Test |
|
|
|
@Test |
|
|
|
public void geoNearShouldIgnoreReadPreferenceWhenNotSet() { |
|
|
|
public void geoNearShouldIgnoreReadPreferenceWhenNotSet() { |
|
|
|
|
|
|
|
|
|
|
|
when(db.command(Mockito.any(DBObject.class), Mockito.any(ReadPreference.class))).thenReturn( |
|
|
|
when(db.command(Mockito.any(DBObject.class), Mockito.any(ReadPreference.class))) |
|
|
|
mock(CommandResult.class)); |
|
|
|
.thenReturn(mock(CommandResult.class)); |
|
|
|
when(db.command(Mockito.any(DBObject.class))).thenReturn(mock(CommandResult.class)); |
|
|
|
when(db.command(Mockito.any(DBObject.class))).thenReturn(mock(CommandResult.class)); |
|
|
|
|
|
|
|
|
|
|
|
NearQuery query = NearQuery.near(new Point(1, 1)); |
|
|
|
NearQuery query = NearQuery.near(new Point(1, 1)); |
|
|
|
|