#vulnerable code 
                                @Test
    public void testInsertNullClobAndReadClobAsTuple2() {
        Database db = db();
        insertNullClob(db);
        db.select("select document, document from person_clob where name='FRED'") //
                .getAs(String.class, String.class) //
                .test().awaitDone(TIMEOUT_SECONDS, TimeUnit.SECONDS) //
                .assertValue(Tuple2.create(null, null)) //
                .assertComplete();
    } 
                            #location 6 
                            #vulnerability type RESOURCE_LEAK
#fixed code
                                @Test
    public void testInsertNullClobAndReadClobAsTuple2() {
        try (Database db = db()) {
            insertNullClob(db);
            db.select("select document, document from person_clob where name='FRED'") //
                    .getAs(String.class, String.class) //
                    .test().awaitDone(TIMEOUT_SECONDS, TimeUnit.SECONDS) //
                    .assertValue(Tuple2.create(null, null)) //
                    .assertComplete();
        }
    }