DataAccessLayer.java

Go to the documentation of this file.

/**
 * Copyright (c) Dmitri Pissarenko
 * http://dapissarenko.com
 * 
 * Created on 06.09.2005
 */
package com.dapissarenko.hierarchy;

import java.io.IOException;
import java.util.ArrayList;
import java.util.Collection;
import java.util.Iterator;
import java.util.Vector;

import org.apache.log4j.Logger;
import org.opencyc.api.CycAccess;
import org.opencyc.api.CycApiException;
import org.opencyc.api.CycObjectFactory;
import org.opencyc.cycobject.CycConstant;
import org.opencyc.cycobject.CycList;
import org.opencyc.cycobject.CycVariable;

import com.dapissarenko.hierarchy.civilServants.CivilServantData;
import com.dapissarenko.hierarchy.countries.CountryData;
import com.dapissarenko.hierarchy.departments.DepartmentData;

/**
 * @author Dmitri Pissarenko
 *
 */
public class DataAccessLayer {
    private CycAccess cyc;
    private Logger logger=Logger.getLogger(getClass());
    public DataAccessLayer(CycAccess cyc)
    {
        this.cyc=cyc;
    }
    public Collection getDepartmentList(CycConstant mt) throws CycApiException, IOException
    {
        CycList query = null;
        CycList response = null;
        CycVariable departmentVariable = null;
        CycConstant item=null;
        DepartmentData departmentData=null;
        Collection collection=null;
        Iterator iterator=null;

        collection=new Vector();
        
        query = CycAccess.current().makeCycList("(#$isa ?DEPARTMENT #$Department)");
        departmentVariable = CycObjectFactory.makeCycVariable("?DEPARTMENT");
        
        response = CycAccess.current().askWithVariable(query, 
                departmentVariable, mt);
        
        iterator=response.iterator();
        while (iterator.hasNext())
        {
            item=(CycConstant)iterator.next();
            
            departmentData=new DepartmentData();
            departmentData.setName(item.getName());
            departmentData.setFieldOfWork(this.getPredicateValue("fieldOfWork", item, mt));
            collection.add(departmentData);
        }
        
        return collection;
        
    }
    public Collection getCountryList(CycConstant mt) throws CycApiException, IOException
    {
        CycList query = null;
        CycList response = null;
        CycVariable countryVariable = null;
        CycConstant item=null;
        CountryData countryData=null;
        Collection collection=null;
        Iterator iterator=null;

        collection=new Vector();
        
        query = CycAccess.current().makeCycList("(#$isa ?COUNTRY #$Country)");
        countryVariable = CycObjectFactory.makeCycVariable("?COUNTRY");
        
        response = CycAccess.current().askWithVariable(query, 
                countryVariable, mt);
        
        iterator=response.iterator();
        while (iterator.hasNext())
        {
            item=(CycConstant)iterator.next();
            
            countryData=new CountryData();
            countryData.setCountryName(item.getName());
            countryData.setCountryComment(this.getComment(item, mt));
            
            collection.add(countryData);
        }
        
        return collection;
    }
    private String getPredicateValue(String predicateName, CycConstant item, CycConstant mt)  throws CycApiException, IOException
    {
        CycList query = null;
        CycList response = null;
        CycVariable variable = null;
        String value=null;
        
        value=null;
        query = CycAccess.current().makeCycList("(#$"+predicateName + " #$"+ item.getName() + " ?VAR)");
        variable = CycObjectFactory.makeCycVariable("?VAR");
        
        response = CycAccess.current().askWithVariable(query, 
                variable, mt);
        
        if (response.size()>0)
        {
            value=(String)response.iterator().next();
        }
        
        return value;
    }
    private String getComment(CycConstant country, CycConstant mt) throws CycApiException, IOException
    {
        return this.getPredicateValue("comment", country, mt);       
    }
    public Collection getCivilServantsList(CycConstant mt) throws CycApiException, IOException
    {
        CycList query = null;
        CycList response = null;
        CycVariable civilServantVariable = null;
        CycConstant item=null;
        CivilServantData civilServantData=null;
        Collection collection=null;
        Iterator iterator=null;

        collection=new Vector();
        
        query = CycAccess.current().makeCycList("(#$isa ?CIVIL_SERVANT #$CivilServant)");
        civilServantVariable = CycObjectFactory.makeCycVariable("?CIVIL_SERVANT");
        
        response = CycAccess.current().askWithVariable(query, 
                civilServantVariable, mt);
        
        iterator=response.iterator();
        while (iterator.hasNext())
        {
            item=(CycConstant)iterator.next();
            
            civilServantData=new CivilServantData();
            civilServantData.setFieldOfWork(this.getPredicateValue("fieldOfWork", item, mt));
            civilServantData.setGivenNames(this.getPredicateValue("givenNames", item, mt));
            civilServantData.setFamilyName(this.getPredicateValue("familyName", item, mt));
            
            collection.add(civilServantData);
        }
        
        return collection;
    }
    public Collection getHeadOfDepartmentList(CycConstant mt) throws CycApiException, IOException
    {
        CycList query = null;
        CycList response = null;
        CycVariable departmentVariable = null;
        CycVariable headVariable = null;
        CycList item=null;
        DepartmentData departmentData=null;
        Collection collection=null;
        ArrayList variables=null;
        Iterator iterator=null;
        CycConstant department=null;
        CycConstant head=null;
        String fullHeadName=null;

        collection=new Vector();
        
        query = CycAccess.current().makeCycList("(#$headOfDepartment ?HEAD_OF_DEPARTMENT ?DEPARTMENT)");
        departmentVariable = CycObjectFactory.makeCycVariable("?DEPARTMENT");
        headVariable = CycObjectFactory.makeCycVariable("?HEAD_OF_DEPARTMENT");
        
        variables=new ArrayList();
        variables.add(departmentVariable);
        variables.add(headVariable);
        
        response = CycAccess.current().askWithVariables(query, 
                variables, mt);

        iterator=response.iterator();
        while (iterator.hasNext())
        {
            item=(CycList)iterator.next();
            
            head=(CycConstant)item.first();
            department=(CycConstant)item.second();
            fullHeadName=this.getFullHeadName(head, mt);
            
            departmentData=new DepartmentData();
            departmentData.setHeadOfDepartment(fullHeadName);
            departmentData.setName(department.getName());
              
            collection.add(departmentData);
        }
        
        return collection;
        
    }
    private String getFullHeadName(CycConstant person, CycConstant mt)  throws CycApiException, IOException
    {
        String fullName=null;
        
        fullName = this.getPredicateValue("givenNames", person, mt);
        fullName += " ";
        fullName += this.getPredicateValue("familyName", person, mt);
        
        return fullName;
    }
    public String[] getRabinovichRoles(CycConstant mt) throws CycApiException, IOException
    {
        CycList query = null;
        CycList response = null;
        CycVariable propertyVariable = null;
        Object item=null;
        Vector collection=null;
        Iterator iterator=null;

        collection=new Vector();
        
        query = CycAccess.current().makeCycList("(#$isa #$MokiiNilovichRabinovich ?PROPERTY)");
        propertyVariable = CycObjectFactory.makeCycVariable("?PROPERTY");
        
        response = CycAccess.current().askWithVariable(query, 
                propertyVariable, mt);

        iterator=response.iterator();
        while (iterator.hasNext())
        {
            item=iterator.next();
              
            collection.add(item.toString());
        }
        
        return (String[])collection.toArray(new String[collection.size()]);
    }
    public CivilServantData[] getCivilServantsWithSubordinates(CycConstant mt) throws CycApiException, IOException
    {
        CycList query = null;
        CycList response = null;
        CycVariable bossVariable = null;
        CycVariable subordinateVariable=null;
        CycList item=null;
        CivilServantData civilServantData=null;
        ArrayList variables=null;
        Collection collection=null;
        Iterator iterator=null;

        collection=new Vector();
        
        query = CycAccess.current().makeCycList("(#$superiors ?BOSS ?SUBORD)");
        bossVariable = CycObjectFactory.makeCycVariable("?BOSS");
        subordinateVariable = CycObjectFactory.makeCycVariable("?SUBORD");
        
        variables=new ArrayList();
        variables.add(bossVariable);
        variables.add(subordinateVariable);
        
        response = CycAccess.current().askWithVariables(query, 
                variables, mt);
        
        iterator=response.iterator();
        while (iterator.hasNext())
        {
            item=(CycList)iterator.next();
            
            civilServantData=new CivilServantData();
            civilServantData.setFieldOfWork(this.getPredicateValue("fieldOfWork", (CycConstant)item.first(), mt));
            civilServantData.setGivenNames(this.getPredicateValue("givenNames", (CycConstant)item.first(), mt));
            civilServantData.setFamilyName(this.getPredicateValue("familyName", (CycConstant)item.first(), mt));
            
            collection.add(civilServantData);
        }
        
        return (CivilServantData[])collection.toArray(new CivilServantData[collection.size()]);
        
    }
    public CivilServantData[] getBossOfBagaturLobo(CycConstant mt) throws CycApiException, IOException
    {
        CycList query = null;
        CycList response = null;
        CycVariable bossVariable = null;
        CycConstant item=null;
        CivilServantData civilServantData=null;
        ArrayList variables=null;
        Collection collection=null;
        Iterator iterator=null;

        collection=new Vector();
        
        query = CycAccess.current().makeCycList("(#$superiors ?BOSS #$BagaturLobo)");
        bossVariable = CycObjectFactory.makeCycVariable("?BOSS");
        
        response = CycAccess.current().askWithVariable(query, 
                bossVariable, mt);
        
        iterator=response.iterator();
        while (iterator.hasNext())
        {
            item=(CycConstant)iterator.next();
            
            civilServantData=new CivilServantData();
            civilServantData.setFieldOfWork(this.getPredicateValue("fieldOfWork", item, mt));
            civilServantData.setGivenNames(this.getPredicateValue("givenNames", item, mt));
            civilServantData.setFamilyName(this.getPredicateValue("familyName", item, mt));
            
            collection.add(civilServantData);
        }
        
        return (CivilServantData[])collection.toArray(new CivilServantData[collection.size()]);
        
    }
}

---