7 #define ECPGdebug(X,Y) ECPGdebug((X)+100,(Y)) 12 #include "ecpg_config.h" 14 #ifndef ENABLE_THREAD_SAFETY 18 printf(
"No threading enabled.\n");
23 #define WIN32_LEAN_AND_MEAN 37 #ifndef POSTGRES_SQLCA_H 38 #define POSTGRES_SQLCA_H 41 #if defined(WIN32) || defined(__CYGWIN__) 42 #define PGDLLIMPORT __declspec (dllimport) 48 #define SQLERRMC_LEN 150 94 #ifndef POSTGRES_ECPG_INTERNAL 95 #define sqlca (*ECPGget_sqlca()) 107 #line 1 "regression.h" 125 static unsigned __stdcall
fn(
void*
arg)
127 static void*
fn(
void*
arg)
149 value = (intptr_t)
arg;
150 sprintf(name,
"Connection: %d", value);
152 {
ECPGconnect(__LINE__, 0,
"ecpg1_regression" , NULL, NULL , name, 0);
167 ECPGt_char,&(r),(
long)0,(
long)0,(1)*
sizeof(
char),
203 threads[
i] = (HANDLE)_beginthreadex(NULL, 0,
fn, (
void*)
i, 0, &id);
206 WaitForMultipleObjects(THREADS, threads, TRUE, INFINITE);
208 CloseHandle(threads[i]);
211 pthread_create(&threads[i], NULL,
fn, (
void *) i);
213 pthread_join(threads[i], NULL);
bool ECPGdisconnect(int lineno, const char *connection_name)
bool ECPGdo(const int lineno, const int compat, const int force_indicator, const char *connection_name, const bool questionmarks, const int st, const char *query,...)
struct sqlca_t * ECPGget_sqlca(void)
bool ECPGconnect(int lineno, int c, const char *name, const char *user, const char *passwd, const char *connection_name, int autocommit)
struct sqlca_t::@147 sqlerrm
static void * fn(void *arg)
bool ECPGsetcommit(int lineno, const char *mode, const char *connection_name)
char sqlerrmc[SQLERRMC_LEN]