<BUG>stmt = connection.createStatement();try {</BUG><CONTEXT>}} finally {stmt.close();}for (String tableName : new String[] {OUTBOUND_MSGS_TABLE_NAME, INBOUND_MSGS_TABLE_NAME}) {<extra_id_0>stmt.executeUpdate(MessageFormat.format(CREATE_MESSAGES_TABLE_STMT, tableName));} catch (SQLException ex) {if (!isTableExistsError(ex)) {</CONTEXT>
stmt = con.createStatement();try {stmt.executeUpdate(CREATE_DEST_SEQUENCES_TABLE_STMT);