|
| 1 | +#include <questdb/ilp/line_sender.h> |
| 2 | +#include <stdio.h> |
| 3 | +#include <stdbool.h> |
| 4 | +#include <string.h> |
| 5 | + |
| 6 | +static bool example(const char* host, const char* port) |
| 7 | +{ |
| 8 | + line_sender_error* err = NULL; |
| 9 | + line_sender_opts* opts = NULL; |
| 10 | + line_sender* sender = NULL; |
| 11 | + line_sender_buffer* buffer = NULL; |
| 12 | + |
| 13 | + line_sender_utf8 host_utf8 = { 0, NULL }; |
| 14 | + if (!line_sender_utf8_init(&host_utf8, strlen(host), host, &err)) |
| 15 | + goto on_error; |
| 16 | + |
| 17 | + line_sender_utf8 port_utf8 = { 0, NULL }; |
| 18 | + if (!line_sender_utf8_init(&port_utf8, strlen(port), port, &err)) |
| 19 | + goto on_error; |
| 20 | + |
| 21 | + // Call `line_sender_opts_new` if instead you have an integer port. |
| 22 | + opts = line_sender_opts_new_service(host_utf8, port_utf8); |
| 23 | + |
| 24 | + // Enable TLS to accept connections using common trusted CAs. |
| 25 | + line_sender_opts_tls(opts); |
| 26 | + |
| 27 | + // Use `QDB_UTF_8_FROM_STR_OR` to init from `const char*`. |
| 28 | + line_sender_utf8 key_id = QDB_UTF8_LITERAL("testUser1"); |
| 29 | + line_sender_utf8 priv_key = QDB_UTF8_LITERAL( |
| 30 | + "5UjEMuA0Pj5pjK8a-fa24dyIf-Es5mYny3oE_Wmus48"); |
| 31 | + line_sender_utf8 pub_key_x = QDB_UTF8_LITERAL( |
| 32 | + "fLKYEaoEb9lrn3nkwLDA-M_xnuFOdSt9y0Z7_vWSHLU"); |
| 33 | + line_sender_utf8 pub_key_y = QDB_UTF8_LITERAL( |
| 34 | + "Dt5tbS1dEDMSYfym3fgMv0B99szno-dFc1rYF9t0aac"); |
| 35 | + |
| 36 | + line_sender_opts_auth( |
| 37 | + opts, |
| 38 | + key_id, // kid |
| 39 | + priv_key, // d |
| 40 | + pub_key_x, // x |
| 41 | + pub_key_y); // y |
| 42 | + sender = line_sender_connect(opts, &err); |
| 43 | + line_sender_opts_free(opts); |
| 44 | + opts = NULL; |
| 45 | + if (!sender) |
| 46 | + goto on_error; |
| 47 | + |
| 48 | + buffer = line_sender_buffer_new(); |
| 49 | + line_sender_buffer_reserve(buffer, 64 * 1024); // 64KB buffer initial size. |
| 50 | + |
| 51 | + // We prepare all our table names and column names in advance. |
| 52 | + // If we're inserting multiple rows, this allows us to avoid |
| 53 | + // re-validating the same strings over and over again. |
| 54 | + line_sender_table_name table_name = QDB_TABLE_NAME_LITERAL("c_cars_tls"); |
| 55 | + line_sender_column_name id_name = QDB_COLUMN_NAME_LITERAL("id"); |
| 56 | + line_sender_column_name x_name = QDB_COLUMN_NAME_LITERAL("x"); |
| 57 | + line_sender_column_name y_name = QDB_COLUMN_NAME_LITERAL("y"); |
| 58 | + line_sender_column_name booked_name = QDB_COLUMN_NAME_LITERAL("booked"); |
| 59 | + line_sender_column_name passengers_name = QDB_COLUMN_NAME_LITERAL( |
| 60 | + "passengers"); |
| 61 | + line_sender_column_name driver_name = QDB_COLUMN_NAME_LITERAL("driver"); |
| 62 | + |
| 63 | + if (!line_sender_buffer_table(buffer, table_name, &err)) |
| 64 | + goto on_error; |
| 65 | + |
| 66 | + line_sender_utf8 id_value = QDB_UTF8_LITERAL( |
| 67 | + "d6e5fe92-d19f-482a-a97a-c105f547f721"); |
| 68 | + if (!line_sender_buffer_symbol(buffer, id_name, id_value, &err)) |
| 69 | + goto on_error; |
| 70 | + |
| 71 | + if (!line_sender_buffer_column_f64(buffer, x_name, 30.5, &err)) |
| 72 | + goto on_error; |
| 73 | + |
| 74 | + if (!line_sender_buffer_column_f64(buffer, y_name, -150.25, &err)) |
| 75 | + goto on_error; |
| 76 | + |
| 77 | + if (!line_sender_buffer_column_bool(buffer, booked_name, true, &err)) |
| 78 | + goto on_error; |
| 79 | + |
| 80 | + if (!line_sender_buffer_column_i64(buffer, passengers_name, 3, &err)) |
| 81 | + goto on_error; |
| 82 | + |
| 83 | + line_sender_utf8 driver_value = QDB_UTF8_LITERAL("John Doe"); |
| 84 | + if (!line_sender_buffer_column_str(buffer, driver_name, driver_value, &err)) |
| 85 | + goto on_error; |
| 86 | + |
| 87 | + if (!line_sender_buffer_at_now(buffer, &err)) |
| 88 | + goto on_error; |
| 89 | + |
| 90 | + // To insert more records, call `line_sender_buffer_table(..)...` again. |
| 91 | + |
| 92 | + if (!line_sender_flush(sender, buffer, &err)) |
| 93 | + goto on_error; |
| 94 | + |
| 95 | + line_sender_close(sender); |
| 96 | + |
| 97 | + return true; |
| 98 | + |
| 99 | +on_error: ; |
| 100 | + line_sender_opts_free(opts); |
| 101 | + size_t err_len = 0; |
| 102 | + const char* err_msg = line_sender_error_msg(err, &err_len); |
| 103 | + fprintf(stderr, "Error running example: %.*s\n", (int)err_len, err_msg); |
| 104 | + line_sender_error_free(err); |
| 105 | + line_sender_buffer_free(buffer); |
| 106 | + line_sender_close(sender); |
| 107 | + return false; |
| 108 | +} |
| 109 | + |
| 110 | +static bool displayed_help(int argc, const char* argv[]) |
| 111 | +{ |
| 112 | + for (int index = 1; index < argc; ++index) |
| 113 | + { |
| 114 | + const char* arg = argv[index]; |
| 115 | + if ((strncmp(arg, "-h", 2) == 0) || (strncmp(arg, "--help", 6) == 0)) |
| 116 | + { |
| 117 | + fprintf(stderr, "Usage:\n"); |
| 118 | + fprintf(stderr, "line_sender_c_example_auth_tls: [HOST [PORT]]\n"); |
| 119 | + fprintf(stderr, " HOST: ILP host (defaults to \"localhost\").\n"); |
| 120 | + fprintf(stderr, " PORT: ILP port (defaults to \"9009\").\n"); |
| 121 | + return true; |
| 122 | + } |
| 123 | + } |
| 124 | + return false; |
| 125 | +} |
| 126 | + |
| 127 | +int main(int argc, const char* argv[]) |
| 128 | +{ |
| 129 | + if (displayed_help(argc, argv)) |
| 130 | + return 0; |
| 131 | + |
| 132 | + const char* host = "localhost"; |
| 133 | + if (argc >= 2) |
| 134 | + host = argv[1]; |
| 135 | + const char* port = "9009"; |
| 136 | + if (argc >= 3) |
| 137 | + port = argv[2]; |
| 138 | + |
| 139 | + return !example(host, port); |
| 140 | +} |
0 commit comments