1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
|
/*-
* See the file LICENSE for redistribution information.
*
* Copyright (c) 1997-2009 Oracle. All rights reserved.
*
* $Id$
*/
#include <sys/types.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#ifdef _WIN32
extern int getopt(int, char * const *, const char *);
#else
#include <unistd.h>
#endif
#include <db.h>
#define DATABASE "sequence.db"
#define SEQUENCE "my_sequence"
int main __P((int, char *[]));
int usage __P((void));
int
main(argc, argv)
int argc;
char *argv[];
{
extern int optind;
DB *dbp;
DB_SEQUENCE *seq;
DBT key;
int i, ret, rflag;
db_seq_t seqnum;
char ch;
const char *database, *progname = "ex_sequence";
dbp = NULL;
seq = NULL;
rflag = 0;
while ((ch = getopt(argc, argv, "r")) != EOF)
switch (ch) {
case 'r':
rflag = 1;
break;
case '?':
default:
return (usage());
}
argc -= optind;
argv += optind;
/* Accept optional database name. */
database = *argv == NULL ? DATABASE : argv[0];
/* Optionally discard the database. */
if (rflag)
(void)remove(database);
/* Create and initialize database object, open the database. */
if ((ret = db_create(&dbp, NULL, 0)) != 0) {
fprintf(stderr,
"%s: db_create: %s\n", progname, db_strerror(ret));
return (EXIT_FAILURE);
}
dbp->set_errfile(dbp, stderr);
dbp->set_errpfx(dbp, progname);
if ((ret = dbp->open(dbp,
NULL, database, NULL, DB_BTREE, DB_CREATE, 0664)) != 0) {
dbp->err(dbp, ret, "%s: open", database);
goto err;
}
if ((ret = db_sequence_create(&seq, dbp, 0)) != 0) {
dbp->err(dbp, ret, "db_sequence_create");
goto err;
}
memset(&key, 0, sizeof(DBT));
key.data = SEQUENCE;
key.size = (u_int32_t)strlen(SEQUENCE);
if ((ret = seq->open(seq, NULL, &key, DB_CREATE)) != 0) {
dbp->err(dbp, ret, "%s: DB_SEQUENCE->open", SEQUENCE);
goto err;
}
for (i = 0; i < 10; i++) {
if ((ret = seq->get(seq, NULL, 1, &seqnum, 0)) != 0) {
dbp->err(dbp, ret, "DB_SEQUENCE->get");
goto err;
}
/* There's no portable way to print 64-bit numbers. */
#ifdef _WIN32
printf("Got sequence number %I64d\n", (int64_t)seqnum);
#else
printf(
"Got sequence number %llu\n", (unsigned long long)seqnum);
#endif
}
/* Close everything down. */
if ((ret = seq->close(seq, 0)) != 0) {
seq = NULL;
dbp->err(dbp, ret, "DB_SEQUENCE->close");
goto err;
}
if ((ret = dbp->close(dbp, 0)) != 0) {
fprintf(stderr,
"%s: DB->close: %s\n", progname, db_strerror(ret));
return (EXIT_FAILURE);
}
return (EXIT_SUCCESS);
err: if (seq != NULL)
(void)seq->close(seq, 0);
if (dbp != NULL)
(void)dbp->close(dbp, 0);
return (EXIT_FAILURE);
}
int
usage()
{
(void)fprintf(stderr, "usage: ex_sequence [-r] [database]\n");
return (EXIT_FAILURE);
}
|
