Changeset: 1ddb63bf0678 for MonetDB
URL: http://dev.monetdb.org/hg/MonetDB?cmd=changeset;node=1ddb63bf0678
Modified Files:
        sql/storage/bat/bat_storage.c
        sql/storage/bat/bat_utils.c
        sql/storage/bat/bat_utils.h
Branch: Jul2015
Log Message:

make sure all deletes are bat-transaction level committed (ie always update
the bat delta management once we apply changes in a sql transaction)


diffs (57 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
@@ -2051,14 +2051,10 @@ tr_update_dbat(sql_trans *tr, sql_dbat *
        if (BUNlast(db) > db->batInserted || cleared) {
                BAT *odb = temp_descriptor(tdb->dbid);
 
-               /* For large deletes write the new deletes bat */
-               if (BATcount(db) > SNAPSHOT_MINSIZE) {
-                       temp_destroy(tdb->dbid);
-                       tdb->dbid = fdb->dbid;
-               } else {
-                       append_inserted(odb, db);
-                       temp_destroy(fdb->dbid);
-               }
+               append_inserted(odb, db);
+               BATcommit(odb);
+               temp_destroy(fdb->dbid);
+
                fdb->dbid = 0;
                tdb->cnt = fdb->cnt;
                bat_destroy(odb);
diff --git a/sql/storage/bat/bat_utils.c b/sql/storage/bat/bat_utils.c
--- a/sql/storage/bat/bat_utils.c
+++ b/sql/storage/bat/bat_utils.c
@@ -101,20 +101,6 @@ append_inserted(BAT *b, BAT *i )
        return nr;
 }
 
-BUN
-copy_inserted(BAT *b, BAT *i )
-{
-       BUN nr = 0;
-       BUN r;
-               BATiter ii = bat_iterator(i);
-
-       for (r = i->batInserted; r < BUNlast(i); r++) {
-               BUNins(b, BUNhead(ii,r), BUNtail(ii,r), TRUE);
-                       nr++;
-       }
-       return nr;
-}
-
 BAT *ebats[MAXATOMS] = { NULL };
 
 log_bid 
diff --git a/sql/storage/bat/bat_utils.h b/sql/storage/bat/bat_utils.h
--- a/sql/storage/bat/bat_utils.h
+++ b/sql/storage/bat/bat_utils.h
@@ -29,7 +29,6 @@ extern void bat_destroy(BAT *b);
 extern BAT *bat_new(int ht, int tt, BUN size, int role);
 
 extern BUN append_inserted(BAT *b, BAT *i );
-extern BUN copy_inserted(BAT *b, BAT *i );
 
 extern BAT *ebats[MAXATOMS];
 
_______________________________________________
checkin-list mailing list
[email protected]
https://www.monetdb.org/mailman/listinfo/checkin-list

Reply via email to