Fixed bugs, reported in issue #8. (#25)

progmachine · web-flow · commit 6ca29b7042ce · 2024-05-24T05:47:10.000-04:00
* Fixed bugs, reported in issue #8. Bunch of memory leaks, occuring in tests. One heap-buffer-overrun in read operation at convert.c:3162. Two memory leaks, detected by my unit tests: password, conn_settings, pqopt fields overwrite if their values provided by both, system config and connstring. Restored reference counting lifetime managment of COL_INFO objects. Some minor cosmetic changes. Signed-off-by: Alexandr Kuznetsov <progmachine@xenlab.one> * Minor cosmetic changes. Signed-off-by: Alexandr Kuznetsov <progmachine@xenlab.one> * Forgot set col_info to NULL in TABLE_INFO object while clearing it. Signed-off-by: Alexandr Kuznetsov <progmachine@xenlab.one> * Fixing comments. Signed-off-by: Alexandr Kuznetsov <progmachine@xenlab.one> --------- Signed-off-by: Alexandr Kuznetsov <progmachine@xenlab.one>
diff --git a/bind.c b/bind.c
@@ -701,6 +701,8 @@ IPD_free_params(IPDFields *ipdopts, char option)
 		return;
 	if (option == STMT_FREE_PARAMS_ALL)
 	{
+		for (int i = 0; i < ipdopts->allocated; ++i)
+			NULL_THE_NAME(ipdopts->parameters[i].paramName);
 		free(ipdopts->parameters);
 		ipdopts->parameters = NULL;
 		ipdopts->allocated = 0;
diff --git a/connection.c b/connection.c
@@ -553,21 +553,28 @@ CC_clear_col_info(ConnectionClass *self, BOOL destroy)
 
 		for (i = 0; i < self->ntables; i++)
 		{
+			/* Going through COL_INFO cache table and releasing coli objects. */
 			if (coli = self->col_info[i], NULL != coli)
 			{
-				if (destroy || coli->refcnt == 0)
+				coli->refcnt--;
+				if (coli->refcnt <= 0)
 				{
+					/* Last reference to coli object disappeared. Now destroying it. */
 					free_col_info_contents(coli);
 					free(coli);
 					self->col_info[i] = NULL;
 				}
 				else
+				{
+					/* coli object have another reference to it, so it will be destroyed somewhere else. */
 					coli->acc_time = 0;
+				}
 			}
 		}
-		self->ntables = 0;
+		self->ntables = 0; /* Now we have cleared COL_INFO cached objects table. */
 		if (destroy)
 		{
+			/* We destroying COL_INFO cache completely. */
 			free(self->col_info);
 			self->col_info = NULL;
 			self->coli_allocated = 0;
@@ -966,7 +973,7 @@ handle_pgres_error(ConnectionClass *self, const PGresult *pgres,
 		CC_on_abort(self, CONN_DEAD); /* give up the connection */
 	}
 	else if ((errseverity_nonloc && strcmp(errseverity_nonloc, "FATAL") == 0) ||
-		(NULL == errseverity_nonloc && errseverity && strcmp(errseverity, "FATAL") == 0)) /* no */ 
+		(NULL == errseverity_nonloc && errseverity && strcmp(errseverity, "FATAL") == 0)) /* no */
 	{
 		CC_set_errornumber(self, CONNECTION_SERVER_REPORTED_SEVERITY_FATAL);
 		CC_on_abort(self, CONN_DEAD); /* give up the connection */
@@ -2873,7 +2880,7 @@ LIBPQ_connect(ConnectionClass *self)
 		QLOG(0, "PQconnectdbParams:");
 		for (popt = opts, pval = vals; *popt; popt++, pval++)
 			QPRINTF(0, " %s='%s'", *popt, *pval);
-		QPRINTF(0, "\n"); 
+		QPRINTF(0, "\n");
 	}
 	pqconn = PQconnectdbParams(opts, vals, FALSE);
 	if (!pqconn)
diff --git a/convert.c b/convert.c
@@ -3056,7 +3056,7 @@ MYLOG(DETAIL_LOG_LEVEL, "type=" FORMAT_UINTEGER " concur=" FORMAT_UINTEGER "\n",
 		}
 		if (SC_is_fetchcursor(stmt))
 		{
-			snprintfcat(new_statement, qb->str_alsize, 
+			snprintfcat(new_statement, qb->str_alsize,
 				"declare \"%s\"%s cursor%s for ",
 				SC_cursor_name(stmt), opt_scroll, opt_hold);
 			qb->npos = strlen(new_statement);
@@ -3159,7 +3159,7 @@ MYLOG(DETAIL_LOG_LEVEL, "type=" FORMAT_UINTEGER " concur=" FORMAT_UINTEGER "\n",
 					CVT_APPEND_STR(qb, bestitem);
 				}
 				CVT_APPEND_STR(qb, "\" from ");
-				CVT_APPEND_DATA(qb, qp->statement + qp->from_pos + 5, npos - qp->from_pos - 5);
+				CVT_APPEND_DATA(qb, qp->statement + qp->from_pos + 5, qp->stmt_len - qp->from_pos - 5);
 			}
 		}
 		npos -= qp->declare_pos;
@@ -3744,7 +3744,7 @@ inner_process_tokens(QueryParse *qp, QueryBuild *qb)
 				}
 				if (converted)
 				{
-				        const char *column_def = (const char *) QR_get_value_backend_text(coli->result, i, COLUMNS_COLUMN_DEF);
+					const char *column_def = (const char *) QR_get_value_backend_text(coli->result, i, COLUMNS_COLUMN_DEF);
 					if (NULL != column_def &&
 					    strncmp(column_def, "nextval", 7) == 0)
 					{
@@ -3770,6 +3770,7 @@ inner_process_tokens(QueryParse *qp, QueryBuild *qb)
 					}
 				}
 			}
+			TI_ClearObject(pti);
 		}
 		if (!converted)
 			CVT_APPEND_STR(qb, "NULL");
diff --git a/descriptor.c b/descriptor.c
@@ -41,26 +41,39 @@ MYLOG(DETAIL_LOG_LEVEL, "entering count=%d\n", count);
 		{
 			if (ti[i])
 			{
-				COL_INFO *coli = ti[i]->col_info;
-				if (coli)
-				{
-MYLOG(0, "!!!refcnt %p:%d -> %d\n", coli, coli->refcnt, coli->refcnt - 1);
-					coli->refcnt--;
-					if (coli->refcnt <= 0 && 0 == coli->acc_time) /* acc_time == 0 means the table is dropped */
-						free_col_info_contents(coli);
-				}
-				NULL_THE_NAME(ti[i]->schema_name);
-				NULL_THE_NAME(ti[i]->table_name);
-				NULL_THE_NAME(ti[i]->table_alias);
-				NULL_THE_NAME(ti[i]->bestitem);
-				NULL_THE_NAME(ti[i]->bestqual);
-				TI_Destroy_IH(ti[i]);
+				TI_ClearObject(ti[i]);
 				free(ti[i]);
 				ti[i] = NULL;
 			}
 		}
 	}
 }
+void    TI_ClearObject(TABLE_INFO *ti)
+{
+	if (ti)
+	{
+		COL_INFO *coli = ti->col_info;
+		if (coli)
+		{
+MYLOG(0, "!!!refcnt %p:%d -> %d\n", coli, coli->refcnt, coli->refcnt - 1);
+			coli->refcnt--;
+			if (coli->refcnt <= 1 && 0 == coli->acc_time) /* acc_time == 0 means the table is dropped */
+				free_col_info_contents(coli); /* Now coli object is unused, and may be reused later. */
+			if (coli->refcnt <= 0)
+			{
+				/* Last reference to coli object disappeared. Now destroying it. */
+				free(coli);
+				ti->col_info = NULL;
+			}
+		}
+		NULL_THE_NAME(ti->schema_name);
+		NULL_THE_NAME(ti->table_name);
+		NULL_THE_NAME(ti->table_alias);
+		NULL_THE_NAME(ti->bestitem);
+		NULL_THE_NAME(ti->bestqual);
+		TI_Destroy_IH(ti);
+	}
+}
 void	FI_Constructor(FIELD_INFO *self, BOOL reuse)
 {
 MYLOG(DETAIL_LOG_LEVEL, "entering reuse=%d\n", reuse);
diff --git a/descriptor.h b/descriptor.h
@@ -55,6 +55,7 @@ typedef struct
 #define	TI_set_has_no_subclass(ti)	(ti->flags &= (~TI_HASSUBCLASS))
 void	TI_Constructor(TABLE_INFO *, const ConnectionClass *);
 void	TI_Destructor(TABLE_INFO **, int);
+void    TI_ClearObject(TABLE_INFO *ti);
 void	TI_Create_IH(TABLE_INFO *ti);
 void	TI_Destroy_IH(TABLE_INFO *ti);
 const pgNAME	TI_From_IH(TABLE_INFO *ti, OID tableoid);
diff --git a/dlg_specific.c b/dlg_specific.c
@@ -624,6 +624,7 @@ copyConnAttributes(ConnInfo *ci, const char *attribute, const char *value)
 		STRCPY_FIXED(ci->username, value);
 	else if (stricmp(attribute, INI_PASSWORD) == 0 || stricmp(attribute, "pwd") == 0)
 	{
+		NULL_THE_NAME(ci->password);
 		ci->password = decode_or_remove_braces(value);
 #ifndef FORCE_PASSWORDE_DISPLAY
 		MYLOG(0, "key='%s' value='xxxxxxxx'\n", attribute);
@@ -669,11 +670,13 @@ copyConnAttributes(ConnInfo *ci, const char *attribute, const char *value)
 	else if (stricmp(attribute, INI_CONNSETTINGS) == 0 || stricmp(attribute, ABBR_CONNSETTINGS) == 0)
 	{
 		/* We can use the conn_settings directly when they are enclosed with braces */
+		NULL_THE_NAME(ci->conn_settings);
 		ci->conn_settings_in_str = TRUE;
 		ci->conn_settings = decode_or_remove_braces(value);
 	}
 	else if (stricmp(attribute, INI_PQOPT) == 0 || stricmp(attribute, ABBR_PQOPT) == 0)
 	{
+		NULL_THE_NAME(ci->pqopt);
 		ci->pqopt_in_str = TRUE;
 		ci->pqopt = decode_or_remove_braces(value);
 	}
diff --git a/parse.c b/parse.c
@@ -713,8 +713,7 @@ MYPRINTF(0, "->%d\n", updatable);
 }
 
 static BOOL
-getCOLIfromTable(ConnectionClass *conn, pgNAME *schema_name, pgNAME table_name,
-COL_INFO **coli)
+getCOLIfromTable(ConnectionClass *conn, pgNAME *schema_name, pgNAME table_name, COL_INFO **coli)
 {
 	int	colidx;
 	BOOL	found = FALSE;
@@ -836,11 +835,13 @@ getColumnsInfo(ConnectionClass *conn, TABLE_INFO *wti, OID greloid, StatementCla
 		MYLOG(0, "      Success\n");
 		if (greloid != 0)
 		{
+			/* We have reloid. Try to find appropriate coli object from connection COL_INFO cache. */
 			for (k = 0; k < conn->ntables; k++)
 			{
 				tcoli = conn->col_info[k];
 				if (tcoli->table_oid == greloid)
 				{
+					/* We found appropriate coli object, so we will use it. */
 					coli = tcoli;
 					coli_exist = TRUE;
 					break;
@@ -849,42 +850,46 @@ getColumnsInfo(ConnectionClass *conn, TABLE_INFO *wti, OID greloid, StatementCla
 		}
 		if (!coli_exist)
 		{
+			/* Not found, try to find unused coli or oldest (if overflow) in connection COL_INFO cache. */
 			for (k = 0; k < conn->ntables; k++)
 			{
 				tcoli = conn->col_info[k];
-				if (0 < tcoli->refcnt)
-					continue;
+				if (1 < tcoli->refcnt)
+					continue; /* This coli object is used somewhere else, skipping it. */
 				if ((0 == tcoli->table_oid &&
 				    NAME_IS_NULL(tcoli->table_name)) ||
 				    strnicmp(SAFE_NAME(tcoli->schema_name), "pg_temp_", 8) == 0)
 				{
+					/* Found unused coli object, taking it. */
 					coli = tcoli;
 					coli_exist = TRUE;
 					break;
 				}
-				if (NULL == ccoli ||
-				    tcoli->acc_time < acctime)
+				if (NULL == ccoli || tcoli->acc_time < acctime)
 				{
+					/* Not yet found. Alongside, searching least recently used coli object. */
 					ccoli = tcoli;
 					acctime = tcoli->acc_time;
 				}
 			}
-			if (!coli_exist &&
-			    NULL != ccoli &&
-			    conn->ntables >= COLI_RECYCLE)
+			if (!coli_exist && NULL != ccoli && conn->ntables >= COLI_RECYCLE)
 			{
+				/* Not found unsed object. Amount of them is on limit. Taking least recently used coli object. */
 				coli_exist = TRUE;
 				coli = ccoli;
 			}
 		}
 		if (coli_exist)
 		{
+			/* We have ready to use coli object. Cleaning it. */
 			free_col_info_contents(coli);
 		}
 		else
 		{
+			/* We have no coli object. Must create a new one. */
 			if (conn->ntables >= conn->coli_allocated)
 			{
+				/* No place in connection COL_INFO cache table. Allocating or reallocating. */
 				Int2	new_alloc;
 				COL_INFO **col_info;
 
@@ -904,6 +909,7 @@ getColumnsInfo(ConnectionClass *conn, TABLE_INFO *wti, OID greloid, StatementCla
 				conn->coli_allocated = new_alloc;
 			}
 
+			/* Allocating new COL_INFO object. */
 			MYLOG(0, "PARSE: malloc at conn->col_info[%d]\n", conn->ntables);
 			coli = conn->col_info[conn->ntables] = (COL_INFO *) malloc(sizeof(COL_INFO));
 		}
@@ -915,6 +921,7 @@ getColumnsInfo(ConnectionClass *conn, TABLE_INFO *wti, OID greloid, StatementCla
 		}
 		col_info_initialize(coli);
 
+		coli->refcnt++; /* Counting one reference to coli object from connection COL_INFO cache table. */
 		coli->result = res;
 		if (res && QR_get_num_cached_tuples(res) > 0)
 		{
@@ -969,7 +976,7 @@ MYLOG(DETAIL_LOG_LEVEL, "oid item == %s\n", (const char *) QR_get_value_backend_
 		MYLOG(0, "Created col_info table='%s', ntables=%d\n", PRINT_NAME(wti->table_name), conn->ntables);
 		/* Associate a table from the statement with a SQLColumn info */
 		found = TRUE;
-		coli->refcnt++;
+		coli->refcnt++; /* Counting another one reference to coli object from TABLE_INFO wti object. */
 		wti->col_info = coli;
 	}
 cleanup:
diff --git a/results.c b/results.c
@@ -5007,6 +5007,7 @@ PGAPI_SetCursorName(HSTMT hstmt,
 		return SQL_INVALID_HANDLE;
 	}
 
+	NULL_THE_NAME(stmt->cursor_name);
 	SET_NAME_DIRECTLY(stmt->cursor_name, make_string(szCursor, cbCursor, NULL, 0));
 	return SQL_SUCCESS;
 }
diff --git a/statement.c b/statement.c
@@ -277,6 +277,11 @@ PGAPI_FreeStmt(HSTMT hstmt,
 			 * before freeing the associated cursors. Otherwise
 			 * CC_cursor_count() would get wrong results.
 			 */
+			if (stmt->parsed)
+			{
+				QR_Destructor(stmt->parsed);
+				stmt->parsed = NULL;
+			}
 			res = SC_get_Result(stmt);
 			QR_Destructor(res);
 			SC_init_Result(stmt);
@@ -495,6 +500,11 @@ SC_Destructor(StatementClass *self)
 
 		QR_Destructor(res);
 	}
+	if (self->parsed)
+	{
+		QR_Destructor(self->parsed);
+		self->parsed = NULL;
+	}
 
 	SC_initialize_stmts(self, TRUE);
 
@@ -1391,7 +1401,7 @@ SC_create_errorinfo(const StatementClass *self, PG_ErrorInfo *pgerror_fail_safe)
 			pgerror = pgerror_fail_safe;
 			pgerror->status = self->__error_number;
 			pgerror->errorsize = sizeof(pgerror->__error_message);
-			STRCPY_FIXED(pgerror->__error_message, ermsg); 
+			STRCPY_FIXED(pgerror->__error_message, ermsg);
 			pgerror->recsize = -1;
 		}
 		else
@@ -2047,7 +2057,7 @@ SC_execute(StatementClass *self)
 			qflag &= (~READ_ONLY_QUERY); /* must be a SAVEPOINT after DECLARE */
 		}
 		rhold = CC_send_query_append(conn, self->stmt_with_params, qryi, qflag, SC_get_ancestor(self), appendq);
-		first = rhold.first;	
+		first = rhold.first;
 		if (useCursor && QR_command_maybe_successful(first))
 		{
 			/*
@@ -2199,6 +2209,7 @@ MYLOG(DETAIL_LOG_LEVEL, "!!%p->miscinfo=%x res=%p\n", self, self->miscinfo, firs
 					QR_set_fields(first,  NULL);
 					tres->num_fields = first->num_fields;
 					QR_detach(first);
+					QR_Destructor(first);
 					SC_set_Result(self, tres);
 					rhold = self->rhold;
 				}
diff --git a/test/src/cte-test.c b/test/src/cte-test.c
@@ -30,13 +30,13 @@ runTest(HSTMT hstmt)
 	intparam = 3;
 	cbParam1 = sizeof(intparam);
 	rc = SQLBindParameter(hstmt, 1, SQL_PARAM_INPUT,
-						  SQL_INTEGER,	/* value type */
-						  SQL_INTEGER,	/* param type */
-						  0,			/* column size (ignored for SQL_INTEGER) */
-						  0,			/* dec digits */
-						  &intparam,	/* param value ptr */
-						  sizeof(intparam), /* buffer len (ignored for SQL_INTEGER) */
-						  &cbParam1		/* StrLen_or_IndPtr (ignored for SQL_INTEGER) */);
+						  SQL_INTEGER,      /* value type                                 */
+						  SQL_INTEGER,      /* param type                                 */
+						  0,                /* column size (ignored for SQL_INTEGER)      */
+						  0,                /* dec digits                                 */
+						  &intparam,        /* param value ptr                            */
+						  sizeof(intparam), /* buffer len (ignored for SQL_INTEGER)       */
+						  &cbParam1         /* StrLen_or_IndPtr (ignored for SQL_INTEGER) */);
 	CHECK_STMT_RESULT(rc, "SQLBindParameter failed", hstmt);
 
 	/* Execute */
diff --git a/test/src/cursor-block-delete-test.c b/test/src/cursor-block-delete-test.c
diff --git a/test/src/premature-test.c b/test/src/premature-test.c

Original file line number	Diff line number	Diff line change
`@@ -701,6 +701,8 @@ IPD_free_params(IPDFields *ipdopts, char option)`
`701`	`701`	`return;`
`702`	`702`	`if (option == STMT_FREE_PARAMS_ALL)`
`703`	`703`	`{`
	`704`	`+ for (int i = 0; i < ipdopts->allocated; ++i)`
	`705`	`+ NULL_THE_NAME(ipdopts->parameters[i].paramName);`
`704`	`706`	`free(ipdopts->parameters);`
`705`	`707`	`ipdopts->parameters = NULL;`
`706`	`708`	`ipdopts->allocated = 0;`
Original file line number	Diff line number	Diff line change
`@@ -553,21 +553,28 @@ CC_clear_col_info(ConnectionClass *self, BOOL destroy)`
`553`	`553`
`554`	`554`	`for (i = 0; i < self->ntables; i++)`
`555`	`555`	`{`
	`556`	`+ /* Going through COL_INFO cache table and releasing coli objects. */`
`556`	`557`	`if (coli = self->col_info[i], NULL != coli)`
`557`	`558`	`{`
`558`		`- if (destroy \|\| coli->refcnt == 0)`
	`559`	`+ coli->refcnt--;`
	`560`	`+ if (coli->refcnt <= 0)`
`559`	`561`	`{`
	`562`	`+ /* Last reference to coli object disappeared. Now destroying it. */`
`560`	`563`	`free_col_info_contents(coli);`
`561`	`564`	`free(coli);`
`562`	`565`	`self->col_info[i] = NULL;`
`563`	`566`	`}`
`564`	`567`	`else`
	`568`	`+ {`
	`569`	`+ /* coli object have another reference to it, so it will be destroyed somewhere else. */`
`565`	`570`	`coli->acc_time = 0;`
	`571`	`+ }`
`566`	`572`	`}`
`567`	`573`	`}`
`568`		`- self->ntables = 0;`
	`574`	`+ self->ntables = 0; /* Now we have cleared COL_INFO cached objects table. */`
`569`	`575`	`if (destroy)`
`570`	`576`	`{`
	`577`	`+ /* We destroying COL_INFO cache completely. */`
`571`	`578`	`free(self->col_info);`
`572`	`579`	`self->col_info = NULL;`
`573`	`580`	`self->coli_allocated = 0;`
`@@ -966,7 +973,7 @@ handle_pgres_error(ConnectionClass self, const PGresult pgres,`
`966`	`973`	`CC_on_abort(self, CONN_DEAD); /* give up the connection */`
`967`	`974`	`}`
`968`	`975`	`else if ((errseverity_nonloc && strcmp(errseverity_nonloc, "FATAL") == 0) \|\|`
`969`		`- (NULL == errseverity_nonloc && errseverity && strcmp(errseverity, "FATAL") == 0)) /* no */`
	`976`	`+ (NULL == errseverity_nonloc && errseverity && strcmp(errseverity, "FATAL") == 0)) /* no */`
`970`	`977`	`{`
`971`	`978`	`CC_set_errornumber(self, CONNECTION_SERVER_REPORTED_SEVERITY_FATAL);`
`972`	`979`	`CC_on_abort(self, CONN_DEAD); /* give up the connection */`
`@@ -2873,7 +2880,7 @@ LIBPQ_connect(ConnectionClass *self)`
`2873`	`2880`	`QLOG(0, "PQconnectdbParams:");`
`2874`	`2881`	`for (popt = opts, pval = vals; *popt; popt++, pval++)`
`2875`	`2882`	`QPRINTF(0, " %s='%s'", popt, pval);`
`2876`		`- QPRINTF(0, "\n");`
	`2883`	`+ QPRINTF(0, "\n");`
`2877`	`2884`	`}`
`2878`	`2885`	`pqconn = PQconnectdbParams(opts, vals, FALSE);`
`2879`	`2886`	`if (!pqconn)`
Original file line number	Diff line number	Diff line change
`@@ -3056,7 +3056,7 @@ MYLOG(DETAIL_LOG_LEVEL, "type=" FORMAT_UINTEGER " concur=" FORMAT_UINTEGER "\n",`
`3056`	`3056`	`}`
`3057`	`3057`	`if (SC_is_fetchcursor(stmt))`
`3058`	`3058`	`{`
`3059`		`- snprintfcat(new_statement, qb->str_alsize,`
	`3059`	`+ snprintfcat(new_statement, qb->str_alsize,`
`3060`	`3060`	`"declare \"%s\"%s cursor%s for ",`
`3061`	`3061`	`SC_cursor_name(stmt), opt_scroll, opt_hold);`
`3062`	`3062`	`qb->npos = strlen(new_statement);`
`@@ -3159,7 +3159,7 @@ MYLOG(DETAIL_LOG_LEVEL, "type=" FORMAT_UINTEGER " concur=" FORMAT_UINTEGER "\n",`
`3159`	`3159`	`CVT_APPEND_STR(qb, bestitem);`
`3160`	`3160`	`}`
`3161`	`3161`	`CVT_APPEND_STR(qb, "\" from ");`
`3162`		`- CVT_APPEND_DATA(qb, qp->statement + qp->from_pos + 5, npos - qp->from_pos - 5);`
	`3162`	`+ CVT_APPEND_DATA(qb, qp->statement + qp->from_pos + 5, qp->stmt_len - qp->from_pos - 5);`
`3163`	`3163`	`}`
`3164`	`3164`	`}`
`3165`	`3165`	`npos -= qp->declare_pos;`
`@@ -3744,7 +3744,7 @@ inner_process_tokens(QueryParse qp, QueryBuild qb)`
`3744`	`3744`	`}`
`3745`	`3745`	`if (converted)`
`3746`	`3746`	`{`
`3747`		`- const char column_def = (const char ) QR_get_value_backend_text(coli->result, i, COLUMNS_COLUMN_DEF);`
	`3747`	`+ const char column_def = (const char ) QR_get_value_backend_text(coli->result, i, COLUMNS_COLUMN_DEF);`
`3748`	`3748`	`if (NULL != column_def &&`
`3749`	`3749`	`strncmp(column_def, "nextval", 7) == 0)`
`3750`	`3750`	`{`
`@@ -3770,6 +3770,7 @@ inner_process_tokens(QueryParse qp, QueryBuild qb)`
`3770`	`3770`	`}`
`3771`	`3771`	`}`
`3772`	`3772`	`}`
	`3773`	`+ TI_ClearObject(pti);`
`3773`	`3774`	`}`
`3774`	`3775`	`if (!converted)`
`3775`	`3776`	`CVT_APPEND_STR(qb, "NULL");`
Original file line number	Diff line number	Diff line change
`@@ -624,6 +624,7 @@ copyConnAttributes(ConnInfo ci, const char attribute, const char *value)`
`624`	`624`	`STRCPY_FIXED(ci->username, value);`
`625`	`625`	`else if (stricmp(attribute, INI_PASSWORD) == 0 \|\| stricmp(attribute, "pwd") == 0)`
`626`	`626`	`{`
	`627`	`+ NULL_THE_NAME(ci->password);`
`627`	`628`	`ci->password = decode_or_remove_braces(value);`
`628`	`629`	`#ifndef FORCE_PASSWORDE_DISPLAY`
`629`	`630`	`MYLOG(0, "key='%s' value='xxxxxxxx'\n", attribute);`
`@@ -669,11 +670,13 @@ copyConnAttributes(ConnInfo ci, const char attribute, const char *value)`
`669`	`670`	`else if (stricmp(attribute, INI_CONNSETTINGS) == 0 \|\| stricmp(attribute, ABBR_CONNSETTINGS) == 0)`
`670`	`671`	`{`
`671`	`672`	`/* We can use the conn_settings directly when they are enclosed with braces */`
	`673`	`+ NULL_THE_NAME(ci->conn_settings);`
`672`	`674`	`ci->conn_settings_in_str = TRUE;`
`673`	`675`	`ci->conn_settings = decode_or_remove_braces(value);`
`674`	`676`	`}`
`675`	`677`	`else if (stricmp(attribute, INI_PQOPT) == 0 \|\| stricmp(attribute, ABBR_PQOPT) == 0)`
`676`	`678`	`{`
	`679`	`+ NULL_THE_NAME(ci->pqopt);`
`677`	`680`	`ci->pqopt_in_str = TRUE;`
`678`	`681`	`ci->pqopt = decode_or_remove_braces(value);`
`679`	`682`	`}`
Original file line number	Diff line number	Diff line change
`@@ -713,8 +713,7 @@ MYPRINTF(0, "->%d\n", updatable);`
`713`	`713`	`}`
`714`	`714`
`715`	`715`	`static BOOL`
`716`		`-getCOLIfromTable(ConnectionClass conn, pgNAME schema_name, pgNAME table_name,`
`717`		`-COL_INFO **coli)`
	`716`	`+getCOLIfromTable(ConnectionClass conn, pgNAME schema_name, pgNAME table_name, COL_INFO **coli)`
`718`	`717`	`{`
`719`	`718`	`int colidx;`
`720`	`719`	`BOOL found = FALSE;`
`@@ -836,11 +835,13 @@ getColumnsInfo(ConnectionClass conn, TABLE_INFO wti, OID greloid, StatementCla`
`836`	`835`	`MYLOG(0, " Success\n");`
`837`	`836`	`if (greloid != 0)`
`838`	`837`	`{`
	`838`	`+ /* We have reloid. Try to find appropriate coli object from connection COL_INFO cache. */`
`839`	`839`	`for (k = 0; k < conn->ntables; k++)`
`840`	`840`	`{`
`841`	`841`	`tcoli = conn->col_info[k];`
`842`	`842`	`if (tcoli->table_oid == greloid)`
`843`	`843`	`{`
	`844`	`+ /* We found appropriate coli object, so we will use it. */`
`844`	`845`	`coli = tcoli;`
`845`	`846`	`coli_exist = TRUE;`
`846`	`847`	`break;`
`@@ -849,42 +850,46 @@ getColumnsInfo(ConnectionClass conn, TABLE_INFO wti, OID greloid, StatementCla`
`849`	`850`	`}`
`850`	`851`	`if (!coli_exist)`
`851`	`852`	`{`
	`853`	`+ /* Not found, try to find unused coli or oldest (if overflow) in connection COL_INFO cache. */`
`852`	`854`	`for (k = 0; k < conn->ntables; k++)`
`853`	`855`	`{`
`854`	`856`	`tcoli = conn->col_info[k];`
`855`		`- if (0 < tcoli->refcnt)`
`856`		`- continue;`
	`857`	`+ if (1 < tcoli->refcnt)`
	`858`	`+ continue; /* This coli object is used somewhere else, skipping it. */`
`857`	`859`	`if ((0 == tcoli->table_oid &&`
`858`	`860`	`NAME_IS_NULL(tcoli->table_name)) \|\|`
`859`	`861`	`strnicmp(SAFE_NAME(tcoli->schema_name), "pg_temp_", 8) == 0)`
`860`	`862`	`{`
	`863`	`+ /* Found unused coli object, taking it. */`
`861`	`864`	`coli = tcoli;`
`862`	`865`	`coli_exist = TRUE;`
`863`	`866`	`break;`
`864`	`867`	`}`
`865`		`- if (NULL == ccoli \|\|`
`866`		`- tcoli->acc_time < acctime)`
	`868`	`+ if (NULL == ccoli \|\| tcoli->acc_time < acctime)`
`867`	`869`	`{`
	`870`	`+ /* Not yet found. Alongside, searching least recently used coli object. */`
`868`	`871`	`ccoli = tcoli;`
`869`	`872`	`acctime = tcoli->acc_time;`
`870`	`873`	`}`
`871`	`874`	`}`
`872`		`- if (!coli_exist &&`
`873`		`- NULL != ccoli &&`
`874`		`- conn->ntables >= COLI_RECYCLE)`
	`875`	`+ if (!coli_exist && NULL != ccoli && conn->ntables >= COLI_RECYCLE)`
`875`	`876`	`{`
	`877`	`+ /* Not found unsed object. Amount of them is on limit. Taking least recently used coli object. */`
`876`	`878`	`coli_exist = TRUE;`
`877`	`879`	`coli = ccoli;`
`878`	`880`	`}`
`879`	`881`	`}`
`880`	`882`	`if (coli_exist)`
`881`	`883`	`{`
	`884`	`+ /* We have ready to use coli object. Cleaning it. */`
`882`	`885`	`free_col_info_contents(coli);`
`883`	`886`	`}`
`884`	`887`	`else`
`885`	`888`	`{`
	`889`	`+ /* We have no coli object. Must create a new one. */`
`886`	`890`	`if (conn->ntables >= conn->coli_allocated)`
`887`	`891`	`{`
	`892`	`+ /* No place in connection COL_INFO cache table. Allocating or reallocating. */`
`888`	`893`	`Int2 new_alloc;`
`889`	`894`	`COL_INFO **col_info;`
`890`	`895`
`@@ -904,6 +909,7 @@ getColumnsInfo(ConnectionClass conn, TABLE_INFO wti, OID greloid, StatementCla`
`904`	`909`	`conn->coli_allocated = new_alloc;`
`905`	`910`	`}`
`906`	`911`
	`912`	`+ /* Allocating new COL_INFO object. */`
`907`	`913`	`MYLOG(0, "PARSE: malloc at conn->col_info[%d]\n", conn->ntables);`
`908`	`914`	`coli = conn->col_info[conn->ntables] = (COL_INFO *) malloc(sizeof(COL_INFO));`
`909`	`915`	`}`
`@@ -915,6 +921,7 @@ getColumnsInfo(ConnectionClass conn, TABLE_INFO wti, OID greloid, StatementCla`
`915`	`921`	`}`
`916`	`922`	`col_info_initialize(coli);`
`917`	`923`
	`924`	`+ coli->refcnt++; /* Counting one reference to coli object from connection COL_INFO cache table. */`
`918`	`925`	`coli->result = res;`
`919`	`926`	`if (res && QR_get_num_cached_tuples(res) > 0)`
`920`	`927`	`{`
`@@ -969,7 +976,7 @@ MYLOG(DETAIL_LOG_LEVEL, "oid item == %s\n", (const char *) QR_get_value_backend_`
`969`	`976`	`MYLOG(0, "Created col_info table='%s', ntables=%d\n", PRINT_NAME(wti->table_name), conn->ntables);`
`970`	`977`	`/* Associate a table from the statement with a SQLColumn info */`
`971`	`978`	`found = TRUE;`
`972`		`- coli->refcnt++;`
	`979`	`+ coli->refcnt++; /* Counting another one reference to coli object from TABLE_INFO wti object. */`
`973`	`980`	`wti->col_info = coli;`
`974`	`981`	`}`
`975`	`982`	`cleanup:`
Original file line number	Diff line number	Diff line change
`@@ -5007,6 +5007,7 @@ PGAPI_SetCursorName(HSTMT hstmt,`
`5007`	`5007`	`return SQL_INVALID_HANDLE;`
`5008`	`5008`	`}`
`5009`	`5009`
	`5010`	`+ NULL_THE_NAME(stmt->cursor_name);`
`5010`	`5011`	`SET_NAME_DIRECTLY(stmt->cursor_name, make_string(szCursor, cbCursor, NULL, 0));`
`5011`	`5012`	`return SQL_SUCCESS;`
`5012`	`5013`	`}`