xxq250
/
homework-jianmu
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

add flush test to composite primary key insert

This commit is contained in:
Chris Zhai 2024-04-12 10:57:46 +08:00
parent f5ac7d6e5b
commit 0241be8b08
1 changed files with 21 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

30
tests/system-test/1-insert/composite_primary_key_insert.py
View File

@ -102,6 +102,7 @@ class TDTestCase:
tdSql.execute(f"insert into {self.stable_name} (tbname, engine, ts, pk, c2) values('{table_name}', 1, {current_ts2}, 2, '5')", show=SHOW_LOG)
tdSql.execute(f"insert into {self.stable_name} (tbname, engine, ts, pk) values('{table_name}', 1, now + 2s, 2)", show=SHOW_LOG)
tdSql.execute(f"flush database {table_name}", show=SHOW_LOG)
tdSql.query(f'select * from {self.stable_name}')
tdSql.checkRows(6)
tdSql.query(f"select * from {self.stable_name} where engine = 1 and ts ={current_ts1}", show=SHOW_LOG)
@ -151,6 +152,7 @@ class TDTestCase:
tdSql.execute(f"create table {table_name} using {self.stable_name} tags(3)", show=SHOW_LOG)
tdSql.execute(f"insert into {table_name} file '{self.tdCsv.file}'", show=SHOW_LOG)
tdSql.execute(f"flush database {table_name}", show=SHOW_LOG)
tdSql.query(f'select * from {table_name}')
tdSql.checkRows(6)
tdSql.query(f"select * from {table_name} where engine=3 and ts='2024-03-29 16:55:42.572'", show=SHOW_LOG)
@ -224,6 +226,7 @@ class TDTestCase:
tdSql.execute(f"insert into {table_name} (ts, pk, c2) values({current_ts2}, 2, '5')", show=SHOW_LOG)
tdSql.execute(f"insert into {table_name} (ts, pk) values(now + 2s, 2)", show=SHOW_LOG)
tdSql.execute(f"flush database {table_name}", show=SHOW_LOG)
tdSql.query(f'select * from {table_name}')
tdSql.checkRows(6)
tdSql.query(f"select * from {table_name} where ts ={current_ts1}", show=SHOW_LOG)
@ -288,6 +291,7 @@ class TDTestCase:
table_name = f'{self.ntable_name}_1'
tdSql.execute(f"create table {table_name} using {self.stable_name} tags(3)", show=SHOW_LOG)
tdSql.error(f"insert into {table_name} file '{self.tdCsv.file}'", show=SHOW_LOG)
tdSql.execute(f"flush database {table_name}", show=SHOW_LOG)
tdSql.query(f'select * from {table_name}')
tdSql.checkRows(0)
self._check_select(table_name)
@ -339,6 +343,7 @@ class TDTestCase:
source_data = tdSql.queryResult
tdSql.execute(f"insert into dest_{self.ctable_name} select ts, pk, c2 from source_{self.ntable_name}", show=SHOW_LOG)
tdSql.execute(f"flush database {table_name}", show=SHOW_LOG)
tdSql.query(f'select * from dest_{self.ctable_name}')
dest_data = tdSql.queryResult
self._compare_table_data(source_data, dest_data, 3, 3)
@ -471,6 +476,8 @@ class TDTestCase:
except SchemalessError as errMsg:
tdSql.checkEqual(errMsg.msg == 'Can not insert data into table with primary key', True)
tdSql.execute(f"flush database {table_name}", show=SHOW_LOG)
def test_insert_values_special(self, dtype: LegalDataType):
# 4.insert into values without ts column
# drop tables
@ -520,6 +527,7 @@ class TDTestCase:
# # 5.3.insert value into normal table
tdSql.execute(f"create table {self.ntable_name} (ts timestamp, pk {dtype.value} primary key, c2 varchar(20))", show=SHOW_LOG)
tdSql.error(f"insert into {self.ntable_name} (ts, c2) values(now, '1')", show=SHOW_LOG)
tdSql.execute(f"flush database {table_name}", show=SHOW_LOG)
tdSql.query(f'select * from {self.ntable_name}')
tdSql.checkRows(0)
self._check_select(self.ntable_name)
@ -569,6 +577,7 @@ class TDTestCase:
f"{self.ctable_name}_3 using {self.stable_name} (engine) tags(3) values('2021-07-15 14:06:34.630', null, 500)"
tdSql.error(error_sql, show=SHOW_LOG)
tdSql.execute(f"flush database {table_name}", show=SHOW_LOG)
tdSql.query(f'select * from {self.stable_name}')
tdSql.checkRows(0)
self._check_select(self.stable_name)
@ -674,6 +683,7 @@ class TDTestCase:
f"{self.ntable_name} values('2021-07-14 14:06:34.630', 1, 300) ('2021-07-14 14:06:34.630', 2, 400) "
tdSql.error(error_sql, show=SHOW_LOG)
tdSql.execute(f"flush database {table_name}", show=SHOW_LOG)
tdSql.query(f'select * from {self.stable_name}')
tdSql.checkRows(0)
tdSql.query(f'select * from {self.ntable_name}')
@ -727,6 +737,7 @@ class TDTestCase:
stmt.execute()
tdSql.execute(f"flush database {table_name}", show=SHOW_LOG)
tdSql.query(f'select * from {self.stable_name}')
tdSql.checkRows(3)
self._check_select(self.stable_name)
@ -863,6 +874,7 @@ class TDTestCase:
tdSql.execute(f"insert into source_table values(now, 100, 1000)", show=SHOW_LOG)
tdSql.execute(f"insert into dest_table select * from source_table", show=SHOW_LOG)
tdSql.execute(f"flush database {table_name}", show=SHOW_LOG)
tdSql.query(f'select * from dest_table where c2=1000')
tdSql.checkRows(1)
tdSql.execute(f"delete from dest_table", show=SHOW_LOG)
@ -892,19 +904,19 @@ class TDTestCase:
self.prepare_db()
for date_type in LegalDataType.__members__.items():
tdLog.info(f'<dateType={date_type}>')
# 1.insert into value with pk - pass
tdLog.info('[1.insert into value with pk]')
self.test_insert_data(date_type[1], HasPK.YES)
# tdLog.info(f'<dateType={date_type}>')
# # 1.insert into value with pk - pass
# tdLog.info('[1.insert into value with pk]')
# self.test_insert_data(date_type[1], HasPK.YES)
# 2.insert into value without pk - pass
tdLog.info('[2.insert into value without pk]')
self.test_insert_data(date_type[1], HasPK.NO)
# # 2.insert into value without pk - pass
# tdLog.info('[2.insert into value without pk]')
# self.test_insert_data(date_type[1], HasPK.NO)
# 3.insert into illegal data - pass
tdLog.info('[3.insert into illegal data]')
# for illegal_data in IllegalData.__members__.items():
# self.test_insert_data_illegal(date_type[1], illegal_data[1])
for illegal_data in IllegalData.__members__.items():
self.test_insert_data_illegal(date_type[1], illegal_data[1])
# 4. insert into select - pass
tdLog.info('[4. insert into select]')