#include "db_headers.h"
#include "db_query.h"
#include "nisdb_mt.h"
#include <string.h>
db_query::db_query(db_scheme * scheme, int size, nis_attr* attrlist)
{
int i;
num_components = size;
components = new db_qcomp[size];
if (components == NULL) {
num_components = 0;
FATAL(
"db_query::db_query: cannot allocate space for components",
DB_MEMORY_LIMIT);
}
for (i = 0; i < size; i++) {
if (!scheme->find_index(attrlist[i].zattr_ndx,
&(components[i].which_index))) {
syslog(LOG_ERR, "db_query::db_query: bad index (%s)",
attrlist[i].zattr_ndx);
clear_components(i);
return;
}
components[i].index_value = new
item(attrlist[i].zattr_val.zattr_val_val,
attrlist[i].zattr_val.zattr_val_len);
if (components[i].index_value == NULL) {
clear_components(i);
FATAL(
"db_query::db_query:cannot allocate space for index",
DB_MEMORY_LIMIT);
}
}
}
db_query::db_query(db_scheme *scheme, entry_object_p obj)
{
num_components = scheme->numkeys();
db_key_desc *keyinfo = scheme->keyloc();
int objsize = obj->en_cols.en_cols_len;
struct entry_col * objcols = obj->en_cols.en_cols_val;
components = new db_qcomp[num_components];
int wherein_obj, i;
if (components == NULL) {
FATAL(
"db_query::db_query: cannot allocate space for components",
DB_MEMORY_LIMIT);
}
for (i = 0; i < num_components; i++) {
components[i].which_index = i;
wherein_obj = keyinfo[i].column_number;
if (wherein_obj >= objsize) {
syslog(LOG_ERR,
"db_query::column %d cannot occur in object with %d columns (start counting at 0)\n",
wherein_obj, objsize);
clear_components(i);
return;
}
components[i].index_value = new
item(objcols[wherein_obj].ec_value.ec_value_val,
objcols[wherein_obj].ec_value.ec_value_len);
if (components[i].index_value == NULL) {
clear_components(i);
FATAL(
"db_query::db_query:cannot allocate space for index",
DB_MEMORY_LIMIT);
}
}
}
void
db_query::clear_components(int how_many)
{
int i;
if (components) {
for (i = 0; i < how_many; i++)
if (components[i].index_value)
delete components[i].index_value;
delete components;
components = NULL;
}
num_components = 0;
}
db_query::~db_query()
{
clear_components(num_components);
}
void
db_query::print()
{
int i;
for (i = 0; i < num_components; i++) {
printf("%d: ", components[i].which_index);
components[i].index_value->print();
putchar('\n');
}
}