#define _CRT_SECURE_NO_WARNINGS
#include <iostream>
#include <stdio.h>  
#include <stdlib.h>  
#include <string.h>  

#include "example.h"
#include "ibase.h"
#include "Timer.cpp"

isc_db_handle db;
ISC_STATUS status_vector[20];
short dpb_buf_len = 20;
char dpb_buf[] = {
                                isc_dpb_version1,                //версия буфера   
                                isc_dpb_user_name,                //начинается кластер параметра имя пользователя  
                                6,                                 //длина этого параметра 6 байт  
                                'S','Y','S','D','B','A',                //строка имени пользователя  
                                isc_dpb_password,                //начинается кластер пароля пользователя  
                                9,                                 //длина его 9 байт  
                                'm','a','s','t','e','r','k','e','y'        //сам пароль  
};

#define COUNTRYLEN 15
#define CODELEN    5

const char* sel_str = "SELECT FIRST_NAME, PHOTO FROM CH";

/* Blob parameter buffer. */
const char bpb[9] = {1, 2, 2, -4, -1, 1, 2, 1, 0};

int setenv(const char* name, const char* value, int overwrite)
{
    int errcode = 0;
    if (!overwrite) {
        size_t envsize = 0;
        errcode = getenv_s(&envsize, NULL, 0, name);
        if (errcode || envsize) return errcode;
    }
    return _putenv_s(name, value);
}

int main()
{

    setenv("ISC_USER", "sysdba", 0);
    setenv("ISC_PASSWORD", "masterkey", 0);
	
    char                first_name[CODELEN + 2];
    short               flag0 = 0, flag1 = 0;
    ISC_QUAD            blob_id;
    isc_blob_handle     blob_handle = NULL;
    short               blob_seg_len;
    char                blob_segment[65400];
    isc_db_handle       DB = NULL;
    isc_tr_handle       trans = NULL;
    ISC_STATUS_ARRAY    status;
    isc_stmt_handle     stmt = NULL;
    XSQLDA* sqlda;
    long                fetch_stat;
    char                empdb[128];

	
	
    strcpy(empdb, "C:\\test3.fdb");

    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(2));
    sqlda->sqln = 4;
    sqlda->version = 1;

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

    sqlda->sqlvar[0].sqldata = (char*)first_name;
    sqlda->sqlvar[0].sqltype = SQL_TEXT + 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;

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

    /*
     *  Display job descriptions.
     */

    Timer timer;
    timer.start();

    while ((fetch_stat = isc_dsql_fetch(status, &stmt, 1, sqlda)) == 0)
    {
        printf("\nFirst Name: %5s\n", first_name);

        /* Open the blob with the fetched blob_id. */
        if (isc_open_blob2(status, &DB, &trans, &blob_handle, &blob_id, 0, NULL))
        {
            ERREXIT(status, 1)
        }

        /* Get blob segments and their lengths and print each segment. */
        while (isc_get_segment(status, &blob_handle,
            (unsigned short*)&blob_seg_len, sizeof(blob_segment),
            blob_segment) == 0)
            printf("  %*.*s", blob_seg_len, blob_seg_len, blob_segment);

        /* Close the blob.  */
        if (status[1] == isc_segstr_eof)
        {
            if (isc_close_blob(status, &blob_handle))
            {
                ERREXIT(status, 1)
            }
        }
        else
            isc_print_status(status);

        printf("\n");
    }

    timer.stop();

    std::cout << timer.elapsedMilliseconds();

    //std::cout << timer.getCurrDelta();

    if (fetch_stat != 100L)
        isc_print_status(status);

    if (isc_dsql_free_statement(status, &stmt, DSQL_drop))
    {
        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;
}