Skip to content
体验新版
项目
组织
正在加载...
登录
切换导航
打开侧边栏
taosdata
TDengine
提交
5d9c3807
T
TDengine
项目概览
taosdata
/
TDengine
1 年多 前同步成功
通知
1185
Star
22016
Fork
4786
代码
文件
提交
分支
Tags
贡献者
分支图
Diff
Issue
1
列表
看板
标记
里程碑
合并请求
0
Wiki
0
Wiki
分析
仓库
DevOps
项目成员
Pages
T
TDengine
项目概览
项目概览
详情
发布
仓库
仓库
文件
提交
分支
标签
贡献者
分支图
比较
Issue
1
Issue
1
列表
看板
标记
里程碑
合并请求
0
合并请求
0
Pages
分析
分析
仓库分析
DevOps
Wiki
0
Wiki
成员
成员
收起侧边栏
关闭侧边栏
动态
分支图
创建新Issue
提交
Issue看板
提交
5d9c3807
编写于
7月 23, 2021
作者:
J
jiajingbin
浏览文件
操作
浏览文件
下载
电子邮件补丁
差异文件
save
上级
90ecf82d
变更
1
隐藏空白更改
内联
并排
Showing
1 changed file
with
16 addition
and
10 deletion
+16
-10
tests/pytest/insert/schemalessInsert.py
tests/pytest/insert/schemalessInsert.py
+16
-10
未找到文件。
tests/pytest/insert/schemalessInsert.py
浏览文件 @
5d9c3807
...
@@ -717,9 +717,11 @@ class TDTestCase:
...
@@ -717,9 +717,11 @@ class TDTestCase:
input_sql
=
f
'
{
stb_name
}
,t0=t c0=f,c1="
{
self
.
getLongName
(
16374
,
"letters"
)
}
",c2="
{
self
.
getLongName
(
16374
,
"letters"
)
}
",c3="
{
self
.
getLongName
(
16374
,
"letters"
)
}
",c4="
{
self
.
getLongName
(
12
,
"letters"
)
}
" 1626006833639000000ns'
input_sql
=
f
'
{
stb_name
}
,t0=t c0=f,c1="
{
self
.
getLongName
(
16374
,
"letters"
)
}
",c2="
{
self
.
getLongName
(
16374
,
"letters"
)
}
",c3="
{
self
.
getLongName
(
16374
,
"letters"
)
}
",c4="
{
self
.
getLongName
(
12
,
"letters"
)
}
" 1626006833639000000ns'
code
=
self
.
_conn
.
insertLines
([
input_sql
])
code
=
self
.
_conn
.
insertLines
([
input_sql
])
tdSql
.
checkEqual
(
code
,
0
)
tdSql
.
checkEqual
(
code
,
0
)
input_sql
=
f
'
{
stb_name
}
,t0=t c0=f,c1="
{
self
.
getLongName
(
16374
,
"letters"
)
}
",c2="
{
self
.
getLongName
(
16374
,
"letters"
)
}
",c3="
{
self
.
getLongName
(
16374
,
"letters"
)
}
",c4="
{
self
.
getLongName
(
13
,
"letters"
)
}
" 1626006833639000000ns'
# input_sql = f'{stb_name},t0=t c0=f,c1="{self.getLongName(16374, "letters")}",c2="{self.getLongName(16374, "letters")}",c3="{self.getLongName(16374, "letters")}",c4="{self.getLongName(13, "letters")}" 1626006833639000000ns'
code
=
self
.
_conn
.
insertLines
([
input_sql
])
# print(input_sql)
tdSql
.
checkNotEqual
(
code
,
0
)
# code = self._conn.insertLines([input_sql])
# print(code)
# tdSql.checkNotEqual(code, 0)
# ? tag nchar max is 16384, col+ts nchar max 49151
# ? tag nchar max is 16384, col+ts nchar max 49151
def
tagColNcharMaxLengthCheckCase
(
self
):
def
tagColNcharMaxLengthCheckCase
(
self
):
...
@@ -772,8 +774,7 @@ class TDTestCase:
...
@@ -772,8 +774,7 @@ class TDTestCase:
"""
"""
stb_name
=
self
.
getLongName
(
8
,
"letters"
)
stb_name
=
self
.
getLongName
(
8
,
"letters"
)
lines
=
[
"st123456,t1=3i64,t2=4f64,t3=
\"
t3
\"
c1=3i64,c3=L
\"
passit
\"
,c2=false,c4=4f64 1626006833639000000ns"
,
lines
=
[
"st123456,t1=3i64,t2=4f64,t3=
\"
t3
\"
c1=3i64,c3=L
\"
passit
\"
,c2=false,c4=4f64 1626006833639000000ns"
,
f
"
{
stb_name
}
,t2=5f64,t3=L
\"
ste
\"
c1=tRue,c2=4i64,c3=
\"
iam
\"
1626056811823316532ns"
,
f
"
{
stb_name
}
,t2=5f64,t3=L
\"
ste
\"
c1=tRue,c2=4i64,c3=
\"
iam
\"
1626056811823316532ns"
]
]
code
=
self
.
_conn
.
insertLines
(
lines
)
code
=
self
.
_conn
.
insertLines
(
lines
)
# tdSql.checkEqual(code, 0)
# tdSql.checkEqual(code, 0)
...
@@ -781,17 +782,22 @@ class TDTestCase:
...
@@ -781,17 +782,22 @@ class TDTestCase:
"""
"""
stb --> supertable
stb --> supertable
tb --> table
tb --> table
ts --> timestamp
ts --> timestamp
, same default
col --> column
col --> column
, same default
tag --> tag
tag --> tag
, same default
d --> different
d --> different
s --> same
s --> same
a --> add
m --> minus
"""
"""
d_stb_d_tb_list
=
list
()
d_stb_d_tb_list
=
list
()
s_stb_s_tb_list
=
list
()
s_stb_s_tb_a_col_a_tag_list
=
list
()
for
i
in
range
(
count
):
for
i
in
range
(
count
):
d_stb_d_tb_list
.
append
(
self
.
genFullTypeSql
(
t0
=
"f"
,
c0
=
"f"
))
d_stb_d_tb_list
.
append
(
self
.
genFullTypeSql
(
t0
=
"f"
,
c0
=
"f"
))
s_stb_s_tb_list
.
append
(
self
.
genFullTypeSql
(
t7
=
f
'"
{
self
.
getLongName
(
8
,
"letters"
)
}
"'
,
c7
=
f
'
{
self
.
getLongName
(
8
,
"letters"
)
}
"'
,
cl_add_tag
=
True
))
return
d_stb_d_tb_list
,
s_stb_s_tb_a_col_a_tag_list
.
append
(
self
.
genFullTypeSql
(
t7
=
f
'"
{
self
.
getLongName
(
8
,
"letters"
)
}
"'
,
c7
=
f
'
{
self
.
getLongName
(
8
,
"letters"
)
}
"'
))
return
d_stb_d_tb_list
,
s_stb_s_tb_list
,
s_stb_s_tb_a_col_a_tag_list
def
genMultiThreadSeq
(
self
,
sql_list
):
def
genMultiThreadSeq
(
self
,
sql_list
):
tlist
=
list
()
tlist
=
list
()
...
...
编辑
预览
Markdown
is supported
0%
请重试
或
添加新附件
.
添加附件
取消
You are about to add
0
people
to the discussion. Proceed with caution.
先完成此消息的编辑!
取消
想要评论请
注册
或
登录