113 |
113 |
114 void pg_resourcepool_freeresource(PgResourcePool *pg, PgResource *res) { |
114 void pg_resourcepool_freeresource(PgResourcePool *pg, PgResource *res) { |
115 if(res->connection) { |
115 if(res->connection) { |
116 PQfinish(res->connection); |
116 PQfinish(res->connection); |
117 } |
117 } |
|
118 pool_free(pg->pool, res); |
118 } |
119 } |
119 |
120 |
120 int pg_resourcepool_prepare(PgResourcePool *pg, PgResource *res) { |
121 int pg_resourcepool_prepare(PgResourcePool *pg, PgResource *res) { |
121 PGresult *result = PQexec(res->connection, "BEGIN"); |
122 PGresult *result = PQexec(res->connection, "BEGIN"); |
122 PQclear(result); // TODO: handle error |
123 PQclear(result); // TODO: handle error |