blob: 3ad53e8317087f93f46827d81ad1defb125d4b96 [file] [log] [blame]
import os
import logging
from dtest import Tester, create_ks, create_cf
logger = logging.getLogger(__name__)
class TestCFID(Tester):
def test_cfid(self):
""" Test through adding/dropping cf's that the path to sstables for each cf are unique
and formatted correctly
cluster = self.cluster
[node1] = cluster.nodelist()
session = self.patient_cql_connection(node1)
create_ks(session, 'ks', 1)
for x in range(0, 5):
create_cf(session, 'cf', gc_grace=0, key_type='int', columns={'c1': 'int'})
session.execute('insert into cf (key, c1) values (1,1)')
session.execute('insert into cf (key, c1) values (2,1)')
session.execute('drop table;')
# get a list of cf directories
cfs = os.listdir(node1.get_path() + "/data0/ks")
except OSError:"Path to sstables not valid.")
# check that there are 5 unique directories
assert len(cfs) == 5
# check that these are in fact column family directories
for dire in cfs:
assert dire[0:2] == 'cf'