import com.hp.hpl.jena.graph.query.Domain; //导入依赖的package包/类
public BindingQueryPlan prepareBindings(GraphQuery q, Node[] variables) {   
	this.variables = variables;
	this.indexes = new HashMap<Node,Integer>();
	for (int i = 0; i < variables.length; i++) {
		indexes.put(variables[i], new Integer(i));
	}
	BasicPattern pattern = new BasicPattern();
	for (Triple t: q.getPattern()) {
		pattern.add(t);
	}
	Plan plan = QueryEngineD2RQ.getFactory().create(new OpBGP(pattern), dataset, null, null);
	final ExtendedIterator<Domain> queryIterator = new Map1Iterator<Binding,Domain>(new BindingToDomain(), plan.iterator());
	return new BindingQueryPlan() {
		public ExtendedIterator<Domain> executeBindings() {
			return queryIterator;
		}
	};
}
 

import com.hp.hpl.jena.graph.query.Domain; //导入依赖的package包/类
public BindingQueryPlan prepareBindings(Query q, Node[] variables) {   
	this.variables = variables;
	this.indexes = new HashMap<Node,Integer>();
	for (int i = 0; i < variables.length; i++) {
		indexes.put(variables[i], new Integer(i));
	}
	BasicPattern pattern = new BasicPattern();
	for (Triple t: q.getPattern()) {
		pattern.add(t);
	}
	Plan plan = QueryEngineD2RQ.getFactory().create(new OpBGP(pattern), dataset, null, null);
	final ExtendedIterator<Domain> queryIterator = new Map1Iterator<Binding,Domain>(new BindingToDomain(), plan.iterator());
	return new BindingQueryPlan() {
		public ExtendedIterator<Domain> executeBindings() {
			return queryIterator;
		}
	};
}
 

import com.hp.hpl.jena.graph.query.Domain; //导入依赖的package包/类
@Override
public boolean hasNext() {
  if (finished) return false;

  if (slot != null) return true;
        
  if (!iter.hasNext()) {
    NiceIterator.close(iter);
    finished = true;
    return false;
  }
        
  Domain d = (Domain)iter.next();
  Node s = triple.getSubject();
  Node p = triple.getPredicate();
  Node o = triple.getObject();
  int i = 0;
  if (s.isVariable()) s = d.getElement(i++);
  if (p.isVariable()) p = d.getElement(i++);
  if (o.isVariable()) o = d.getElement(i++);
  slot = new Triple(s,p,o);
  return true ;
}
 

import com.hp.hpl.jena.graph.query.Domain; //导入依赖的package包/类
protected void setArgs( Domain args, PreparedStatement ps )
{
try
    {
    for (int i = 0; i < compiled.argCnt; i++)
        {
        int ix = (compiled.argIndex.get( i )).intValue();
        Node arg = args.get( ix );
        if (arg == null) throw new JenaException( "Null query argument" );
        String val = compiled.driver.nodeToRDBString( arg, false );
        ps.setString( i + 1, val );
        }
    }
catch (SQLException e)
    { throw new JenaException( "Bad query argument", e ); }

}
 

import com.hp.hpl.jena.graph.query.Domain; //导入依赖的package包/类
public Domain map1(Binding binding) {
	Domain d = new Domain(variables.length);
	for (int i = 0; i < variables.length; i++) {
		Var v = Var.alloc(variables[i]);
		Node value = binding.get(v);
		int index = ((Integer) indexes.get(v)).intValue();
		d.setElement(index, value);
	}
	return d;
}
 

import com.hp.hpl.jena.graph.query.Domain; //导入依赖的package包/类
Domain convert() throws TuplesException {
  Domain d = new Domain(proj.size());
  for (int i = 0; i < proj.size(); i++) {
    Node n = Jenara.o2n((org.jrdf.graph.Node)answer.getObject(i));
    d.setElement(i, n);
  }
  return d ;
}
 

import com.hp.hpl.jena.graph.query.Domain; //导入依赖的package包/类
@Override
public Object next() {
  if (!hasNext()) throw new NoSuchElementException("AnswerIterator.next");
  Domain d = slot;
  slot = null;
  return d;
}
 

import com.hp.hpl.jena.graph.query.Domain; //导入依赖的package包/类
private void extendSourceBinding( Domain current, Pipe sink, PreparedStatement ps )
{
ResultSet rs = null;
ResultSetStringIterator it = null;
setArgs( current, ps );
// System.out.println( ">> " + compiled.stmt.toString().replaceAll( " AND ", "\n  AND " ) );
try
    {
    it = new ResultSetStringIterator();
    ps.execute();
    rs = ps.getResultSet();
    it.reset( rs, ps );
    while (it.hasNext())
        {
        Domain useme = current.copy();
        List<String> row = it.next();
        for (int i = 0; i < compiled.resList.length; i++)
            {
            int j = compiled.resList[i];
            String o = row.get( i );
            Node n = compiled.driver.RDBStringToNode( o );
            useme.setElement( j, n );
            }
        sink.put( useme );
        }
    }
catch (Exception e)
    { throw new JenaException( "Query execute failed: " + e ); }
finally
    { 
    if (it != null) it.close(); 
    if (rs != null) closeResultSet( rs );
    }
}
 

import com.hp.hpl.jena.graph.query.Domain; //导入依赖的package包/类
private static String getQual(DBQuery query,int alias,char pred, Element spo) {
	String qual = "";
	if (spo instanceof Fixed) {
		Node obj = ((Fixed) spo).asNodeMatch((Domain) null);
		if ( query.isReifier )
			qual = query.driver.genSQLReifQualConst(alias,pred,obj);
		else
			qual = query.driver.genSQLQualConst(alias,pred,obj);
	} else if (spo instanceof Free){
		Free v = (Free) spo;
		VarDesc bind = query.getBinding(v.getListing());
		// only bind to argument value for first use of variable.
		// subsequent references should join to first binding.
		if ( v.isArg() && !bind.isBoundToCol ) {
			query.argCnt++;
			query.argType += pred;
			query.argIndex.add(new Integer(v.getMapping()));
			qual = query.driver.genSQLQualParam(alias, pred);
			bind.bindToCol(alias, pred);
		} else {
			if (bind.isBoundToCol()) {
				qual =
					query.driver.genSQLJoin( bind.alias, bind.column,
						alias, pred);
			} else {
				// nothing to compare. just binding the var to the column
				bind.bindToCol(alias, pred);
				qual = "";
			}
		}
	} else if ( spo != Element.ANY )
		throw new JenaException("Invalid Element in qualifier");
	return qual;
}
 

import com.hp.hpl.jena.graph.query.Domain; //导入依赖的package包/类
private boolean shareFixedSubject( DBPattern other )
{ // Yukk.
boolean originalDefinition = 
    S instanceof Fixed
    && other.S instanceof Fixed
    && S.match( (Domain) null, other.S.asNodeMatch( (Domain) null ) )
    ;
return 
    originalDefinition;
}
 

import com.hp.hpl.jena.graph.query.Domain; //导入依赖的package包/类
public static ExtendedIterator<List<? extends RDFNode>> queryBindingsWith
( final Model model, Model query, Resource [] variables )
{
Map1<Domain, List<? extends RDFNode>> mm = new Map1<Domain, List<? extends RDFNode>>()
    { public List<? extends RDFNode> map1( Domain x ) { return mappy( model, x ); } };
QueryMapper qm = new QueryMapper( query, variables );
return
    qm.getQuery().executeBindings( model.getGraph(), qm.getVariables() )
    .mapWith( mm )
    ;
}
 

import com.hp.hpl.jena.graph.query.Domain; //导入依赖的package包/类
public Object map1(Object o) 
{
	Binding binding = (Binding) o;
	Domain d = new Domain(variables.length);
	for (int i = 0; i < variables.length; i++) 
	{
		Var v = Var.alloc(variables[i]);
		Node value = binding.get(v);
		int index = ((Integer) indexes.get(v)).intValue();
		d.setElement(index, value);
	}
	return d;
}
 

import com.hp.hpl.jena.graph.query.Domain; //导入依赖的package包/类
public void app( Domain d, StageElement next, MatchOrBind s )
{
Iterator<Triple> it = iterator();
while (it.hasNext())
    if (s.matches( it.next() )) next.run( d );
}
 

import com.hp.hpl.jena.graph.query.Domain; //导入依赖的package包/类
@Override
  public boolean match( Domain d, Node x )
{throw new JenaException("Attempt to match a free variable");		
}
 

import com.hp.hpl.jena.graph.query.Domain; //导入依赖的package包/类
@Override
   public Node asNodeMatch( Domain d ) {
	throw new JenaException("asNodeMatch not supported");
}
 

import com.hp.hpl.jena.graph.query.Domain; //导入依赖的package包/类
/**
	compile a triple pattern.
*/

   private static void compilePattern( DBQueryStageCompiler compiler, DBQuery query,
   		DBPattern dbpat )
       {
		Element subj = dbpat.S;
		Element obj = dbpat.O;
		Element pred = dbpat.P;
		String qual = "";
		int alias = query.aliasCnt;

		if ( query.isReifier ) {
       		boolean newAlias = true;
       		if ( !(pred instanceof Fixed) ) throw new JenaException("Reifier predicate not bound");
       		Node p = ((Fixed) pred).asNodeMatch( (Domain) null );
       		char reifProp = getReificationChar( p );
			if ( !subj.equals(Element.ANY) ) {
				// optionally do join optimization for reification.
				// if the subject is joined with another pattern and
				// that subject is already bound, skip the join.
				if ( query.qryFullReif && (subj instanceof Free) && 
					query.getBinding(((Free)subj).getListing()).isBoundToCol() ) {
						alias = (query.getBinding(((Free)subj).getListing())).alias;
						newAlias = false;
					} else 
						qual = query.sqlAnd.gen(getQual(query,alias,'N',subj));
			}			
			qual += query.sqlAnd.gen(getQual(query,alias,reifProp,obj));
			qual += query.sqlAnd.gen(query.driver.genSQLQualGraphId(alias,query.graphId));
			if ( newAlias ) query.newAlias();
       		
       	} else {
       		// query over triple table
			qual = query.sqlAnd.gen(getQual(query,alias,'S',subj));
			qual += query.sqlAnd.gen(getQual(query,alias,'P',pred));
			qual += query.sqlAnd.gen(getQual(query,alias,'O',obj));
			qual += query.sqlAnd.gen(query.driver.genSQLQualGraphId(alias,query.graphId));
			query.newAlias();
       	}
	query.stmt += qual;
       }
 

import com.hp.hpl.jena.graph.query.Domain; //导入依赖的package包/类
public static List<RDFNode> mappy( Model m, Domain L )
{
ArrayList<RDFNode> result = new ArrayList<RDFNode>( L.size() );
for (int i = 0; i < L.size(); i += 1) result.add( asRDF( m, L.get( i ) ) );
return result;
}
 

import com.hp.hpl.jena.graph.query.Domain; //导入依赖的package包/类
/**
     For every triple t in this bunch that matches <code>s<code>, invoke
     <code>next.run(d)</code>. <code>d</code> may have been 
     side-effected by the match. <code>app</code> is the main reason
     that TripleBunch exists at all: it's a way to iterate as fast as possible
     over the triples in the context of a graph query, without having to
     construct an Iterator object which has to maintain the iteration state
     in instance variables.
*/
public abstract void app( Domain d, StageElement next, MatchOrBind s );
 

import com.hp.hpl.jena.graph.query.Domain; //导入依赖的package包/类
public abstract MatchOrBind reset( Domain d );