Couchbase C Client  2.9.4
Asynchronous C Client for Couchbase
example/subdoc/subdoc-xattrs.c

Shows how to work with XATTRs using subdocument API.

/* -*- Mode: C; tab-width: 4; c-basic-offset: 4; indent-tabs-mode: nil -*- */
/*
* Copyright 2017 Couchbase, Inc.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing, software
* distributed under the License is distributed on an "AS IS" BASIS,
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
* See the License for the specific language governing permissions and
* limitations under the License.
*/
#include <unistd.h>
#include <stdlib.h>
#include <libcouchbase/n1ql.h>
#include <assert.h>
#include <string.h>
static void generic_callback(lcb_t instance, int type, const lcb_RESPBASE *rb)
{
if (rb->rc != LCB_SUCCESS && rb->rc != LCB_SUBDOC_MULTI_FAILURE) {
printf("Failure: 0x%x, %s\n", rb->rc, lcb_strerror(instance, rb->rc));
return;
}
switch (type) {
size_t iter = 0;
size_t index = 0;
const lcb_RESPSUBDOC *resp = (const lcb_RESPSUBDOC *)rb;
while (lcb_sdresult_next(resp, &ent, &iter)) {
if (index == 0 && ent.status != LCB_SUCCESS) {
// attribute does not exist, skip response
return;
}
if (index == 1) {
printf(" * %.*s: %.*s%%\n", (int)resp->nkey, resp->key, (int)ent.nvalue, ent.value);
}
index++;
}
break;
}
case LCB_CALLBACK_SDMUTATE: {
size_t iter = 0;
size_t oix = 0;
const lcb_RESPSUBDOC *resp = (const lcb_RESPSUBDOC *)rb;
while (lcb_sdresult_next(resp, &ent, &iter)) {
size_t index = oix++;
if (type == LCB_CALLBACK_SDMUTATE) {
index = ent.index;
}
printf("[%lu]: 0x%x. %.*s\n", index, ent.status, (int)ent.nvalue, ent.value);
}
break;
}
}
}
static void n1qlrow_callback(lcb_t instance, int type, const lcb_RESPN1QL *resp)
{
if (resp->rc != LCB_SUCCESS) {
printf("Failure: 0x%x, %s\n", resp->rc, lcb_strerror(instance, resp->rc));
printf("HTTP status: %d\n", (int)resp->htresp->htstatus);
{
const char *const *hdr = resp->htresp->headers;
for (; hdr && *hdr; hdr++) {
printf("%s", *hdr);
if (hdr + 1) {
printf(" = %s", *(++hdr));
}
printf("\n");
}
}
printf("%.*s\n", (int)resp->nrow, resp->row);
return;
}
char *start = "{\"docID\":\"";
char *stop = "\"";
char *key = strstr(resp->row, start);
if (key == NULL || key != resp->row) {
return;
}
key += strlen(start);
char *z = strstr(key, stop);
if (z == NULL) {
return;
}
*z = '\0';
lcb_sched_enter(instance);
{
lcb_CMDSUBDOC cmd = {};
lcb_SDSPEC specs[2] = {};
char *path = "discounts.jsmith123";
LCB_CMD_SET_KEY(&cmd, key, strlen(key));
specs[0].sdcmd = LCB_SDCMD_EXISTS;
LCB_SDSPEC_SET_PATH(&specs[0], path, strlen(path));
specs[1].sdcmd = LCB_SDCMD_GET;
LCB_SDSPEC_SET_PATH(&specs[1], path, strlen(path));
cmd.specs = specs;
cmd.nspecs = 2;
rc = lcb_subdoc3(instance, NULL, &cmd);
assert(rc == LCB_SUCCESS);
}
lcb_sched_leave(instance);
}
#define DEFAULT_CONNSTR "couchbase://localhost/travel-sample"
static lcb_t connect_as(char *username, char *password)
{
struct lcb_create_st crst = {.version = 3};
crst.v.v3.connstr = DEFAULT_CONNSTR;
crst.v.v3.username = username;
crst.v.v3.passwd = password;
lcb_t instance;
rc = lcb_create(&instance, &crst);
assert(rc == LCB_SUCCESS);
rc = lcb_connect(instance);
assert(rc == LCB_SUCCESS);
lcb_wait(instance);
rc = lcb_get_bootstrap_status(instance);
assert(rc == LCB_SUCCESS);
lcb_install_callback3(instance, LCB_CALLBACK_DEFAULT, generic_callback);
return instance;
}
int main()
{
lcb_t instance;
instance = connect_as("Administrator", "password");
// Add key-value pairs to hotel_10138, representing traveller-Ids and associated discount percentages
{
lcb_CMDSUBDOC cmd = {};
lcb_SDSPEC specs[4] = {};
char *key = "hotel_10138";
LCB_CMD_SET_KEY(&cmd, key, strlen(key));
{
char *path = "discounts.jsmith123";
char *val = "20";
LCB_SDSPEC_SET_PATH(&specs[0], path, strlen(path));
LCB_CMD_SET_VALUE(&specs[0], val, strlen(val));
}
{
char *path = "discounts.pjones356";
char *val = "30";
LCB_SDSPEC_SET_PATH(&specs[1], path, strlen(path));
LCB_CMD_SET_VALUE(&specs[1], val, strlen(val));
}
// The following lines, "insert" and "remove", simply demonstrate insertion and
// removal of the same path and value
{
char *path = "discounts.jbrown789";
char *val = "25";
LCB_SDSPEC_SET_PATH(&specs[2], path, strlen(path));
LCB_CMD_SET_VALUE(&specs[2], val, strlen(val));
}
{
char *path = "discounts.jbrown789";
specs[3].sdcmd = LCB_SDCMD_REMOVE;
LCB_SDSPEC_SET_PATH(&specs[3], path, strlen(path));
}
cmd.specs = specs;
cmd.nspecs = 4;
rc = lcb_subdoc3(instance, NULL, &cmd);
assert(rc == LCB_SUCCESS);
}
// Add key - value pairs to hotel_10142, again representing traveller - Ids and associated discount percentages
{
lcb_CMDSUBDOC cmd = {};
lcb_SDSPEC specs[2] = {};
char *key = "hotel_10142";
LCB_CMD_SET_KEY(&cmd, key, strlen(key));
{
char *path = "discounts.jsmith123";
char *val = "15";
LCB_SDSPEC_SET_PATH(&specs[0], path, strlen(path));
LCB_CMD_SET_VALUE(&specs[0], val, strlen(val));
}
{
char *path = "discounts.pjones356";
char *val = "10";
LCB_SDSPEC_SET_PATH(&specs[1], path, strlen(path));
LCB_CMD_SET_VALUE(&specs[1], val, strlen(val));
}
cmd.specs = specs;
cmd.nspecs = 2;
rc = lcb_subdoc3(instance, NULL, &cmd);
assert(rc == LCB_SUCCESS);
}
lcb_wait(instance);
// Create a user and assign roles. This user will search for their available discounts.
{
lcb_CMDHTTP cmd = {};
char *path = "/settings/rbac/users/local/jsmith123";
char *payload = "password=jsmith123pwd&name=John+Smith"
"&roles=data_reader[travel-sample],query_select[travel-sample],data_writer[travel-sample]";
cmd.method = LCB_HTTP_METHOD_PUT;
LCB_CMD_SET_KEY(&cmd, path, strlen(path));
cmd.body = payload;
cmd.nbody = strlen(payload);
cmd.content_type = "application/x-www-form-urlencoded";
lcb_http3(instance, NULL, &cmd);
lcb_wait(instance);
}
lcb_destroy(instance);
// reconnect using new user
instance = connect_as("jsmith123", "jsmith123pwd");
// Perform a N1QL Query to return document IDs from the bucket. These IDs will be
// used to reference each document in turn, and check for extended attributes
// corresponding to discounts.
{
lcb_CMDN1QL cmd = {};
char *query = "SELECT id, meta(`travel-sample`).id AS docID FROM `travel-sample`";
lcb_n1p_setstmtz(params, query);
rc = lcb_n1p_mkcmd(params, &cmd);
assert(rc == LCB_SUCCESS);
cmd.callback = n1qlrow_callback;
printf("User \"jsmith123\" has discounts in the hotels below:\n");
lcb_n1ql_query(instance, NULL, &cmd);
lcb_wait(instance);
}
lcb_destroy(instance);
}