#include <windows.h>
#include <commctrl.h>
#include <process.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <ctype.h>
#include <wsqllib.h>
#include <winlib/winlib.h>

#include "sqlbase.h"
#include "dbinit.h"
#include "dbroutes.h"
#include "dbutil.h"
#include "sqlcmd.h"


void OrderBy(VARS *v)
{
       char *p;

       if ((p = GetInput(v->hwndMain, "Order By", v->order, 300)))
               strcpy(v->order, p);
}


void Search(void *arg)
{
       SQLRESULT *newRow, *prevRow = NULL;
       SQLRESFIELD *rf, *newField, *prevField;
       MYSQL_ROW row;
       int i, fc, first;
       char *p, *s;
       SQLFIELD *f;
       HWND focus;
       VARS *v = (VARS*)arg;

       v->sqlCmdActive = TRUE;

       ShowStatus(v->hwndStatus, 0, "Processing...");

       sprintf(v->buf, "SELECT * FROM %s", v->table);

       first = 1;

       for (i = 0, f = v->fields; i < v->nFields;
                       i++, f = f->next) {
               s = GetText(v, i);
               if (strlen(s)) {
                       if (! first)
                               strcat(v->buf, " AND ");
                       else
                               strcat(v->buf, " WHERE ");
                       first = 0;
                       sprintf(v->buf2, "%s LIKE '%s'", f->name, s);
                       strcat(v->buf, v->buf2);
               }
       }

       sprintf(v->buf2, " ORDER BY %s", v->order);
       strcat(v->buf, v->buf2);

       if (! SQLQuery(0, v->buf))
               goto end;

   while (v->result) {
       rf = v->result->fields;
               while (rf) {
                       free(rf->data);
                       p = (char*)rf;
                       rf = rf->next;
                       free(p);
               }
               p = (char*)v->result;
               v->result = v->result->next;
               free(p);
   }

       v->numRows = 0;
       while ((row = SQLFetchRow(0))) {
               newRow = malloc(sizeof(SQLRESULT));
               newRow->fields = prevField = NULL;

               for (i = 0; i < v->nFields; i++) {
                       newField = malloc(sizeof(SQLRESFIELD));
                       newField->next = NULL;

                       if (row[i] == NULL)
                               newField->data = NewString("");
                       else
                               newField->data = NewString(row[i]);

                       if (! newRow->fields)
                               newRow->fields = newField;
                       if (prevField)
                               prevField->next = newField;
                       prevField = newField;
               }

               newRow->next = NULL;
               if (! v->result)
               v->result = newRow;
               if (prevRow)
               prevRow->next = newRow;
               prevRow = newRow;
               v->numRows++;
       }

       SQLEndQuery(0);

       ShowStatus(v->hwndStatus, 0, "");
       if (! v->numRows) {
               ShowStatus(v->hwndStatus, 0, "No rows found");
               goto end;
       }

       v->rowNum = 0;
       SetFields(v);

end:
       v->sqlCmdActive = FALSE;
}


void AddRow(VARS *v)
{
       int empty = 1;
       int i, first;
       char *s;

       if (Empty(v))
               return;

       if (! Prompt(v->hwndMain, "Add Row", "Add row?", 1))
               return;

       sprintf(v->buf, "INSERT INTO %s VALUES (", v->table);

       first = 1;
       for (i = 0; i < v->nFields; i++) {
               if (! first)
                       strcat (v->buf, ", ");
               first = 0;
               s = GetText(v, i);
               sprintf(v->buf2, "'%s'", s);
               strcat(v->buf, v->buf2);
       }
       strcat(v->buf, ")");

       SQLQuery(0, v->buf);
}


void DeleteRow(VARS *v)
{
       char *p;
       int i, first;
       SQLFIELD *f;
       SQLRESULT *row, *prevRow = NULL;
       SQLRESFIELD *rf;
       char *s;

       if (! v->result)
               return;

       if (Empty(v))
               return;

       if (! Prompt(v->hwndMain, "Delete Row", "Delete row?", 0))
               return;

       sprintf(v->buf, "DELETE FROM %s WHERE ", v->table);

       first = 1;
       for (i = 0, f = v->fields; i < v->nFields;
                       i++, f = f->next) {
               s = GetText(v, i);
               if (strlen(s)) {
                       if (! first)
                               strcat(v->buf, " AND ");
                       first = 0;
                       sprintf(v->buf2, "%s='%s'", f->name, s);
                       strcat(v->buf, v->buf2);
               }
       }

       if (! SQLQuery(0, v->buf))
               return;

   for (i = 0, row = v->result; i < v->rowNum; i++, row = row->next)
               prevRow = row;
   if (prevRow)
               prevRow->next = row->next;
   else
               v->result = v->result->next;

       rf = row->fields;
       while (rf) {
               free(rf->data);
               p = (char*)rf;
               rf = rf->next;
               free(p);
       }
       free(row);
       v->numRows--;

       if (v->rowNum > 0)
               v->rowNum--;

       if (v->numRows)
               SetFields(v);
       else
               ClearFields(v);
}


void UpdateRow(VARS *v)
{
       char *p;
       int i, first;
       SQLFIELD *f;
       SQLRESULT *row, *newRow, *prevRow = NULL;
       SQLRESFIELD *rf, *newField, *prevField;
       char *s;

       if (! v->result)
               return;

       if (Empty(v))
               return;

       if (! Prompt(v->hwndMain, "Update Row", "Update row?", 1))
               return;

       sprintf(v->buf, "UPDATE %s SET ", v->table);

       first = 1;
       for (i = 0, f = v->fields; i < v->nFields;
                       i++, f = f->next) {
               s = GetText(v, i);
               if (! first)
                       strcat(v->buf, ", ");
               first = 0;
               sprintf(v->buf2, "%s='%s'", f->name, s);
               strcat(v->buf, v->buf2);
       }

       strcat(v->buf, " WHERE ");

       for (i = 0, row = v->result; i < v->rowNum; i++)
               row = row->next;

       first = 1;
       for (i = 0, f = v->fields, rf = row->fields;
                       i < v->nFields;
                       i++, f = f->next, rf = rf->next) {
               s = rf->data;
               if (strlen(s)) {
                       if (! first)
                               strcat(v->buf, " AND ");
                       first = 0;
                       sprintf(v->buf2, "%s='%s'", f->name, s);
                       strcat(v->buf, v->buf2);
               }
       }

       if (! SQLQuery(0, v->buf))
               return;

       newRow = malloc(sizeof(SQLRESULT));
       newRow->fields = prevField = NULL;

       for (i = 0; i < v->nFields; i++) {
               newField = malloc(sizeof(SQLRESFIELD));
               newField->next = NULL;

               s = GetText(v, i);
               newField->data = NewString(s);

               if (! newRow->fields)
                       newRow->fields = newField;
               if (prevField)
                       prevField->next = newField;
               prevField = newField;
       }

   for (i = 0, row = v->result; i < v->rowNum; i++, row = row->next)
               prevRow = row;

       newRow->next = row->next;
   if (prevRow)
               prevRow->next = newRow;
   else
               v->result = newRow;

       rf = row->fields;
       while (rf) {
               free(rf->data);
               p = (char*)rf;
               rf = rf->next;
               free(p);
       }
       free(row);
}

You are viewing proxied material from bitreich.org. The copyright of proxied material belongs to its original authors. Any comments or complaints in relation to proxied material should be directed to the original authors of the content concerned. Please see the disclaimer for more details.