@@ -32,8 +32,8 @@ extern PGresult *PQexecFinish(PGconn *conn);
3232extern bool PQexecStart (PGconn * conn );
3333
3434
35- int PQsendASNQuery (PGconn * conn ,const char * query );
36- PGresult * PQASNexec (PGconn * conn ,const char * query );
35+ int PQsendASNQuery (PGconn * conn ,const char * query , const int msglen );
36+ PGresult * PQASNexec (PGconn * conn ,const char * query , const int msglen );
3737void symbol_for_ruby_pg (void );
3838
3939
@@ -48,14 +48,14 @@ void symbol_for_ruby_pg(void);
4848 * XXXXX - when is it safe to free bufferInfo / buffer?
4949 */
5050int
51- PQsendASNQuery (PGconn * conn ,const char * query )
51+ PQsendASNQuery (PGconn * conn ,const char * query , const int msglen )
5252{
53- int encoding = 0 ;
53+ int encoding = 1 ;
5454struct bufferInfo bufferInfo ;
5555
5656bufferInfo .buffer = query ;
57- bufferInfo .offset = strlen ( query ) ;
58- bufferInfo .length = strlen ( query ) ;
57+ bufferInfo .offset = msglen ;
58+ bufferInfo .length = msglen ;
5959
6060/* check the argument */
6161if (!query )
@@ -110,11 +110,11 @@ PQsendASNQuery(PGconn *conn, const char *query)
110110}
111111
112112PGresult *
113- PQASNexec (PGconn * conn ,const char * query )
113+ PQASNexec (PGconn * conn ,const char * query , const int msglen )
114114{
115115if (!PQexecStart (conn ))
116116return NULL ;
117- if (!PQsendASNQuery (conn ,query ))
117+ if (!PQsendASNQuery (conn ,query , msglen ))
118118return NULL ;
119119return PQexecFinish (conn );
120120}