#vulnerable code 
                                @Test
    public void testCompleteCompletes() {
        Database db = db(1);
        db //
                .update("update person set score=-3 where name='FRED'") //
                .complete() //
                .timeout(TIMEOUT_SECONDS, TimeUnit.SECONDS) //
                .blockingAwait();

        int score = db.select("select score from person where name='FRED'") //
                .getAs(Integer.class) //
                .timeout(TIMEOUT_SECONDS, TimeUnit.SECONDS) //
                .blockingFirst();
        assertEquals(-3, score);
    } 
                            #location 11 
                            #vulnerability type RESOURCE_LEAK
#fixed code
                                @Test
    public void testCompleteCompletes() {
        try (Database db = db(1)) {
            db //
                    .update("update person set score=-3 where name='FRED'") //
                    .complete() //
                    .timeout(TIMEOUT_SECONDS, TimeUnit.SECONDS) //
                    .blockingAwait();

            int score = db.select("select score from person where name='FRED'") //
                    .getAs(Integer.class) //
                    .timeout(TIMEOUT_SECONDS, TimeUnit.SECONDS) //
                    .blockingFirst();
            assertEquals(-3, score);
        }
    }