- list_record(row, columns, n_columns, out);
-
- next_row: ;
- }
- free(columns);
-}
-
-static void
-pre_cmd_set(struct vsctl_context *ctx)
-{
- const char *table_name = ctx->argv[1];
- const struct vsctl_table_class *table;
- int i;
-
- table = pre_get_table(ctx, table_name);
- for (i = 3; i < ctx->argc; i++) {
- pre_parse_column_key_value(ctx, ctx->argv[i], table);
- }
-}
-
-static void
-set_column(const struct vsctl_table_class *table,
- const struct ovsdb_idl_row *row, const char *arg,
- struct ovsdb_symbol_table *symtab)
-{
- const struct ovsdb_idl_column *column;
- char *key_string, *value_string;
- char *error;
-
- error = parse_column_key_value(arg, table, &column, &key_string,
- NULL, NULL, 0, &value_string);
- die_if_error(error);
- if (!value_string) {
- vsctl_fatal("%s: missing value", arg);
- }
-
- if (key_string) {
- union ovsdb_atom key, value;
- struct ovsdb_datum datum;
-
- if (column->type.value.type == OVSDB_TYPE_VOID) {
- vsctl_fatal("cannot specify key to set for non-map column %s",
- column->name);
- }
-
- die_if_error(ovsdb_atom_from_string(&key, &column->type.key,
- key_string, symtab));
- die_if_error(ovsdb_atom_from_string(&value, &column->type.value,
- value_string, symtab));
-
- ovsdb_datum_init_empty(&datum);
- ovsdb_datum_add_unsafe(&datum, &key, &value, &column->type);
-
- ovsdb_atom_destroy(&key, column->type.key.type);
- ovsdb_atom_destroy(&value, column->type.value.type);
-
- ovsdb_datum_union(&datum, ovsdb_idl_read(row, column),
- &column->type, false);
- ovsdb_idl_txn_write(row, column, &datum);
- } else {
- struct ovsdb_datum datum;
-
- die_if_error(ovsdb_datum_from_string(&datum, &column->type,
- value_string, symtab));
- ovsdb_idl_txn_write(row, column, &datum);
- }
-
- free(key_string);
- free(value_string);
-}
-
-static void
-cmd_set(struct vsctl_context *ctx)
-{
- const char *table_name = ctx->argv[1];
- const char *record_id = ctx->argv[2];
- const struct vsctl_table_class *table;
- const struct ovsdb_idl_row *row;
- int i;
-
- table = get_table(table_name);
- row = must_get_row(ctx, table, record_id);
- for (i = 3; i < ctx->argc; i++) {
- set_column(table, row, ctx->argv[i], ctx->symtab);
- }
-}
-
-static void
-pre_cmd_add(struct vsctl_context *ctx)
-{
- const char *table_name = ctx->argv[1];
- const char *column_name = ctx->argv[3];
- const struct vsctl_table_class *table;
- const struct ovsdb_idl_column *column;
-
- table = pre_get_table(ctx, table_name);
- pre_get_column(ctx, table, column_name, &column);
-}
-
-static void
-cmd_add(struct vsctl_context *ctx)
-{
- const char *table_name = ctx->argv[1];
- const char *record_id = ctx->argv[2];
- const char *column_name = ctx->argv[3];
- const struct vsctl_table_class *table;
- const struct ovsdb_idl_column *column;
- const struct ovsdb_idl_row *row;
- const struct ovsdb_type *type;
- struct ovsdb_datum old;
- int i;
-
- table = get_table(table_name);
- row = must_get_row(ctx, table, record_id);
- die_if_error(get_column(table, column_name, &column));
-
- type = &column->type;
- ovsdb_datum_clone(&old, ovsdb_idl_read(row, column), &column->type);
- for (i = 4; i < ctx->argc; i++) {
- struct ovsdb_type add_type;
- struct ovsdb_datum add;
-
- add_type = *type;
- add_type.n_min = 1;
- add_type.n_max = UINT_MAX;
- die_if_error(ovsdb_datum_from_string(&add, &add_type, ctx->argv[i],
- ctx->symtab));
- ovsdb_datum_union(&old, &add, type, false);
- ovsdb_datum_destroy(&add, type);
- }
- if (old.n > type->n_max) {
- vsctl_fatal("\"add\" operation would put %u %s in column %s of "
- "table %s but the maximum number is %u",
- old.n,
- type->value.type == OVSDB_TYPE_VOID ? "values" : "pairs",
- column->name, table->class->name, type->n_max);
- }
- ovsdb_idl_txn_verify(row, column);
- ovsdb_idl_txn_write(row, column, &old);
-}
-
-static void
-pre_cmd_remove(struct vsctl_context *ctx)
-{
- const char *table_name = ctx->argv[1];
- const char *column_name = ctx->argv[3];
- const struct vsctl_table_class *table;
- const struct ovsdb_idl_column *column;
-
- table = pre_get_table(ctx, table_name);
- pre_get_column(ctx, table, column_name, &column);
-}
-
-static void
-cmd_remove(struct vsctl_context *ctx)
-{
- const char *table_name = ctx->argv[1];
- const char *record_id = ctx->argv[2];
- const char *column_name = ctx->argv[3];
- const struct vsctl_table_class *table;
- const struct ovsdb_idl_column *column;
- const struct ovsdb_idl_row *row;
- const struct ovsdb_type *type;
- struct ovsdb_datum old;
- int i;
-
- table = get_table(table_name);
- row = must_get_row(ctx, table, record_id);
- die_if_error(get_column(table, column_name, &column));
-
- type = &column->type;
- ovsdb_datum_clone(&old, ovsdb_idl_read(row, column), &column->type);
- for (i = 4; i < ctx->argc; i++) {
- struct ovsdb_type rm_type;
- struct ovsdb_datum rm;
- char *error;
-
- rm_type = *type;
- rm_type.n_min = 1;
- rm_type.n_max = UINT_MAX;
- error = ovsdb_datum_from_string(&rm, &rm_type,
- ctx->argv[i], ctx->symtab);
- if (error && ovsdb_type_is_map(&rm_type)) {
- free(error);
- rm_type.value.type = OVSDB_TYPE_VOID;
- die_if_error(ovsdb_datum_from_string(&rm, &rm_type,
- ctx->argv[i], ctx->symtab));
- }
- ovsdb_datum_subtract(&old, type, &rm, &rm_type);
- ovsdb_datum_destroy(&rm, &rm_type);
- }
- if (old.n < type->n_min) {
- vsctl_fatal("\"remove\" operation would put %u %s in column %s of "
- "table %s but the minimum number is %u",
- old.n,
- type->value.type == OVSDB_TYPE_VOID ? "values" : "pairs",
- column->name, table->class->name, type->n_min);
- }
- ovsdb_idl_txn_verify(row, column);
- ovsdb_idl_txn_write(row, column, &old);
-}
-
-static void
-pre_cmd_clear(struct vsctl_context *ctx)
-{
- const char *table_name = ctx->argv[1];
- const struct vsctl_table_class *table;
- int i;
-
- table = pre_get_table(ctx, table_name);
- for (i = 3; i < ctx->argc; i++) {
- const struct ovsdb_idl_column *column;
-
- pre_get_column(ctx, table, ctx->argv[i], &column);
- }
-}
-
-static void
-cmd_clear(struct vsctl_context *ctx)
-{
- const char *table_name = ctx->argv[1];
- const char *record_id = ctx->argv[2];
- const struct vsctl_table_class *table;
- const struct ovsdb_idl_row *row;
- int i;
-
- table = get_table(table_name);
- row = must_get_row(ctx, table, record_id);
- for (i = 3; i < ctx->argc; i++) {
- const struct ovsdb_idl_column *column;
- const struct ovsdb_type *type;
- struct ovsdb_datum datum;
-
- die_if_error(get_column(table, ctx->argv[i], &column));
-
- type = &column->type;
- if (type->n_min > 0) {
- vsctl_fatal("\"clear\" operation cannot be applied to column %s "
- "of table %s, which is not allowed to be empty",
- column->name, table->class->name);
- }
-
- ovsdb_datum_init_empty(&datum);
- ovsdb_idl_txn_write(row, column, &datum);
- }
-}
-
-static void
-pre_create(struct vsctl_context *ctx)
-{
- const char *id = shash_find_data(&ctx->options, "--id");
- const char *table_name = ctx->argv[1];
- const struct vsctl_table_class *table;
-
- table = get_table(table_name);
- if (!id && !table->class->is_root) {
- VLOG_WARN("applying \"create\" command to table %s without --id "
- "option will have no effect", table->class->name);