Changeset: e1f9d2df56a2 for MonetDB
URL: http://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=e1f9d2df56a2
Modified Files:
sql/storage/bat/bat_storage.c
sql/storage/bat/bat_table.c
Branch: Jun2016
Log Message:
merged with Jul2015
diffs (128 lines):
diff --git a/sql/storage/bat/bat_storage.c b/sql/storage/bat/bat_storage.c
--- a/sql/storage/bat/bat_storage.c
+++ b/sql/storage/bat/bat_storage.c
@@ -1686,7 +1686,7 @@ gtr_update_delta( sql_trans *tr, sql_del
}
bat_destroy(ins);
- if (cbat->ucnt) {
+ if (cbat->ucnt && cbat->uibid) {
BAT *ui = temp_descriptor(cbat->uibid);
BAT *uv = temp_descriptor(cbat->uvbid);
/* any updates */
@@ -1945,7 +1945,7 @@ tr_update_delta( sql_trans *tr, sql_delt
}
bat_destroy(ins);
- if (cbat->ucnt || cleared) {
+ if ((cbat->ucnt || cleared) && cbat->uibid) {
BAT *ui = temp_descriptor(cbat->uibid);
BAT *uv = temp_descriptor(cbat->uvbid);
@@ -2144,6 +2144,11 @@ update_table(sql_trans *tr, sql_table *f
} else if (tt->data && ft->base.allocated) {
tr_update_dbat(tr, tt->data, ft->data, ft->cleared);
} else if (store_nr_active == 1 && !ft->base.allocated) {
+ if (!tt->data && tt->po) {
+ sql_table *ot = tr_find_table(tr->parent, tt);
+ tt->data = timestamp_dbat(ot->data, tr->stime);
+ }
+ assert(tt->data);
tr_merge_dbat(tr, tt->data);
ft->data = NULL;
} else if (ft->data) {
@@ -2179,6 +2184,11 @@ update_table(sql_trans *tr, sql_table *f
} else if (oc->data && cc->base.allocated) {
tr_update_delta(tr, oc->data, cc->data,
cc->unique == 1);
} else if (store_nr_active == 1 && !cc->base.allocated)
{
+ if (!oc->data) {
+ sql_column *o =
tr_find_column(tr->parent, oc);
+ oc->data = timestamp_delta(o->data,
tr->stime);
+ }
+ assert(oc->data);
tr_merge_delta(tr, oc->data, oc->unique == 1);
cc->data = NULL;
} else if (cc->data) {
@@ -2239,6 +2249,11 @@ update_table(sql_trans *tr, sql_table *f
} else if (oi->data && ci->base.allocated) {
tr_update_delta(tr, oi->data, ci->data,
0);
} else if (store_nr_active == 1 &&
!ci->base.allocated) {
+ if (!oi->data) {
+ sql_idx *o =
tr_find_idx(tr->parent, oi);
+ oi->data =
timestamp_delta(o->data, tr->stime);
+ }
+ assert(oi->data);
tr_merge_delta(tr, oi->data, 0);
ci->data = NULL;
} else if (ci->data) {
@@ -2294,7 +2309,7 @@ tr_log_delta( sql_trans *tr, sql_delta *
}
bat_destroy(ins);
- if (cbat->ucnt) {
+ if (cbat->ucnt && cbat->uibid) {
BAT *ui = temp_descriptor(cbat->uibid);
BAT *uv = temp_descriptor(cbat->uvbid);
/* any updates */
diff --git a/sql/storage/bat/bat_table.c b/sql/storage/bat/bat_table.c
--- a/sql/storage/bat/bat_table.c
+++ b/sql/storage/bat/bat_table.c
@@ -142,7 +142,37 @@ full_destroy(sql_column *c, BAT *b)
bat_destroy(b);
}
-static oid column_find_row(sql_trans *tr, sql_column *c, const void *value,
...);
+static oid
+column_find_oid(sql_trans *tr, sql_column *c, const int *vid)
+{
+ BAT *b = NULL, *s = NULL;
+ oid rid = oid_nil;
+
+ b = full_column(tr, c);
+ if (!b)
+ return oid_nil;
+
+ if (store_funcs.count_del(tr, c->t))
+ s = store_funcs.bind_del(tr, c->t, RD_INS);
+
+ if (BAThash(b, 0) == GDK_SUCCEED) {
+ BATiter cni = bat_iterator(b);
+ BUN p;
+
+ HASHloop(cni, cni.b->T->hash, p, vid) {
+ oid pos = p;
+
+ if (!s || BUNfnd(s, &pos) == BUN_NONE) {
+ rid = p;
+ break;
+ }
+ }
+ }
+ if (s)
+ bat_destroy(s);
+ return rid;
+}
+
static oid
column_find_row(sql_trans *tr, sql_column *c, const void *value, ...)
{
@@ -151,14 +181,17 @@ column_find_row(sql_trans *tr, sql_colum
oid rid = oid_nil;
sql_column *n = NULL;
+ va_start(va, value);
+ if ((n = va_arg(va, sql_column *)) == NULL && c->type.type->localtype
==TYPE_int)
+ return column_find_oid(tr, c, value);
+
s = delta_cands(tr, c->t);
if (!s)
return oid_nil;
- va_start(va, value);
b = full_column(tr, c);
if (!b)
return oid_nil;
- if ((n = va_arg(va, sql_column *)) == NULL) {
+ if (!n) {
if (BAThash(b, 0) == GDK_SUCCEED) {
BATiter cni = bat_iterator(b);
BUN p;
_______________________________________________
checkin-list mailing list
checkin-list@monetdb.org
https://www.monetdb.org/mailman/listinfo/checkin-list
