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
134
135
136
137
138
|
/**************************************************************************************************
* EJDB database library http://ejdb.org
* Copyright (C) 2012-2013 Softmotions Ltd <info@softmotions.com>
*
* This file is part of EJDB.
* EJDB is free software; you can redistribute it and/or modify it under the terms of
* the GNU Lesser General Public License as published by the Free Software Foundation; either
* version 2.1 of the License or any later version. EJDB is distributed in the hope
* that it will be useful, but WITHOUT ANY WARRANTY; without even the implied warranty of
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser General Public
* License for more details.
* You should have received a copy of the GNU Lesser General Public License along with EJDB;
* if not, write to the Free Software Foundation, Inc., 59 Temple Place, Suite 330,
* Boston, MA 02111-1307 USA.
*************************************************************************************************/
#ifndef EJDB_PRIVATE_H
#define EJDB_PRIVATE_H
#include "ejdb.h"
#include "tcutil.h"
#include "tctdb.h"
#include "tchdb.h"
#include <assert.h>
EJDB_EXTERN_C_START
#define BSON_IS_IDXSUPPORTED_TYPE(atype) (atype == BSON_STRING || \
atype == BSON_INT || atype == BSON_LONG || atype == BSON_DOUBLE || \
atype == BSON_ARRAY || atype == BSON_DATE)
#define EJDB_MAX_COLLECTIONS 1024
struct EJCOLL { /**> EJDB Collection. */
char *cname; /**> Collection name. */
int cnamesz; /**> Collection name length. */
TCTDB *tdb; /**> Collection TCTDB. */
EJDB *jb; /**> Database handle. */
void *mmtx; /*> Mutex for method */
};
struct EJDB {
EJCOLL * cdbs[EJDB_MAX_COLLECTIONS]; /*> Collection DBs for JSON collections. */
int cdbsnum; /*> Count of collection DB. */
TCTDB *metadb; /*> Metadata DB. */
void *mmtx; /*> Mutex for method */
};
enum { /**> Query field flags */
// Comparison flags
EJCOMPGT = 1, /**> Comparison GT */
EJCOMPGTE = 1 << 1, /**> Comparison GTE */
EJCOMPLT = 1 << 2, /**> Comparison LT */
EJCOMPLTE = 1 << 3, /**> Comparison LTE */
EJCONDSTARTWITH = 1 << 4, /**> Starts with */
EJFEXCLUDED = 1 << 5, /**> If query field excluded from matching */
EJFNOINDEX = 1 << 6, /**> Do not use index for field */
EJFORDERUSED = 1 << 7, /**> This ordering field was used */
EJFPKMATCHING = 1 << 8, /**> _id PK field matching */
EJCONDICASE = 1 << 9, /**> Ignore case in matching */
EJCONDSET = 1 << 10, /**> $set Set field update operation */
EJCONDINC = 1 << 11, /**> $inc Inc field update operation */
EJCONDADDSET = 1 << 12, /**> $addToSet Adds value to the array only if its not in the array already. */
EJCONDPULL = 1 << 13, /**> $pull Removes all occurrences of value from field, if field is an array */
EJCONDUPSERT = 1 << 14, /**> $upsert Upsert $set operation */
EJCONDALL = 1 << 15, /**> 'All' modificator for $pull or $addToSet ($addToSetAll or $pullAll) */
EJCONDOIT = 1 << 16 /**> $do query field operation */
};
enum { /**> Query flags */
EJQINTERNAL = 1, /**> Internal query object used in _ejdbqryexecute */
EJQUPDATING = 1 << 1, /**> Query in updating mode */
EJQDROPALL = 1 << 2, /**> Drop bson object if matched */
EJQONLYCOUNT = 1 << 3 /**> Only count mode */
};
struct EJQF { /**> Matching field and status */
bool negate; /**> Negate expression */
int fpathsz; /**>JSON field path size */
int exprsz; /**> Size of query operand expression */
int tcop; /**> Matching operation eg. TDBQCSTREQ */
bson_type ftype; /**> BSON field type */
uint32_t flags; /**> Various field matching|status flags */
uint32_t mflags; /**> Temporary matching flags used during single record matching */
int order; /**> 0 no order, 1 ASC, -1 DESC */
int orderseq; /**> Seq number for order fields */
int elmatchgrp; /**> $elemMatch group id */
int elmatchpos; /**> $elemMatch fieldpath position */
char *fpath; /**>JSON field path */
char *expr; /**> Query operand expression, string or TCLIST data */
const TDBIDX *idx; /**> Column index for this field if exists */
bson *idxmeta; /**> Index metainfo */
bson *updateobj; /**> Update bson object for $set and $inc operations */
TCLIST *exprlist; /**> List representation of expression */
TCMAP *exprmap; /**> Hash map for expression tokens used in $in matching operation. */
void *regex; /**> Regular expression object */
EJDB *jb; /**> Reference to the EJDB during query processing */
EJQ *q; /**> Query object in which this field embedded */
double exprdblval; /**> Double value representation */
int64_t exprlongval; /**> Integer value represeintation */
};
typedef struct EJQF EJQF;
struct EJQ { /**> Query object. */
TCLIST *qobjlist; /**> List of query field objects *EJQF */
TCLIST *orqlist; /**> List of $or joined query objects *EJQ */
TCLIST *andqlist; /**> List of $and joined query objects *EJQ */
bson *hints; /**> Hints bson object */
uint32_t skip; /**> Number of records to skip. */
uint32_t max; /**> Max number of results */
uint32_t flags; /**> Control flags */
EJQ *lastmatchedorq; /**> Reference to the last matched $or query */
//Temporal buffers used during query processing
TCXSTR *colbuf; /**> TCTDB current column buffer */
TCXSTR *bsbuf; /**> current bson object buff */
TCXSTR *tmpbuf; /**> Tmp buffer */
};
#define JDBCOLBSON "$" /**> TCDB colname with BSON byte data */
#define JDBCOLBSONL 1 /**> TCDB colname with BSON byte data columen len */
#define JBINOPTMAPTHRESHOLD 16 /**> If number of tokens in `$in` array exeeds it then TCMAP will be used in fullscan matching of tokens */
EJDB_EXPORT bool ejcollockmethod(EJCOLL *coll, bool wr);
EJDB_EXPORT bool ejcollunlockmethod(EJCOLL *coll);
EJDB_EXTERN_C_END
#endif /* EJDB_PRIVATE_H */
|
