Skip to content

P
Postgres FD Implementation
Commit 87157899 authored by Michael Meskes's avatar Michael Meskes
Browse files
Options

Made sure SET DESCRIPTOR accepts all data types including constants.

parent a72dd7a9
Hide whitespace changes
Inline Side-by-side
Showing with 161 additions and 137 deletions
src/interfaces/ecpg/ChangeLog
View file @ 87157899
...@@ -1825,6 +1825,15 @@ Sun Jun 27 13:50:58 CEST 2004 ...@@ -1825,6 +1825,15 @@ Sun Jun 27 13:50:58 CEST 2004
Mon Jun 28 11:08:42 CEST 2004 Mon Jun 28 11:08:42 CEST 2004
- Arrays can be read as arrays or as character strings now. - Arrays can be read as arrays or as character strings now.
Wed Jun 30 16:56:32 CEST 2004
- Added SET DESCRIPTOR command.
- Cleaned up error handling in preprocessor.
Sun Jul 4 16:53:53 CEST 2004
- Made sure SET DESCRIPTOR accepts all data types including constants.
- Set pgtypes library version to 1.2. - Set pgtypes library version to 1.2.
- Set ecpg version to 3.2.0. - Set ecpg version to 3.2.0.
- Set compat library version to 1.2. - Set compat library version to 1.2.
......
src/interfaces/ecpg/ecpglib/data.c
View file @ 87157899
/* $PostgreSQL: pgsql/src/interfaces/ecpg/ecpglib/data.c,v 1.25 2004/06/28 11:47:41 meskes Exp $ */ /* $PostgreSQL: pgsql/src/interfaces/ecpg/ecpglib/data.c,v 1.26 2004/07/04 15:02:22 meskes Exp $ */
#define POSTGRES_ECPG_INTERNAL #define POSTGRES_ECPG_INTERNAL
#include "postgres_fe.h" #include "postgres_fe.h"
...@@ -76,10 +76,7 @@ ECPGget_data(const PGresult *results, int act_tuple, int act_field, int lineno, ...@@ -76,10 +76,7 @@ ECPGget_data(const PGresult *results, int act_tuple, int act_field, int lineno,
* and 0 if not * and 0 if not
*/ */
if (PQgetisnull(results, act_tuple, act_field)) if (PQgetisnull(results, act_tuple, act_field))
{
printf("MM NULL\n");
value_for_indicator = -1; value_for_indicator = -1;
}
switch (ind_type) switch (ind_type)
{ {
......
src/interfaces/ecpg/ecpglib/descriptor.c
View file @ 87157899
/* dynamic SQL support routines /* dynamic SQL support routines
* *
* $PostgreSQL: pgsql/src/interfaces/ecpg/ecpglib/descriptor.c,v 1.9 2004/07/01 18:32:58 meskes Exp $ * $PostgreSQL: pgsql/src/interfaces/ecpg/ecpglib/descriptor.c,v 1.10 2004/07/04 15:02:22 meskes Exp $
*/ */
#define POSTGRES_ECPG_INTERNAL #define POSTGRES_ECPG_INTERNAL
...@@ -436,6 +436,7 @@ ECPGset_desc(int lineno, char *desc_name, int index,...) ...@@ -436,6 +436,7 @@ ECPGset_desc(int lineno, char *desc_name, int index,...)
va_list args; va_list args;
struct descriptor *desc; struct descriptor *desc;
struct descriptor_item *desc_item; struct descriptor_item *desc_item;
struct variable *var;
for (desc = all_descriptors; desc; desc = desc->next) for (desc = all_descriptors; desc; desc = desc->next)
{ {
...@@ -463,69 +464,59 @@ ECPGset_desc(int lineno, char *desc_name, int index,...) ...@@ -463,69 +464,59 @@ ECPGset_desc(int lineno, char *desc_name, int index,...)
desc->items = desc_item; desc->items = desc_item;
} }
if (!(var = (struct variable *) ECPGalloc(sizeof(struct variable), lineno)))
return false;
va_start(args, index); va_start(args, index);
do do
{ {
enum ECPGdtype itemtype; enum ECPGdtype itemtype;
long varcharsize; enum ECPGttype type;
long offset; const char *tobeinserted = NULL;
long arrsize; bool malloced;
enum ECPGttype vartype;
void *var;
itemtype = va_arg(args, enum ECPGdtype); itemtype = va_arg(args, enum ECPGdtype);
if (itemtype == ECPGd_EODT) if (itemtype == ECPGd_EODT)
break; break;
vartype = va_arg(args, enum ECPGttype); type = va_arg(args, enum ECPGttype);
var = va_arg(args, void *); ECPGget_variable(&args, type, var, false);
varcharsize = va_arg(args, long);
arrsize = va_arg(args, long);
offset = va_arg(args, long);
switch (itemtype) switch (itemtype)
{ {
case ECPGd_data: case ECPGd_data:
{ {
// FIXME: how to do this in general? if (!ECPGstore_input(lineno, true, var, &tobeinserted, &malloced))
switch (vartype)
{ {
case ECPGt_char: ECPGfree(var);
desc_item->data = strdup((char *)var); return false;
break;
case ECPGt_int:
{
char buf[20];
snprintf(buf, 20, "%d", *(int *)var);
desc_item->data = strdup(buf);
break;
}
default:
abort();
} }
desc_item->data = (char *) tobeinserted;
tobeinserted = NULL;
break; break;
} }
case ECPGd_indicator: case ECPGd_indicator:
set_int_item(lineno, &desc_item->indicator, var, vartype); set_int_item(lineno, &desc_item->indicator, var->pointer, var->type);
break; break;
case ECPGd_length: case ECPGd_length:
set_int_item(lineno, &desc_item->length, var, vartype); set_int_item(lineno, &desc_item->length, var->pointer, var->type);
break; break;
case ECPGd_precision: case ECPGd_precision:
set_int_item(lineno, &desc_item->precision, var, vartype); set_int_item(lineno, &desc_item->precision, var->pointer, var->type);
break; break;
case ECPGd_scale: case ECPGd_scale:
set_int_item(lineno, &desc_item->scale, var, vartype); set_int_item(lineno, &desc_item->scale, var->pointer, var->type);
break; break;
case ECPGd_type: case ECPGd_type:
set_int_item(lineno, &desc_item->type, var, vartype); set_int_item(lineno, &desc_item->type, var->pointer, var->type);
break; break;
default: default:
...@@ -533,6 +524,7 @@ ECPGset_desc(int lineno, char *desc_name, int index,...) ...@@ -533,6 +524,7 @@ ECPGset_desc(int lineno, char *desc_name, int index,...)
char type_str[20]; char type_str[20];
snprintf(type_str, sizeof(type_str), "%d", itemtype); snprintf(type_str, sizeof(type_str), "%d", itemtype);
ECPGraise(lineno, ECPG_UNKNOWN_DESCRIPTOR_ITEM, ECPG_SQLSTATE_ECPG_INTERNAL_ERROR, type_str); ECPGraise(lineno, ECPG_UNKNOWN_DESCRIPTOR_ITEM, ECPG_SQLSTATE_ECPG_INTERNAL_ERROR, type_str);
ECPGfree(var);
return false; return false;
} }
} }
...@@ -544,6 +536,7 @@ ECPGset_desc(int lineno, char *desc_name, int index,...) ...@@ -544,6 +536,7 @@ ECPGset_desc(int lineno, char *desc_name, int index,...)
}*/ }*/
} }
while (true); while (true);
ECPGfree(var);
return true; return true;
} }
......
src/interfaces/ecpg/ecpglib/execute.c
View file @ 87157899
/* $PostgreSQL: pgsql/src/interfaces/ecpg/ecpglib/execute.c,v 1.35 2004/06/30 15:01:56 meskes Exp $ */ /* $PostgreSQL: pgsql/src/interfaces/ecpg/ecpglib/execute.c,v 1.36 2004/07/04 15:02:22 meskes Exp $ */
/* /*
* The aim is to get a simpler inteface to the database routines. * The aim is to get a simpler inteface to the database routines.
...@@ -69,6 +69,59 @@ quote_postgres(char *arg, int lineno) ...@@ -69,6 +69,59 @@ quote_postgres(char *arg, int lineno)
return res; return res;
} }
void
ECPGget_variable(va_list *ap, enum ECPGttype type, struct variable *var, bool indicator)
{
var->type = type;
var->pointer = va_arg(*ap, char *);
var->varcharsize = va_arg(*ap, long);
var->arrsize = va_arg(*ap, long);
var->offset = va_arg(*ap, long);
if (var->arrsize == 0 || var->varcharsize == 0)
var->value = *((char **) (var->pointer));
else
var->value = var->pointer;
/*
* negative values are used to indicate an array without given
* bounds
*/
/* reset to zero for us */
if (var->arrsize < 0)
var->arrsize = 0;
if (var->varcharsize < 0)
var->varcharsize = 0;
var->next = NULL;
if (indicator)
{
var->ind_type = va_arg(*ap, enum ECPGttype);
var->ind_pointer = va_arg(*ap, char *);
var->ind_varcharsize = va_arg(*ap, long);
var->ind_arrsize = va_arg(*ap, long);
var->ind_offset = va_arg(*ap, long);
if (var->ind_type != ECPGt_NO_INDICATOR
&& (var->ind_arrsize == 0 || var->ind_varcharsize == 0))
var->ind_value = *((char **) (var->ind_pointer));
else
var->ind_value = var->ind_pointer;
/*
* negative values are used to indicate an array without given
* bounds
*/
/* reset to zero for us */
if (var->ind_arrsize < 0)
var->ind_arrsize = 0;
if (var->ind_varcharsize < 0)
var->ind_varcharsize = 0;
}
}
/* /*
* create a list of variables * create a list of variables
* The variables are listed with input variables preceding outputvariables * The variables are listed with input variables preceding outputvariables
...@@ -118,8 +171,7 @@ create_statement(int lineno, int compat, int force_indicator, struct connection ...@@ -118,8 +171,7 @@ create_statement(int lineno, int compat, int force_indicator, struct connection
if (!(var = (struct variable *) ECPGalloc(sizeof(struct variable), lineno))) if (!(var = (struct variable *) ECPGalloc(sizeof(struct variable), lineno)))
return false; return false;
var->type = type; ECPGget_variable(&ap, type, var, true);
var->pointer = va_arg(ap, char *);
/* if variable is NULL, the statement hasn't been prepared */ /* if variable is NULL, the statement hasn't been prepared */
if (var->pointer == NULL) if (var->pointer == NULL)
...@@ -129,48 +181,6 @@ create_statement(int lineno, int compat, int force_indicator, struct connection ...@@ -129,48 +181,6 @@ create_statement(int lineno, int compat, int force_indicator, struct connection
return false; return false;
} }
var->varcharsize = va_arg(ap, long);
var->arrsize = va_arg(ap, long);
var->offset = va_arg(ap, long);
if (var->arrsize == 0 || var->varcharsize == 0)
var->value = *((char **) (var->pointer));
else
var->value = var->pointer;
/*
* negative values are used to indicate an array without given
* bounds
*/
/* reset to zero for us */
if (var->arrsize < 0)
var->arrsize = 0;
if (var->varcharsize < 0)
var->varcharsize = 0;
var->ind_type = va_arg(ap, enum ECPGttype);
var->ind_pointer = va_arg(ap, char *);
var->ind_varcharsize = va_arg(ap, long);
var->ind_arrsize = va_arg(ap, long);
var->ind_offset = va_arg(ap, long);
var->next = NULL;
if (var->ind_type != ECPGt_NO_INDICATOR
&& (var->ind_arrsize == 0 || var->ind_varcharsize == 0))
var->ind_value = *((char **) (var->ind_pointer));
else
var->ind_value = var->ind_pointer;
/*
* negative values are used to indicate an array without given
* bounds
*/
/* reset to zero for us */
if (var->ind_arrsize < 0)
var->ind_arrsize = 0;
if (var->ind_varcharsize < 0)
var->ind_varcharsize = 0;
for (ptr = *list; ptr && ptr->next; ptr = ptr->next); for (ptr = *list; ptr && ptr->next; ptr = ptr->next);
if (ptr == NULL) if (ptr == NULL)
...@@ -477,8 +487,8 @@ ECPGstore_result(const PGresult *results, int act_field, ...@@ -477,8 +487,8 @@ ECPGstore_result(const PGresult *results, int act_field,
return status; return status;
} }
static bool bool
ECPGstore_input(const struct statement * stmt, const struct variable * var, ECPGstore_input(const int lineno, const bool force_indicator, const struct variable * var,
const char **tobeinserted_p, bool *malloced_p) const char **tobeinserted_p, bool *malloced_p)
{ {
char *mallocedval = NULL; char *mallocedval = NULL;
...@@ -491,7 +501,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var, ...@@ -491,7 +501,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var,
#if 0 #if 0
if (var->arrsize > 1 &&...) if (var->arrsize > 1 &&...)
{ {
ECPGraise(stmt->lineno, ECPG_ARRAY_INSERT, ECPG_SQLSTATE_DATATYPE_MISMATCH, NULL); ECPGraise(lineno, ECPG_ARRAY_INSERT, ECPG_SQLSTATE_DATATYPE_MISMATCH, NULL);
return false; return false;
} }
#endif #endif
...@@ -530,7 +540,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var, ...@@ -530,7 +540,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var,
break; break;
#endif /* HAVE_LONG_LONG_INT_64 */ #endif /* HAVE_LONG_LONG_INT_64 */
case ECPGt_NO_INDICATOR: case ECPGt_NO_INDICATOR:
if (stmt->force_indicator == false) if (force_indicator == false)
{ {
if (ECPGis_noind_null(var->type, var->value)) if (ECPGis_noind_null(var->type, var->value))
*tobeinserted_p = "null"; *tobeinserted_p = "null";
...@@ -546,7 +556,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var, ...@@ -546,7 +556,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var,
int element; int element;
case ECPGt_short: case ECPGt_short:
if (!(mallocedval = ECPGalloc(var->arrsize * 20, stmt->lineno))) if (!(mallocedval = ECPGalloc(var->arrsize * 20, lineno)))
return false; return false;
if (var->arrsize > 1) if (var->arrsize > 1)
...@@ -566,7 +576,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var, ...@@ -566,7 +576,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var,
break; break;
case ECPGt_int: case ECPGt_int:
if (!(mallocedval = ECPGalloc(var->arrsize * 20, stmt->lineno))) if (!(mallocedval = ECPGalloc(var->arrsize * 20, lineno)))
return false; return false;
if (var->arrsize > 1) if (var->arrsize > 1)
...@@ -586,7 +596,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var, ...@@ -586,7 +596,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var,
break; break;
case ECPGt_unsigned_short: case ECPGt_unsigned_short:
if (!(mallocedval = ECPGalloc(var->arrsize * 20, stmt->lineno))) if (!(mallocedval = ECPGalloc(var->arrsize * 20, lineno)))
return false; return false;
if (var->arrsize > 1) if (var->arrsize > 1)
...@@ -606,7 +616,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var, ...@@ -606,7 +616,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var,
break; break;
case ECPGt_unsigned_int: case ECPGt_unsigned_int:
if (!(mallocedval = ECPGalloc(var->arrsize * 20, stmt->lineno))) if (!(mallocedval = ECPGalloc(var->arrsize * 20, lineno)))
return false; return false;
if (var->arrsize > 1) if (var->arrsize > 1)
...@@ -626,7 +636,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var, ...@@ -626,7 +636,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var,
break; break;
case ECPGt_long: case ECPGt_long:
if (!(mallocedval = ECPGalloc(var->arrsize * 20, stmt->lineno))) if (!(mallocedval = ECPGalloc(var->arrsize * 20, lineno)))
return false; return false;
if (var->arrsize > 1) if (var->arrsize > 1)
...@@ -646,7 +656,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var, ...@@ -646,7 +656,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var,
break; break;
case ECPGt_unsigned_long: case ECPGt_unsigned_long:
if (!(mallocedval = ECPGalloc(var->arrsize * 20, stmt->lineno))) if (!(mallocedval = ECPGalloc(var->arrsize * 20, lineno)))
return false; return false;
if (var->arrsize > 1) if (var->arrsize > 1)
...@@ -666,7 +676,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var, ...@@ -666,7 +676,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var,
break; break;
#ifdef HAVE_LONG_LONG_INT_64 #ifdef HAVE_LONG_LONG_INT_64
case ECPGt_long_long: case ECPGt_long_long:
if (!(mallocedval = ECPGalloc(var->arrsize * 30, stmt->lineno))) if (!(mallocedval = ECPGalloc(var->arrsize * 30, lineno)))
return false; return false;
if (var->arrsize > 1) if (var->arrsize > 1)
...@@ -686,7 +696,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var, ...@@ -686,7 +696,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var,
break; break;
case ECPGt_unsigned_long_long: case ECPGt_unsigned_long_long:
if (!(mallocedval = ECPGalloc(var->arrsize * 30, stmt->lineno))) if (!(mallocedval = ECPGalloc(var->arrsize * 30, lineno)))
return false; return false;
if (var->arrsize > 1) if (var->arrsize > 1)
...@@ -706,7 +716,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var, ...@@ -706,7 +716,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var,
break; break;
#endif /* HAVE_LONG_LONG_INT_64 */ #endif /* HAVE_LONG_LONG_INT_64 */
case ECPGt_float: case ECPGt_float:
if (!(mallocedval = ECPGalloc(var->arrsize * 25, stmt->lineno))) if (!(mallocedval = ECPGalloc(var->arrsize * 25, lineno)))
return false; return false;
if (var->arrsize > 1) if (var->arrsize > 1)
...@@ -726,7 +736,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var, ...@@ -726,7 +736,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var,
break; break;
case ECPGt_double: case ECPGt_double:
if (!(mallocedval = ECPGalloc(var->arrsize * 25, stmt->lineno))) if (!(mallocedval = ECPGalloc(var->arrsize * 25, lineno)))
return false; return false;
if (var->arrsize > 1) if (var->arrsize > 1)
...@@ -746,7 +756,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var, ...@@ -746,7 +756,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var,
break; break;
case ECPGt_bool: case ECPGt_bool:
if (!(mallocedval = ECPGalloc(var->arrsize + sizeof("array []"), stmt->lineno))) if (!(mallocedval = ECPGalloc(var->arrsize + sizeof("array []"), lineno)))
return false; return false;
if (var->arrsize > 1) if (var->arrsize > 1)
...@@ -765,7 +775,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var, ...@@ -765,7 +775,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var,
for (element = 0; element < var->arrsize; element++) for (element = 0; element < var->arrsize; element++)
sprintf(mallocedval + strlen(mallocedval), "%c,", (((int *) var->value)[element]) ? 't' : 'f'); sprintf(mallocedval + strlen(mallocedval), "%c,", (((int *) var->value)[element]) ? 't' : 'f');
else else
ECPGraise(stmt->lineno, ECPG_CONVERT_BOOL, ECPG_SQLSTATE_DATATYPE_MISMATCH, "different size"); ECPGraise(lineno, ECPG_CONVERT_BOOL, ECPG_SQLSTATE_DATATYPE_MISMATCH, "different size");
strcpy(mallocedval + strlen(mallocedval) - 1, "]"); strcpy(mallocedval + strlen(mallocedval) - 1, "]");
} }
...@@ -776,7 +786,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var, ...@@ -776,7 +786,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var,
else if (var->offset == sizeof(int)) else if (var->offset == sizeof(int))
sprintf(mallocedval, "'%c'", (*((int *) var->value)) ? 't' : 'f'); sprintf(mallocedval, "'%c'", (*((int *) var->value)) ? 't' : 'f');
else else
ECPGraise(stmt->lineno, ECPG_CONVERT_BOOL, ECPG_SQLSTATE_DATATYPE_MISMATCH, "different size"); ECPGraise(lineno, ECPG_CONVERT_BOOL, ECPG_SQLSTATE_DATATYPE_MISMATCH, "different size");
} }
*tobeinserted_p = mallocedval; *tobeinserted_p = mallocedval;
...@@ -787,15 +797,15 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var, ...@@ -787,15 +797,15 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var,
case ECPGt_unsigned_char: case ECPGt_unsigned_char:
{ {
/* set slen to string length if type is char * */ /* set slen to string length if type is char * */
int slen = (var->varcharsize == 0) ? strlen((char *) var->value) : var->varcharsize; int slen = (var->varcharsize == 0) ? strlen((char *) var->value) : var->varcharsize;
if (!(newcopy = ECPGalloc(slen + 1, stmt->lineno))) if (!(newcopy = ECPGalloc(slen + 1, lineno)))
return false; return false;
strncpy(newcopy, (char *) var->value, slen); strncpy(newcopy, (char *) var->value, slen);
newcopy[slen] = '\0'; newcopy[slen] = '\0';
mallocedval = quote_postgres(newcopy, stmt->lineno); mallocedval = quote_postgres(newcopy, lineno);
if (!mallocedval) if (!mallocedval)
return false; return false;
...@@ -810,7 +820,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var, ...@@ -810,7 +820,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var,
{ {
int slen = strlen((char *) var->value); int slen = strlen((char *) var->value);
if (!(mallocedval = ECPGalloc(slen + 1, stmt->lineno))) if (!(mallocedval = ECPGalloc(slen + 1, lineno)))
return false; return false;
strncpy(mallocedval, (char *) var->value, slen); strncpy(mallocedval, (char *) var->value, slen);
...@@ -825,13 +835,13 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var, ...@@ -825,13 +835,13 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var,
struct ECPGgeneric_varchar *variable = struct ECPGgeneric_varchar *variable =
(struct ECPGgeneric_varchar *) (var->value); (struct ECPGgeneric_varchar *) (var->value);
if (!(newcopy = (char *) ECPGalloc(variable->len + 1, stmt->lineno))) if (!(newcopy = (char *) ECPGalloc(variable->len + 1, lineno)))
return false; return false;
strncpy(newcopy, variable->arr, variable->len); strncpy(newcopy, variable->arr, variable->len);
newcopy[variable->len] = '\0'; newcopy[variable->len] = '\0';
mallocedval = quote_postgres(newcopy, stmt->lineno); mallocedval = quote_postgres(newcopy, lineno);
if (!mallocedval) if (!mallocedval)
return false; return false;
...@@ -862,7 +872,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var, ...@@ -862,7 +872,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var,
PGTYPESnumeric_free(nval); PGTYPESnumeric_free(nval);
slen = strlen(str); slen = strlen(str);
if (!(mallocedval = ECPGrealloc(mallocedval, strlen(mallocedval) + slen + sizeof("array [] "), stmt->lineno))) if (!(mallocedval = ECPGrealloc(mallocedval, strlen(mallocedval) + slen + sizeof("array [] "), lineno)))
return false; return false;
if (!element) if (!element)
...@@ -885,7 +895,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var, ...@@ -885,7 +895,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var,
PGTYPESnumeric_free(nval); PGTYPESnumeric_free(nval);
slen = strlen(str); slen = strlen(str);
if (!(mallocedval = ECPGalloc(slen + 1, stmt->lineno))) if (!(mallocedval = ECPGalloc(slen + 1, lineno)))
return false; return false;
strncpy(mallocedval, str, slen); strncpy(mallocedval, str, slen);
...@@ -907,10 +917,10 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var, ...@@ -907,10 +917,10 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var,
{ {
for (element = 0; element < var->arrsize; element++) for (element = 0; element < var->arrsize; element++)
{ {
str = quote_postgres(PGTYPESinterval_to_asc((interval *) ((var + var->offset * element)->value)), stmt->lineno); str = quote_postgres(PGTYPESinterval_to_asc((interval *) ((var + var->offset * element)->value)), lineno);
slen = strlen(str); slen = strlen(str);
if (!(mallocedval = ECPGrealloc(mallocedval, strlen(mallocedval) + slen + sizeof("array [],interval "), stmt->lineno))) if (!(mallocedval = ECPGrealloc(mallocedval, strlen(mallocedval) + slen + sizeof("array [],interval "), lineno)))
return false; return false;
if (!element) if (!element)
...@@ -924,10 +934,10 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var, ...@@ -924,10 +934,10 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var,
} }
else else
{ {
str = quote_postgres(PGTYPESinterval_to_asc((interval *) (var->value)), stmt->lineno); str = quote_postgres(PGTYPESinterval_to_asc((interval *) (var->value)), lineno);
slen = strlen(str); slen = strlen(str);
if (!(mallocedval = ECPGalloc(slen + sizeof("interval ") + 1, stmt->lineno))) if (!(mallocedval = ECPGalloc(slen + sizeof("interval ") + 1, lineno)))
return false; return false;
strcpy(mallocedval, "interval "); strcpy(mallocedval, "interval ");
...@@ -950,10 +960,10 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var, ...@@ -950,10 +960,10 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var,
{ {
for (element = 0; element < var->arrsize; element++) for (element = 0; element < var->arrsize; element++)
{ {
str = quote_postgres(PGTYPESdate_to_asc(*(date *) ((var + var->offset * element)->value)), stmt->lineno); str = quote_postgres(PGTYPESdate_to_asc(*(date *) ((var + var->offset * element)->value)), lineno);
slen = strlen(str); slen = strlen(str);
if (!(mallocedval = ECPGrealloc(mallocedval, strlen(mallocedval) + slen + sizeof("array [],date "), stmt->lineno))) if (!(mallocedval = ECPGrealloc(mallocedval, strlen(mallocedval) + slen + sizeof("array [],date "), lineno)))
return false; return false;
if (!element) if (!element)
...@@ -967,10 +977,10 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var, ...@@ -967,10 +977,10 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var,
} }
else else
{ {
str = quote_postgres(PGTYPESdate_to_asc(*(date *) (var->value)), stmt->lineno); str = quote_postgres(PGTYPESdate_to_asc(*(date *) (var->value)), lineno);
slen = strlen(str); slen = strlen(str);
if (!(mallocedval = ECPGalloc(slen + sizeof("date ") + 1, stmt->lineno))) if (!(mallocedval = ECPGalloc(slen + sizeof("date ") + 1, lineno)))
return false; return false;
strcpy(mallocedval, "date "); strcpy(mallocedval, "date ");
...@@ -993,10 +1003,10 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var, ...@@ -993,10 +1003,10 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var,
{ {
for (element = 0; element < var->arrsize; element++) for (element = 0; element < var->arrsize; element++)
{ {
str = quote_postgres(PGTYPEStimestamp_to_asc(*(timestamp *) ((var + var->offset * element)->value)), stmt->lineno); str = quote_postgres(PGTYPEStimestamp_to_asc(*(timestamp *) ((var + var->offset * element)->value)), lineno);
slen = strlen(str); slen = strlen(str);
if (!(mallocedval = ECPGrealloc(mallocedval, strlen(mallocedval) + slen + sizeof("array [], timestamp "), stmt->lineno))) if (!(mallocedval = ECPGrealloc(mallocedval, strlen(mallocedval) + slen + sizeof("array [], timestamp "), lineno)))
return false; return false;
if (!element) if (!element)
...@@ -1010,10 +1020,10 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var, ...@@ -1010,10 +1020,10 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var,
} }
else else
{ {
str = quote_postgres(PGTYPEStimestamp_to_asc(*(timestamp *) (var->value)), stmt->lineno); str = quote_postgres(PGTYPEStimestamp_to_asc(*(timestamp *) (var->value)), lineno);
slen = strlen(str); slen = strlen(str);
if (!(mallocedval = ECPGalloc(slen + sizeof("timestamp") + 1, stmt->lineno))) if (!(mallocedval = ECPGalloc(slen + sizeof("timestamp") + 1, lineno)))
return false; return false;
strcpy(mallocedval, "timestamp "); strcpy(mallocedval, "timestamp ");
...@@ -1032,7 +1042,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var, ...@@ -1032,7 +1042,7 @@ ECPGstore_input(const struct statement * stmt, const struct variable * var,
default: default:
/* Not implemented yet */ /* Not implemented yet */
ECPGraise(stmt->lineno, ECPG_UNSUPPORTED, ECPG_SQLSTATE_ECPG_INTERNAL_ERROR, (char *) ECPGtype_name(var->type)); ECPGraise(lineno, ECPG_UNSUPPORTED, ECPG_SQLSTATE_ECPG_INTERNAL_ERROR, (char *) ECPGtype_name(var->type));
return false; return false;
break; break;
} }
...@@ -1104,7 +1114,7 @@ ECPGexecute(struct statement * stmt) ...@@ -1104,7 +1114,7 @@ ECPGexecute(struct statement * stmt)
desc_inlist.ind_value = desc_inlist.ind_pointer = NULL; desc_inlist.ind_value = desc_inlist.ind_pointer = NULL;
desc_inlist.ind_varcharsize = desc_inlist.ind_arrsize = desc_inlist.ind_offset = 0; desc_inlist.ind_varcharsize = desc_inlist.ind_arrsize = desc_inlist.ind_offset = 0;
if (!ECPGstore_input(stmt, &desc_inlist, &tobeinserted, &malloced)) if (!ECPGstore_input(stmt->lineno, stmt->force_indicator, &desc_inlist, &tobeinserted, &malloced))
return false; return false;
break; break;
...@@ -1116,7 +1126,7 @@ ECPGexecute(struct statement * stmt) ...@@ -1116,7 +1126,7 @@ ECPGexecute(struct statement * stmt)
} }
else else
{ {
if (!ECPGstore_input(stmt, var, &tobeinserted, &malloced)) if (!ECPGstore_input(stmt->lineno, stmt->force_indicator, var, &tobeinserted, &malloced))
return false; return false;
} }
if (tobeinserted) if (tobeinserted)
......
src/interfaces/ecpg/ecpglib/extern.h
View file @ 87157899
...@@ -124,6 +124,8 @@ PGresult **ECPGdescriptor_lvalue (int line, const char *descriptor); ...@@ -124,6 +124,8 @@ PGresult **ECPGdescriptor_lvalue (int line, const char *descriptor);
bool ECPGstore_result (const PGresult * results, int act_field, bool ECPGstore_result (const PGresult * results, int act_field,
const struct statement *stmt, struct variable *var); const struct statement *stmt, struct variable *var);
bool ECPGstore_input(const int, const bool, const struct variable *, const char **, bool *);
void ECPGget_variable(va_list *, enum ECPGttype, struct variable *, bool);
/* SQLSTATE values generated or processed by ecpglib (intentionally /* SQLSTATE values generated or processed by ecpglib (intentionally
* not exported -- users should refer to the codes directly) */ * not exported -- users should refer to the codes directly) */
......
src/interfaces/ecpg/include/ecpglib.h
View file @ 87157899
...@@ -8,6 +8,7 @@ ...@@ -8,6 +8,7 @@
#include "libpq-fe.h" #include "libpq-fe.h"
#include "ecpgtype.h" #include "ecpgtype.h"
#include <string.h>
#ifndef __BEOS__ #ifndef __BEOS__
#ifndef __cplusplus #ifndef __cplusplus
......
src/interfaces/ecpg/preproc/preproc.y
View file @ 87157899
/* $PostgreSQL: pgsql/src/interfaces/ecpg/preproc/preproc.y,v 1.290 2004/06/30 15:01:57 meskes Exp $ */ /* $PostgreSQL: pgsql/src/interfaces/ecpg/preproc/preproc.y,v 1.291 2004/07/04 15:02:23 meskes Exp $ */
/* Copyright comment */ /* Copyright comment */
%{ %{
...@@ -504,7 +504,7 @@ add_additional_variables(char *name, bool insert) ...@@ -504,7 +504,7 @@ add_additional_variables(char *name, bool insert)
%type <str> AlterUserSetStmt privilege_list privilege privilege_target %type <str> AlterUserSetStmt privilege_list privilege privilege_target
%type <str> opt_grant_grant_option opt_revoke_grant_option cursor_options %type <str> opt_grant_grant_option opt_revoke_grant_option cursor_options
%type <str> transaction_mode_list_or_empty transaction_mode_list %type <str> transaction_mode_list_or_empty transaction_mode_list
%type <str> function_with_argtypes_list function_with_argtypes %type <str> function_with_argtypes_list function_with_argtypes IntConstVar
%type <str> DropdbStmt ClusterStmt grantee RevokeStmt Bit DropOpClassStmt %type <str> DropdbStmt ClusterStmt grantee RevokeStmt Bit DropOpClassStmt
%type <str> GrantStmt privileges PosAllConst constraints_set_list %type <str> GrantStmt privileges PosAllConst constraints_set_list
%type <str> ConstraintsSetStmt AllConst CreateDomainStmt opt_nowait %type <str> ConstraintsSetStmt AllConst CreateDomainStmt opt_nowait
...@@ -4204,6 +4204,17 @@ IntConst: PosIntConst { $$ = $1; } ...@@ -4204,6 +4204,17 @@ IntConst: PosIntConst { $$ = $1; }
| '-' PosIntConst { $$ = cat2_str(make_str("-"), $2); } | '-' PosIntConst { $$ = cat2_str(make_str("-"), $2); }
; ;
IntConstVar: Iconst
{
char *length = mm_alloc(32);
sprintf(length, "%d", (int) strlen($1));
new_variable($1, ECPGmake_simple_type(ECPGt_const, length), 0);
$$ = $1;
}
| cvariable { $$ = $1; }
;
StringConst: Sconst { $$ = $1; } StringConst: Sconst { $$ = $1; }
| civar { $$ = $1; } | civar { $$ = $1; }
; ;
...@@ -5283,8 +5294,8 @@ opt_output: SQL_OUTPUT { $$ = make_str("output"); } ...@@ -5283,8 +5294,8 @@ opt_output: SQL_OUTPUT { $$ = make_str("output"); }
/* /*
* dynamic SQL: descriptor based access * dynamic SQL: descriptor based access
* written by Christof Petig <christof.petig@wtal.de> * originall written by Christof Petig <christof.petig@wtal.de>
* and Peter Eisentraut <peter.eisentraut@credativ.de> * and Peter Eisentraut <peter.eisentraut@credativ.de>
*/ */
/* /*
...@@ -5319,7 +5330,7 @@ ECPGGetDescHeaderItems: ECPGGetDescHeaderItem ...@@ -5319,7 +5330,7 @@ ECPGGetDescHeaderItems: ECPGGetDescHeaderItem
| ECPGGetDescHeaderItems ',' ECPGGetDescHeaderItem | ECPGGetDescHeaderItems ',' ECPGGetDescHeaderItem
; ;
ECPGGetDescHeaderItem: CVARIABLE '=' desc_header_item ECPGGetDescHeaderItem: cvariable '=' desc_header_item
{ push_assignment($1, $3); } { push_assignment($1, $3); }
; ;
...@@ -5331,8 +5342,10 @@ ECPGSetDescHeaderItems: ECPGSetDescHeaderItem ...@@ -5331,8 +5342,10 @@ ECPGSetDescHeaderItems: ECPGSetDescHeaderItem
| ECPGSetDescHeaderItems ',' ECPGSetDescHeaderItem | ECPGSetDescHeaderItems ',' ECPGSetDescHeaderItem
; ;
ECPGSetDescHeaderItem: desc_header_item '=' CVARIABLE ECPGSetDescHeaderItem: desc_header_item '=' IntConstVar
{ push_assignment($3, $1); } {
push_assignment($3, $1);
}
; ;
...@@ -5343,9 +5356,7 @@ desc_header_item: SQL_COUNT { $$ = ECPGd_count; } ...@@ -5343,9 +5356,7 @@ desc_header_item: SQL_COUNT { $$ = ECPGd_count; }
* manipulate a descriptor * manipulate a descriptor
*/ */
ECPGGetDescriptor: GET SQL_DESCRIPTOR quoted_ident_stringvar SQL_VALUE CVARIABLE ECPGGetDescItems ECPGGetDescriptor: GET SQL_DESCRIPTOR quoted_ident_stringvar SQL_VALUE IntConstVar ECPGGetDescItems
{ $$.str = $5; $$.name = $3; }
| GET SQL_DESCRIPTOR quoted_ident_stringvar SQL_VALUE Iconst ECPGGetDescItems
{ $$.str = $5; $$.name = $3; } { $$.str = $5; $$.name = $3; }
; ;
...@@ -5353,12 +5364,10 @@ ECPGGetDescItems: ECPGGetDescItem ...@@ -5353,12 +5364,10 @@ ECPGGetDescItems: ECPGGetDescItem
| ECPGGetDescItems ',' ECPGGetDescItem | ECPGGetDescItems ',' ECPGGetDescItem
; ;
ECPGGetDescItem: CVARIABLE '=' descriptor_item { push_assignment($1, $3); }; ECPGGetDescItem: cvariable '=' descriptor_item { push_assignment($1, $3); };
ECPGSetDescriptor: SET SQL_DESCRIPTOR quoted_ident_stringvar SQL_VALUE CVARIABLE ECPGSetDescItems ECPGSetDescriptor: SET SQL_DESCRIPTOR quoted_ident_stringvar SQL_VALUE IntConstVar ECPGSetDescItems
{ $$.str = $5; $$.name = $3; }
| SET SQL_DESCRIPTOR quoted_ident_stringvar SQL_VALUE Iconst ECPGSetDescItems
{ $$.str = $5; $$.name = $3; } { $$.str = $5; $$.name = $3; }
; ;
...@@ -5366,7 +5375,11 @@ ECPGSetDescItems: ECPGSetDescItem ...@@ -5366,7 +5375,11 @@ ECPGSetDescItems: ECPGSetDescItem
| ECPGSetDescItems ',' ECPGSetDescItem | ECPGSetDescItems ',' ECPGSetDescItem
; ;
ECPGSetDescItem: descriptor_item '=' CVARIABLE { push_assignment($3, $1); }; ECPGSetDescItem: descriptor_item '=' IntConstVar
{
push_assignment($3, $1);
}
;
descriptor_item: SQL_CARDINALITY { $$ = ECPGd_cardinality; } descriptor_item: SQL_CARDINALITY { $$ = ECPGd_cardinality; }
......
src/interfaces/ecpg/preproc/variable.c
View file @ 87157899
...@@ -419,7 +419,7 @@ dump_variables(struct arguments * list, int mode) ...@@ -419,7 +419,7 @@ dump_variables(struct arguments * list, int mode)
/* Then the current element and its indicator */ /* Then the current element and its indicator */
ECPGdump_a_type(yyout, list->variable->name, list->variable->type, ECPGdump_a_type(yyout, list->variable->name, list->variable->type,
list->indicator->name, list->indicator->type, list->indicator->name, list->indicator->type,
NULL, NULL, 0, NULL, NULL); NULL, NULL, make_str("0"), NULL, NULL);
/* Then release the list element. */ /* Then release the list element. */
if (mode != 0) if (mode != 0)
......
src/interfaces/ecpg/test/test_desc.pgc
View file @ 87157899
...@@ -31,8 +31,7 @@ main() ...@@ -31,8 +31,7 @@ main()
EXEC SQL EXECUTE foo1 USING DESCRIPTOR indesc; EXEC SQL EXECUTE foo1 USING DESCRIPTOR indesc;
//EXEC SQL SET DESCRIPTOR indesc VALUE 1 DATA = 2; EXEC SQL SET DESCRIPTOR indesc VALUE 1 DATA = 2;
EXEC SQL SET DESCRIPTOR indesc VALUE 1 DATA = :val1output;
EXEC SQL SET DESCRIPTOR indesc VALUE 2 INDICATOR = :val2null, DATA = :val2; EXEC SQL SET DESCRIPTOR indesc VALUE 2 INDICATOR = :val2null, DATA = :val2;
EXEC SQL EXECUTE foo1 USING DESCRIPTOR indesc; EXEC SQL EXECUTE foo1 USING DESCRIPTOR indesc;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment