postgresql/src/interfaces/ecpg/test/test_thread.pgc

/* ---
 *	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");
}