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();
			}
			if (dbType != null && dbType.equalsIgnoreCase(Database.DB_TYPE_MSSQL))
			{
				Statement identityStmt = null;
				try
				{
					ConnectionManager.commitConnection(con);
					identityStmt = con.createStatement();
					identityStmt.execute("SET IDENTITY_INSERT " + tableName + " OFF");
					log.fine(tableName + " identity insert set OFF");
				}
				catch (SQLException e)
				{
					log.fine(tableName + " does not have identity On");
				}
				finally
				{
					ConnectionManager.cleanUp(null, identityStmt, null);
				}
			}
		}
		catch (SQLException e)
		{
			try
			{
				if (beginning != null)
					con.rollback(beginning);
			}
			catch (SQLException e1)
			{
				throw new DataAccessException(ErrorCode.ERR_ROLLBACK_CONNECTION, e, log);
			}
			throw new DataAccessException(ErrorCode.ERR_EXECUTE_QUERY, e, log);
		}
		return true;
	}