@ -469,12 +469,20 @@ static int config_module(int reload)
if(PQstatus(conn)!=CONNECTION_BAD){
charsqlcmd[512];
char*fname,*ftype,*flen,*fnotnull,*fdef;
char*tableptr;
inti,rows;
ast_debug(1,"Successfully connected to PostgreSQL database.\n");
connected=1;
/* Remove any schema name from the table */
if((tableptr=strrchr(table,'.'))){
tableptr++;
}else{
tableptr=table;
}
/* Query the columns */
snprintf(sqlcmd,sizeof(sqlcmd),"select a.attname, t.typname, a.attlen, a.attnotnull, d.adsrc from pg_class c, pg_type t, pg_attribute a left outer join pg_attrdef d on a.atthasdef and d.adrelid = a.attrelid and d.adnum = a.attnum where c.oid = a.attrelid and a.atttypid = t.oid and (a.attnum > 0) and c.relname = '%s' order by c.relname, attnum",table);
snprintf(sqlcmd,sizeof(sqlcmd),"select a.attname, t.typname, a.attlen, a.attnotnull, d.adsrc from pg_class c, pg_type t, pg_attribute a left outer join pg_attrdef d on a.atthasdef and d.adrelid = a.attrelid and d.adnum = a.attnum where c.oid = a.attrelid and a.atttypid = t.oid and (a.attnum > 0) and c.relname = '%s' order by c.relname, attnum",tableptr);