compat_informix-test_informix2.c File Reference

#include <ecpglib.h>
#include <ecpgerrno.h>
#include <sqlca.h>
#include <ecpg_informix.h>
#include <stdio.h>
#include <stdlib.h>
#include "sqltypes.h"

Include dependency graph for compat_informix-test_informix2.c:

Go to the source code of this file.

Data Structures
struct	sqlca_t

Macros
#define	ECPGdebug(X, Y)   ECPGdebug((X)+100,(Y))
#define	POSTGRES_SQLCA_H
#define	PGDLLIMPORT
#define	SQLERRMC_LEN   150
#define	sqlca   (*ECPGget_sqlca())

Functions
struct sqlca_t *	ECPGget_sqlca (void)
static void	sql_check (const char *fn, const char *caller, int ignore)
int	main (void)

Macro Definition Documentation

ECPGdebug

#define ECPGdebug	(		X,
			Y
	)		ECPGdebug((X)+100,(Y))

Definition at line 9 of file compat_informix-test_informix2.c.

PGDLLIMPORT

#define PGDLLIMPORT

Definition at line 25 of file compat_informix-test_informix2.c.

POSTGRES_SQLCA_H

#define POSTGRES_SQLCA_H

Definition at line 19 of file compat_informix-test_informix2.c.

sqlca

#define sqlca   (*ECPGget_sqlca())

Definition at line 76 of file compat_informix-test_informix2.c.

SQLERRMC_LEN

#define SQLERRMC_LEN   150

Definition at line 29 of file compat_informix-test_informix2.c.

Function Documentation

ECPGget_sqlca()

struct sqlca_t* ECPGget_sqlca

(

void

)

Definition at line 108 of file misc.c.

{
    struct sqlca_t *sqlca;
 
    pthread_once(&sqlca_key_once, ecpg_sqlca_key_init);
 
    sqlca = pthread_getspecific(sqlca_key);
    if (sqlca == NULL)
    {
        sqlca = malloc(sizeof(struct sqlca_t));
        if (sqlca == NULL)
            return NULL;
        ecpg_init_sqlca(sqlca);
        pthread_setspecific(sqlca_key, sqlca);
    }
    return sqlca;
}

main()

int main

(

void

)

Definition at line 136 of file compat_informix-test_informix2.c.

{
    /* exec sql begin declare section */
         
         
         
         
         
    
#line 47 "test_informix2.pgc"
 int c ;
 
#line 48 "test_informix2.pgc"
 timestamp d ;
 
#line 49 "test_informix2.pgc"
 timestamp e ;
 
#line 50 "test_informix2.pgc"
 timestamp maxd ;
 
#line 51 "test_informix2.pgc"
 char dbname [ 30 ] ;
/* exec sql end declare section */
#line 52 "test_informix2.pgc"
 
 
    interval *intvl;
 
    /* exec sql whenever sqlerror  stop ; */
#line 56 "test_informix2.pgc"
 
 
    ECPGdebug(1, stderr);
 
    strcpy(dbname, "ecpg1_regression");
    { ECPGconnect(__LINE__, 1, dbname , NULL, NULL , NULL, 0); 
#line 61 "test_informix2.pgc"
 
if (sqlca.sqlcode < 0) exit (1);}
#line 61 "test_informix2.pgc"
 
    sql_check("main", "connect", 0);
 
    { ECPGdo(__LINE__, 1, 1, NULL, 0, ECPGst_normal, "set DateStyle to 'DMY'", ECPGt_EOIT, ECPGt_EORT);
#line 64 "test_informix2.pgc"
 
if (sqlca.sqlcode < 0) exit (1);}
#line 64 "test_informix2.pgc"
 
 
    { ECPGdo(__LINE__, 1, 1, NULL, 0, ECPGst_normal, "create table history ( customerid integer , timestamp timestamp without time zone , action_taken char ( 5 ) , narrative varchar ( 100 ) )", ECPGt_EOIT, ECPGt_EORT);
#line 66 "test_informix2.pgc"
 
if (sqlca.sqlcode < 0) exit (1);}
#line 66 "test_informix2.pgc"
 
    sql_check("main", "create", 0);
 
    { ECPGdo(__LINE__, 1, 1, NULL, 0, ECPGst_normal, "insert into history ( customerid , timestamp , action_taken , narrative ) values ( 1 , '2003-05-07 13:28:34 CEST' , 'test' , 'test' )", ECPGt_EOIT, ECPGt_EORT);
#line 71 "test_informix2.pgc"
 
if (sqlca.sqlcode < 0) exit (1);}
#line 71 "test_informix2.pgc"
 
    sql_check("main", "insert", 0);
 
    { ECPGdo(__LINE__, 1, 1, NULL, 0, ECPGst_normal, "select max ( timestamp ) from history", ECPGt_EOIT, 
    ECPGt_timestamp,&(maxd),(long)1,(long)1,sizeof(timestamp), 
    ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, ECPGt_EORT);
#line 76 "test_informix2.pgc"
 
if (sqlca.sqlcode < 0) exit (1);}
#line 76 "test_informix2.pgc"
 
    sql_check("main", "select max", 100);
 
    { ECPGdo(__LINE__, 1, 1, NULL, 0, ECPGst_normal, "select customerid , timestamp from history where timestamp = $1  limit 1", 
    ECPGt_timestamp,&(maxd),(long)1,(long)1,sizeof(timestamp), 
    ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, ECPGt_EOIT, 
    ECPGt_int,&(c),(long)1,(long)1,sizeof(int), 
    ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, 
    ECPGt_timestamp,&(d),(long)1,(long)1,sizeof(timestamp), 
    ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, ECPGt_EORT);
#line 83 "test_informix2.pgc"
 
if (sqlca.sqlcode < 0) exit (1);}
#line 83 "test_informix2.pgc"
 
    sql_check("main", "select", 0);
 
    printf("Read in customer %d\n", c);
 
    intvl = PGTYPESinterval_from_asc("1 day 2 hours 24 minutes 65 seconds", NULL);
    PGTYPEStimestamp_add_interval(&d, intvl, &e);
    free(intvl);
    c++;
 
    { ECPGdo(__LINE__, 1, 1, NULL, 0, ECPGst_normal, "insert into history ( customerid , timestamp , action_taken , narrative ) values ( $1  , $2  , 'test' , 'test' )", 
    ECPGt_int,&(c),(long)1,(long)1,sizeof(int), 
    ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, 
    ECPGt_timestamp,&(e),(long)1,(long)1,sizeof(timestamp), 
    ECPGt_NO_INDICATOR, NULL , 0L, 0L, 0L, ECPGt_EOIT, ECPGt_EORT);
#line 95 "test_informix2.pgc"
 
if (sqlca.sqlcode < 0) exit (1);}
#line 95 "test_informix2.pgc"
 
    sql_check("main", "update", 0);
 
    { ECPGtrans(__LINE__, NULL, "commit");
#line 98 "test_informix2.pgc"
 
if (sqlca.sqlcode < 0) exit (1);}
#line 98 "test_informix2.pgc"
 
 
    { ECPGdo(__LINE__, 1, 1, NULL, 0, ECPGst_normal, "drop table history", ECPGt_EOIT, ECPGt_EORT);
#line 100 "test_informix2.pgc"
 
if (sqlca.sqlcode < 0) exit (1);}
#line 100 "test_informix2.pgc"
 
    sql_check("main", "drop", 0);
 
    { ECPGtrans(__LINE__, NULL, "commit");
#line 103 "test_informix2.pgc"
 
if (sqlca.sqlcode < 0) exit (1);}
#line 103 "test_informix2.pgc"
 
 
    { ECPGdisconnect(__LINE__, "CURRENT");
#line 105 "test_informix2.pgc"
 
if (sqlca.sqlcode < 0) exit (1);}
#line 105 "test_informix2.pgc"
 
    sql_check("main", "disconnect", 0);
 
    printf("All OK!\n");
 
    exit(0);
 
/*
                 Table "public.history"
    Column    |            Type             | Nullable
--------------+-----------------------------+----------
 customerid   | integer                     | not null
 timestamp    | timestamp without time zone | not null
 action_taken | character(5)                | not null
 narrative    | character varying(100)      |
*/
 
}

References dbname, ECPGconnect(), ECPGdebug, ECPGdisconnect(), ECPGdo(), ECPGst_normal, ECPGt_EOIT, ECPGt_EORT, ECPGt_int, ECPGt_NO_INDICATOR, ECPGt_timestamp, ECPGtrans(), exit(), free, PGTYPESinterval_from_asc(), PGTYPEStimestamp_add_interval(), printf, sql_check(), and sqlca.

sql_check()

static void sql_check ( const char *  fn, const char *  caller, int  ignore  )

static

Definition at line 100 of file compat_informix-test_informix2.c.

{
  char errorstring[255];
 
  if (SQLCODE == ignore)
    return;
  else
  {
    if (SQLCODE != 0)
    {
 
      sprintf(errorstring, "**SQL error %ld doing '%s' in function '%s'. [%s]",
             SQLCODE, caller, fn, sqlca.sqlerrm.sqlerrmc);
      fprintf(stderr, "%s", errorstring);
      printf("%s\n", errorstring);
 
      /* attempt a ROLLBACK */
      { ECPGtrans(__LINE__, NULL, "rollback");}
#line 27 "test_informix2.pgc"
 
 
      if (SQLCODE == 0)
      {
        sprintf(errorstring, "Rollback successful.\n");
      } else {
        sprintf(errorstring, "Rollback failed with code %ld.\n", SQLCODE);
      }
 
      fprintf(stderr, "%s", errorstring);
      printf("%s\n", errorstring);
 
      exit(1);
    }
  }
}

References ECPGtrans(), exit(), fn(), fprintf, printf, sprintf, sqlca, and SQLCODE.

Referenced by main().