File: api8.c

package info (click to toggle)
firebird3.0 3.0.13.ds7-2
  • links: PTS, VCS
  • area: main
  • in suites: forky, sid
  • size: 42,632 kB
  • sloc: ansic: 374,403; cpp: 319,973; sql: 14,691; pascal: 14,532; yacc: 7,557; fortran: 5,645; sh: 5,336; makefile: 1,041; perl: 194; sed: 83; awk: 76; xml: 19; csh: 15
file content (181 lines) | stat: -rw-r--r-- 4,855 bytes parent folder | download | duplicates (16)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
/*
 *    Program type:  API Interface
 *
 *    Description:
 *        This program updates a blob data type.
 *        Project descriptions are added for a set of projects.
 * The contents of this file are subject to the Interbase Public
 * License Version 1.0 (the "License"); you may not use this file
 * except in compliance with the License. You may obtain a copy
 * of the License at http://www.Inprise.com/IPL.html
 *
 * Software distributed under the License is distributed on an
 * "AS IS" basis, WITHOUT WARRANTY OF ANY KIND, either express
 * or implied. See the License for the specific language governing
 * rights and limitations under the License.
 *
 * The Original Code was created by Inprise Corporation
 * and its predecessors. Portions created by Inprise Corporation are
 * Copyright (C) Inprise Corporation.
 *
 * All Rights Reserved.
 * Contributor(s): ______________________________________.
 */


#include <stdlib.h>
#include <string.h>
#include <ibase.h>
#include <stdio.h>
#include "example.h"

#define PROJLEN     5
#define BUFLEN      512

char *    get_line (void);

static char *Proj_data[] =
{
    "VBASE",
        "Design a video data base management system for ",
        "controlling on-demand video distribution.",
        0,
    "DGPII",
        "Develop second generation digital pizza maker ",
        "with flash-bake heating element and ",
        "digital ingredient measuring system.",
        0,
    "GUIDE",
        "Develop a prototype for the automobile version of ",
        "the hand-held map browsing device.",
        0,
    "MAPDB",
        "Port the map browsing database software to run ",
        "on the automobile model.",
        0,
    "HWRII",
        "Integrate the hand-writing recognition module into the ",
        "universal language translator.",
        0,
    0
};

int Inp_ptr = 0;

int main (int argc, char** argv)
{
    char                proj_id[PROJLEN + 1];
    char                upd_stmt[BUFLEN + 1];
    ISC_QUAD            blob_id;
    isc_blob_handle     blob_handle = NULL;
    isc_db_handle       DB = NULL;           /* database handle */
    isc_tr_handle       trans = NULL;        /* transaction handle */
    ISC_STATUS_ARRAY    status;              /* status vector */
    XSQLDA *            sqlda;
    unsigned short      len;
    char *              line;
    int                 rec_cnt = 0;
    char                empdb[128];

    if (argc > 1)
        strcpy(empdb, argv[1]);
    else
        strcpy(empdb, "employee.fdb");

    strcpy(upd_stmt, "UPDATE project SET proj_desc = ? WHERE proj_id = ?");

    if (isc_attach_database(status, 0, empdb, &DB, 0, NULL))
        isc_print_status(status);

    /*
     *  Set-up the SQLDA for the update statement.
     */

    sqlda = (XSQLDA *) malloc(XSQLDA_LENGTH(2));
    sqlda->sqln = 2;
    sqlda->sqld = 2;
    sqlda->version = 1;

    sqlda->sqlvar[0].sqldata = (char *) &blob_id;
    sqlda->sqlvar[0].sqltype = SQL_BLOB;
    sqlda->sqlvar[0].sqllen  = sizeof(ISC_QUAD);

    sqlda->sqlvar[1].sqldata = proj_id;
    sqlda->sqlvar[1].sqltype = SQL_TEXT;
    sqlda->sqlvar[1].sqllen  = 5;

    if (isc_start_transaction(status, &trans, 1, &DB, 0, NULL))
        isc_print_status(status);

    /*
     *  Get the next project id and update the project description.
     */
    line = get_line();
    while (line)
    {
        strcpy(proj_id, line);
        printf("\nUpdating description for project:  %s\n\n", proj_id);

        blob_handle = 0;
        if (isc_create_blob(status, &DB, &trans, &blob_handle, &blob_id))
        {
            ERREXIT(status, 1)
        }
        line = get_line();
        while (line)
        {
            printf("  Inserting segment:  %s\n", line);
            len = (unsigned short)strlen(line);

            if (isc_put_segment(status, &blob_handle, len, line))
            {
                ERREXIT (status, 1)
            }
            line = get_line();
        }

        if (isc_close_blob(status, &blob_handle))
        {
            ERREXIT(status, 1)
        }

        if (isc_dsql_execute_immediate(status, &DB, &trans, 0, upd_stmt, 1,
                                       sqlda))
        {
            ERREXIT (status, 1)
        }

        if (isc_sqlcode(status) == 0)
            rec_cnt++;
        else
            printf("Input error -- no project record with key: %s\n", proj_id);
        line = get_line();
    }
  
    if (isc_rollback_transaction (status, &trans))
    {
        ERREXIT(status, 1)
    }
    printf("\n\nAdded %d project descriptions.\n", rec_cnt);

    if (isc_detach_database(status, &DB))
    {
        ERREXIT(status, 1)
    }

    free(sqlda);

    return 0;
}


/*
 *    Get the next input line, which is either a project id
 *    or a project description segment.
 */

char *get_line (void)
{
    return Proj_data[Inp_ptr++];
}