localrepositorytest.java

这是外国一个开源推理机

/*
 * Sesame - Storage and Querying architecture for RDF and RDF Schema Copyright
 * (C) 2001-2005 Aduna
 * 
 * Contact: Aduna Prinses Julianaplein 14 b 3817 CS Amersfoort The Netherlands
 * tel. [phone] fax. [phone]
 * 
 * http://aduna.biz/ http://www.openrdf.org/
 * 
 * This library is free software; you can redistribute it and/or modify it under
 * the terms of the GNU Lesser General Public License as published by the Free
 * Software Foundation; either version 2.1 of the License, or (at your option)
 * any later version.
 * 
 * This library is distributed in the hope that it will be useful, but WITHOUT
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS
 * FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public License for more
 * details.
 * 
 * You should have received a copy of the GNU Lesser General Public License
 * along with this library; if not, write to the Free Software Foundation, Inc.,
 * 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
 */

package org.openrdf.sesame.repository.local;

import org.openrdf.sesame.Sesame;
import org.openrdf.sesame.repository.RepositoryTest;
import org.openrdf.sesame.repository.SesameRepository;

public class LocalRepositoryTest extends RepositoryTest implements
		LocalRepositoryChangedListener
{

	private int _addedEvents;
	private int _removedEvents;
	
	/*-------------+
	 | Constructors |
	 +-------------*/

	/**
	 * Creates a new HTTP repository test.
	 */
	public LocalRepositoryTest() {
		super("LocalRepositoryTest");
	}

	/*--------+
	 | Methods |
	 +--------*/

	// implements RepositoryTest.createRepository()
	protected SesameRepository _createRepository() {
		try {
			/*
			 RepositoryConfig config = new RepositoryConfig("myRep");

			 //SailConfig rdbmsSail = new RdfSchemaRepositoryConfig(
			 //"com.mysql.jdbc.Driver", "jdbc:mysql://localhost:3306/testdb", "sesame", "");
			 //config.addSail(rdbmsSail);

			 SailConfig memSail = new RdfSchemaRepositoryConfig("/tmp/mem-rdf.rdf");
			 config.addSail(memSail);
			 
			 config.setWorldReadable(true);
			 config.setWorldWriteable(true);
			 */

			LocalService service = Sesame.getService();
			LocalRepository repository = service.createRepository("myRep", true);
			repository.addListener(this);
			return repository;
		}
		catch (Exception e) {
			fail("[" + e.getClass() + "]: " + e.getMessage());
			throw new RuntimeException(e);
		}
	}

	public void repositoryChanged(LocalRepositoryChangedEvent event) {
		if (event.statementsAdded()) {
			_addedEvents++;
		}
		if (event.statementsRemoved()) {
			_removedEvents++;
		}

	}
	
	public void testAddData_URL() {
		super.testAddData_URL();
		
		// each test does a clear operation so a single remove event is detected.
		assertEquals("expected single remove event ", 1, _removedEvents);
		assertEquals("expected single add event ", 1, _addedEvents);
	}
	
	public void testAddData_File() {
		super.testAddData_File();
		
		// each test does a clear operation so a single remove event is detected.
		assertEquals("expected single remove event ", 1, _removedEvents);
		assertEquals("expected single add event ", 1, _addedEvents);
	}	
	
	public void testRemoveBNodes() {
		super.testRemoveBNodes();
		assertEquals("expected 44 remove events", 44, _removedEvents);
		assertEquals("expected single add event ", 1, _addedEvents);
	}
	
	public void testAddGraphQuery() {
		super.testAddGraphQuery();
		assertEquals("expected single remove event", 1, _removedEvents);
		assertEquals("expected single add event ", 2, _addedEvents);
	}
	
	public void testRemoveGraphQuery() {
		super.testRemoveGraphQuery();
		assertEquals("expected two remove events", 2, _removedEvents);
		assertEquals("expected single add event ", 1, _addedEvents);
	}
	
	public void testRemoveStatements() {
		super.testRemoveStatements();
		assertEquals("expected two remove events", 2, _removedEvents);
		assertEquals("expected single add event ", 1, _addedEvents);
	}
	
	public void testRemoveGraph() {
		super.testRemoveGraph();
		assertEquals("expected two remove events", 2, _removedEvents);
		assertEquals("expected single add event ", 1, _addedEvents);
	}
	
	public void testAddGraph() {
		super.testAddGraph();
		assertEquals("expected single remove event", 1, _removedEvents);
		assertEquals("expected single add event ", 2, _addedEvents);
	}
}