Lines Matching refs:dbi

79 db_connect(struct dbinfo *dbi) {  in db_connect()  argument
80 dbi->conn = PQsetdbLogin(dbi->host, NULL, NULL, NULL, dbi->database, in db_connect()
81 dbi->user, dbi->passwd); in db_connect()
83 if (PQstatus(dbi->conn) == CONNECTION_OK) in db_connect()
94 maybe_reconnect(struct dbinfo *dbi) { in maybe_reconnect() argument
95 if (PQstatus(dbi->conn) == CONNECTION_OK) in maybe_reconnect()
98 return (db_connect(dbi)); in maybe_reconnect()
119 struct dbinfo *dbi = dbdata; in pgsqldb_lookup() local
137 "lower(NAME) = lower('%s')", dbi->table, canonname); in pgsqldb_lookup()
140 result = maybe_reconnect(dbi); in pgsqldb_lookup()
144 res = PQexec(dbi->conn, str); in pgsqldb_lookup()
182 struct dbinfo *dbi = dbdata; in pgsqldb_allnodes() local
192 dbi->table); in pgsqldb_allnodes()
194 result = maybe_reconnect(dbi); in pgsqldb_allnodes()
198 res = PQexec(dbi->conn, str); in pgsqldb_allnodes()
245 struct dbinfo *dbi; in pgsqldb_create() local
254 dbi = isc_mem_get(ns_g_mctx, sizeof(struct dbinfo)); in pgsqldb_create()
255 if (dbi == NULL) in pgsqldb_create()
257 dbi->conn = NULL; in pgsqldb_create()
258 dbi->database = NULL; in pgsqldb_create()
259 dbi->table = NULL; in pgsqldb_create()
260 dbi->host = NULL; in pgsqldb_create()
261 dbi->user = NULL; in pgsqldb_create()
262 dbi->passwd = NULL; in pgsqldb_create()
273 STRDUP_OR_FAIL(dbi->database, argv[0]); in pgsqldb_create()
274 STRDUP_OR_FAIL(dbi->table, argv[1]); in pgsqldb_create()
276 STRDUP_OR_FAIL(dbi->host, argv[2]); in pgsqldb_create()
278 STRDUP_OR_FAIL(dbi->user, argv[3]); in pgsqldb_create()
280 STRDUP_OR_FAIL(dbi->passwd, argv[4]); in pgsqldb_create()
282 result = db_connect(dbi); in pgsqldb_create()
286 *dbdata = dbi; in pgsqldb_create()
290 pgsqldb_destroy(zone, driverdata, (void **)&dbi); in pgsqldb_create()
299 struct dbinfo *dbi = *dbdata; in pgsqldb_destroy() local
304 if (dbi->conn != NULL) in pgsqldb_destroy()
305 PQfinish(dbi->conn); in pgsqldb_destroy()
306 if (dbi->database != NULL) in pgsqldb_destroy()
307 isc_mem_free(ns_g_mctx, dbi->database); in pgsqldb_destroy()
308 if (dbi->table != NULL) in pgsqldb_destroy()
309 isc_mem_free(ns_g_mctx, dbi->table); in pgsqldb_destroy()
310 if (dbi->host != NULL) in pgsqldb_destroy()
311 isc_mem_free(ns_g_mctx, dbi->host); in pgsqldb_destroy()
312 if (dbi->user != NULL) in pgsqldb_destroy()
313 isc_mem_free(ns_g_mctx, dbi->user); in pgsqldb_destroy()
314 if (dbi->passwd != NULL) in pgsqldb_destroy()
315 isc_mem_free(ns_g_mctx, dbi->passwd); in pgsqldb_destroy()
316 if (dbi->database != NULL) in pgsqldb_destroy()
317 isc_mem_free(ns_g_mctx, dbi->database); in pgsqldb_destroy()
318 isc_mem_put(ns_g_mctx, dbi, sizeof(struct dbinfo)); in pgsqldb_destroy()