WIP on gh-105-unpack-binary: 0f95f28 Skip SQL tests if tarantool version < 2.0.0

Author: DifferentialOrange

test/suites/test_dml.py

@@ -4,10 +4,12 @@
 
 import sys
 import unittest
+
 import tarantool
 
 from .lib.tarantool_server import TarantoolServer
 
+
 class TestSuite_Request(unittest.TestCase):
     @classmethod
     def setUpClass(self):
@@ -31,17 +33,65 @@ def setUpClass(self):
             parts = {2, 'num', 3, 'str'},
             unique = false})
         """.replace('\n', ' '))
+
         self.space_created = self.adm("box.schema.create_space('space_2')")
         self.adm("""
         box.space['space_2']:create_index('primary', {
             type = 'hash',
             parts = {1, 'num'},
             unique = true})
         """.replace('\n', ' '))
+
+        self.adm("box.schema.create_space('space_str')")
+        self.adm("""
+        box.space['space_str']:create_index('primary', {
+            type = 'tree',
+            parts = {1, 'str'},
+            unique = true})
+        """.replace('\n', ' '))
+
+        self.adm("box.schema.create_space('space_varbin')")
+        self.adm("""
+        box.space['space_varbin']:create_index('primary', {
+            type = 'tree',
+            parts = {1, 'varbinary'},
+            unique = true})
+        """.replace('\n', ' '))
+        self.adm("""
+        buffer = require('buffer')
+        ffi = require('ffi')
+
+        function encode_bin(bytes)
+            local tmpbuf = buffer.ibuf()
+            local p = tmpbuf:alloc(3 + #bytes)
+            p[0] = 0x91
+            p[1] = 0xC4
+            p[2] = #bytes
+            for i, c in pairs(bytes) do
+                p[i + 3 - 1] = c
+            end
+            return tmpbuf
+        end
+
+        function bintuple_insert(space, bytes)
+            local tmpbuf = encode_bin(bytes)
+            ffi.cdef[[
+                int box_insert(uint32_t space_id, const char *tuple, const char *tuple_end, box_tuple_t **result);
+            ]]
+            ffi.C.box_insert(space.id, tmpbuf.rpos, tmpbuf.wpos, nil)
+        end
+        """)
         self.adm("json = require('json')")
         self.adm("fiber = require('fiber')")
         self.adm("uuid = require('uuid')")
 
+    @classmethod
+    def assertNotRaises(self, func, *args, **kwargs):
+        try:
+            func(*args, **kwargs)
+        except Exception as e:
+            self.fail(f'Function raised Exception: {repr(e)}')
+
     def setUp(self):
         # prevent a remote tarantool from clean our session
         if self.srv.is_started():
@@ -299,6 +349,42 @@ def test_12_update_fields(self):
             [[2, 'help', 7]]
         )
 
+    def test_13_string_insert_default_behavior(self):
+        self.assertNotRaises(self.con.insert, 'space_str', [ 'test_13_string_insert_default_behavior' ])
+
+    def test_14_string_select_default_behavior(self):
+        self.adm(r"box.space['space_str']:insert{test_14_string_select_default_behavior}")
+        # resp = self.con.select('space_str', ['test_14_string_select_default_behavior'])
+        # self.assertIsInstance(resp, str)
+        self.assertSequenceEqual(
+            self.con.select('space_str', ['test_14_string_select_default_behavior']),
+            [['test_14_string_select_default_behavior']])
+
+
+    # def test_14_utf_string_select_default_behavior(self):
+    #     self.assertNotRaises(self.con.insert, 'space_str', [ 'test_13_string_insert_default_behavior' ])
+
+    #     self.assertSequenceEqual(
+    #         self.con.insert('space_varbin', [ b'test_13_binary_default_behavior' ]),
+    #         [[ b'test_13_binary_default_behavior' ]])
+
+    # def test_14_string_select_default_behavior(self):
+    #     self.adm(r"""
+    #         bintuple_insert(box.space['space_varbin'], {0x13})
+    #     """)]
+    #     self.assertSequenceEqual(
+    #         self.con.insert('space_str', [ 'test_13_binary_default_behavior' ]), 
+    #         [[ 'test_13_binary_default_behavior' ]])
+
+    #     self.assertSequenceEqual(
+    #         self.con.insert('space_varbin', [ b'test_13_binary_default_behavior' ]),
+    #         [[ b'test_13_binary_default_behavior' ]])
+
+    # def test_14_binary_binary_mode_behavior(self):
+    #     self.adm(r"""
+    #         bintuple_insert(box.space['space_varbin'], {0x14})
+    #     """)
+
     @classmethod
     def tearDownClass(self):
         self.con.close()