3 #define POSTGRES_ECPG_INTERNAL
13 #ifdef ENABLE_THREAD_SAFETY
16 static pthread_once_t actual_connection_key_once = PTHREAD_ONCE_INIT;
21 #ifdef ENABLE_THREAD_SAFETY
23 ecpg_actual_connection_init(
void)
25 pthread_key_create(&actual_connection_key, NULL);
29 ecpg_pthreads_init(
void)
31 pthread_once(&actual_connection_key_once, ecpg_actual_connection_init);
40 if ((connection_name == NULL) || (strcmp(connection_name,
"CURRENT") == 0))
42 #ifdef ENABLE_THREAD_SAFETY
64 if (strcmp(connection_name, con->
name) == 0)
78 if ((connection_name == NULL) || (strcmp(connection_name,
"CURRENT") == 0))
80 #ifdef ENABLE_THREAD_SAFETY
98 #ifdef ENABLE_THREAD_SAFETY
104 #ifdef ENABLE_THREAD_SAFETY
140 #ifdef ENABLE_THREAD_SAFETY
147 ecpg_log(
"ecpg_finish: connection %s closed\n", act->
name ? act->
name :
"(null)");
161 ecpg_log(
"ecpg_finish: called an extra time\n");
170 if (!
ecpg_init(con, connection_name, lineno))
173 ecpg_log(
"ECPGsetcommit on line %d: action \"%s\"; connection \"%s\"\n", lineno,
mode, con->
name);
186 else if (!con->
autocommit && strncmp(
mode,
"on", strlen(
"on")) == 0)
206 if (!
ecpg_init(con, connection_name, lineno))
209 #ifdef ENABLE_THREAD_SAFETY
240 if (strncmp(
sqlstate,
"00", 2) == 0)
243 ecpg_log(
"ECPGnoticeReceiver: %s\n", message);
259 sqlca->sqlwarn[2] =
'W';
260 sqlca->sqlwarn[0] =
'W';
262 strncpy(
sqlca->sqlerrm.sqlerrmc, message,
sizeof(
sqlca->sqlerrm.sqlerrmc));
263 sqlca->sqlerrm.sqlerrmc[
sizeof(
sqlca->sqlerrm.sqlerrmc) - 1] = 0;
264 sqlca->sqlerrm.sqlerrml = strlen(
sqlca->sqlerrm.sqlerrmc);
284 const char **conn_keywords;
285 const char **conn_values;
312 envname = getenv(
"PG_DBPATH");
320 if (
dbname == NULL && connection_name == NULL)
321 connection_name =
"DEFAULT";
323 #if ENABLE_THREAD_SAFETY
324 ecpg_pthreads_init();
331 ecpg_log(
"ECPGconnect: connection identifier %s is already in use\n",
345 if (strncmp(
dbname,
"tcp:", 4) == 0 || strncmp(
dbname,
"unix:", 5) == 0)
352 if (strncmp(
dbname,
"tcp:", 4) == 0)
354 else if (strncmp(
dbname,
"unix:", 5) == 0)
357 if (strncmp(
dbname + offset,
"postgresql://", strlen(
"postgresql://")) == 0)
365 offset += strlen(
"postgresql://");
367 tmp = strrchr(
dbname + offset,
'?');
385 tmp = strrchr(
dbname + offset,
':');
393 if (strncmp(
dbname,
"unix:", 5) == 0)
400 if (strcmp(
dbname + offset,
"localhost") != 0 &&
401 strcmp(
dbname + offset,
"127.0.0.1") != 0)
403 ecpg_log(
"ECPGconnect: non-localhost access via sockets on line %d\n", lineno);
421 if (*(
dbname + offset) !=
'\0')
432 tmp = strrchr(
dbname,
':');
440 tmp = strrchr(
dbname,
'@');
471 if (passwd && strlen(passwd) > 0)
479 conn_keywords = (
const char **)
ecpg_alloc((connect_params + 1) *
sizeof(
char *), lineno);
480 conn_values = (
const char **)
ecpg_alloc(connect_params *
sizeof(
char *), lineno);
481 if (conn_keywords == NULL || conn_values == NULL)
502 #ifdef ENABLE_THREAD_SAFETY
505 if (connection_name != NULL)
518 all_connections =
this;
519 #ifdef ENABLE_THREAD_SAFETY
524 ecpg_log(
"ECPGconnect: opening database %s on %s port %s %s%s %s%s\n",
525 realname ? realname :
"<DEFAULT>",
526 host ? host :
"<DEFAULT>",
534 conn_keywords[
i] =
"dbname";
535 conn_values[
i] = realname;
540 conn_keywords[
i] =
"host";
541 conn_values[
i] = host;
546 conn_keywords[
i] =
"port";
547 conn_values[
i] =
port;
552 conn_keywords[
i] =
"user";
553 conn_values[
i] =
user;
556 if (passwd && strlen(passwd) > 0)
558 conn_keywords[
i] =
"password";
559 conn_values[
i] = passwd;
580 for (token1 =
str; *token1 ==
' '; token1++)
583 for (
e = 0; token1[
e] && token1[
e] !=
'=';
e++)
589 for (token2 = token1 +
e + 1; *token2 ==
' '; token2++)
592 for (
a = 0; token2[
a] && token2[
a] !=
'&';
a++)
597 str = token2 +
a + 1;
602 conn_keywords[
i] = token1;
603 conn_values[
i] = token2;
615 conn_keywords[
i] = NULL;
633 const char *db = realname ? realname :
ecpg_gettext(
"<DEFAULT>");
639 #ifdef ENABLE_THREAD_SAFETY
653 #ifdef ENABLE_THREAD_SAFETY
677 #ifdef ENABLE_THREAD_SAFETY
681 if (strcmp(connection_name,
"ALL") == 0)
696 if (!
ecpg_init(con, connection_name, lineno))
698 #ifdef ENABLE_THREAD_SAFETY
707 #ifdef ENABLE_THREAD_SAFETY
static void ecpg_finish(struct connection *act)
static struct connection * ecpg_get_connection_nr(const char *connection_name)
static struct connection * all_connections
bool ECPGsetconn(int lineno, const char *connection_name)
PGconn * ECPGget_PGconn(const char *connection_name)
bool ECPGsetcommit(int lineno, const char *mode, const char *connection_name)
struct connection * ecpg_get_connection(const char *connection_name)
bool ECPGdisconnect(int lineno, const char *connection_name)
static void ECPGnoticeReceiver(void *arg, const PGresult *result)
static struct connection * actual_connection
bool ECPGconnect(int lineno, int c, const char *name, const char *user, const char *passwd, const char *connection_name, int autocommit)
#define ECPG_WARNING_IN_TRANSACTION
#define ECPG_WARNING_UNKNOWN_PORTAL
#define ECPG_WARNING_PORTAL_EXISTS
#define ECPG_WARNING_NO_TRANSACTION
#define ECPG_OUT_OF_MEMORY
bool ecpg_check_PQresult(PGresult *, int, PGconn *, enum COMPAT_MODE)
#define ECPG_SQLSTATE_NO_ACTIVE_SQL_TRANSACTION
char * ecpg_alloc(long, int)
#define ECPG_SQLSTATE_ECPG_OUT_OF_MEMORY
#define ECPG_SQLSTATE_ECPG_INTERNAL_ERROR
#define ECPG_SQLSTATE_INVALID_CURSOR_NAME
void ecpg_log(const char *format,...) pg_attribute_printf(1
void ecpg_clear_auto_mem(void)
#define ECPG_SQLSTATE_ACTIVE_SQL_TRANSACTION
bool ecpg_init(const struct connection *, const char *, const int)
#define ECPG_SQLSTATE_DUPLICATE_CURSOR
void ecpg_init_sqlca(struct sqlca_t *sqlca)
bool ecpg_deallocate_all_conn(int lineno, enum COMPAT_MODE c, struct connection *conn)
#define ECPG_SQLSTATE_SQLCLIENT_UNABLE_TO_ESTABLISH_SQLCONNECTION
void ecpg_raise(int line, int code, const char *sqlstate, const char *str)
bool ecpg_internal_regression_mode
char * ecpg_strdup(const char *, int)
int errmsg(const char *fmt,...)
PGconn * PQconnectdbParams(const char *const *keywords, const char *const *values, int expand_dbname)
PGTransactionStatusType PQtransactionStatus(const PGconn *conn)
char * PQerrorMessage(const PGconn *conn)
ConnStatusType PQstatus(const PGconn *conn)
void PQfinish(PGconn *conn)
PQnoticeReceiver PQsetNoticeReceiver(PGconn *conn, PQnoticeReceiver proc, void *arg)
void PQclear(PGresult *res)
PGresult * PQexec(PGconn *conn, const char *query)
char * PQresultErrorField(const PGresult *res, int fieldcode)
struct sqlca_t * ECPGget_sqlca(void)
Assert(fmt[strlen(fmt) - 1] !='\n')
static PgChecksumMode mode
char * last_dir_separator(const char *filename)
#define PG_DIAG_MESSAGE_PRIMARY
int pthread_mutex_unlock(pthread_mutex_t *mp)
void * pthread_getspecific(pthread_key_t key)
int pthread_mutex_lock(pthread_mutex_t *mp)
void pthread_setspecific(pthread_key_t key, void *val)
CRITICAL_SECTION * pthread_mutex_t
struct ECPGtype_information_cache * cache_head
struct prepared_statement * prep_stmts