Merge pull request #21 from ydb-platform/fix-3.1-lesson

Author: KirillKurdyukov

dev-1/lesson-3.1/java/src/main/java/tech/ydb/app/Application.java

@@ -30,13 +30,15 @@ public static void main(String[] args) {
                 schemaYdbRepository.dropSchema();
                 schemaYdbRepository.createSchema();
 
-                issueYdbRepository.addIssue("Ticket 1");
+                var firstIssue = issueYdbRepository.addIssue("Ticket 1");
                 issueYdbRepository.addIssue("Ticket 2");
                 issueYdbRepository.addIssue("Ticket 3");
 
                 for (var issue : issueYdbRepository.findAll()) {
                     LOGGER.info("Issue: {}", issue);
                 }
+
+                LOGGER.info("First issue: {}", issueYdbRepository.findById(firstIssue.id()));
             }
         }
     }

dev-1/lesson-3.1/java/src/main/java/tech/ydb/app/IssueYdbRepository.java

@@ -10,6 +10,8 @@
 import tech.ydb.table.query.Params;
 import tech.ydb.table.values.PrimitiveValue;
 
+import javax.annotation.Nullable;
+
 /**
  * Репозиторий для работы с тикетами в базе данных YDB
  * Реализует операции добавления и чтения тикетов
@@ -61,6 +63,29 @@ UPSERT INTO issues (id, title, created_at)
         return new Issue(id, title, now);
     }
 
+    /**
+     * Возвращает тикет по заданному id
+     *
+     * @return найденный тикет или null, если тикет с указанным id не найден
+     */
+    @Nullable
+    public Issue findById(long id) {
+        // Выполняем SELECT запрос в режиме SNAPSHOT_RO для чтения данных
+        // Этот режим сообщает серверу, что это транзакция только для чтения.
+        // Это позволяет снизить накладные расходы на подготовку к изменениям и просто читать данные из
+        // одного снимка базы данных.
+        var resultSet = queryServiceHelper.executeQuery("SELECT id, title, created_at FROM issues WHERE id=$id;",
+                TxMode.SNAPSHOT_RO, Params.of("$id", PrimitiveValue.newInt64(id)));
+
+        var resultSetReader = resultSet.getResultSet(0);
+
+        return resultSetReader.next() ? new Issue(
+                resultSetReader.getColumn(0).getInt64(),
+                resultSetReader.getColumn(1).getText(),
+                resultSetReader.getColumn(2).getTimestamp()
+        ) : null;
+    }
+
     /**
      * Получает все тикеты из базы данных
      *