5 relation *relation_create(tupleschema *schema) {
6 relation *r = (relation *) malloc( sizeof( relation ) );
8 .content = (hashvector) {
10 .variant = nibble_index_levels,
14 .fill = 0, .holes = 0, .type = (itemkeyfun*) schema
16 .constraints = (vector) {
17 .variant = single_index_level,
25 #define COPYA(T,P,N) (T*) memcpy( malloc( N * sizeof(T) ), P, N * sizeof( T ) )
26 #define COPY(T,P) COPYA(T,P,1)
28 // Add an indexing hashvector to the relation using the given column
29 // flags with 1 indicating key column and 0 indicating value column.
30 int relation_add_constraint(relation *r,...) {
32 tupleschema *ts = (tupleschema *) r->content.type;
33 tuple *columns = (tuple*) calloc( ts->arity, sizeof( void* ) );
36 for ( ; i < ts->arity; i++ ) {
37 if ( va_arg( ap, int ) ) {
38 (*columns)[i] = ts->columns[i];
42 ts = tupleschema_create( ts->arity, columns );
43 i = (int) r->constraints.size;
46 hashvector_create( nibble_index_levels, (itemkeyfun*) ts ) );
50 //============== Adding an item =============
51 // Iteration context for adding or querying a relation
58 // Determine matches to ((knockout*)data)->key in
59 // (hashvector*)item, optionally using ((knockout*)data)->columns
60 // for ignoring full matches to the key tuple.
61 static int knockout_check(vector_index index,void *item,void *data) {
62 knockout *kod = (knockout*) data;
64 for ( ; i < ((hashvector*) item)->table.size; i++ ) {
65 void *old = hashvector_next( (hashvector*) item, &i, kod->item );
67 vector_append( &kod->knockouts, old );
73 // delete the (tuple*)item from the (hashvector*)data
74 static int knockout_delete_item(vector_index index,void *item,void *data) {
75 hashvector_delete( (hashvector*)data, item );
79 // delete the tuples of (vector*)data from the (hashvector*)item
80 static int knockout_delete(vector_index index,void *item,void *data) {
81 vector_iterate( (vector*)data, 0, knockout_delete_item, item );
85 // add the (tuple*)data to the (hashvector*)item
86 static int knockout_add(vector_index index,void *item,void *data) {
87 hashvector_add( (hashvector*)item, data );
91 // Find and remove all collisions for a query, unless "add" is
92 // non-zero in which case the function aborts if there is any match in
94 static int knockout_clear(knockout *this,relation *r,tuple *item,int add) {
95 (*this) = (knockout) {
98 .variant = bitpair_index_levels,
99 .size = 0, .entries = 0
103 knockout_check( 0, &r->content, this );
104 if ( add && this->knockouts.size > 0 ) {
107 // Find all constraint knockouts
108 vector_iterate( &r->constraints, 0, knockout_check, this );
109 if ( this->knockouts.size > 0 ) {
110 // Delete them from all tables
112 &this->knockouts, 0, knockout_delete_item, &r->content );
114 &r->constraints, 0, knockout_delete, &this->knockouts );
119 // add a tuple to a relation and return a vector of knocked out
120 // tuples, if any, or 0 otherwise.
121 vector *relation_add(relation *r,tuple *item) {
123 if ( knockout_clear( &data, r, item, 1 ) ) {
125 hashvector_add( &r->content, item );
126 vector_iterate( &r->constraints, 0, knockout_add, item );
127 if ( data.knockouts.size > 0 ) {
128 return vector_clone( single_index_level, &data.knockouts );
134 vector *relation_delete(relation *r,tuple *item) {
136 (void) knockout_clear( &data, r, item, 0 );
137 if ( data.knockouts.size > 0 ) {
138 return vector_clone( single_index_level, &data.knockouts );
143 void *relation_next(relation *r,vector_index *index,tuple *query) {
144 return hashvector_next( &r->content, index, query );