1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
|
#include "duckdb.h"
#include <stdio.h>
int main() {
duckdb_database db = NULL;
duckdb_connection con = NULL;
duckdb_result result;
if (duckdb_open(NULL, &db) == DuckDBError) {
fprintf(stderr, "Failed to open database\n");
goto cleanup;
}
if (duckdb_connect(db, &con) == DuckDBError) {
fprintf(stderr, "Failed to open connection\n");
goto cleanup;
}
if (duckdb_query(con, "CREATE TABLE integers(i INTEGER, j INTEGER);", NULL) == DuckDBError) {
fprintf(stderr, "Failed to query database\n");
goto cleanup;
}
if (duckdb_query(con, "INSERT INTO integers VALUES (3, 4), (5, 6), (7, NULL);", NULL) == DuckDBError) {
fprintf(stderr, "Failed to query database\n");
goto cleanup;
}
if (duckdb_query(con, "SELECT * FROM integers", &result) == DuckDBError) {
fprintf(stderr, "Failed to query database\n");
goto cleanup;
}
// print the names of the result
idx_t row_count = duckdb_row_count(&result);
idx_t column_count = duckdb_column_count(&result);
for (size_t i = 0; i < column_count; i++) {
printf("%s ", duckdb_column_name(&result, i));
}
printf("\n");
// print the data of the result
for (size_t row_idx = 0; row_idx < row_count; row_idx++) {
for (size_t col_idx = 0; col_idx < column_count; col_idx++) {
char *val = duckdb_value_varchar(&result, col_idx, row_idx);
printf("%s ", val);
duckdb_free(val);
}
printf("\n");
}
// duckdb_print_result(result);
cleanup:
duckdb_destroy_result(&result);
duckdb_disconnect(&con);
duckdb_close(&db);
}
|
