home *** CD-ROM | disk | FTP | other *** search
/ Java 1.2 How-To / JavaHowTo.iso / 3rdParty / jbuilder / TRIAL / INTRBASE / DATA.Z / api8.c < prev    next >
Encoding:
C/C++ Source or Header  |  1998-03-15  |  4.3 KB  |  167 lines
  1. /*
  2.  *    Program type:  API Interface
  3.  *
  4.  *    Description:
  5.  *        This program updates a blob data type.
  6.  *        Project descriptions are added for a set of projects.
  7.  */
  8.  
  9.  
  10. #include <stdlib.h>
  11. #include <string.h>
  12. #include <ibase.h>
  13. #include <stdio.h>
  14. #include "example.h"
  15.  
  16. #define PROJLEN     5
  17. #define BUFLEN      512
  18.  
  19. char ISC_FAR*    get_line PROTO((void));
  20.  
  21. static char *Proj_data[] =
  22. {
  23.     "VBASE",
  24.         "Design a video data base management system for ",
  25.         "controlling on-demand video distribution.",
  26.         0,
  27.     "DGPII",
  28.         "Develop second generation digital pizza maker ",
  29.         "with flash-bake heating element and ",
  30.         "digital ingredient measuring system.",
  31.         0,
  32.     "GUIDE",
  33.         "Develop a prototype for the automobile version of ",
  34.         "the hand-held map browsing device.",
  35.         0,
  36.     "MAPDB",
  37.         "Port the map browsing database software to run ",
  38.         "on the automobile model.",
  39.         0,
  40.     "HWRII",
  41.         "Integrate the hand-writing recognition module into the ",
  42.         "universal language translator.",
  43.         0,
  44.     0
  45. };
  46.  
  47. int Inp_ptr = 0;
  48.  
  49. int main (ARG(int, argc), ARG(char **, argv))
  50. ARGLIST(int argc)
  51. ARGLIST(char **argv)                         
  52. {
  53.     char                proj_id[PROJLEN + 1];
  54.     char                upd_stmt[BUFLEN + 1];
  55.     ISC_QUAD            blob_id;
  56.     isc_blob_handle     blob_handle = NULL;
  57.     isc_db_handle       DB = NULL;           /* database handle */
  58.     isc_tr_handle       trans = NULL;        /* transaction handle */
  59.     long                status[20];          /* status vector */
  60.     XSQLDA ISC_FAR    * sqlda;
  61.     unsigned short      len;
  62.     char ISC_FAR*       line;
  63.     int                 rec_cnt = 0;
  64.     char                empdb[128];
  65.  
  66.     if (argc > 1)
  67.         strcpy(empdb, argv[1]);
  68.     else
  69.         strcpy(empdb, "employee.gdb");
  70.  
  71.     strcpy(upd_stmt, "UPDATE project SET proj_desc = ? WHERE proj_id = ?");
  72.  
  73.     if (isc_attach_database(status, 0, empdb, &DB, 0, NULL))
  74.         isc_print_status(status);
  75.  
  76.     /*
  77.      *  Set-up the SQLDA for the update statement.
  78.      */
  79.  
  80.     sqlda = (XSQLDA ISC_FAR *) malloc(XSQLDA_LENGTH(2));
  81.     sqlda->sqln = 2;
  82.     sqlda->sqld = 2;
  83.     sqlda->version = 1;
  84.  
  85.     sqlda->sqlvar[0].sqldata = (char ISC_FAR *) &blob_id;
  86.     sqlda->sqlvar[0].sqltype = SQL_BLOB;
  87.     sqlda->sqlvar[0].sqllen  = sizeof(ISC_QUAD);
  88.  
  89.     sqlda->sqlvar[1].sqldata = proj_id;
  90.     sqlda->sqlvar[1].sqltype = SQL_TEXT;
  91.     sqlda->sqlvar[1].sqllen  = 5;
  92.  
  93.     if (isc_start_transaction(status, &trans, 1, &DB, 0, NULL))
  94.         isc_print_status(status);
  95.  
  96.     /*
  97.      *  Get the next project id and update the project description.
  98.      */
  99.     line = get_line();
  100.     while (line)
  101.     {
  102.         strcpy(proj_id, line);
  103.         printf("\nUpdating description for project:  %s\n\n", proj_id);
  104.  
  105.         blob_handle = 0;
  106.         if (isc_create_blob(status, &DB, &trans, &blob_handle, &blob_id))
  107.         {
  108.             ERREXIT(status, 1)
  109.         }
  110.         line = get_line();
  111.         while (line)
  112.         {
  113.             printf("  Inserting segment:  %s\n", line);
  114.             len = (unsigned short)strlen(line);
  115.  
  116.             if (isc_put_segment(status, &blob_handle, len, line))
  117.             {
  118.                 ERREXIT (status, 1)
  119.             }
  120.             line = get_line();
  121.         }
  122.  
  123.         if (isc_close_blob(status, &blob_handle))
  124.         {
  125.             ERREXIT(status, 1)
  126.         }
  127.  
  128.         if (isc_dsql_execute_immediate(status, &DB, &trans, 0, upd_stmt, 1,
  129.                                        sqlda))
  130.         {
  131.             ERREXIT (status, 1)
  132.         }
  133.  
  134.         if (isc_sqlcode(status) == 0)
  135.             rec_cnt++;
  136.         else
  137.             printf("Input error -- no project record with key: %s\n", proj_id);
  138.         line = get_line();
  139.     }
  140.   
  141.     if (isc_rollback_transaction (status, &trans))
  142.     {
  143.         ERREXIT(status, 1)
  144.     }
  145.     printf("\n\nAdded %d project descriptions.\n", rec_cnt);
  146.  
  147.     if (isc_detach_database(status, &DB))
  148.     {
  149.         ERREXIT(status, 1)
  150.     }
  151.  
  152.     free(sqlda);
  153.  
  154.     return 0;
  155. }
  156.  
  157.  
  158. /*
  159.  *    Get the next input line, which is either a project id
  160.  *    or a project description segment.
  161.  */
  162.  
  163. char *get_line PROTO ((void))
  164. {
  165.     return Proj_data[Inp_ptr++];
  166. }
  167.