r2dbc SQL command execution.java

@SpringBootApplication
public class ReactivespringApplication implements CommandLineRunner {

    @Autowired
    private DatabaseClient databaseClient;
    @Autowired
    private ReservationRepository reservationRepository;

    public static void main(String[] args) {
        SpringApplication.run(ReactivespringApplication.class, args);
    }

    @Override
    public void run(String... args) throws Exception {
        Arrays.asList("DROP TABLE IF EXISTS reservation;",
                "CREATE TABLE reservation (room_id serial primary key, name varchar, check_in timestamp, check_out timestamp, price bigint, room_number integer);")
                .forEach(s ->
                        databaseClient.execute(s)
                                .fetch()
                                .rowsUpdated()
                                .block()
                );
    }
}