12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485 |
- #include <grass/dbmi.h>
- #include "globals.h"
- #include "proto.h"
- int db__driver_list_databases(dbString * dbpath, int npaths,
- dbHandle ** dblist, int *dbcount)
- {
- int i;
- PGCONN pgconn;
- PGresult *res;
- int rec_num = 0;
- dbHandle *list;
- init_error();
- *dblist = NULL;
- *dbcount = 0;
- /* TODO: the solution below is not good as user usually does not have permissions for "template1" */
- append_error
- ("db_driver_list_databases() is not implemented in pg driver");
- report_error();
- return DB_FAILED;
- if (npaths > 0) {
- G_debug(3, "location: %s", db_get_string(dbpath));
- if (parse_conn(db_get_string(dbpath), &pgconn) == DB_FAILED) {
- report_error();
- return DB_FAILED;
- }
- }
- G_debug(3, "host = %s, port = %s, options = %s, tty = %s",
- pgconn.host, pgconn.port, pgconn.options, pgconn.tty);
- pg_conn =
- PQsetdb(pgconn.host, pgconn.port, pgconn.options, pgconn.tty,
- "template1");
- if (PQstatus(pg_conn) == CONNECTION_BAD) {
- append_error("Cannot connect to Postgres:\n");
- append_error(PQerrorMessage(pg_conn));
- report_error();
- PQfinish(pg_conn);
- return DB_FAILED;
- }
- res = PQexec(pg_conn, "select datname from pg_database");
- if (!res || PQresultStatus(res) != PGRES_TUPLES_OK) {
- append_error("Cannot select from Postgres:\n");
- append_error(PQerrorMessage(pg_conn));
- report_error();
- PQclear(res);
- PQfinish(pg_conn);
- return DB_FAILED;
- }
- rec_num = PQntuples(res);
- list = db_alloc_handle_array(rec_num);
- if (list == NULL) {
- append_error("Cannot db_alloc_handle_array()");
- report_error();
- return DB_FAILED;
- }
- for (i = 0; i < rec_num; i++) {
- db_init_handle(&list[i]);
- if (db_set_handle(&list[i], PQgetvalue(res, i, 0), NULL) != DB_OK) {
- append_error("db_set_handle()");
- report_error();
- db_free_handle_array(list, rec_num);
- return DB_FAILED;
- }
- }
- PQclear(res);
- PQfinish(pg_conn);
- *dblist = list;
- *dbcount = rec_num;
- return DB_OK;
- }
|