mirror of
https://github.com/hanzoai/datastore-orm.git
synced 2026-09-30 21:40:30 +00:00
zeekay
dda3979851
This is our fork, so it should read like it. `import datastore_orm` instead of `from infi.clickhouse_orm import ...`: `infi` was the original vendor's org namespace, and carrying someone else's org name through every import in the consuming codebase is not a fork, it is a vendored copy that never got renamed. The `infi` namespace package is gone entirely (src/infi/__init__.py with it), the distribution is `datastore-orm`, and the metadata points at Hanzo rather than at the upstream repo and author. NOT renamed, deliberately: the migration history tables are still `infi_clickhouse_orm_migrations`. That name is persisted state — 448 rows in production key off it — so changing it is a data migration, not a rename. Doing it carelessly reproduces the exact failure this fork just hit, where a package rename orphaned the history and silently blocked every migration.
47 lines
1.6 KiB
Python
47 lines
1.6 KiB
Python
import unittest
|
|
from uuid import UUID
|
|
from datastore_orm.database import Database
|
|
from datastore_orm.fields import Int16Field, UUIDField
|
|
from datastore_orm.models import Model
|
|
from datastore_orm.engines import Memory
|
|
|
|
|
|
class UUIDFieldsTest(unittest.TestCase):
|
|
|
|
def setUp(self):
|
|
self.database = Database('test-db', log_statements=True)
|
|
|
|
def tearDown(self):
|
|
self.database.drop_database()
|
|
|
|
def test_uuid_field(self):
|
|
if self.database.server_version < (18, 1):
|
|
raise unittest.SkipTest('ClickHouse version too old')
|
|
# Create a model
|
|
class TestModel(Model):
|
|
i = Int16Field()
|
|
f = UUIDField()
|
|
engine = Memory()
|
|
self.database.create_table(TestModel)
|
|
# Check valid values (all values are the same UUID)
|
|
values = [
|
|
'12345678-1234-5678-1234-567812345678',
|
|
'{12345678-1234-5678-1234-567812345678}',
|
|
'12345678123456781234567812345678',
|
|
'urn:uuid:12345678-1234-5678-1234-567812345678',
|
|
b'\x12\x34\x56\x78'*4,
|
|
(0x12345678, 0x1234, 0x5678, 0x12, 0x34, 0x567812345678),
|
|
0x12345678123456781234567812345678,
|
|
UUID(int=0x12345678123456781234567812345678),
|
|
]
|
|
for index, value in enumerate(values):
|
|
rec = TestModel(i=index, f=value)
|
|
self.database.insert([rec])
|
|
for rec in TestModel.objects_in(self.database):
|
|
self.assertEqual(rec.f, UUID(values[0]))
|
|
# Check invalid values
|
|
for value in [None, 'zzz', -1, '123']:
|
|
with self.assertRaises(ValueError):
|
|
TestModel(i=1, f=value)
|
|
|