Fulltext for C and Python

Author: mnunberg1

README.md

@@ -268,3 +268,17 @@ C |
 Go |
 node.js
 
+## Full-Text (CBFT) Queries
+
+### Basic full-text example
+
+This should show basic functionality of the FTS feature. Search for 'hoppy'
+in `beer-sample`
+
+[C](c/fts-basic.cc) |
+[Python](python/fts-basic.py) |
+.NET |
+Go |
+node.js |
+Java |
+PHP

c/.gitignore

@@ -15,3 +15,4 @@ connecting-ssl
 *.dSYM
 subdoc-updating
 subdoc-retrieving
+fts-basic

c/Makefile

@@ -1,7 +1,7 @@
 PROGS=connecting updating retrieving query-create-index query-criteria \
 	  query-placeholders counter expiration \
 	  query-consistency cas durability bulk-get bulk-store \
-	  connecting-ssl subdoc-retrieving subdoc-updating
+	  connecting-ssl subdoc-retrieving subdoc-updating fts-basic
 
 all: $(PROGS)
 

c/fts-basic.cc

@@ -0,0 +1,43 @@
+#include <libcouchbase/couchbase.h>
+#include <libcouchbase/cbft.h>
+#include <cassert>
+#include <cstdio>
+#include <cstdlib>
+#include <string>
+
+static void rowCallback(lcb_t, int, const lcb_RESPFTS *resp)
+{
+    if (resp->rflags & LCB_RESP_F_FINAL) {
+        printf("Status: %d\n", resp->rc);
+        printf("Meta: %.*s\n", (int)resp->nrow, resp->row);
+        if (resp->htresp) {
+            printf("HTTP Response: %.*s\n", (int)resp->htresp->nbody, resp->htresp->body);
+        }
+    } else {
+        printf("Row: %.*s\n", (int)resp->nrow, resp->row);
+    }
+}
+
+int main(int, char **)
+{
+    lcb_t instance;
+    lcb_error_t rc = lcb_create(&instance, NULL);
+    assert(rc == LCB_SUCCESS);
+    lcb_cntl_string(instance, "detailed_errcodes", "true");
+    lcb_connect(instance);
+    lcb_wait(instance);
+    assert(lcb_get_bootstrap_status(instance) == LCB_SUCCESS);
+
+    // Be sure to include the indexName within the request payload
+    std::string encodedQuery(
+        "{\"query\":{\"match\":\"hoppy\"},\"indexName\":\"beer-search\",\"size\":10}");
+    lcb_CMDFTS cmd = { 0 };
+    cmd.callback = rowCallback;
+    cmd.query = encodedQuery.c_str();
+    cmd.nquery = encodedQuery.size();
+    rc = lcb_fts_query(instance, NULL, &cmd);
+    assert(rc == LCB_SUCCESS);
+
+    lcb_wait(instance);
+    lcb_destroy(instance);
+}

python/fts-basic.py

@@ -0,0 +1,18 @@
+#!/usr/bin/env python
+from __future__ import print_function
+from pprint import pprint
+
+from couchbase.bucket import Bucket
+import couchbase.fulltext as FT
+
+cb = Bucket()
+results = cb.search(
+        'travel-search',
+        FT.MatchQuery('part', fuzziness=0, field='content'),
+        limit=3,
+        facets={'countries': FT.TermFacet('country', limit=3)})
+
+for row in results:
+    pprint(row)
+
+print('Facet results:')