Как подключиться к postgres и выполнить запрос с помощью r2dbc - PullRequest
Новая
       67

Как подключиться к postgres и выполнить запрос с помощью r2dbc

0 голосов
/ 18 июня 2020

Я пытаюсь написать простую функцию, которая будет подключаться к postgres и выполнять оператор выбора. 

PostgresqlConnectionFactory connectionFactory = new PostgresqlConnectionFactory(
        PostgresqlConnectionConfiguration.builder()
            .host("localhost")
            .port(5432)
            .database("MyDB")
            .username("username")
            .password("password").build());



DatabaseClient client = DatabaseClient.create(connectionFactory);

Flux<Map<String, Object>> result = client.execute("select * from table").fetch().all();

result.map(s -> {
  System.out.println(s);
  return null;
});

Приведенный выше фрагмент кода ничего не печатает. Ошибки тоже нет. Я могу подключиться к БД, используя те же учетные данные. Чего не хватает в коде для потоковой передачи данных из БД?

1 Ответ

0 голосов
/ 19 июля 2020

Создайте класс конфигурации, аналогичный приведенному ниже коду, для подключения к базе данных PostgreSQL 

@Configuration
@EnableR2dbcRepositories
public class DatabaseConfig extends AbstractR2dbcConfiguration {

    @Override
    public ConnectionFactory connectionFactory() {
        return ConnectionFactories.get("r2dbc:postgresql://localhost:5432/DATABASE_NAME");
    }

}
...