modify node ci example
This commit is contained in:
parent
7576e3d9e9
commit
fba6877702
|
@ -58,6 +58,7 @@ node sql_example.js
|
|||
|
||||
node stmt_example.js
|
||||
|
||||
|
||||
node tmq_example.js
|
||||
|
||||
node tmq_seek_example.js
|
|
@ -2,6 +2,34 @@
|
|||
|
||||
set -e
|
||||
|
||||
check_transactions() {
|
||||
for i in {1..30}
|
||||
do
|
||||
output=$(taos -s "show transactions;")
|
||||
if [[ $output == *"Query OK, 0 row(s)"* ]]; then
|
||||
echo "Success: No transactions are in progress."
|
||||
return 0
|
||||
fi
|
||||
sleep 1
|
||||
done
|
||||
|
||||
echo "Error: Transactions are still in progress after 30 attempts."
|
||||
return 1
|
||||
}
|
||||
|
||||
reset_cache() {
|
||||
response=$(curl --location -uroot:taosdata 'http://127.0.0.1:6041/rest/sql' --data 'reset query cache')
|
||||
|
||||
if [[ $response == \{\"code\":0* ]]; then
|
||||
echo "Success: Query cache reset successfully."
|
||||
else
|
||||
echo "Error: Failed to reset query cache. Response: $response"
|
||||
return 1
|
||||
fi
|
||||
}
|
||||
|
||||
|
||||
|
||||
taosd >>/dev/null 2>&1 &
|
||||
taosadapter >>/dev/null 2>&1 &
|
||||
|
||||
|
@ -11,18 +39,26 @@ cd ../../docs/examples/python
|
|||
|
||||
# 1
|
||||
taos -s "create database if not exists log"
|
||||
check_transactions || exit 1
|
||||
reset_cache || exit 1
|
||||
python3 connect_example.py
|
||||
|
||||
# 2
|
||||
taos -s "drop database if exists power"
|
||||
check_transactions || exit 1
|
||||
reset_cache || exit 1
|
||||
python3 native_insert_example.py
|
||||
|
||||
# 3
|
||||
taos -s "drop database power"
|
||||
check_transactions || exit 1
|
||||
reset_cache || exit 1
|
||||
python3 bind_param_example.py
|
||||
|
||||
# 4
|
||||
taos -s "drop database power"
|
||||
check_transactions || exit 1
|
||||
reset_cache || exit 1
|
||||
python3 multi_bind_example.py
|
||||
|
||||
# 5
|
||||
|
@ -33,20 +69,28 @@ python3 async_query_example.py
|
|||
|
||||
# 7
|
||||
taos -s "drop database if exists test"
|
||||
check_transactions || exit 1
|
||||
reset_cache || exit 1
|
||||
python3 line_protocol_example.py
|
||||
|
||||
# 8
|
||||
taos -s "drop database test"
|
||||
check_transactions || exit 1
|
||||
reset_cache || exit 1
|
||||
python3 telnet_line_protocol_example.py
|
||||
|
||||
# 9
|
||||
taos -s "drop database test"
|
||||
check_transactions || exit 1
|
||||
reset_cache || exit 1
|
||||
python3 json_protocol_example.py
|
||||
|
||||
# 10
|
||||
pip install SQLAlchemy
|
||||
pip install pandas
|
||||
taosBenchmark -y -d power -t 10 -n 10
|
||||
check_transactions || exit 1
|
||||
reset_cache || exit 1
|
||||
python3 conn_native_pandas.py
|
||||
python3 conn_rest_pandas.py
|
||||
taos -s "drop database if exists power"
|
||||
|
@ -119,10 +163,19 @@ python3 reqid_rest.py
|
|||
|
||||
python3 reqid_ws.py
|
||||
|
||||
taos -s "drop database test"
|
||||
check_transactions || exit 1
|
||||
reset_cache || exit 1
|
||||
python3 schemaless_native.py
|
||||
|
||||
taos -s "drop database test"
|
||||
check_transactions || exit 1
|
||||
reset_cache || exit 1
|
||||
python3 schemaless_ws.py
|
||||
|
||||
taos -s "drop database test"
|
||||
check_transactions || exit 1
|
||||
reset_cache || exit 1
|
||||
python3 stmt_native.py
|
||||
|
||||
python3 stmt_ws.py
|
||||
|
|
Loading…
Reference in New Issue