Skip to content

Commit 01c12fa

Browse files
committed
add test
1 parent e2e2a3a commit 01c12fa

File tree

1 file changed

+50
-0
lines changed

1 file changed

+50
-0
lines changed

tests/scheme/scheme_test.py

Lines changed: 50 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1,4 +1,5 @@
11
import typing
2+
import pytest
23

34
import ydb
45

@@ -25,3 +26,52 @@ def test_tables(self, driver_sync: ydb.Driver, database: str, table_name: str, c
2526

2627
assert has_column_table
2728
assert has_row_table
29+
30+
31+
@pytest.mark.parametrize(
32+
[
33+
ydb.scheme.SchemeEntryType.TYPE_UNSPECIFIED,
34+
ydb.scheme.SchemeEntryType.DIRECTORY,
35+
ydb.scheme.SchemeEntryType.TABLE,
36+
ydb.scheme.SchemeEntryType.PERS_QUEUE_GROUP,
37+
ydb.scheme.SchemeEntryType.DATABASE,
38+
ydb.scheme.SchemeEntryType.RTMR_VOLUME,
39+
ydb.scheme.SchemeEntryType.BLOCK_STORE_VOLUME,
40+
ydb.scheme.SchemeEntryType.COORDINATION_NODE,
41+
ydb.scheme.SchemeEntryType.COLUMN_STORE,
42+
ydb.scheme.SchemeEntryType.COLUMN_TABLE,
43+
ydb.scheme.SchemeEntryType.SEQUENCE,
44+
ydb.scheme.SchemeEntryType.REPLICATION,
45+
ydb.scheme.SchemeEntryType.TOPIC,
46+
ydb.scheme.SchemeEntryType.EXTERNAL_TABLE,
47+
ydb.scheme.SchemeEntryType.EXTERNAL_DATA_SOURCE,
48+
ydb.scheme.SchemeEntryType.VIEW,
49+
ydb.scheme.SchemeEntryType.RESOURCE_POOL,
50+
],
51+
)
52+
def test_scheme_entry(self, scheme_entry_type):
53+
from ydb.scheme import SchemeEntryType as et
54+
55+
scheme_entry = ydb.scheme.SchemeEntry(
56+
effective_permissions=None,
57+
kwargs=None,
58+
name="example",
59+
owner=None,
60+
permissions=None,
61+
size_bytes=42,
62+
type=scheme_entry_type,
63+
)
64+
65+
assert scheme_entry.is_table() == (scheme_entry_type in (et.TABLE,))
66+
assert scheme_entry.is_any_table() == (scheme_entry_type in (et.TABLE, et.COLUMN_TABLE))
67+
assert scheme_entry.is_column_table() == (scheme_entry_type in (et.COLUMN_TABLE,))
68+
assert scheme_entry.is_column_store() == (scheme_entry_type in (et.COLUMN_STORE,))
69+
assert scheme_entry.is_row_table() == (scheme_entry_type in (et.TABLE,))
70+
assert scheme_entry.is_directory() == (scheme_entry_type in (et.DIRECTORY,))
71+
assert scheme_entry.is_database() == (scheme_entry_type in (et.DATABASE,))
72+
assert scheme_entry.is_coordination_node() == (scheme_entry_type in (et.COORDINATION_NODE,))
73+
assert scheme_entry.is_directory_or_database() == (scheme_entry_type in (et.DIRECTORY, et.DATABASE))
74+
assert scheme_entry.is_external_table() == (scheme_entry_type in (et.EXTERNAL_TABLE,))
75+
assert scheme_entry.is_external_data_source() == (scheme_entry_type in (et.EXTERNAL_DATA_SOURCE,))
76+
assert scheme_entry.is_view() == (scheme_entry_type in (et.VIEW,))
77+
assert scheme_entry.is_resource_pool() == (scheme_entry_type in (et.RESOURCE_POOL,))

0 commit comments

Comments
 (0)