Merge branch 'master' into fix_textfield

Author: gkorland

API.md

@@ -195,6 +195,41 @@ Add a single document to the index.
              NOTE: Geo points shoule be encoded as strings of "lon,lat"
 
 
+### aggregate
+```py
+
+def aggregate(self, query)
+
+```
+
+
+
+Issue an aggregation query
+
+### Parameters
+
+**query**: This can be either an `AggeregateRequest`, or a `Cursor`
+
+An `AggregateResult` object is returned. You can access the rows from its
+`rows` property, which will always yield the rows of the result
+
+
+### alter\_schema\_add
+```py
+
+def alter_schema_add(self, fields)
+
+```
+
+
+
+Alter the existing search index by adding new fields. The index must already exist.
+
+### Parameters:
+
+- **fields**: a list of Field objects to add for the index
+
+
 ### batch\_indexer
 ```py
 

redisearch/client.py

@@ -84,13 +84,12 @@ class TagField(Field):
     See http://redisearch.io/Tags/
     """
     def __init__(self, name, separator = ',', no_index=False):
-        Field.__init__(self, name, Field.TAG)
-        if separator != ',':
-            self.args.append(Field.SEPARATOR)
-            self.args.append(separator)
+        args = [Field.TAG, Field.SEPARATOR, separator]
 
         if no_index:
-            self.args.append(Field.NOINDEX)
+            args.append(Field.NOINDEX)
+
+        Field.__init__(self, name, *args)
 
 
 class Client(object):
@@ -102,6 +101,7 @@ class Client(object):
     NUMERIC = 'NUMERIC'
 
     CREATE_CMD = 'FT.CREATE'
+    ALTER_CMD = 'FT.ALTER'
     SEARCH_CMD = 'FT.SEARCH'
     ADD_CMD = 'FT.ADD'
     DROP_CMD = 'FT.DROP'
@@ -200,6 +200,21 @@ def create_index(self, fields, no_term_offsets=False,
 
         return self.redis.execute_command(*args)
 
+    def alter_schema_add(self, fields):
+        """
+        Alter the existing search index by adding new fields. The index must already exist.
+
+        ### Parameters:
+
+        - **fields**: a list of Field objects to add for the index
+        """
+
+        args = [self.ALTER_CMD, self.index_name, 'SCHEMA', 'ADD']
+
+        args += list(itertools.chain(*(f.redis_args() for f in fields)))
+
+        return self.redis.execute_command(*args)
+
     def drop_index(self):
         """
         Drop the index if it exists
@@ -367,4 +382,4 @@ def aggregate(self, query):
             rows = raw[1:]
 
         res = AggregateResult(rows, cursor, schema)
-        return res
+        return res

test/test.py

@@ -510,6 +510,30 @@ def testTextFieldSortableNostem(self):
             self.assertIn(b'SORTABLE', response['fields'][0])
             self.assertIn(b'NOSTEM', response['fields'][0])
 
+    def testAlterSchemaAdd(self):
+        conn = self.redis()
+
+        with conn as r:
+            # Creating a client with a given index name
+            client = Client('alterIdx', port=conn.port)
+            client.redis.flushdb()
+
+            # Creating the index definition and schema
+            client.create_index((TextField('title'),))
+
+            # Using alter to add a field
+            client.alter_schema_add((TextField('body'),))
+
+            # Indexing a document
+            client.add_document('doc1', title = 'MyTitle', body = 'Some content only in the body')
+
+            # Searching with parameter only in the body (the added field)
+            q = Query("only in the body")
+
+            # Ensure we find the result searching on the added body field
+            res = client.search(q)
+            self.assertEqual(1, res.total)
+
 if __name__ == '__main__':
 
     unittest.main()