1 /* Processed by ecpg (regression mode) */
2 /* These include files are added by the preprocessor */
3 #include <ecpglib.h>
4 #include <ecpgerrno.h>
5 #include <sqlca.h>
6 /* End of automatic include section */
7 #define ECPGdebug(X,Y) ECPGdebug((X)+100,(Y))
8
9 #line 1 "prep.pgc"
10 #include <stdlib.h>
11 #include "ecpg_config.h"
12
13 #ifndef ENABLE_THREAD_SAFETY
14 int
main(void)15 main(void)
16 {
17 printf("No threading enabled.\n");
18 return 0;
19 }
20 #else
21 #ifdef WIN32
22 #define WIN32_LEAN_AND_MEAN
23 #include <windows.h>
24 #include <process.h>
25 #include <locale.h>
26 #else
27 #include <pthread.h>
28 #endif
29 #include <stdio.h>
30
31 #define THREADS 16
32 #define REPEATS 50
33
34
35 #line 1 "sqlca.h"
36 #ifndef POSTGRES_SQLCA_H
37 #define POSTGRES_SQLCA_H
38
39 #ifndef PGDLLIMPORT
40 #if defined(WIN32) || defined(__CYGWIN__)
41 #define PGDLLIMPORT __declspec (dllimport)
42 #else
43 #define PGDLLIMPORT
44 #endif /* __CYGWIN__ */
45 #endif /* PGDLLIMPORT */
46
47 #define SQLERRMC_LEN 150
48
49 #ifdef __cplusplus
50 extern "C"
51 {
52 #endif
53
54 struct sqlca_t
55 {
56 char sqlcaid[8];
57 long sqlabc;
58 long sqlcode;
59 struct
60 {
61 int sqlerrml;
62 char sqlerrmc[SQLERRMC_LEN];
63 } sqlerrm;
64 char sqlerrp[8];
65 long sqlerrd[6];
66 /* Element 0: empty */
67 /* 1: OID of processed tuple if applicable */
68 /* 2: number of rows processed */
69 /* after an INSERT, UPDATE or */
70 /* DELETE statement */
71 /* 3: empty */
72 /* 4: empty */
73 /* 5: empty */
74 char sqlwarn[8];
75 /* Element 0: set to 'W' if at least one other is 'W' */
76 /* 1: if 'W' at least one character string */
77 /* value was truncated when it was */
78 /* stored into a host variable. */
79
80 /*
81 * 2: if 'W' a (hopefully) non-fatal notice occurred
82 */ /* 3: empty */
83 /* 4: empty */
84 /* 5: empty */
85 /* 6: empty */
86 /* 7: empty */
87
88 char sqlstate[5];
89 };
90
91 struct sqlca_t *ECPGget_sqlca(void);
92
93 #ifndef POSTGRES_ECPG_INTERNAL
94 #define sqlca (*ECPGget_sqlca())
95 #endif
96
97 #ifdef __cplusplus
98 }
99 #endif
100
101 #endif
102
103 #line 25 "prep.pgc"
104
105
106 #line 1 "regression.h"
107
108
109
110
111
112
113 #line 26 "prep.pgc"
114
115
116 /* exec sql whenever sqlerror sqlprint ; */
117 #line 28 "prep.pgc"
118
119 /* exec sql whenever not found sqlprint ; */
120 #line 29 "prep.pgc"
121
122
123 #ifdef WIN32
fn(void * arg)124 static unsigned __stdcall fn(void* arg)
125 #else
126 static void* fn(void* arg)
127 #endif
128 {
129 int i;
130
131 /* exec sql begin declare section */
132
133
134
135
136 #line 40 "prep.pgc"
137 int value ;
138
139 #line 41 "prep.pgc"
140 char name [ 100 ] ;
141
142 #line 42 "prep.pgc"
143 char query [ 256 ] = "INSERT INTO T VALUES ( ? )" ;
144 /* exec sql end declare section */
145 #line 43 "prep.pgc"
146
147
148 #ifdef WIN32
149 #ifdef _MSC_VER /* requires MSVC */
150 _configthreadlocale(_ENABLE_PER_THREAD_LOCALE);
151 #endif
152 #endif
153
154 value = (long)arg;
155 sprintf(name, "Connection: %d", value);
156
157 { ECPGconnect(__LINE__, 0, "ecpg1_regression" , NULL, NULL , name, 0);
158 #line 54 "prep.pgc"
159
160 if (sqlca.sqlcode < 0) sqlprint();}
161 #line 54 "prep.pgc"
162
163 { ECPGsetcommit(__LINE__, "on", NULL);
164 #line 55 "prep.pgc"
165
166 if (sqlca.sqlcode < 0) sqlprint();}
167 #line 55 "prep.pgc"
168
169 for (i = 1; i <= REPEATS; ++i)
170 {
171 { ECPGprepare(__LINE__, NULL, 0, "i", query);
172 #line 58 "prep.pgc"
173
174 if (sqlca.sqlcode < 0) sqlprint();}
175 #line 58 "prep.pgc"
176
177 { ECPGdo(__LINE__, 0, 1, NULL, 0, ECPGst_execute, "i",
178 ECPGt_int,&(value),(long)1,(long)1,sizeof(int),
179 ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, ECPGt_EOIT, ECPGt_EORT);
180 #line 59 "prep.pgc"
181
182 if (sqlca.sqlcode == ECPG_NOT_FOUND) sqlprint();
183 #line 59 "prep.pgc"
184
185 if (sqlca.sqlcode < 0) sqlprint();}
186 #line 59 "prep.pgc"
187
188 }
189 { ECPGdeallocate(__LINE__, 0, NULL, "i");
190 #line 61 "prep.pgc"
191
192 if (sqlca.sqlcode < 0) sqlprint();}
193 #line 61 "prep.pgc"
194
195 { ECPGdisconnect(__LINE__, name);
196 #line 62 "prep.pgc"
197
198 if (sqlca.sqlcode < 0) sqlprint();}
199 #line 62 "prep.pgc"
200
201
202 return 0;
203 }
204
main()205 int main ()
206 {
207 int i;
208 #ifdef WIN32
209 HANDLE threads[THREADS];
210 #else
211 pthread_t threads[THREADS];
212 #endif
213
214 { ECPGconnect(__LINE__, 0, "ecpg1_regression" , NULL, NULL , NULL, 0);
215 #line 76 "prep.pgc"
216
217 if (sqlca.sqlcode < 0) sqlprint();}
218 #line 76 "prep.pgc"
219
220 { ECPGsetcommit(__LINE__, "on", NULL);
221 #line 77 "prep.pgc"
222
223 if (sqlca.sqlcode < 0) sqlprint();}
224 #line 77 "prep.pgc"
225
226 { ECPGdo(__LINE__, 0, 1, NULL, 0, ECPGst_normal, "drop table if exists T", ECPGt_EOIT, ECPGt_EORT);
227 #line 78 "prep.pgc"
228
229 if (sqlca.sqlcode < 0) sqlprint();}
230 #line 78 "prep.pgc"
231
232 { ECPGdo(__LINE__, 0, 1, NULL, 0, ECPGst_normal, "create table T ( i int )", ECPGt_EOIT, ECPGt_EORT);
233 #line 79 "prep.pgc"
234
235 if (sqlca.sqlcode < 0) sqlprint();}
236 #line 79 "prep.pgc"
237
238 { ECPGdisconnect(__LINE__, "CURRENT");
239 #line 80 "prep.pgc"
240
241 if (sqlca.sqlcode < 0) sqlprint();}
242 #line 80 "prep.pgc"
243
244
245 #ifdef WIN32
246 for (i = 0; i < THREADS; ++i)
247 {
248 unsigned id;
249 threads[i] = (HANDLE)_beginthreadex(NULL, 0, fn, (void*)i, 0, &id);
250 }
251
252 WaitForMultipleObjects(THREADS, threads, TRUE, INFINITE);
253 for (i = 0; i < THREADS; ++i)
254 CloseHandle(threads[i]);
255 #else
256 for (i = 0; i < THREADS; ++i)
257 pthread_create(&threads[i], NULL, fn, (void *) (long) i);
258 for (i = 0; i < THREADS; ++i)
259 pthread_join(threads[i], NULL);
260 #endif
261
262 return 0;
263 }
264 #endif
265