From c1a19ae0f4e5cd027719aeb53af98499df6903e8 Mon Sep 17 00:00:00 2001 From: menshibin Date: Tue, 24 Sep 2024 19:24:20 +0800 Subject: [PATCH] add nodejs python ci examples --- .../node/websocketexample/all_type_query.js | 13 ++++++++++--- .../node/websocketexample/all_type_stmt.js | 15 +++++++++++---- .../websocketexample/json_line_example.js | 1 + .../node/websocketexample/line_example.js | 1 + .../node/websocketexample/nodejsChecker.js | 3 ++- .../node/websocketexample/sql_example.js | 19 ++++++++++++++----- .../node/websocketexample/stmt_example.js | 1 + .../websocketexample/telnet_line_example.js | 3 ++- .../node/websocketexample/tmq_example.js | 1 + .../node/websocketexample/tmq_seek_example.js | 1 + docs/examples/python/connect_example.py | 3 ++- 11 files changed, 46 insertions(+), 15 deletions(-) diff --git a/docs/examples/node/websocketexample/all_type_query.js b/docs/examples/node/websocketexample/all_type_query.js index 266d110d24..c628b2f7b4 100644 --- a/docs/examples/node/websocketexample/all_type_query.js +++ b/docs/examples/node/websocketexample/all_type_query.js @@ -34,6 +34,7 @@ async function json_tag_example() { } catch (err) { console.error(`Failed to create database example_json_tag or stable stb, ErrCode: ${err.code}, ErrMessage: ${err.message}`); + throw err; } finally { if (wsSql) { await wsSql.close(); @@ -78,9 +79,10 @@ async function all_type_example() { let row = wsRows.getData(); console.log(row); } - + } catch (err) { console.error(`Failed to create database all_type_example or stable stb, ErrCode: ${err.code}, ErrMessage: ${err.message}`); + throw err; } finally { if (wsSql) { await wsSql.close(); @@ -90,8 +92,13 @@ async function all_type_example() { } async function test() { - await json_tag_example() - await all_type_example() + try { + await json_tag_example() + await all_type_example() + } catch (err) { + process.exitCode = 1; + } + taos.destroy(); } diff --git a/docs/examples/node/websocketexample/all_type_stmt.js b/docs/examples/node/websocketexample/all_type_stmt.js index 8a0dcf21e1..d4f0380621 100644 --- a/docs/examples/node/websocketexample/all_type_stmt.js +++ b/docs/examples/node/websocketexample/all_type_stmt.js @@ -46,6 +46,7 @@ async function json_tag_example() { } catch (err) { console.error(`Failed to create database example_json_tag or stable stb, ErrCode: ${err.code}, ErrMessage: ${err.message}`); + throw err } finally { if (wsSql) { await wsSql.close(); @@ -125,6 +126,7 @@ async function all_type_example() { } catch (err) { console.error(`Failed to create database all_type_example or stable stb, ErrCode: ${err.code}, ErrMessage: ${err.message}`); + throw err; } finally { if (stmt) { await stmt.close(); @@ -139,10 +141,15 @@ async function all_type_example() { async function test() { - taos.setLevel("debug") - await json_tag_example() - await all_type_example() - taos.destroy(); + try { + taos.setLevel("debug") + await json_tag_example() + await all_type_example() + taos.destroy(); + } catch(e) { + process.exitCode = 1 + } + } test() diff --git a/docs/examples/node/websocketexample/json_line_example.js b/docs/examples/node/websocketexample/json_line_example.js index e6587eaa45..42fd3f175e 100644 --- a/docs/examples/node/websocketexample/json_line_example.js +++ b/docs/examples/node/websocketexample/json_line_example.js @@ -38,6 +38,7 @@ async function test() { } catch (err) { console.error(err.code, err.message); + process.exitCode = 1; } finally { if (wsRows) { diff --git a/docs/examples/node/websocketexample/line_example.js b/docs/examples/node/websocketexample/line_example.js index ac3083d358..5502db2895 100644 --- a/docs/examples/node/websocketexample/line_example.js +++ b/docs/examples/node/websocketexample/line_example.js @@ -29,6 +29,7 @@ async function test() { } catch (err) { console.error(`Failed to insert data with schemaless, ErrCode: ${err.code}, ErrMessage: ${err.message}`); + process.exitCode = 1; } finally { if (wsRows) { diff --git a/docs/examples/node/websocketexample/nodejsChecker.js b/docs/examples/node/websocketexample/nodejsChecker.js index d81aeb585f..a3bfaa125e 100644 --- a/docs/examples/node/websocketexample/nodejsChecker.js +++ b/docs/examples/node/websocketexample/nodejsChecker.js @@ -11,7 +11,7 @@ for(var i = 2; i < global.process.argv.length; i++){ if(host == null){ console.log("Usage: node nodejsChecker.js host= port="); - process.exit(0); + process.exit(1); } @@ -62,6 +62,7 @@ async function test() { } catch (err) { console.error(err.code, err.message); + process.exitCode = 1; } finally { if (wsRows) { diff --git a/docs/examples/node/websocketexample/sql_example.js b/docs/examples/node/websocketexample/sql_example.js index 8eb8af989d..08095a0dee 100644 --- a/docs/examples/node/websocketexample/sql_example.js +++ b/docs/examples/node/websocketexample/sql_example.js @@ -41,6 +41,7 @@ async function createDbAndTable() { console.log("Create stable power.meters successfully"); } catch (err) { console.error(`Failed to create database power or stable meters, ErrCode: ${err.code}, ErrMessage: ${err.message}`); + throw err; } finally { if (wsSql) { await wsSql.close(); @@ -68,6 +69,7 @@ async function insertData() { console.log("Successfully inserted " + taosResult.getAffectRows() + " rows to power.meters."); } catch (err) { console.error(`Failed to insert data to power.meters, sql: ${insertQuery}, ErrCode: ${err.code}, ErrMessage: ${err.message}`); + throw err; } finally { if (wsSql) { await wsSql.close(); @@ -91,6 +93,7 @@ async function queryData() { } catch (err) { console.error(`Failed to query data from power.meters, sql: ${sql}, ErrCode: ${err.code}, ErrMessage: ${err.message}`); + throw err; } finally { if (wsRows) { @@ -118,6 +121,7 @@ async function sqlWithReqid() { } catch (err) { console.error(`Failed to query data from power.meters, reqId: ${reqId}, ErrCode: ${err.code}, ErrMessage: ${err.message}`); + throw err; } finally { if (wsRows) { @@ -131,11 +135,16 @@ async function sqlWithReqid() { // ANCHOR_END: sqlWithReqid async function test() { - await createDbAndTable(); - await insertData(); - await queryData(); - await sqlWithReqid(); - taos.destroy(); + try { + await createDbAndTable(); + await insertData(); + await queryData(); + await sqlWithReqid(); + taos.destroy(); + } catch(e) { + process.exitCode = 1; + } + } test() diff --git a/docs/examples/node/websocketexample/stmt_example.js b/docs/examples/node/websocketexample/stmt_example.js index e3bb3c4dda..cdd9cd6a15 100644 --- a/docs/examples/node/websocketexample/stmt_example.js +++ b/docs/examples/node/websocketexample/stmt_example.js @@ -60,6 +60,7 @@ async function prepare() { } catch (err) { console.error(`Failed to insert to table meters using stmt, ErrCode: ${err.code}, ErrMessage: ${err.message}`); + process.exitCode = 1; } finally { if (stmt) { diff --git a/docs/examples/node/websocketexample/telnet_line_example.js b/docs/examples/node/websocketexample/telnet_line_example.js index 924137e162..a2b0cc0c38 100644 --- a/docs/examples/node/websocketexample/telnet_line_example.js +++ b/docs/examples/node/websocketexample/telnet_line_example.js @@ -11,7 +11,7 @@ for(var i = 2; i < global.process.argv.length; i++){ if(host == null){ console.log("Usage: node nodejsChecker.js host= port="); - process.exit(0); + process.exit(1); } let dbData = ["meters.current 1648432611249 10.3 location=California.SanFrancisco groupid=2", @@ -44,6 +44,7 @@ async function test() { } catch (err) { console.error(err.code, err.message); + process.exitCode = 1; } finally { if (wsRows) { diff --git a/docs/examples/node/websocketexample/tmq_example.js b/docs/examples/node/websocketexample/tmq_example.js index 5097402e6a..3250b1aba3 100644 --- a/docs/examples/node/websocketexample/tmq_example.js +++ b/docs/examples/node/websocketexample/tmq_example.js @@ -89,6 +89,7 @@ async function test() { } catch (err) { console.error(`Failed to unsubscribe consumer, topic: ${topic}, groupId: ${groupId}, clientId: ${clientId}, ErrCode: ${err.code}, ErrMessage: ${err.message}`); + process.exitCode = 1; } finally { if (consumer) { diff --git a/docs/examples/node/websocketexample/tmq_seek_example.js b/docs/examples/node/websocketexample/tmq_seek_example.js index b2bd569d92..a5ef783ef9 100644 --- a/docs/examples/node/websocketexample/tmq_seek_example.js +++ b/docs/examples/node/websocketexample/tmq_seek_example.js @@ -89,6 +89,7 @@ async function test() { } catch (err) { console.error(`Failed to seek offset, topic: ${topic}, groupId: ${groupId}, clientId: ${clientId}, ErrCode: ${err.code}, ErrMessage: ${err.message}`); + process.exitCode = 1; } finally { if (consumer) { diff --git a/docs/examples/python/connect_example.py b/docs/examples/python/connect_example.py index ce8b306024..86b568c0aa 100644 --- a/docs/examples/python/connect_example.py +++ b/docs/examples/python/connect_example.py @@ -4,7 +4,7 @@ def create_connection(): # all parameters are optional. conn = None host = "localhost" - port = 6030 + port = 6031 try: conn = taos.connect( user="root", @@ -15,6 +15,7 @@ def create_connection(): print(f"Connected to {host}:{port} successfully."); except Exception as err: print(f"Failed to connect to {host}:{port} , ErrMessage:{err}") + raise err finally: if conn: conn.close()