diff options
| -rw-r--r-- | src/protocol/pool_process_query.c | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/protocol/pool_process_query.c b/src/protocol/pool_process_query.c index 66dbb0aa1..09a2c28af 100644 --- a/src/protocol/pool_process_query.c +++ b/src/protocol/pool_process_query.c @@ -2747,7 +2747,7 @@ void do_query(POOL_CONNECTION *backend, char *query, POOL_SELECT_RESULT **result res->nullflags[num_data] = len; - if (len > 0) /* NOT NULL? */ + if (len >= 0) /* NOT NULL? */ { res->data[num_data] = palloc(len + 1); memcpy(res->data[num_data], p, len); @@ -2770,7 +2770,7 @@ void do_query(POOL_CONNECTION *backend, char *query, POOL_SELECT_RESULT **result res->nullflags[num_data] = len; - if (len > 0) + if (len >= 0) { p = pool_read2(backend, len); res->data[num_data] = palloc(len + 1); |