cursor.cs   [plain text]

m4_ignore([dnl
#include <sys/types.h>
#include <sys/stat.h>

#include <errno.h>
#include <stdarg.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>

#include <db.h>

#define	MAXIMUM_RETRY	5

int add_cat(DB_ENV *dbenv, DB *db, char *name, ...);

int add_color(DB_ENV *a, DB *b, char *c, int d) {
	a = NULL; b = NULL; c = NULL; d = 0;
	return (0);
}
int add_fruit(DB_ENV *a, DB *b, char *c, char *d) {
	a = NULL; b = NULL; c = NULL; d = 0;
	return (0);
}
void  db_open(DB_ENV *a, DB **b, char *c, int d) {
	a = NULL; b = NULL; c = NULL; d = 0;
}
void usage(){}
void env_open(DB_ENV **a) { a = NULL; }
void env_dir_create() {}
])
m4_indent([dnl
int
main(int argc, char *argv[])
{
	extern int optind;
	DB *db_cats, *db_color, *db_fruit;
	DB_ENV *dbenv;
	int ch;
m4_blank
	while ((ch = getopt(argc, argv, "")) != EOF)
		switch (ch) {
		case '?':
		default:
			usage();
		}
	argc -= optind;
	argv += optind;
m4_blank
	env_dir_create();
	env_open(&dbenv);
m4_blank
	/* Open database: Key is fruit class; Data is specific type. */
	db_open(dbenv, &db_fruit, "fruit", 0);
m4_blank
	/* Open database: Key is a color; Data is an integer. */
	db_open(dbenv, &db_color, "color", 0);
m4_blank
	/*
	 * Open database:
	 *	Key is a name; Data is: company name, cat breeds.
	 */
	db_open(dbenv, &db_cats, "cats", 1);
m4_blank
	add_fruit(dbenv, db_fruit, "apple", "yellow delicious");
m4_blank
	add_color(dbenv, db_color, "blue", 0);
	add_color(dbenv, db_color, "blue", 3);
m4_blank
m4_cbold([dnl
	add_cat(dbenv, db_cats,
		"Amy Adams",
		"Oracle",
		"abyssinian",
		"bengal",
		"chartreaux",
		NULL);])
m4_blank
	return (0);
}
m4_blank
m4_cbold([dnl
int
add_cat(DB_ENV *dbenv, DB *db, char *name, ...)
{
	va_list ap;
	DBC *dbc;
	DBT key, data;
	DB_TXN *tid;
	int fail, ret, t_ret;
	char *s;
m4_blank
	/* Initialization. */
	fail = 0;
m4_blank
	memset(&key, 0, sizeof(key));
	memset(&data, 0, sizeof(data));
	key.data = name;
	key.size = strlen(name);
m4_blank
retry:	/* Begin the transaction. */
	if ((ret = dbenv-__GT__txn_begin(dbenv, NULL, &tid, 0)) != 0) {
		dbenv-__GT__err(dbenv, ret, "DB_ENV-__GT__txn_begin");
		exit (1);
	}
m4_blank
	/* Delete any previously existing item. */
	switch (ret = db-__GT__del(db, tid, &key, 0)) {
	case 0:
	case DB_NOTFOUND:
		break;
	case DB_LOCK_DEADLOCK:
	default:
		/* Retry the operation. */
		if ((t_ret = tid-__GT__abort(tid)) != 0) {
			dbenv-__GT__err(dbenv, t_ret, "DB_TXN-__GT__abort");
			exit (1);
		}
		if (fail++ == MAXIMUM_RETRY)
			return (ret);
		goto retry;
	}
m4_blank
	/* Create a cursor. */
	if ((ret = db-__GT__cursor(db, tid, &dbc, 0)) != 0) {
		dbenv-__GT__err(dbenv, ret, "db-__GT__cursor");
		exit (1);
	}
m4_blank
	/* Append the items, in order. */
	va_start(ap, name);
	while ((s = va_arg(ap, char *)) != NULL) {
		data.data = s;
		data.size = strlen(s);
		switch (ret = dbc-__GT__c_put(dbc, &key, &data, DB_KEYLAST)) {
		case 0:
			break;
		case DB_LOCK_DEADLOCK:
		default:
			va_end(ap);
m4_blank
			/* Retry the operation. */
			if ((t_ret = dbc-__GT__c_close(dbc)) != 0) {
				dbenv-__GT__err(
				    dbenv, t_ret, "dbc-__GT__c_close");
				exit (1);
			}
			if ((t_ret = tid-__GT__abort(tid)) != 0) {
				dbenv-__GT__err(dbenv, t_ret, "DB_TXN-__GT__abort");
				exit (1);
			}
			if (fail++ == MAXIMUM_RETRY)
				return (ret);
			goto retry;
		}
	}
	va_end(ap);
m4_blank
	/* Success: commit the change. */
	if ((ret = dbc-__GT__c_close(dbc)) != 0) {
		dbenv-__GT__err(dbenv, ret, "dbc-__GT__c_close");
		exit (1);
	}
	if ((ret = tid-__GT__commit(tid, 0)) != 0) {
		dbenv-__GT__err(dbenv, ret, "DB_TXN-__GT__commit");
		exit (1);
	}
	return (0);
}])])