Handle creation of tables via SQL

Author: Brett Hazen

riak/codecs/ttb.py

@@ -154,7 +154,10 @@ def decode_timeseries(self, resp_ttb, tsobj,
         self.maybe_err_ttb(resp_ttb)
 
         resp_a = resp_ttb[0]
-        if resp_a == tsputresp_a:
+
+        if resp_ttb == tsqueryresp_a:
+            return tsobj
+        elif resp_a == tsputresp_a:
             return
         elif resp_a == tsgetresp_a or resp_a == tsqueryresp_a:
             resp_data = resp_ttb[1]
@@ -175,7 +178,7 @@ def decode_timeseries(self, resp_ttb, tsobj,
                 raise RiakError(
                     "Expected 3-tuple in response, got: {}".format(resp_data))
         else:
-            raise RiakError("Unknown TTB response type: {}".format(resp_a))
+            raise RiakError("Unknown TTB response type: {}".format(resp_ttb))
 
     def decode_timeseries_cols(self, cnames, ctypes):
         cnames = [bytes_to_str(cname) for cname in cnames]

riak/tests/test_timeseries_ttb.py

@@ -1,5 +1,7 @@
 # -*- coding: utf-8 -*-
 import datetime
+import random
+import string
 import logging
 import six
 import unittest
@@ -130,6 +132,24 @@ class TimeseriesTtbTests(IntegrationTestBase, unittest.TestCase):
     def setUpClass(cls):
         super(TimeseriesTtbTests, cls).setUpClass()
 
+    def test_query_that_creates_table_using_interpolation(self):
+        table = ''.join(
+            [random.choice(string.ascii_letters + string.digits)
+                for n in range(32)])
+        query = """CREATE TABLE test-{table} (
+            geohash varchar not null,
+            user varchar not null,
+            time timestamp not null,
+            weather varchar not null,
+            temperature double,
+            PRIMARY KEY((geohash, user, quantum(time, 15, m)),
+                geohash, user, time))
+        """
+        ts_obj = self.client.ts_query(table, query)
+        self.assertIsNotNone(ts_obj)
+        self.assertFalse(hasattr(ts_obj, 'ts_cols'))
+        self.assertIsNone(ts_obj.rows)
+
     def test_query_that_returns_table_description(self):
         fmt = 'DESCRIBE {table}'
         query = fmt.format(table=table_name)