运行数据库命令

bson_t reply;
bson_error_t error;
bson_t *command = BCON_NEW ("hello", BCON_INT32 (1));
bool retval = mongoc_client_command_simple (client, "admin", command, NULL, &reply, &error);
if (!retval) {
    fprintf (stderr, "Failed to run command: %s\n", error.message);
} else {
    char *str = bson_as_canonical_extended_json (&reply, NULL);
    printf ("%s\n", str);
    bson_free (str);
}
bson_destroy (command);
bson_destroy (&reply);

bson_t reply;
bson_error_t error;
bson_t *command = BCON_NEW(
    "grantRolesToUser", BCON_UTF8("user011"),
    "roles", "[", BCON_UTF8("readWrite"), "]"
);
mongoc_write_concern_t *write_concern = mongoc_write_concern_new();
mongoc_write_concern_set_w (write_concern, MONGOC_WRITE_CONCERN_W_MAJORITY);
bson_t *opts = bson_new();
mongoc_write_concern_append(write_concern, opts);
bool retval = mongoc_client_command_with_opts(client, "admin", command, NULL, opts, &reply, &error);
if (!retval) {
    fprintf(stderr, "Failed to run command: %s\n", error.message);
} else {
    char *str = bson_as_canonical_extended_json(&reply, NULL);
    printf("Command Result: %s\n", str);
    bson_free(str);
}
bson_destroy(command);
bson_destroy(opts);
bson_destroy(&reply);
mongoc_write_concern_destroy (write_concern);

1
bson_t reply;
2
bson_error_t error;
3
4
bson_t *cmd = BCON_NEW ("cloneCollectionAsCapped",
5
        BCON_UTF8 ("my_collection"),
6
        "toCollection",
7
        BCON_UTF8 ("my_capped_collection"),
8
        "size",
9
        BCON_INT64 (1024 * 1024));
10
11
/* Includes write concern "majority" in command options */
12
mongoc_write_concern_t *write_concern = mongoc_write_concern_new ();
13
mongoc_write_concern_set_w (write_concern, MONGOC_WRITE_CONCERN_W_MAJORITY);
14
bson_t *opts = bson_new ();
15
mongoc_write_concern_append (write_concern, opts);
16
17
if (mongoc_client_write_command_with_opts (client, "test", cmd, opts, &reply, &error)) {
18
    char *str = bson_as_canonical_extended_json (&reply, NULL);
19
    printf ("cloneCollectionAsCapped: %s\n", str);
20
    bson_free (str);
21
} else {
22
    fprintf (stderr, "cloneCollectionAsCapped: %s\n", error.message);
23
}
24
25
bson_free (cmd);
26
bson_free (opts);
27
bson_destroy (&reply);
28
29
/* Defines distinct values of "x" in "my_collection" where "y" sorts after "one" */
30
cmd = BCON_NEW ("distinct",
31
        BCON_UTF8 ("my_collection"),
32
        "key",
33
        BCON_UTF8 ("x"),
34
        "query",
35
        "{",
36
        "y",
37
        "{",
38
        "$gt",
39
        BCON_UTF8 ("one"),
40
        "}",
41
        "}");
42
43
mongoc_read_prefs_t *read_prefs = mongoc_read_prefs_new (MONGOC_READ_SECONDARY);
44
45
/* Specifies "One" sorts after "one" to override default behavior */
46
opts = BCON_NEW ("collation", "{", "locale", BCON_UTF8 ("en_US"), "caseFirst", BCON_UTF8 ("lower"), "}");
47
48
/* Adds a read concern to "opts" */
49
mongoc_read_concern_t *read_concern = mongoc_read_concern_new ();
50
mongoc_read_concern_set_level (read_concern, MONGOC_READ_CONCERN_LEVEL_MAJORITY);
51
mongoc_read_concern_append (read_concern, opts);
52
53
if (mongoc_client_read_command_with_opts (client, "test", cmd, read_prefs, opts, &reply, &error)) {
54
    char* str = bson_as_canonical_extended_json (&reply, NULL);
55
    printf ("distinct: %s\n", str);
56
    bson_free (str);
57
} else {
58
    fprintf (stderr, "distinct: %s\n", error.message);
59
}
60
61
bson_destroy (cmd);
62
bson_destroy (opts);
63
bson_destroy (&reply);
64
mongoc_read_prefs_destroy (read_prefs);
65
mongoc_read_concern_destroy (read_concern);
66
mongoc_write_concern_destroy (write_concern);