Merge pull request #43 from amitaarunsingh/master

dump all data as rdf, submit rdf into 4store.

5 files changed, 922 insertions, 0 deletions

diff --git a/gstudio/4store_rdf_import.py b/gstudio/4store_rdf_import.py
new file mode 100644
index 0000000..5541895
--- /dev/null
+++ b/gstudio/4store_rdf_import.py
@@ -0,0 +1,199 @@
+
+import rdflib
+from rdflib.graph import ConjunctiveGraph as Graph
+from rdflib import plugin
+from rdflib.store import Store, NO_STORE, VALID_STORE
+from rdflib.namespace import Namespace
+from rdflib.term import Literal
+from rdflib.term import URIRef
+from tempfile import mkdtemp
+from gstudio.models import *
+from objectapp.models import *
+import settings
+import os.path
+from django.core.management.base import NoArgsCommand
+from django.core.management.base import BaseCommand
+from pprint import pprint
+
+import subprocess
+from HTTP4Store import HTTP4Store
+
+
+def rdf_all(notation='xml'):
+    """
+    Funtion takes  title of node, and rdf notation.
+    """
+    valid_formats = ["xml", "n3", "ntriples", "trix"]
+    default_graph_uri = "http://gstudio.gnowledge.org/rdfstore"
+  
+    configString = "/var/tmp/rdfstore"
+
+    # Get the IOMemory plugin.
+    store = plugin.get('IOMemory', Store)('rdfstore')
+   
+
+
+    # Open previously created store, or create it if it doesn't exist yet
+    graph = Graph(store="IOMemory",
+               identifier = URIRef(default_graph_uri))
+    path = mkdtemp()
+    rt = graph.open(path, create=False)
+    if rt == NO_STORE:
+    
+        graph.open(path, create=True)
+    else:
+        assert rt == VALID_STORE, "The underlying store is corrupt"
+
+
+    # Now we'll add some triples to the graph & commit the changes
+    
+    graph.bind("gstudio", "http://gnowledge.org/")
+    exclusion_fields = ["id", "rght", "node_ptr_id", "image", "lft", "_state", "_altnames_cache", "_tags_cache", "nid_ptr_id", "_mptt_cached_fields"]
+
+    for node in NID.objects.all():
+    	    node_dict=node.ref.__dict__
+    	    node_type = node.reftype
+            try:       
+            
+           	 if (node_type=='Gbobject'):
+    	    		node=Gbobject.objects.get(title=node)
+    		
+    	    	 elif (node_type=='None'):
+    			node=Gbobject.objects.get(title=node)
+    		 
+            	 elif (node_type=='Processes'):
+    			node=Gbobject.objects.get(title=node)
+    			 
+            	 elif (node_type=='System'):
+    			node=Gbobject.objects.get(title=node)
+    			rdflib=link(node)
+			url_addr=link1(node)
+                	a=fstore_dump(url_addr) 
+            	 elif (node_type=='Objecttype'):
+    			node=Objecttype.objects.get(title=node)
+    			
+    	    	 elif (node_type=='Attributetype'):
+    			node=Attributetype.objects.get(title=node)
+    	        	 
+    	    	 elif (node_type=='Complement'):
+    			node=Complement.objects.get(title=node)
+    			
+            	 elif (node_type=='Union'):
+    	   		node=Union.objects.get(title=node)
+    			 
+            	 elif (node_type=='Intersection'):
+    			node=Intersection.objects.get(title=node)
+    	
+            	 elif (node_type=='Expression'):
+    			node=Expression.objects.get(title=node)
+    		
+            	 elif (node_type=='Processtype'):
+    			node=Processtype.objects.get(title=node)
+    		 
+            	 elif (node_type=='Systemtype'):
+    	 		node=Systemtype.objects.get(title=node)
+    			
+            	 elif (node_type=='AttributeSpecification'):
+    			node=AttributeSpecification.objects.get(title=node)
+    			
+            	 elif (node_type=='RelationSpecification'):
+    			node=RelationSpecification.objects.get(title=node)
+    		 rdflib=link(node) 	 
+                 url_addr=link1(node)
+                 a=fstore_dump(url_addr) 
+            	 if(node_type=='Attribute'):
+    			node=Attribute.objects.get(title=node)
+    			rdflib = Namespace('http://sbox.gnowledge.org/gstudio/')
+              	
+            	 elif(node_type=='Relationtype' ):
+    			node=Relationtype.objects.get(title=node)
+    			rdflib = Namespace('http://sbox.gnowledge.org/gstudio/')
+                
+    	    	 elif(node_type=='Metatype'):
+    			node=Metatype.objects.get(title=node)
+    			rdflib = Namespace('http://sbox.gnowledge.org/gstudio/')
+                 url_addr='http://sbox.gnowledge.org/gstudio/'
+                 a=fstore_dump(url_addr) 
+            except:
+            	if(node_type=='Attribute'):
+                	rdflib= Namespace('http://sbox.gnowledge.org/gstudio/')
+    
+            	if(node_type=='Relationtype' ):
+                	rdflib= Namespace('http://sbox.gnowledge.org/gstudio/')
+                    
+            	if(node_type=='Metatype'):
+                	rdflib= Namespace('http://sbox.gnowledge.org/gstudio/')
+            	
+           
+    subject=str(node_dict['id'])
+    for key in node_dict:
+        if key not in exclusion_fields:
+           predicate=str(key)
+           pobject=str(node_dict[predicate])
+           graph.add((rdflib[subject], rdflib[predicate], Literal(pobject)))                        
+        
+    rdf_code=graph.serialize(format=notation)
+               #path to store the rdf in a file
+    
+    #x = os.path.join(os.path.dirname(__file__), 'rdffiles.rdf')
+    
+    graph.commit()
+    graph.close()
+    
+
+
+#provides the url address of particular node.
+def link(node):
+	node_url=node.get_absolute_url()
+    	site_addr= node.sites.all() 
+    	a=site_addr[0]
+    	host_name=a.name
+   
+    	link='http://'
+    	#Concatenating the above variables will give the url address.
+
+    	url_addr=link+host_name+node_url
+    	rdflib=Namespace(url_addr) 
+        return rdflib
+
+def link1(node):
+	node_url=node.get_absolute_url()
+    	site_addr= node.sites.all() 
+    	a=site_addr[0]
+    	host_name=a.name
+   
+    	link='http://'
+    	#Concatenating the above variables will give the url address.
+
+    	url_addr=link+host_name+node_url
+    	
+        return url_addr
+  
+def fstore_dump(url_addr):
+	
+	store = HTTP4Store('http://localhost:8067')
+	status = store.status()
+	response = store.add_from_uri('http://example.com/nodetypes/2012/05/25/mouse/')
+        return response
+
+    	
+	
+    	
+	
+	
+	
+       
+
+
+
+class Command(BaseCommand):
+	def handle(self,*args,**options):		
+                # verify the type of the node and pass the node to display the rdf accordingly.		
+	
+    		rdf_all(*args)
+
+
+
+
+
+
diff --git a/gstudio/fstore_rdf_import.py b/gstudio/fstore_rdf_import.py
new file mode 100644
index 0000000..ea48548
--- /dev/null
+++ b/gstudio/fstore_rdf_import.py
@@ -0,0 +1,187 @@
+
+import rdflib
+from rdflib.graph import ConjunctiveGraph as Graph
+from rdflib import plugin
+from rdflib.store import Store, NO_STORE, VALID_STORE
+from rdflib.namespace import Namespace
+from rdflib.term import Literal
+from rdflib.term import URIRef
+from tempfile import mkdtemp
+from gstudio.models import *
+from objectapp.models import *
+import settings
+import os.path
+
+from pprint import pprint
+
+import subprocess
+from HTTP4Store import HTTP4Store
+
+
+def rdf_all(notation='xml'):
+    """
+    Funtion takes  title of node, and rdf notation.
+    """
+    valid_formats = ["xml", "n3", "ntriples", "trix"]
+    default_graph_uri = "http://gstudio.gnowledge.org/rdfstore"
+  
+    configString = "/var/tmp/rdfstore"
+
+    # Get the IOMemory plugin.
+    store = plugin.get('IOMemory', Store)('rdfstore')
+   
+
+
+    # Open previously created store, or create it if it doesn't exist yet
+    graph = Graph(store="IOMemory",
+               identifier = URIRef(default_graph_uri))
+    path = mkdtemp()
+    rt = graph.open(path, create=False)
+    if rt == NO_STORE:
+    
+        graph.open(path, create=True)
+    else:
+        assert rt == VALID_STORE, "The underlying store is corrupt"
+
+
+    # Now we'll add some triples to the graph & commit the changes
+    
+    graph.bind("gstudio", "http://gnowledge.org/")
+    exclusion_fields = ["id", "rght", "node_ptr_id", "image", "lft", "_state", "_altnames_cache", "_tags_cache", "nid_ptr_id", "_mptt_cached_fields"]
+
+    for node in NID.objects.all():
+    	    node_dict=node.ref.__dict__
+    	    node_type = node.reftype
+            try:       
+            
+           	 if (node_type=='Gbobject'):
+    	    		node=Gbobject.objects.get(title=node)
+    		
+    	    	 elif (node_type=='None'):
+    			node=Gbobject.objects.get(title=node)
+    		 
+            	 elif (node_type=='Processes'):
+    			node=Gbobject.objects.get(title=node)
+    			 
+            	 elif (node_type=='System'):
+    			node=Gbobject.objects.get(title=node)
+    			
+            	 elif (node_type=='Objecttype'):
+    			node=Objecttype.objects.get(title=node)
+    			
+    	    	 elif (node_type=='Attributetype'):
+    			node=Attributetype.objects.get(title=node)
+    	        	 
+    	    	 elif (node_type=='Complement'):
+    			node=Complement.objects.get(title=node)
+    			
+            	 elif (node_type=='Union'):
+    	   		node=Union.objects.get(title=node)
+    			 
+            	 elif (node_type=='Intersection'):
+    			node=Intersection.objects.get(title=node)
+    	
+            	 elif (node_type=='Expression'):
+    			node=Expression.objects.get(title=node)
+    		
+            	 elif (node_type=='Processtype'):
+    			node=Processtype.objects.get(title=node)
+    		 
+            	 elif (node_type=='Systemtype'):
+    	 		node=Systemtype.objects.get(title=node)
+    			
+            	 elif (node_type=='AttributeSpecification'):
+    			node=AttributeSpecification.objects.get(title=node)
+    			
+            	 elif (node_type=='RelationSpecification'):
+    			node=RelationSpecification.objects.get(title=node)
+    		 rdflib=link(node) 	 
+                 url_addr=link1(node)
+                 fstore_dump(url_addr) 
+            	 if(node_type=='Attribute'):
+    			node=Attribute.objects.get(title=node)
+    			rdflib = Namespace('http://sbox.gnowledge.org/gstudio/')
+              	
+            	 elif(node_type=='Relationtype' ):
+    			node=Relationtype.objects.get(title=node)
+    			rdflib = Namespace('http://sbox.gnowledge.org/gstudio/')
+                
+    	    	 elif(node_type=='Metatype'):
+    			node=Metatype.objects.get(title=node)
+    			rdflib = Namespace('http://sbox.gnowledge.org/gstudio/')
+                 url_addr='http://sbox.gnowledge.org/gstudio/'
+                 fstore_dump(url_addr) 
+            except:
+            	if(node_type=='Attribute'):
+                	rdflib= Namespace('http://sbox.gnowledge.org/gstudio/')
+    
+            	if(node_type=='Relationtype' ):
+                	rdflib= Namespace('http://sbox.gnowledge.org/gstudio/')
+                    
+            	if(node_type=='Metatype'):
+                	rdflib= Namespace('http://sbox.gnowledge.org/gstudio/')
+            	
+           
+    subject=str(node_dict['id'])
+    for key in node_dict:
+        if key not in exclusion_fields:
+           predicate=str(key)
+           pobject=str(node_dict[predicate])
+           graph.add((rdflib[subject], rdflib[predicate], Literal(pobject)))                        
+        
+    rdf_code=graph.serialize(format=notation)
+               #path to store the rdf in a file
+    
+    #x = os.path.join(os.path.dirname(__file__), 'rdffiles.rdf')
+    
+    graph.commit()
+    graph.close()
+    
+
+
+#provides the url address of particular node.
+def link(node):
+	node_url=node.get_absolute_url()
+    	site_addr= node.sites.all() 
+    	a=site_addr[0]
+    	host_name=a.name
+   
+    	link='http://'
+    	#Concatenating the above variables will give the url address.
+
+    	url_addr=link+host_name+node_url
+    	rdflib=Namespace(url_addr) 
+        return rdflib
+
+def link1(node):
+	node_url=node.get_absolute_url()
+    	site_addr= node.sites.all() 
+    	a=site_addr[0]
+    	host_name=a.name
+   
+    	link='http://'
+    	#Concatenating the above variables will give the url address.
+
+    	url_addr=link+host_name+node_url
+    	
+        return url_addr
+  
+def fstore_dump(url_addr):
+	
+	store = HTTP4Store('http://localhost:8067')
+	status = store.status()
+	response = store.add_from_uri('http://example.com/nodetypes/2012/05/25/mouse/')
+        return response
+
+    	
+	
+    	
+	
+	
+	
+       
+
+
+
+
+
diff --git a/gstudio/management/commands/dump_all_rdf.py b/gstudio/management/commands/dump_all_rdf.py
new file mode 100644
index 0000000..0b0097e
--- /dev/null
+++ b/gstudio/management/commands/dump_all_rdf.py
@@ -0,0 +1,186 @@
+
+import rdflib
+from rdflib.graph import ConjunctiveGraph as Graph
+from rdflib import plugin
+from rdflib.store import Store, NO_STORE, VALID_STORE
+from rdflib.namespace import Namespace
+from rdflib.term import Literal
+from rdflib.term import URIRef
+from tempfile import mkdtemp
+from gstudio.models import *
+from objectapp.models import *
+import settings
+import os.path
+from django.core.management.base import NoArgsCommand
+from django.core.management.base import BaseCommand
+
+
+def rdf_all(notation='xml'):
+    """
+    Funtion takes  title of node, and rdf notation.
+    """
+    valid_formats = ["xml", "n3", "ntriples", "trix"]
+    default_graph_uri = "http://gstudio.gnowledge.org/rdfstore"
+  
+    configString = "/var/tmp/rdfstore"
+
+    # Get the IOMemory plugin.
+    store = plugin.get('IOMemory', Store)('rdfstore')
+   
+
+
+    # Open previously created store, or create it if it doesn't exist yet
+    graph = Graph(store="IOMemory",
+               identifier = URIRef(default_graph_uri))
+    path = mkdtemp()
+    rt = graph.open(path, create=False)
+    if rt == NO_STORE:
+    
+        graph.open(path, create=True)
+    else:
+        assert rt == VALID_STORE, "The underlying store is corrupt"
+
+
+    # Now we'll add some triples to the graph & commit the changes
+    
+    graph.bind("gstudio", "http://gnowledge.org/")
+    exclusion_fields = ["id", "rght", "node_ptr_id", "image", "lft", "_state", "_altnames_cache", "_tags_cache", "nid_ptr_id", "_mptt_cached_fields"]
+
+    for node in NID.objects.all():
+        node_dict=node.ref.__dict__
+        node_type = node.reftype
+        try:
+            if (node_type=='Gbobject'):
+    	    	node=Gbobject.objects.get(title=node)
+    		rdflib=link(node)
+    	    elif (node_type=='None'):
+    		node=Gbobject.objects.get(title=node)
+    		rdflib=link(node)  
+		   
+            elif (node_type=='Process'):
+    		node=Gbobject.objects.get(title=node)
+    		rdflib=link(node)
+		  
+            elif (node_type=='System'):
+    		node=Gbobject.objects.get(title=node)
+    		rdflib=link(node)
+		
+            elif (node_type=='Objecttype'):
+    		node=Objecttype.objects.get(title=node)
+    		rdflib=link(node)
+
+    	    elif (node_type=='Attributetype'):
+    		node=Attributetype.objects.get(title=node)
+    	        rdflib=link(node)
+    	
+    	    elif (node_type=='Complement'):
+    		node=Complement.objects.get(title=node)
+    		rdflib=link(node)
+    
+            elif (node_type=='Union'):
+    	   	node=Union.objects.get(title=node)
+    		rdflib=link(node)
+    	
+            elif (node_type=='Intersection'):
+    		node=Intersection.objects.get(title=node)
+    		rdflib=link(node)
+    
+            elif (node_type=='Expression'):
+    		node=Expression.objects.get(title=node)
+    		rdflib=link(node)
+    
+            elif (node_type=='Processtype'):
+    		node=Processtype.objects.get(title=node)
+    		rdflib=link(node)
+    
+            elif (node_type=='Systemtype'):
+    	 	node=Systemtype.objects.get(title=node)
+    		rdflib=link(node)
+    
+            elif (node_type=='AttributeSpecification'):
+    		node=AttributeSpecification.objects.get(title=node)
+    		rdflib=link(node) 	 
+              
+            elif (node_type=='RelationSpecification'):
+    		node=RelationSpecification.objects.get(title=node)
+    		rdflib=link(node) 	 
+    
+            elif(node_type=='Attribute'):
+    		node=Attribute.objects.get(title=node)
+    		rdflib = Namespace('http://sbox.gnowledge.org/gstudio/')
+    
+            elif(node_type=='Relationtype' ):
+    		node=Relationtype.objects.get(title=node)
+    		rdflib = Namespace('http://sbox.gnowledge.org/gstudio/')
+    
+    	    elif(node_type=='Metatype'):
+    		node=Metatype.objects.get(title=node)
+    		rdflib = Namespace('http://sbox.gnowledge.org/gstudio/')
+        except:
+            if(node_type=='Attribute'):
+                node=Attribute.objects.get(title=node) 
+                rdflib= Namespace('http://sbox.gnowledge.org/gstudio/')
+    
+            if(node_type=='Relationtype' ):
+                node=Attribute.objects.get(title=node)
+                rdflib= Namespace('http://sbox.gnowledge.org/gstudio/')
+                    
+            if(node_type=='Metatype'):
+                node=Attribute.objects.get(title=node)
+                rdflib= Namespace('http://sbox.gnowledge.org/gstudio/')
+
+        subject=str(node_dict['id'])
+        for key in node_dict:
+            if key not in exclusion_fields:
+                predicate=str(key)
+                pobject=str(node_dict[predicate])
+                graph.add((rdflib[subject], rdflib[predicate], Literal(pobject)))                        
+        
+    rdf_code=graph.serialize(format=notation)
+               #path to store the rdf in a file
+    
+    x = os.path.join(os.path.dirname(__file__), 'rdffiles.rdf')
+    temp_path=str(x)
+    file = open(temp_path, 'w')
+    file.write(rdf_code)
+    file.close()
+    graph.commit()
+    print rdf_code
+    graph.close()
+    
+
+
+#provides the url address of particular node.
+def link(node):
+	node_url=node.get_absolute_url()
+    	site_addr= node.sites.all() 
+    	a=site_addr[0]
+    	host_name=a.name
+   
+    	link='http://'
+    	#Concatenating the above variables will give the url address.
+
+    	url_addr=link+host_name+node_url
+    	rdflib=Namespace(url_addr) 
+        return rdflib
+
+
+    	
+	
+	
+	
+       
+
+
+
+class Command(BaseCommand):
+	def handle(self,*args,**options):		
+                # verify the type of the node and pass the node to display the rdf accordingly.		
+	
+    		rdf_all(*args)
+
+
+
+
+
+
diff --git a/gstudio/management/commands/generate_all_rdf.py b/gstudio/management/commands/generate_all_rdf.py
new file mode 100644
index 0000000..a504a00
--- /dev/null
+++ b/gstudio/management/commands/generate_all_rdf.py
@@ -0,0 +1,183 @@
+
+import rdflib
+from rdflib.graph import ConjunctiveGraph as Graph
+from rdflib import plugin
+from rdflib.store import Store, NO_STORE, VALID_STORE
+from rdflib.namespace import Namespace
+from rdflib.term import Literal
+from rdflib.term import URIRef
+from tempfile import mkdtemp
+from gstudio.models import *
+from objectapp.models import *
+from django.core.management.base import NoArgsCommand
+from django.core.management.base import BaseCommand
+
+
+
+
+def rdf_description(name,notation='xml' ):
+    """
+    Funtion takes  title of node, and rdf notation.
+    """
+    valid_formats = ["xml", "n3", "ntriples", "trix"]
+    default_graph_uri = "http://gstudio.gnowledge.org/rdfstore"
+   # default_graph_uri = "http://example.com/"
+    configString = "/var/tmp/rdfstore"
+
+    # Get the IOMemory plugin.
+    store = plugin.get('IOMemory', Store)('rdfstore')
+   
+
+
+    # Open previously created store, or create it if it doesn't exist yet
+    graph = Graph(store="IOMemory",
+               identifier = URIRef(default_graph_uri))
+    path = mkdtemp()
+    rt = graph.open(path, create=False)
+    if rt == NO_STORE:
+    
+        graph.open(path, create=True)
+    else:
+        assert rt == VALID_STORE, "The underlying store is corrupt"
+
+
+    # Now we'll add some triples to the graph & commit the changes
+    #rdflib = Namespace('http://sbox.gnowledge.org/gstudio/')
+    graph.bind("gstudio", "http://gnowledge.org/")
+    exclusion_fields = ["id", "rght", "node_ptr_id", "image", "lft", "_state", "_altnames_cache", "_tags_cache", "nid_ptr_id", "_mptt_cached_fields"]
+
+    #verifies the type of node 
+    
+    
+    node=NID.objects.get(title=name)
+    node_type=node.reftype
+    
+    
+
+    if (node_type=='Gbobject' ):
+    	node=Gbobject.objects.get(title=name)
+    	rdflib=link(node)
+    elif (node_type=='None'):
+    	node=Gbobject.objects.get(title=name)
+    	rdflib=link(node)  
+		   
+    elif (node_type=='Processes'):
+    	node=Gbobject.objects.get(title=name)
+    	rdflib=link(node)
+		  
+    elif (node_type=='System'):
+    	node=Gbobject.objects.get(title=name)
+    	rdflib=link(node)
+		
+    elif (node_type=='Objecttype'):
+    	node=Objecttype.objects.get(title=name)
+    	rdflib=link(node)
+
+    elif (node_type=='Attributetype'):
+    	node=Attributetype.objects.get(title=name)
+        rdflib=link(node)
+    	
+    elif (node_type=='Complement'):
+    	node=Complement.objects.get(title=name)
+    	rdflib=link(node)
+    
+    elif (node_type=='Union'):
+    	node=Union.objects.get(title=name)
+    	rdflib=link(node)
+    	
+    elif (node_type=='Intersection'):
+    	node=Intersection.objects.get(title=name)
+    	rdflib=link(node)
+    
+    elif (node_type=='Expression'):
+    	node=Expression.objects.get(title=name)
+    	rdflib=link(node)
+    
+    elif (node_type=='Processtype'):
+    	node=Processtype.objects.get(title=name)
+    	rdflib=link(node)
+    
+    elif (node_type=='Systemtype'):
+    	node=Systemtype.objects.get(title=name)
+    	rdflib=link(node)
+    
+    elif (node_type=='AttributeSpecification'):
+    	node=AttributeSpecification.objects.get(title=name)
+    	rdflib=link(node) 	 
+    
+    elif (node_type=='RelationSpecification'):
+    	node=RelationSpecification.objects.get(title=name)
+    	rdflib=link(node) 	 
+    
+    elif(node_type=='Attribute'):
+    	node=Attribute.objects.get(title=name)
+    	rdflib = Namespace('http://sbox.gnowledge.org/gstudio/')
+    
+    elif(node_type=='Relationtype' ):
+    	node=Relationtype.objects.get(title=name)
+    	rdflib = Namespace('http://sbox.gnowledge.org/gstudio/')
+    
+    elif(node_type=='Metatype'):
+    	node=Metatype.objects.get(title=name)
+    	rdflib = Namespace('http://sbox.gnowledge.org/gstudio/')
+    else:
+	rdflib = Namespace('http://sbox.gnowledge.org/gstudio/')
+		
+        
+    
+    node_dict=node.__dict__
+
+    subject=str(node_dict['id'])
+    for key in node_dict:
+        if key not in exclusion_fields:
+            predicate=str(key)
+            pobject=str(node_dict[predicate])
+            graph.add((rdflib[subject], rdflib[predicate], Literal(pobject)))
+
+     
+    rdf_code=graph.serialize(format=notation)
+    
+    graph.commit()
+    print rdf_code
+    graph.close()
+   
+
+
+
+
+#provides the url address of particular node.
+def link(node):
+	node_url=node.get_absolute_url()
+    	site_addr= node.sites.all() 
+    	a=site_addr[0]
+    	host_name=a.name
+   
+    	link='http://'
+    	#Concatenating the above variables will give the url address.
+
+    	url_addr=link+host_name+node_url
+    	rdflib=Namespace(url_addr) 
+        return rdflib
+
+
+
+
+
+
+
+class Command(BaseCommand):
+	def handle(self,*args,**options):
+		
+                # verifies and pass  the node rdf_discription() to display the rdf accordingly.
+		
+		inr=0
+		
+		object_list=NID.objects.all()
+		for each in object_list:
+    			rdf_description(object_list[inr],*args)
+    			inr=inr+1
+
+
+
+
+
diff --git a/gstudio/management/commands/generate_rdf_xml.py b/gstudio/management/commands/generate_rdf_xml.py
new file mode 100644
index 0000000..645f4ff
--- /dev/null
+++ b/gstudio/management/commands/generate_rdf_xml.py
@@ -0,0 +1,167 @@
+from django.conf import settings
+from django.utils.encoding import smart_str
+from django.contrib.sites.models import Site
+from django.template.loader import render_to_string
+from django.core.management.base import NoArgsCommand
+from django.core.management.base import BaseCommand, CommandError
+from django.conf import settings
+
+from tagging.models import Tag
+
+from gstudio import __version__
+from gstudio.settings import PROTOCOL
+from gstudio.models import Nodetype
+from gstudio.models import Metatype
+
+import urllib
+import rdflib
+from rdflib.events import Dispatcher, Event
+from rdflib.graph import ConjunctiveGraph as Graph
+from rdflib import plugin
+from rdflib.store import Store, NO_STORE, VALID_STORE
+from rdflib.namespace import Namespace
+from rdflib.term import Literal
+from rdflib.term import URIRef
+from tempfile import mkdtemp
+from gstudio.models import *
+from objectapp.models import *
+from reversion.models import Version
+from optparse import make_option
+from pprint import pprint
+import httplib2
+from urllib import urlencode
+
+def get_nodetype():
+	"""
+    	returns the model the id belongs to.  
+    	"""    
+    	try:
+        	""" 
+        	ALGO:     get object id, go to version model, return for the given id.
+        	"""
+                name='student'
+        	node = NID.objects.get(title=str(name))
+        	# Retrieving only the relevant tupleset for the versioned objects
+        	vrs = Version.objects.filter(type=0 , object_id=node.id) 
+        	# Returned value is a list, so splice it .
+        	vrs =  vrs[0]
+
+    	except Error:
+        	return "The item was not found."
+        
+    	return vrs.object._meta.module_name   
+    
+
+def rdf_description(notation='xml' ):
+	"""
+    	Funtion takes  title of node, and rdf notation.
+    	"""
+	name='student'
+    	valid_formats = ["xml", "n3", "ntriples", "trix"]
+    	default_graph_uri = "http://gstudio.gnowledge.org/rdfstore"
+   	# default_graph_uri = "http://example.com/"
+    	configString = "/var/tmp/rdfstore"
+
+    	# Get the Sleepycat plugin.
+    	store = plugin.get('IOMemory', Store)('rdfstore')
+   
+
+
+    	# Open previously created store, or create it if it doesn't exist yet
+    	graph = Graph(store="IOMemory",
+              	identifier = URIRef(default_graph_uri))
+    	path = mkdtemp()
+    	rt = graph.open(path, create=False)
+    	if rt == NO_STORE:
+    #There is no underlying Sleepycat infrastructure, create it
+        	graph.open(path, create=True)
+    	else:
+        	assert rt == VALID_STORE, "The underlying store is corrupt"
+
+
+    # Now we'll add some triples to the graph & commit the changes
+   # rdflib = Namespace('http://sbox.gnowledge.org/gstudio/')
+    	graph.bind("gstudio", "http://gnowledge.org/")
+    	exclusion_fields = ["id", "rght", "node_ptr_id", "image", "lft", "_state", "_altnames_cache", "_tags_cache", "nid_ptr_id", "_mptt_cached_fields"]
+    	node_type=get_nodetype()
+    	if (node_type=='gbobject'):
+        	node=Gbobject.objects.get(title=name)
+    	elif (node_type=='objecttype'):
+       		node=Objecttype.objects.get(title=name)
+  	elif (node_type=='metatype'):
+        	node=Metatype.objects.get(title=name)
+    	elif (node_type=='attributetype'):
+       		node=Attributetype.objects.get(title=name)
+   	elif (node_type=='relationtype'):
+       		node=Relationtype.objects.get(title=name)
+  	elif (node_type=='attribute'):
+        	node=Attribute.objects.get(title=name)
+    	elif (node_type=='complement'):
+        	node=Complement.objects.get(title=name)
+    	elif (node_type=='union'):
+        	node=Union.objects.get(title=name)
+    	elif (node_type=='intersection'):
+        	node=Intersection.objects.get(title=name)
+    	elif (node_type=='expression'):
+        	node=Expression.objects.get(title=name)
+    	elif (node_type=='processtype'):
+        	node=Processtype.objects.get(title=name)
+    	elif (node_type=='systemtype'):
+        	node=Systemtype.objects.get(title=name)
+   
+   
+    
+   
+    
+    	node_url=node.get_absolute_url()
+    	site_add= node.sites.all() 
+    	a = site_add[0] 
+    	host_name =a.name
+    #host_name=name
+    	link='http://'
+    #Concatenating the above variables will give the url address.
+
+    	url_add=link+host_name+node_url
+    	rdflib = Namespace(url_add)
+ # node=Objecttype.objects.get(title=name)
+
+    	node_dict=node.__dict__
+
+    	subject=str(node_dict['id'])
+    	for key in node_dict:
+        	if key not in exclusion_fields:
+            		predicate=str(key)
+            		pobject=str(node_dict[predicate])
+            		graph.add((rdflib[subject], rdflib[predicate], Literal(pobject)))
+
+     
+    	rdf_code=graph.serialize(format=notation)
+
+   
+
+    
+
+
+    #graph = rdflib.Graph("IOMemory")
+    #graph.open("store", create=True)
+    #graph.parse(rdf_code)
+
+    # print out all the triples in the graph
+   # for subject, predicate, object in graph:
+      #  print subject, predicate, object
+   # store.add(self,(subject, predicate, object),context)
+     
+     
+    	graph.commit()
+    	print rdf_code
+    	graph.close()
+
+
+
+class Command(NoArgsCommand):
+    
+    def handle(self, **options):
+         
+
+    	 get_nodetype()
+	 rdf_description()