MAPRDB-397, MAPRDB-459

.gitignore

@@ -0,0 +1,13 @@
+.project
+.classpath
+.checkstyle
+.settings/
+.idea/
+*.log
+*.lck
+*.iml
+target/
+*.DS_Store
+*.patch
+*~
+git.properties

Sample.py

@@ -0,0 +1,67 @@
+from entity.document.Document import Document
+from entity.document.DocumentStore import DocumentStore
+from entity.storage.ConnectionManager import ConnectionManager
+from entity.storage.Connection import Connection
+
+
+"""Example for customer may works with Python client"""
+"""Create a connection, get store, insert new document into store"""
+# create a connection by path:user@password
+connection = Connection(ConnectionManager.get_connection(url="ojai:mapr:user@password"))
+
+# Get a store and keep it as DocumentStore object
+store = DocumentStore(connection.get_store(store_name="/test_name"))
+
+# Json string or json map
+json_string = "json string"
+
+# Create new document from json_document
+new_document = connection.new_document(json_string)
+
+# Insert new document into the store
+store.insert_or_replace(new_document)
+
+# close
+store.close()
+connection.close()
+
+
+"""Create a connection, get store, find document by id"""
+# create a connection by path:user@password
+connection = Connection(ConnectionManager.get_connection(url="ojai:mapr:user@password"))
+
+# Get a store and keep it as DocumentStore object
+store = DocumentStore(connection.get_store(store_name="/test_name"))
+
+# Fetch document from store by id
+json_document = store.find_by_id("id_005")
+
+# close
+store.close()
+connection.close()
+
+
+"""Create a connection, get store, create a query, execute find query and got through document stream"""
+# create a connection by path:user@password
+connection = Connection(ConnectionManager.get_connection(url="ojai:mapr:user@password"))
+
+# Get a store and keep it as DocumentStore object
+store = DocumentStore(connection.get_store(store_name="/test_name"))
+
+# Build query
+query = connection.new_query().select("_id", "city").build()
+
+# fetch all document from store by query
+document_stream = store.find_query(query)
+
+# go to fetched records and pritnt them
+for document in document_stream.result:
+    print document
+
+
+# close
+store.close()
+connection.close()
+
+
+

entity/document/Document.py

@@ -0,0 +1,169 @@
+from abc import ABCMeta, abstractmethod
+
+
+class Document:
+    __metaclass__ = ABCMeta
+
+    @abstractmethod
+    def set_id(self, _id):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def get_id(self):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def get_id_string(self):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def get_id_binary(self):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def size(self):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def empty(self):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def set(self, field_path, value):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def set_boolean(self, field_path, value):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def set_byte(self, field_path, value):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def set_long(self, field_path, value):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def set_float(self, field_path, value):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def set_decimal(self, field_path, value):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def set_time(self, field_path, value):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def set_date(self, field_path, value):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def set_timestamp(self, field_path, value):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def set_interval(self, field_path, value):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def set_byte_array(self, field_path, value, offset=None, length=None):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def set_map(self, field_path, value):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def set_document(self, field_path, value):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def set_value_obj(self, field_path, value):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def set_array(self, field_path, values):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def set_null(self, field_path):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def delete(self, field_path):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def get_string(self, field_path):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def get_boolean(self, field_path):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def get_byte(self, field_path):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def get_int(self, field_path):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def get_long(self, field_path):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def get_float(self, field_path):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def get_double(self, field_path):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def get_decimal(self, field_path):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def get_time(self, field_path):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def get_date(self, field_path):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def get_timestamp(self, field_path):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def get_binary(self, field_path):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def get_interval(self, field_path):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def get_value(self, field_path):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def get_map(self, field_path):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def get_list(self, field_path):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def as_reader(self, field_path=None):
+        raise NotImplementedError("Should have implemented this")
+
+    @abstractmethod
+    def as_map(self):
+        raise NotImplementedError("Should have implemented this")