+ const char *h;
+ if (!c[i])
+ continue;
+ if (!host)
+ {
+ ZOOM_connection_destroy(c[i]);
+ c[i] = 0;
+ }
+ else if ((h = ZOOM_connection_option_get(c[i], "host"))
+ && !strcmp(h, wrbuf_cstr(host)))
+ {
+ ZOOM_connection_destroy(c[i]);
+ c[i] = 0;
+ }
+ }
+ if (host)
+ wrbuf_destroy(host);
+ return 0;
+}
+
+static void display_records(ZOOM_connection c,
+ ZOOM_resultset r,
+ size_t start, size_t count, const char *type)
+{
+ size_t i;
+ for (i = 0; i < count; i++)
+ {
+ size_t pos = i + start;
+ ZOOM_record rec = ZOOM_resultset_record(r, pos);
+ const char *db = ZOOM_record_get(rec, "database", 0);
+
+ if (ZOOM_record_error(rec, 0, 0, 0))
+ {
+ const char *msg;
+ const char *addinfo;
+ const char *diagset;
+ int error = ZOOM_record_error(rec, &msg, &addinfo, &diagset);
+
+ printf("%lld %s: %s (%s:%d) %s\n", (long long) pos,
+ (db ? db : "unknown"),
+ msg, diagset, error, addinfo ? addinfo : "none");
+ }
+ else
+ {
+ int len;
+ const char *render = ZOOM_record_get(rec, type, &len);
+ const char *syntax = ZOOM_record_get(rec, "syntax", 0);
+ const char *schema = ZOOM_record_get(rec, "schema", 0);
+ /* if rec is non-null, we got a record for display */
+ if (rec)
+ {
+ printf("%lld database=%s syntax=%s schema=%s\n",
+ (long long) pos, (db ? db : "unknown"), syntax,
+ schema ? schema : "unknown");
+ if (render)
+ {
+ if (fwrite(render, 1, len, stdout) != (size_t) len)
+ {
+ printf("write to stdout failed\n");
+ }
+ }
+ printf("\n");
+ }
+ }
+ }
+}
+
+static int cmd_show(ZOOM_connection *c, ZOOM_resultset *r,
+ ZOOM_options options,
+ const char **args)
+{
+ int i;
+ size_t start = 0, count = 1;
+ const char *type = "render";
+ WRBUF render_str = 0;
+ int ret = 0;
+
+ {
+ WRBUF tmp;
+
+ if ((tmp = next_token_new_wrbuf(args)))
+ {
+ start = atoi(wrbuf_cstr(tmp));
+ wrbuf_destroy(tmp);
+ }
+
+ if ((tmp = next_token_new_wrbuf(args)))
+ {
+ count = atoi(wrbuf_cstr(tmp));
+ wrbuf_destroy(tmp);
+ }
+ render_str = next_token_new_wrbuf(args);
+ }
+ if (render_str)
+ type = wrbuf_cstr(render_str);
+
+ for (i = 0; i < MAX_CON; i++)
+ ZOOM_resultset_records(r[i], 0, start, count);
+ process_events(c);
+
+ for (i = 0; i < MAX_CON; i++)
+ {
+ int error;
+ const char *errmsg, *addinfo, *dset;
+ /* display errors if any */
+ if (!c[i])
+ continue;
+ if ((error = ZOOM_connection_error_x(c[i], &errmsg, &addinfo, &dset)))
+ {
+ printf("%s error: %s (%s:%d) %s\n",
+ ZOOM_connection_option_get(c[i], "host"), errmsg,
+ dset, error, addinfo);
+ ret = 1;
+ }
+ else if (r[i])
+ {
+ /* OK, no major errors. Display records... */
+ display_records(c[i], r[i], start, count, type);
+ }
+ }
+ if (render_str)
+ wrbuf_destroy(render_str);
+ return ret;
+}
+
+static void display_facets(ZOOM_facet_field *facets, int count) {
+ int index;
+ printf("Facets: \n");
+ for (index = 0; index < count; index++) {
+ int term_index;
+ const char *facet_name = ZOOM_facet_field_name(facets[index]);
+ printf(" %s: \n", facet_name);
+ for (term_index = 0; term_index < ZOOM_facet_field_term_count(facets[index]); term_index++) {
+ int freq = 0;
+ const char *term = ZOOM_facet_field_get_term(facets[index], term_index, &freq);
+ printf(" %s(%d) \n", term, freq);
+ }
+ }
+}
+
+static int cmd_facets(ZOOM_connection *c, ZOOM_resultset *r,
+ ZOOM_options options,
+ const char **args)
+{
+ int i;
+ int ret = 0;
+
+ process_events(c);
+
+ for (i = 0; i < MAX_CON; i++)
+ {
+ int error;
+ const char *errmsg, *addinfo, *dset;
+ /* display errors if any */
+ if (!c[i])
+ continue;
+ if ((error = ZOOM_connection_error_x(c[i], &errmsg, &addinfo, &dset)))
+ {
+ printf("%s error: %s (%s:%d) %s\n",
+ ZOOM_connection_option_get(c[i], "host"), errmsg,
+ dset, error, addinfo);
+ ret = 1;
+ }
+ else if (r[i])
+ {
+ int num_facets = ZOOM_resultset_facets_size(r[i]);
+ if (num_facets) {
+ ZOOM_facet_field *facets = ZOOM_resultset_facets(r[i]);
+ display_facets(facets, num_facets);
+ }
+ }