Add contraints for FDW tables

knizhnik · knizhnik · commit 276ae57b732e · 2016-01-14T23:12:49.000+03:00
diff --git a/contrib/postgres_fdw/connection.c b/contrib/postgres_fdw/connection.c
@@ -22,9 +22,6 @@
 #include "utils/hsearch.h"
 #include "utils/memutils.h"
 
-#undef DEBUG3
-#define DEBUG3 WARNING
-
 /*
  * Connection cache hash table entry
  *
diff --git a/contrib/postgres_fdw/tests/dtmbench.cpp b/contrib/postgres_fdw/tests/dtmbench.cpp
@@ -160,7 +160,8 @@ void initializeDatabase()
 	int accountsPerShard = (cfg.nAccounts + cfg.nShards - 1)/cfg.nShards;
 	for (int i = 0; i < cfg.nShards; i++) 
 	{ 
-		exec(txn, "insert into t_fdw%i (select generate_series(0,%d), %d)", i+1, accountsPerShard*i, accountsPerShard-1, 0);
+		exec(txn, "alter table t_fdw%i add check (u between %d and %d)", i+1, accountsPerShard*i, accountsPerShard-1);
+		exec(txn, "insert into t_fdw%i (select generate_series(%d,%d), %d)", i+1, accountsPerShard*i, accountsPerShard-1, 0);
 	}
     txn.commit();
 }
diff --git a/contrib/postgres_fdw/tests/makefile b/contrib/postgres_fdw/tests/makefile
@@ -1,5 +1,5 @@
 CXX=g++
-CXXFLAGS=-g -Wall -O0 -pthread 
+CXXFLAGS=-g -Wall -O2 -pthread 
 
 all: dtmbench
 

Original file line number	Diff line number	Diff line change
`@@ -22,9 +22,6 @@`
`22`	`22`	`#include "utils/hsearch.h"`
`23`	`23`	`#include "utils/memutils.h"`
`24`	`24`
`25`		`-#undef DEBUG3`
`26`		`-#define DEBUG3 WARNING`
`27`		`-`
`28`	`25`	`/*`
`29`	`26`	`* Connection cache hash table entry`
`30`	`27`	`*`
Original file line number	Diff line number	Diff line change
`@@ -160,7 +160,8 @@ void initializeDatabase()`
`160`	`160`	`int accountsPerShard = (cfg.nAccounts + cfg.nShards - 1)/cfg.nShards;`
`161`	`161`	`for (int i = 0; i < cfg.nShards; i++)`
`162`	`162`	`{`
`163`		`- exec(txn, "insert into t_fdw%i (select generate_series(0,%d), %d)", i+1, accountsPerShard*i, accountsPerShard-1, 0);`
	`163`	`+ exec(txn, "alter table t_fdw%i add check (u between %d and %d)", i+1, accountsPerShard*i, accountsPerShard-1);`
	`164`	`+ exec(txn, "insert into t_fdw%i (select generate_series(%d,%d), %d)", i+1, accountsPerShard*i, accountsPerShard-1, 0);`
`164`	`165`	`}`
`165`	`166`	`txn.commit();`
`166`	`167`	`}`