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
|
/*-
* See the file LICENSE for redistribution information.
*
* Copyright (c) 1997, 2015 Oracle and/or its affiliates. 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 ch, i, ret, rflag;
db_seq_t seqnum;
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);
}
|
