finish stmt2 get fiels test
This commit is contained in:
parent
0d1a99d7d0
commit
69aac6d778
|
@ -103,68 +103,12 @@ void do_query(TAOS* taos, const char* sql) {
|
||||||
|
|
||||||
// printf("=================error test===================\n");
|
// printf("=================error test===================\n");
|
||||||
|
|
||||||
// // case 14 : INSERT INTO db.d0 using db.stb values(?,?)
|
|
||||||
// // none para for ctbname
|
|
||||||
// sql = "INSERT INTO db.d0 using db.stb values(?,?)";
|
|
||||||
// printf("case 14 (no tags error): %s\n", sql);
|
|
||||||
// getFields(taos, sql);
|
|
||||||
|
|
||||||
// // case 15 : insert into db.stb(t1,t2,tbname) values(?,?,?)
|
|
||||||
// // no value
|
|
||||||
// sql = "insert into db.stb(t1,t2,tbname) values(?,?,?)";
|
|
||||||
// printf("case 15 (no PK error): %s\n", sql);
|
|
||||||
// getFields(taos, sql);
|
|
||||||
|
|
||||||
// // case 16 : insert into db.stb(ts,b,tbname) values(?,?,?,?,?)
|
|
||||||
// // wrong para nums
|
|
||||||
// sql = "insert into db.stb(ts,b,tbname) values(?,?,?,?,?)";
|
|
||||||
// printf("case 16 (wrong para nums): %s\n", sql);
|
|
||||||
// getFields(taos, sql);
|
|
||||||
|
|
||||||
// // case 17 : insert into db.? values(?,?)
|
|
||||||
// // normal table must have tbnam
|
|
||||||
// sql = "insert into db.? values(?,?)";
|
|
||||||
// printf("case 17 (normal table must have tbname): %s\n", sql);
|
|
||||||
// getFields(taos, sql);
|
|
||||||
|
|
||||||
// // case 18 : INSERT INTO db.stb(t1,t2,ts,b) values(?,?,?,?)
|
|
||||||
// // no tbname error
|
|
||||||
// sql = "INSERT INTO db.stb(t1,t2,ts,b) values(?,?,?,?)";
|
|
||||||
// printf("case 18 (no tbname error): %s\n", sql);
|
|
||||||
// getFields(taos, sql);
|
|
||||||
|
|
||||||
// // case 19 : insert into db.ntb(nts,ni) values(?,?,?,?,?)
|
|
||||||
// // wrong para nums
|
|
||||||
// sql = "insert into ntb(nts,ni) values(?,?,?,?,?)";
|
|
||||||
// printf("case 19 : %s\n", sql);
|
|
||||||
// getFields(taos, sql);
|
|
||||||
|
|
||||||
// // case 20 : insert into db.stb(t1,t2,ts,b,tbname) values(*,*,*,*,*)
|
|
||||||
// // wrong simbol
|
|
||||||
// sql = "insert into db.stb(t1,t2,ts,b,tbname) values(*,*,*,*,*)";
|
|
||||||
// printf("=================normal test===================\n");
|
|
||||||
// printf("case 20 : %s\n", sql);
|
|
||||||
// getFields(taos, sql);
|
|
||||||
|
|
||||||
// // case 21 : INSERT INTO ! using db.stb TAGS(?,?) VALUES(?,?)
|
|
||||||
// // wrong simbol
|
|
||||||
// sql = "insert into ! using db.stb tags(?, ?) values(?,?)";
|
|
||||||
// printf("case 21 : %s\n", sql);
|
|
||||||
// getFields(taos, sql);
|
|
||||||
|
|
||||||
// // case 22 : INSERT INTO ! using db.stb TAGS(?,?) VALUES(?,?)
|
// // case 22 : INSERT INTO ! using db.stb TAGS(?,?) VALUES(?,?)
|
||||||
// // wrong tbname
|
// // wrong tbname
|
||||||
// sql = "insert into db.stb values(?,?)";
|
// sql = "insert into db.stb values(?,?)";
|
||||||
// printf("case 22 : %s\n", sql);
|
// printf("case 22 : %s\n", sql);
|
||||||
// getFields(taos, sql);
|
// getFields(taos, sql);
|
||||||
|
|
||||||
// // case 23 : select * from ? where ts = ?
|
|
||||||
// // wrong query type
|
|
||||||
// sql = "select * from ? where ts = ?";
|
|
||||||
// printf("case 23 : %s\n", sql);
|
|
||||||
// getQueryFields(taos, sql);
|
|
||||||
// }
|
|
||||||
|
|
||||||
} // namespace
|
} // namespace
|
||||||
|
|
||||||
int main(int argc, char** argv) {
|
int main(int argc, char** argv) {
|
||||||
|
@ -229,13 +173,13 @@ TEST(stmt2Case, insert_stb_get_fields_Test) {
|
||||||
getFieldsSuccess(taos, sql, expectedFields, 5);
|
getFieldsSuccess(taos, sql, expectedFields, 5);
|
||||||
}
|
}
|
||||||
|
|
||||||
// case 4 : random order
|
// case 4 : random order 2
|
||||||
{
|
{
|
||||||
const char* sql = "insert into db.stb(tbname,ts,t2,b,t1) values(?,?,?,?,?)";
|
const char* sql = "insert into db.stb(ts,tbname,b,t2,t1) values(?,?,?,?,?)";
|
||||||
TAOS_FIELD_ALL expectedFields[5] = {{"tbname", TSDB_DATA_TYPE_BINARY, 0, 0, 271, TAOS_FIELD_TBNAME},
|
TAOS_FIELD_ALL expectedFields[5] = {{"ts", TSDB_DATA_TYPE_TIMESTAMP, 2, 0, 8, TAOS_FIELD_COL},
|
||||||
{"ts", TSDB_DATA_TYPE_TIMESTAMP, 2, 0, 8, TAOS_FIELD_COL},
|
{"tbname", TSDB_DATA_TYPE_BINARY, 0, 0, 271, TAOS_FIELD_TBNAME},
|
||||||
{"t2", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_TAG},
|
|
||||||
{"b", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_COL},
|
{"b", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_COL},
|
||||||
|
{"t2", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_TAG},
|
||||||
{"t1", TSDB_DATA_TYPE_INT, 0, 0, 4, TAOS_FIELD_TAG}};
|
{"t1", TSDB_DATA_TYPE_INT, 0, 0, 4, TAOS_FIELD_TAG}};
|
||||||
printf("case 4 : %s\n", sql);
|
printf("case 4 : %s\n", sql);
|
||||||
getFieldsSuccess(taos, sql, expectedFields, 5);
|
getFieldsSuccess(taos, sql, expectedFields, 5);
|
||||||
|
@ -275,6 +219,50 @@ TEST(stmt2Case, insert_stb_get_fields_Test) {
|
||||||
getFieldsSuccess(taos, sql, expectedFields, 2);
|
getFieldsSuccess(taos, sql, expectedFields, 2);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// case 8 : test all types
|
||||||
|
{
|
||||||
|
const char* sql =
|
||||||
|
"insert into "
|
||||||
|
"all_stb(tbname,tts,tv1,tv2,tv3,tv4,tv5,tv6,tv7,tv8,tv9,tv10,tv11,tv12,tv13,tv14,tv15,ts,v1,v2,v3,v4,v5,v6,v7,"
|
||||||
|
"v8,v9,v10,"
|
||||||
|
"v11,v12,v13,v14,v15) values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
|
||||||
|
TAOS_FIELD_ALL expectedFields[33] = {{"tbname", TSDB_DATA_TYPE_BINARY, 0, 0, 271, TAOS_FIELD_TBNAME},
|
||||||
|
{"tts", TSDB_DATA_TYPE_TIMESTAMP, 2, 0, 8, TAOS_FIELD_TAG},
|
||||||
|
{"tv1", TSDB_DATA_TYPE_BOOL, 0, 0, 1, TAOS_FIELD_TAG},
|
||||||
|
{"tv2", TSDB_DATA_TYPE_TINYINT, 0, 0, 1, TAOS_FIELD_TAG},
|
||||||
|
{"tv3", TSDB_DATA_TYPE_SMALLINT, 0, 0, 2, TAOS_FIELD_TAG},
|
||||||
|
{"tv4", TSDB_DATA_TYPE_INT, 0, 0, 4, TAOS_FIELD_TAG},
|
||||||
|
{"tv5", TSDB_DATA_TYPE_BIGINT, 0, 0, 8, TAOS_FIELD_TAG},
|
||||||
|
{"tv6", TSDB_DATA_TYPE_UTINYINT, 0, 0, 1, TAOS_FIELD_TAG},
|
||||||
|
{"tv7", TSDB_DATA_TYPE_USMALLINT, 0, 0, 2, TAOS_FIELD_TAG},
|
||||||
|
{"tv8", TSDB_DATA_TYPE_UINT, 0, 0, 4, TAOS_FIELD_TAG},
|
||||||
|
{"tv9", TSDB_DATA_TYPE_UBIGINT, 0, 0, 8, TAOS_FIELD_TAG},
|
||||||
|
{"tv10", TSDB_DATA_TYPE_FLOAT, 0, 0, 4, TAOS_FIELD_TAG},
|
||||||
|
{"tv11", TSDB_DATA_TYPE_DOUBLE, 0, 0, 8, TAOS_FIELD_TAG},
|
||||||
|
{"tv12", TSDB_DATA_TYPE_VARCHAR, 0, 0, 22, TAOS_FIELD_TAG},
|
||||||
|
{"tv13", TSDB_DATA_TYPE_VARBINARY, 0, 0, 22, TAOS_FIELD_TAG},
|
||||||
|
{"tv14", TSDB_DATA_TYPE_GEOMETRY, 0, 0, 102, TAOS_FIELD_TAG},
|
||||||
|
{"tv15", TSDB_DATA_TYPE_NCHAR, 0, 0, 82, TAOS_FIELD_TAG},
|
||||||
|
{"ts", TSDB_DATA_TYPE_TIMESTAMP, 2, 0, 8, TAOS_FIELD_COL},
|
||||||
|
{"v1", TSDB_DATA_TYPE_BOOL, 0, 0, 1, TAOS_FIELD_COL},
|
||||||
|
{"v2", TSDB_DATA_TYPE_TINYINT, 0, 0, 1, TAOS_FIELD_COL},
|
||||||
|
{"v3", TSDB_DATA_TYPE_SMALLINT, 0, 0, 2, TAOS_FIELD_COL},
|
||||||
|
{"v4", TSDB_DATA_TYPE_INT, 0, 0, 4, TAOS_FIELD_COL},
|
||||||
|
{"v5", TSDB_DATA_TYPE_BIGINT, 0, 0, 8, TAOS_FIELD_COL},
|
||||||
|
{"v6", TSDB_DATA_TYPE_UTINYINT, 0, 0, 1, TAOS_FIELD_COL},
|
||||||
|
{"v7", TSDB_DATA_TYPE_USMALLINT, 0, 0, 2, TAOS_FIELD_COL},
|
||||||
|
{"v8", TSDB_DATA_TYPE_UINT, 0, 0, 4, TAOS_FIELD_COL},
|
||||||
|
{"v9", TSDB_DATA_TYPE_UBIGINT, 0, 0, 8, TAOS_FIELD_COL},
|
||||||
|
{"v10", TSDB_DATA_TYPE_FLOAT, 0, 0, 4, TAOS_FIELD_COL},
|
||||||
|
{"v11", TSDB_DATA_TYPE_DOUBLE, 0, 0, 8, TAOS_FIELD_COL},
|
||||||
|
{"v12", TSDB_DATA_TYPE_VARCHAR, 0, 0, 22, TAOS_FIELD_COL},
|
||||||
|
{"v13", TSDB_DATA_TYPE_VARBINARY, 0, 0, 22, TAOS_FIELD_COL},
|
||||||
|
{"v14", TSDB_DATA_TYPE_GEOMETRY, 0, 0, 102, TAOS_FIELD_COL},
|
||||||
|
{"v15", TSDB_DATA_TYPE_NCHAR, 0, 0, 82, TAOS_FIELD_COL}};
|
||||||
|
printf("case 8 : %s\n", sql);
|
||||||
|
getFieldsSuccess(taos, sql, expectedFields, 33);
|
||||||
|
}
|
||||||
|
|
||||||
// not support case
|
// not support case
|
||||||
printf("not support case \n");
|
printf("not support case \n");
|
||||||
|
|
||||||
|
@ -285,32 +273,60 @@ TEST(stmt2Case, insert_stb_get_fields_Test) {
|
||||||
// getFieldsError(taos, sql, TSDB_CODE_TSC_INVALID_OPERATION);
|
// getFieldsError(taos, sql, TSDB_CODE_TSC_INVALID_OPERATION);
|
||||||
// }
|
// }
|
||||||
|
|
||||||
// case 7 : no pk
|
// case 2 : no pk
|
||||||
{
|
{
|
||||||
const char* sql = "insert into db.stb(b,tbname) values(?,?)";
|
const char* sql = "insert into db.stb(b,tbname) values(?,?)";
|
||||||
|
printf("case 2 : %s\n", sql);
|
||||||
|
getFieldsError(taos, sql, TSDB_CODE_TSC_INVALID_OPERATION);
|
||||||
|
}
|
||||||
|
|
||||||
|
// case 3 : no tbname and tag(not support bind)
|
||||||
|
{
|
||||||
|
const char* sql = "insert into db.stb(ts,b) values(?,?)";
|
||||||
|
printf("case 3 : %s\n", sql);
|
||||||
|
getFieldsError(taos, sql, TSDB_CODE_TSC_INVALID_OPERATION);
|
||||||
|
}
|
||||||
|
|
||||||
|
// case 4 : no col and tag(not support bind)
|
||||||
|
{
|
||||||
|
const char* sql = "insert into db.stb(tbname) values(?)";
|
||||||
|
printf("case 4 : %s\n", sql);
|
||||||
|
getFieldsError(taos, sql, TSDB_CODE_TSC_INVALID_OPERATION);
|
||||||
|
}
|
||||||
|
|
||||||
|
// case 5 : no field name
|
||||||
|
{
|
||||||
|
const char* sql = "insert into db.stb(?,?,?,?,?)";
|
||||||
|
printf("case 5 : %s\n", sql);
|
||||||
|
getFieldsError(taos, sql, TSDB_CODE_PAR_SYNTAX_ERROR);
|
||||||
|
}
|
||||||
|
|
||||||
|
// case 6 : test super table not exist
|
||||||
|
{
|
||||||
|
const char* sql = "insert into db.nstb(?,?,?,?,?)";
|
||||||
|
printf("case 6 : %s\n", sql);
|
||||||
|
getFieldsError(taos, sql, TSDB_CODE_PAR_SYNTAX_ERROR);
|
||||||
|
}
|
||||||
|
|
||||||
|
// case 7 : no col
|
||||||
|
{
|
||||||
|
const char* sql = "insert into db.stb(t1,t2,tbname) values(?,?,?)";
|
||||||
printf("case 7 : %s\n", sql);
|
printf("case 7 : %s\n", sql);
|
||||||
getFieldsError(taos, sql, TSDB_CODE_TSC_INVALID_OPERATION);
|
getFieldsError(taos, sql, TSDB_CODE_TSC_INVALID_OPERATION);
|
||||||
}
|
}
|
||||||
|
|
||||||
// case 5 : no tbname and tag(not support bind)
|
// case 8 : wrong para nums
|
||||||
{
|
{
|
||||||
const char* sql = "insert into db.stb(ts,b) values(?,?)";
|
const char* sql = "insert into db.stb(ts,b,tbname) values(?,?,?,?,?)";
|
||||||
printf("case 5 : %s\n", sql);
|
|
||||||
getFieldsError(taos, sql, TSDB_CODE_TSC_INVALID_OPERATION);
|
|
||||||
}
|
|
||||||
|
|
||||||
// case 5 : no tbname and tag(not support bind)
|
|
||||||
{
|
|
||||||
const char* sql = "insert into db.stb(tbname) values(?)";
|
|
||||||
printf("case 5 : %s\n", sql);
|
|
||||||
getFieldsError(taos, sql, TSDB_CODE_TSC_INVALID_OPERATION);
|
|
||||||
}
|
|
||||||
|
|
||||||
// case 8 : no param
|
|
||||||
{
|
|
||||||
const char* sql = "insert into db.stb(?,?,?,?,?)";
|
|
||||||
printf("case 8 : %s\n", sql);
|
printf("case 8 : %s\n", sql);
|
||||||
getFieldsError(taos, sql, TSDB_CODE_PAR_SYNTAX_ERROR);
|
getFieldsError(taos, sql, TSDB_CODE_PAR_INVALID_COLUMNS_NUM);
|
||||||
|
}
|
||||||
|
|
||||||
|
// case 9 : wrong simbol
|
||||||
|
{
|
||||||
|
const char* sql = "insert into db.stb(t1,t2,ts,b,tbname) values(*,*,*,*,*)";
|
||||||
|
printf("case 9 : %s\n", sql);
|
||||||
|
getFieldsError(taos, sql, TSDB_CODE_TSC_SQL_SYNTAX_ERROR);
|
||||||
}
|
}
|
||||||
|
|
||||||
taos_close(taos);
|
taos_close(taos);
|
||||||
|
@ -318,170 +334,295 @@ TEST(stmt2Case, insert_stb_get_fields_Test) {
|
||||||
}
|
}
|
||||||
|
|
||||||
TEST(stmt2Case, insert_ctb_using_get_fields_Test) {
|
TEST(stmt2Case, insert_ctb_using_get_fields_Test) {
|
||||||
// do_query(taos, "CREATE TABLE db.d0 USING db.stb (t1,t2) TAGS (7,'Cali');");
|
TAOS* taos = taos_connect("localhost", "root", "taosdata", NULL, 0);
|
||||||
|
ASSERT_NE(taos, nullptr);
|
||||||
|
|
||||||
// // case 2 : INSERT INTO db.d0 VALUES (?,?)
|
do_query(taos, "drop database if exists db");
|
||||||
// // test child table
|
do_query(taos, "create database db PRECISION 'ns'");
|
||||||
// {
|
do_query(taos,
|
||||||
// const char* sql = "INSERT INTO db.d0(ts,b) VALUES (?,?)";
|
"create table db.stb (ts timestamp, b binary(10)) tags(t1 "
|
||||||
// TAOS_FIELD_ALL expectedFields[2] = {{"ts", TSDB_DATA_TYPE_TIMESTAMP, 2, 0, 8, TAOS_FIELD_COL},
|
"int, t2 binary(10))");
|
||||||
// {"b", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_COL}};
|
do_query(
|
||||||
// printf("case 2 : %s\n", sql);
|
taos,
|
||||||
// getFieldsSuccess(taos, sql, expectedFields, 2);
|
"create table if not exists db.all_stb(ts timestamp, v1 bool, v2 tinyint, v3 smallint, v4 int, v5 bigint, v6 "
|
||||||
// }
|
"tinyint unsigned, v7 smallint unsigned, v8 int unsigned, v9 bigint unsigned, v10 float, v11 double, v12 "
|
||||||
|
"binary(20), v13 varbinary(20), v14 geometry(100), v15 nchar(20))tags(tts timestamp, tv1 bool, tv2 tinyint, tv3 "
|
||||||
|
"smallint, tv4 int, tv5 bigint, tv6 tinyint unsigned, tv7 smallint unsigned, tv8 int unsigned, tv9 bigint "
|
||||||
|
"unsigned, tv10 float, tv11 double, tv12 binary(20), tv13 varbinary(20), tv14 geometry(100), tv15 nchar(20));");
|
||||||
|
do_query(taos, "CREATE TABLE db.t0 USING db.stb (t1,t2) TAGS (7,'Cali');");
|
||||||
|
|
||||||
// // case 6 : INSERT INTO db.? using db.stb (t1,t2)TAGS(?,?) (ts,b)VALUES(?,?)
|
printf("support case \n");
|
||||||
// // normal insert clause
|
// case 1 : test child table already exist
|
||||||
// {
|
{
|
||||||
// const char* sql = "INSERT INTO db.? using db.stb (t1,t2)TAGS(?,?) (ts,b)VALUES(?,?)";
|
const char* sql = "INSERT INTO db.t0(ts,b)using db.stb (t1,t2) TAGS(?,?) VALUES (?,?)";
|
||||||
// TAOS_FIELD_ALL expectedFields[5] = {{"tbname", TSDB_DATA_TYPE_BINARY, 0, 0, 271, TAOS_FIELD_TBNAME},
|
TAOS_FIELD_ALL expectedFields[4] = {{"t1", TSDB_DATA_TYPE_INT, 0, 0, 4, TAOS_FIELD_TAG},
|
||||||
// {"t1", TSDB_DATA_TYPE_INT, 0, 0, 4, TAOS_FIELD_TAG},
|
{"t2", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_TAG},
|
||||||
// {"t2", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_TAG},
|
{"ts", TSDB_DATA_TYPE_TIMESTAMP, 2, 0, 8, TAOS_FIELD_COL},
|
||||||
// {"ts", TSDB_DATA_TYPE_TIMESTAMP, 2, 0, 8, TAOS_FIELD_COL},
|
{"b", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_COL}};
|
||||||
// {"b", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_COL}};
|
printf("case 1 : %s\n", sql);
|
||||||
// printf("case 6 : %s\n", sql);
|
getFieldsSuccess(taos, sql, expectedFields, 4);
|
||||||
// getFieldsSuccess(taos, sql, expectedFields, 5);
|
}
|
||||||
// }
|
|
||||||
|
|
||||||
// // case 7 : insert into db.? using db.stb(t2,t1) tags(?, ?) (b,ts)values(?,?)
|
// case 2 : insert clause
|
||||||
// // disordered
|
{
|
||||||
// {
|
const char* sql = "INSERT INTO db.? using db.stb (t1,t2) TAGS(?,?) (ts,b)VALUES(?,?)";
|
||||||
// const char* sql = "insert into db.? using db.stb(t2,t1) tags(?, ?) (b,ts)values(?,?)";
|
TAOS_FIELD_ALL expectedFields[5] = {{"tbname", TSDB_DATA_TYPE_BINARY, 0, 0, 271, TAOS_FIELD_TBNAME},
|
||||||
// TAOS_FIELD_ALL expectedFields[5] = {{"tbname", TSDB_DATA_TYPE_BINARY, 0, 0, 271, TAOS_FIELD_TBNAME},
|
{"t1", TSDB_DATA_TYPE_INT, 0, 0, 4, TAOS_FIELD_TAG},
|
||||||
// {"t2", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_TAG},
|
{"t2", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_TAG},
|
||||||
// {"t1", TSDB_DATA_TYPE_INT, 0, 0, 4, TAOS_FIELD_TAG},
|
{"ts", TSDB_DATA_TYPE_TIMESTAMP, 2, 0, 8, TAOS_FIELD_COL},
|
||||||
// {"b", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_COL},
|
{"b", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_COL}};
|
||||||
// {"ts", TSDB_DATA_TYPE_TIMESTAMP, 2, 0, 8, TAOS_FIELD_COL}};
|
printf("case 2 : %s\n", sql);
|
||||||
// printf("case 7 : %s\n", sql);
|
getFieldsSuccess(taos, sql, expectedFields, 5);
|
||||||
// getFieldsSuccess(taos, sql, expectedFields, 5);
|
}
|
||||||
// }
|
|
||||||
|
|
||||||
// // case 8 : insert into db.? using db.stb tags(?, ?) values(?,?)
|
// case 3 : insert child table not exist
|
||||||
// // no field name
|
{
|
||||||
// {
|
const char* sql = "INSERT INTO db.d1 using db.stb (t1,t2)TAGS(?,?) (ts,b)VALUES(?,?)";
|
||||||
// const char* sql = "insert into db.? using db.stb tags(?, ?) values(?,?)";
|
TAOS_FIELD_ALL expectedFields[4] = {{"t1", TSDB_DATA_TYPE_INT, 0, 0, 4, TAOS_FIELD_TAG},
|
||||||
// TAOS_FIELD_ALL expectedFields[5] = {{"tbname", TSDB_DATA_TYPE_BINARY, 0, 0, 271, TAOS_FIELD_TBNAME},
|
{"t2", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_TAG},
|
||||||
// {"t1", TSDB_DATA_TYPE_INT, 0, 0, 4, TAOS_FIELD_TAG},
|
{"ts", TSDB_DATA_TYPE_TIMESTAMP, 2, 0, 8, TAOS_FIELD_COL},
|
||||||
// {"t2", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_TAG},
|
{"b", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_COL}};
|
||||||
// {"ts", TSDB_DATA_TYPE_TIMESTAMP, 2, 0, 8, TAOS_FIELD_COL},
|
printf("case 3 : %s\n", sql);
|
||||||
// {"b", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_COL}};
|
getFieldsSuccess(taos, sql, expectedFields, 4);
|
||||||
// printf("case 8 : %s\n", sql);
|
}
|
||||||
// getFieldsSuccess(taos, sql, expectedFields, 5);
|
|
||||||
// }
|
|
||||||
|
|
||||||
// // case 9 : insert into db.? using db.stb (t2)tags(?) (ts)values(?)
|
// case 4 : random order
|
||||||
// // less para
|
{
|
||||||
// {
|
const char* sql = "INSERT INTO db.? using db.stb (t2,t1)TAGS(?,?) (b,ts)VALUES(?,?)";
|
||||||
// const char* sql = "insert into db.? using db.stb (t2)tags(?) (ts)values(?)";
|
TAOS_FIELD_ALL expectedFields[5] = {{"tbname", TSDB_DATA_TYPE_BINARY, 0, 0, 271, TAOS_FIELD_TBNAME},
|
||||||
// TAOS_FIELD_ALL expectedFields[3] = {{"tbname", TSDB_DATA_TYPE_BINARY, 0, 0, 271, TAOS_FIELD_TBNAME},
|
{"t2", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_TAG},
|
||||||
// {"t2", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_TAG},
|
{"t1", TSDB_DATA_TYPE_INT, 0, 0, 4, TAOS_FIELD_TAG},
|
||||||
// {"ts", TSDB_DATA_TYPE_TIMESTAMP, 2, 0, 8, TAOS_FIELD_COL}};
|
{"b", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_COL},
|
||||||
// printf("case 9 : %s\n", sql);
|
{"ts", TSDB_DATA_TYPE_TIMESTAMP, 2, 0, 8, TAOS_FIELD_COL}};
|
||||||
// getFieldsSuccess(taos, sql, expectedFields, 3);
|
printf("case 4 : %s\n", sql);
|
||||||
// }
|
getFieldsSuccess(taos, sql, expectedFields, 5);
|
||||||
|
}
|
||||||
|
|
||||||
// // case 10 : insert into db.d0 (ts)values(?)
|
// case 5 : less para
|
||||||
// // less para
|
{
|
||||||
// {
|
const char* sql = "insert into db.? using db.stb (t2)tags(?) (ts)values(?)";
|
||||||
// const char* sql = "insert into db.d0 (ts)values(?)";
|
TAOS_FIELD_ALL expectedFields[3] = {{"tbname", TSDB_DATA_TYPE_BINARY, 0, 0, 271, TAOS_FIELD_TBNAME},
|
||||||
// TAOS_FIELD_ALL expectedFields[1] = {{"ts", TSDB_DATA_TYPE_TIMESTAMP, 2, 0, 8, TAOS_FIELD_COL}};
|
{"t2", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_TAG},
|
||||||
// printf("case 10 : %s\n", sql);
|
{"ts", TSDB_DATA_TYPE_TIMESTAMP, 2, 0, 8, TAOS_FIELD_COL}};
|
||||||
// getFieldsSuccess(taos, sql, expectedFields, 1);
|
printf("case 5 : %s\n", sql);
|
||||||
// }
|
getFieldsSuccess(taos, sql, expectedFields, 3);
|
||||||
// // case 11 : insert into abc using stb tags(?, ?) values(?,?)
|
}
|
||||||
// // insert create table
|
|
||||||
// {
|
|
||||||
// const char* sql = "insert into abc using stb tags(?, ?) values(?,?)";
|
|
||||||
// TAOS_FIELD_ALL expectedFields[4] = {{"t1", TSDB_DATA_TYPE_INT, 0, 0, 4, TAOS_FIELD_TAG},
|
|
||||||
// {"t2", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_TAG},
|
|
||||||
// {"ts", TSDB_DATA_TYPE_TIMESTAMP, 2, 0, 8, TAOS_FIELD_COL},
|
|
||||||
// {"b", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_COL}};
|
|
||||||
// printf("case 11 : %s\n", sql);
|
|
||||||
// getFieldsSuccess(taos, sql, expectedFields, 4);
|
|
||||||
// }
|
|
||||||
|
|
||||||
// // // case 13 : insert into ? using all_stb tags(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)
|
// case 6 : insert into db.? using db.stb tags(?, ?) values(?,?)
|
||||||
// // values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)
|
// no field name
|
||||||
// // // test all types
|
{
|
||||||
// // sql =
|
const char* sql = "insert into db.? using db.stb tags(?, ?) values(?,?)";
|
||||||
// // "insert into all_stb "
|
TAOS_FIELD_ALL expectedFields[5] = {{"tbname", TSDB_DATA_TYPE_BINARY, 0, 0, 271, TAOS_FIELD_TBNAME},
|
||||||
// //
|
{"t1", TSDB_DATA_TYPE_INT, 0, 0, 4, TAOS_FIELD_TAG},
|
||||||
// "(tbname,tts,tv1,tv2,tv3,tv4,tv5,tv6,tv7,tv8,tv9,tv10,tv11,tv12,tv13,tv14,tv15,ts,v1,v2,v3,v4,v5,v6,v7,v8,v9,v10,"
|
{"t2", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_TAG},
|
||||||
// // "v11,v12,v13,v14,v15) values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
|
{"ts", TSDB_DATA_TYPE_TIMESTAMP, 2, 0, 8, TAOS_FIELD_COL},
|
||||||
// // printf("case 13 : %s\n", sql);
|
{"b", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_COL}};
|
||||||
// // getFields(taos, sql);
|
printf("case 6 : %s\n", sql);
|
||||||
|
getFieldsSuccess(taos, sql, expectedFields, 5);
|
||||||
|
}
|
||||||
|
|
||||||
// case 12 : insert into ? using all_stb tags(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)
|
// case 7 : insert into db.d0 (ts)values(?)
|
||||||
// values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)
|
// less para
|
||||||
// test all types
|
{
|
||||||
// {
|
const char* sql = "insert into db.t0 (ts)values(?)";
|
||||||
// const char* sql =
|
TAOS_FIELD_ALL expectedFields[1] = {{"ts", TSDB_DATA_TYPE_TIMESTAMP, 2, 0, 8, TAOS_FIELD_COL}};
|
||||||
// "insert into ? using all_stb tags(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?) values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
|
printf("case 7 : %s\n", sql);
|
||||||
// TAOS_FIELD_ALL expectedFields[33] = {{"tbname", TSDB_DATA_TYPE_BINARY, 0, 0, 271, TAOS_FIELD_TBNAME},
|
getFieldsSuccess(taos, sql, expectedFields, 1);
|
||||||
// {"tts", TSDB_DATA_TYPE_TIMESTAMP, 2, 0, 8, TAOS_FIELD_TAG},
|
}
|
||||||
// {"tv1", TSDB_DATA_TYPE_BOOL, 0, 0, 1, TAOS_FIELD_TAG},
|
|
||||||
// {"tv2", TSDB_DATA_TYPE_TINYINT, 0, 0, 1, TAOS_FIELD_TAG},
|
// case 8 : 'db' 'stb'
|
||||||
// {"tv3", TSDB_DATA_TYPE_SMALLINT, 0, 0, 2, TAOS_FIELD_TAG},
|
{
|
||||||
// {"tv4", TSDB_DATA_TYPE_INT, 0, 0, 4, TAOS_FIELD_TAG},
|
const char* sql = "INSERT INTO 'db'.? using 'db'.'stb' (t1,t2) TAGS(?,?) (ts,b)VALUES(?,?)";
|
||||||
// {"tv5", TSDB_DATA_TYPE_BIGINT, 0, 0, 8, TAOS_FIELD_TAG},
|
TAOS_FIELD_ALL expectedFields[5] = {{"tbname", TSDB_DATA_TYPE_BINARY, 0, 0, 271, TAOS_FIELD_TBNAME},
|
||||||
// {"tv6", TSDB_DATA_TYPE_UTINYINT, 0, 0, 1, TAOS_FIELD_TAG},
|
{"t1", TSDB_DATA_TYPE_INT, 0, 0, 4, TAOS_FIELD_TAG},
|
||||||
// {"tv7", TSDB_DATA_TYPE_USMALLINT, 0, 0, 2, TAOS_FIELD_TAG},
|
{"t2", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_TAG},
|
||||||
// {"tv8", TSDB_DATA_TYPE_UINT, 0, 0, 4, TAOS_FIELD_TAG},
|
{"ts", TSDB_DATA_TYPE_TIMESTAMP, 2, 0, 8, TAOS_FIELD_COL},
|
||||||
// {"tv9", TSDB_DATA_TYPE_UBIGINT, 0, 0, 8, TAOS_FIELD_TAG},
|
{"b", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_COL}};
|
||||||
// {"tv10", TSDB_DATA_TYPE_FLOAT, 0, 0, 4, TAOS_FIELD_TAG},
|
printf("case 8 : %s\n", sql);
|
||||||
// {"tv11", TSDB_DATA_TYPE_DOUBLE, 0, 0, 8, TAOS_FIELD_TAG},
|
getFieldsSuccess(taos, sql, expectedFields, 5);
|
||||||
// {"tv12", TSDB_DATA_TYPE_VARCHAR, 0, 0, 22, TAOS_FIELD_TAG},
|
}
|
||||||
// {"tv13", TSDB_DATA_TYPE_VARBINARY, 0, 0, 22, TAOS_FIELD_TAG},
|
|
||||||
// {"tv14", TSDB_DATA_TYPE_GEOMETRY, 0, 0, 102, TAOS_FIELD_TAG},
|
// case 9 : use db
|
||||||
// {"tv15", TSDB_DATA_TYPE_NCHAR, 0, 0, 82, TAOS_FIELD_TAG},
|
{
|
||||||
// {"ts", TSDB_DATA_TYPE_TIMESTAMP, 2, 0, 8, TAOS_FIELD_COL},
|
do_query(taos, "use db");
|
||||||
// {"v1", TSDB_DATA_TYPE_BOOL, 0, 0, 1, TAOS_FIELD_COL},
|
const char* sql = "INSERT INTO ? using stb (t1,t2) TAGS(?,?) (ts,b)VALUES(?,?)";
|
||||||
// {"v2", TSDB_DATA_TYPE_TINYINT, 0, 0, 1, TAOS_FIELD_COL},
|
TAOS_FIELD_ALL expectedFields[5] = {{"tbname", TSDB_DATA_TYPE_BINARY, 0, 0, 271, TAOS_FIELD_TBNAME},
|
||||||
// {"v3", TSDB_DATA_TYPE_SMALLINT, 0, 0, 2, TAOS_FIELD_COL},
|
{"t1", TSDB_DATA_TYPE_INT, 0, 0, 4, TAOS_FIELD_TAG},
|
||||||
// {"v4", TSDB_DATA_TYPE_INT, 0, 0, 4, TAOS_FIELD_COL},
|
{"t2", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_TAG},
|
||||||
// {"v5", TSDB_DATA_TYPE_BIGINT, 0, 0, 8, TAOS_FIELD_COL},
|
{"ts", TSDB_DATA_TYPE_TIMESTAMP, 2, 0, 8, TAOS_FIELD_COL},
|
||||||
// {"v6", TSDB_DATA_TYPE_UTINYINT, 0, 0, 1, TAOS_FIELD_COL},
|
{"b", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_COL}};
|
||||||
// {"v7", TSDB_DATA_TYPE_USMALLINT, 0, 0, 2, TAOS_FIELD_COL},
|
printf("case 9 : %s\n", sql);
|
||||||
// {"v8", TSDB_DATA_TYPE_UINT, 0, 0, 4, TAOS_FIELD_COL},
|
getFieldsSuccess(taos, sql, expectedFields, 5);
|
||||||
// {"v9", TSDB_DATA_TYPE_UBIGINT, 0, 0, 8, TAOS_FIELD_COL},
|
}
|
||||||
// {"v10", TSDB_DATA_TYPE_FLOAT, 0, 0, 4, TAOS_FIELD_COL},
|
|
||||||
// {"v11", TSDB_DATA_TYPE_DOUBLE, 0, 0, 8, TAOS_FIELD_COL},
|
// case 10 : test all types
|
||||||
// {"v12", TSDB_DATA_TYPE_VARCHAR, 0, 0, 22, TAOS_FIELD_COL},
|
{
|
||||||
// {"v13", TSDB_DATA_TYPE_VARBINARY, 0, 0, 22, TAOS_FIELD_COL},
|
const char* sql =
|
||||||
// {"v14", TSDB_DATA_TYPE_GEOMETRY, 0, 0, 102, TAOS_FIELD_COL},
|
"insert into ? using all_stb tags(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?) values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
|
||||||
// {"v15", TSDB_DATA_TYPE_NCHAR, 0, 0, 82, TAOS_FIELD_COL}};
|
TAOS_FIELD_ALL expectedFields[33] = {{"tbname", TSDB_DATA_TYPE_BINARY, 0, 0, 271, TAOS_FIELD_TBNAME},
|
||||||
// printf("case 12 : %s\n", sql);
|
{"tts", TSDB_DATA_TYPE_TIMESTAMP, 2, 0, 8, TAOS_FIELD_TAG},
|
||||||
// getFieldsSuccess(taos, sql, expectedFields, 33);
|
{"tv1", TSDB_DATA_TYPE_BOOL, 0, 0, 1, TAOS_FIELD_TAG},
|
||||||
// }
|
{"tv2", TSDB_DATA_TYPE_TINYINT, 0, 0, 1, TAOS_FIELD_TAG},
|
||||||
|
{"tv3", TSDB_DATA_TYPE_SMALLINT, 0, 0, 2, TAOS_FIELD_TAG},
|
||||||
|
{"tv4", TSDB_DATA_TYPE_INT, 0, 0, 4, TAOS_FIELD_TAG},
|
||||||
|
{"tv5", TSDB_DATA_TYPE_BIGINT, 0, 0, 8, TAOS_FIELD_TAG},
|
||||||
|
{"tv6", TSDB_DATA_TYPE_UTINYINT, 0, 0, 1, TAOS_FIELD_TAG},
|
||||||
|
{"tv7", TSDB_DATA_TYPE_USMALLINT, 0, 0, 2, TAOS_FIELD_TAG},
|
||||||
|
{"tv8", TSDB_DATA_TYPE_UINT, 0, 0, 4, TAOS_FIELD_TAG},
|
||||||
|
{"tv9", TSDB_DATA_TYPE_UBIGINT, 0, 0, 8, TAOS_FIELD_TAG},
|
||||||
|
{"tv10", TSDB_DATA_TYPE_FLOAT, 0, 0, 4, TAOS_FIELD_TAG},
|
||||||
|
{"tv11", TSDB_DATA_TYPE_DOUBLE, 0, 0, 8, TAOS_FIELD_TAG},
|
||||||
|
{"tv12", TSDB_DATA_TYPE_VARCHAR, 0, 0, 22, TAOS_FIELD_TAG},
|
||||||
|
{"tv13", TSDB_DATA_TYPE_VARBINARY, 0, 0, 22, TAOS_FIELD_TAG},
|
||||||
|
{"tv14", TSDB_DATA_TYPE_GEOMETRY, 0, 0, 102, TAOS_FIELD_TAG},
|
||||||
|
{"tv15", TSDB_DATA_TYPE_NCHAR, 0, 0, 82, TAOS_FIELD_TAG},
|
||||||
|
{"ts", TSDB_DATA_TYPE_TIMESTAMP, 2, 0, 8, TAOS_FIELD_COL},
|
||||||
|
{"v1", TSDB_DATA_TYPE_BOOL, 0, 0, 1, TAOS_FIELD_COL},
|
||||||
|
{"v2", TSDB_DATA_TYPE_TINYINT, 0, 0, 1, TAOS_FIELD_COL},
|
||||||
|
{"v3", TSDB_DATA_TYPE_SMALLINT, 0, 0, 2, TAOS_FIELD_COL},
|
||||||
|
{"v4", TSDB_DATA_TYPE_INT, 0, 0, 4, TAOS_FIELD_COL},
|
||||||
|
{"v5", TSDB_DATA_TYPE_BIGINT, 0, 0, 8, TAOS_FIELD_COL},
|
||||||
|
{"v6", TSDB_DATA_TYPE_UTINYINT, 0, 0, 1, TAOS_FIELD_COL},
|
||||||
|
{"v7", TSDB_DATA_TYPE_USMALLINT, 0, 0, 2, TAOS_FIELD_COL},
|
||||||
|
{"v8", TSDB_DATA_TYPE_UINT, 0, 0, 4, TAOS_FIELD_COL},
|
||||||
|
{"v9", TSDB_DATA_TYPE_UBIGINT, 0, 0, 8, TAOS_FIELD_COL},
|
||||||
|
{"v10", TSDB_DATA_TYPE_FLOAT, 0, 0, 4, TAOS_FIELD_COL},
|
||||||
|
{"v11", TSDB_DATA_TYPE_DOUBLE, 0, 0, 8, TAOS_FIELD_COL},
|
||||||
|
{"v12", TSDB_DATA_TYPE_VARCHAR, 0, 0, 22, TAOS_FIELD_COL},
|
||||||
|
{"v13", TSDB_DATA_TYPE_VARBINARY, 0, 0, 22, TAOS_FIELD_COL},
|
||||||
|
{"v14", TSDB_DATA_TYPE_GEOMETRY, 0, 0, 102, TAOS_FIELD_COL},
|
||||||
|
{"v15", TSDB_DATA_TYPE_NCHAR, 0, 0, 82, TAOS_FIELD_COL}};
|
||||||
|
printf("case 10 : %s\n", sql);
|
||||||
|
getFieldsSuccess(taos, sql, expectedFields, 33);
|
||||||
|
}
|
||||||
|
printf("not support case \n");
|
||||||
|
|
||||||
|
// case 1 : test super table not exist
|
||||||
|
{
|
||||||
|
const char* sql = "INSERT INTO db.?(ts,b)using db.nstb (t1,t2) TAGS(?,?) VALUES (?,?)";
|
||||||
|
printf("case 1 : %s\n", sql);
|
||||||
|
getFieldsError(taos, sql, TSDB_CODE_PAR_SYNTAX_ERROR);
|
||||||
|
}
|
||||||
|
|
||||||
|
// case 2 : no pk
|
||||||
|
{
|
||||||
|
const char* sql = "INSERT INTO db.?(ts,b)using db.nstb (t1,t2) TAGS(?,?) (n)VALUES (?)";
|
||||||
|
printf("case 2 : %s\n", sql);
|
||||||
|
getFieldsError(taos, sql, TSDB_CODE_PAR_SYNTAX_ERROR);
|
||||||
|
}
|
||||||
|
|
||||||
|
// case 3 : less param and no filed name
|
||||||
|
{
|
||||||
|
const char* sql = "INSERT INTO db.?(ts,b)using db.stb TAGS(?)VALUES (?,?)";
|
||||||
|
printf("case 3 : %s\n", sql);
|
||||||
|
getFieldsError(taos, sql, TSDB_CODE_PAR_SYNTAX_ERROR);
|
||||||
|
}
|
||||||
|
|
||||||
|
// case 4 : none para for ctbname
|
||||||
|
{
|
||||||
|
const char* sql = "INSERT INTO db.d0 using db.stb values(?,?)";
|
||||||
|
printf("case 4 : %s\n", sql);
|
||||||
|
getFieldsError(taos, sql, TSDB_CODE_TSC_SQL_SYNTAX_ERROR);
|
||||||
|
}
|
||||||
|
|
||||||
|
// case 5 : none para for ctbname
|
||||||
|
{
|
||||||
|
const char* sql = "insert into ! using db.stb tags(?, ?) values(?,?)";
|
||||||
|
printf("case 5 : %s\n", sql);
|
||||||
|
getFieldsError(taos, sql, TSDB_CODE_TSC_SQL_SYNTAX_ERROR);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
TEST(stmt2Case, insert_ntb_get_fields_Test) {
|
TEST(stmt2Case, insert_ntb_get_fields_Test) {
|
||||||
// do_query(taos, "CREATE TABLE db.ntb(nts timestamp, nb binary(10),nvc varchar(16),ni int);");
|
TAOS* taos = taos_connect("localhost", "root", "taosdata", NULL, 0);
|
||||||
|
ASSERT_NE(taos, nullptr);
|
||||||
|
|
||||||
// // // case 3 : INSERT INTO db.ntb VALUES(?,?,?,?)
|
do_query(taos, "drop database if exists db");
|
||||||
// // // test normal table
|
do_query(taos, "create database db PRECISION 'ms'");
|
||||||
// {
|
do_query(taos, "CREATE TABLE db.ntb(nts timestamp, nb binary(10),nvc varchar(16),ni int);");
|
||||||
// const char* sql = "INSERT INTO db.ntb VALUES(?,?,?,?)";
|
do_query(
|
||||||
// TAOS_FIELD_ALL expectedFields[4] = {{"nts", TSDB_DATA_TYPE_TIMESTAMP, 2, 0, 8, TAOS_FIELD_COL},
|
taos,
|
||||||
// {"nb", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_COL},
|
"create table if not exists db.all_ntb(ts timestamp, v1 bool, v2 tinyint, v3 smallint, v4 int, v5 bigint, v6 "
|
||||||
// {"nvc", TSDB_DATA_TYPE_BINARY, 0, 0, 18, TAOS_FIELD_COL},
|
"tinyint unsigned, v7 smallint unsigned, v8 int unsigned, v9 bigint unsigned, v10 float, v11 double, v12 "
|
||||||
// {"ni", TSDB_DATA_TYPE_INT, 0, 0, 4, TAOS_FIELD_COL}};
|
"binary(20), v13 varbinary(20), v14 geometry(100), v15 nchar(20));");
|
||||||
// printf("case 3 : %s\n", sql);
|
|
||||||
// getFieldsSuccess(taos, sql, expectedFields, 4);
|
|
||||||
// }
|
|
||||||
|
|
||||||
// {
|
printf("support case \n");
|
||||||
// // case 4 : insert into db.stb(t1,tbname,ts,t2,b) values(?,?,?,?,?)
|
|
||||||
// // test random order
|
// case 1 : test normal table no field name
|
||||||
// const char* sql = "insert into db.stb(t1,tbname,ts,t2,b) values(?,?,?,?,?)";
|
{
|
||||||
// TAOS_FIELD_ALL expectedFields[5] = {{"t1", TSDB_DATA_TYPE_INT, 0, 0, 4, TAOS_FIELD_TAG},
|
const char* sql = "INSERT INTO db.ntb VALUES(?,?,?,?)";
|
||||||
// {"tbname", TSDB_DATA_TYPE_BINARY, 0, 0, 271, TAOS_FIELD_TBNAME},
|
TAOS_FIELD_ALL expectedFields[4] = {{"nts", TSDB_DATA_TYPE_TIMESTAMP, 0, 0, 8, TAOS_FIELD_COL},
|
||||||
// {"ts", TSDB_DATA_TYPE_TIMESTAMP, 2, 0, 8, TAOS_FIELD_COL},
|
{"nb", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_COL},
|
||||||
// {"t2", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_TAG},
|
{"nvc", TSDB_DATA_TYPE_BINARY, 0, 0, 18, TAOS_FIELD_COL},
|
||||||
// {"b", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_COL}};
|
{"ni", TSDB_DATA_TYPE_INT, 0, 0, 4, TAOS_FIELD_COL}};
|
||||||
// printf("case 4 : %s\n", sql);
|
printf("case 1 : %s\n", sql);
|
||||||
// getFieldsSuccess(taos, sql, expectedFields, 5);
|
getFieldsSuccess(taos, sql, expectedFields, 4);
|
||||||
// }
|
}
|
||||||
|
|
||||||
|
// case 2 : test random order
|
||||||
|
{
|
||||||
|
const char* sql = "INSERT INTO db.ntb (ni,nb,nvc,nts)VALUES(?,?,?,?)";
|
||||||
|
TAOS_FIELD_ALL expectedFields[4] = {{"ni", TSDB_DATA_TYPE_INT, 0, 0, 4, TAOS_FIELD_COL},
|
||||||
|
{"nb", TSDB_DATA_TYPE_BINARY, 0, 0, 12, TAOS_FIELD_COL},
|
||||||
|
{"nvc", TSDB_DATA_TYPE_BINARY, 0, 0, 18, TAOS_FIELD_COL},
|
||||||
|
{"nts", TSDB_DATA_TYPE_TIMESTAMP, 0, 0, 8, TAOS_FIELD_COL}};
|
||||||
|
printf("case 2 : %s\n", sql);
|
||||||
|
getFieldsSuccess(taos, sql, expectedFields, 4);
|
||||||
|
}
|
||||||
|
|
||||||
|
// case 3 : less param
|
||||||
|
{
|
||||||
|
const char* sql = "INSERT INTO db.ntb (nts)VALUES(?)";
|
||||||
|
TAOS_FIELD_ALL expectedFields[1] = {{"nts", TSDB_DATA_TYPE_TIMESTAMP, 0, 0, 8, TAOS_FIELD_COL}};
|
||||||
|
printf("case 3 : %s\n", sql);
|
||||||
|
getFieldsSuccess(taos, sql, expectedFields, 1);
|
||||||
|
}
|
||||||
|
|
||||||
|
// case 4 : test all types
|
||||||
|
{
|
||||||
|
const char* sql = "insert into db.all_ntb values(?,?,?,?,?,?,?,?,?,?,?,?,?,?,?,?)";
|
||||||
|
TAOS_FIELD_ALL expectedFields[16] = {{"ts", TSDB_DATA_TYPE_TIMESTAMP, 0, 0, 8, TAOS_FIELD_COL},
|
||||||
|
{"v1", TSDB_DATA_TYPE_BOOL, 0, 0, 1, TAOS_FIELD_COL},
|
||||||
|
{"v2", TSDB_DATA_TYPE_TINYINT, 0, 0, 1, TAOS_FIELD_COL},
|
||||||
|
{"v3", TSDB_DATA_TYPE_SMALLINT, 0, 0, 2, TAOS_FIELD_COL},
|
||||||
|
{"v4", TSDB_DATA_TYPE_INT, 0, 0, 4, TAOS_FIELD_COL},
|
||||||
|
{"v5", TSDB_DATA_TYPE_BIGINT, 0, 0, 8, TAOS_FIELD_COL},
|
||||||
|
{"v6", TSDB_DATA_TYPE_UTINYINT, 0, 0, 1, TAOS_FIELD_COL},
|
||||||
|
{"v7", TSDB_DATA_TYPE_USMALLINT, 0, 0, 2, TAOS_FIELD_COL},
|
||||||
|
{"v8", TSDB_DATA_TYPE_UINT, 0, 0, 4, TAOS_FIELD_COL},
|
||||||
|
{"v9", TSDB_DATA_TYPE_UBIGINT, 0, 0, 8, TAOS_FIELD_COL},
|
||||||
|
{"v10", TSDB_DATA_TYPE_FLOAT, 0, 0, 4, TAOS_FIELD_COL},
|
||||||
|
{"v11", TSDB_DATA_TYPE_DOUBLE, 0, 0, 8, TAOS_FIELD_COL},
|
||||||
|
{"v12", TSDB_DATA_TYPE_VARCHAR, 0, 0, 22, TAOS_FIELD_COL},
|
||||||
|
{"v13", TSDB_DATA_TYPE_VARBINARY, 0, 0, 22, TAOS_FIELD_COL},
|
||||||
|
{"v14", TSDB_DATA_TYPE_GEOMETRY, 0, 0, 102, TAOS_FIELD_COL},
|
||||||
|
{"v15", TSDB_DATA_TYPE_NCHAR, 0, 0, 82, TAOS_FIELD_COL}};
|
||||||
|
printf("case 4 : %s\n", sql);
|
||||||
|
getFieldsSuccess(taos, sql, expectedFields, 16);
|
||||||
|
}
|
||||||
|
|
||||||
|
printf("not support case \n");
|
||||||
|
|
||||||
|
// case 1 : wrong db
|
||||||
|
{
|
||||||
|
const char* sql = "insert into ntb values(?,?,?,?)";
|
||||||
|
printf("case 1 : %s\n", sql);
|
||||||
|
getFieldsError(taos, sql, TSDB_CODE_TSC_INVALID_OPERATION);
|
||||||
|
}
|
||||||
|
|
||||||
|
// case 2 : normal table must have tbnam
|
||||||
|
{
|
||||||
|
const char* sql = "insert into db.? values(?,?)";
|
||||||
|
printf("case 2 : %s\n", sql);
|
||||||
|
getFieldsError(taos, sql, TSDB_CODE_PAR_TABLE_NOT_EXIST);
|
||||||
|
}
|
||||||
|
|
||||||
|
// case 3 : wrong para nums
|
||||||
|
{
|
||||||
|
const char* sql = "insert into db.ntb(nts,ni) values(?,?,?,?,?)";
|
||||||
|
printf("case 3 : %s\n", sql);
|
||||||
|
getFieldsError(taos, sql, TSDB_CODE_PAR_INVALID_COLUMNS_NUM);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
TEST(stmt2Case, select_get_fields_Test) {
|
TEST(stmt2Case, select_get_fields_Test) {
|
||||||
|
@ -492,20 +633,25 @@ TEST(stmt2Case, select_get_fields_Test) {
|
||||||
do_query(taos, "use db");
|
do_query(taos, "use db");
|
||||||
do_query(taos, "CREATE TABLE db.ntb(nts timestamp, nb binary(10),nvc varchar(16),ni int);");
|
do_query(taos, "CREATE TABLE db.ntb(nts timestamp, nb binary(10),nvc varchar(16),ni int);");
|
||||||
{
|
{
|
||||||
// case 1 : select * from ntb where ts = ?
|
// case 1 :
|
||||||
// query type
|
|
||||||
const char* sql = "select * from ntb where ts = ?";
|
const char* sql = "select * from ntb where ts = ?";
|
||||||
printf("case 1 : %s\n", sql);
|
printf("case 1 : %s\n", sql);
|
||||||
getQueryFields(taos, sql, 1);
|
getQueryFields(taos, sql, 1);
|
||||||
}
|
}
|
||||||
|
|
||||||
{
|
{
|
||||||
// case 2 : select * from ntb where ts = ? and b = ?
|
// case 2 :
|
||||||
// query type
|
|
||||||
const char* sql = "select * from ntb where ts = ? and b = ?";
|
const char* sql = "select * from ntb where ts = ? and b = ?";
|
||||||
printf("case 2 : %s\n", sql);
|
printf("case 2 : %s\n", sql);
|
||||||
getQueryFields(taos, sql, 2);
|
getQueryFields(taos, sql, 2);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
{
|
||||||
|
// case 3 :
|
||||||
|
const char* sql = "select * from ? where ts = ?";
|
||||||
|
printf("case 3 : %s\n", sql);
|
||||||
|
getFieldsError(taos, sql, TSDB_CODE_PAR_SYNTAX_ERROR);
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
TEST(stmt2Case, get_fields_error_Test) {
|
TEST(stmt2Case, get_fields_error_Test) {
|
||||||
|
@ -519,7 +665,6 @@ TEST(stmt2Case, get_fields_error_Test) {
|
||||||
|
|
||||||
TEST(stmt2Case, stmt2_init_prepare_Test) {
|
TEST(stmt2Case, stmt2_init_prepare_Test) {
|
||||||
TAOS* taos = taos_connect("localhost", "root", "taosdata", NULL, 0);
|
TAOS* taos = taos_connect("localhost", "root", "taosdata", NULL, 0);
|
||||||
|
|
||||||
{
|
{
|
||||||
(void)taos_stmt2_init(NULL, NULL);
|
(void)taos_stmt2_init(NULL, NULL);
|
||||||
ASSERT_EQ(terrno, TSDB_CODE_INVALID_PARA);
|
ASSERT_EQ(terrno, TSDB_CODE_INVALID_PARA);
|
||||||
|
|
Loading…
Reference in New Issue