/*
 *  Program type:  API Interface
 *
 *    Description:
 *      This program selects a blob data type.
 *      A set of project descriptions is printed.
 * 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 TYPELEN        12
#define PROJLEN        20
#define BUFLEN        512

/* This macro is used to declare structures representing SQL VARCHAR types */
#define SQL_VARCHAR(len) struct {short vary_length; char vary_string[(len)+1];}

int main (int argc, char** argv)
{
    SQL_VARCHAR(PROJLEN + 2)    proj_name;
    char                        prod_type[TYPELEN + 2];
    char                        sel_str[BUFLEN + 1];
    ISC_QUAD                    blob_id;
    isc_blob_handle             blob_handle = NULL;
    short                       blob_seg_len;
    char                        blob_segment[11];
    isc_db_handle               DB = NULL;        /* database handle */
    isc_tr_handle               trans = NULL;     /* transaction handle */
    ISC_STATUS_ARRAY            status;           /* status vector */
    isc_stmt_handle             stmt = NULL;      /* statement handle */
    XSQLDA *                    sqlda;
    long                        fetch_stat, blob_stat;
    short                       flag0 = 0,
                                flag1 = 0,
                                flag2 = 0;
    char                        empdb[128];

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


    strcpy(sel_str, "SELECT proj_name, proj_desc, product FROM project WHERE \
           product IN ('software', 'hardware', 'other') ORDER BY proj_name");

    if (isc_attach_database(status, 0, empdb, &DB, 0, NULL))
    {
        ERREXIT(status, 1)
    }

    if (isc_start_transaction(status, &trans, 1, &DB, 0, NULL))
    {
        ERREXIT(status, 1)
    }

    /*
     *    Allocate and prepare the select statement.
     */

    if (isc_dsql_allocate_statement(status, &DB, &stmt))
    {
        ERREXIT(status, 1)
    }
    
    sqlda = (XSQLDA *) malloc(XSQLDA_LENGTH(3));
    sqlda->sqln = 3;
    sqlda->version = 1;

    if (isc_dsql_prepare(status, &trans, &stmt, 0, sel_str, 1, sqlda))
    {
        ERREXIT(status, 1)
    }

    sqlda->sqlvar[0].sqldata = (char *)&proj_name;
    sqlda->sqlvar[0].sqltype = SQL_VARYING + 1;
    sqlda->sqlvar[0].sqlind  = &flag0;

    sqlda->sqlvar[1].sqldata = (char *) &blob_id;
    sqlda->sqlvar[1].sqltype = SQL_BLOB + 1;
    sqlda->sqlvar[1].sqlind  = &flag1;

    sqlda->sqlvar[2].sqldata = prod_type;
    sqlda->sqlvar[2].sqltype = SQL_TEXT + 1;
    sqlda->sqlvar[2].sqlind  = &flag2;

    if (isc_dsql_execute(status, &trans, &stmt, 1, NULL))
    {
        ERREXIT(status, 1)
    }

    /*
     *    For each project in the select statement, get and display
     *    project descriptions.
     */

    while ((fetch_stat = isc_dsql_fetch(status, &stmt, 1, sqlda)) == 0)
    {
        prod_type[TYPELEN] = '\0';
        printf("\nPROJECT:  %-20.*s   TYPE:  %-15s\n\n",
               proj_name.vary_length, proj_name.vary_string, prod_type);

        /* Open the blob with the fetched blob_id.   Notice that the
        *  segment length is shorter than the average segment fetched.
        *  Each partial fetch should return isc_segment.
        */
        if (isc_open_blob(status, &DB, &trans, &blob_handle, &blob_id))
        {
            ERREXIT(status, 1)
        }

        /* Get blob segments and their lengths and print each segment. */
        blob_stat = isc_get_segment(status, &blob_handle,
                                    (unsigned short *) &blob_seg_len,
                                    sizeof(blob_segment), blob_segment);
        while (blob_stat == 0 || status[1] == isc_segment)
        {
            printf("%*.*s", blob_seg_len, blob_seg_len, blob_segment);
            blob_stat = isc_get_segment(status, &blob_handle,
                                        (unsigned short *)&blob_seg_len,
                                        sizeof(blob_segment), blob_segment);
        }
        /* Close the blob.  Should be blob_stat to check */
        if (status[1] == isc_segstr_eof)
        {
            if (isc_close_blob(status, &blob_handle))
            {
                ERREXIT(status, 1)
            }
        }
        else
            isc_print_status(status);

        printf("\n");
    }

    if (fetch_stat != 100L)
    {
        ERREXIT(status, 1)
    }

    if (isc_dsql_free_statement(status, &stmt, DSQL_close))
    {
        ERREXIT(status, 1)
    }

    if (isc_commit_transaction (status, &trans))
    {
        ERREXIT(status, 1)
    }

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

    free(sqlda);

    return 0;
}