Как получить запись из aerospike, используя список в java?

Мои данные в test.setName выглядят так

| id    | cities              | lob        |
|-------|---------------------|------------|
| id123 | ["Cthdcn","Ctdel"]  | ["Lob132"] |
| id345 | ["Ctijs","Ctdelhi"] | ["LOB231"] |
| id765 | ["Cthui"]           | ["Lob875"] |

"Города" уже представлены как LIST INDEX, и вы хотите получить конкретная запись, указав массив городов, например (["Ctijs","Ctdelhi"]) через java-клиент.

Я хочу получить (получить) записи, указав массив городов, используя Джава. Я использую следующий метод

    public Record testGet(String namespace, String set, String city, List<String> binNames) {
    Statement statement = new Statement();
    statement.setNamespace(namespace);
    statement.setSetName(set);
    Filter filter = Filter.contains("cities", IndexCollectionType.LIST, city);
    statement.setFilter(filter);
    RecordSet records = this.client.query((QueryPolicy)null, statement);
    return records.getRecord();
}

Я получаю ноль. Как я могу получить эту конкретную запись? (AQL-версия 3.23.0)

В приведенном выше коде, что вы передали для String city в testGet()?

pgupta 16.12.2020 19:19

@pgupta я передал "Cthui" как String city

Vrishank Gupta 16.12.2020 19:20

выберите lob из test.setName в LIST, где города = "Cthui", этот запрос отлично работает в aql

Vrishank Gupta 16.12.2020 19:20
Пользовательский скаляр GraphQL
Пользовательский скаляр GraphQL
Листовые узлы системы типов GraphQL называются скалярами. Достигнув скалярного типа, невозможно спуститься дальше по иерархии типов. Скалярный тип...
Как вычислять биты и понимать побитовые операторы в Java - объяснение с примерами
Как вычислять биты и понимать побитовые операторы в Java - объяснение с примерами
В компьютерном программировании биты играют важнейшую роль в представлении и манипулировании данными на двоичном уровне. Побитовые операции...
Поднятие тревоги для долго выполняющихся методов в Spring Boot
Поднятие тревоги для долго выполняющихся методов в Spring Boot
Приходилось ли вам сталкиваться с требованиями, в которых вас могли попросить поднять тревогу или выдать ошибку, когда метод Java занимает больше...
Полный курс Java для разработчиков веб-сайтов и приложений
Полный курс Java для разработчиков веб-сайтов и приложений
Получите сертификат Java Web и Application Developer, используя наш курс.
3
3
630
1
Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

Вот небольшой скрипт на AQL в текстовом файле list.aql для воспроизведения вашего теста:

список.aql:

TRUNCATE test
DROP INDEX test.setName idx_city
SELECT * FROM test
CREATE LIST INDEX idx_city ON test.setName (cities) STRING

INSERT INTO test.setName (PK, id, cities, lob) VALUES ('key1', 'id123', LIST('["Cthdcn", "Ctdel"]'), LIST('["Lob132
"]'))
INSERT INTO test.setName (PK, id, cities, lob) VALUES ('key2', 'id345', LIST('["Ctijs", "Ctdelhi"]'), LIST('["LOB23
1"]'))
INSERT INTO test.setName (PK, id, cities, lob) VALUES ('key3', 'id765', LIST('["Cthui"]'), LIST('["Lob875"]'))

select * from test.setName

select * from test.setName in LIST where cities = 'Cthdcn'

Вывод в aql:

aql> run 'list.aql'
TRUNCATE test
OK

DROP INDEX test.setName idx_city
Error: (201)  Index does not exist on the system.

SELECT * FROM test
0 rows in set (0.156 secs)

OK

CREATE LIST INDEX idx_city ON test.setName (cities) STRING
OK, 1 index added.

INSERT INTO test.setName (PK, id, cities, lob) VALUES ('key1', 'id123', LIST('["Cthdcn", "Ctdel"]'), LIST('["Lob132"]'))
OK, 1 record affected.

INSERT INTO test.setName (PK, id, cities, lob) VALUES ('key2', 'id345', LIST('["Ctijs", "Ctdelhi"]'), LIST('["LOB231"]'))
OK, 1 record affected.

INSERT INTO test.setName (PK, id, cities, lob) VALUES ('key3', 'id765', LIST('["Cthui"]'), LIST('["Lob875"]'))
OK, 1 record affected.

select * from test.setName
+---------+------------------------------+--------------------+
| id      | cities                       | lob                |
+---------+------------------------------+--------------------+
| "id123" | LIST('["Cthdcn", "Ctdel"]')  | LIST('["Lob132"]') |
| "id765" | LIST('["Cthui"]')            | LIST('["Lob875"]') |
| "id345" | LIST('["Ctijs", "Ctdelhi"]') | LIST('["LOB231"]') |
+---------+------------------------------+--------------------+
3 rows in set (0.124 secs)

OK

select * from test.setName in LIST where cities = 'Cthdcn'
+---------+-----------------------------+--------------------+
| id      | cities                      | lob                |
+---------+-----------------------------+--------------------+
| "id123" | LIST('["Cthdcn", "Ctdel"]') | LIST('["Lob132"]') |
+---------+-----------------------------+--------------------+
1 row in set (0.001 secs)

OK

aql>

В Java вам придется перебирать набор записей, чтобы получить каждую запись, удовлетворяющую запросу.

RecordSet records = client.query( .....)
while (records.next()){
  Record r = records.getRecord();
  ....
}
records.close()

Я только что протестировал следующий код:

public void read () {
                Record record = null;
                Statement stmt = new Statement();
                stmt.setSetName("setName");
                stmt.setNamespace("test");
                stmt.setIndexName("idx_city");
                stmt.setFilter(Filter.contains("cities", IndexCollectionType.LIST, "Cthui"));

                RecordSet recordSet = this.client.query(queryPolicy, stmt);
            while (recordSet.next()) {
                record = recordSet.getRecord();
                System.out.println(record.toString());
            }

         }

и это сработало для меня.

$ java -jar ./target/dm-predicateFilter-1.0-full.jar
(gen:1),(exp:348432597),(bins:(id:id765),(cities:[Cthui]),(lob:[Lob875]))

Другие вопросы по теме

Получить имя по идентификатору
Как избежать ошибки в методе MYSQL CONVERT() при передаче 0-секундной строки и вычитании из этого значения?
Я не могу автоматически добавить идентификатор пользователя к его созданию - Symfony 5
Сбой при создании триггера Ошибка SQL [1054] [42S22]: Неизвестный столбец «оценка» в «списке полей»
Как вставить контрольное ограничение для номера телефона в mysql?
Отбросить двойные кавычки, найденные в данных в базе данных, совместимой с Presto SQL (AWS Athena)?
Средство Oracle Instant Client SQL*Loader не запускается из-за отсутствия файла libomsodm.so
Получить все документы, свойство которых равно одному из элементов массива
Дубликат идентификатора таблицы Postgres, когда существует уникальное ограничение первичного ключа
ОШИБКА 1452: Невозможно добавить или обновить дочернюю строку: ограничение внешнего ключа не работает. Кто-нибудь может помочь