Context Navigation

source: trunk/tools/database/db.cpp

Visit:

Last change on this file was 8006, checked in by bird, 24 years ago
New kFile* classes; now in sync with os2tools.
File size: 78.3 KB

Rev	Line
[8006]	1	/* $Id: db.cpp,v 1.29 2002-02-24 02:58:29 bird Exp $ *
[2761]	2	*
[830]	3	* DB - contains all database routines.
	4	*
[3920]	5	* Copyright (c) 1999-2000 knut st. osmundsen
[830]	6	*
	7	*/
	8
	9	/*******************************************************************************
	10	* Defined Constants *
	11	*******************************************************************************/
	12	#define CheckLogContinue(sprintfargs) \
	13	if (rc < 0) \
	14	{ \
	15	if (pszError[1] == '\xFE') \
	16	{ \
	17	strcat(pszError, "\n\t"); \
	18	pszError += 2; \
	19	} \
	20	sprintf sprintfargs; \
	21	ulRc++; \
	22	pszError += strlen(pszError); \
	23	pszError[1] = '\xFE'; \
[1993]	24	} \
	25	rc=rc
[830]	26
	27
	28	#define CheckFKError(table, msg) \
	29	pres2 = mysql_store_result(pmysql);\
	30	if (rc < 0 \|\| pres2 == NULL \|\| \
[2759]	31	mysql_num_rows(pres2) == 0) \
[830]	32	{ \
	33	if (pszError[1] == '\xFE') \
	34	{ \
	35	strcat(pszError, "\n\t"); \
	36	pszError += 2; \
	37	} \
	38	sprintf(pszError, table ":" \
	39	msg \
	40	" (refcode=%s) " \
	41	"(sql=%s)", \
	42	row1[0], \
	43	pszQuery); \
	44	ulRc++; \
	45	pszError += strlen(pszError); \
	46	pszError[1] = '\xFE'; \
	47	} \
	48	if (pres2 != NULL) \
[1993]	49	mysql_free_result(pres2)
[830]	50
	51
	52	/*******************************************************************************
	53	* Header Files *
	54	*******************************************************************************/
	55	#define INCL_DOSMISC
	56	#include <os2.h>
	57	#include <stdio.h>
	58	#include <stdlib.h>
	59	#include <string.h>
	60	#include <memory.h>
	61	#include <signal.h>
	62	#include <assert.h>
	63	#include <limits.h>
	64	#include <mysql.h>
	65
[8006]	66	#include "kTypes.h"
[830]	67	#include "db.h"
	68
	69
	70	/@Global**********************************************************************
	71	* Global Variables *
	72	*******************************************************************************/
	73	static MYSQL mysql;
	74	static MYSQL *pmysql = NULL;
	75
	76
	77	/@IntFunc*********************************************************************
	78	* Internal Functions *
	79	*******************************************************************************/
	80	static long getvalue(int iField, MYSQL_ROW pRow);
	81	static unsigned long CheckAuthorError(char * &pszError, const char pszFieldName, const char pszFieldValue, const char *pszQuery);
	82	static unsigned long logDbError(char * &pszError, const char *pszQuery);
[2818]	83	static char sqlstrcat(char pszQuery, const char pszBefore, const char pszStr, const char *pszAfter = NULL);
	84
[2761]	85	#ifndef DLL
[830]	86	extern "C" void dbHandler(int sig);
	87	#endif
	88
	89
	90	/**
	91	* Gets the descriptions of the last database error.
	92	* @returns Readonly string.
	93	*/
	94	char * _System dbGetLastErrorDesc(void)
	95	{
	96	return mysql_error(&mysql);
	97	}
	98
	99
	100	/**
	101	* Connects to local database.
	102	* @returns Success indicator, TRUE / FALSE.
	103	* @param pszDatabase Name of database to use.
	104	*/
	105	BOOL _System dbConnect(const char pszHost, const char pszUser, const char pszPassword, const char pszDatabase)
	106	{
	107	BOOL fRet = FALSE;
[2761]	108	#ifndef DLL
[830]	109	static fHandler = FALSE;
	110	/* signal handler */
	111	if (!fHandler)
	112	{
	113	if ( SIG_ERR == signal(SIGBREAK, dbHandler)
	114	\|\| SIG_ERR == signal(SIGINT, dbHandler)
	115	\|\| SIG_ERR == signal(SIGTERM, dbHandler)
	116	\|\| SIG_ERR == signal(SIGABRT, dbHandler)
	117	\|\| SIG_ERR == signal(SIGSEGV, dbHandler)
	118	\|\| SIG_ERR == signal(SIGILL, dbHandler)
	119	)
	120	fprintf(stderr, "Error installing signalhandler...");
	121	else
	122	fHandler = TRUE;
	123	}
	124	#endif
	125
	126	/* connect to server */
	127	memset(&mysql, 0, sizeof(mysql));
[7911]	128	mysql_init(&mysql);
[830]	129	pmysql = mysql_connect(&mysql, pszHost, pszUser, pszPassword);
	130	if (pmysql != NULL)
	131	{
	132	/* connect to database */
	133	fRet = mysql_select_db(pmysql, pszDatabase) >= 0;
	134	if (fRet)
	135	mysql_refresh(pmysql, REFRESH_TABLES);
	136	}
	137
	138	return fRet;
	139	}
	140
	141
	142	/**
	143	* Disconnects from database.
	144	* @returns Success indicator. TRUE / FALSE.
	145	*/
	146	BOOL _System dbDisconnect(void)
	147	{
	148	if (pmysql != NULL)
	149	{
	150	mysql_refresh(pmysql, REFRESH_TABLES);
	151	mysql_close(pmysql);
	152	pmysql = NULL;
	153	}
	154	return TRUE;
	155	}
	156
[2759]	157	/**
[6678]	158	* Gets the refid for the give dll name.
	159	* @returns Dll refid. -1 on error.
	160	* @param pszDllName Dll name.
[2759]	161	*/
[6678]	162	signed long _System dbGetDll(const char *pszDllName)
[2759]	163	{
	164	int rc;
	165	char szQuery[256];
	166	MYSQL_RES * pres;
[830]	167
[6678]	168	sprintf(&szQuery[0], "SELECT refcode FROM dll WHERE name = '%s'\n", pszDllName);
[2759]	169	rc = mysql_query(pmysql, &szQuery[0]);
	170	pres = mysql_store_result(pmysql);
	171
	172	if (rc >= 0 && pres != NULL && mysql_num_rows(pres) == 1)
	173	rc = (int)getvalue(0, mysql_fetch_row(pres));
	174	else
	175	rc = -1;
	176	mysql_free_result(pres);
[3882]	177	return (signed long)rc;
[2759]	178	}
	179
	180
[830]	181	/**
[6678]	182	* Count the function in a given dll.
	183	* @returns Number of functions. -1 on error.
	184	* @param lDll Dll refcode.
	185	* @param fNotAliases TRUE: don't count aliased functions.
[2759]	186	*/
[6678]	187	signed long _System dbCountFunctionInDll(signed long lDll, BOOL fNotAliases)
[2759]	188	{
	189	signed long rc;
	190	char szQuery[256];
	191	MYSQL_RES * pres;
	192
[6678]	193	if (lDll >= 0)
[2759]	194	{
[6678]	195	sprintf(&szQuery[0], "SELECT count(refcode) FROM function WHERE dll = %ld\n", lDll);
[2770]	196	if (fNotAliases)
	197	strcat(&szQuery[0], " AND aliasfn < 0");
[2759]	198	rc = mysql_query(pmysql, &szQuery[0]);
	199	pres = mysql_store_result(pmysql);
	200
	201	if (rc >= 0 && pres != NULL && mysql_num_rows(pres) == 1)
	202	rc = (int)getvalue(0, mysql_fetch_row(pres));
	203	else
	204	rc = -1;
	205	mysql_free_result(pres);
	206	}
	207	else
	208	rc = -1;
	209	return rc;
	210	}
	211
	212
	213
	214	/**
[6678]	215	* Checks if dll exists. If not exists the dll is inserted.
	216	* @returns Dll refcode. -1 on errors.
	217	* @param pszDll Dll name.
	218	* @remark This search must be case insensitive.
	219	* (In the mysql-world everything is case insensitive!)
[830]	220	*/
[6678]	221	signed long _System dbCheckInsertDll(const char *pszDll, char fchType)
[830]	222	{
[2759]	223	int rc;
	224	char szQuery[256];
	225	MYSQL_RES * pres;
[830]	226
	227	/* try find match */
[6678]	228	sprintf(&szQuery[0], "SELECT refcode, name FROM dll WHERE name = '%s'\n", pszDll);
[830]	229	rc = mysql_query(pmysql, &szQuery[0]);
	230	pres = mysql_store_result(pmysql);
	231
[6678]	232	/* not found? - insert dll */
[830]	233	if (rc < 0 \|\| pres == NULL \|\| mysql_num_rows(pres) == 0)
	234	{
	235	mysql_free_result(pres);
	236
[6678]	237	sprintf(&szQuery[0], "INSERT INTO dll(name, type) VALUES('%s', '%c')\n", pszDll, fchType);
[830]	238	rc = mysql_query(pmysql, &szQuery[0]);
[3882]	239	if (rc < 0)
	240	return -1;
[830]	241
	242	/* select row to get refcode */
[6678]	243	sprintf(&szQuery[0], "SELECT refcode, name FROM dll WHERE name = '%s'\n", pszDll);
[830]	244	rc = mysql_query(pmysql, &szQuery[0]);
	245	pres = mysql_store_result(pmysql);
	246	}
	247
	248	if (rc >= 0 && pres != NULL && mysql_num_rows(pres) == 1)
[1993]	249	rc = (int)getvalue(0, mysql_fetch_row(pres));
[830]	250	else
	251	rc = -1;
	252	mysql_free_result(pres);
	253
[3882]	254	return (long)rc;
[830]	255	}
	256
	257
	258	/**
	259	* Simple select for a long value.
	260	* @returns long value
	261	* @param pszTable From part.
	262	* @param pszGetColumn Name of column to retreive.
	263	* @param pszMatch1 Match column/expression
	264	* @param pszMatchValue1 Match value.
	265	* @remark Dirty! Don't use this!
	266	*/
	267	unsigned short _System dbGet(const char pszTable, const char pszGetColumn,
	268	const char pszMatch1, const char pszMatchValue1)
	269	{
[1993]	270	int rc;
[830]	271	char szQuery[256];
	272	MYSQL_RES *pres;
	273
	274	/* try find match */
	275	sprintf(&szQuery[0], "SELECT %s FROM %s WHERE %s = '%s'\n",
	276	pszGetColumn, pszTable, pszMatch1, pszMatchValue1);
	277	rc = mysql_query(pmysql, &szQuery[0]);
	278	pres = mysql_store_result(pmysql);
	279
	280	if (rc >= 0 && pres != NULL && mysql_num_rows(pres) == 1)
[1993]	281	rc = (int)getvalue(0, mysql_fetch_row(pres));
[830]	282	else
	283	rc = -1;
	284	mysql_free_result(pres);
	285
[3882]	286	return (unsigned short)rc;
[830]	287	}
	288
	289
	290	/**
	291	* Updates or inserts a function name into the database.
[3882]	292	* The update flags is always updated.
	293	* @returns Success indicator. TRUE / FALSE.
[6678]	294	* @param lDll Dll refcode.
[3882]	295	* @param pszFunction Function name.
	296	* @param pszIntFunction Internal function name. (required!)
	297	* @param ulOrdinal Ordinal value.
	298	* @param fIgnoreOrdinal Do not update ordinal value.
	299	* @param fchType Function type flag. One of the FUNCTION_* defines.
[830]	300	*/
[6678]	301	BOOL _System dbInsertUpdateFunction(signed long lDll,
[2759]	302	const char pszFunction, const char pszIntFunction,
[3882]	303	unsigned long ulOrdinal, BOOL fIgnoreOrdinal, char fchType)
[830]	304	{
[3882]	305	int rc;
	306	long lFunction = -1;
	307	char szQuery[512];
	308	char * pszQuery = &szQuery[0];
[830]	309	MYSQL_RES *pres;
	310
[2770]	311	/* when no internal name fail! */
[2759]	312	if (pszIntFunction == NULL \|\| *pszIntFunction == '\0')
[2770]	313	return FALSE;
[2759]	314
[830]	315	/* try find function */
[6678]	316	sprintf(pszQuery, "SELECT refcode, intname FROM function WHERE dll = %d AND name = '%s'", lDll, pszFunction);
[3882]	317	rc = mysql_query(pmysql, pszQuery);
[830]	318	pres = mysql_store_result(pmysql);
[2759]	319	if (rc >= 0 && pres != NULL && mysql_num_rows(pres) != 0)
[3882]	320	{ /*
	321	* Found the function. So now we'll update it.
	322	*/
[2004]	323	MYSQL_ROW parow;
[830]	324	if (mysql_num_rows(pres) > 1)
	325	{
[6678]	326	fprintf(stderr, "internal database integrity error(%s): More function by the same name for the same dll. "
	327	"lDll = %d, pszFunction = %s\n", __FUNCTION__, lDll, pszFunction);
[830]	328	return FALSE;
	329	}
	330
[2004]	331	parow = mysql_fetch_row(pres);
[3882]	332	lFunction = getvalue(0, parow);
[830]	333	mysql_free_result(pres);
	334
[3882]	335	strcpy(pszQuery, "UPDATE function SET updated = updated + 1");
	336	pszQuery += strlen(pszQuery);
[2759]	337	if (strcmp(parow[1], pszIntFunction) != 0)
[3882]	338	pszQuery += sprintf(pszQuery, ", intname = '%s'", pszIntFunction);
[2759]	339
[3882]	340	if (!fIgnoreOrdinal)
	341	pszQuery += sprintf(pszQuery, ", ordinal = %ld", ulOrdinal);
[2759]	342
[3882]	343	sprintf(pszQuery, ", type = '%c' WHERE refcode = %ld", fchType, lFunction);
	344	rc = mysql_query(pmysql, &szQuery[0]);
[830]	345	}
	346	else
[3882]	347	{ /*
	348	* The function was not found. (or maybe an error occured?)
	349	* Insert it.
	350	*/
[6678]	351	sprintf(&szQuery[0], "INSERT INTO function(dll, name, intname, ordinal, updated, type) VALUES(%d, '%s', '%s', %ld, 1, '%c')",
	352	lDll, pszFunction, pszIntFunction, ulOrdinal, fchType);
[830]	353	rc = mysql_query(pmysql, &szQuery[0]);
	354	}
	355
	356	return rc >= 0;
	357	}
	358
	359
[3838]	360
[830]	361	/**
[3838]	362	* Inserts or updates (existing) file information.
	363	* @returns Success indicator (TRUE / FALSE).
[6678]	364	* @param lDll Dll reference code.
[3838]	365	* @param pszFilename Filename.
	366	* @param pszDescription Pointer to file description.
	367	* @param pszLastDateTime Date and time for last change (ISO).
	368	* @param lLastAuthor Author number. (-1 if not found.)
	369	* @param pszRevision Pointer to revision string.
	370	* @sketch
	371	* @remark
	372	*/
[6678]	373	BOOL _System dbInsertUpdateFile(signed long lDll,
[3838]	374	const char *pszFilename,
	375	const char *pszDescription,
	376	const char *pszLastDateTime,
	377	signed long lLastAuthor,
	378	const char *pszRevision)
	379	{
	380	int rc;
	381	long lFile = -1;
	382	char szQuery[0x10000];
	383	MYSQL_RES *pres;
	384
	385	/* parameter assertions */
[6678]	386	assert(lDll != 0);
[3838]	387	assert(pszFilename != NULL);
	388	assert(*pszFilename != '\0');
	389
	390	/* try find file */
[6678]	391	sprintf(&szQuery[0], "SELECT refcode, name FROM file WHERE dll = %d AND name = '%s'", lDll, pszFilename);
[3838]	392	rc = mysql_query(pmysql, &szQuery[0]);
	393	pres = mysql_store_result(pmysql);
	394	if (rc >= 0 && pres != NULL && mysql_num_rows(pres) != 0)
	395	{ /* update file (file is found) */
	396	MYSQL_ROW parow;
	397	if (mysql_num_rows(pres) > 1)
	398	{
[6678]	399	fprintf(stderr, "internal database integrity error(%s): More files by the same name in the same dll. "
	400	"lDll = %d, pszFilename = %s\n", __FUNCTION__, lDll, pszFilename);
[3838]	401	return FALSE;
	402	}
	403
	404	parow = mysql_fetch_row(pres);
[3848]	405	assert(parow);
	406	lFile = getvalue(0, parow);
[3838]	407	mysql_free_result(pres);
	408
	409	if (strcmp(parow[1], pszFilename) != 0) /* case might have changed... */
	410	{
	411	sprintf(&szQuery[0], "UPDATE file SET name = '%s' WHERE refcode = %ld",
	412	pszFilename, lFile);
	413	rc = mysql_query(pmysql, &szQuery[0]);
	414	}
	415
	416	if (rc >= 0)
	417	{
	418	if (pszDescription != NULL && pszDescription != '\0')
	419	{
	420	szQuery[0] = '\0';
	421	sqlstrcat(&szQuery[0], "UPDATE file SET description = ", pszDescription, NULL);
	422	sprintf(&szQuery[strlen(szQuery)], " WHERE refcode = %ld", lFile);
	423	}
	424	else
	425	sprintf(&szQuery[0], "UPDATE file SET description = NULL WHERE refcode = %ld",
	426	lFile);
	427	rc = mysql_query(pmysql, &szQuery[0]);
	428	}
	429
	430	if (rc >= 0 && pszLastDateTime != NULL && *pszLastDateTime != '\0')
	431	{
	432	sprintf(&szQuery[0], "UPDATE file SET lastdatetime = '%s' WHERE refcode = %ld",
	433	pszLastDateTime, lFile);
	434	rc = mysql_query(pmysql, &szQuery[0]);
	435	}
	436
	437	if (rc >= 0)
	438	{
	439	sprintf(&szQuery[0], "UPDATE file SET lastauthor = %ld WHERE refcode = %ld",
	440	lLastAuthor, lFile);
	441	rc = mysql_query(pmysql, &szQuery[0]);
	442	}
	443
	444	if (rc >= 0 && pszRevision != NULL && *pszRevision != '\0')
	445	{
	446	sprintf(&szQuery[0], "UPDATE file SET revision = '%s' WHERE refcode = %ld",
	447	pszRevision, lFile);
	448	rc = mysql_query(pmysql, &szQuery[0]);
	449	}
	450
	451	}
	452	else
	453	{ /* insert */
[6678]	454	sprintf(&szQuery[0], "INSERT INTO file(dll, name, lastauthor, description, lastdatetime, revision) VALUES(%d, '%s', %ld, ",
	455	lDll, pszFilename, lLastAuthor);
[3838]	456	if (pszDescription != NULL && *pszDescription != '\0')
	457	sqlstrcat(&szQuery[0], NULL, pszDescription);
	458	else
	459	strcat(&szQuery[0], "NULL");
	460
	461	if (pszLastDateTime != NULL && *pszLastDateTime != '\0')
	462	sqlstrcat(&szQuery[0], ", ", pszLastDateTime);
	463	else
	464	strcat(&szQuery[0], ", '1975-03-13 14:00:00'"); /* dummy */
	465
	466	if (pszRevision != NULL && *pszRevision != '\0')
	467	sqlstrcat(&szQuery[0], ", ", pszRevision, ")");
	468	else
	469	strcat(&szQuery[0], ", '')");
	470
	471	rc = mysql_query(pmysql, &szQuery[0]);
	472	}
	473
	474	return rc >= 0;
	475	}
	476
	477
	478	/**
[830]	479	* Get a long value.
	480	* @returns Number value of pRow[iField]. -1 on error.
	481	* @param iField Index into pRow.
	482	* @param pRow Pointer to array (of string pointers).
	483	*/
	484	static long getvalue(int iField, MYSQL_ROW papszRow)
	485	{
	486	if (papszRow[iField] != NULL)
	487	return atol((char*)papszRow[iField]);
	488
	489	return -1;
	490	}
	491
[2770]	492
[2773]	493	#if 0
[2770]	494	/*
	495	* Stubs used while optimizing sqls.
	496	*/
	497	int mysql_query1(MYSQL mysql, const char q)
	498	{ return mysql_query(mysql, q); }
	499	int mysql_query2(MYSQL mysql, const char q)
	500	{ return mysql_query(mysql, q); }
	501	int mysql_query3(MYSQL mysql, const char q)
	502	{ return mysql_query(mysql, q); }
	503	int mysql_query4(MYSQL mysql, const char q)
	504	{ return mysql_query(mysql, q); }
	505	int mysql_query5(MYSQL mysql, const char q)
	506	{ return mysql_query(mysql, q); }
[2773]	507	int mysql_query6(MYSQL mysql, const char q)
	508	{ return mysql_query(mysql, q); }
[2770]	509
	510	#else
	511
	512	#define mysql_query1 mysql_query
	513	#define mysql_query2 mysql_query
	514	#define mysql_query3 mysql_query
	515	#define mysql_query4 mysql_query
	516	#define mysql_query5 mysql_query
[2773]	517	#define mysql_query6 mysql_query
[2770]	518
	519	#endif
	520
	521
	522
[830]	523	/**
[2759]	524	* Find occurences of a function, given by internal name.
[830]	525	* @returns success indicator, TRUE / FALSE.
[3838]	526	* @param pszFunctionName Pointer to a function name string. (input)
	527	* @param pFnFindBuf Pointer to a find buffer. (output)
[6678]	528	* @param lDll Dll refcode (optional). If given the search is limited to
	529	* the given dll and aliasing functions is updated (slow!).
	530	* @sketch 1) Get functions for this dll(if given).
[2773]	531	* 2) Get functions which aliases the functions found in (1).
	532	* 3) Get new aliases by intname
	533	* 4) Get new aliases by name
	534	* 5) Update all functions from (1) to have aliasfn -2 (DONTMIND)
	535	* 6) Update all functions from (3) and (4) to alias the first function from 1.
[830]	536	*/
[6678]	537	BOOL _System dbFindFunction(const char *pszFunctionName, PFNFINDBUF pFnFindBuf, signed long lDll)
[830]	538	{
	539	MYSQL_RES *pres;
	540	MYSQL_ROW row;
	541	int rc;
[2776]	542	char szQuery[1024];
[830]	543
[2773]	544	/*
[6678]	545	* 1) Get functions for this dll(if given).
[2773]	546	*/
[6678]	547	if (lDll < 0)
	548	sprintf(&szQuery[0], "SELECT refcode, dll, aliasfn, file, name FROM function WHERE intname = '%s'",
[2761]	549	pszFunctionName);
	550	else
[6678]	551	sprintf(&szQuery[0], "SELECT refcode, dll, aliasfn, file, name FROM function "
	552	"WHERE intname = '%s' AND dll = %ld",
	553	pszFunctionName, lDll);
[830]	554
[2770]	555	rc = mysql_query1(pmysql, &szQuery[0]);
[830]	556	if (rc >= 0)
	557	{
[2773]	558	pres = mysql_store_result(pmysql);
[830]	559	if (pres != NULL)
	560	{
[2773]	561	char szFnName[NBR_FUNCTIONS][80];
	562
[830]	563	pFnFindBuf->cFns = 0;
	564	while ((row = mysql_fetch_row(pres)) != NULL)
	565	{
	566	pFnFindBuf->alRefCode[pFnFindBuf->cFns] = atol(row[0]);
[6678]	567	pFnFindBuf->alDllRefCode[pFnFindBuf->cFns] = atol(row[1]);
[2761]	568	pFnFindBuf->alAliasFn[pFnFindBuf->cFns] = atol(row[2]);
[3838]	569	pFnFindBuf->alFileRefCode[pFnFindBuf->cFns] = atol(row[3]);
	570	strcpy(szFnName[pFnFindBuf->cFns], row[4]);
[830]	571
	572	/* next */
	573	pFnFindBuf->cFns++;
	574	}
	575	mysql_free_result(pres);
[2761]	576
[6678]	577	/* alias check and fix */
	578	if (lDll >= 0 && pFnFindBuf->cFns != 0)
[2761]	579	{
[6678]	580	int cFnsThisDll, cFnsAliasesAndThisDll, i, f;
[2761]	581
[2773]	582	/*
	583	* 2) Get functions which aliases the functions found in (1).
	584	*/
[6678]	585	cFnsThisDll = (int)pFnFindBuf->cFns;
	586	strcpy(&szQuery[0], "SELECT refcode, dll, aliasfn, file, name FROM function WHERE aliasfn IN (");
	587	for (i = 0; i < cFnsThisDll; i++)
[2761]	588	{
[2773]	589	if (i > 0) strcat(&szQuery[0], " OR ");
	590	sprintf(&szQuery[strlen(szQuery)], "(%ld)", pFnFindBuf->alRefCode[i]);
[2761]	591	}
[2773]	592	strcat(&szQuery[0], ")");
[2761]	593
	594	rc = mysql_query2(pmysql, &szQuery[0]);
	595	if (rc >= 0)
	596	{
[2770]	597	pres = mysql_store_result(pmysql);
	598	if (pres != NULL)
[2761]	599	{
[2770]	600	while ((row = mysql_fetch_row(pres)) != NULL)
	601	{
	602	pFnFindBuf->alRefCode[pFnFindBuf->cFns] = atol(row[0]);
[6678]	603	pFnFindBuf->alDllRefCode[pFnFindBuf->cFns] = atol(row[1]);
[2773]	604	pFnFindBuf->alAliasFn[pFnFindBuf->cFns] = atol(row[2]);
[3838]	605	pFnFindBuf->alFileRefCode[pFnFindBuf->cFns] = atol(row[3]);
	606	strcpy(szFnName[pFnFindBuf->cFns], row[4]);
[2770]	607
	608	/* next */
	609	pFnFindBuf->cFns++;
	610	}
	611	mysql_free_result(pres);
	612
[2773]	613	/*
	614	* 3) Get new aliases by intname
	615	*/
[6678]	616	cFnsAliasesAndThisDll = (int)pFnFindBuf->cFns;
	617	sprintf(&szQuery[0], "SELECT refcode, dll, aliasfn, file FROM function "
	618	"WHERE aliasfn = (-1) AND dll <> %ld AND (intname = '%s'",
	619	lDll, pszFunctionName);
	620	for (i = 0; i < cFnsAliasesAndThisDll; i++)
[2773]	621	sprintf(&szQuery[strlen(&szQuery[0])], " OR intname = '%s'", szFnName[i]);
	622	strcat(&szQuery[0], ")");
	623
[2770]	624	rc = mysql_query3(pmysql, &szQuery[0]);
[2761]	625	if (rc >= 0)
	626	{
[2770]	627	pres = mysql_store_result(pmysql);
	628	if (pres != NULL)
[2761]	629	{
[2770]	630	while ((row = mysql_fetch_row(pres)) != NULL)
	631	{
	632	pFnFindBuf->alRefCode[pFnFindBuf->cFns] = atol(row[0]);
[6678]	633	pFnFindBuf->alDllRefCode[pFnFindBuf->cFns] = atol(row[1]);
[2770]	634	if (row[2] != NULL)
	635	pFnFindBuf->alAliasFn[pFnFindBuf->cFns] = atol(row[2]);
	636	else
	637	pFnFindBuf->alAliasFn[pFnFindBuf->cFns] = ALIAS_NULL;
[3838]	638	pFnFindBuf->alFileRefCode[pFnFindBuf->cFns] = atol(row[3]);
[2770]	639
	640	/* next */
	641	pFnFindBuf->cFns++;
	642	}
	643	mysql_free_result(pres);
	644
[2773]	645
	646	/*
	647	* 4) Get new aliases by name
	648	*/
[6678]	649	sprintf(&szQuery[0], "SELECT refcode, dll, aliasfn, file FROM function "
	650	"WHERE aliasfn = (-1) AND dll <> %ld AND (name = '%s'",
	651	lDll, pszFunctionName);
	652	for (i = 0; i < cFnsAliasesAndThisDll; i++)
[2773]	653	sprintf(&szQuery[strlen(&szQuery[0])], " OR name = '%s'", szFnName[i]);
	654	strcat(&szQuery[0], ")");
[2770]	655
	656	rc = mysql_query4(pmysql, &szQuery[0]);
[2761]	657	if (rc >= 0)
	658	{
[2773]	659	pres = mysql_store_result(pmysql);
	660	if (pres != NULL)
[2761]	661	{
[2773]	662	while ((row = mysql_fetch_row(pres)) != NULL)
	663	{
	664	pFnFindBuf->alRefCode[pFnFindBuf->cFns] = atol(row[0]);
[6678]	665	pFnFindBuf->alDllRefCode[pFnFindBuf->cFns] = atol(row[1]);
[2773]	666	if (row[2] != NULL)
	667	pFnFindBuf->alAliasFn[pFnFindBuf->cFns] = atol(row[2]);
	668	else
	669	pFnFindBuf->alAliasFn[pFnFindBuf->cFns] = ALIAS_NULL;
[3838]	670	pFnFindBuf->alFileRefCode[pFnFindBuf->cFns] = atol(row[3]);
[2761]	671
[2773]	672	/* next */
	673	pFnFindBuf->cFns++;
	674	}
	675	mysql_free_result(pres);
	676
	677	/*
	678	* 5) Update all functions from (1) to have aliasfn -2 (DONTMIND)
	679	*/
	680	sprintf(&szQuery[0], "UPDATE function SET aliasfn = (-2) "
[2776]	681	"WHERE refcode IN (",
[6678]	682	lDll, pszFunctionName);
	683	for (f = 0, i = 0; i < cFnsThisDll; i++)
[2776]	684	if (pFnFindBuf->alAliasFn[i] != ALIAS_DONTMIND)
	685	sprintf(&szQuery[strlen(&szQuery[0])],
	686	f++ != 0 ? ", %ld" : "%ld", pFnFindBuf->alRefCode[i]);
[2773]	687	strcat(&szQuery[0], ") AND aliasfn <> (-2)");
[2776]	688	if (f > 0)
	689	rc = mysql_query5(pmysql, &szQuery[0]);
	690	else
	691	rc = 0;
[6678]	692	if (rc >= 0 && cFnsAliasesAndThisDll < pFnFindBuf->cFns)
[2773]	693	{
	694	/*
	695	* 6) Update all functions from (3) and (4) to alias the first function from 1.
	696	*/
[3838]	697	sprintf(&szQuery[0], "UPDATE function SET aliasfn = (%ld), file = (%ld) "
[2773]	698	"WHERE aliasfn = (-1) AND refcode IN (",
[3838]	699	pFnFindBuf->alRefCode[0], pFnFindBuf->alFileRefCode[0]);
[6678]	700	for (i = cFnsAliasesAndThisDll; i < pFnFindBuf->cFns; i++)
[2776]	701	{
[2773]	702	sprintf(&szQuery[strlen(&szQuery[0])],
[6678]	703	i > cFnsAliasesAndThisDll ? ", %ld" : "%ld", pFnFindBuf->alRefCode[i]);
[2776]	704	}
[2773]	705	strcat(&szQuery[0], ")");
	706	rc = mysql_query6(pmysql, &szQuery[0]);
	707	} /* query 5 */
[2761]	708	}
[2773]	709	} /* query 4 */
[2761]	710	}
[2773]	711	} /* query 3 */
[2761]	712	}
[2773]	713	} /* query 2 */
[2761]	714	}
[2773]	715	} /* query 1 */
[2761]	716	else
	717	rc = -1;
	718	}
	719
	720	return rc >= 0;
	721	}
	722
	723
	724	/**
[3838]	725	* Finds the refcode for a file (if it exists).
[6678]	726	* @returns File 'refcode'.
	727	* -1 on error or not found.
	728	* @param lDll Refcode of the dll which this file belongs to.
	729	* @param pszFilename The filename to search for.
[3838]	730	*/
[6678]	731	signed long _System dbFindFile(signed long lDll, const char *pszFilename)
[3838]	732	{
	733	char szQuery[256];
	734	MYSQL_RES * pres;
	735	signed long lRefCode = -1;
	736
[6678]	737	assert(lDll >= 0);
[3838]	738	assert(pszFilename != NULL);
	739	assert(*pszFilename != '\0');
	740
[6678]	741	sprintf(&szQuery[0], "SELECT refcode FROM file WHERE dll = %ld AND name = '%s'",
	742	lDll, pszFilename);
[3838]	743	if (mysql_query(pmysql, &szQuery[0]) >= 0)
	744	{
	745	pres = mysql_store_result(pmysql);
	746	if (pres != NULL)
	747	{
	748	MYSQL_ROW parow = mysql_fetch_row(pres);
	749	if (parow != NULL)
	750	lRefCode = getvalue(0, parow);
	751	mysql_free_result(pres);
	752	}
	753	}
	754
	755	return lRefCode;
	756	}
	757
	758
	759	/**
[830]	760	* Finds the refcode for an author, if the author exists.
	761	* @returns Author 'refcode'.
	762	* @param pszAuthor String which holds the identifier of an author.
	763	* This doesn't have to be the name. Initials, alias and email
	764	* is also searched.
[2818]	765	* @param pszEmail Email address. Might be NULL!
[830]	766	*/
[2818]	767	signed long _System dbFindAuthor(const char pszAuthor, const char pszEmail)
[830]	768	{
	769	signed long refcode = -1;
	770	MYSQL_RES *pres;
[2818]	771	char szQuery[512];
[830]	772
[2818]	773	/*
	774	* parameter validations
	775	*/
	776	if (pszAuthor == NULL \|\| strlen(pszAuthor) > 64)
	777	return -1;
	778	if (pszEmail != NULL && strlen(pszEmail) > 64)
	779	{
	780	fprintf(stderr, "email too long!");
	781	return -1;
	782	}
	783
	784	/*
	785	* Query
	786	*/
[830]	787	sprintf(&szQuery[0],
	788	"SELECT refcode FROM author "
	789	"WHERE name = '%s' OR "
	790	" initials = '%s' OR "
	791	" alias = '%s' OR "
	792	" email = '%s'",
	793	pszAuthor, pszAuthor, pszAuthor, pszAuthor);
[2818]	794
	795	if (pszEmail != NULL)
	796	sprintf(&szQuery[strlen(&szQuery[0])], " OR email = '%s'", pszEmail);
	797
[830]	798	if (mysql_query(pmysql, &szQuery[0]) >= 0)
	799	{
	800	pres = mysql_store_result(pmysql);
	801	if (pres != NULL)
	802	{
[2004]	803	MYSQL_ROW parow;
	804
[830]	805	/* integrety check */
	806	if (mysql_num_rows(pres) > 1)
	807	fprintf(stderr, "Integrety: author '%s' is not unique!\n", pszAuthor);
[2004]	808	parow = mysql_fetch_row(pres);
	809	if (parow != NULL)
	810	refcode = getvalue(0, parow);
	811
[830]	812	mysql_free_result(pres);
	813	}
	814	}
	815
	816	return refcode;
	817	}
	818
	819
	820	/**
	821	* Gets the state of a function.
	822	* @returns state code. On error -1.
	823	* @param lRefCode Function refcode.
	824	*/
	825	signed long _System dbGetFunctionState(signed long lRefCode)
	826	{
	827	signed long lState = -1;
	828	MYSQL_RES *pres;
	829	char szQuery[128];
	830
	831	sprintf(&szQuery[0], "SELECT state FROM function WHERE refcode = %ld", lRefCode);
	832	if (mysql_query(pmysql, &szQuery[0]) >= 0)
	833	{
	834	pres = mysql_store_result(pmysql);
	835	if (pres != NULL)
	836	{
[2004]	837	MYSQL_ROW parow = mysql_fetch_row(pres);
	838	if (parow != NULL)
	839	lState = getvalue(0, parow);
[830]	840	mysql_free_result(pres);
	841	}
	842	}
	843
	844	return lState;
	845	}
	846
[2773]	847	#if 1
	848	/*
	849	* Stubs used while optimizing sqls.
	850	*/
	851	int mysql_queryu1(MYSQL mysql, const char q)
	852	{ return mysql_query(mysql, q); }
	853	int mysql_queryu2(MYSQL mysql, const char q)
	854	{ return mysql_query(mysql, q); }
	855	int mysql_queryu3(MYSQL mysql, const char q)
	856	{ return mysql_query(mysql, q); }
	857	int mysql_queryu4(MYSQL mysql, const char q)
	858	{ return mysql_query(mysql, q); }
	859	int mysql_queryu5(MYSQL mysql, const char q)
	860	{ return mysql_query(mysql, q); }
	861	int mysql_queryu6(MYSQL mysql, const char q)
	862	{ return mysql_query(mysql, q); }
	863	int mysql_queryu7(MYSQL mysql, const char q)
	864	{ return mysql_query(mysql, q); }
	865	int mysql_queryu8(MYSQL mysql, const char q)
	866	{ return mysql_query(mysql, q); }
	867	#else
	868	#define mysql_queryu1 mysql_query
	869	#define mysql_queryu2 mysql_query
	870	#define mysql_queryu3 mysql_query
	871	#define mysql_queryu4 mysql_query
	872	#define mysql_queryu5 mysql_query
	873	#define mysql_queryu6 mysql_query
	874	#define mysql_queryu7 mysql_query
	875	#define mysql_queryu8 mysql_query
	876	#endif
[830]	877
	878	/**
	879	* Updates function information.
	880	* @returns number of errors.
[2761]	881	* @param pFnDesc Function description struct.
[6678]	882	* @param lDll Dll which we are working at.
[2761]	883	* @param pszError Buffer for error messages
[830]	884	* @result on error(s) pszError will hold information about the error(s).
	885	*/
[6678]	886	unsigned long _System dbUpdateFunction(PFNDESC pFnDesc, signed long lDll, char *pszError)
[830]	887	{
[2773]	888	MYSQL_RES * pres;
	889	MYSQL_ROW row;
[2818]	890	char * pszQuery2 = (char*)malloc(65500);
	891	char * pszQuery = pszQuery2;
[2773]	892	long lCurrentState;
	893	int i,k,rc;
	894	unsigned long ulRc = 0;
[830]	895
[2818]	896	/* check if malloc have failed allocating memory for us. */
	897	if (pszQuery2 == NULL)
	898	{
	899	strcpy(pszError, "internal dbUpdateFunction error - malloc failed!\n");
	900	return 1;
	901	}
	902
	903
	904	/*
	905	* Loop thru all functions in the array of refocodes.
	906	*/
[2759]	907	for (k = 0; k < pFnDesc->cRefCodes; k++)
[830]	908	{
[2773]	909	/*
	910	* Get current status
	911	*/
[2759]	912	lCurrentState = dbGetFunctionState(pFnDesc->alRefCode[k]);
[2818]	913	if (lCurrentState == -1 && dbGetLastErrorDesc() != NULL && strlen(dbGetLastErrorDesc()) != 0)
[2759]	914	{
	915	strcpy(pszError, dbGetLastErrorDesc());
[3899]	916	/*
	917	* Set updated flag
	918	*/
	919	sprintf(pszQuery, "UPDATE function SET updated = updated + 1 WHERE refcode = %ld",
	920	pFnDesc->alRefCode[k]);
	921	rc = mysql_queryu1(pmysql, pszQuery2);
[2818]	922	free(pszQuery2);
[2759]	923	return 1;
	924	}
[830]	925
[2773]	926
	927	/*
	928	* Update function table first
	929	*/
[3899]	930	strcpy(pszQuery, "UPDATE function SET updated = updated + 1");
[2759]	931	pszQuery += strlen(pszQuery);
[2818]	932
	933	/* Status */
	934	if (lCurrentState != pFnDesc->lStatus
	935	&& pFnDesc->lStatus != 0
[3899]	936	&& (lCurrentState == 0 \|\| pFnDesc->lStatus != 99)
	937	)
	938	pszQuery += sprintf(pszQuery, ", state = %ld", pFnDesc->lStatus);
[830]	939
[3899]	940	/* File */
	941	if (pFnDesc->lFile >= 0)
	942	pszQuery += sprintf(pszQuery, ", file = %ld", pFnDesc->lFile);
	943	else
	944	pszQuery += sprintf(pszQuery, ", file = -1");
	945
[3917]	946	/* Line */
	947	if (pFnDesc->lLine >= 0)
	948	pszQuery += sprintf(pszQuery, ", line = %ld", pFnDesc->lLine);
	949	else
	950	pszQuery += sprintf(pszQuery, ", line = -1");
	951
[2818]	952	/* return type */
[2759]	953	if (pFnDesc->pszReturnType != NULL)
[3899]	954	pszQuery = sqlstrcat(pszQuery, ", return = ", pFnDesc->pszReturnType);
	955	else
	956	pszQuery += sprintf(pszQuery, ", return = NULL");
[830]	957
[2818]	958	/* Description */
	959	if (pFnDesc->pszDescription != NULL)
[3899]	960	pszQuery = sqlstrcat(pszQuery, ", description = ", pFnDesc->pszDescription);
	961	else
	962	pszQuery += sprintf(pszQuery, ", description = NULL");
[2818]	963
	964	/* Remark */
	965	if (pFnDesc->pszRemark != NULL)
[3899]	966	pszQuery = sqlstrcat(pszQuery, ", remark = ", pFnDesc->pszRemark);
	967	else
	968	pszQuery += sprintf(pszQuery, ", remark = NULL");
[2818]	969
	970	/* Description */
	971	if (pFnDesc->pszReturnDesc != NULL)
[3899]	972	pszQuery = sqlstrcat(pszQuery, ", returndesc = ", pFnDesc->pszReturnDesc);
	973	else
	974	pszQuery += sprintf(pszQuery, ", returndesc = NULL");
[2818]	975
	976	/* Sketch */
	977	if (pFnDesc->pszSketch != NULL)
[3899]	978	pszQuery = sqlstrcat(pszQuery, ", sketch = ", pFnDesc->pszSketch);
	979	else
	980	pszQuery += sprintf(pszQuery, ", sketch = NULL");
[2818]	981
	982	/* Equiv */
	983	if (pFnDesc->pszEquiv != NULL)
[3899]	984	pszQuery = sqlstrcat(pszQuery, ", equiv = ", pFnDesc->pszEquiv);
	985	else
	986	pszQuery += sprintf(pszQuery, ", equiv = NULL");
[2818]	987
[3882]	988	/* Time */
[2818]	989	if (pFnDesc->pszTime != NULL)
[3899]	990	pszQuery = sqlstrcat(pszQuery, ", time = ", pFnDesc->pszTime);
	991	else
	992	pszQuery += sprintf(pszQuery, ", time = NULL");
[2818]	993
	994	/* Execute update query? */
[3899]	995	sprintf(pszQuery + strlen(pszQuery), " WHERE refcode = %ld", pFnDesc->alRefCode[k]);
	996	rc = mysql_queryu2(pmysql, pszQuery2);
	997	if (rc < 0)
[2759]	998	{
[3899]	999	sprintf(pszError, "Updating functiontable failed with error: %s - (sql=%s) ",
	1000	dbGetLastErrorDesc(), pszQuery2);
	1001	pszError += strlen(pszError) - 1;
	1002	ulRc++;
[2759]	1003	}
[830]	1004
[2773]	1005
	1006	/*
	1007	* Parameters
	1008	*/
[2818]	1009	pszQuery = pszQuery2;
[2773]	1010	sprintf(pszQuery, "SELECT count(*) FROM parameter WHERE function = %ld", pFnDesc->alRefCode[k]);
	1011	rc = mysql_queryu3(pmysql, pszQuery);
	1012	if (rc >= 0)
[830]	1013	{
[2773]	1014	pres = mysql_store_result(pmysql);
	1015	if (pres != NULL)
	1016	row = mysql_fetch_row(pres);
	1017	if (pres != NULL && row != NULL && mysql_num_rows(pres) == 1)
	1018	{
[6651]	1019	#if 0 /* keep getting duplicate keys when parameter order/names are changed. */
[2773]	1020	if (atol(row[0]) == pFnDesc->cParams)
	1021	{ /* update parameters */
	1022	for (i = 0; i < pFnDesc->cParams; i++)
	1023	{
[2818]	1024	sprintf(pszQuery, "UPDATE parameter SET type = '%s', name = '%s'",
[2773]	1025	pFnDesc->apszParamType[i] != NULL ? pFnDesc->apszParamType[i] : "",
[2818]	1026	pFnDesc->apszParamName[i] != NULL ? pFnDesc->apszParamName[i] : "");
	1027	if (pFnDesc->apszParamDesc[i] != NULL)
	1028	sqlstrcat(pszQuery, ", description = ", pFnDesc->apszParamDesc[i]);
	1029	sprintf(pszQuery + strlen(pszQuery), " WHERE function = (%ld) AND sequencenbr = (%ld)",
	1030	pFnDesc->alRefCode[k], i);
[2773]	1031	rc = mysql_queryu4(pmysql, pszQuery);
	1032	if (rc < 0)
	1033	{
	1034	if (*pszError == ' ')
	1035	strcpy(pszError++, "\n\t");
[3899]	1036	sprintf(pszError, "Updating parameter %i failed with error: %s - (sql=%s) ",
[2773]	1037	i, dbGetLastErrorDesc(), pszQuery);
	1038	pszError += strlen(pszError) - 1;
	1039	ulRc++;
	1040	}
	1041	}
	1042	}
	1043	else
[6651]	1044	#endif
[2773]	1045	{
	1046	if (atol(row[0]) != 0)
	1047	{ /* delete old parameters */
	1048	sprintf(pszQuery, "DELETE FROM parameter WHERE function = %ld", pFnDesc->alRefCode[k]);
	1049	rc = mysql_queryu5(pmysql, pszQuery);
	1050	if (rc < 0)
	1051	{
	1052	if (*pszError == ' ')
	1053	strcpy(pszError++, "\n\t");
	1054	sprintf(pszError, "Deleting old parameters failed with error: %s - (sql=%s) ",
	1055	dbGetLastErrorDesc(), pszQuery);
	1056	pszError += strlen(pszError) - 1;
	1057	ulRc++;
	1058	}
	1059	}
[830]	1060
[2773]	1061	/* insert parameters */
	1062	for (i = 0; i < pFnDesc->cParams; i++)
	1063	{
[2818]	1064	sprintf(pszQuery, "INSERT INTO parameter(function, sequencenbr, type, name, description) "
	1065	"VALUES (%ld, %d, '%s', '%s'",
[2773]	1066	pFnDesc->alRefCode[k], i,
	1067	pFnDesc->apszParamType[i] != NULL ? pFnDesc->apszParamType[i] : "",
	1068	pFnDesc->apszParamName[i] != NULL ? pFnDesc->apszParamName[i] : ""
	1069	);
[2818]	1070	if (pFnDesc->apszParamDesc[i] != NULL)
[6642]	1071	sqlstrcat(pszQuery, ", ", pFnDesc->apszParamDesc[i], ")");
[2818]	1072	else
	1073	strcat(pszQuery, ", NULL)");
	1074
	1075	rc = mysql_queryu6(pmysql, pszQuery2);
[2773]	1076	if (rc < 0)
	1077	{
	1078	if (*pszError == ' ')
	1079	strcpy(pszError++, "\n\t");
	1080	sprintf(pszError, "Inserting parameter %i failed with error: %s - (sql=%s) ",
	1081	i, dbGetLastErrorDesc(), pszQuery);
	1082	pszError += strlen(pszError) - 1;
	1083	ulRc++;
	1084	}
	1085	}
	1086	}
	1087	}
	1088	else
[2759]	1089	{
	1090	if (*pszError == ' ')
	1091	strcpy(pszError++, "\n\t");
[2773]	1092	sprintf(pszError, "failed to store result or to fetch a row , error: %s - (sql=%s) ",
	1093	dbGetLastErrorDesc(), pszQuery);
[2759]	1094	pszError += strlen(pszError) - 1;
	1095	ulRc++;
	1096	}
	1097	}
[2773]	1098	else
	1099	{
	1100	if (*pszError == ' ')
	1101	strcpy(pszError++, "\n\t");
	1102	sprintf(pszError, "Failed querying number of parameters, error: %s - (sql=%s) ",
	1103	dbGetLastErrorDesc(), pszQuery);
	1104	pszError += strlen(pszError) - 1;
	1105	ulRc++;
	1106	}
[830]	1107
[2773]	1108
	1109	/*
	1110	* Authors
	1111	*/
[2759]	1112	sprintf(pszQuery, "DELETE FROM fnauthor WHERE function = %ld", pFnDesc->alRefCode[k]);
[2773]	1113	rc = mysql_queryu7(pmysql, pszQuery);
[830]	1114	if (rc < 0)
	1115	{
	1116	if (*pszError == ' ')
	1117	strcpy(pszError++, "\n\t");
[2759]	1118	sprintf(pszError, "Deleting old authors failed with error: %s - (sql=%s) ",
[2773]	1119	dbGetLastErrorDesc(), pszQuery);
[830]	1120	pszError += strlen(pszError) - 1;
	1121	ulRc++;
	1122	}
	1123
[2759]	1124	for (i = 0; i < pFnDesc->cAuthors; i++)
	1125	{
	1126	if (pFnDesc->alAuthorRefCode[i] == -1)
	1127	continue;
	1128	sprintf(pszQuery, "INSERT INTO fnauthor(author, function) "
	1129	"VALUES (%ld, %ld)",
	1130	pFnDesc->alAuthorRefCode[i], pFnDesc->alRefCode[k]);
[2773]	1131	rc = mysql_queryu8(pmysql, pszQuery);
[2759]	1132	if (rc < 0)
	1133	{
	1134	if (*pszError == ' ')
	1135	strcpy(pszError++, "\n\t");
	1136	sprintf(pszError, "Inserting parameter %i failed with error: %s - (sql=%s) ",
[2773]	1137	i, dbGetLastErrorDesc(), pszQuery);
[2759]	1138	pszError += strlen(pszError) - 1;
	1139	ulRc++;
	1140	}
	1141	}
	1142	} /* for */
[2761]	1143
[6678]	1144	lDll = lDll;
[2818]	1145	free(pszQuery2);
[830]	1146	return ulRc;
	1147	}
	1148
	1149
	1150	/**
[3838]	1151	* Removes all the existing design notes in the specified file.
[6678]	1152	* @returns Success indicator.
	1153	* @param lFile File refcode of the file to remove all design notes for.
	1154	* @sketch
	1155	* @status
	1156	* @author knut st. osmundsen (knut.stange.osmundsen@pmsc.no)
	1157	* @remark
[3838]	1158	*/
	1159	BOOL _System dbRemoveDesignNotes(signed long lFile)
	1160	{
	1161	char szQuery[80];
	1162
	1163	assert(lFile >= 0);
	1164	sprintf(&szQuery[0], "DELETE FROM designnote WHERE file = %ld", lFile);
	1165	return mysql_query(pmysql, &szQuery[0]) >= 0;
	1166	}
	1167
	1168
	1169	/**
	1170	* Adds a design note.
	1171	* @returns Success indicator.
[6678]	1172	* @param lDll Dll refcode.
[3838]	1173	* @param lFile File refcode.
	1174	* @param pszTitle Design note title.
	1175	* @param pszText Design note text.
[6663]	1176	* @param lLevel Level of the note section. 0 is the design note it self.
[6678]	1177	* @param lSeqNbr Sequence number (in dll). If 0 the use next available number.
[6663]	1178	* @param lSeqNbrNote Sequence number in note.
[3917]	1179	* @param lLine Line number (1 - based!).
[6663]	1180	* @param fSubSection TRUE if subsection FALSE if design note.
	1181	* if TRUE *plRefCode will hold the reference id of the note.
	1182	* if FALSE *plRefCode will receive the reference id of the note being created.
	1183	* @param plRefCode Pointer to reference id of the design note. see fSubSection for more info.
[3838]	1184	*/
[6678]	1185	BOOL _System dbAddDesignNote(signed long lDll,
[3838]	1186	signed long lFile,
	1187	const char *pszTitle,
	1188	const char *pszText,
[6663]	1189	signed long lLevel,
[3838]	1190	signed long lSeqNbr,
[6663]	1191	signed long lSeqNbrNote,
	1192	signed long lLine,
	1193	BOOL fSubSection,
	1194	signed long *plRefCode)
[3838]	1195	{
[6663]	1196	int rc;
[3838]	1197	char szQuery[0x10200];
	1198	MYSQL_RES * pres;
	1199
	1200
[6678]	1201	assert(lDll >= 0 && lFile >= 0);
[6663]	1202	assert(lSeqNbrNote >= 0);
[3838]	1203
	1204	/*
	1205	* If no lSqlNbr the make one.
	1206	*/
[6663]	1207	if (lSeqNbr == 0 && !fSubSection)
[3838]	1208	{
[6678]	1209	sprintf(&szQuery[0], "SELECT MAX(seqnbr) + 1 FROM designnote WHERE dll = %ld AND level = 0", lDll);
[3838]	1210	if (mysql_query(pmysql, &szQuery[0]) >= 0)
	1211	{
	1212	pres = mysql_store_result(pmysql);
	1213	if (pres != NULL)
	1214	{
	1215	MYSQL_ROW parow = mysql_fetch_row(pres);
[6663]	1216	if (parow != NULL && parow[0])
[3838]	1217	lSeqNbr = getvalue(0, parow);
	1218	else
	1219	lSeqNbr = 1;
	1220	mysql_free_result(pres);
	1221	}
	1222	else
	1223	return FALSE;
	1224	}
	1225	else
	1226	return FALSE;
	1227	}
	1228
	1229	/*
[6663]	1230	* Create insert query.
[3838]	1231	*/
[6663]	1232	if (!fSubSection)
[6678]	1233	sprintf(&szQuery[0], "INSERT INTO designnote(dll, file, level, seqnbrnote, seqnbr, line, name, note) "
[6663]	1234	"VALUES (%ld, %ld, %ld, %ld, %ld, %ld, ",
[6678]	1235	lDll, lFile, lLevel, lSeqNbrNote, lSeqNbr, lLine);
[6663]	1236	else
[6678]	1237	sprintf(&szQuery[0], "INSERT INTO designnote(refcode, dll, file, level, seqnbrnote, seqnbr, line, name, note) "
[6663]	1238	"VALUES (%ld, %ld, %ld, %ld, %ld, %ld, %ld, ",
[6678]	1239	*plRefCode, lDll, lFile, lLevel, lSeqNbrNote, lSeqNbr, lLine);
[6663]	1240
[3838]	1241	if (pszTitle != NULL && *pszTitle != '\0')
	1242	sqlstrcat(&szQuery[0], NULL, pszTitle);
	1243	else
	1244	strcat(&szQuery[0], "NULL");
	1245	sqlstrcat(&szQuery[0], ", ", pszText == NULL ? "" : pszText, ")");
	1246
[6663]	1247	if (mysql_query(pmysql, &szQuery[0]) >= 0)
	1248	{
	1249	if (!fSubSection)
	1250	*plRefCode = mysql_insert_id(pmysql);
	1251	return TRUE;
	1252	}
	1253	return FALSE;
[3838]	1254	}
	1255
	1256
	1257
	1258	/**
[830]	1259	* Updates the history tables.
	1260	* @returns Number of signals/errors.
	1261	* @param pszError Pointer to buffer which will hold the error messages.
	1262	* @remark This should be called whenever updates have been completed.
	1263	*/
	1264	unsigned long _System dbCreateHistory(char *pszError)
	1265	{
	1266	unsigned long ulRc = 0;
	1267	MYSQL_RES *pres;
	1268	MYSQL_ROW row;
	1269	char szQuery[256];
	1270	char *pszQuery = &szQuery[0];
	1271	int rc;
	1272	char szCurDt[20] = {0}; /yyyy-mm-dd\0/
	1273
	1274	mysql_refresh(pmysql, REFRESH_TABLES);
	1275
	1276	/* get currentdate - just in case the date changes between the delete and the update is completed. */
	1277	strcpy(pszQuery, "SELECT CURDATE()");
	1278	rc = mysql_query(pmysql, pszQuery);
	1279	pres = mysql_use_result(pmysql);
	1280	if (rc >= 0 && pres != NULL)
	1281	{
	1282	row = mysql_fetch_row(pres);
	1283	if (row != NULL && mysql_num_rows(pres) == 1)
	1284	{
	1285	strcpy(&szCurDt[0], row[0]);
	1286	while (mysql_fetch_row(pres) != NULL)
[1993]	1287	pres=pres;
[830]	1288
	1289	/* delete - all rows on this date in the history tables */
[6678]	1290	sprintf(pszQuery, "DELETE FROM historydll WHERE date = '%s'", &szCurDt[0]);
[830]	1291	rc = mysql_query(pmysql, pszQuery);
	1292	CheckLogContinue((pszError, "error removing old history rows: %s - (sql=%s) ", dbGetLastErrorDesc(), pszQuery));
	1293
	1294	sprintf(pszQuery, "DELETE FROM historyapigroup WHERE date = '%s'", &szCurDt[0]);
	1295	rc = mysql_query(pmysql, pszQuery);
	1296	CheckLogContinue((pszError, "error removing old history rows: %s - (sql=%s) ", dbGetLastErrorDesc(), pszQuery));
	1297
[6678]	1298	sprintf(pszQuery, "DELETE FROM historydlltotal WHERE date = '%s'", &szCurDt[0]);
[830]	1299	rc = mysql_query(pmysql, pszQuery);
	1300	CheckLogContinue((pszError, "error removing old history rows: %s - (sql=%s) ", dbGetLastErrorDesc(), pszQuery));
	1301
	1302	sprintf(pszQuery, "DELETE FROM historyapigrouptotal WHERE date = '%s'", &szCurDt[0]);
	1303	CheckLogContinue((pszError, "error removing old history rows: %s - (sql=%s) ", dbGetLastErrorDesc(), pszQuery));
	1304
	1305	/* insert new stats */
[6678]	1306	sprintf(pszQuery, "INSERT INTO historydll(dll, state, date, count) "
	1307	"SELECT dll, state, '%s', count(*) FROM function GROUP BY dll, state",
[830]	1308	&szCurDt[0]);
	1309	rc = mysql_query(pmysql, pszQuery);
	1310	CheckLogContinue((pszError, "error inserting: %s - (sql=%s) ", dbGetLastErrorDesc(), pszQuery));
	1311
	1312	sprintf(pszQuery, "INSERT INTO historyapigroup(apigroup, state, date, count) "
[3920]	1313	"SELECT apigroup, state, '%s', count(*) FROM function WHERE apigroup IS NOT NULL "
[830]	1314	"GROUP BY apigroup, state",
	1315	&szCurDt[0]);
	1316	rc = mysql_query(pmysql, pszQuery);
	1317	CheckLogContinue((pszError, "error inserting: %s - (sql=%s) ", dbGetLastErrorDesc(), pszQuery));
	1318
	1319	/* inserting new totals */
[6678]	1320	sprintf(pszQuery, "INSERT INTO historydlltotal(dll, date, totalcount) "
	1321	"SELECT dll, '%s', count(*) FROM function GROUP BY dll",
[830]	1322	&szCurDt[0]);
	1323	rc = mysql_query(pmysql, pszQuery);
	1324	CheckLogContinue((pszError, "error inserting: %s - (sql=%s) ", dbGetLastErrorDesc(), pszQuery));
	1325
	1326	sprintf(pszQuery, "INSERT INTO historyapigrouptotal(apigroup, date, totalcount) "
[6678]	1327	"SELECT apigroup, '%s', count(*) FROM function WHERE apigroup IS NOT NULL "
[830]	1328	"GROUP BY apigroup",
	1329	&szCurDt[0]);
	1330	rc = mysql_query(pmysql, pszQuery);
	1331	CheckLogContinue((pszError, "error inserting: %s - (sql=%s) ", dbGetLastErrorDesc(), pszQuery));
	1332	}
	1333	else
	1334	{
	1335	sprintf(pszError, "error getting current date (row == NULL): %s - (sql=%s) ",
	1336	dbGetLastErrorDesc(), pszQuery);
	1337	ulRc++;
	1338	}
	1339	}
	1340	else
	1341	{
	1342	sprintf(pszError, "error getting current date: %s - (sql=%s) ",
	1343	dbGetLastErrorDesc(), pszQuery);
	1344	ulRc++;
	1345	}
	1346
	1347	mysql_refresh(pmysql, REFRESH_TABLES);
	1348
	1349	return ulRc;
	1350	}
	1351
	1352
	1353	/**
	1354	* Check that database integrety is ok. Verfies foreign keys.
	1355	* @returns numbers of errors.
	1356	* @param pszError Very large buffer which will hold error messges (if any).
	1357	* @sketch
	1358	* @remark current versions of mysql don't support 'SELECT ... WHERE id NOT IN(SELECT id FROM table)'
	1359	*/
	1360	unsigned long _System dbCheckIntegrity(char *pszError)
	1361	{
	1362	char szQuery[384];
	1363	char *pszQuery = &szQuery[0];
	1364	MYSQL_RES *pres1;
	1365	MYSQL_RES *pres2;
	1366	MYSQL_ROW row1;
	1367	int rc;
	1368	unsigned long ulRc = 0;
	1369
	1370	mysql_refresh(pmysql, REFRESH_TABLES);
	1371
	1372	/* foreign keys in function table */
[6678]	1373	strcpy(pszQuery, "SELECT refcode, dll, state, apigroup, file FROM function");
[830]	1374	rc = mysql_query(pmysql, pszQuery);
	1375	if (rc >= 0)
	1376	{
	1377	pres1 = mysql_store_result(pmysql);
	1378	if (pres1 != NULL)
	1379	{
	1380	while ((row1 = mysql_fetch_row(pres1)) != NULL)
	1381	{
[6678]	1382	/* check dll */
	1383	sprintf(pszQuery, "SELECT refcode FROM dll WHERE refcode = %s", row1[1]);
[830]	1384	rc = mysql_query(pmysql, pszQuery);
[6678]	1385	CheckFKError("function/dll", "Foreign key 'dll' not found in the dll table");
[830]	1386
	1387	/* check state */
[3838]	1388	sprintf(pszQuery, "SELECT refcode FROM state WHERE refcode = %s", row1[2]);
[830]	1389	rc = mysql_query(pmysql, pszQuery);
	1390	CheckFKError("function/state", "Foreign key 'state' not found in the state table");
	1391
	1392	/* check apigroup */
	1393	if (row1[3] != NULL)
	1394	{
[3838]	1395	sprintf(pszQuery, "SELECT refcode FROM apigroup WHERE refcode = %s", row1[3]);
[830]	1396	rc = mysql_query(pmysql, pszQuery);
	1397	CheckFKError("function/state", "Foreign key 'state' not found in the state table");
	1398	}
[3838]	1399
	1400	/* check file */
	1401	if (atoi(row1[4]) >= 0)
	1402	{
	1403	sprintf(pszQuery, "SELECT refcode FROM file WHERE refcode = %s", row1[4]);
	1404	rc = mysql_query(pmysql, pszQuery);
	1405	CheckFKError("function/file", "Foreign key 'file' not found in the file table");
	1406	}
[830]	1407	}
	1408	mysql_free_result(pres1);
	1409	}
	1410	}
	1411	else
	1412	ulRc += logDbError(pszError, pszQuery);
	1413
[3838]	1414	/* foreign keys in file */
[6678]	1415	strcpy(pszQuery, "SELECT refcode, dll FROM file");
[3838]	1416	rc = mysql_query(pmysql, pszQuery);
	1417	if (rc >= 0)
	1418	{
	1419	pres1 = mysql_store_result(pmysql);
	1420	if (pres1 != NULL)
	1421	{
	1422	while ((row1 = mysql_fetch_row(pres1)) != NULL)
	1423	{
[6678]	1424	/* check dll */
	1425	sprintf(pszQuery, "SELECT refcode FROM dll WHERE refcode = %s", row1[1]);
[3838]	1426	rc = mysql_query(pmysql, pszQuery);
[6678]	1427	CheckFKError("apigroup/dll", "Foreign key 'dll' not found in the dll table");
[3838]	1428	}
	1429	mysql_free_result(pres1);
	1430	}
	1431	}
	1432	else
	1433	ulRc += logDbError(pszError, pszQuery);
	1434
[830]	1435	/* foreign keys in apigroup */
[6678]	1436	strcpy(pszQuery, "SELECT refcode, dll FROM apigroup");
[830]	1437	rc = mysql_query(pmysql, pszQuery);
	1438	if (rc >= 0)
	1439	{
	1440	pres1 = mysql_store_result(pmysql);
	1441	if (pres1 != NULL)
	1442	{
	1443	while ((row1 = mysql_fetch_row(pres1)) != NULL)
	1444	{
[6678]	1445	/* check dll */
	1446	sprintf(pszQuery, "SELECT refcode FROM dll WHERE refcode = %s", row1[1]);
[830]	1447	rc = mysql_query(pmysql, pszQuery);
[6678]	1448	CheckFKError("file/dll", "Foreign key 'dll' not found in the dll table");
[830]	1449	}
	1450	mysql_free_result(pres1);
	1451	}
	1452	}
	1453	else
	1454	ulRc += logDbError(pszError, pszQuery);
	1455
	1456	/* foreign keys in fnauthor */
	1457	strcpy(pszQuery, "SELECT function, author FROM fnauthor");
	1458	rc = mysql_query(pmysql, pszQuery);
	1459	if (rc >= 0)
	1460	{
	1461	pres1 = mysql_store_result(pmysql);
	1462	if (pres1 != NULL)
	1463	{
	1464	while ((row1 = mysql_fetch_row(pres1)) != NULL)
	1465	{
	1466	/* check function */
	1467	sprintf(pszQuery, "SELECT refcode FROM function WHERE refcode = %s", row1[1]);
	1468	rc = mysql_query(pmysql, pszQuery);
	1469	CheckFKError("fnauthor/function", "Foreign key 'function' not found in the function table");
	1470
	1471	/* check author */
	1472	sprintf(pszQuery, "SELECT refcode FROM author WHERE refcode = %s", row1[1]);
	1473	rc = mysql_query(pmysql, pszQuery);
	1474	CheckFKError("fnauthor/author", "Foreign key 'author' not found in the author table");
	1475	}
	1476	mysql_free_result(pres1);
	1477	}
	1478	}
	1479	else
	1480	ulRc += logDbError(pszError, pszQuery);
	1481
[6678]	1482	/* foreign keys in historydll table */
	1483	strcpy(pszQuery, "SELECT date, dll, state FROM historydll");
[830]	1484	rc = mysql_query(pmysql, pszQuery);
	1485	if (rc >= 0)
	1486	{
	1487	pres1 = mysql_store_result(pmysql);
	1488	if (pres1 != NULL)
	1489	{
	1490	while ((row1 = mysql_fetch_row(pres1)) != NULL)
	1491	{
[6678]	1492	/* check dll */
	1493	sprintf(pszQuery, "SELECT refcode FROM dll WHERE refcode = %s", row1[1]);
[830]	1494	rc = mysql_query(pmysql, pszQuery);
[6678]	1495	CheckFKError("historydll/dll", "Foreign key 'dll' not found in the dll table");
[830]	1496
	1497	/* check state */
	1498	sprintf(pszQuery, "SELECT refcode FROM state WHERE refcode = %s", row1[2]);
	1499	rc = mysql_query(pmysql, pszQuery);
[6678]	1500	CheckFKError("historydll/state", "Foreign key 'state' not found in the state table");
[830]	1501	}
	1502	mysql_free_result(pres1);
	1503	}
	1504	}
	1505	else
	1506	ulRc += logDbError(pszError, pszQuery);
	1507
	1508	/* foreign keys in historyapigroup table */
	1509	strcpy(pszQuery, "SELECT date, apigroup, state FROM historyapigroup");
	1510	rc = mysql_query(pmysql, pszQuery);
	1511	if (rc >= 0)
	1512	{
	1513	pres1 = mysql_store_result(pmysql);
	1514	if (pres1 != NULL)
	1515	{
	1516	while ((row1 = mysql_fetch_row(pres1)) != NULL)
	1517	{
[6678]	1518	/* check dll */
[830]	1519	sprintf(pszQuery, "SELECT refcode FROM apigroup WHERE refcode = %s", row1[1]);
	1520	rc = mysql_query(pmysql, pszQuery);
	1521	CheckFKError("historyapigroup/apigroup", "Foreign key 'apigroup' not found in the apigroup table");
	1522
	1523	/* check state */
	1524	sprintf(pszQuery, "SELECT refcode FROM state WHERE refcode = %s", row1[2]);
	1525	rc = mysql_query(pmysql, pszQuery);
	1526	CheckFKError("historyapigroup/state", "Foreign key 'state' not found in the state table");
	1527	}
	1528	mysql_free_result(pres1);
	1529	}
	1530	}
	1531	else
	1532	ulRc += logDbError(pszError, pszQuery);
	1533
[6678]	1534	/* foreign keys in historydlltotal table */
	1535	strcpy(pszQuery, "SELECT date, dll FROM historydlltotal");
[830]	1536	rc = mysql_query(pmysql, pszQuery);
	1537	if (rc >= 0)
	1538	{
	1539	pres1 = mysql_store_result(pmysql);
	1540	if (pres1 != NULL)
	1541	{
	1542	while ((row1 = mysql_fetch_row(pres1)) != NULL)
	1543	{
[6678]	1544	/* check dll */
	1545	sprintf(pszQuery, "SELECT refcode FROM dll WHERE refcode = %s", row1[1]);
[830]	1546	rc = mysql_query(pmysql, pszQuery);
[6678]	1547	CheckFKError("historydlltotal/dll", "Foreign key 'dll' not found in the dll table");
[830]	1548	}
	1549	mysql_free_result(pres1);
	1550	}
	1551	}
	1552	else
	1553	ulRc += logDbError(pszError, pszQuery);
	1554
	1555	/* foreign keys in historyapigroup table */
	1556	strcpy(pszQuery, "SELECT date, apigroup FROM historyapigrouptotal");
	1557	rc = mysql_query(pmysql, pszQuery);
	1558	if (rc >= 0)
	1559	{
	1560	pres1 = mysql_store_result(pmysql);
	1561	if (pres1 != NULL)
	1562	{
	1563	while ((row1 = mysql_fetch_row(pres1)) != NULL)
	1564	{
[6678]	1565	/* check dll */
[830]	1566	sprintf(pszQuery, "SELECT refcode FROM apigroup WHERE refcode = %s", row1[1]);
	1567	rc = mysql_query(pmysql, pszQuery);
	1568	CheckFKError("historyapigrouptotal/apigroup", "Foreign key 'apigroup' not found in the apigroup table");
	1569	}
	1570	mysql_free_result(pres1);
	1571	}
	1572	}
	1573	else
	1574	ulRc += logDbError(pszError, pszQuery);
	1575
	1576	/* foreign keys in parameter table */
	1577	strcpy(pszQuery, "SELECT sequencenbr, function FROM parameter");
	1578	rc = mysql_query(pmysql, pszQuery);
	1579	if (rc >= 0)
	1580	{
	1581	pres1 = mysql_store_result(pmysql);
	1582	if (pres1 != NULL)
	1583	{
	1584	while ((row1 = mysql_fetch_row(pres1)) != NULL)
	1585	{
	1586	/* check function */
	1587	sprintf(pszQuery, "SELECT refcode FROM function WHERE refcode = %s", row1[1]);
	1588	rc = mysql_query(pmysql, pszQuery);
	1589	CheckFKError("parameter/function", "Foreign key 'function' not found in the function table");
	1590	}
	1591	mysql_free_result(pres1);
	1592	}
	1593	}
	1594	else
	1595	ulRc += logDbError(pszError, pszQuery);
	1596
	1597	/* Author table is special, since you should be able to interchangably reference an
	1598	* author by any of the following tables:
	1599	* name
	1600	* initials
	1601	* alias
	1602	* email
	1603	*/
	1604	strcpy(pszQuery, "SELECT name, initials, alias, email FROM author");
	1605	rc = mysql_query(pmysql, pszQuery);
	1606	if (rc >= 0)
	1607	{
	1608	pres1 = mysql_store_result(pmysql);
	1609	if (pres1 != NULL)
	1610	{
	1611	while ((row1 = mysql_fetch_row(pres1)) != NULL)
	1612	{
	1613	/* check name */
	1614	sprintf(pszQuery, "SELECT name FROM author WHERE "
	1615	"initials = '%s' OR alias = '%s' OR email = '%s'",
	1616	row1[0], row1[0], row1[0]);
	1617	ulRc += CheckAuthorError(pszError, "name", row1[0], pszQuery);
	1618
	1619	/* check initials */
	1620	sprintf(pszQuery, "SELECT name FROM author WHERE "
	1621	"alias = '%s' OR email = '%s'",
	1622	row1[1], row1[1]);
	1623	ulRc += CheckAuthorError(pszError, "initials", row1[1], pszQuery);
	1624
	1625	/* alias */
	1626	if (row1[2] != NULL)
	1627	{
	1628	sprintf(pszQuery, "SELECT name FROM author WHERE "
	1629	"email = '%s'",
	1630	row1[2]);
	1631	ulRc += CheckAuthorError(pszError, "alias", row1[2], pszQuery);
	1632	}
	1633	}
	1634	mysql_free_result(pres1);
	1635	}
	1636	}
	1637	else
	1638	ulRc += logDbError(pszError, pszQuery);
	1639
	1640	return ulRc;
	1641	}
	1642
	1643
	1644	/**
	1645	* Checks for duplicate key and sql error for a given author key in the author table... (arg!)
	1646	* @returns Number of errors.
	1647	* @param pszError Reference to error buffer pointer.
	1648	* @param pszFieldName Key field name; used for logging.
	1649	* @param pszFieldValue Key value; used for logging
	1650	* @param pszQuery Query which is to be exectued to test for duplicate key.
	1651	* @remark Uses pszError[1] == '\xFE' to detect when to insert '\n\t'.
	1652	*/
	1653	static unsigned long CheckAuthorError(char * &pszError, const char pszFieldName, const char pszFieldValue, const char *pszQuery)
	1654	{
	1655	MYSQL_ROW row;
	1656	MYSQL_RES *pres;
	1657	unsigned long ulRc = 0;
	1658	int rc;
	1659
	1660	rc = mysql_query(pmysql, pszQuery);
	1661	pres = mysql_store_result(pmysql);
[2759]	1662	if (rc < 0 \|\| (pres != NULL && mysql_num_rows(pres) != 0))
[830]	1663	{ /* some kind of error has occurred */
	1664	if (pszError[1] == '\xFE')
	1665	{
	1666	strcat(pszError, "\n\t");
	1667	pszError += 2;
	1668	}
	1669
	1670	if (rc < 0) /* sql error or 'duplicate key' */
	1671	{
	1672	sprintf(pszError, "author/%s: select failed - %s (sql=%s)",
	1673	pszFieldName, dbGetLastErrorDesc(), pszQuery);
	1674	}
	1675	else
	1676	{ /* 'duplicate key' - print duplicates */
	1677	sprintf(pszError, "author/%s: 'duplicate key', %s='%s': ",
	1678	pszFieldName, pszFieldValue, pszFieldName);
	1679
	1680	while ((row = mysql_fetch_row(pres)) != NULL)
	1681	{
	1682	pszError += strlen(pszError);
	1683	sprintf(pszError, "'%s' ", row[0]);
	1684	}
	1685	}
	1686
	1687	pszError += strlen(pszError);
	1688	pszError[1] = '\xFE';
	1689	ulRc = 1;
	1690	}
	1691	if (pres != NULL)
	1692	mysql_free_result(pres);
	1693
	1694	return ulRc;
	1695	}
	1696
	1697
	1698	/**
	1699	* Writes db error (rc<0) to the log buffer.
	1700	* @returns Number of signals.
	1701	* @param pszError Reference to the error buffer pointer.
	1702	* @param pszQuery Pointer to query which was executed.
	1703	* @remark Uses pszError[1] == '\xFE' to detect when to insert '\n\t'.
	1704	*/
	1705	static unsigned long logDbError(char * &pszError, const char *pszQuery)
	1706	{
	1707	if (pszError[1] == '\xFE')
	1708	{
	1709	strcat(pszError, "\n\t");
	1710	pszError += 2;
	1711	}
	1712	sprintf(pszError, "select failed: %s - (sql=%s)", dbGetLastErrorDesc(), pszQuery);
	1713
	1714	pszError += strlen(pszError);
	1715	pszError[1] = '\xFE';
	1716
	1717	return 1;
	1718	}
	1719
	1720
	1721	/**
	1722	* Executes a give query and returns a result identifier/pointer.
	1723	* @returns Query result identifier/pointer. NULL on error.
	1724	* @param pszQuery Pointer to query.
	1725	* @remark Used by and designed for kHtmlPC.
	1726	*/
	1727	void * _System dbExecuteQuery(const char *pszQuery)
	1728	{
	1729	assert(pmysql != NULL);
	1730	if (mysql_query(pmysql, pszQuery) >= 0)
	1731	return mysql_store_result(pmysql);
	1732
	1733	return NULL;
	1734	}
	1735
	1736
	1737	/**
	1738	* Asks for the number of rows in the result.
	1739	* @returns Number of rows in the result. -1 on error.
	1740	* @param pres Query result identifier/pointer.
	1741	* @remark Used by and designed for kHtmlPC.
	1742	*/
	1743	signed long _System dbQueryResultRows(void *pres)
	1744	{
	1745	if (pres == NULL)
	1746	return -1;
	1747	return mysql_num_rows((MYSQL_RES*)pres);
	1748	}
	1749
	1750
	1751	/**
	1752	* Frees the storage allocated by the given result.
	1753	* @returns Success indicator, TRUE/FALSE.
	1754	* @param pres Query result identifier/pointer.
	1755	* @remark Used by and designed for kHtmlPC.
	1756	*/
	1757	BOOL _System dbFreeResult(void *pres)
	1758	{
	1759	if (pres != NULL)
	1760	mysql_free_result((MYSQL_RES*)pres);
	1761	else
	1762	return FALSE;
	1763	return TRUE;
	1764	}
	1765
	1766
	1767	/**
	1768	* Fetch data from a result. Returns the data by calling the given callback function.
	1769	* @returns Success indicator, TRUE/FALSE.
	1770	* @param pres Query result identifier/pointer.
	1771	* @param dbFetchCallBack Callback-function.
	1772	* @param pvUser User parameter which is passed onto dbFetchCallBack.
	1773	* @remark Used by and designed for kHtmlPC.
	1774	*/
	1775	BOOL _System dbFetch(void pres, DBCALLBACKFETCH dbFetchCallBack, void pvUser)
	1776	{
	1777	BOOL fRc = FALSE;
	1778	MYSQL_ROW row = mysql_fetch_row((MYSQL_RES*)pres);
	1779
	1780	if (row)
	1781	{
	1782	MYSQL_FIELD *pField;
	1783	int i = 0;
	1784	mysql_field_seek((MYSQL_RES*)pres, 0);
	1785
	1786	while ((pField = mysql_fetch_field((MYSQL_RES*)pres)) != NULL)
	1787	if (dbFetchCallBack(row[i++], pField->name, pvUser) != 0)
	1788	return FALSE;
	1789
	1790	fRc = TRUE;
	1791	}
	1792
	1793	return fRc;
	1794	}
	1795
	1796
	1797	/**
	1798	* Converts an ISO date to days after Christ, year 0.
	1799	* @returns days. -1 on error;
	1800	* @param pszDate ISO Date.
	1801	*/
	1802	signed long _System dbDateToDaysAfterChrist(const char *pszDate)
	1803	{
	1804	signed long lRet = -1;
	1805	char szQuery[128];
	1806
	1807	sprintf(&szQuery[0], "SELECT to_days('%s')", pszDate);
	1808	if (mysql_query(pmysql, &szQuery[0]) >= 0)
	1809	{
	1810	MYSQL_ROW row;
	1811	MYSQL_RES *pres = mysql_use_result(pmysql);
	1812	row = mysql_fetch_row(pres);
	1813	if (row != NULL)
	1814	{
	1815	lRet = atol(row[0]);
	1816	do { row = mysql_fetch_row(pres); } while (row != NULL);
	1817	}
	1818	}
	1819
	1820	return lRet;
	1821	}
	1822
	1823
	1824	/**
	1825	* Converts days after Christ (year 0) to ISO date.
	1826	* @returns Success indicator. TRUE/FALSE;
	1827	* @param lDays Days after Christ (year 0).
	1828	* @param pszDate ISO Date. Result.
	1829	*/
	1830	BOOL _System dbDaysAfterChristToDate(signed long lDays, char *pszDate)
	1831	{
	1832	BOOL fRet = FALSE;
	1833	char szQuery[128];
	1834
	1835	if (lDays < 0)
	1836	return FALSE;
	1837
	1838	sprintf(&szQuery[0], "SELECT from_days(%ld)", lDays);
	1839	if (mysql_query(pmysql, &szQuery[0]) >= 0)
	1840	{
	1841	MYSQL_ROW row;
	1842	MYSQL_RES *pres = mysql_use_result(pmysql);
	1843	row = mysql_fetch_row(pres);
	1844	if (row != NULL)
	1845	{
	1846	fRet = strlen(row[0]) == (4+1+2+1+2) && row[0][4] == '-' && row[0][7] == '-'
	1847	&& strcmp(row[0], "0000-00-00") != 0;
	1848	if (fRet)
	1849	strcpy(pszDate, row[0]);
	1850	do { row = mysql_fetch_row(pres); } while (row != NULL);
	1851	}
	1852	}
	1853
	1854	return fRet;
	1855	}
	1856
	1857
[2759]	1858	/**
[6678]	1859	* Display all functions for, the given dll, that is not updated.
[2759]	1860	* @returns TRUE / FALSE.
[6678]	1861	* @param lDll Dll reference number.
[2759]	1862	* @param dbFetchCall Callback function which will be called once for each
	1863	* field for all the functions not updated.
	1864	* pvUser is NULL, pszValue field value, pszFieldName the field name.
	1865	*/
[6678]	1866	BOOL _System dbGetNotUpdatedFunction(signed long lDll, DBCALLBACKFETCH dbFetchCallBack)
[2759]	1867	{
	1868	BOOL fRet = FALSE;
	1869	void *pres;
[2765]	1870	char szQuery[256];
[2759]	1871
	1872	/* not updated names */
[2765]	1873	sprintf(&szQuery[0], "SELECT f1.name, f1.intname, f1.updated, f1.aliasfn, d.name, f2.name, f2.intname AS last "
	1874	"FROM function f1 LEFT OUTER JOIN function f2 ON f1.aliasfn = f2.refcode "
[6678]	1875	" LEFT JOIN dll d ON f2.dll = d.refcode "
	1876	"WHERE f1.dll = %ld AND f1.updated = 0",
	1877	lDll);
[2759]	1878	pres = dbExecuteQuery(szQuery);
	1879	if (pres != NULL)
	1880	{
	1881	BOOL f;
	1882	do
	1883	{
	1884	f = dbFetch(pres, dbFetchCallBack, NULL);
	1885	} while (f);
	1886	dbFreeResult(pres);
	1887	fRet = TRUE;
	1888	}
	1889
	1890	/* warn about updated > 1 too */
[2765]	1891	sprintf(&szQuery[0], "SELECT f1.name, f1.intname, f1.updated, f1.aliasfn, d.name, f2.name, f2.intname AS last "
	1892	"FROM function f1 LEFT OUTER JOIN function f2 ON f1.aliasfn = f2.refcode "
[6678]	1893	" LEFT JOIN dll d ON f2.dll = d.refcode "
	1894	"WHERE f1.dll = %ld AND f1.updated > 1",
	1895	lDll);
[2759]	1896	pres = dbExecuteQuery(szQuery);
	1897	if (pres != NULL)
	1898	{
	1899	BOOL f;
	1900	do
	1901	{
	1902	f = dbFetch(pres, dbFetchCallBack, NULL);
	1903	} while (f);
	1904	dbFreeResult(pres);
	1905	fRet = TRUE;
	1906	}
	1907
[2761]	1908	strcpy(&szQuery[0], "UPDATE function SET updated = 0");
[2759]	1909	mysql_query(pmysql, &szQuery[0]);
	1910
	1911	return fRet;
	1912	}
	1913
	1914
[2765]	1915	/**
[6678]	1916	* Counts the function for the given DLL which has been updated.
	1917	* @returns -1 on error, number of updated function on success.
	1918	* @param lDll Dll reference number.
[2765]	1919	*/
[6678]	1920	signed long _System dbGetNumberOfUpdatedFunction(signed long lDll)
[2765]	1921	{
	1922	int rc;
	1923	char szQuery[128];
	1924	MYSQL_RES * pres;
	1925
[6678]	1926	sprintf(&szQuery[0], "SELECT count(*) FROM function WHERE dll = (%ld) AND updated > 0\n", lDll);
[2765]	1927	rc = mysql_query(pmysql, &szQuery[0]);
	1928	pres = mysql_store_result(pmysql);
	1929	if (rc >= 0 && pres != NULL && mysql_num_rows(pres) == 1)
	1930	rc = (int)getvalue(0, mysql_fetch_row(pres));
	1931	else
	1932	rc = -1;
	1933	mysql_free_result(pres);
	1934	return (signed long)rc;
	1935	}
	1936
	1937
[3882]	1938
[2818]	1939	/**
[6678]	1940	* Clear the update flags for all file in a dll/module.
	1941	* @returns Success indicator. (TRUE / FALSE)
	1942	* @param lDll Dll refcode.
	1943	* @author knut st. osmundsen (knut.stange.osmundsen@mynd.no)
	1944	* @remark Intended for use by APIImport.
[3882]	1945	*/
[6678]	1946	BOOL _System dbClearUpdateFlagFile(signed long lDll)
[3882]	1947	{
	1948	int rc;
	1949	char szQuery[128];
	1950
	1951	sprintf(&szQuery[0],
[6678]	1952	"UPDATE file SET updated = 0 WHERE dll = (%ld)",
	1953	lDll);
[3882]	1954	rc = mysql_query(pmysql, &szQuery[0]);
	1955	return rc == 0;
	1956	}
	1957
	1958
	1959	/**
	1960	* Clear update flag
[6678]	1961	* @returns Success indicator.
	1962	* @param lDll Dll refcode.
	1963	* @param fAll All dll. If false only APIs and Internal APIs are cleared
	1964	* @author knut st. osmundsen (knut.stange.osmundsen@mynd.no)
	1965	* @remark Intended for use by APIImport.
[3882]	1966	*/
[6678]	1967	BOOL _System dbClearUpdateFlagFunction(signed long lDll, BOOL fAll)
[3882]	1968	{
	1969	int rc;
	1970	char szQuery[128];
	1971
	1972	sprintf(&szQuery[0],
[6678]	1973	"UPDATE function SET updated = 0 WHERE dll = (%ld)",
	1974	lDll);
[3882]	1975	if (!fAll)
	1976	strcat(&szQuery[0], " AND type IN ('A', 'I')");
	1977	rc = mysql_query(pmysql, &szQuery[0]);
	1978	return rc == 0;
	1979	}
	1980
	1981
	1982
	1983	/**
[6678]	1984	* Deletes all the files in a dll/module which was not found/updated.
[3882]	1985	* @returns Success indicator.
[6678]	1986	* @param lDll Dll refcode.
[3882]	1987	* @sketch Select all files which is to be deleted.
	1988	* Set all references to each file in function to -1.
	1989	* Delete all files which is to be deleted.
	1990	* @author knut st. osmundsen (knut.stange.osmundsen@mynd.no)
	1991	* @remark Use with GRATE CARE!
	1992	*/
[6678]	1993	BOOL _System dbDeleteNotUpdatedFiles(signed long lDll)
[3882]	1994	{
	1995	MYSQL_RES * pres;
	1996	int rc;
	1997	BOOL fRc = TRUE;
	1998	char szQuery[128];
	1999
	2000	sprintf(&szQuery[0],
[6678]	2001	"SELECT refcode FROM file WHERE dll = (%ld) AND updated = 0",
	2002	lDll);
[3882]	2003	rc = mysql_query(pmysql, &szQuery[0]);
	2004	pres = mysql_store_result(pmysql);
	2005	if (pres != NULL && mysql_num_rows(pres))
	2006	{
	2007	MYSQL_ROW row;
	2008	while ((row = mysql_fetch_row(pres)) != NULL)
	2009	{
	2010	sprintf(&szQuery[0],
	2011	"UPDATE function SET file = -1 WHERE file = %s",
	2012	row[0]);
	2013	rc = mysql_query(pmysql, &szQuery[0]);
	2014	if (rc) fRc = FALSE;
	2015	}
	2016	}
	2017
	2018	sprintf(&szQuery[0],
[6678]	2019	"DELETE FROM file WHERE dll = %ld AND updated = 0",
	2020	lDll);
[3882]	2021	rc = mysql_query(pmysql, &szQuery[0]);
	2022	if (rc) fRc = FALSE;
	2023
	2024	return fRc;
	2025	}
	2026
	2027
	2028	/**
	2029	* Deletes all the functions which haven't been updated.
	2030	* All rows in other tables which references the functions are
	2031	* also delete.
	2032	*
	2033	* @returns Success indicator. (TRUE / FALSE)
[6678]	2034	* @param lDll The refcode of the dll owning the functions.
	2035	* @param fAll All function. If FALSE then only APIs and Internal APIs.
	2036	* @sketch Select all functions which wan't updated (ie. updated = 0 and dll = lDll).
[3899]	2037	* If anyone Then
[3882]	2038	* Delete the referenced to the functions in:
	2039	* parameters
	2040	* fnauthor
[3899]	2041	* Delete all function which wasn't updated.
	2042	* EndIf
[3882]	2043	* @remark Use with GREATE CARE!
	2044	*/
[6678]	2045	BOOL _System dbDeleteNotUpdatedFunctions(signed long lDll, BOOL fAll)
[3882]	2046	{
	2047	MYSQL_RES * pres;
	2048	int rc;
	2049	BOOL fRc = TRUE;
	2050	char szQuery[128];
	2051
	2052	sprintf(&szQuery[0],
[6678]	2053	"SELECT refcode FROM function WHERE dll = %ld AND updated = 0",
	2054	lDll);
[3882]	2055	if (!fAll)
	2056	strcat(&szQuery[0], " AND type IN ('A', 'I')");
	2057	rc = mysql_query(pmysql, &szQuery[0]);
	2058	pres = mysql_store_result(pmysql);
[3899]	2059
[3882]	2060	if (pres != NULL && mysql_num_rows(pres))
	2061	{
	2062	MYSQL_ROW row;
	2063	while ((row = mysql_fetch_row(pres)) != NULL)
	2064	{
	2065	/* delete parameters */
[3944]	2066	sprintf(&szQuery[0], "DELETE FROM parameter WHERE function = %s", row[0]);
[3882]	2067	rc = mysql_query(pmysql, &szQuery[0]);
	2068	if (rc) fRc = FALSE;
	2069
	2070	/* author relations */
[3944]	2071	sprintf(&szQuery[0], "DELETE FROM fnauthor WHERE function = %s", row[0]);
[3882]	2072	rc = mysql_query(pmysql, &szQuery[0]);
	2073	if (rc) fRc = FALSE;
	2074	}
[3899]	2075
	2076	/*
	2077	* Delete the functions only if above completed without errors.
	2078	*
	2079	* Deleting the functions before all the references has successfully be
	2080	* deleted causes database corruption!
	2081	*/
	2082	if (fRc)
	2083	{
	2084	sprintf(&szQuery[0],
[6678]	2085	"DELETE FROM function WHERE dll = %ld AND updated = 0",
	2086	lDll);
[3899]	2087	if (!fAll)
	2088	strcat(&szQuery[0], " AND type IN ('A', 'I')");
	2089	rc = mysql_query(pmysql, &szQuery[0]);
	2090	if (rc) fRc = FALSE;
	2091	}
[3882]	2092	}
	2093
	2094	return fRc;
	2095	}
	2096
	2097
	2098
	2099	/**
[3838]	2100	* Appends a set of strings to a query. The main string (pszStr) is enclosed in "'"s.
[2818]	2101	* @returns Pointer to end of the string.
	2102	* @param pszQuery Outputbuffer
	2103	* @param pszBefore Text before string, might be NULL.
	2104	* @param pszStr String (NOT NULL)
	2105	* @param pszAfter Text after, might be NULL.
	2106	* @status completely implemented
	2107	* @author knut st. osmundsen (knut.stange.osmundsen@pmsc.no)
	2108	*/
	2109	static char sqlstrcat(char pszQuery, const char pszBefore, const char pszStr, const char *pszAfter)
	2110	{
[3882]	2111	char * pszLineStart = pszQuery;
[3848]	2112	register char ch;
[2818]	2113
	2114	pszQuery += strlen(pszQuery);
	2115
	2116	/*
	2117	* String before
	2118	*/
	2119	if (pszBefore != NULL)
	2120	{
	2121	strcpy(pszQuery, pszBefore);
	2122	pszQuery += strlen(pszQuery);
	2123	}
	2124
	2125	/*
	2126	* THE String
	2127	*/
	2128	*pszQuery++ = '\'';
	2129	while ((ch = *pszStr++) != '\0')
	2130	{
[3848]	2131	switch (ch)
[3838]	2132	{
[3848]	2133	case '\'':
	2134	*pszQuery++ = '\\';
	2135	*pszQuery++ = '\'';
	2136	break;
	2137
	2138	case '"':
	2139	*pszQuery++ = '\\';
	2140	*pszQuery++ = '"';
	2141	break;
	2142
	2143	case '\\':
	2144	*pszQuery++ = '\\';
	2145	*pszQuery++ = '\\';
	2146	break;
	2147
	2148	case '%':
	2149	*pszQuery++ = '\\';
	2150	*pszQuery++ = '%';
	2151	break;
	2152
	2153	case '_':
	2154	*pszQuery++ = '\\';
	2155	*pszQuery++ = '_';
	2156	break;
	2157
	2158	case '\n':
	2159	*pszQuery++ = '\\';
	2160	*pszQuery++ = 'r';
	2161	*pszQuery++ = '\\';
	2162	*pszQuery++ = 'n';
	2163	break;
[3882]	2164
[3848]	2165	case '\t':
	2166	*pszQuery++ = '\\';
	2167	*pszQuery++ = 't';
	2168	break;
	2169
	2170	case '\r':
	2171	break;
	2172
	2173	default:
	2174	*pszQuery++ = ch;
[3838]	2175	}
[3848]	2176
	2177	/* Add new lines every 80 chars MySql don't like long lines. */
	2178	if (pszLineStart - pszQuery > 80)
[3838]	2179	{
[3848]	2180	*pszQuery = '\n';
	2181	pszLineStart = pszQuery;
[3838]	2182	}
[2818]	2183	}
	2184	*pszQuery++ = '\'';
	2185
	2186	/*
	2187	* String after
	2188	*/
	2189	if (pszAfter != NULL)
	2190	{
	2191	strcpy(pszQuery, pszAfter);
	2192	pszQuery += strlen(pszQuery);
	2193	}
	2194	else
	2195	*pszQuery = '\0';
	2196
	2197
	2198	return pszQuery;
	2199	}
	2200
	2201
[2761]	2202	#ifndef DLL
[830]	2203	/**
	2204	* Signal handler.
	2205	* Ensures that the database connection is closed at termination.
	2206	* @param sig Signal number.
	2207	*/
	2208	void dbHandler(int sig)
	2209	{
	2210	if (pmysql != NULL)
	2211	{
	2212	fprintf(stderr, "\n\t!disconnecting from database!\n");
	2213	dbDisconnect();
	2214	}
	2215
	2216	flushall();
	2217	switch (sig)
	2218	{
	2219	case SIGBREAK:
	2220	printf("\nSIGBREAK\n");
	2221	exit(-1);
	2222	break;
	2223	case SIGINT:
	2224	printf("\nSIGINT\n");
	2225	exit(-1);
	2226	break;
	2227	case SIGTERM:
	2228	printf("\nSIGTERM\n");
	2229	exit(-1);
	2230	break;
	2231	case SIGSEGV:
	2232	raise(sig);
	2233	break;
	2234	case SIGILL:
	2235	printf("\nSIGILL\n");
	2236	exit(-1);
	2237	break;
	2238	}
	2239	}
	2240
	2241
	2242	#else
	2243	/*******/
	2244	/* DLL */
	2245	/*******/
	2246	/* prototypes used in the _DLL_InitTerm function */
	2247	extern "C"
	2248	{
	2249	int _CRT_init(void);
	2250	void _CRT_term(void);
	2251	void __ctordtorInit( void );
	2252	void __ctordtorTerm( void );
	2253	unsigned long _System _DLL_InitTerm(unsigned long hModule, unsigned long ulFlag);
	2254	}
	2255
	2256
	2257	/**
	2258	* Dll InitTerm function.
	2259	* @returns 0 on success.
	2260	* 1 on error.
	2261	* @param hModule
	2262	* @param ulFlags
	2263	* @remark We'll ensure that the database connection is terminated as we terminate.
	2264	*/
	2265	unsigned long _System _DLL_InitTerm(unsigned long hModule, unsigned long ulFlag)
	2266	{
	2267	/-------------------------------------------------------------------------/
	2268	/* If ulFlag is zero then the DLL is being loaded so initialization should */
	2269	/* be performed. If ulFlag is 1 then the DLL is being freed so */
	2270	/* termination should be performed. */
	2271	/-------------------------------------------------------------------------/
	2272
	2273	switch (ulFlag)
	2274	{
	2275	case 0:
	2276	if (_CRT_init() == -1)
	2277	return 0;
	2278	__ctordtorInit();
	2279	break;
	2280
	2281	case 1:
	2282	/* ensure that db connection is terminated */
	2283	if (pmysql != NULL)
	2284	{
	2285	fprintf(stderr, "\n\t!disconnecting from database!\n");
	2286	dbDisconnect();
	2287	}
	2288	__ctordtorTerm();
	2289	break;
	2290
	2291	default:
	2292	return 0;
	2293	}
	2294	hModule = hModule;
	2295	return 1;
	2296	}
	2297
	2298	/*****************************************************************/
	2299	/* -why is this terminate function referenced but not defined??? */
	2300	/* and where is it referenced??? */
	2301	/* -Probably an export missing from the libraries. */
	2302	/*****************************************************************/
	2303	void terminate(void)
	2304	{
	2305	DosPutMessage(0, sizeof("terminate")-1, "terminate");
	2306	exit(-1);
	2307	}
	2308
	2309	/****************************************/
	2310	/* EMX run-time trouble */
	2311	/* _environ is missing when using -Zomf */
	2312	/****************************************/
	2313	char **_environ = environ;
	2314
	2315	#endif

Note: See TracBrowser for help on using the repository browser.

Download in other formats: