public boolean flushRows() throws DataAccessException
	{
		if(deleteQuery!=null)
		{
			log.info("Rows deleted for table "+tableName+": "+rowsEffected);
		}
		try
		{
			if (insertStmt != null)
			{
				if (rowsToInsert > 0)
				{
					insertStmt.executeBatch();
					log.fine(rowsToInsert + " number of rows inserted in previous table\n");
					rowsToInsert = 0;
				}
				insertStmt.close();
			}
		}
		catch (SQLException e)
		{
			try
			{
				if (beginning != null)
					con.rollback(beginning);
				else
					con.rollback();
			}
			catch (SQLException e1)
			{
				throw new DataAccessException(ErrorCode.ERR_ROLLBACK_CONNECTION, e, log);
			}
			throw new DataAccessException(ErrorCode.ERR_EXECUTE_QUERY, e, log);
		}
		if(containsAutoIncrementColumn == true)
		{
			setIdentityInsert(con, tableName, false);
		}
		return true;
	}