Scanning by nested properties seems to not work

[sasagonz]

Hi.

If I run this by command line I get results:

aws dynamodb scan --table-name Person --filter-expression "address.countryCode = :value" --expression-attribute-values '{":value":{"S":"ES"}}' --endpoint-url http://localhost:8000

See that I'm searching by person.address.countryCode.

Ok, I have Person configured with @DynamoDBTable and the address attribute with @DynamoDBDocument. Then, in PersonRepository, I have:

@EnableScan List<Person> findByAddressCountryCode( @Param("addressCountryCode") String addressCountryCode);

But when I execute the method in JUnit, it doesn't return anything. Debugging, I see that in DynamoDBScanExpression, only scanFilter attribute is used, and not expressionAttributeNames and expressionAttributeValues, like by command line. The thing is that I cannot see which request is sent to my local dynamodb server. Maybe it is sending the key/value [countryCode / ES] instead of [address.countryCode / ES]. I'm suspecting that because I see (debugging) that in ScanRequestMarshaller, tableName is set to Person and scanFilterMap contains the field countryCode, which doesn't correspond to Person but to Person.Address

Could anyone tell me if it is an already known problem or what I'm doing wrong?

NOTE: other JUnit methods that test other repository methods over Person works without problem. But always over basic attributes like Number or String.

Regards.

[derjust]

Thanks for the detailed report.

I’m quite sure it’s not implemented at all. But for sure worth to add it.
Would you mind putting your Person/Address entities here?

[sasagonz]

Thanks for your quick response. Please see below the code:

public class PersonId implements Serializable {

    private static final long serialVersionUID = 1L;

    private String name;
    private String area;

    @DynamoDBRangeKey
    public String getArea() {
      return area;
    }

    @DynamoDBHashKey
    public String getName() {
      return name;
    }

    public PersonId() {}

    public PersonId(String name, String area) {
      this.name = name;
      this.area = area;
    }
    public void setName(String name) {
      this.name = name;
    }
    public void setArea(String area) {
      this.area = area;
    }
}

@DynamoDBTable(tableName = "Person")
public class Person {

    @Id
    private PersonId personId;

    private String phone;
    private Address address;

    @DynamoDBHashKey
    public String getName() {
        return personId != null ? personId.getName() : null;
    }

    @DynamoDBRangeKey
    public String getArea() {
        return personId != null ? personId.getArea() : null;
    }
    public Address getAddress() {
        return address;
    }
    public String getPhone() {
        return phone;
    }
    public void setPhone(String phone) {
        this.phone = phone;
    }
    public void setName(String name) {
        if (personId == null) {
            personId = new PersonId();
        }
        this.personId.setName(name);
    }
    public void setArea(String area) {
        if (personId == null) {
            personId = new PersonId();
        }
        this.personId.setArea(area);
    }
    public void setAddress(Address address) {
        this.address = address;
    }
}

@DynamoDBDocument
public class Address {
    private String city;
    private String country;

    public String getCity() {
        return city;
    }
    public void setCity(String city) {
        this.city = city;
    }
    public String getCountry() {
        return country;
    }
    public void setCountry(String country) {
        this.country = country;
    }
}

public interface PersonRepository extends PagingAndSortingRepository<Person, PersonId> {

    Person findByNameAndArea(@Param("name") String name, @Param("name") String area);
    
    @EnableScan
    List<Person> findByArea(@Param("name") String area);
    
    @EnableScan
    List<Person> findByPhone(@Param("phone") String phone);
    
    @EnableScan
    List<Person> findByAddressCountry(@Param("country") String country);
}

[parxier]

Would love to use this feature. When is 5.0.3 planned to release? Also is there any workaround apart from writing completely custom repository method implementation? https://github.com/derjust/spring-data-dynamodb/wiki/Custom-repository-implementations
Thank you!

[derjust]

@parxier There is no fixed time frame for 5.0.3.
Custom repositories are your only way for the time being.

[parxier]

@derjust Thank you. Is 5.0.3-SNAPSHOT available somewhere centrally to try?

[derjust]

SNAPSHOT builds are available via the OSSRH snapshot repository