From: Michael Meskes <meskes@topsystem.de>

Here's my next patch. this one should fix some more bugs. ecpg now fully
understands the whenever statement.

11 files changed, 242 insertions, 51 deletions

diff --git a/src/interfaces/ecpg/ChangeLog b/src/interfaces/ecpg/ChangeLog
index 017314777e4..ff721fa5013 100644
--- a/src/interfaces/ecpg/ChangeLog
+++ b/src/interfaces/ecpg/ChangeLog
@@ -29,3 +29,12 @@ Mon Feb 16 16:17:21 CET 1998
 
 	- enable initialisation in declare section.
 	- connect call accepts a variable as well. 
+
+Wed Feb 18 21:41:30 CET 1998
+
+	- added whenever statement
+
+Thu Feb 19 12:48:14 CET 1998
+
+	- added do option to whenever statement
+
diff --git a/src/interfaces/ecpg/TODO b/src/interfaces/ecpg/TODO
index 832cd66dab9..3de01c497af 100644
--- a/src/interfaces/ecpg/TODO
+++ b/src/interfaces/ecpg/TODO
@@ -3,7 +3,7 @@ This list is still from Linus. MM
 The variables should be static.
     
 Preprocessor cannot do syntax checking on your SQL statements Whatever you
-write is copied more or less exactly to the postgres95 and you will not be
+write is copied more or less exactly to the PostgreSQL and you will not be
 able to locate your errors until run-time.
     
 No restriction to strings only The PQ interface, and most of all the PQexec
@@ -42,4 +42,6 @@ Now comes my list (MM):
 
 What do we do with enum data types?
 
-'signed' isn't understood so far
+The cursor is opened when the declare statement is issued. 
+
+The is no exec sql prepare statement.
diff --git a/src/interfaces/ecpg/include/ecpglib.h b/src/interfaces/ecpg/include/ecpglib.h
index 1fb35f8dfee..4634b695735 100644
--- a/src/interfaces/ecpg/include/ecpglib.h
+++ b/src/interfaces/ecpg/include/ecpglib.h
@@ -24,4 +24,9 @@ struct ECPGgeneric_varchar {
     char arr[1];
 };
 
+/* print an error message */
+void sqlprint(void);
 
+/* define this for simplicity as well as compatibility */
+
+#define       SQLCODE    sqlca.sqlcode
diff --git a/src/interfaces/ecpg/lib/ecpglib.c b/src/interfaces/ecpg/lib/ecpglib.c
index 9f5911c4774..19ec7f3b69a 100644
--- a/src/interfaces/ecpg/lib/ecpglib.c
+++ b/src/interfaces/ecpg/lib/ecpglib.c
@@ -232,7 +232,7 @@ ECPGdo(int lineno, char *query,...)
 		return false;
 	}
 
-	/* Now then request is built. */
+	/* Now the request is built. */
 
 	if (committed)
 	{
@@ -646,3 +646,10 @@ ECPGlog(const char *format,...)
 		free(f);
 	}
 }
+
+/* print out an error message */
+void sqlprint(void)
+{
+	sqlca.sqlerrm.sqlerrmc[sqlca.sqlerrm.sqlerrml] = '\0';
+	printf ("sql error %s\n", sqlca.sqlerrm.sqlerrmc);
+}
diff --git a/src/interfaces/ecpg/preproc/ecpg.c b/src/interfaces/ecpg/preproc/ecpg.c
index c5d7beeece3..58368eee847 100644
--- a/src/interfaces/ecpg/preproc/ecpg.c
+++ b/src/interfaces/ecpg/preproc/ecpg.c
@@ -54,8 +54,9 @@ main(int argc, char *const argv[])
 		for (fnr = optind; fnr < argc; fnr++)
 		{
 			char	   *filename, *ptr2ext;
+			int	   ext = 0;
 
-			filename = mm_alloc(strlen(argv[fnr]) + 2);
+			filename = mm_alloc(strlen(argv[fnr]) + 4);
 
 			strcpy(filename, argv[fnr]);
 
@@ -63,6 +64,8 @@ main(int argc, char *const argv[])
 			/* no extension or extension not equal .pgc */
 			if (ptr2ext == NULL || strcmp(ptr2ext, ".pgc") != 0)
 			{ 
+				if (ptr2ext == NULL)
+					ext = 1; /* we need this information a while later */
 				ptr2ext = filename + strlen(filename);
 				ptr2ext[0] = '.';
 			}
@@ -82,7 +85,19 @@ main(int argc, char *const argv[])
 				}
 			}
 
-			yyin = fopen(input_filename = argv[fnr], "r");
+			if (ext == 1) 
+			{
+				/* no extension => add .pgc */
+				ptr2ext = strrchr(filename, '.');
+				ptr2ext[1] = 'p';
+				ptr2ext[2] = 'g';
+				ptr2ext[3] = 'c';
+				ptr2ext[4] = '\0';
+				input_filename = filename;
+			}
+			else
+				input_filename = argv[fnr];
+			yyin = fopen(input_filename, "r");
 			if (yyin == NULL)
 				perror(argv[fnr]);
 			else
diff --git a/src/interfaces/ecpg/preproc/extern.h b/src/interfaces/ecpg/preproc/extern.h
index 9a3f9e12b6e..8055e5b07c1 100644
--- a/src/interfaces/ecpg/preproc/extern.h
+++ b/src/interfaces/ecpg/preproc/extern.h
@@ -11,4 +11,4 @@ extern FILE *yyin, *yyout;
 extern void lex_init(void);
 extern char * input_filename;
 extern int yyparse(void);
-extern void *mm_alloc(size_t);
+extern void *mm_alloc(size_t), *mm_realloc(void *, size_t);
diff --git a/src/interfaces/ecpg/preproc/pgc.l b/src/interfaces/ecpg/preproc/pgc.l
index 2f87d6ffd4b..f3def3d2e98 100644
--- a/src/interfaces/ecpg/preproc/pgc.l
+++ b/src/interfaces/ecpg/preproc/pgc.l
@@ -15,25 +15,35 @@ letter	[A-Za-z_]
 digit	[0-9]
 length	{digit}+
 symbol	{letter}({letter}|{digit})*
+label	({letter}|{digit})*
 string	'[^']*'
 
-exec	[eE][xX][eE][cC]
-execute	[eE][xX][eE][cC][uU][tT][eE]
-sql	[sS][qQ][lL]
-varchar	[vV][aA][rR][cC][hH][aA][rR]
-varchar2	[vV][aA][rR][cC][hH][aA][rR]2
-into	[iI][nN][tT][oO]
 begin	[bB][eE][gG][iI][nN]
-end	[eE][nN][dD]
+break   [bB][rR][eE][aA][kK]
+commit  [cC][oO][mM][mM][iI][tT]
+connect [cC][oO][nN][nN][eE][cC][tT]
+continue [cC][oO][nN][tT][iI][nN][uU][eE]
 declare [dD][eE][cC][lL][aA][rR][eE]
-section	[sS][eE][cC][tT][iI][oO][nN]
+do      [dD][oO]
+end	[eE][nN][dD]
+exec	[eE][xX][eE][cC]
+execute	[eE][xX][eE][cC][uU][tT][eE]
+found	[fF][oO][uU][nN][dD]
+goto    [gG][oO][tT][oO]
+immediate [iI][mM][mM][eE][dD][iI][aA][tT][eE]
 include [iI][nN][cC][lL][uU][dD][eE]
-connect [cC][oO][nN][nN][eE][cC][tT]
+into	[iI][nN][tT][oO]
+not	[nN][oO][tT]
 open	[oO][pP][eE][nN]
-commit  [cC][oO][mM][mM][iI][tT]
-immediate [iI][mM][mM][eE][dD][iI][aA][tT][eE]
 release [rR][eE][lL][eE][aA][sS][eE]
 rollback [rR][oO][lL][lL][bB][aA][cC][kK]
+section	[sS][eE][cC][tT][iI][oO][nN]
+sql	[sS][qQ][lL]
+sqlerror [sS][qQ][lL][eE][rR][rR][oO][rR]
+sqlprint [sS][qQ][lL][pP][rR][iI][nN][tT]
+varchar	[vV][aA][rR][cC][hH][aA][rR]
+varchar2	[vV][aA][rR][cC][hH][aA][rR]2
+whenever [wW][hH][eE][nN][eE][vV][eE][rR]
 work    [wW][oO][rR][kK]
 %%
 <C>{exec}{ws}{sql}	{ BEGIN SQL; dbg(SQL_START); return SQL_START; }
@@ -51,8 +61,15 @@ work    [wW][oO][rR][kK]
 <SQL>{release}		{ dbg(SQL_RELEASE); return SQL_RELEASE; }
 <SQL>{work}		{ dbg(SQL_WORK); return SQL_WORK; }
 <SQL>{rollback}		{ dbg(SQL_ROLLBACK); return SQL_ROLLBACK; }
-
+<SQL>{whenever}		{ dbg(SQL_WHENEVER); return SQL_WHENEVER; }
+<SQL>{sqlerror}		{ dbg(SQL_SQLERROR); return SQL_SQLERROR; }
+<SQL>{sqlprint}		{ dbg(SQL_SQLPRINT); return SQL_SQLPRINT; }
+<SQL>{not}{ws}{found}	{ dbg(SQL_NOT_FOUND); return SQL_NOT_FOUND; }
+<SQL>{break}		{ dbg(SQL_BREAK); return SQL_BREAK; }
+<SQL>{continue}		{ dbg(SQL_CONTINUE); return SQL_CONTINUE; }
 <SQL>{into}		{ dbg(SQL_INTO); return SQL_INTO; }
+<SQL>{goto}		{ dbg(SQL_GOTO); return SQL_GOTO; }
+<SQL>{do}		{ dbg(SQL_DO); return SQL_DO; }
 			  
 {length}		{ dbg(S_LENGTH); return S_LENGTH; }
 			  
@@ -67,6 +84,7 @@ double			{ dbg(S_DOUBLE); return S_DOUBLE; }
 bool                    { dbg(S_BOOL); return S_BOOL; }
 
 static			{ dbg(S_STATIC); return S_STATIC; }
+signed			{ dbg(S_SIGNED); return S_SIGNED; }
 extern			{ dbg(S_EXTERN); return S_EXTERN; }
 auto			{ dbg(S_AUTO); return S_AUTO; }
 const			{ dbg(S_CONST); return S_CONST; }
@@ -77,6 +95,7 @@ struct			{ dbg(S_STRUCT); return S_STRUCT; }
 {string}		{ dbg(SQL_STRING); return SQL_STRING; }
 <SQL>{ws}		; 
 {symbol}		{ dbg(S_SYMBOL); return S_SYMBOL; }
+{label}			{ dbg(S_LABEL); return S_LABEL; }
 
 <SQL>"!<"		{ dbg(S_SYMBOL); return S_SYMBOL; }
 <SQL>"!>"		{ dbg(S_SYMBOL); return S_SYMBOL; }
@@ -114,8 +133,10 @@ struct			{ dbg(S_STRUCT); return S_STRUCT; }
 ";"			{ dbg(;); return ';'; }
 "="			{ dbg(=); return '='; }
 ","			{ dbg(komma); return ','; }
+\(			{ dbg(braceopen); return '('; }
+\)			{ dbg(braceclose); return ')'; }
 \{			{ dbg(blockstart); return '{'; }
-\}			{ dbg(blockend); return'}'; }
+\}			{ dbg(blockend); return '}'; }
 \*			{ dbg(*); return('*'); }
 
 <SQL>":"		{ dbg(:); return ':'; }
diff --git a/src/interfaces/ecpg/preproc/preproc.y b/src/interfaces/ecpg/preproc/preproc.y
index 670ea9b8c6a..52b814ac194 100644
--- a/src/interfaces/ecpg/preproc/preproc.y
+++ b/src/interfaces/ecpg/preproc/preproc.y
@@ -14,6 +14,8 @@ static void yyerror(char *);
  */
 int	debugging = 0;
 static int	struct_level = 0;
+static char	*do_str = NULL;
+static int	do_length = 0;
 
 /* temporarily store record members while creating the data structure */
 struct ECPGrecord_member *record_member_list[128] = { NULL };
@@ -23,7 +25,7 @@ struct ECPGrecord_member *record_member_list[128] = { NULL };
  */
 char * input_filename = NULL;
 
-void
+static void
 output_line_number()
 {
     if (input_filename)
@@ -31,6 +33,47 @@ output_line_number()
 }
 
 /*
+ * store the whenever action here
+ */
+static struct when when_error, when_nf;
+
+static void
+print_action(struct when *w)
+{
+	switch (w->code)
+	{
+		case W_CONTINUE: fprintf(yyout, "continue;");
+				 break;
+		case W_BREAK:	 fprintf(yyout, "break;");
+                                 break;
+		case W_SQLPRINT: fprintf(yyout, "sqlprint();");
+                                 break;
+		case W_GOTO:	 fprintf(yyout, "goto %s;", w->str);
+				 break;
+		case W_DO:	 fprintf(yyout, "%s;", w->str);
+				 break;
+		default:	 fprintf(yyout, "{/* not implemented yet */}");
+				 break;
+	}
+}
+
+static void
+whenever_action()
+{
+	if (when_nf.code != W_NOTHING)
+	{
+		fprintf(yyout, "\nif (SQLCODE > 0) ");
+		print_action(&when_nf);
+	}
+	if (when_error.code != W_NOTHING)
+        {
+                fprintf(yyout, "\nif (SQLCODE < 0) ");
+		print_action(&when_error);
+        }
+	output_line_number();
+}
+
+/*
  * Handling of the variables.
  */
 
@@ -176,28 +219,31 @@ dump_variables(struct arguments * list)
     char *			symbolname;
     int				indexsize;
     enum ECPGttype		type_enum;
+    struct when			action;
 }
 
 %token <tagname> SQL_START SQL_SEMI SQL_STRING SQL_INTO
 %token <tagname> SQL_BEGIN SQL_END SQL_DECLARE SQL_SECTION SQL_INCLUDE 
 %token <tagname> SQL_CONNECT SQL_OPEN SQL_EXECUTE SQL_IMMEDIATE
-%token <tagname> SQL_COMMIT SQL_ROLLBACK SQL_RELEASE SQL_WORK
+%token <tagname> SQL_COMMIT SQL_ROLLBACK SQL_RELEASE SQL_WORK SQL_WHENEVER
+%token <tagname> SQL_SQLERROR SQL_NOT_FOUND SQL_BREAK SQL_CONTINUE
+%token <tagname> SQL_DO SQL_GOTO SQL_SQLPRINT
 
-%token <tagname> S_SYMBOL S_LENGTH S_ANYTHING
+%token <tagname> S_SYMBOL S_LENGTH S_ANYTHING S_LABEL
 %token <tagname> S_VARCHAR S_VARCHAR2
-%token <tagname> S_EXTERN S_STATIC S_AUTO S_CONST S_REGISTER S_STRUCT
+%token <tagname> S_EXTERN S_STATIC S_AUTO S_CONST S_REGISTER S_STRUCT S_SIGNED
 %token <tagname> S_UNSIGNED S_SIGNED
 %token <tagname> S_LONG S_SHORT S_INT S_CHAR S_FLOAT S_DOUBLE S_BOOL
-%token <tagname> '[' ']' ';' ',' '{' '}' '=' '*'
+%token <tagname> '[' ']' ';' ',' '{' '}' '=' '*' '(' ')'
 
 %type <type> type type_detailed varchar_type simple_type array_type struct_type
-%type <symbolname> symbol
+%type <symbolname> symbol label
 %type <tagname> maybe_storage_clause varchar_tag db_name
 %type <type_enum> simple_tag
 %type <indexsize> index length
+%type <action> action
 %type <tagname> canything sqlanything both_anything vartext commit_release
 
-
 %%
 prog : statements;
 
@@ -211,6 +257,7 @@ statement : sqldeclaration
 	  | sqlcommit
 	  | sqlrollback
 	  | sqlexecute
+	  | sqlwhenever
 	  | sqlstatement
 	  | cthing
 	  | blockstart
@@ -247,8 +294,18 @@ variable_declaration : type initializer ';'	{
 initializer : /*empty */
 	    | '=' {fwrite(yytext, yyleng, 1, yyout);} vartext;
 
-vartext : both_anything {fwrite(yytext, yyleng, 1, yyout);}
-	| vartext both_anything {fwrite(yytext, yyleng, 1, yyout);}
+vartext : /* empty */ {}
+	| vartext both_anything {
+	if (do_length == 0)
+		fwrite(yytext, yyleng, 1, yyout);
+	else
+	{
+		if (strlen(do_str) + yyleng + 1 >= do_length)
+			do_str = mm_realloc(do_str, do_length += yyleng);
+
+		strcat(do_str, yytext);
+	}
+}
 
 symbol : S_SYMBOL { 
     char * name = (char *)malloc(yyleng + 1);
@@ -351,6 +408,7 @@ simple_tag : S_CHAR { $<type_enum>$ = ECPGt_char; }
 
 maybe_storage_clause : S_EXTERN { fwrite(yytext, yyleng, 1, yyout); }
 		       | S_STATIC { fwrite(yytext, yyleng, 1, yyout); }
+		       | S_SIGNED { fwrite(yytext, yyleng, 1, yyout); }
 		       | S_CONST { fwrite(yytext, yyleng, 1, yyout); }
 		       | S_REGISTER { fwrite(yytext, yyleng, 1, yyout); }
 		       | S_AUTO { fwrite(yytext, yyleng, 1, yyout); }
@@ -369,7 +427,7 @@ filename : cthing
 
 sqlconnect : SQL_START SQL_CONNECT { fprintf(yyout, "ECPGconnect("); }
 	     db_name
-	     SQL_SEMI { fprintf(yyout, ");"); output_line_number();}
+	     SQL_SEMI { fprintf(yyout, ");"); whenever_action();}
 
 db_name : SQL_STRING { fprintf(yyout, "\""); fwrite(yytext + 1, yyleng - 2, 1, yyout); fprintf(yyout, "\""); }
 	| ':' symbol { /* check if we have a char variabnle */
@@ -395,7 +453,7 @@ sqlgarbage : /* Empty */
 
 sqlcommit : SQL_START commit_release SQL_SEMI {
     fprintf(yyout, "ECPGcommit(__LINE__);"); 
-    output_line_number();
+    whenever_action();
 }
 
 commit_release : SQL_COMMIT
@@ -404,7 +462,7 @@ commit_release : SQL_COMMIT
 
 sqlrollback : SQL_START SQL_ROLLBACK SQL_SEMI {
     fprintf(yyout, "ECPGrollback(__LINE__);");
-    output_line_number();
+    whenever_action();
 };
 
 sqlexecute : SQL_START { /* Reset stack */
@@ -415,11 +473,59 @@ sqlexecute : SQL_START { /* Reset stack */
     fprintf(yyout, "\", ");		   
     dump_variables(argsinsert);
     fprintf(yyout, "ECPGt_EOIT, ");
-    dump_variables(argsresult);
+    /* dump_variables(argsresult); output variables must not exist here */
     fprintf(yyout, "ECPGt_EORT );");
-    output_line_number();
+    whenever_action();
 };
 
+sqlwhenever : SQL_START SQL_WHENEVER SQL_SQLERROR action SQL_SEMI{
+	when_error = $<action>4;
+}
+	| SQL_START SQL_WHENEVER SQL_NOT_FOUND action SQL_SEMI{
+	when_nf = $<action>4;
+}
+
+action : SQL_BREAK {
+	$<action>$.code = W_BREAK;
+	$<action>$.str = NULL;
+}
+       | SQL_CONTINUE {
+	$<action>$.code = W_CONTINUE;
+	$<action>$.str = NULL;
+}
+       | SQL_SQLPRINT {
+	$<action>$.code = W_SQLPRINT;
+	$<action>$.str = NULL;
+}
+       | SQL_GOTO label {
+	$<action>$.code = W_GOTO;
+	$<action>$.str = $<symbolname>2;
+}
+	| SQL_GOTO symbol {
+        $<action>$.code = W_GOTO;
+        $<action>$.str = $<symbolname>2;
+}
+       | SQL_DO symbol '(' {
+	do_str = (char *) mm_alloc(do_length = strlen($<symbolname>2) + 4);
+	sprintf(do_str, "%s (", $<symbolname>2);
+} vartext ')' {
+	do_str[strlen(do_str)+1]='\0';
+	do_str[strlen(do_str)]=')';
+	$<action>$.code = W_DO;
+	$<action>$.str = do_str;
+	do_str = NULL;
+	do_length = 0;
+}
+
+label : S_LABEL {
+    char * name = (char *)malloc(yyleng + 1);
+
+    strncpy(name, yytext, yyleng);
+    name[yyleng] = '\0';
+
+    $<symbolname>$ = name;
+}
+
 sqlstatement : SQL_START { /* Reset stack */
     reset_variables();
     fprintf(yyout, "ECPGdo(__LINE__, \"");
@@ -430,7 +536,7 @@ sqlstatement : SQL_START { /* Reset stack */
     fprintf(yyout, "ECPGt_EOIT, ");
     dump_variables(argsresult);
     fprintf(yyout, "ECPGt_EORT );");
-    output_line_number();
+    whenever_action();
 };
 
 sqlstatement_words : sqlstatement_word
@@ -478,9 +584,9 @@ both_anything : S_LENGTH | S_VARCHAR | S_VARCHAR2
 	  | SQL_BEGIN | SQL_END 
 	  | SQL_DECLARE | SQL_SECTION 
 	  | SQL_INCLUDE 
-	  | S_SYMBOL
+	  | S_SYMBOL | S_LABEL
 	  | S_STATIC | S_EXTERN | S_AUTO | S_CONST | S_REGISTER | S_STRUCT
-	  | '[' | ']' | ',' | '=' | '*'
+	  | '[' | ']' | ',' | '=' | '*' | '(' | ')'
 	  | S_ANYTHING;
 
 blockstart : '{' {
@@ -495,6 +601,6 @@ blockend : '}' {
 %%
 static void yyerror(char * error)
 {
-    fprintf(stderr, "%s\n", error);
+    fprintf(stderr, "%s in line %d\n", error, yylineno);
     exit(1);
 }
diff --git a/src/interfaces/ecpg/preproc/type.c b/src/interfaces/ecpg/preproc/type.c
index ae6b0997da5..bac44a72ed3 100644
--- a/src/interfaces/ecpg/preproc/type.c
+++ b/src/interfaces/ecpg/preproc/type.c
@@ -18,6 +18,20 @@ void *mm_alloc(size_t size)
         return (ptr);
 }
 
+/* realloc + error check */
+void *mm_realloc(void * ptr, size_t size)
+{
+        ptr = realloc(ptr, size);
+
+        if (ptr == NULL)
+        {
+                fprintf(stderr, "Out of memory\n");
+                exit(1);
+        }
+
+        return (ptr);
+}
+
 /* Constructors
    Yes, I mostly write c++-code
  */
diff --git a/src/interfaces/ecpg/preproc/type.h b/src/interfaces/ecpg/preproc/type.h
index 73fa3804836..80a7266f9c7 100644
--- a/src/interfaces/ecpg/preproc/type.h
+++ b/src/interfaces/ecpg/preproc/type.h
@@ -51,3 +51,19 @@ struct ECPGtemp_type {
 };
 
 extern const char * ECPGtype_name(enum ECPGttype typ);
+
+/* some stuff for whenever statements */
+enum WHEN {
+        W_NOTHING,
+        W_CONTINUE,
+        W_BREAK,
+        W_SQLPRINT,
+        W_GOTO,
+        W_DO
+};
+
+struct when
+{ 
+        enum WHEN   code;
+        char *      str;
+};
diff --git a/src/interfaces/ecpg/test/test2.pgc b/src/interfaces/ecpg/test/test2.pgc
index 37533515c3d..9c25e63f948 100644
--- a/src/interfaces/ecpg/test/test2.pgc
+++ b/src/interfaces/ecpg/test/test2.pgc
@@ -2,10 +2,11 @@
 
 exec sql include sqlca;
 
-#define       SQLCODE    sqlca.sqlcode
-
 extern void ECPGdebug(int n, FILE *dbgs);
 
+exec sql whenever not found sqlprint;
+exec sql whenever sqlerror db_error(msg);
+
 void
 db_error (char *msg)
 {
@@ -24,37 +25,32 @@ exec sql begin declare section;
 							    } birth;
 				} personal;
 exec sql end declare section;
+	char msg[128];
 	FILE *dbgs;
 
 	if ((dbgs = fopen("log", "w")) != NULL)
 		ECPGdebug(1, dbgs);
 
+	strcpy(msg, "connect");
 	exec sql connect 'mm';
-	if (SQLCODE)
-		db_error ("connect");
 
+	strcpy(msg, "declare");
 	exec sql declare cur cursor for 
 		select name, born, age from meskes;
-	if (SQLCODE) db_error ("declare");
 
 	exec sql open cur;
-	if (SQLCODE)
-		db_error ("open");
 
 	while (1) {
+		strcpy(msg, "fetch");
 		exec sql fetch in cur into :personal;
-		if (SQLCODE)
-			break;
 		printf ("%8.8s was born %d (age = %d)\n", personal.name.arr, personal.birth.born, personal.birth.age);
 	}
 
-	if (SQLCODE < 0)
-		db_error ("fetch");
-
+	strcpy(msg, "close");
 	exec sql close cur;
-	if (SQLCODE) db_error ("close");
+
+	strcpy(msg, "commit");
 	exec sql commit;
-	if (SQLCODE) db_error ("commit");
 
 	if (dbgs != NULL)
 		fclose(dbgs);