PYCBC-1676: Update couchbase query operations example to use blocking API

Change-Id: I610210a98475c1967859e4766d062621c17dc8ec
Reviewed-on: https://review.couchbase.org/c/couchbase-python-client/+/227602
Tested-by: Build Bot <build@couchbase.com>
Reviewed-by: Dimitris Christodoulou <dimitris.christodoulou@couchbase.com>

Author: thejcfactor

examples/couchbase/couchbase_query_operations.py

@@ -1,10 +1,10 @@
 import uuid
 
-from acouchbase.cluster import Cluster, get_event_loop
 from couchbase.auth import PasswordAuthenticator
 
 # **DEPRECATED**, import ALL options from `couchbase.options`
-from couchbase.cluster import (ClusterOptions,
+from couchbase.cluster import (Cluster,
+                               ClusterOptions,
                                QueryOptions,
                                QueryScanConsistency)
 from couchbase.exceptions import ParsingFailedException
@@ -15,9 +15,9 @@
 # from couchbase.n1ql import QueryScanConsistency
 
 
-async def main():
-    cluster = await Cluster.connect('couchbase://localhost',
-                                    ClusterOptions(PasswordAuthenticator('Administrator', 'password')))
+def main():
+    cluster = Cluster.connect('couchbase://localhost',
+                              ClusterOptions(PasswordAuthenticator('Administrator', 'password')))
     bucket = cluster.bucket("travel-sample")
     collection = bucket.default_collection()
 
@@ -26,7 +26,7 @@ async def main():
         result = cluster.query(
             "SELECT * FROM `travel-sample` LIMIT 10;", QueryOptions(metrics=True))
 
-        async for row in result.rows():
+        for row in result.rows():
             print(f'Found row: {row}')
 
         metrics = result.metadata().metrics()
@@ -39,35 +39,36 @@ async def main():
     # positional params
     q_str = "SELECT ts.* FROM `travel-sample` ts WHERE ts.`type`=$1 LIMIT 10"
     result = cluster.query(q_str, "hotel")
-    rows = [r async for r in result]
+    rows = [r for r in result]
 
     # positional params via QueryOptions
     result = cluster.query(q_str, QueryOptions(positional_parameters=["hotel"]))
-    rows = [r async for r in result]
+    rows = [r for r in result]
 
     # named params
     q_str = "SELECT ts.* FROM `travel-sample` ts WHERE ts.`type`=$doc_type LIMIT 10"
     result = cluster.query(q_str, doc_type='hotel')
-    rows = [r async for r in result]
+    rows = [r for r in result]
 
     # name params via QueryOptions
     result = cluster.query(q_str, QueryOptions(named_parameters={'doc_type': 'hotel'}))
-    rows = [r async for r in result]
+    rows = [r for r in result]
 
     # iterate over result/rows
     q_str = "SELECT ts.* FROM `travel-sample` ts WHERE ts.`type`='airline' LIMIT 10"
     result = cluster.query(q_str)
 
     # iterate over rows
-    async for row in result:
+    for row in result:
         # each row is an serialized JSON object
         name = row["name"]
         callsign = row["callsign"]
         print(f'Airline name: {name}, callsign: {callsign}')
 
     # query metrics
     result = cluster.query("SELECT 1=1", QueryOptions(metrics=True))
-    await result.execute()
+    # ignore results
+    result.execute()
 
     print("Execution time: {}".format(
         result.metadata().metrics().execution_time()))
@@ -76,7 +77,7 @@ async def main():
     result = cluster.query(
         "SELECT ts.* FROM `travel-sample` ts WHERE ts.`type`='airline' LIMIT 10",
         QueryOptions(scan_consistency=QueryScanConsistency.REQUEST_PLUS))
-    rows = [r async for r in result]
+    rows = [r for r in result]
 
     # Read your own writes
     new_airline = {
@@ -89,35 +90,34 @@ async def main():
         "type": "airline"
     }
 
-    res = await collection.upsert(
-        "airline_{}".format(new_airline["id"]), new_airline)
+    res = collection.upsert("airline_{}".format(new_airline["id"]), new_airline)
 
     ms = MutationState(res)
 
     result = cluster.query(
         "SELECT ts.* FROM `travel-sample` ts WHERE ts.`type`='airline' LIMIT 10",
         QueryOptions(consistent_with=ms))
-    rows = [r async for r in result]
+    rows = [r for r in result]
 
     # client context id
     result = cluster.query(
         "SELECT ts.* FROM `travel-sample` ts WHERE ts.`type`='hotel' LIMIT 10",
         QueryOptions(client_context_id="user-44{}".format(uuid.uuid4())))
-    rows = [r async for r in result]
+    rows = [r for r in result]
 
     # read only
     result = cluster.query(
         "SELECT ts.* FROM `travel-sample` ts WHERE ts.`type`='hotel' LIMIT 10",
         QueryOptions(read_only=True))
-    rows = [r async for r in result]
+    rows = [r for r in result]
 
     agent_scope = bucket.scope("inventory")
 
     result = agent_scope.query(
         "SELECT a.* FROM `airline` a WHERE a.country=$country LIMIT 10",
         country='France')
-    rows = [r async for r in result]
+    rows = [r for r in result]
+
 
 if __name__ == "__main__":
-    loop = get_event_loop()
-    loop.run_until_complete(main())
+    main()