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

[TD-6199]<feature>:restore schemless test file before development

This commit is contained in:
Shenglian Zhou 2021-08-23 10:08:29 +08:00
parent 806451934b
commit 4714688f30
1 changed files with 36 additions and 36 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

72
tests/pytest/insert/schemalessInsert.py
View File

@ -1145,7 +1145,7 @@ class TDTestCase:
s_stb_d_tb_a_col_m_tag_list = self.genSqlList(stb_name=stb_name)[5] s_stb_d_tb_a_col_m_tag_list = self.genSqlList(stb_name=stb_name)[5]
self.multiThreadRun(self.genMultiThreadSeq(s_stb_d_tb_a_col_m_tag_list)) self.multiThreadRun(self.genMultiThreadSeq(s_stb_d_tb_a_col_m_tag_list))
tdSql.query(f"show tables;") tdSql.query(f"show tables;")
tdSql.checkRows(3) tdSql.checkRows(6)
def sStbDtbDdataAtMcInsertMultiThreadCheckCase(self): def sStbDtbDdataAtMcInsertMultiThreadCheckCase(self):
""" """
@ -1242,7 +1242,7 @@ class TDTestCase:
s_stb_d_tb_d_ts_a_col_m_tag_list = self.genSqlList(stb_name=stb_name)[11] s_stb_d_tb_d_ts_a_col_m_tag_list = self.genSqlList(stb_name=stb_name)[11]
self.multiThreadRun(self.genMultiThreadSeq(s_stb_d_tb_d_ts_a_col_m_tag_list)) self.multiThreadRun(self.genMultiThreadSeq(s_stb_d_tb_d_ts_a_col_m_tag_list))
tdSql.query(f"show tables;") tdSql.query(f"show tables;")
#tdSql.checkRows(6) tdSql.checkRows(6)
def test(self): def test(self):
input_sql1 = "rfasta,id=\"rfasta_1\",t0=true,t1=127i8,t2=32767i16,t3=2147483647i32,t4=9223372036854775807i64,t5=11.12345f32,t6=22.123456789f64,t7=\"ddzhiksj\",t8=L\"ncharTagValue\" c0=True,c1=127i8,c2=32767i16,c3=2147483647i32,c4=9223372036854775807i64,c5=11.12345f32,c6=22.123456789f64,c7=\"bnhwlgvj\",c8=L\"ncharTagValue\",c9=7u64 1626006933640000000ns" input_sql1 = "rfasta,id=\"rfasta_1\",t0=true,t1=127i8,t2=32767i16,t3=2147483647i32,t4=9223372036854775807i64,t5=11.12345f32,t6=22.123456789f64,t7=\"ddzhiksj\",t8=L\"ncharTagValue\" c0=True,c1=127i8,c2=32767i16,c3=2147483647i32,c4=9223372036854775807i64,c5=11.12345f32,c6=22.123456789f64,c7=\"bnhwlgvj\",c8=L\"ncharTagValue\",c9=7u64 1626006933640000000ns"
@ -1261,35 +1261,35 @@ class TDTestCase:
# self._conn.insert_lines([input_sql4]) # self._conn.insert_lines([input_sql4])
def runAll(self): def runAll(self):
# self.initCheckCase() self.initCheckCase()
# self.boolTypeCheckCase() self.boolTypeCheckCase()
# self.symbolsCheckCase() self.symbolsCheckCase()
# self.tsCheckCase() self.tsCheckCase()
# self.idSeqCheckCase() self.idSeqCheckCase()
# self.idUpperCheckCase() self.idUpperCheckCase()
# self.noIdCheckCase() self.noIdCheckCase()
# self.maxColTagCheckCase() self.maxColTagCheckCase()
# self.idIllegalNameCheckCase() self.idIllegalNameCheckCase()
# self.idStartWithNumCheckCase() self.idStartWithNumCheckCase()
# self.nowTsCheckCase() self.nowTsCheckCase()
# self.dateFormatTsCheckCase() self.dateFormatTsCheckCase()
# self.illegalTsCheckCase() self.illegalTsCheckCase()
# self.tagValueLengthCheckCase() self.tagValueLengthCheckCase()
# self.colValueLengthCheckCase() self.colValueLengthCheckCase()
# self.tagColIllegalValueCheckCase() self.tagColIllegalValueCheckCase()
# self.duplicateIdTagColInsertCheckCase() self.duplicateIdTagColInsertCheckCase()
# self.noIdStbExistCheckCase() self.noIdStbExistCheckCase()
# self.duplicateInsertExistCheckCase() self.duplicateInsertExistCheckCase()
# self.tagColBinaryNcharLengthCheckCase() self.tagColBinaryNcharLengthCheckCase()
# self.tagColAddDupIDCheckCase() self.tagColAddDupIDCheckCase()
# self.tagColAddCheckCase() self.tagColAddCheckCase()
# self.tagMd5Check() self.tagMd5Check()
# self.tagColBinaryMaxLengthCheckCase() self.tagColBinaryMaxLengthCheckCase()
# # self.tagColNcharMaxLengthCheckCase() # self.tagColNcharMaxLengthCheckCase()
# self.batchInsertCheckCase() self.batchInsertCheckCase()
# self.multiInsertCheckCase(1000) self.multiInsertCheckCase(1000)
# self.batchErrorInsertCheckCase() self.batchErrorInsertCheckCase()
# # MultiThreads # MultiThreads
self.stbInsertMultiThreadCheckCase() self.stbInsertMultiThreadCheckCase()
self.sStbStbDdataInsertMultiThreadCheckCase() self.sStbStbDdataInsertMultiThreadCheckCase()
self.sStbStbDdataAtcInsertMultiThreadCheckCase() self.sStbStbDdataAtcInsertMultiThreadCheckCase()
@ -1297,19 +1297,19 @@ class TDTestCase:
self.sStbDtbDdataInsertMultiThreadCheckCase() self.sStbDtbDdataInsertMultiThreadCheckCase()
# # ! concurrency conflict # # ! concurrency conflict
self.sStbDtbDdataAcMtInsertMultiThreadCheckCase() # self.sStbDtbDdataAcMtInsertMultiThreadCheckCase()
self.sStbDtbDdataAtMcInsertMultiThreadCheckCase() # self.sStbDtbDdataAtMcInsertMultiThreadCheckCase()
self.sStbStbDdataDtsInsertMultiThreadCheckCase() self.sStbStbDdataDtsInsertMultiThreadCheckCase()
# # ! concurrency conflict # # ! concurrency conflict
self.sStbStbDdataDtsAcMtInsertMultiThreadCheckCase() # self.sStbStbDdataDtsAcMtInsertMultiThreadCheckCase()
self.sStbStbDdataDtsAtMcInsertMultiThreadCheckCase() # self.sStbStbDdataDtsAtMcInsertMultiThreadCheckCase()
self.sStbDtbDdataDtsInsertMultiThreadCheckCase() self.sStbDtbDdataDtsInsertMultiThreadCheckCase()
# ! concurrency conflict # ! concurrency conflict
self.sStbDtbDdataDtsAcMtInsertMultiThreadCheckCase() # self.sStbDtbDdataDtsAcMtInsertMultiThreadCheckCase()