static join enabled with pushStatic statement

Author: emrekenar

src/main/antlr/While.g4

@@ -34,6 +34,7 @@ ADAPT : 'adapt';
 MONITOR : 'monitor';
 TICK : 'tick';
 WINDOW : 'window';
+PUSH_STATIC: 'pushStatic';
 BREAKPOINT : 'breakpoint';
 SUPER : 'super';
 DESTROY : 'destroy';
@@ -151,6 +152,7 @@ statement :   SKIP_S SEMI
 			| RETURN expression SEMI                                                                                                                    # return_statement
 			| fmu=expression DOT TICK OPARAN time=expression CPARAN SEMI                                                                                # tick_statement
 			| (declType = type)? target=expression ASS WINDOW OPARAN monitor=expression CPARAN SEMI                                                     # window_statement
+            | PUSH_STATIC SEMI                                                                                                                          # pushStatic_statement
 			| ((declType = type)? target=expression ASS)? expression DOT NAME OPARAN (expression (COMMA expression)*)? CPARAN SEMI                      # call_statement
         // TODO: allow new statements without assignment
 			| (declType = type)? target=expression ASS NEW newType = type OPARAN (expression (COMMA expression)*)? CPARAN (MODELS owldescription = expression)? SEMI                         # create_statement

src/main/kotlin/no/uio/microobject/ast/Translate.kt

@@ -433,6 +433,11 @@ class Translate : WhileBaseVisitor<ProgramElement>() {
         return MonitorStmt(target, query, ll, ctx!!.start.line, target.getType())
     }
 
+    override fun visitPushStatic_statement(ctx: PushStatic_statementContext?): ProgramElement {
+        return PushStaticStatement(ctx!!.start.line)
+    }
+
+
     override fun visitWindow_statement(ctx: Window_statementContext?): ProgramElement {
         val target = visit(ctx!!.target) as Location
         if(ctx.declType != null) {

src/main/kotlin/no/uio/microobject/ast/stmt/PushStaticStmt.kt

@@ -0,0 +1,43 @@
+package no.uio.microobject.ast.stmt
+
+import com.sksamuel.hoplite.ConfigLoader
+import no.uio.microobject.ast.*
+import no.uio.microobject.ast.expr.FALSEEXPR
+import no.uio.microobject.ast.expr.LiteralExpr
+import no.uio.microobject.ast.expr.TRUEEXPR
+import no.uio.microobject.runtime.*
+import no.uio.microobject.type.*
+import no.uio.microobject.data.TripleSettings
+import org.apache.jena.datatypes.xsd.XSDDatatype
+import java.io.File
+
+import eu.larkc.csparql.core.engine.CsparqlQueryResultProxy
+import eu.larkc.csparql.common.RDFTuple
+
+data class PushStaticStmt(val pos : Int = -1) : Statement {
+    override fun toString(): String = "pushStatic()"
+    override fun getRDF(): String {
+        var s = "prog:stmt${this.hashCode()} rdf:type smol:PushStaticStmt.".trimIndent()
+        return s
+    }
+
+
+    override fun eval(heapObj: Memory, stackFrame: StackEntry, interpreter: Interpreter): EvalResult {
+        // fixed iri: prog:staticTable
+        val namedIri = "${interpreter.settings.progPrefix}staticTable"
+
+        // add only staticTable
+        val ts = TripleSettings(
+            sources = hashMapOf("heap" to false, "staticTable" to true, "vocabularyFile" to false, "fmos" to false, "externalOntology" to false, "urlOntology" to false),
+            guards = hashMapOf("heap" to true, "staticTable" to true),
+            virtualization = hashMapOf("heap" to true, "staticTable" to true, "fmos" to true),
+            jenaReasoner = interpreter.settings.reasoner,
+            cachedModel = null
+        )
+        val sTableModel = interpreter.tripleManager.getModel(ts)
+        interpreter.streamManager.putStaticNamedGraph(namedIri, sTableModel)
+
+        return EvalResult(null, emptyList())
+    }
+
+}

src/main/kotlin/no/uio/microobject/data/StreamManager.kt

@@ -16,12 +16,14 @@ import java.util.Observer;
 import java.util.Observable
 import java.util.concurrent.ConcurrentHashMap
 import java.io.File
+import java.io.StringWriter
 import org.slf4j.Logger
 import org.slf4j.LoggerFactory
 import org.apache.log4j.BasicConfigurator
 import org.apache.log4j.Level
 import org.apache.log4j.Logger as Log4jLogger
 import org.apache.log4j.PropertyConfigurator
+import org.apache.jena.rdf.model.Model
 import kotlin.text.toLong
 
 class ResultPusher(private val name: LiteralExpr, private val resultTable: MutableMap<LiteralExpr, RDFTable?>) : Observer {
@@ -154,5 +156,16 @@ class StreamManager(private val settings: Settings, val staticTable: StaticTable
         return queryWithPrefixes
     }
 
+    public fun putStaticNamedGraph(iri: String, model: Model) {
+        if (!engineInitialized) initEngine()
+
+        // serialize the model (RDF/XML matches the engine's first attempt)
+        val sw = StringWriter()
+        model.write(sw, "RDF/XML")
+
+        // hand it to the C-SPARQL engine
+        engine.putStaticNamedModel(iri, sw.toString())
+    }
+
 }