本文整理汇总了Java中com.hp.hpl.jena.graph.query.Domain类的典型用法代码示例。如果您正苦于以下问题:Java Domain类的具体用法?Java Domain怎么用?Java Domain使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
Domain类属于com.hp.hpl.jena.graph.query包,在下文中一共展示了Domain类的19个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: prepareBindings
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;
}
};
}
开发者ID:d2rq,项目名称:r2rml-kit,代码行数:19,代码来源:D2RQQueryHandler.java
示例2: prepareBindings
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;
}
};
}
开发者ID:aitoralmeida,项目名称:c4a_data_repository,代码行数:19,代码来源:D2RQQueryHandler.java
示例3: hasNext
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 ;
}
开发者ID:quoll,项目名称:mulgara,代码行数:24,代码来源:GraphMulgara.java
示例4: setArgs
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 ); }
}
开发者ID:jacekkopecky,项目名称:parkjam,代码行数:18,代码来源:DBQueryStage.java
示例5: map1
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;
}
开发者ID:d2rq,项目名称:r2rml-kit,代码行数:11,代码来源:D2RQQueryHandler.java
示例6: convert
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 ;
}
开发者ID:quoll,项目名称:mulgara,代码行数:9,代码来源:PatternMulgara.java
示例7: next
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;
}
开发者ID:quoll,项目名称:mulgara,代码行数:8,代码来源:PatternMulgara.java
示例8: extendSourceBinding
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 );
}
}
开发者ID:jacekkopecky,项目名称:parkjam,代码行数:35,代码来源:DBQueryStage.java
示例9: getQual
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;
}
开发者ID:jacekkopecky,项目名称:parkjam,代码行数:35,代码来源:DBQueryStageCompiler.java
示例10: shareFixedSubject
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;
}
开发者ID:jacekkopecky,项目名称:parkjam,代码行数:11,代码来源:DBPattern.java
示例11: map1
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 )
;
}
开发者ID:jacekkopecky,项目名称:parkjam,代码行数:12,代码来源:ModelQueryUtil.java
示例12: map1
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;
}
开发者ID:vaibhavkhadilkar,项目名称:D2RQ-Update,代码行数:14,代码来源:D2RQRWQueryHandler.java
示例13: app
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 );
}
开发者ID:jacekkopecky,项目名称:parkjam,代码行数:7,代码来源:SetBunch.java
示例14: match
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");
}
开发者ID:jacekkopecky,项目名称:parkjam,代码行数:5,代码来源:Free.java
示例15: asNodeMatch
import com.hp.hpl.jena.graph.query.Domain; //导入依赖的package包/类
@Override
public Node asNodeMatch( Domain d ) {
throw new JenaException("asNodeMatch not supported");
}
开发者ID:jacekkopecky,项目名称:parkjam,代码行数:5,代码来源:Free.java
示例16: compilePattern
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;
}
开发者ID:jacekkopecky,项目名称:parkjam,代码行数:44,代码来源:DBQueryStageCompiler.java
示例17: mappy
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;
}
开发者ID:jacekkopecky,项目名称:parkjam,代码行数:7,代码来源:ModelQueryUtil.java
示例18: app
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 );
开发者ID:jacekkopecky,项目名称:parkjam,代码行数:11,代码来源:TripleBunch.java
示例19: reset
import com.hp.hpl.jena.graph.query.Domain; //导入依赖的package包/类
public abstract MatchOrBind reset( Domain d );
开发者ID:jacekkopecky,项目名称:parkjam,代码行数:2,代码来源:MatchOrBind.java
注:本文中的com.hp.hpl.jena.graph.query.Domain类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论