aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorMichael Meskes <meskes@postgresql.org>2007-02-27 13:27:05 +0000
committerMichael Meskes <meskes@postgresql.org>2007-02-27 13:27:05 +0000
commite9a97570fadeb79d5a21086399bdf5b48d924b17 (patch)
treeb8f9403e0f1cc72f22f46ea01798d2365678c400
parent355451be0ee862a93d9a8e253971b380eadc9901 (diff)
downloadpostgresql-e9a97570fadeb79d5a21086399bdf5b48d924b17.tar.gz
postgresql-e9a97570fadeb79d5a21086399bdf5b48d924b17.zip
Backported bug fix for #2956.
-rw-r--r--src/interfaces/ecpg/ecpglib/execute.c50
1 files changed, 34 insertions, 16 deletions
diff --git a/src/interfaces/ecpg/ecpglib/execute.c b/src/interfaces/ecpg/ecpglib/execute.c
index 77bb26cc345..b3d0bc72079 100644
--- a/src/interfaces/ecpg/ecpglib/execute.c
+++ b/src/interfaces/ecpg/ecpglib/execute.c
@@ -1,4 +1,4 @@
-/* $PostgreSQL: pgsql/src/interfaces/ecpg/ecpglib/execute.c,v 1.43.2.9 2007/02/06 09:41:52 meskes Exp $ */
+/* $PostgreSQL: pgsql/src/interfaces/ecpg/ecpglib/execute.c,v 1.43.2.10 2007/02/27 13:27:05 meskes Exp $ */
/*
* The aim is to get a simpler inteface to the database routines.
@@ -38,27 +38,45 @@
static char *
quote_postgres(char *arg, int lineno)
{
- char *res = (char *) ECPGalloc(2 * strlen(arg) + 3, lineno);
- int i,
- ri = 0;
+ char *res;
+ int error;
+ size_t length;
+ size_t escaped_len;
+ size_t buffer_len;
+ /*
+ * if quote is false we just need to store things in a descriptor they
+ * will be quoted once they are inserted in a statement
+ */
+ length = strlen(arg);
+ buffer_len = 2 * length + 1;
+ res = (char *) ECPGalloc(buffer_len + 3, lineno);
if (!res)
return (res);
- if (strchr(arg, '\\') != NULL)
- res[ri++] = ESCAPE_STRING_SYNTAX;
- res[ri++] = '\'';
-
- for (i = 0; arg[i]; i++, ri++)
+ error = 0;
+ escaped_len = PQescapeString(res+1, arg, buffer_len);
+ if (error)
{
- if (SQL_STR_DOUBLE(arg[i]))
- res[ri++] = arg[i];
- res[ri] = arg[i];
+ ECPGfree(res);
+ return NULL;
+ }
+ if (length == escaped_len)
+ {
+ res[0] = res[escaped_len+1] = '\'';
+ res[escaped_len+2] = '\0';
+ }
+ else
+ {
+ /*
+ * We don't know if the target database is using
+ * standard_conforming_strings, so we always use E'' strings.
+ */
+ memmove(res+2, res+1, escaped_len);
+ res[0] = ESCAPE_STRING_SYNTAX;
+ res[1] = res[escaped_len+2] = '\'';
+ res[escaped_len+3] = '\0';
}
-
- res[ri++] = '\'';
- res[ri] = '\0';
-
ECPGfree(arg);
return res;
}