Jena TDB CRUD 사용

Jena TDB CRUD 사용

 

 

 

Maven Dependency 추가

<dependency>
  		<groupId>org.apache.jena</groupId>
  		<artifactId>jena-fuseki</artifactId>
  		<version>1.1.1</version>
  	</dependency>
  	<dependency>
  		<groupId>org.apache.jena</groupId>
  		<artifactId>apache-jena-libs</artifactId>
  		<type>pom</type>
  		<version>2.13.0</version>
  	</dependency>

 

Jena용 라이브러리를 pom.xml에 추가해준다.

 

 

 

 

TDB Controller 클래스 생성

public class TDBControll {
	private Dataset ds;

	// TDB용 데이터셋을 생성한다.
	public void TDBConnection(String path) {
		ds = TDBFactory.createDataset(path);
	}

	// TDB에서 온톨로지 또는 모델을 읽어온다.
	public void loadModel(String modelName, String path) {
		Model model = null;
		ds.begin(ReadWrite.WRITE);
		try {
			model = ds.getNamedModel(modelName);
			FileManager.get().readModel(model, path);
			ds.commit();
		} finally {
			ds.end();
		}
	}

	// TDB Store에 triple을 추가한다.
	public void addStatement(String modelName, String subject, String property, String object) {
		Model model = null;

		ds.begin(ReadWrite.WRITE);
		try {
			model = ds.getNamedModel(modelName);
			Statement stmt = model.createStatement(model.createResource(subject), model.createProperty(property),
					model.createResource(object));
			model.add(stmt);
			ds.commit();
		} catch (Exception e) {
			// TODO: handle exception
		} finally {
			if (model != null)
				model.close();
			ds.end();
		}
	}

	// TDB Store에서 triple을 읽어온다.
	public List<Statement> getStatements(String modelName, String subject, String property, String object) {
		List<Statement> results = new ArrayList<Statement>();
		Model model = null;

		ds.begin(ReadWrite.READ);
		try {
			model = ds.getNamedModel(modelName);

			Selector selector = new SimpleSelector((subject != null) ? model.createResource(subject) : (Resource) null,
					(property != null) ? model.createProperty(property) : (Property) null,
					(object != null) ? model.createResource(object) : (RDFNode) null);

			StmtIterator it = model.listStatements(selector);
			{
				while (it.hasNext()) {
					Statement stmt = it.next();
					results.add(stmt);
				}
			}
			ds.commit();
		} finally {
			// TODO: handle finally clause
			if (model != null)
				model.close();
			ds.end();
		}
		return results;
	}
	// TDB Store에서 triple을 삭제한다. 
	public void removeStatement(String modelName, String subject, String property, String object) {
		Model model = null;

		ds.begin(ReadWrite.WRITE);
		try {
			model = ds.getNamedModel(modelName);

			Statement stmt = model.createStatement(model.createResource(subject), model.createProperty(property),
					model.createResource(object));

			model.remove(stmt);
			ds.commit();
		} finally {
			if (model != null)
				model.close();
			ds.end();
		}
	}

	public void close() {
		ds.close();
	}
}

 

 

 

 

Main에서의 Controller 사용

public class Main {
	public static void main(String[] args) {
		// TODO Auto-generated method stub
		TDBControll tdb = null;

		String URI = "https://tutorial-academy.com/2015/tdb#";

		String namedModel1 = "Model_German_Cars";
		String namedModel2 = "Model_US_Cars";

		String john = URI + "John";
		String mike = URI + "Mike";
		String bill = URI + "Bill";
		String owns = URI + "owns";

		tdb = new TDBControll();
		tdb.TDBConnection("tdb");
		
		// named Model 1
		tdb.addStatement(namedModel1, john, owns, URI + "Porsche");
		tdb.addStatement(namedModel1, john, owns, URI + "BMW");
		tdb.addStatement(namedModel1, mike, owns, URI + "BMW");
		tdb.addStatement(namedModel1, bill, owns, URI + "Audi");
		tdb.addStatement(namedModel1, bill, owns, URI + "BMW");

		// named Model 2
		tdb.addStatement(namedModel2, john, owns, URI + "Chrysler");
		tdb.addStatement(namedModel2, john, owns, URI + "Ford");
		tdb.addStatement(namedModel2, bill, owns, URI + "Chevrolet");

		// null = wildcard search. Matches everything with BMW as object!
		List<Statement> result = tdb.getStatements(namedModel1, null, null, URI + "BMW");
		System.out.println(namedModel1 + " size: " + result.size() + "\n\t" + result);

		// null = wildcard search. Matches everything with john as subject!
		result = tdb.getStatements(namedModel2, john, null, null);
		System.out.println(namedModel2 + " size: " + result.size() + "\n\t" + result);

		// remove all statements from namedModel1
		tdb.removeStatement(namedModel1, john, owns, URI + "Porsche");
		tdb.removeStatement(namedModel1, john, owns, URI + "BMW");
		tdb.removeStatement(namedModel1, mike, owns, URI + "BMW");
		tdb.removeStatement(namedModel1, bill, owns, URI + "Audi");
		tdb.removeStatement(namedModel1, bill, owns, URI + "BMW");

		result = tdb.getStatements(namedModel1, john, null, null);
		System.out.println(namedModel1 + " size: " + result.size() + "\n\t" + result);
		tdb.close();
	}

}

 

 

출력 결과

Model_German_Cars size: 3
	[[https://tutorial-academy.com/2015/tdb#John, https://tutorial-academy.com/2015/tdb#owns, https://tutorial-academy.com/2015/tdb#BMW], [https://tutorial-academy.com/2015/tdb#Mike, https://tutorial-academy.com/2015/tdb#owns, https://tutorial-academy.com/2015/tdb#BMW], [https://tutorial-academy.com/2015/tdb#Bill, https://tutorial-academy.com/2015/tdb#owns, https://tutorial-academy.com/2015/tdb#BMW]]
Model_US_Cars size: 2
	[[https://tutorial-academy.com/2015/tdb#John, https://tutorial-academy.com/2015/tdb#owns, https://tutorial-academy.com/2015/tdb#Chrysler], [https://tutorial-academy.com/2015/tdb#John, https://tutorial-academy.com/2015/tdb#owns, https://tutorial-academy.com/2015/tdb#Ford]]
Model_German_Cars size: 0
	[]