cgi_data.c File Reference

#include "cgi.h"

Include dependency graph for cgi_data.c:

Go to the source code of this file.

Functions
int	SkipLines (FILE *in, size_t lines)
int	DoesFileMatchForm (CGINameValue *data, CGINameValue *hdr)
CGINameValue *	_loaddbheader (FILE *f, int extra)
void	WriteXML (FILE *f, CGINameValue *data)
int	SaveDataToXML (CGINameValue *data, char *filename, int *pos)
int	DatabaseOpen (char *filename, FILE **database, CGINameValue **header, int extra, int rw)
int	DatabaseReset (FILE *database)
int	DatabaseFFD (FILE *database, int skiprecords)
void	ResetList (CGINameValue *v)
int	DatabaseDeleteRecord (char *database, int record)
void	UnfixQuotes (char *c)
void	FixQuotes (CGINameValue *v)
int	DatabaseReadRecord (FILE *database, CGINameValue *v, int *flags)
void	WriteValue (HANDLE file, char *c)
int	DatabaseSaveIndex (char *indexfile, CGINameValue *Params, int pos)
int	DatabaseSaveNewRecord (char *filename, CGINameValue *v, int *pos)
void	DatabaseClose (FILE *database, CGINameValue *header)
char *	FindEndChar (char *text, char start, char finish)
int	CreateDatabase (CGINameValue *data, char *filename)
int	SaveDataToASC (CGINameValue *data, char *filename, int *pos)

---

Function Documentation

CGINameValue* _loaddbheader (  FILE *  f, int  extra )

record index starts with 1. record 0 refers to the header. A new array structure is returned. Remember to use See also: DeleteNVP Definition at line 69 of file cgi_data.c. References CGIFCLOSE, DeleteNVP(), MAXBUF, CGINameValue::name, NewNVP(), ReadUntilChar(), strdup(), and CGINameValue::value. Referenced by DatabaseOpen(). { char name[MAXBUF]; int c; size_t x; size_t fieldcount = 0; CGINameValue*v, *i; do { c = ReadUntilChar(f,name,MAXBUF,"\t\n",'\r'); fieldcount++; if (c == EOF) /* the header needs to be LF terminated! */ { CGIFCLOSE(f); return 0; } } while (c != '\r' && c != '\n'); if (fieldcount == 1 && *name == 0) return 0; /* create a structure to hold the values */ v = NewNVP(fieldcount+extra); i = v; for (x = fieldcount; x < fieldcount + extra; x++) {v[x].name = strdup(""); v[x].value = strdup(""); } /* reopen the file at the beginning */ #ifdef __WINCE__ fseek(f,0,SEEK_SET); #else rewind(f); #endif /* read the fieldnames into the structure */ do { char * d; c = ReadUntilChar(f,name,MAXBUF,"\t\n",'\r'); d = strchr(name,'\r'); if (d) *d = 0; /* just in case we opened it in binary mode */ i->name = strdup((name[0] == '#') ? name+1 : name); i++; fieldcount --; if (c == EOF) { CGIFCLOSE(f); DeleteNVP(v); return 0; } } while (c != '\r' && c != '\n' && fieldcount); return v; }

int CreateDatabase (  CGINameValue *  data, char *  filename )

Definition at line 922 of file cgi_data.c. References CGIFOPEN, CGINameValue::name, NULLSTR, and stricmp(). Referenced by SaveDataToASC(). { char * lastfieldname=NULLSTR; register int x ; FILE* handle; char * c; /*File does not exist, so we save fieldnames. Appends to the data file*/ handle=CGIFOPEN(filename,"ab+"); if (handle ==0) { return 4; } for(x=0; data[x].name ; x++) { c = data[x].name; if (!*c) continue; if (stricmp(lastfieldname,c)) { if (*lastfieldname) fwrite("\t",1,1,handle); fwrite(c,1,strlen(c),handle); } lastfieldname=c; } fwrite("\r\n",2,1,handle); CGIFCLOSE(handle); /* done! */ return 0; /* success */ }

void DatabaseClose (  FILE *  database, CGINameValue *  header )

Frees memory allocated for database and header, if non-null. Definition at line 911 of file cgi_data.c. References CGIFCLOSE, and DeleteNVP(). Referenced by CGImain(), DatabaseSaveIndex(), DatabaseSaveNewRecord(), JSHasRecord(), LoadUserDataASC(), and Login(). { if (database) CGIFCLOSE(database); if (header) DeleteNVP(header); }

int DatabaseDeleteRecord (  char *  database, int  record )

Returns 0 on success. May return error code 15. Definition at line 355 of file cgi_data.c. References CGIFCLOSE, CGIFOPEN, and NULL. {/* can't use CGIFOPEN for writing, since it would truncate the data */ char c; int count = 0; #ifdef __WINCE__ FILE* f = CGIFOPEN(database,"r+"); if (f == NULL) return 7; while (count < record) { if (fread(&c,1,1,f) != 1) {CGIFCLOSE(f); return 15;} if (c == '\n') count ++; } fread(&c,1,1,f); if (c == '\n') return 0; /* can't delete an empty row, sorry */ fseek(f,-1,SEEK_CUR); if (fwrite("#",1,1,f) != 1) {CGIFCLOSE(f); return 15;} CGIFCLOSE(f); #else int f = open(database,O_RDWR); if (f < 0) return 7; while (count < record) { if (read(f,&c,1) != 1) {close(f); return 15;} if (c == '\n') count ++; } read(f,&c,1); if (c == '\n') return 0; /* can't delete an empty row, sorry */ lseek(f,-1,SEEK_CUR); if (write(f,"#",1) != 1) { close(f);return 15;} close(f); #endif /* deletes a row from the database. Minor data loss. */ /* if the first row is named STATUS, everything will work great! */ return 0; }

int DatabaseFFD (  FILE *  database, int  skiprecords )

Definition at line 332 of file cgi_data.c. References DatabaseReset(), and SkipLines(). Referenced by CGImain(). { if (skiprecords < 0) return DatabaseReset(database); if (skiprecords == 0) return 0; return SkipLines(database,skiprecords); }

int DatabaseOpen (  char *  filename, FILE **  database, CGINameValue **  header, int  extra, int  rw )

Definition at line 294 of file cgi_data.c. References _loaddbheader(), CGIFCLOSE, CGIFOPEN, DATABASE, and NULL. Referenced by CGImain(), DatabaseSaveIndex(), DatabaseSaveNewRecord(), EZSReport(), JSHasRecord(), LoadUserDataASC(), and Login(). { /*char newname[MAXPATH]; */ DATABASE * file; int ret; #ifdef __BORLANDC__ file = CGIFOPEN(filename,"rb+"); /* open a buffered file in text mode*/ #else file = CGIFOPEN(filename,rw ? "rb+" : "rb"); /* open a buffered file in text mode*/ #endif if (database) { *database = file; } if (file == NULL) { if (header) *header = 0; ret = 0; } else { CGINameValue * v = _loaddbheader(file,extra); if (header) *header = v; ret = v ? 1 : 0; if (database == NULL) CGIFCLOSE(file); } return ret; }

int DatabaseReadRecord (  FILE *  database, CGINameValue *  v, int *  flags )

When reading data, it uses FixQuotes() to remove leading/trailing quotes and convert doubled quotes to single quotes. The file pointer is advanced to the next record. v comes from DatabaseOpen(). Definition at line 449 of file cgi_data.c. References CGIFREE, CGIMALLOC, FixQuotes(), MAXDATA, CGINameValue::name, NULL, ReadUntilChar(), ResetList(), strdup(), UnfixQuotes(), and CGINameValue::value. Referenced by CGImain(), DatabaseFindFast(), DatabaseFindNextRecord(), LoadUserDataASC(), and PrintRecords(). { int c = 0; char*d = 0; char *data = 0; int any = 0; data = CGIMALLOC(MAXDATA); if (flags) *flags = 0; if (data == NULL) return 0; ResetList(v); /* clear the record, just to be sure */ do { if (v->name == NULL) /* end of header, but not end of line? */ { /* finish off the line and continue */ ReadUntilChar(database,0,0,"\n",0); break; } c = ReadUntilChar(database,data,MAXDATA,"\t\n",'\r'); d = strchr(data,'\r'); if (d != NULL) *d = 0; /* just in case we opened it in binary mode */ if (any == 0 && flags != NULL) { switch (data[0]) { case 0 : *flags = 2; if (*data) if (strstr(data+1,"\"\t")) data[0]='\"'; break; case '#': *flags = 1; if (*data) if (strstr(data+1,"\"\t")) data[0]='\"'; break; default: *flags = 0; } } if (*data) { v->value = strdup(data); if (v->value[0] == '\"') UnfixQuotes(v->value); any = 1; } v++; if (c == EOF ) /* premature end of file */ { CGIFREE(data); if (any) FixQuotes(v); return any; } } while (c != '\n'); CGIFREE(data); if (any) FixQuotes(v); return any; }

int DatabaseReset (  FILE *  database  )

Definition at line 322 of file cgi_data.c. References SkipLines(). Referenced by DatabaseFFD(). { #ifdef __WINCE__ fseek(database,0,SEEK_SET); #else rewind(database); #endif return SkipLines(database,1); }

int DatabaseSaveIndex (  char *  indexfile, CGINameValue *  Params, int  pos )

Definition at line 568 of file cgi_data.c. References CGIFOPEN, DatabaseClose(), DatabaseOpen(), GetFieldValue, and NULL. { FILE * indexdb; CGINameValue * indexheader; int ret = 0; if (DatabaseOpen(indexfile,&indexdb,&indexheader,0,0)) { FILE* ndx; DatabaseClose(indexdb,NULL); ndx = CGIFOPEN(indexfile,"ab"); if (ndx) { size_t i; for ( i=0; indexheader[i].name; i++) { if (!strcmp(indexheader[i].name,"_POS")) { fprintf(ndx,"%d",pos); } else { fprintf(ndx,"\"%s\"\t",GetFieldValue(Params,indexheader[i].name)); } } fprintf(ndx,"\n"); fclose(ndx); } else ret = 9; DatabaseClose(NULL,indexheader); } return ret; }

int DatabaseSaveNewRecord (  char *  filename, CGINameValue *  v, int *  pos )

Uses WriteValue() to save data in a quoted, tab-delimited file. Linefeeds and newlines are removed, but data inside quotes can have tabs, and Excel 97 will read it fine. Definition at line 605 of file cgi_data.c. References BufferWriteL(), DatabaseClose(), DatabaseOpen(), MAXPATH, CGINameValue::name, NewBuffer(), NULLSTR, stricmp(), CGINameValue::value, and WriteValue(). Referenced by SaveDataToASC(). { int x,y; CGINameValue * header; char *c, * lastfieldname; int ret = 0, writecomma; #ifdef XP_WIN HANDLE fh; DWORD written=0; #ifndef VPWSCGI HANDLE Mutex; #endif #else TextBuffer * buf; int fh; static struct flock myLock ; #endif if (!DatabaseOpen(filename,0,&header,0,0)) { /*LogError("\nTried to read a data file, failed: "); LogError(filename);*/ return 2; } /* do this early to minimize the time the file is open if (!DoesFileMatchForm(v, header)) ret = 5; */ /* personal web server is single-threaded, no need for file locks */ #if defined(XP_WIN) && !defined(VPWSCGI) { #ifdef UNICODE wchar_t Mutex_name[MAXPATH+1]; ToWideChar(_filename,strlen(_filename),Mutex_name,MAXPATH); #else char Mutex_name[MAXPATH+1]; strncpy(Mutex_name,filename,MAXPATH); #endif Mutex_name[MAXPATH] = 0; for (x=0; Mutex_name[x]; x++) if (Mutex_name[x] == '\\') Mutex_name[x] = '/'; Mutex = CreateMutex(0,FALSE,Mutex_name); /* wait up to 20 seconds */ if(Mutex) if ( WaitForSingleObject(Mutex,20000) == WAIT_TIMEOUT) { CloseHandle(Mutex); DatabaseClose(0,header); return 23; } } #endif #ifdef XP_WIN /* binary mode, direct write */ #ifdef __WINCE__ { wchar_t fn[MAXPATH+1]; ToWideChar(filename,strlen(filename),fn,MAXPATH+1); fh = CreateFileW(fn,GENERIC_READ|GENERIC_WRITE,FILE_SHARE_READ|FILE_SHARE_WRITE,0,OPEN_EXISTING,FILE_ATTRIBUTE_NORMAL,0); } #else fh = CreateFileA(filename,GENERIC_READ|GENERIC_WRITE,FILE_SHARE_READ|FILE_SHARE_WRITE,0,OPEN_EXISTING,FILE_FLAG_SEQUENTIAL_SCAN,0); #endif if (fh == INVALID_HANDLE_VALUE) { #if !defined(VPWSCGI) if (Mutex) CloseHandle(Mutex); #endif x = GetLastError(); return 6; } x = SetFilePointer(fh,0,0,FILE_END); #else fh = open(filename,O_WRONLY|O_APPEND); if (fh == -1) { return 6; } #endif /* Wait for a file lock to become available */ #ifdef XP_POSIX myLock.l_type = F_WRLCK ; myLock.l_start = 0 ; myLock.l_whence = SEEK_END ; myLock.l_len = 0 ; myLock.l_pid = getpid() ; fcntl(fh, F_SETLKW, &myLock); #endif if (pos) { #ifdef XP_WIN *pos = x; #else *pos = lseek(fh,0,SEEK_END); #endif } #ifndef XP_WIN buf = NewBuffer(16384); #endif for(x=0; header[x].name; x++) { /* if two consecutive questions have the same fieldname, append their data together */ if (!header[x].name[0]) continue; /*don't write empty fieldnames */ #ifdef XP_WIN WriteFile(fh,"\"",1,&written,0); #else BufferWriteL(buf,"\"",1); /* write(fh,"\"",1); */ #endif y = 0; lastfieldname = NULLSTR; writecomma = 0; while (v[y].name) { if (v[y].name[0] && stricmp(header[x].name,v[y].name)==0) {/*write this entry*/ c = v[y].value; if ( c && *c ) { if (*lastfieldname && writecomma) #ifdef XP_WIN WriteFile(fh,",",1,&written,0); WriteValue(fh,c); #else BufferWriteL(buf,",",1); WriteValue(buf,c); /* write(fh,",",1); WriteValue(fh,c); */ #endif if (*c) writecomma = 1; } lastfieldname=header[x].name; } y++; } #ifdef XP_WIN WriteFile(fh,"\"\t",2,&written,0); #else BufferWriteL(buf,"\"\t",2); /*write(fh,"\"\t",2); */ #endif } #ifdef XP_WIN WriteFile(fh,"\r\n",2,&written,0); #else BufferWriteL(buf,"\r\n",2); /*write(fh,"\r\n",2);*/ #endif #if defined(XP_WIN) && !defined(VPWSCGI) if (Mutex) { ReleaseMutex(Mutex); CloseHandle(Mutex); } #endif #ifndef XP_WIN c = CopyBuffer(buf); x = lseek(fh,0,SEEK_END); if (pos) *pos = x; write(fh,c,BufferSize(buf)); free(c); DeleteBuffer(buf); #endif #ifdef XP_POSIX myLock.l_type = F_UNLCK; fcntl(fh, F_SETLKW, &myLock); #endif #ifdef XP_WIN CloseHandle(fh); #else close(fh); #endif DatabaseClose(0,header); return ret; }

int DoesFileMatchForm (  CGINameValue *  data, CGINameValue *  hdr )

Writes any missing fields in the log file. Fields beginning with _ are ones that we add for our convenience and don't have to be saved. Definition at line 42 of file cgi_data.c. References GetField(), HasTokenI(), LogError(), and NULL. { int x; if (hdr == NULL) return 0; for (x=0; (data[x].name != NULL); x++) { if (data[x].name[0] == 0) continue; if (data[x].name[0] == '_') continue; if (HasTokenI("HOST,DATE,TIME",data[x].name,0)) continue; if (data[x].value == 0) continue; if (data[x].value[0] == 0) continue; /* don't require fields that we add to save */ if (GetField(hdr, data[x].name) == NULL) { LogError("\nCGI_DATA: data file missing the field: "); LogError(data[x].name); return 0; } } return 1; }

char* FindEndChar (  char *  text, char  start, char  finish )

Referenced by EvaluateAlgebra().

void FixQuotes (  CGINameValue *  v  )

Definition at line 421 of file cgi_data.c. References NULL, and CGINameValue::value. Referenced by DatabaseReadRecord(). { int x; for (x=0; v[x].name; x++) { if (v[x].value == NULL) continue; if (v[x].value[0] == '\"') { int a=1,b=0; while (v[x].value[a]) { v[x].value[b] = v[x].value[a]; if (v[x].value[a] == '\"') { if (v[x].value[a+1] == '\"') a++; else break; } a++; b++; } v[x].value[b] = 0; } } }

void ResetList (  CGINameValue *  v  )

Definition at line 339 of file cgi_data.c. References CGIFREE, CGINameValue::name, NULL, and CGINameValue::value. Referenced by DatabaseReadRecord(). { for (; v->name; v++) { #ifdef CGIFREE CGIFREE(v->value); #else if (v->value != NULL) { CGIFREE(v->value); v->value = NULL; } #endif } }

int SaveDataToASC (  CGINameValue *  data, char *  filename, int *  pos )

Adds a new record to the database Definition at line 952 of file cgi_data.c. References CGIFCLOSE, CGIFOPEN, CreateDatabase(), and DatabaseSaveNewRecord(). { #if 0 int x; FILE* handle; /* Check to see if file exists*/ handle=CGIFOPEN(filename,"rb"); if ( handle == 0 ) { x = CreateDatabase(data,filename); if (x) return x; /* that should ensure that the file exists, now open it in append mode*/ } else { CGIFCLOSE(handle); } #endif return DatabaseSaveNewRecord(filename,data,pos); }

int SaveDataToXML (  CGINameValue *  data, char *  filename, int *  pos )

Adds a new record to the database Definition at line 198 of file cgi_data.c. References CGIFCLOSE, CGIFOPEN, MAXPATH, NULL, swapchars(), and WriteXML(). { FILE* f = NULL; #ifndef __WINCE__ int fh; #endif #ifdef XP_POSIX static struct flock myLock ; #endif #if defined(XP_WIN) && !defined(VPWSCGI) HANDLE Mutex; char Mutex_name[MAXPATH+1]; #endif /* #ifndef __WINCE__ if (access(filename,2)) return 6; #endif */ #if defined(XP_WIN) && !defined(VPWSCGI) strncpy(Mutex_name,filename,MAXPATH); Mutex_name[MAXPATH] = 0; swapchars(Mutex_name, '\\', '/'); Mutex = CreateMutex(0,FALSE,Mutex_name); /* wait up to 20 seconds */ if (Mutex) if (WaitForSingleObject(Mutex,20000) == WAIT_TIMEOUT) { CloseHandle(Mutex); return 23; } #endif #ifdef __WINCE__ f = CGIFOPEN(filename,"ab"); #else fh = open(filename,O_WRONLY|O_APPEND); if (fh != -1) { f = fdopen(fh,"ab"); } #endif if (!f) return 8; /* Wait for a file lock to become available */ #ifdef XP_POSIX myLock.l_type = F_WRLCK ; myLock.l_start = 0 ; myLock.l_whence = SEEK_END ; myLock.l_len = 0 ; myLock.l_pid = getpid() ; fcntl(fh, F_SETLKW, &myLock); #endif if (pos) *pos = ftell(f); WriteXML(f,data); #ifdef XP_POSIX myLock.l_type = F_UNLCK; fcntl(fh, F_SETLKW, &myLock); #endif #if defined(XP_WIN) && !defined(VPWSCGI) if (Mutex) { ReleaseMutex(Mutex); CloseHandle(Mutex); } #endif CGIFCLOSE(f); return 0; }

int SkipLines (  FILE *  in, size_t  lines )

Definition at line 26 of file cgi_data.c. Referenced by DatabaseFFD(), and DatabaseReset(). { char c; int skipped =0; while (lines && fread(&c,1,1,in)>0 ) { if (c == '\n') {lines--; skipped++;} } if (lines) return 0; return skipped; }

void UnfixQuotes (  char *  c  )

Definition at line 400 of file cgi_data.c. Referenced by DatabaseReadRecord(). { char * d = c; if (!strcmp(c,"\"\"")) { c[0] = 0; return; } while (*c) { if (c[0] == '\"') c++; *d = *c; d++; if (*c) c++; } }

void WriteValue (  HANDLE  file, char *  c )

Quotes get doubled and linefeeds ge stripped Definition at line 508 of file cgi_data.c. Referenced by DatabaseSaveNewRecord(). { size_t len; DWORD written=0; while (*c) { if (*c == '\"') WriteFile(file,"\"",1,&written,0); if (*c != '\n' && *c != '\r') { len = strcspn(c+1,"\""); WriteFile(file,c,1+len,&written,0); c += len; } c++; } }

void WriteXML (  FILE *  f, CGINameValue *  data )

Generates an XML TRANSACTION tag from data. Links are expected to be seen as parentfield_number_childfield Definition at line 127 of file cgi_data.c. References CGIFREE, CGINameValue::name, NULL, strdup(), and stricmp(). Referenced by SaveDataToXML(). { int i; char * currentchild = NULL; int currentitem = -1; fprintf(f,"<TRANSACTION>"); for(i=0;data[i].name;i++) /* skip host, date, time */ { char * c; int inchild = 0; char* name; if (!data[i].name[0]) continue; if (data[i].name[0] == '_') continue; name = data[i].name; c = strchr(name,'_'); if (c) if (strchr(c+2,'_')) if (strchr("1234567890",c[1])) /* item_1_name */ { int thisitem; int newobj = 0; char* newchild = strdup(name); inchild = 1; c = strchr(newchild,'_'); thisitem = atoi(c+1); name = strchr(c+2,'_'); if (name) name++; c[0] = 0; if (thisitem != currentitem || stricmp(currentchild,newchild)) { newobj = 1; currentitem = thisitem; } if (newobj && currentchild) fprintf(f,"</%s>\n",currentchild); if (name) { if (currentchild) CGIFREE(currentchild); currentchild = newchild; if (newobj) fprintf(f,"<%s id=%d>\n",currentchild,thisitem); } else name=data[1].name; } if (inchild == 0 && currentchild) { fprintf(f,"</%s>\n",currentchild); if (currentchild) CGIFREE(currentchild); currentchild = NULL; } fprintf(f,"<%s>%s</%s>\n",name,data[i].value,name); } if (currentchild) printf("</%s>\n",currentchild); if (currentchild) CGIFREE(currentchild); fprintf(f,"</TRANSACTION>\n"); }

Raosoft EZReport, EZSurvey, InterForm, RapidReport, Raosoft, and SurveyWin are registered trademarks of Raosoft, Inc. Page contents © 1996-2007 by Raosoft, Inc. You may use and modify this file for your own use, but may not distribute it or derivative works without the prior written consent of Raosoft, Inc. This software is provided "as is," and Raosoft makes no warranty, express or implied, of fitness for a particular application. Every measure has been taken to anticipate risks inherent to computer networks, but we cannot guarantee safety or reliability of this program in every situation.

Tel: 206-525-4025 (US) Email: raosoft@raosoft.com
http://www.raosoft.com/