Merge pull request #261 from uwescience/sql-lang

Sql backend: basic, incomplete implementation and some tests

c++/scan_code.py

@@ -1,5 +1,5 @@
 import raco.algebra as alg
-import raco.clang as clang
+import raco.language.clang as clang
 import raco.boolean as rbool
 
 
@@ -311,7 +311,7 @@ def visit (self,n):
 
         #generate code for a join chain
         elif isinstance(n,alg.NaryOperator) :
-            if isinstance(n,clang.FilteringNLJoinChain) :
+            if isinstance(n, clang.FilteringNLJoinChain) :
                 for arg in n.args :
                     self.visit(arg)
                 self.generate_join_chain(n)

c_test_environment/clang_tests.py

@@ -3,7 +3,7 @@
 from testquery import ClangRunner
 from generate_test_relations import generate_default
 from generate_test_relations import need_generate
-from raco.language import CCAlgebra
+from raco.language.clang import CCAlgebra
 from platform_tests import PlatformTest
 
 import sys

c_test_environment/grappalang_tests.py

@@ -3,7 +3,7 @@
 from testquery import GrappalangRunner
 from generate_test_relations import generate_default
 from generate_test_relations import need_generate
-from raco.language import GrappaAlgebra
+from raco.language.grappalang import GrappaAlgebra
 from platform_tests import PlatformTest
 from nose.plugins.skip import SkipTest
 

examples/emitcode.py

@@ -1,5 +1,5 @@
 from raco import RACompiler
-from raco.algebra import LogicalAlgebra
+from raco.language.logical import LogicalAlgebra
 from raco.compile import compile
 import raco.viz as viz
 
@@ -28,7 +28,7 @@ def emitCode(query, name, algebra):
     dlog.optimize(target=algebra, eliminate_common_subexpressions=False)
 
     LOG.info("physical: %s",dlog.physicalplan)
-    
+
     print dlog.physicalplan
     physical_dot = viz.operator_to_dot(dlog.physicalplan)
     with open("%s.physical.dot"%(name), 'w') as dwf:
@@ -38,7 +38,7 @@ def emitCode(query, name, algebra):
     code = ""
     code += comment("Query " + query)
     code += compile(dlog.physicalplan)
-    
+
     fname = name+'.cpp'
     with open(fname, 'w') as f:
         f.write(code)

examples/sp2bench/sp2bench_rdf_long.py

@@ -1,7 +1,7 @@
 import emitcode
 import raco.algebra as algebra
 import raco.rules as rules
-from raco.grappalang import GrappaSymmetricHashJoin, GrappaHashJoin
+from raco.language.grappalang import GrappaSymmetricHashJoin, GrappaHashJoin
 from raco.language import CCAlgebra, GrappaAlgebra
 
 
@@ -48,7 +48,7 @@
 # TODO be sure DISTINCT
 
 
-# syntactically join with equality; 
+# syntactically join with equality;
 #queries['Q5a'] = """A(person, name) :- %(tr)s(article, 'http://www.w3.org/1999/02/22-rdf-syntax-ns#type', 'http://localhost/vocabulary/bench/Article'),
 queries['Q5a'] = """A(person, name) :- %(tr)s(article, 'http://www.w3.org/1999/02/22-rdf-syntax-ns#type', 'http://localhost/vocabulary/bench/Article'),
                             %(tr)s(article, 'http://purl.org/dc/elements/1.1/creator', person),
@@ -71,24 +71,24 @@
 # TODO: Q7 requires double negation
 
 
-#TODO: enable Q8, after dealing with HashJoin( $0 != $7 ) type of cases 
-#queries['Q8'] = """Erdoes(erdoes) :- %(tr)s(erdoes, 'http://www.w3.org/1999/02/22-rdf-syntax-ns#type', 'http://xmlns.com/foaf/0.1/Person'), 
-_ = """Erdoes(erdoes) :- %(tr)s(erdoes, 'http://www.w3.org/1999/02/22-rdf-syntax-ns#type', 'http://xmlns.com/foaf/0.1/Person'), 
-                          %(tr)s(erdoes, 'http://xmlns.com/foaf/0.1/name', "Paul Erdoes") 
+#TODO: enable Q8, after dealing with HashJoin( $0 != $7 ) type of cases
+#queries['Q8'] = """Erdoes(erdoes) :- %(tr)s(erdoes, 'http://www.w3.org/1999/02/22-rdf-syntax-ns#type', 'http://xmlns.com/foaf/0.1/Person'),
+_ = """Erdoes(erdoes) :- %(tr)s(erdoes, 'http://www.w3.org/1999/02/22-rdf-syntax-ns#type', 'http://xmlns.com/foaf/0.1/Person'),
+                          %(tr)s(erdoes, 'http://xmlns.com/foaf/0.1/name', "Paul Erdoes")
         A(name) :- Erdoes(erdoes),
                    %(tr)s(doc, 'http://purl.org/dc/elements/1.1/creator', erdoes),
                    %(tr)s(doc, 'http://purl.org/dc/elements/1.1/creator', author),
                    %(tr)s(doc2, 'http://purl.org/dc/elements/1.1/creator', author),
                    %(tr)s(doc2, 'http://purl.org/dc/elements/1.1/creator', author2),
                    %(tr)s(author2, 'http://xmlns.com/foaf/0.1/name', name),
-                   author != erdoes, 
-                   doc2 != doc, 
+                   author != erdoes,
+                   doc2 != doc,
                    author2 != erdoes,
                    author2 != author
-                     
+
          A(name) :- Erdoes(erdoes),
                     %(tr)s(doc, 'http://purl.org/dc/elements/1.1/creator', erdoes),
-                    %(tr)s(doc, 'http://purl.org/dc/elements/1.1/creator', author), 
+                    %(tr)s(doc, 'http://purl.org/dc/elements/1.1/creator', author),
                     %(tr)s(author, 'http://xmlns.com/foaf/0.1/name', name),
                     author != erdoes"""
 #TODO be sure DISTINCT
@@ -105,7 +105,7 @@
 
 queries['Q11'] = """A(ee) :- %(tr)s(publication, 'http://www.w3.org/2000/01/rdf-schema#seeAlso', ee)"""
 #TODO order by, limit, offset
-    
+
 alg = CCAlgebra
 prefix=""
 import sys