[转帖]使用jena写入多个本体文件到mysql_MySQL, Oracle及数据库讨论区_Weblogic技术|Tuxedo技术|中间件技术|Oracle论坛|JAVA论坛|Linux/Unix技术|hadoop论坛

总帖数

每页帖数

1/1页

返回列表

发起投票

查看: 1922 | 回复: 0

主题： [转帖]使用jena写入多个本体文件到mysql

huan.liu

注册用户

等级：新兵
经验：72
发帖：58
精华：0
注册：2011-11-23
状态：离线
发送短消息息给huan.liu

加好友发送短消息息给huan.liu

发消息

发表于：

2015-3-18 16:49:17 | [全部帖] [楼主帖]

楼主

代码如下：

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());
            }
      }
}