代码如下:
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.InputStreamReader;
import java.io.UnsupportedEncodingException;
import com.hp.hpl.jena.db.DBConnection;
import com.hp.hpl.jena.db.IDBConnection;
import com.hp.hpl.jena.ontology.OntModel;
import com.hp.hpl.jena.ontology.OntModelSpec;
import com.hp.hpl.jena.rdf.model.Model;
import com.hp.hpl.jena.rdf.model.ModelFactory;
import com.hp.hpl.jena.rdf.model.ModelMaker;
public class JenaDBOpration {
// path of driver class
public static final String strDriver = "com.mysql.jdbc.Driver";
// The URL of the MySql database
// this can be modified when the server location changes
public static final String strURL = "jdbc:mysql://localhost/ontologydb";
// database user id
public static final String strUser = "root";
// database password
public static final String strPassWord = "nicky";
// database type
public static final String strDB = "MySQL";
public static final String strFilePath1 = "ontologymetadatamodel.owl/";
public static final String strFilePath2 = "1dhdwqm.owl/";
public static final String strOntologyName1 = "One";
public static final String strOntologyName2 = "Two";
public static boolean TestMySQLDriver(String MySQL_Driver) {
boolean result = false;
// 加载数据库驱动类,需要处理异常
try {
Class.forName(MySQL_Driver);
result = true;
} catch (ClassNotFoundException e) {
System.out.println(e.getMessage());
System.out.println("Driver is not available...");
}
return result;
}
public static InputStreamReader ReadFile(String FilePath) {
FileInputStream inputSreamfile = null;
try {
File file = new File(FilePath);
inputSreamfile = new FileInputStream(file);
} catch (FileNotFoundException e) {
e.printStackTrace();
System.out.println("Ontology File is not available...");
}
InputStreamReader in = null;
try {
in = new InputStreamReader(inputSreamfile, "UTF-8");
} catch (UnsupportedEncodingException e) {
e.printStackTrace();
}
return in;
}
// 建立一个到mysql的连接
public static IDBConnection connectDB(String DB_URL, String DB_USER,
String DB_PASSWARD, String DB_NAME) {
return new DBConnection(DB_URL, DB_USER, DB_PASSWARD, DB_NAME);
}
/* 从文件读取本体并将其存入数据库 */
public static boolean createDBModelFromFile(IDBConnection con,
String Ontology_Name, String filePath) {
try {
ModelMaker maker = ModelFactory.createModelRDBMaker(con);
Model base = maker.createModel(Ontology_Name);
base.read(ReadFile(filePath), null);
base.commit();
} catch (Exception E) {
System.out.println(E.getMessage());
}
return true;
}
/* 从数据库中得到已存入本体 */
public static OntModel getModelFromDB(IDBConnection con,
String Ontology_Name) {
ModelMaker maker = ModelFactory.createModelRDBMaker(con);
Model base = maker.getModel(Ontology_Name);
OntModel newmodel = ModelFactory.createOntologyModel(
getModelSpec(maker), base);
return newmodel;
}
public static OntModelSpec getModelSpec(ModelMaker maker) {
OntModelSpec spec = new OntModelSpec(OntModelSpec.OWL_MEM);
spec.setImportModelMaker(maker);
return spec;
}
/**
* @param args
*/
public static void main(String[] args) {
// TODO Auto-generated method stub
try {
boolean test = false;
try {
test = JenaDBOpration.TestMySQLDriver(strDriver);
} catch (Exception ex) {
System.out.println(ex.getMessage());
}
if (test) {
try {
IDBConnection idbc = JenaDBOpration.connectDB(strURL,
strUser, strPassWord, strDB);
JenaDBOpration.createDBModelFromFile(idbc,
strOntologyName1, strFilePath1);
JenaDBOpration.createDBModelFromFile(idbc,
strOntologyName2, strFilePath2);
} catch (Exception ex2) {
System.out.println(ex2.getMessage());
}
}
} catch (Exception e) {
System.out.println(e.getMessage());
}
}
}
Jena_g1t1_stmt和Jena_g2t1_stmt中村法规的是本体文件的数据信息,包括有class、properties(其它的暂时还不清楚,因为我的本体里面暂时只有这些,instance不清楚存放在哪,后续试验会做)。