add costestimate 0 -> always uses; creating new btrees when curr is full

Author: tastelessjolt

src/backend/access/smerge/smbtree.c

@@ -27,7 +27,6 @@ create_btree_index_stmt(Relation heap, int attsnum, AttrNumber *attrs, char *ind
 	List* indexParams;
 	IndexElem* indexElem;
 
-	ListCell* head;
 	ListCell* prevCell;
 	ListCell* currCell;
 
@@ -97,3 +96,27 @@ create_btree_index_stmt(Relation heap, int attsnum, AttrNumber *attrs, char *ind
 	btreeIndStmt->if_not_exists = false;
 	return btreeIndStmt;
 }
+
+ObjectAddress 
+_sm_create_curr_btree (Relation heap, SmMetadata* metadata) {
+	IndexStmt* btreeIndStmt;
+	ObjectAddress addr;
+
+	btreeIndStmt = create_btree_index_stmt(heap, metadata->attnum, metadata->attrs, NULL);
+	addr = DefineIndex(RelationGetRelid(heap), 
+						btreeIndStmt,
+						InvalidOid,
+						false,
+						true,
+						false,
+						true);
+
+	if ( addr.objectId == InvalidOid ) {
+		printf("Error creating sub btree index\n");
+	}
+	else {
+		printf("OID: %d \n", addr.objectId);
+	}
+
+	return addr;
+} 

src/backend/access/smerge/smerge.c

@@ -33,7 +33,6 @@
 #include "utils/memutils.h"
 
 #include "access/nbtree.h"
-#include "commands/defrem.h"
 
 
 #include <string.h>
@@ -197,7 +196,15 @@ smergeinsert(Relation rel, Datum *values, bool *isnull,
 
 	if (sm_metadata->currTuples >= MAX_INMEM_TUPLES) {
 		printf("Exceeded! (:3)\n");
-		
+		sm_metadata->tree[0][sm_metadata->levels[0]++] = sm_metadata->curr;
+		ObjectAddress addr = _sm_create_curr_btree(heapRel, sm_metadata);
+		sm_metadata->currTuples = 0;
+		if (addr.objectId != InvalidOid)
+			sm_metadata->curr = addr.objectId;
+		else 
+			printf("Error in creating a sub-btree\n");
+
+		// call merge func here
 	}
 
 	_sm_write_metadata(rel, sm_metadata);
@@ -370,5 +377,8 @@ smergecostestimate(PlannerInfo *root,
                 Selectivity *indexSelectivity,
                 double *indexCorrelation)
 {
-
+	*indexStartupCost = 0.0;
+	*indexTotalCost = 0.01;
+	*indexSelectivity = 0.0;
+	*indexCorrelation = 0.9;
 }

src/include/access/smerge.h

@@ -22,6 +22,7 @@
 #include "access/xlogreader.h"
 #include "access/attnum.h"
 
+#include "catalog/objectaddress.h"
 #include "catalog/pg_index.h"
 #include "lib/stringinfo.h"
 #include "storage/bufmgr.h"
@@ -37,7 +38,7 @@
 #include "utils/rel.h"
 
 #include "storage/smgr.h"
-
+#include "commands/defrem.h"
 /*
  * Define constants here
  */
@@ -106,6 +107,7 @@ typedef SmScanOpaqueData* SmScanOpaque;
 // btree create functions
 extern Node* create_false_node(void);
 extern IndexStmt* create_btree_index_stmt(Relation heap, int attsnum, AttrNumber *attrs, char *indname);
+extern ObjectAddress _sm_create_curr_btree (Relation heap, SmMetadata* metadata);
 
 /* 
  * start smerge specific