This command starts a docker container with TDengine server running and maps the container's ports from 6030 to 6041 to the host's ports from 6030 to 6041. If the host is already running TDengine server and occupying the same port(s), you need to map the container's port to a different unused port segment. (Please see [TDengine 2.0 Port Description](https://www.taosdata.com/en/documentation/faq#port) for details). In order to support TDengine clients accessing TDengine server services, both TCP and UDP ports need to be open.
-**--name tdengine**: Set the container name, we can see the corresponding container by the container name
-**-d**: Keeping containers running in the background
-**docker run**: Run a container via Docker
-**tdengine/tdengine**: Pulled from the official TDengine published application image
-**-d**: put the container run in the background
-**7760c955f225d72e9c1ec5a4cef66149a7b94dae7598b11eb392138877e7d292**: The long character returned is the container ID, and we can also view the corresponding container by its container ID
-**-p**: specify the port(s) to map. Note: If you do not use port mapping, you can still go inside the Docker container to access TDengine services or develop your application, but you cannot provide services outside the container
-**tdengine/tdengine**: the official TDengine published application image that is pulled
-**526aa188da767ae94b244226a2b2eec2b5f17dd8eff592893d9ec0cd0f3a1ccd**: The long character returned is the container ID, and we can also view the corresponding container by its container ID
Further, you can also use the `docker run` command to start the docker container running TDengine server, and use the `--name` command line parameter to name the container tdengine, use `--hostname` to specify the hostname as tdengine-server, and use `-v` to mount the local directory (-v) to synchronize the data inside the host and the container to prevent data loss after the container is deleted.
2, Verify that the container is running correctly.
-**--name tdengine**: set the container name, we can access the corresponding container by container name
-**--hostnamename=tdengine-server**: set the hostname of the Linux system inside the container, we can map the hostname and IP to solve the problem that the container IP may change.
-**-v**: Set the host file directory to be mapped to the inner container directory to avoid data loss after the container is deleted.
### Use the `docker ps` command to verify that the container is running correctly
```bash
```bash
$ docker ps
$ docker ps
...
@@ -38,30 +50,30 @@ CONTAINER ID IMAGE COMMAND CREATED STATUS ·
...
@@ -38,30 +50,30 @@ CONTAINER ID IMAGE COMMAND CREATED STATUS ·
c452519b0f9b tdengine/tdengine "taosd" 14 minutes ago Up 14 minutes ···
c452519b0f9b tdengine/tdengine "taosd" 14 minutes ago Up 14 minutes ···
```
```
-**docker ps**: Lists information about all containers that are in running state.
-**docker ps**: list all containers in running state.
-**CONTAINER ID**: Container ID.
-**CONTAINER ID**: container ID.
-**IMAGE**: The mirror used.
-**IMAGE**: the image used.
-**COMMAND**: The command to run when starting the container.
-**COMMAND**: the command to run when starting the container.
-**CREATED**: The time when the container was created.
-**CREATED**: container creation time.
-**STATUS**: The container status. Up means running.
-**STATUS**: container status. UP means running.
3, Go inside the Docker container and use TDengine.
### Enter the docker container to do development via the `docker exec` COMMAND
```bash
```bash
$ docker exec-it tdengine /bin/bash
$ docker exec-it tdengine /bin/bash
root@c452519b0f9b:~/TDengine-server-2.0.20.13#
root@tdengine-server:~/TDengine-server-2.0.20.13#
```
```
-**docker exec**: Enter the container via the docker exec command; if you exit, the container will not stop.
-**docker exec**: Enter the container by `docker exec` command, if exited, the container will not stop.
-**-i**: Enter the interactive mode.
-**-i**: use interactive mode.
-**-t**: Specify a terminal.
-**-t**: specify a terminal.
-**c452519b0f9b**: The container ID, which needs to be modified according to the value returned by the docker ps command.
-**tdengine**: container name, needs to be changed according to the value returned by the docker ps command.
-**/bin/bash**: Load the container and run bash to interact with it.
-**/bin/bash**: load the container and run bash to interact with it.
4, After entering the container, execute the taos shell client program.
After entering the container, execute the taos shell client program.
Welcome to the TDengine shell from Linux, Client Version:2.0.20.13
Welcome to the TDengine shell from Linux, Client Version:2.0.20.13
Copyright (c) 2020 by TAOS Data, Inc. All rights reserved.
Copyright (c) 2020 by TAOS Data, Inc. All rights reserved.
...
@@ -69,23 +81,94 @@ Copyright (c) 2020 by TAOS Data, Inc. All rights reserved.
...
@@ -69,23 +81,94 @@ Copyright (c) 2020 by TAOS Data, Inc. All rights reserved.
taos>
taos>
```
```
The TDengine terminal successfully connects to the server and prints out a welcome message and version information. If it fails, an error message is printed.
The TDengine shell successfully connects to the server and prints out a welcome message and version information. If it fails, an error message is printed.
In the TDengine terminal, you can create/delete databases, tables, super tables, etc., and perform insert and query operations via SQL commands. For details, you can refer to [TAOS SQL guide](https://www.taosdata.com/en/documentation/taos-sql).
In the TDengine shell, you can create/delete databases, tables, super tables, etc., and perform insert and query operations via SQL commands. For details, please refer to the [TAOS SQL documentation](https://www.taosdata.com/en/documentation/taos-sql).
## Learn more about TDengine with taosdemo
### Accessing TDengine server inside Docker container from the host side
1, Following the above steps, exit the TDengine terminal program first.
After starting the TDengine Docker container with the correct port mapped with the -p command line parameter, you can access the TDengine running inside the Docker container from the host side using the taos shell command.
```bash
$ taos> q
root@c452519b0f9b:~/TDengine-server-2.0.20.13#
```
```
$ taos
2, Execute taosdemo from the command line interface.
Welcome to the TDengine shell from Linux, Client Version:2.0.22.3
Copyright (c) 2020 by TAOS Data, Inc. All rights reserved.
taos>
```
You can also access the TDengine server inside the Docker container using `curl` command from the host side through the RESTful port.
This command accesses the TDengine server through the RESTful interface, which connects to port 6041 on the local machine, so the connection is successful.
TDengine RESTful interface details can be found in the [official documentation](https://www.taosdata.com/en/documentation/connector#restful).
### Running TDengine server and taosAdapter with a Docker container
Docker containers of TDegnine version 2.4.0.0 and later include a component named `taosAdapter`, which supports data writing and querying capabilities to the TDengine server through the RESTful interface and provides the data ingestion interfaces compatible with InfluxDB/OpenTSDB. Allows seamless migration of InfluxDB/OpenTSDB applications to access TDengine.
Note: If taosAdapter is running inside the container, you need to add mapping to other additional ports as needed, please refer to [taosAdapter documentation](https://github.com/taosdata/taosadapter/blob/develop/README.md) for the default port number and modification methods for the specific purpose.
Running TDengine version 2.4.0.0 image with docker.
taosAdapter supports multiple data collection agents (e.g. Telegraf, StatsD, collectd, etc.), here only demonstrate how StasD is simulated to write data, and the command is executed from the host side as follows.
```
$ echo "foo:1|c" | nc -u -w0 127.0.0.1 6044
```
Then you can use the taos shell to query the taosAdapter automatically created database statsd and the contents of the super table foo.
```
taos> show databases;
name | created_time | ntables | vgroups | replica | quorum | days | keep | cache(MB) | blocks | minrows | maxrows | wallevel | fsync | comp | cachelast | precision | update | status |
taosdemo is simulating data generated by power equipments monitoring...
taosdemo is simulating data generated by power equipments monitoring...
...
@@ -217,27 +300,3 @@ tdengine
...
@@ -217,27 +300,3 @@ tdengine
-**docker stop**: Stop the specified running docker image with docker stop.
-**docker stop**: Stop the specified running docker image with docker stop.
-**tdengine**: The name of the container.
-**tdengine**: The name of the container.
## TDengine connected in Docker during programming development
There are two ideas for connecting from outside of Docker to use TDengine services running inside a Docker container:
1, By port mapping (-p), the open network port inside the container is mapped to the specified port of the host. By mounting the local directory (-v), you can synchronize the data inside the host and the container to prevent data loss after the container is deleted.
```bash
$ docker run -d-v /etc/taos:/etc/taos -P 6041:6041 tdengine/tdengine
- The first command starts a docker container with TDengine running and maps the 6041 port of the container to port 6041 of the host.
- The second command, accessing TDengine through the RESTful interface, connects to port 6041 on the local machine, so the connection is successful.
Note: In this example, for convenience reasons, only port 6041 is mapped, which is required for RESTful. If you wish to connect to the TDengine service in a non-RESTful manner, you will need to map a total of 11 ports starting at 6030. In the example, mounting the local directory also only deals with the /etc/taos directory where the configuration files are located, but not the data storage directory.
2, Go directly to the docker container to do development via the exec command. That is, put the program code in the same Docker container where the TDengine server is located and connect to the TDengine service local to the container.
@@ -761,17 +761,16 @@ Query OK, 1 row(s) in set (0.000141s)
...
@@ -761,17 +761,16 @@ Query OK, 1 row(s) in set (0.000141s)
you see sample code here: [JDBC example](https://github.com/taosdata/TDengine/tree/develop/tests/examples/JDBC)
you see sample code here: [JDBC example](https://github.com/taosdata/TDengine/tree/develop/tests/examples/JDBC)
## FAQ
## FAQ
- Why does not addBatch and executeBatch provide a performance benefit for executing "batch writes/updates"?
**Cause**:In TDengine's JDBC implementation, SQL statements submitted through the addBatch method are executed in the order in which they are added. This method does not reduce the number of interactions with the server and does not improve performance.
**Answer**：1. Concatenate multiple values in an INSERT statement; 2. Use multi-threaded concurrent insertion; 3. Use the parameter-binding to write
- java.lang.UnsatisfiedLinkError: no taos in java.library.path
- java.lang.UnsatisfiedLinkError: no taos in java.library.path
**Cause**：The application program cannot find Library function *taos*
**Cause**：The application program cannot find Library function *taos*
**Answer**：Copy `C:\TDengine\driver\taos.dll` to `C:\Windows\System32\` on Windows and make a soft link through `ln -s /usr/local/taos/driver/libtaos.so.x.x.x.x /usr/lib/libtaos.so` on Linux.
**Answer**：Copy `C:\TDengine\driver\taos.dll` to `C:\Windows\System32\` on Windows and make a soft link through `ln -s /usr/local/taos/driver/libtaos.so.x.x.x.x /usr/lib/libtaos.so` on Linux.
- java.lang.UnsatisfiedLinkError: taos.dll Can't load AMD 64 bit on a IA 32-bit platform
- java.lang.UnsatisfiedLinkError: taos.dll Can't load AMD 64 bit on a IA 32-bit platform
**Cause**：Currently TDengine only support 64bit JDK
**Cause**：Currently TDengine only support 64bit JDK
**Answer**：re-install 64bit JDK.
**Answer**：re-install 64bit JDK.
- For other questions, please refer to [Issues](https://github.com/taosdata/TDengine/issues)
- For other questions, please refer to [Issues](https://github.com/taosdata/TDengine/issues)
sql='select * from stable_1 where t_smallint between 0 and 32767 and t_float between 0 and 3.4E38 and t_nchar is not null and q_smallint between 0 and 32767 and q_nchar is not null and t_binary is not null and q_tinyint is not null and ts < now +1s order by ts ;;;'
tdSql.query('select q_int from sub_empty_1 union all select q_int from sub_empty_2;')
tdSql.checkRows(0)
tdSql.error('select q_int from sub_empty_1 union all select q_int from stable_empty group by tbname;')
tdSql.error('select q_intfrom group by tbname union all select q_int from sub_empty_1 group by tbname;')
tdSql.query('select q_int from sub_empty_1 union all select q_int from stable_empty ;')
tdSql.checkRows(0)
tdSql.query('select q_int from stable_empty union all select q_int from sub_empty_1 ;')
tdSql.checkRows(0)
tdSql.query('select q_int from stable_1 union all select q_int from stable_empty ;')
tdSql.checkRows(30)
tdSql.query('select q_int from stable_1 union all select q_int from sub_empty_1 ;')
tdSql.checkRows(30)
tdSql.query('select q_int from sub_table1_2 union all select q_int from stable_empty ;')
tdSql.checkRows(10)
tdSql.query('select q_int from sub_table1_2 union all select q_int from sub_empty_1 ;')
tdSql.checkRows(10)
tdSql.query('select q_int from stable_empty union all select q_int from sub_table1_2 ;')
tdSql.checkRows(10)
tdSql.query('select q_int from sub_empty_1 union all select q_int from sub_table1_2 ;')
tdSql.checkRows(10)
tdSql.query('select q_int from regular_empty union all select q_int from stable_empty ;')
tdSql.checkRows(0)
tdSql.query('select q_int from regular_empty union all select q_int from sub_empty_1 ;')
tdSql.checkRows(0)
tdSql.query('select q_int from stable_empty union all select q_int from regular_empty ;')
tdSql.checkRows(0)
tdSql.query('select q_int from sub_empty_1 union all select q_int from regular_empty ;')
tdSql.checkRows(0)
tdSql.query('select q_int from regular_empty union all select q_int from regular_table_2 ;')
tdSql.checkRows(10)
tdSql.query('select q_int from regular_empty union all select q_int from sub_empty_1 ;')
tdSql.checkRows(0)
tdSql.query('select q_int from stable_empty union all select q_int from regular_table_2 ;')
tdSql.checkRows(10)
tdSql.query('select q_int from sub_empty_1 union all select q_int from regular_table_2 ;')
tdSql.checkRows(10)
# regular table
tdSql.query('select q_int from regular_table_3 union all select q_int from regular_table_2 ;')
tdSql.checkRows(20)
tdSql.query('select q_int from regular_table_2 union all select q_int from regular_table_3 ;')
tdSql.checkRows(20)
tdSql.query('select q_int from regular_table_3 union all select q_int from sub_empty_1 ;')
tdSql.checkRows(10)
tdSql.query('select q_int from sub_table1_1 union all select q_int from regular_table_2 ;')
tdSql.checkRows(20)
tdSql.query('select q_int from regular_table_2 union all select q_int from sub_table1_1 ;')
tdSql.checkRows(20)
tdSql.query('select q_int from sub_empty_1 union all select q_int from regular_table_2 ;')
tdSql.checkRows(10)
tdSql.query('select q_int from regular_table_2 union all select q_int from sub_empty_1 ;')
tdSql.checkRows(10)
tdSql.query('select q_int from sub_empty_1 union all select q_int from stable_1 ;')
tdSql.checkRows(30)
tdSql.query('select q_int from stable_1 union all select q_int from sub_empty_1 ;')
tdSql.checkRows(30)
tdSql.query('select q_int from regular_table_1 union all select q_int from stable_1 ;')
tdSql.checkRows(40)
tdSql.query('select q_int from stable_1 union all select q_int from regular_table_1 ;')
tdSql.checkRows(40)
tdSql.query('select q_int from sub_empty_1 union all select q_int from regular_table_2 ;')
tdSql.checkRows(10)
tdSql.query('select q_int from regular_table_2 union all select q_int from sub_empty_1 ;')
tdSql.checkRows(10)
tdSql.query('select q_int from regular_table_1 union all select q_int from regular_table_2 ;')
tdSql.checkRows(20)
tdSql.query('select q_int from regular_table_2 union all select q_int from regular_table_1 ;')
tdSql.checkRows(20)
# sub_table
tdSql.query('select q_int from sub_empty_1 union all select q_int from sub_table2_2 ;')
tdSql.checkRows(10)
tdSql.query('select q_int from sub_table2_2 union all select q_int from sub_empty_1 ;')
tdSql.checkRows(10)
tdSql.query('select q_int from regular_table_1 union all select q_int from sub_table2_2 ;')
tdSql.checkRows(20)
tdSql.query('select q_int from sub_table2_2 union all select q_int from regular_table_1 ;')
tdSql.checkRows(20)
tdSql.query('select q_int from sub_table2_1 union all select q_int from sub_table2_2 ;')
tdSql.checkRows(20)
tdSql.query('select q_int from sub_table2_2 union all select q_int from sub_table2_1 ;')
tdSql.checkRows(20)
tdSql.query('select q_int from sub_table2_1 union all select q_int from sub_table2_2 ;')
tdSql.checkRows(20)
tdSql.query('select q_int from sub_table2_2 union all select q_int from sub_table2_1 ;')
tdSql.checkRows(20)
tdSql.query('select q_int from sub_table2_2 union all select q_int from sub_table2_2 ;')
tdSql.checkRows(20)
# stable
tdSql.query('select q_int from stable_1 union all select q_int from sub_table2_2 ;')
tdSql.checkRows(40)
tdSql.query('select q_int from sub_table2_2 union all select q_int from stable_1 ;')
tdSql.checkRows(40)
tdSql.query('select q_int from stable_2 union all select q_int from stable_1 ;')
tdSql.checkRows(60)
tdSql.query('select q_int from stable_1 union all select q_int from stable_2 ;')
tdSql.checkRows(60)
tdSql.query('select q_int from stable_1 union all select q_int from stable_1 ;')
tdSql.checkRows(60)
tdSql.query('select q_int from stable_empty union all select q_int from stable_1 ;')
tdSql.checkRows(30)
tdSql.query('select q_int from stable_1 union all select q_int from stable_empty ;')
tdSql.checkRows(30)
tdSql.query('select q_int from stable_empty union all select q_int from stable_1 ;')
tdSql.checkRows(30)
tdSql.query('select q_int from stable_1 union all select q_int from stable_empty ;')
tdSql.checkRows(30)
tdSql.query('select q_int from regular_empty union all select q_int from stable_1 ;')
tdSql.checkRows(30)
tdSql.query('select q_int from stable_1 union all select q_int from regular_empty ;')
tdSql.checkRows(30)
tdSql.query('select q_int from regular_empty union all select q_int from stable_1 ;')
tdSql.checkRows(30)
tdSql.query('select q_int from stable_1 union all select q_int from regular_empty ;')
tdSql.checkRows(30)
tdSql.query('select q_int from stable_1 union all select q_int from stable_empty ;')
tdSql.checkRows(30)
tdSql.query('select q_int from sub_empty_2 union all select q_int from stable_1 ;')
tdSql.checkRows(30)
tdSql.query('select q_int from stable_1 union all select q_int from sub_empty_2 ;')
tdSql.checkRows(30)
tdSql.query('select q_int from sub_empty_2 union all select q_int from stable_1 ;')
tdSql.checkRows(30)
tdSql.query('select q_int from stable_1 union all select q_int from sub_empty_2 ;')
tdSql.checkRows(30)
defquery_with_union(self):
tdLog.info(" ====================================== elapsed mixup with union all =================================================")
# union all with empty
tdSql.query("select elapsed(ts,10s) from regular_table_1 union all select elapsed(ts,10s) from regular_table_2;")
tdSql.query("select elapsed(ts,10s) from regular_table_1 where ts>=\"2015-01-01 00:00:00.000\" and ts < \"2015-01-01 00:10:00.000\" interval(1s) fill(prev) union all \
select elapsed(ts,10s) from regular_table_2 where ts>=\"2015-01-01 00:00:00.000\" and ts < \"2015-01-01 00:10:00.000\" interval(1s) fill(prev);")
tdSql.checkRows(1200)
tdSql.checkData(0,1,0.1)
tdSql.checkData(500,1,0)
tdSql.query("select elapsed(ts,10s) from sub_empty_1 where ts>=\"2015-01-01 00:00:00.000\" and ts < \"2015-01-01 00:10:00.000\" interval(1s) fill(prev) union all \
select elapsed(ts,10s) from regular_table_2 where ts>=\"2015-01-01 00:00:00.000\" and ts < \"2015-01-01 00:10:00.000\" interval(1s) fill(prev);")
tdSql.checkRows(600)
tdSql.checkData(0,1,0.1)
tdSql.checkData(500,0,0)
tdSql.query('select elapsed(ts,10s) from sub_empty_1 union all select elapsed(ts,10s) from sub_empty_2;')
tdSql.checkRows(0)
tdSql.query('select elapsed(ts,10s) from regular_table_1 union all select elapsed(ts,10s) from sub_empty_1;')
tdSql.checkRows(1)
tdSql.checkData(0,0,9)
tdSql.query('select elapsed(ts,10s) from sub_empty_1 union all select elapsed(ts,10s) from regular_table_1;')
tdSql.checkRows(1)
tdSql.checkData(0,0,9)
tdSql.query('select elapsed(ts,10s) from sub_empty_1 union all select elapsed(ts,10s) from sub_table1_1;')
tdSql.checkRows(1)
tdSql.checkData(0,0,9)
tdSql.query('select elapsed(ts,10s) from sub_table1_1 union all select elapsed(ts,10s) from sub_empty_1;')
tdSql.checkRows(1)
tdSql.checkData(0,0,9)
tdSql.query('select elapsed(ts,10s) from sub_empty_1 union all select elapsed(ts,10s) from regular_table_1;')
tdSql.checkRows(1)
tdSql.checkData(0,0,9)
tdSql.error('select elapsed(ts,10s) from sub_empty_1 union all select elapsed(ts,10s) from stable_sub_empty group by tbname;')
tdSql.error('select elapsed(ts,10s) from regular_table_1 union all select elapsed(ts,10s) from stable_sub_empty group by tbname;')
tdSql.query('select elapsed(ts,10s) from sub_empty_1 where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(1s) fill(prev) union all select elapsed(ts,10s) from sub_empty_2 where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(1s) fill(prev);')
tdSql.checkRows(0)
tdSql.error('select elapsed(ts,10s) from sub_empty_1 union all select elapsed(ts,10s) from stable_empty group by tbname;')
tdSql.error('select elapsed(ts,10s) from sub_empty_1 interval(1s) union all select elapsed(ts,10s) from stable_empty interval(1s) group by tbname;')
tdSql.error('select elapsed(ts,10s) from sub_empty_1 where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(1s) fill(prev) union all select elapsed(ts,10s) from stable_empty where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(1s) fill(prev) group by tbname;')
tdSql.query("select elapsed(ts,10s) from stable_empty group by tbname union all select elapsed(ts,10s) from stable_empty group by tbname ;")
tdSql.checkRows(0)
tdSql.query("select elapsed(ts,10s) from stable_empty group by tbname union all select elapsed(ts,10s) from stable_1 group by tbname ;")
tdSql.checkRows(3)
tdSql.query("select elapsed(ts,10s) from stable_1 group by tbname union all select elapsed(ts,10s) from stable_1 group by tbname ;")
tdSql.checkRows(6)
tdSql.checkData(0,0,9)
tdSql.checkData(5,0,9)
tdSql.query("select elapsed(ts,10s) from stable_1 group by tbname union all select elapsed(ts,10s) from stable_2 group by tbname ;")
tdSql.checkRows(6)
tdSql.checkData(0,0,9)
tdSql.checkData(5,0,9)
tdSql.query('select elapsed(ts,10s) from stable_1 where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(10s) fill(prev) group by tbname union all\
select elapsed(ts,10s) from stable_2 where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(10s) fill(prev) group by tbname ;')
tdSql.checkRows(360)
tdSql.checkData(0,1,1)
tdSql.checkData(50,1,0)
tdSql.query('select elapsed(ts,10s) from stable_empty group by tbname union all select elapsed(ts,10s) from stable_2 group by tbname ;')
tdSql.checkRows(3)
tdSql.query('select elapsed(ts,10s) from stable_1 group by tbname union all select elapsed(ts,10s) from stable_empty group by tbname ;')
tdSql.checkRows(3)
tdSql.query('select elapsed(ts,10s) from stable_empty where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(10s) fill(prev) group by tbname union all\
select elapsed(ts,10s) from stable_2 where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(10s) fill(prev) group by tbname ;')
tdSql.checkRows(180)
tdSql.query('select elapsed(ts,10s) from stable_1 where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(10s) fill(prev) group by tbname union all\
select elapsed(ts,10s) from stable_empty where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(10s) fill(prev) group by tbname ;')
tdSql.checkRows(180)
tdSql.query('select elapsed(ts,10s) from sub_table1_1 where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(10s) fill(prev) union all\
select elapsed(ts,10s) from sub_table2_2 where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(10s) fill(prev) ;')
tdSql.checkRows(120)
tdSql.checkData(0,1,1)
tdSql.checkData(12,1,0)
tdSql.query('select elapsed(ts,10s) from sub_table1_1 where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(10s) fill(prev) union all\
select elapsed(ts,10s) from sub_table1_1 where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(10s) fill(prev) ;')
tdSql.checkRows(120)
tdSql.checkData(0,1,1)
tdSql.checkData(12,1,0)
tdSql.query('select elapsed(ts,10s) from regular_table_1 where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(10s) fill(prev) union all\
select elapsed(ts,10s) from sub_table1_1 where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(10s) fill(prev) ;')
tdSql.checkRows(120)
tdSql.checkData(0,1,1)
tdSql.checkData(12,1,0)
tdSql.query('select elapsed(ts,10s) from regular_table_1 where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(10s) fill(prev) union all\
select elapsed(ts,10s) from regular_table_1 where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(10s) fill(prev) ;')
tdSql.checkRows(120)
tdSql.checkData(0,1,1)
tdSql.checkData(12,1,0)
tdSql.query('select elapsed(ts,10s) from regular_table_1 where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(10s) fill(prev) union all\
select elapsed(ts,10s) from regular_table_2 where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(10s) fill(prev) ;')
tdSql.checkRows(120)
tdSql.checkData(0,1,1)
tdSql.checkData(12,1,0)
tdSql.query('select elapsed(ts,10s) from regular_table_1 where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(10s) fill(prev) union all\
select elapsed(ts,10s) from regular_table_2 where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(10s) fill(prev) ;')
tdSql.checkRows(120)
tdSql.checkData(0,1,1)
tdSql.checkData(12,1,0)
tdSql.query('select elapsed(ts,10s) from sub_empty_1 where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(10s) fill(prev) union all\
select elapsed(ts,10s) from regular_table_2 where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(10s) fill(prev) ;')
tdSql.checkRows(60)
tdSql.checkData(0,1,1)
tdSql.checkData(12,1,0)
tdSql.query('select elapsed(ts,10s) from regular_table_2 where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(10s) fill(prev) union all\
select elapsed(ts,10s) from sub_empty_1 where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(10s) fill(prev) ;')
tdSql.checkRows(60)
tdSql.checkData(0,1,1)
tdSql.checkData(12,1,0)
# stable with stable
tdSql.query('select elapsed(ts,10s) from stable_1 where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(10s) fill(prev) group by tbname union all\
select elapsed(ts,10s) from stable_1 where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(10s) fill(prev) group by tbname;')
tdSql.checkRows(360)
tdSql.checkData(0,1,1)
tdSql.checkData(12,1,0)
tdSql.query('select elapsed(ts,10s) from regular_table_2 interval(10s) union all select elapsed(ts,10s) from sub_empty_1 where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(10s) fill(prev);')
tdSql.checkRows(10)
tdSql.checkData(0,1,1)
tdSql.checkData(9,1,0)
tdSql.query('select elapsed(ts,10s) from regular_table_2 interval(10s) union all select elapsed(ts,10s) from regular_table_1 where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(10s) fill(prev) ;')
tdSql.checkRows(70)
tdSql.checkData(0,1,1)
tdSql.checkData(9,1,0)
tdSql.query('select elapsed(ts,10s) from regular_table_2 interval(10s) order by ts desc union all select elapsed(ts,10s) from regular_table_1 where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(10s) fill(prev) order by ts asc;')
tdSql.checkRows(70)
tdSql.checkData(0,1,0)
tdSql.checkData(1,1,1)
tdSql.checkData(9,1,1)
tdSql.query('select elapsed(ts,10s) from stable_1 group by tbname, ind order by ts desc union all select elapsed(ts,10s) from stable_2 group by tbname, ind order by ts asc ;')
tdSql.checkRows(6)
tdSql.checkData(0,0,9)
tdSql.query('select elapsed(ts,10s) from stable_1 group by tbname, ind order by ts desc union all select elapsed(ts,10s) from stable_1 group by tbname, ind order by ts asc ;')
tdSql.checkRows(6)
tdSql.checkData(0,0,9)
tdSql.query('select elapsed(ts,10s) from stable_1 interval(10s) group by tbname,ind order by ts desc union all select elapsed(ts,10s) from stable_2 where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(10s) fill(prev) group by tbname,ind order by ts asc ;')
tdSql.checkRows(210)
tdSql.checkData(0,1,0)
tdSql.checkData(1,1,1)
tdSql.checkData(9,1,1)
tdSql.query('select elapsed(ts,10s) from stable_2 interval(10s) group by tbname,ind order by ts desc union all select elapsed(ts,10s) from stable_1 where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(10s) fill(prev) group by tbname,ind order by ts asc ;')
tdSql.checkRows(210)
tdSql.checkData(0,1,0)
tdSql.checkData(1,1,1)
tdSql.checkData(9,1,1)
tdSql.query('select elapsed(ts,10s) from stable_1 interval(10s) group by tbname,ind order by ts desc union all select elapsed(ts,10s) from stable_1 where ts>="2015-01-01 00:00:00.000" and ts < "2015-01-01 00:10:00.000" interval(10s) fill(prev) group by tbname,ind order by ts asc ;')
tdSql.execute("create database if not exists testdb keep 36500;")
tdSql.execute("use testdb;")
tdSql.execute("create stable st (ts timestamp , id int , value double) tags(hostname binary(10) ,ind int);")
foriinrange(self.num):
tdSql.execute("insert into sub_%s using st tags('host_%s' , %d) values (%d , %d , %f );"%(str(i),str(i),i*10,self.ts+100*i,i*2,i+10.00))
tdSql.execute("insert into sub_%s using st tags('host_%s' , %d) values (%d , %d , %f );"%(str(i),str(i),i*10,self.ts+200*i,i*2,i+10.00))
tdSql.execute("insert into sub_%s using st tags('host_%s' , %d) values (%d , %d , %f );"%(str(i),str(i),i*10,self.ts+300*i,i*2,i+10.00))
tdSql.execute("insert into sub_%s using st tags('host_%s' , %d) values (%d , %d , %f );"%(str(i),str(i),i*10,self.ts+10000*i,i*2,i+10.00))
cfg_path=self.getcfgPath()
print(cfg_path)
tdSql.execute('select elapsed(ts,10s) from testdb.st where ts>=\"2015-01-01 00:00:00.000\" and ts < \"2015-01-01 00:10:00.000\" session(ts,1d) group by tbname;')
datas=tdSql.getResult('select elapsed(ts,10s) from testdb.st where ts>=\"2015-01-01 00:00:00.000\" and ts < \"2015-01-01 00:10:00.000\" session(ts,1d) group by tbname;')
table_names=["sub_%s"%str(i)foriinrange(10)]
# print(table_names)
forindex,table_nameinenumerate(table_names):
tdSql.query("select elapsed(ts,10s) from testdb.%s where ts>=\"2015-01-01 00:00:00.000\" and ts < \"2015-01-01 00:10:00.000\" session(ts,1d) ;"%table_name)
# print(datas)
tdSql.checkData(0,1,datas[index][1])
foriinrange(10):
taos_cmd1="taos -c %s -s 'select elapsed(ts,10s) from testdb.st where ts>=\"2015-01-01 00:00:00.000\" and ts < \"2015-01-01 00:10:00.000\" session(ts,1d) group by tbname;' "%(cfg_path)
tdSql.execute("create table db.`%s` as select avg(`%s`) from db.`%s` where ts > now interval(1m) sliding(30s);"%(self.cr_tb1,self.col_bigint,self.stb1))
tdSql.query("show db.tables like 'create_table_%' ")
tdSql.checkRows(1)
print("==============drop\ add\ change\ modify column or tag")
print("==============drop==============")
tdSql.execute("ALTER TABLE db.`%s` DROP TAG `%s`; "%(self.stb1,self.tag_ts))
sql=" select * from db.`%s`; "%self.stb1
datacheck=self.table1_checkall(sql)
tdSql.query("describe db.`%s` ; "%self.tb1)
tdSql.checkRows(21)
tdSql.execute("ALTER TABLE db.`%s` DROP TAG `%s`; "%(self.stb1,self.tag_double))
sql=" select * from db.`%s`; "%self.stb1
datacheck=self.table1_checkall(sql)
tdSql.query("describe db.`%s` ; "%self.tb1)
tdSql.checkRows(20)
tdSql.execute("ALTER TABLE db.`%s` DROP TAG `%s`; "%(self.stb1,self.tag_float))
sql=" select * from db.`%s`; "%self.stb1
datacheck=self.table1_checkall(sql)
tdSql.query("describe db.`%s` ; "%self.tb1)
tdSql.checkRows(19)
tdSql.execute("ALTER TABLE db.`%s` DROP TAG `%s`; "%(self.stb1,self.tag_nchar))
sql=" select * from db.`%s`; "%self.stb1
datacheck=self.table1_checkall(sql)
tdSql.query("describe db.`%s` ; "%self.tb1)
tdSql.checkRows(18)
tdSql.execute("ALTER TABLE db.`%s` DROP TAG `%s`; "%(self.stb1,self.tag_binary))
sql=" select * from db.`%s`; "%self.stb1
datacheck=self.table1_checkall(sql)
tdSql.query("describe db.`%s` ; "%self.tb1)
tdSql.checkRows(17)
tdSql.execute("ALTER TABLE db.`%s` DROP TAG `%s`; "%(self.stb1,self.tag_bool))
sql=" select * from db.`%s`; "%self.stb1
datacheck=self.table1_checkall(sql)
tdSql.query("describe db.`%s` ; "%self.tb1)
tdSql.checkRows(16)
tdSql.execute("ALTER TABLE db.`%s` DROP TAG `%s`; "%(self.stb1,self.tag_tinyint))
sql=" select * from db.`%s`; "%self.stb1
datacheck=self.table1_checkall(sql)
tdSql.query("describe db.`%s` ; "%self.tb1)
tdSql.checkRows(15)
tdSql.execute("ALTER TABLE db.`%s` DROP TAG `%s`; "%(self.stb1,self.tag_smallint))
sql=" select * from db.`%s`; "%self.stb1
datacheck=self.table1_checkall(sql)
tdSql.query("describe db.`%s` ; "%self.tb1)
tdSql.checkRows(14)
tdSql.execute("ALTER TABLE db.`%s` DROP TAG `%s`; "%(self.stb1,self.tag_bigint))
sql=" select * from db.`%s`; "%self.stb1
datacheck=self.table1_checkall(sql)
tdSql.query("describe db.`%s` ; "%self.tb1)
tdSql.checkRows(13)
tdSql.execute("ALTER TABLE db.`%s` DROP TAG `%s`; "%(self.stb1,self.tag_int))
sql=" select * from db.`%s`; "%self.stb1
datacheck=self.table1_checkall(sql)
tdSql.query("describe db.`%s` ; "%self.tb1)
tdSql.checkRows(12)
tdSql.execute("ALTER TABLE db.`%s` DROP COLUMN `%s`; "%(self.stb1,self.col_ts))
sql=" select * from db.`%s`; "%self.stb1
datacheck=self.table1_checkall_9(sql)
tdSql.query("describe db.`%s` ; "%self.tb1)
tdSql.checkRows(11)
tdSql.execute("ALTER TABLE db.`%s` DROP COLUMN `%s`; "%(self.stb1,self.col_double))
sql=" select * from db.`%s`; "%self.stb1
datacheck=self.table1_checkall_8(sql)
tdSql.query("describe db.`%s` ; "%self.tb1)
tdSql.checkRows(10)
tdSql.execute("ALTER TABLE db.`%s` DROP COLUMN `%s`; "%(self.stb1,self.col_float))
sql=" select * from db.`%s`; "%self.stb1
datacheck=self.table1_checkall_7(sql)
tdSql.query("describe db.`%s` ; "%self.tb1)
tdSql.checkRows(9)
tdSql.execute("ALTER TABLE db.`%s` DROP COLUMN `%s`; "%(self.stb1,self.col_nchar))
sql=" select * from db.`%s`; "%self.stb1
datacheck=self.table1_checkall_6(sql)
tdSql.query("describe db.`%s` ; "%self.tb1)
tdSql.checkRows(8)
tdSql.execute("ALTER TABLE db.`%s` DROP COLUMN `%s`; "%(self.stb1,self.col_binary))
sql=" select * from db.`%s`; "%self.stb1
datacheck=self.table1_checkall_5(sql)
tdSql.query("describe db.`%s` ; "%self.tb1)
tdSql.checkRows(7)
tdSql.execute("ALTER TABLE db.`%s` DROP COLUMN `%s`; "%(self.stb1,self.col_bool))
sql=" select * from db.`%s`; "%self.stb1
datacheck=self.table1_checkall_4(sql)
tdSql.query("describe db.`%s` ; "%self.tb1)
tdSql.checkRows(6)
tdSql.execute("ALTER TABLE db.`%s` DROP COLUMN `%s`; "%(self.stb1,self.col_tinyint))
sql=" select * from db.`%s`; "%self.stb1
datacheck=self.table1_checkall_3(sql)
tdSql.query("describe db.`%s` ; "%self.tb1)
tdSql.checkRows(5)
tdSql.execute("ALTER TABLE db.`%s` DROP COLUMN `%s`; "%(self.stb1,self.col_smallint))
sql=" select * from db.`%s`; "%self.stb1
datacheck=self.table1_checkall_2(sql)
tdSql.query("describe db.`%s` ; "%self.tb1)
tdSql.checkRows(4)
tdSql.execute("ALTER TABLE db.`%s` DROP COLUMN `%s`; "%(self.stb1,self.col_bigint))
sql=" select * from db.`%s`; "%self.stb1
datacheck=self.table1_checkall_1(sql)
tdSql.query("describe db.`%s` ; "%self.tb1)
tdSql.checkRows(3)
tdSql.error("ALTER TABLE db.`%s` DROP COLUMN `%s`; "%(self.stb1,self.col_int))
sql=" select * from db2.`%s`; "%self.regular_table
datacheck=self.table1_checkall(sql)
tdSql.checkRows(2)
sql=" select * from db2.`%s` where `%s`=1 and `%s`=2 and `%s`=3 and `%s`=4 and `%s`='True' and `%s`=6 and `%s`=7 and `%s`=8 and `%s`=9 and `%s`=10; " \
sql=" select * from db2.`%s` order by ts desc; "%self.regular_table
datacheck=self.table1_checkall(sql)
tdSql.checkRows(6)
sql=" select * from db2.`%s` where `%s`=1 and `%s`=2 and `%s`=3 and `%s`=4 and `%s`='True' and `%s`=6 and `%s`=7 and `%s`=8 and `%s`=9 and `%s`=10; " \
