Add ecpg thread testing file.

1 files changed, 70 insertions, 0 deletions

diff --git a/src/interfaces/ecpg/test/test_thread.pgc b/src/interfaces/ecpg/test/test_thread.pgc
new file mode 100644
index 00000000000..828d66c6a8c
--- /dev/null
+++ b/src/interfaces/ecpg/test/test_thread.pgc
@@ -0,0 +1,70 @@
+/* ---
+ *	Thread test program
+ *	by Philip Yarra
+ *
+ *	To run, create this table in the 'test' database:
+ *	
+ *	CREATE TABLE foo (
+ *	    message character(40)
+ *	);
+ * ---
+ */
+
+
+#include <pthread.h>
+
+int main(void);
+void ins1(void);
+void ins2(void);
+
+int main(void)
+{
+        pthread_t thread1, thread2;
+        pthread_create(&thread1, NULL, (void *) ins1, NULL);
+        pthread_create(&thread2, NULL, (void *) ins2, NULL);
+        pthread_join(thread1, NULL);
+        pthread_join(thread2, NULL);
+        printf("Program done!\n");
+        return 0;
+}
+
+void ins1(void)
+{
+        int i;
+        EXEC SQL BEGIN DECLARE SECTION;
+        char* cs = "test";
+        char* bar = "one!";
+        EXEC SQL END DECLARE SECTION;
+        EXEC SQL WHENEVER sqlerror sqlprint;
+        EXEC SQL CONNECT TO :cs AS test1;
+        for (i = 0; i < 5; i++)
+        {
+                printf("thread 1 : inserting\n");
+                EXEC SQL AT test1 INSERT INTO foo VALUES(:bar);
+                printf("thread 1 : insert done\n");
+        }
+        EXEC SQL AT test1 COMMIT WORK;
+        EXEC SQL DISCONNECT test1;
+        printf("thread 1 : done!\n");
+}
+
+
+void ins2(void)
+{
+        int i;
+        EXEC SQL BEGIN DECLARE SECTION;
+        char* cs = "test";
+        char* bar = "two!";
+        EXEC SQL END DECLARE SECTION;
+        EXEC SQL WHENEVER sqlerror sqlprint;
+        EXEC SQL CONNECT TO :cs AS test2;
+        for (i = 0; i < 5; i++)
+        {
+                printf("thread  2: inserting\n");
+                EXEC SQL AT test2 INSERT INTO foo VALUES(:bar);
+                printf("thread  2: insert done\n");
+        }
+        EXEC SQL AT test2 COMMIT WORK;
+        EXEC SQL DISCONNECT test2;
+        printf("thread  2: done!\n");
+}