@ Override public synchronized void flush ( ) throws DatabaseEngineException { /* * Reconnect on this method does not make sense since a new connection will have nothing to flush. */ try { for ( MappedEntity me : entities . values ( ) ) { me . getInsert ( ) . executeBatch ( ) ; } } catch ( final Exception ex ) { throw new DatabaseEngineException ( "Something went wrong while flushing" , ex ) ; } }
Flushes the batches for all the registered entities .