@Override
    public NativeQuerySpec<Record> select(String sql, Object... args) {
        return new NativeQuerySpecImpl<>(this, sql, args, DefaultRecord::new, false);
    }
@Test
    public void testLoadTable() {
        database
            .sql()
            .reactive()
            .execute(SqlRequests.of("create table \"NATIVE_TEST\"( " +
                                        "\"id\" varchar(32) primary key" +
                                        ",name varchar(32)" +
                                        ",\"testName\" varchar(32)" +
                                        ")"))
            .as(StepVerifier::create)
            .expectComplete()
            .verify();

        DefaultQueryHelper helper = new DefaultQueryHelper(database);

        database
            .dml()
            .insert("native_test")
            .value("id", "test")
            .value("NAME", "test")
            .value("testName", "test")
            .execute()
            .sync();

        helper.select("select id,name,testName from native_test")
              .fetch()
              .doOnNext(System.out::println)
              .as(StepVerifier::create)
              .expectNextCount(1)
              .verifyComplete();
    }