Clean up most -Wunused-but-set-variable warnings from gcc 4.6
This warning is new in gcc 4.6 and part of -Wall. This patch cleans up most of the noise, but there are some still warnings that are trickier to remove.
This commit is contained in:
parent
3c381a55b0
commit
5caa3479c2
@ -341,8 +341,7 @@ ean2isn(ean13 ean, bool errorOK, ean13 *result, enum isn_type accept)
|
|||||||
enum isn_type type = INVALID;
|
enum isn_type type = INVALID;
|
||||||
|
|
||||||
char buf[MAXEAN13LEN + 1];
|
char buf[MAXEAN13LEN + 1];
|
||||||
char *firstdig,
|
char *aux;
|
||||||
*aux;
|
|
||||||
unsigned digval;
|
unsigned digval;
|
||||||
unsigned search;
|
unsigned search;
|
||||||
ean13 ret = ean;
|
ean13 ret = ean;
|
||||||
@ -354,7 +353,7 @@ ean2isn(ean13 ean, bool errorOK, ean13 *result, enum isn_type accept)
|
|||||||
|
|
||||||
/* convert the number */
|
/* convert the number */
|
||||||
search = 0;
|
search = 0;
|
||||||
firstdig = aux = buf + 13;
|
aux = buf + 13;
|
||||||
*aux = '\0'; /* terminate string; aux points to last digit */
|
*aux = '\0'; /* terminate string; aux points to last digit */
|
||||||
do
|
do
|
||||||
{
|
{
|
||||||
@ -528,8 +527,7 @@ ean2string(ean13 ean, bool errorOK, char *result, bool shortType)
|
|||||||
const unsigned (*TABLE_index)[2];
|
const unsigned (*TABLE_index)[2];
|
||||||
enum isn_type type = INVALID;
|
enum isn_type type = INVALID;
|
||||||
|
|
||||||
char *firstdig,
|
char *aux;
|
||||||
*aux;
|
|
||||||
unsigned digval;
|
unsigned digval;
|
||||||
unsigned search;
|
unsigned search;
|
||||||
char valid = '\0'; /* was the number initially written with a
|
char valid = '\0'; /* was the number initially written with a
|
||||||
@ -546,7 +544,7 @@ ean2string(ean13 ean, bool errorOK, char *result, bool shortType)
|
|||||||
|
|
||||||
/* convert the number */
|
/* convert the number */
|
||||||
search = 0;
|
search = 0;
|
||||||
firstdig = aux = result + MAXEAN13LEN;
|
aux = result + MAXEAN13LEN;
|
||||||
*aux = '\0'; /* terminate string; aux points to last digit */
|
*aux = '\0'; /* terminate string; aux points to last digit */
|
||||||
*--aux = valid; /* append '!' for numbers with invalid but
|
*--aux = valid; /* append '!' for numbers with invalid but
|
||||||
* corrected check digit */
|
* corrected check digit */
|
||||||
|
@ -35,7 +35,6 @@ Datum
|
|||||||
fsm_page_contents(PG_FUNCTION_ARGS)
|
fsm_page_contents(PG_FUNCTION_ARGS)
|
||||||
{
|
{
|
||||||
bytea *raw_page = PG_GETARG_BYTEA_P(0);
|
bytea *raw_page = PG_GETARG_BYTEA_P(0);
|
||||||
int raw_page_size;
|
|
||||||
StringInfoData sinfo;
|
StringInfoData sinfo;
|
||||||
FSMPage fsmpage;
|
FSMPage fsmpage;
|
||||||
int i;
|
int i;
|
||||||
@ -45,7 +44,6 @@ fsm_page_contents(PG_FUNCTION_ARGS)
|
|||||||
(errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
|
(errcode(ERRCODE_INSUFFICIENT_PRIVILEGE),
|
||||||
(errmsg("must be superuser to use raw page functions"))));
|
(errmsg("must be superuser to use raw page functions"))));
|
||||||
|
|
||||||
raw_page_size = VARSIZE(raw_page) - VARHDRSZ;
|
|
||||||
fsmpage = (FSMPage) PageGetContents(VARDATA(raw_page));
|
fsmpage = (FSMPage) PageGetContents(VARDATA(raw_page));
|
||||||
|
|
||||||
initStringInfo(&sinfo);
|
initStringInfo(&sinfo);
|
||||||
|
@ -39,14 +39,12 @@ static int
|
|||||||
calc_s2k_simple(PGP_S2K *s2k, PX_MD *md, const uint8 *key,
|
calc_s2k_simple(PGP_S2K *s2k, PX_MD *md, const uint8 *key,
|
||||||
unsigned key_len)
|
unsigned key_len)
|
||||||
{
|
{
|
||||||
unsigned md_bs,
|
unsigned md_rlen;
|
||||||
md_rlen;
|
|
||||||
uint8 buf[PGP_MAX_DIGEST];
|
uint8 buf[PGP_MAX_DIGEST];
|
||||||
unsigned preload;
|
unsigned preload;
|
||||||
unsigned remain;
|
unsigned remain;
|
||||||
uint8 *dst = s2k->key;
|
uint8 *dst = s2k->key;
|
||||||
|
|
||||||
md_bs = px_md_block_size(md);
|
|
||||||
md_rlen = px_md_result_size(md);
|
md_rlen = px_md_result_size(md);
|
||||||
|
|
||||||
remain = s2k->key_len;
|
remain = s2k->key_len;
|
||||||
@ -83,14 +81,12 @@ calc_s2k_simple(PGP_S2K *s2k, PX_MD *md, const uint8 *key,
|
|||||||
static int
|
static int
|
||||||
calc_s2k_salted(PGP_S2K *s2k, PX_MD *md, const uint8 *key, unsigned key_len)
|
calc_s2k_salted(PGP_S2K *s2k, PX_MD *md, const uint8 *key, unsigned key_len)
|
||||||
{
|
{
|
||||||
unsigned md_bs,
|
unsigned md_rlen;
|
||||||
md_rlen;
|
|
||||||
uint8 buf[PGP_MAX_DIGEST];
|
uint8 buf[PGP_MAX_DIGEST];
|
||||||
unsigned preload = 0;
|
unsigned preload = 0;
|
||||||
uint8 *dst;
|
uint8 *dst;
|
||||||
unsigned remain;
|
unsigned remain;
|
||||||
|
|
||||||
md_bs = px_md_block_size(md);
|
|
||||||
md_rlen = px_md_result_size(md);
|
md_rlen = px_md_result_size(md);
|
||||||
|
|
||||||
dst = s2k->key;
|
dst = s2k->key;
|
||||||
@ -129,8 +125,7 @@ static int
|
|||||||
calc_s2k_iter_salted(PGP_S2K *s2k, PX_MD *md, const uint8 *key,
|
calc_s2k_iter_salted(PGP_S2K *s2k, PX_MD *md, const uint8 *key,
|
||||||
unsigned key_len)
|
unsigned key_len)
|
||||||
{
|
{
|
||||||
unsigned md_bs,
|
unsigned md_rlen;
|
||||||
md_rlen;
|
|
||||||
uint8 buf[PGP_MAX_DIGEST];
|
uint8 buf[PGP_MAX_DIGEST];
|
||||||
uint8 *dst;
|
uint8 *dst;
|
||||||
unsigned preload = 0;
|
unsigned preload = 0;
|
||||||
@ -143,7 +138,6 @@ calc_s2k_iter_salted(PGP_S2K *s2k, PX_MD *md, const uint8 *key,
|
|||||||
cval = s2k->iter;
|
cval = s2k->iter;
|
||||||
count = ((unsigned) 16 + (cval & 15)) << ((cval >> 4) + 6);
|
count = ((unsigned) 16 + (cval & 15)) << ((cval >> 4) + 6);
|
||||||
|
|
||||||
md_bs = px_md_block_size(md);
|
|
||||||
md_rlen = px_md_result_size(md);
|
md_rlen = px_md_result_size(md);
|
||||||
|
|
||||||
remain = s2k->key_len;
|
remain = s2k->key_len;
|
||||||
|
@ -52,13 +52,11 @@ static void
|
|||||||
hmac_init(PX_HMAC *h, const uint8 *key, unsigned klen)
|
hmac_init(PX_HMAC *h, const uint8 *key, unsigned klen)
|
||||||
{
|
{
|
||||||
unsigned bs,
|
unsigned bs,
|
||||||
hlen,
|
|
||||||
i;
|
i;
|
||||||
uint8 *keybuf;
|
uint8 *keybuf;
|
||||||
PX_MD *md = h->md;
|
PX_MD *md = h->md;
|
||||||
|
|
||||||
bs = px_md_block_size(md);
|
bs = px_md_block_size(md);
|
||||||
hlen = px_md_result_size(md);
|
|
||||||
keybuf = px_alloc(bs);
|
keybuf = px_alloc(bs);
|
||||||
memset(keybuf, 0, bs);
|
memset(keybuf, 0, bs);
|
||||||
|
|
||||||
|
@ -162,14 +162,12 @@ combo_init(PX_Combo *cx, const uint8 *key, unsigned klen,
|
|||||||
const uint8 *iv, unsigned ivlen)
|
const uint8 *iv, unsigned ivlen)
|
||||||
{
|
{
|
||||||
int err;
|
int err;
|
||||||
unsigned bs,
|
unsigned ks,
|
||||||
ks,
|
|
||||||
ivs;
|
ivs;
|
||||||
PX_Cipher *c = cx->cipher;
|
PX_Cipher *c = cx->cipher;
|
||||||
uint8 *ivbuf = NULL;
|
uint8 *ivbuf = NULL;
|
||||||
uint8 *keybuf;
|
uint8 *keybuf;
|
||||||
|
|
||||||
bs = px_cipher_block_size(c);
|
|
||||||
ks = px_cipher_key_size(c);
|
ks = px_cipher_key_size(c);
|
||||||
|
|
||||||
ivs = px_cipher_iv_size(c);
|
ivs = px_cipher_iv_size(c);
|
||||||
@ -205,7 +203,6 @@ combo_encrypt(PX_Combo *cx, const uint8 *data, unsigned dlen,
|
|||||||
int err = 0;
|
int err = 0;
|
||||||
uint8 *bbuf;
|
uint8 *bbuf;
|
||||||
unsigned bs,
|
unsigned bs,
|
||||||
maxlen,
|
|
||||||
bpos,
|
bpos,
|
||||||
i,
|
i,
|
||||||
pad;
|
pad;
|
||||||
@ -213,7 +210,6 @@ combo_encrypt(PX_Combo *cx, const uint8 *data, unsigned dlen,
|
|||||||
PX_Cipher *c = cx->cipher;
|
PX_Cipher *c = cx->cipher;
|
||||||
|
|
||||||
bbuf = NULL;
|
bbuf = NULL;
|
||||||
maxlen = *rlen;
|
|
||||||
bs = px_cipher_block_size(c);
|
bs = px_cipher_block_size(c);
|
||||||
|
|
||||||
/* encrypt */
|
/* encrypt */
|
||||||
|
@ -867,7 +867,6 @@ restore(char *result, float val, int n)
|
|||||||
'0', '0', '0', '0', '\0'
|
'0', '0', '0', '0', '\0'
|
||||||
};
|
};
|
||||||
char *p;
|
char *p;
|
||||||
char *mant;
|
|
||||||
int exp;
|
int exp;
|
||||||
int i,
|
int i,
|
||||||
dp,
|
dp,
|
||||||
@ -893,7 +892,7 @@ restore(char *result, float val, int n)
|
|||||||
*p = '\0';
|
*p = '\0';
|
||||||
|
|
||||||
/* get the exponent */
|
/* get the exponent */
|
||||||
mant = (char *) strtok(strdup(result), "e");
|
strtok(strdup(result), "e");
|
||||||
exp = atoi(strtok(NULL, "e"));
|
exp = atoi(strtok(NULL, "e"));
|
||||||
|
|
||||||
if (exp == 0)
|
if (exp == 0)
|
||||||
|
@ -38,8 +38,6 @@ gistvacuumcleanup(PG_FUNCTION_ARGS)
|
|||||||
BlockNumber npages,
|
BlockNumber npages,
|
||||||
blkno;
|
blkno;
|
||||||
BlockNumber totFreePages;
|
BlockNumber totFreePages;
|
||||||
BlockNumber lastBlock = GIST_ROOT_BLKNO,
|
|
||||||
lastFilledBlock = GIST_ROOT_BLKNO;
|
|
||||||
bool needLock;
|
bool needLock;
|
||||||
|
|
||||||
/* No-op in ANALYZE ONLY mode */
|
/* No-op in ANALYZE ONLY mode */
|
||||||
@ -90,11 +88,8 @@ gistvacuumcleanup(PG_FUNCTION_ARGS)
|
|||||||
totFreePages++;
|
totFreePages++;
|
||||||
RecordFreeIndexPage(rel, blkno);
|
RecordFreeIndexPage(rel, blkno);
|
||||||
}
|
}
|
||||||
else
|
|
||||||
lastFilledBlock = blkno;
|
|
||||||
UnlockReleaseBuffer(buffer);
|
UnlockReleaseBuffer(buffer);
|
||||||
}
|
}
|
||||||
lastBlock = npages - 1;
|
|
||||||
|
|
||||||
/* Finally, vacuum the FSM */
|
/* Finally, vacuum the FSM */
|
||||||
IndexFreeSpaceMapVacuum(info->index);
|
IndexFreeSpaceMapVacuum(info->index);
|
||||||
|
@ -466,7 +466,6 @@ _bt_log_reuse_page(Relation rel, BlockNumber blkno, TransactionId latestRemovedX
|
|||||||
|
|
||||||
/* XLOG stuff */
|
/* XLOG stuff */
|
||||||
{
|
{
|
||||||
XLogRecPtr recptr;
|
|
||||||
XLogRecData rdata[1];
|
XLogRecData rdata[1];
|
||||||
xl_btree_reuse_page xlrec_reuse;
|
xl_btree_reuse_page xlrec_reuse;
|
||||||
|
|
||||||
@ -478,7 +477,7 @@ _bt_log_reuse_page(Relation rel, BlockNumber blkno, TransactionId latestRemovedX
|
|||||||
rdata[0].buffer = InvalidBuffer;
|
rdata[0].buffer = InvalidBuffer;
|
||||||
rdata[0].next = NULL;
|
rdata[0].next = NULL;
|
||||||
|
|
||||||
recptr = XLogInsert(RM_BTREE_ID, XLOG_BTREE_REUSE_PAGE, rdata);
|
XLogInsert(RM_BTREE_ID, XLOG_BTREE_REUSE_PAGE, rdata);
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* We don't do PageSetLSN or PageSetTLI here because we're about
|
* We don't do PageSetLSN or PageSetTLI here because we're about
|
||||||
|
@ -671,7 +671,6 @@ fmgr_internal_validator(PG_FUNCTION_ARGS)
|
|||||||
{
|
{
|
||||||
Oid funcoid = PG_GETARG_OID(0);
|
Oid funcoid = PG_GETARG_OID(0);
|
||||||
HeapTuple tuple;
|
HeapTuple tuple;
|
||||||
Form_pg_proc proc;
|
|
||||||
bool isnull;
|
bool isnull;
|
||||||
Datum tmp;
|
Datum tmp;
|
||||||
char *prosrc;
|
char *prosrc;
|
||||||
@ -684,7 +683,6 @@ fmgr_internal_validator(PG_FUNCTION_ARGS)
|
|||||||
tuple = SearchSysCache1(PROCOID, ObjectIdGetDatum(funcoid));
|
tuple = SearchSysCache1(PROCOID, ObjectIdGetDatum(funcoid));
|
||||||
if (!HeapTupleIsValid(tuple))
|
if (!HeapTupleIsValid(tuple))
|
||||||
elog(ERROR, "cache lookup failed for function %u", funcoid);
|
elog(ERROR, "cache lookup failed for function %u", funcoid);
|
||||||
proc = (Form_pg_proc) GETSTRUCT(tuple);
|
|
||||||
|
|
||||||
tmp = SysCacheGetAttr(PROCOID, tuple, Anum_pg_proc_prosrc, &isnull);
|
tmp = SysCacheGetAttr(PROCOID, tuple, Anum_pg_proc_prosrc, &isnull);
|
||||||
if (isnull)
|
if (isnull)
|
||||||
@ -717,7 +715,6 @@ fmgr_c_validator(PG_FUNCTION_ARGS)
|
|||||||
Oid funcoid = PG_GETARG_OID(0);
|
Oid funcoid = PG_GETARG_OID(0);
|
||||||
void *libraryhandle;
|
void *libraryhandle;
|
||||||
HeapTuple tuple;
|
HeapTuple tuple;
|
||||||
Form_pg_proc proc;
|
|
||||||
bool isnull;
|
bool isnull;
|
||||||
Datum tmp;
|
Datum tmp;
|
||||||
char *prosrc;
|
char *prosrc;
|
||||||
@ -732,7 +729,6 @@ fmgr_c_validator(PG_FUNCTION_ARGS)
|
|||||||
tuple = SearchSysCache1(PROCOID, ObjectIdGetDatum(funcoid));
|
tuple = SearchSysCache1(PROCOID, ObjectIdGetDatum(funcoid));
|
||||||
if (!HeapTupleIsValid(tuple))
|
if (!HeapTupleIsValid(tuple))
|
||||||
elog(ERROR, "cache lookup failed for function %u", funcoid);
|
elog(ERROR, "cache lookup failed for function %u", funcoid);
|
||||||
proc = (Form_pg_proc) GETSTRUCT(tuple);
|
|
||||||
|
|
||||||
tmp = SysCacheGetAttr(PROCOID, tuple, Anum_pg_proc_prosrc, &isnull);
|
tmp = SysCacheGetAttr(PROCOID, tuple, Anum_pg_proc_prosrc, &isnull);
|
||||||
if (isnull)
|
if (isnull)
|
||||||
|
@ -118,7 +118,6 @@ create_toast_table(Relation rel, Oid toastOid, Oid toastIndexOid, Datum reloptio
|
|||||||
Relation toast_rel;
|
Relation toast_rel;
|
||||||
Relation class_rel;
|
Relation class_rel;
|
||||||
Oid toast_relid;
|
Oid toast_relid;
|
||||||
Oid toast_idxid;
|
|
||||||
Oid toast_typid = InvalidOid;
|
Oid toast_typid = InvalidOid;
|
||||||
Oid namespaceid;
|
Oid namespaceid;
|
||||||
char toast_relname[NAMEDATALEN];
|
char toast_relname[NAMEDATALEN];
|
||||||
@ -274,7 +273,7 @@ create_toast_table(Relation rel, Oid toastOid, Oid toastIndexOid, Datum reloptio
|
|||||||
coloptions[0] = 0;
|
coloptions[0] = 0;
|
||||||
coloptions[1] = 0;
|
coloptions[1] = 0;
|
||||||
|
|
||||||
toast_idxid = index_create(toast_rel, toast_idxname, toastIndexOid,
|
index_create(toast_rel, toast_idxname, toastIndexOid,
|
||||||
indexInfo,
|
indexInfo,
|
||||||
list_make2("chunk_id", "chunk_seq"),
|
list_make2("chunk_id", "chunk_seq"),
|
||||||
BTREE_AM_OID,
|
BTREE_AM_OID,
|
||||||
|
@ -1269,7 +1269,6 @@ show_plan_tlist(PlanState *planstate, List *ancestors, ExplainState *es)
|
|||||||
List *result = NIL;
|
List *result = NIL;
|
||||||
bool useprefix;
|
bool useprefix;
|
||||||
ListCell *lc;
|
ListCell *lc;
|
||||||
int i;
|
|
||||||
|
|
||||||
/* No work if empty tlist (this occurs eg in bitmap indexscans) */
|
/* No work if empty tlist (this occurs eg in bitmap indexscans) */
|
||||||
if (plan->targetlist == NIL)
|
if (plan->targetlist == NIL)
|
||||||
@ -1290,7 +1289,6 @@ show_plan_tlist(PlanState *planstate, List *ancestors, ExplainState *es)
|
|||||||
useprefix = list_length(es->rtable) > 1;
|
useprefix = list_length(es->rtable) > 1;
|
||||||
|
|
||||||
/* Deparse each result column (we now include resjunk ones) */
|
/* Deparse each result column (we now include resjunk ones) */
|
||||||
i = 0;
|
|
||||||
foreach(lc, plan->targetlist)
|
foreach(lc, plan->targetlist)
|
||||||
{
|
{
|
||||||
TargetEntry *tle = (TargetEntry *) lfirst(lc);
|
TargetEntry *tle = (TargetEntry *) lfirst(lc);
|
||||||
|
@ -8164,14 +8164,12 @@ MergeAttributesIntoExisting(Relation child_rel, Relation parent_rel)
|
|||||||
AttrNumber parent_attno;
|
AttrNumber parent_attno;
|
||||||
int parent_natts;
|
int parent_natts;
|
||||||
TupleDesc tupleDesc;
|
TupleDesc tupleDesc;
|
||||||
TupleConstr *constr;
|
|
||||||
HeapTuple tuple;
|
HeapTuple tuple;
|
||||||
|
|
||||||
attrrel = heap_open(AttributeRelationId, RowExclusiveLock);
|
attrrel = heap_open(AttributeRelationId, RowExclusiveLock);
|
||||||
|
|
||||||
tupleDesc = RelationGetDescr(parent_rel);
|
tupleDesc = RelationGetDescr(parent_rel);
|
||||||
parent_natts = tupleDesc->natts;
|
parent_natts = tupleDesc->natts;
|
||||||
constr = tupleDesc->constr;
|
|
||||||
|
|
||||||
for (parent_attno = 1; parent_attno <= parent_natts; parent_attno++)
|
for (parent_attno = 1; parent_attno <= parent_natts; parent_attno++)
|
||||||
{
|
{
|
||||||
|
@ -2156,14 +2156,12 @@ DropConfigurationMapping(AlterTSConfigurationStmt *stmt,
|
|||||||
HeapTuple maptup;
|
HeapTuple maptup;
|
||||||
int i;
|
int i;
|
||||||
Oid prsId;
|
Oid prsId;
|
||||||
int *tokens,
|
int *tokens;
|
||||||
ntoken;
|
|
||||||
ListCell *c;
|
ListCell *c;
|
||||||
|
|
||||||
prsId = ((Form_pg_ts_config) GETSTRUCT(tup))->cfgparser;
|
prsId = ((Form_pg_ts_config) GETSTRUCT(tup))->cfgparser;
|
||||||
|
|
||||||
tokens = getTokenTypes(prsId, stmt->tokentype);
|
tokens = getTokenTypes(prsId, stmt->tokentype);
|
||||||
ntoken = list_length(stmt->tokentype);
|
|
||||||
|
|
||||||
i = 0;
|
i = 0;
|
||||||
foreach(c, stmt->tokentype)
|
foreach(c, stmt->tokentype)
|
||||||
|
@ -92,8 +92,7 @@ vacuum(VacuumStmt *vacstmt, Oid relid, bool do_toast,
|
|||||||
BufferAccessStrategy bstrategy, bool for_wraparound, bool isTopLevel)
|
BufferAccessStrategy bstrategy, bool for_wraparound, bool isTopLevel)
|
||||||
{
|
{
|
||||||
const char *stmttype;
|
const char *stmttype;
|
||||||
volatile bool all_rels,
|
volatile bool in_outer_xact,
|
||||||
in_outer_xact,
|
|
||||||
use_own_xacts;
|
use_own_xacts;
|
||||||
List *relations;
|
List *relations;
|
||||||
|
|
||||||
@ -153,9 +152,6 @@ vacuum(VacuumStmt *vacstmt, Oid relid, bool do_toast,
|
|||||||
}
|
}
|
||||||
vac_strategy = bstrategy;
|
vac_strategy = bstrategy;
|
||||||
|
|
||||||
/* Remember whether we are processing everything in the DB */
|
|
||||||
all_rels = (!OidIsValid(relid) && vacstmt->relation == NULL);
|
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* Build list of relations to process, unless caller gave us one. (If we
|
* Build list of relations to process, unless caller gave us one. (If we
|
||||||
* build one, we put it in vac_context for safekeeping.)
|
* build one, we put it in vac_context for safekeeping.)
|
||||||
|
@ -59,7 +59,6 @@ static bool ExecHashJoinNewBatch(HashJoinState *hjstate);
|
|||||||
TupleTableSlot * /* return: a tuple or NULL */
|
TupleTableSlot * /* return: a tuple or NULL */
|
||||||
ExecHashJoin(HashJoinState *node)
|
ExecHashJoin(HashJoinState *node)
|
||||||
{
|
{
|
||||||
EState *estate;
|
|
||||||
PlanState *outerNode;
|
PlanState *outerNode;
|
||||||
HashState *hashNode;
|
HashState *hashNode;
|
||||||
List *joinqual;
|
List *joinqual;
|
||||||
@ -74,7 +73,6 @@ ExecHashJoin(HashJoinState *node)
|
|||||||
/*
|
/*
|
||||||
* get information from HashJoin node
|
* get information from HashJoin node
|
||||||
*/
|
*/
|
||||||
estate = node->js.ps.state;
|
|
||||||
joinqual = node->js.joinqual;
|
joinqual = node->js.joinqual;
|
||||||
otherqual = node->js.ps.qual;
|
otherqual = node->js.ps.qual;
|
||||||
hashNode = (HashState *) innerPlanState(node);
|
hashNode = (HashState *) innerPlanState(node);
|
||||||
|
@ -639,7 +639,6 @@ ExecMergeTupleDump(MergeJoinState *mergestate)
|
|||||||
TupleTableSlot *
|
TupleTableSlot *
|
||||||
ExecMergeJoin(MergeJoinState *node)
|
ExecMergeJoin(MergeJoinState *node)
|
||||||
{
|
{
|
||||||
EState *estate;
|
|
||||||
List *joinqual;
|
List *joinqual;
|
||||||
List *otherqual;
|
List *otherqual;
|
||||||
bool qualResult;
|
bool qualResult;
|
||||||
@ -655,7 +654,6 @@ ExecMergeJoin(MergeJoinState *node)
|
|||||||
/*
|
/*
|
||||||
* get information from node
|
* get information from node
|
||||||
*/
|
*/
|
||||||
estate = node->js.ps.state;
|
|
||||||
innerPlan = innerPlanState(node);
|
innerPlan = innerPlanState(node);
|
||||||
outerPlan = outerPlanState(node);
|
outerPlan = outerPlanState(node);
|
||||||
econtext = node->js.ps.ps_ExprContext;
|
econtext = node->js.ps.ps_ExprContext;
|
||||||
|
@ -79,7 +79,6 @@ ExecRecursiveUnion(RecursiveUnionState *node)
|
|||||||
PlanState *innerPlan = innerPlanState(node);
|
PlanState *innerPlan = innerPlanState(node);
|
||||||
RecursiveUnion *plan = (RecursiveUnion *) node->ps.plan;
|
RecursiveUnion *plan = (RecursiveUnion *) node->ps.plan;
|
||||||
TupleTableSlot *slot;
|
TupleTableSlot *slot;
|
||||||
RUHashEntry entry;
|
|
||||||
bool isnew;
|
bool isnew;
|
||||||
|
|
||||||
/* 1. Evaluate non-recursive term */
|
/* 1. Evaluate non-recursive term */
|
||||||
@ -93,8 +92,7 @@ ExecRecursiveUnion(RecursiveUnionState *node)
|
|||||||
if (plan->numCols > 0)
|
if (plan->numCols > 0)
|
||||||
{
|
{
|
||||||
/* Find or build hashtable entry for this tuple's group */
|
/* Find or build hashtable entry for this tuple's group */
|
||||||
entry = (RUHashEntry)
|
LookupTupleHashEntry(node->hashtable, slot, &isnew);
|
||||||
LookupTupleHashEntry(node->hashtable, slot, &isnew);
|
|
||||||
/* Must reset temp context after each hashtable lookup */
|
/* Must reset temp context after each hashtable lookup */
|
||||||
MemoryContextReset(node->tempContext);
|
MemoryContextReset(node->tempContext);
|
||||||
/* Ignore tuple if already seen */
|
/* Ignore tuple if already seen */
|
||||||
@ -141,8 +139,7 @@ ExecRecursiveUnion(RecursiveUnionState *node)
|
|||||||
if (plan->numCols > 0)
|
if (plan->numCols > 0)
|
||||||
{
|
{
|
||||||
/* Find or build hashtable entry for this tuple's group */
|
/* Find or build hashtable entry for this tuple's group */
|
||||||
entry = (RUHashEntry)
|
LookupTupleHashEntry(node->hashtable, slot, &isnew);
|
||||||
LookupTupleHashEntry(node->hashtable, slot, &isnew);
|
|
||||||
/* Must reset temp context after each hashtable lookup */
|
/* Must reset temp context after each hashtable lookup */
|
||||||
MemoryContextReset(node->tempContext);
|
MemoryContextReset(node->tempContext);
|
||||||
/* Ignore tuple if already seen */
|
/* Ignore tuple if already seen */
|
||||||
|
@ -175,7 +175,6 @@ GetForeignServerByName(const char *srvname, bool missing_ok)
|
|||||||
UserMapping *
|
UserMapping *
|
||||||
GetUserMapping(Oid userid, Oid serverid)
|
GetUserMapping(Oid userid, Oid serverid)
|
||||||
{
|
{
|
||||||
Form_pg_user_mapping umform;
|
|
||||||
Datum datum;
|
Datum datum;
|
||||||
HeapTuple tp;
|
HeapTuple tp;
|
||||||
bool isnull;
|
bool isnull;
|
||||||
@ -199,8 +198,6 @@ GetUserMapping(Oid userid, Oid serverid)
|
|||||||
errmsg("user mapping not found for \"%s\"",
|
errmsg("user mapping not found for \"%s\"",
|
||||||
MappingUserName(userid))));
|
MappingUserName(userid))));
|
||||||
|
|
||||||
umform = (Form_pg_user_mapping) GETSTRUCT(tp);
|
|
||||||
|
|
||||||
um = (UserMapping *) palloc(sizeof(UserMapping));
|
um = (UserMapping *) palloc(sizeof(UserMapping));
|
||||||
um->userid = userid;
|
um->userid = userid;
|
||||||
um->serverid = serverid;
|
um->serverid = serverid;
|
||||||
|
@ -957,15 +957,14 @@ static void
|
|||||||
pg_GSS_error(int severity, char *errmsg, OM_uint32 maj_stat, OM_uint32 min_stat)
|
pg_GSS_error(int severity, char *errmsg, OM_uint32 maj_stat, OM_uint32 min_stat)
|
||||||
{
|
{
|
||||||
gss_buffer_desc gmsg;
|
gss_buffer_desc gmsg;
|
||||||
OM_uint32 lmaj_s,
|
OM_uint32 lmin_s,
|
||||||
lmin_s,
|
|
||||||
msg_ctx;
|
msg_ctx;
|
||||||
char msg_major[128],
|
char msg_major[128],
|
||||||
msg_minor[128];
|
msg_minor[128];
|
||||||
|
|
||||||
/* Fetch major status message */
|
/* Fetch major status message */
|
||||||
msg_ctx = 0;
|
msg_ctx = 0;
|
||||||
lmaj_s = gss_display_status(&lmin_s, maj_stat, GSS_C_GSS_CODE,
|
gss_display_status(&lmin_s, maj_stat, GSS_C_GSS_CODE,
|
||||||
GSS_C_NO_OID, &msg_ctx, &gmsg);
|
GSS_C_NO_OID, &msg_ctx, &gmsg);
|
||||||
strlcpy(msg_major, gmsg.value, sizeof(msg_major));
|
strlcpy(msg_major, gmsg.value, sizeof(msg_major));
|
||||||
gss_release_buffer(&lmin_s, &gmsg);
|
gss_release_buffer(&lmin_s, &gmsg);
|
||||||
@ -981,7 +980,7 @@ pg_GSS_error(int severity, char *errmsg, OM_uint32 maj_stat, OM_uint32 min_stat)
|
|||||||
|
|
||||||
/* Fetch mechanism minor status message */
|
/* Fetch mechanism minor status message */
|
||||||
msg_ctx = 0;
|
msg_ctx = 0;
|
||||||
lmaj_s = gss_display_status(&lmin_s, min_stat, GSS_C_MECH_CODE,
|
gss_display_status(&lmin_s, min_stat, GSS_C_MECH_CODE,
|
||||||
GSS_C_NO_OID, &msg_ctx, &gmsg);
|
GSS_C_NO_OID, &msg_ctx, &gmsg);
|
||||||
strlcpy(msg_minor, gmsg.value, sizeof(msg_minor));
|
strlcpy(msg_minor, gmsg.value, sizeof(msg_minor));
|
||||||
gss_release_buffer(&lmin_s, &gmsg);
|
gss_release_buffer(&lmin_s, &gmsg);
|
||||||
|
@ -73,15 +73,16 @@ geqo(PlannerInfo *root, int number_of_rels, List *initial_rels)
|
|||||||
Chromosome *kid;
|
Chromosome *kid;
|
||||||
Pool *pool;
|
Pool *pool;
|
||||||
int pool_size,
|
int pool_size,
|
||||||
number_generations,
|
number_generations;
|
||||||
status_interval;
|
#ifdef GEQO_DEBUG
|
||||||
|
int status_interval;
|
||||||
|
#endif
|
||||||
Gene *best_tour;
|
Gene *best_tour;
|
||||||
RelOptInfo *best_rel;
|
RelOptInfo *best_rel;
|
||||||
|
|
||||||
#if defined(ERX)
|
#if defined(ERX)
|
||||||
Edge *edge_table; /* list of edges */
|
Edge *edge_table; /* list of edges */
|
||||||
int edge_failures = 0;
|
int edge_failures = 0;
|
||||||
float difference;
|
|
||||||
#endif
|
#endif
|
||||||
#if defined(CX) || defined(PX) || defined(OX1) || defined(OX2)
|
#if defined(CX) || defined(PX) || defined(OX1) || defined(OX2)
|
||||||
City *city_table; /* list of cities */
|
City *city_table; /* list of cities */
|
||||||
@ -101,7 +102,9 @@ geqo(PlannerInfo *root, int number_of_rels, List *initial_rels)
|
|||||||
/* set GA parameters */
|
/* set GA parameters */
|
||||||
pool_size = gimme_pool_size(number_of_rels);
|
pool_size = gimme_pool_size(number_of_rels);
|
||||||
number_generations = gimme_number_generations(pool_size);
|
number_generations = gimme_number_generations(pool_size);
|
||||||
|
#ifdef GEQO_DEBUG
|
||||||
status_interval = 10;
|
status_interval = 10;
|
||||||
|
#endif
|
||||||
|
|
||||||
/* allocate genetic pool memory */
|
/* allocate genetic pool memory */
|
||||||
pool = alloc_pool(root, pool_size, number_of_rels);
|
pool = alloc_pool(root, pool_size, number_of_rels);
|
||||||
@ -178,7 +181,7 @@ geqo(PlannerInfo *root, int number_of_rels, List *initial_rels)
|
|||||||
|
|
||||||
#if defined (ERX)
|
#if defined (ERX)
|
||||||
/* EDGE RECOMBINATION CROSSOVER */
|
/* EDGE RECOMBINATION CROSSOVER */
|
||||||
difference = gimme_edge_table(root, momma->string, daddy->string, pool->string_length, edge_table);
|
gimme_edge_table(root, momma->string, daddy->string, pool->string_length, edge_table);
|
||||||
|
|
||||||
kid = momma;
|
kid = momma;
|
||||||
|
|
||||||
|
@ -2523,9 +2523,8 @@ transformColumnType(CreateStmtContext *cxt, ColumnDef *column)
|
|||||||
if (column->collClause)
|
if (column->collClause)
|
||||||
{
|
{
|
||||||
Form_pg_type typtup = (Form_pg_type) GETSTRUCT(ctype);
|
Form_pg_type typtup = (Form_pg_type) GETSTRUCT(ctype);
|
||||||
Oid collOid;
|
|
||||||
|
|
||||||
collOid = LookupCollation(cxt->pstate,
|
LookupCollation(cxt->pstate,
|
||||||
column->collClause->collname,
|
column->collClause->collname,
|
||||||
column->collClause->location);
|
column->collClause->location);
|
||||||
/* Complain if COLLATE is applied to an uncollatable type */
|
/* Complain if COLLATE is applied to an uncollatable type */
|
||||||
|
@ -232,7 +232,6 @@ DefineQueryRewrite(char *rulename,
|
|||||||
List *action)
|
List *action)
|
||||||
{
|
{
|
||||||
Relation event_relation;
|
Relation event_relation;
|
||||||
Oid ruleId;
|
|
||||||
int event_attno;
|
int event_attno;
|
||||||
ListCell *l;
|
ListCell *l;
|
||||||
Query *query;
|
Query *query;
|
||||||
@ -488,7 +487,7 @@ DefineQueryRewrite(char *rulename,
|
|||||||
/* discard rule if it's null action and not INSTEAD; it's a no-op */
|
/* discard rule if it's null action and not INSTEAD; it's a no-op */
|
||||||
if (action != NIL || is_instead)
|
if (action != NIL || is_instead)
|
||||||
{
|
{
|
||||||
ruleId = InsertRule(rulename,
|
InsertRule(rulename,
|
||||||
event_type,
|
event_type,
|
||||||
event_relid,
|
event_relid,
|
||||||
event_attno,
|
event_attno,
|
||||||
|
@ -334,7 +334,6 @@ static void
|
|||||||
ResolveRecoveryConflictWithLock(Oid dbOid, Oid relOid)
|
ResolveRecoveryConflictWithLock(Oid dbOid, Oid relOid)
|
||||||
{
|
{
|
||||||
VirtualTransactionId *backends;
|
VirtualTransactionId *backends;
|
||||||
bool report_memory_error = false;
|
|
||||||
bool lock_acquired = false;
|
bool lock_acquired = false;
|
||||||
int num_attempts = 0;
|
int num_attempts = 0;
|
||||||
LOCKTAG locktag;
|
LOCKTAG locktag;
|
||||||
@ -354,11 +353,8 @@ ResolveRecoveryConflictWithLock(Oid dbOid, Oid relOid)
|
|||||||
if (++num_attempts < 3)
|
if (++num_attempts < 3)
|
||||||
backends = GetLockConflicts(&locktag, AccessExclusiveLock);
|
backends = GetLockConflicts(&locktag, AccessExclusiveLock);
|
||||||
else
|
else
|
||||||
{
|
|
||||||
backends = GetConflictingVirtualXIDs(InvalidTransactionId,
|
backends = GetConflictingVirtualXIDs(InvalidTransactionId,
|
||||||
InvalidOid);
|
InvalidOid);
|
||||||
report_memory_error = true;
|
|
||||||
}
|
|
||||||
|
|
||||||
ResolveRecoveryConflictWithVirtualXIDs(backends,
|
ResolveRecoveryConflictWithVirtualXIDs(backends,
|
||||||
PROCSIG_RECOVERY_CONFLICT_LOCK);
|
PROCSIG_RECOVERY_CONFLICT_LOCK);
|
||||||
|
@ -901,13 +901,12 @@ void
|
|||||||
mdimmedsync(SMgrRelation reln, ForkNumber forknum)
|
mdimmedsync(SMgrRelation reln, ForkNumber forknum)
|
||||||
{
|
{
|
||||||
MdfdVec *v;
|
MdfdVec *v;
|
||||||
BlockNumber curnblk;
|
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* NOTE: mdnblocks makes sure we have opened all active segments, so that
|
* NOTE: mdnblocks makes sure we have opened all active segments, so that
|
||||||
* fsync loop will get them all!
|
* fsync loop will get them all!
|
||||||
*/
|
*/
|
||||||
curnblk = mdnblocks(reln, forknum);
|
mdnblocks(reln, forknum);
|
||||||
|
|
||||||
v = mdopen(reln, forknum, EXTENSION_FAIL);
|
v = mdopen(reln, forknum, EXTENSION_FAIL);
|
||||||
|
|
||||||
|
@ -255,7 +255,6 @@ RI_FKey_check(PG_FUNCTION_ARGS)
|
|||||||
Relation fk_rel;
|
Relation fk_rel;
|
||||||
Relation pk_rel;
|
Relation pk_rel;
|
||||||
HeapTuple new_row;
|
HeapTuple new_row;
|
||||||
HeapTuple old_row;
|
|
||||||
Buffer new_row_buf;
|
Buffer new_row_buf;
|
||||||
RI_QueryKey qkey;
|
RI_QueryKey qkey;
|
||||||
SPIPlanPtr qplan;
|
SPIPlanPtr qplan;
|
||||||
@ -274,13 +273,11 @@ RI_FKey_check(PG_FUNCTION_ARGS)
|
|||||||
|
|
||||||
if (TRIGGER_FIRED_BY_UPDATE(trigdata->tg_event))
|
if (TRIGGER_FIRED_BY_UPDATE(trigdata->tg_event))
|
||||||
{
|
{
|
||||||
old_row = trigdata->tg_trigtuple;
|
|
||||||
new_row = trigdata->tg_newtuple;
|
new_row = trigdata->tg_newtuple;
|
||||||
new_row_buf = trigdata->tg_newtuplebuf;
|
new_row_buf = trigdata->tg_newtuplebuf;
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
old_row = NULL;
|
|
||||||
new_row = trigdata->tg_trigtuple;
|
new_row = trigdata->tg_trigtuple;
|
||||||
new_row_buf = trigdata->tg_trigtuplebuf;
|
new_row_buf = trigdata->tg_trigtuplebuf;
|
||||||
}
|
}
|
||||||
|
@ -1081,7 +1081,6 @@ patternsel(PG_FUNCTION_ARGS, Pattern_Type ptype, bool negate)
|
|||||||
List *args = (List *) PG_GETARG_POINTER(2);
|
List *args = (List *) PG_GETARG_POINTER(2);
|
||||||
int varRelid = PG_GETARG_INT32(3);
|
int varRelid = PG_GETARG_INT32(3);
|
||||||
VariableStatData vardata;
|
VariableStatData vardata;
|
||||||
Node *variable;
|
|
||||||
Node *other;
|
Node *other;
|
||||||
bool varonleft;
|
bool varonleft;
|
||||||
Datum constval;
|
Datum constval;
|
||||||
@ -1123,7 +1122,6 @@ patternsel(PG_FUNCTION_ARGS, Pattern_Type ptype, bool negate)
|
|||||||
ReleaseVariableStats(vardata);
|
ReleaseVariableStats(vardata);
|
||||||
return result;
|
return result;
|
||||||
}
|
}
|
||||||
variable = (Node *) linitial(args);
|
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* If the constant is NULL, assume operator is strict and return zero, ie,
|
* If the constant is NULL, assume operator is strict and return zero, ie,
|
||||||
@ -2291,7 +2289,6 @@ eqjoinsel_semi(Oid operator,
|
|||||||
double nd1;
|
double nd1;
|
||||||
double nd2;
|
double nd2;
|
||||||
Form_pg_statistic stats1 = NULL;
|
Form_pg_statistic stats1 = NULL;
|
||||||
Form_pg_statistic stats2 = NULL;
|
|
||||||
bool have_mcvs1 = false;
|
bool have_mcvs1 = false;
|
||||||
Datum *values1 = NULL;
|
Datum *values1 = NULL;
|
||||||
int nvalues1 = 0;
|
int nvalues1 = 0;
|
||||||
@ -2321,7 +2318,6 @@ eqjoinsel_semi(Oid operator,
|
|||||||
|
|
||||||
if (HeapTupleIsValid(vardata2->statsTuple))
|
if (HeapTupleIsValid(vardata2->statsTuple))
|
||||||
{
|
{
|
||||||
stats2 = (Form_pg_statistic) GETSTRUCT(vardata2->statsTuple);
|
|
||||||
have_mcvs2 = get_attstatsslot(vardata2->statsTuple,
|
have_mcvs2 = get_attstatsslot(vardata2->statsTuple,
|
||||||
vardata2->atttype,
|
vardata2->atttype,
|
||||||
vardata2->atttypmod,
|
vardata2->atttypmod,
|
||||||
@ -4415,7 +4411,6 @@ get_variable_range(PlannerInfo *root, VariableStatData *vardata, Oid sortop,
|
|||||||
Datum tmin = 0;
|
Datum tmin = 0;
|
||||||
Datum tmax = 0;
|
Datum tmax = 0;
|
||||||
bool have_data = false;
|
bool have_data = false;
|
||||||
Form_pg_statistic stats;
|
|
||||||
int16 typLen;
|
int16 typLen;
|
||||||
bool typByVal;
|
bool typByVal;
|
||||||
Datum *values;
|
Datum *values;
|
||||||
@ -4439,7 +4434,6 @@ get_variable_range(PlannerInfo *root, VariableStatData *vardata, Oid sortop,
|
|||||||
/* no stats available, so default result */
|
/* no stats available, so default result */
|
||||||
return false;
|
return false;
|
||||||
}
|
}
|
||||||
stats = (Form_pg_statistic) GETSTRUCT(vardata->statsTuple);
|
|
||||||
|
|
||||||
get_typlenbyval(vardata->atttype, &typLen, &typByVal);
|
get_typlenbyval(vardata->atttype, &typLen, &typByVal);
|
||||||
|
|
||||||
|
@ -80,24 +80,9 @@ static int strInArray(const char *pattern, char **arr, int arr_size);
|
|||||||
TableInfo *
|
TableInfo *
|
||||||
getSchemaData(int *numTablesPtr)
|
getSchemaData(int *numTablesPtr)
|
||||||
{
|
{
|
||||||
NamespaceInfo *nsinfo;
|
|
||||||
ExtensionInfo *extinfo;
|
ExtensionInfo *extinfo;
|
||||||
AggInfo *agginfo;
|
|
||||||
InhInfo *inhinfo;
|
InhInfo *inhinfo;
|
||||||
RuleInfo *ruleinfo;
|
|
||||||
ProcLangInfo *proclanginfo;
|
|
||||||
CastInfo *castinfo;
|
|
||||||
OpclassInfo *opcinfo;
|
|
||||||
OpfamilyInfo *opfinfo;
|
|
||||||
CollInfo *collinfo;
|
CollInfo *collinfo;
|
||||||
ConvInfo *convinfo;
|
|
||||||
TSParserInfo *prsinfo;
|
|
||||||
TSTemplateInfo *tmplinfo;
|
|
||||||
TSDictInfo *dictinfo;
|
|
||||||
TSConfigInfo *cfginfo;
|
|
||||||
FdwInfo *fdwinfo;
|
|
||||||
ForeignServerInfo *srvinfo;
|
|
||||||
DefaultACLInfo *daclinfo;
|
|
||||||
int numNamespaces;
|
int numNamespaces;
|
||||||
int numExtensions;
|
int numExtensions;
|
||||||
int numAggregates;
|
int numAggregates;
|
||||||
@ -118,7 +103,7 @@ getSchemaData(int *numTablesPtr)
|
|||||||
|
|
||||||
if (g_verbose)
|
if (g_verbose)
|
||||||
write_msg(NULL, "reading schemas\n");
|
write_msg(NULL, "reading schemas\n");
|
||||||
nsinfo = getNamespaces(&numNamespaces);
|
getNamespaces(&numNamespaces);
|
||||||
|
|
||||||
if (g_verbose)
|
if (g_verbose)
|
||||||
write_msg(NULL, "reading extensions\n");
|
write_msg(NULL, "reading extensions\n");
|
||||||
@ -138,11 +123,11 @@ getSchemaData(int *numTablesPtr)
|
|||||||
/* this must be after getFuncs, too */
|
/* this must be after getFuncs, too */
|
||||||
if (g_verbose)
|
if (g_verbose)
|
||||||
write_msg(NULL, "reading procedural languages\n");
|
write_msg(NULL, "reading procedural languages\n");
|
||||||
proclanginfo = getProcLangs(&numProcLangs);
|
getProcLangs(&numProcLangs);
|
||||||
|
|
||||||
if (g_verbose)
|
if (g_verbose)
|
||||||
write_msg(NULL, "reading user-defined aggregate functions\n");
|
write_msg(NULL, "reading user-defined aggregate functions\n");
|
||||||
agginfo = getAggregates(&numAggregates);
|
getAggregates(&numAggregates);
|
||||||
|
|
||||||
if (g_verbose)
|
if (g_verbose)
|
||||||
write_msg(NULL, "reading user-defined operators\n");
|
write_msg(NULL, "reading user-defined operators\n");
|
||||||
@ -151,39 +136,39 @@ getSchemaData(int *numTablesPtr)
|
|||||||
|
|
||||||
if (g_verbose)
|
if (g_verbose)
|
||||||
write_msg(NULL, "reading user-defined operator classes\n");
|
write_msg(NULL, "reading user-defined operator classes\n");
|
||||||
opcinfo = getOpclasses(&numOpclasses);
|
getOpclasses(&numOpclasses);
|
||||||
|
|
||||||
if (g_verbose)
|
if (g_verbose)
|
||||||
write_msg(NULL, "reading user-defined operator families\n");
|
write_msg(NULL, "reading user-defined operator families\n");
|
||||||
opfinfo = getOpfamilies(&numOpfamilies);
|
getOpfamilies(&numOpfamilies);
|
||||||
|
|
||||||
if (g_verbose)
|
if (g_verbose)
|
||||||
write_msg(NULL, "reading user-defined text search parsers\n");
|
write_msg(NULL, "reading user-defined text search parsers\n");
|
||||||
prsinfo = getTSParsers(&numTSParsers);
|
getTSParsers(&numTSParsers);
|
||||||
|
|
||||||
if (g_verbose)
|
if (g_verbose)
|
||||||
write_msg(NULL, "reading user-defined text search templates\n");
|
write_msg(NULL, "reading user-defined text search templates\n");
|
||||||
tmplinfo = getTSTemplates(&numTSTemplates);
|
getTSTemplates(&numTSTemplates);
|
||||||
|
|
||||||
if (g_verbose)
|
if (g_verbose)
|
||||||
write_msg(NULL, "reading user-defined text search dictionaries\n");
|
write_msg(NULL, "reading user-defined text search dictionaries\n");
|
||||||
dictinfo = getTSDictionaries(&numTSDicts);
|
getTSDictionaries(&numTSDicts);
|
||||||
|
|
||||||
if (g_verbose)
|
if (g_verbose)
|
||||||
write_msg(NULL, "reading user-defined text search configurations\n");
|
write_msg(NULL, "reading user-defined text search configurations\n");
|
||||||
cfginfo = getTSConfigurations(&numTSConfigs);
|
getTSConfigurations(&numTSConfigs);
|
||||||
|
|
||||||
if (g_verbose)
|
if (g_verbose)
|
||||||
write_msg(NULL, "reading user-defined foreign-data wrappers\n");
|
write_msg(NULL, "reading user-defined foreign-data wrappers\n");
|
||||||
fdwinfo = getForeignDataWrappers(&numForeignDataWrappers);
|
getForeignDataWrappers(&numForeignDataWrappers);
|
||||||
|
|
||||||
if (g_verbose)
|
if (g_verbose)
|
||||||
write_msg(NULL, "reading user-defined foreign servers\n");
|
write_msg(NULL, "reading user-defined foreign servers\n");
|
||||||
srvinfo = getForeignServers(&numForeignServers);
|
getForeignServers(&numForeignServers);
|
||||||
|
|
||||||
if (g_verbose)
|
if (g_verbose)
|
||||||
write_msg(NULL, "reading default privileges\n");
|
write_msg(NULL, "reading default privileges\n");
|
||||||
daclinfo = getDefaultACLs(&numDefaultACLs);
|
getDefaultACLs(&numDefaultACLs);
|
||||||
|
|
||||||
if (g_verbose)
|
if (g_verbose)
|
||||||
write_msg(NULL, "reading user-defined collations\n");
|
write_msg(NULL, "reading user-defined collations\n");
|
||||||
@ -192,11 +177,11 @@ getSchemaData(int *numTablesPtr)
|
|||||||
|
|
||||||
if (g_verbose)
|
if (g_verbose)
|
||||||
write_msg(NULL, "reading user-defined conversions\n");
|
write_msg(NULL, "reading user-defined conversions\n");
|
||||||
convinfo = getConversions(&numConversions);
|
getConversions(&numConversions);
|
||||||
|
|
||||||
if (g_verbose)
|
if (g_verbose)
|
||||||
write_msg(NULL, "reading type casts\n");
|
write_msg(NULL, "reading type casts\n");
|
||||||
castinfo = getCasts(&numCasts);
|
getCasts(&numCasts);
|
||||||
|
|
||||||
if (g_verbose)
|
if (g_verbose)
|
||||||
write_msg(NULL, "reading user-defined tables\n");
|
write_msg(NULL, "reading user-defined tables\n");
|
||||||
@ -209,7 +194,7 @@ getSchemaData(int *numTablesPtr)
|
|||||||
|
|
||||||
if (g_verbose)
|
if (g_verbose)
|
||||||
write_msg(NULL, "reading rewrite rules\n");
|
write_msg(NULL, "reading rewrite rules\n");
|
||||||
ruleinfo = getRules(&numRules);
|
getRules(&numRules);
|
||||||
|
|
||||||
/*
|
/*
|
||||||
* Identify extension member objects and mark them as not to be dumped.
|
* Identify extension member objects and mark them as not to be dumped.
|
||||||
|
@ -237,7 +237,6 @@ _WriteExtraToc(ArchiveHandle *AH, TocEntry *te)
|
|||||||
static void
|
static void
|
||||||
_ReadExtraToc(ArchiveHandle *AH, TocEntry *te)
|
_ReadExtraToc(ArchiveHandle *AH, TocEntry *te)
|
||||||
{
|
{
|
||||||
int junk;
|
|
||||||
lclTocEntry *ctx = (lclTocEntry *) te->formatData;
|
lclTocEntry *ctx = (lclTocEntry *) te->formatData;
|
||||||
|
|
||||||
if (ctx == NULL)
|
if (ctx == NULL)
|
||||||
@ -253,7 +252,7 @@ _ReadExtraToc(ArchiveHandle *AH, TocEntry *te)
|
|||||||
* dump it at all.
|
* dump it at all.
|
||||||
*/
|
*/
|
||||||
if (AH->version < K_VERS_1_7)
|
if (AH->version < K_VERS_1_7)
|
||||||
junk = ReadInt(AH);
|
ReadInt(AH);
|
||||||
}
|
}
|
||||||
|
|
||||||
/*
|
/*
|
||||||
|
@ -7389,8 +7389,6 @@ dumpBaseType(Archive *fout, TypeInfo *tyinfo)
|
|||||||
char *typmodin;
|
char *typmodin;
|
||||||
char *typmodout;
|
char *typmodout;
|
||||||
char *typanalyze;
|
char *typanalyze;
|
||||||
Oid typinputoid;
|
|
||||||
Oid typoutputoid;
|
|
||||||
Oid typreceiveoid;
|
Oid typreceiveoid;
|
||||||
Oid typsendoid;
|
Oid typsendoid;
|
||||||
Oid typmodinoid;
|
Oid typmodinoid;
|
||||||
@ -7415,8 +7413,6 @@ dumpBaseType(Archive *fout, TypeInfo *tyinfo)
|
|||||||
appendPQExpBuffer(query, "SELECT typlen, "
|
appendPQExpBuffer(query, "SELECT typlen, "
|
||||||
"typinput, typoutput, typreceive, typsend, "
|
"typinput, typoutput, typreceive, typsend, "
|
||||||
"typmodin, typmodout, typanalyze, "
|
"typmodin, typmodout, typanalyze, "
|
||||||
"typinput::pg_catalog.oid AS typinputoid, "
|
|
||||||
"typoutput::pg_catalog.oid AS typoutputoid, "
|
|
||||||
"typreceive::pg_catalog.oid AS typreceiveoid, "
|
"typreceive::pg_catalog.oid AS typreceiveoid, "
|
||||||
"typsend::pg_catalog.oid AS typsendoid, "
|
"typsend::pg_catalog.oid AS typsendoid, "
|
||||||
"typmodin::pg_catalog.oid AS typmodinoid, "
|
"typmodin::pg_catalog.oid AS typmodinoid, "
|
||||||
@ -7435,8 +7431,6 @@ dumpBaseType(Archive *fout, TypeInfo *tyinfo)
|
|||||||
appendPQExpBuffer(query, "SELECT typlen, "
|
appendPQExpBuffer(query, "SELECT typlen, "
|
||||||
"typinput, typoutput, typreceive, typsend, "
|
"typinput, typoutput, typreceive, typsend, "
|
||||||
"typmodin, typmodout, typanalyze, "
|
"typmodin, typmodout, typanalyze, "
|
||||||
"typinput::pg_catalog.oid AS typinputoid, "
|
|
||||||
"typoutput::pg_catalog.oid AS typoutputoid, "
|
|
||||||
"typreceive::pg_catalog.oid AS typreceiveoid, "
|
"typreceive::pg_catalog.oid AS typreceiveoid, "
|
||||||
"typsend::pg_catalog.oid AS typsendoid, "
|
"typsend::pg_catalog.oid AS typsendoid, "
|
||||||
"typmodin::pg_catalog.oid AS typmodinoid, "
|
"typmodin::pg_catalog.oid AS typmodinoid, "
|
||||||
@ -7456,8 +7450,6 @@ dumpBaseType(Archive *fout, TypeInfo *tyinfo)
|
|||||||
appendPQExpBuffer(query, "SELECT typlen, "
|
appendPQExpBuffer(query, "SELECT typlen, "
|
||||||
"typinput, typoutput, typreceive, typsend, "
|
"typinput, typoutput, typreceive, typsend, "
|
||||||
"typmodin, typmodout, typanalyze, "
|
"typmodin, typmodout, typanalyze, "
|
||||||
"typinput::pg_catalog.oid AS typinputoid, "
|
|
||||||
"typoutput::pg_catalog.oid AS typoutputoid, "
|
|
||||||
"typreceive::pg_catalog.oid AS typreceiveoid, "
|
"typreceive::pg_catalog.oid AS typreceiveoid, "
|
||||||
"typsend::pg_catalog.oid AS typsendoid, "
|
"typsend::pg_catalog.oid AS typsendoid, "
|
||||||
"typmodin::pg_catalog.oid AS typmodinoid, "
|
"typmodin::pg_catalog.oid AS typmodinoid, "
|
||||||
@ -7477,8 +7469,6 @@ dumpBaseType(Archive *fout, TypeInfo *tyinfo)
|
|||||||
"typinput, typoutput, typreceive, typsend, "
|
"typinput, typoutput, typreceive, typsend, "
|
||||||
"'-' AS typmodin, '-' AS typmodout, "
|
"'-' AS typmodin, '-' AS typmodout, "
|
||||||
"typanalyze, "
|
"typanalyze, "
|
||||||
"typinput::pg_catalog.oid AS typinputoid, "
|
|
||||||
"typoutput::pg_catalog.oid AS typoutputoid, "
|
|
||||||
"typreceive::pg_catalog.oid AS typreceiveoid, "
|
"typreceive::pg_catalog.oid AS typreceiveoid, "
|
||||||
"typsend::pg_catalog.oid AS typsendoid, "
|
"typsend::pg_catalog.oid AS typsendoid, "
|
||||||
"0 AS typmodinoid, 0 AS typmodoutoid, "
|
"0 AS typmodinoid, 0 AS typmodoutoid, "
|
||||||
@ -7497,8 +7487,6 @@ dumpBaseType(Archive *fout, TypeInfo *tyinfo)
|
|||||||
"typinput, typoutput, typreceive, typsend, "
|
"typinput, typoutput, typreceive, typsend, "
|
||||||
"'-' AS typmodin, '-' AS typmodout, "
|
"'-' AS typmodin, '-' AS typmodout, "
|
||||||
"'-' AS typanalyze, "
|
"'-' AS typanalyze, "
|
||||||
"typinput::pg_catalog.oid AS typinputoid, "
|
|
||||||
"typoutput::pg_catalog.oid AS typoutputoid, "
|
|
||||||
"typreceive::pg_catalog.oid AS typreceiveoid, "
|
"typreceive::pg_catalog.oid AS typreceiveoid, "
|
||||||
"typsend::pg_catalog.oid AS typsendoid, "
|
"typsend::pg_catalog.oid AS typsendoid, "
|
||||||
"0 AS typmodinoid, 0 AS typmodoutoid, "
|
"0 AS typmodinoid, 0 AS typmodoutoid, "
|
||||||
@ -7518,8 +7506,6 @@ dumpBaseType(Archive *fout, TypeInfo *tyinfo)
|
|||||||
"'-' AS typreceive, '-' AS typsend, "
|
"'-' AS typreceive, '-' AS typsend, "
|
||||||
"'-' AS typmodin, '-' AS typmodout, "
|
"'-' AS typmodin, '-' AS typmodout, "
|
||||||
"'-' AS typanalyze, "
|
"'-' AS typanalyze, "
|
||||||
"typinput::pg_catalog.oid AS typinputoid, "
|
|
||||||
"typoutput::pg_catalog.oid AS typoutputoid, "
|
|
||||||
"0 AS typreceiveoid, 0 AS typsendoid, "
|
"0 AS typreceiveoid, 0 AS typsendoid, "
|
||||||
"0 AS typmodinoid, 0 AS typmodoutoid, "
|
"0 AS typmodinoid, 0 AS typmodoutoid, "
|
||||||
"0 AS typanalyzeoid, "
|
"0 AS typanalyzeoid, "
|
||||||
@ -7542,8 +7528,6 @@ dumpBaseType(Archive *fout, TypeInfo *tyinfo)
|
|||||||
"'-' AS typreceive, '-' AS typsend, "
|
"'-' AS typreceive, '-' AS typsend, "
|
||||||
"'-' AS typmodin, '-' AS typmodout, "
|
"'-' AS typmodin, '-' AS typmodout, "
|
||||||
"'-' AS typanalyze, "
|
"'-' AS typanalyze, "
|
||||||
"typinput::oid AS typinputoid, "
|
|
||||||
"typoutput::oid AS typoutputoid, "
|
|
||||||
"0 AS typreceiveoid, 0 AS typsendoid, "
|
"0 AS typreceiveoid, 0 AS typsendoid, "
|
||||||
"0 AS typmodinoid, 0 AS typmodoutoid, "
|
"0 AS typmodinoid, 0 AS typmodoutoid, "
|
||||||
"0 AS typanalyzeoid, "
|
"0 AS typanalyzeoid, "
|
||||||
@ -7566,8 +7550,6 @@ dumpBaseType(Archive *fout, TypeInfo *tyinfo)
|
|||||||
"'-' AS typreceive, '-' AS typsend, "
|
"'-' AS typreceive, '-' AS typsend, "
|
||||||
"'-' AS typmodin, '-' AS typmodout, "
|
"'-' AS typmodin, '-' AS typmodout, "
|
||||||
"'-' AS typanalyze, "
|
"'-' AS typanalyze, "
|
||||||
"typinput::oid AS typinputoid, "
|
|
||||||
"typoutput::oid AS typoutputoid, "
|
|
||||||
"0 AS typreceiveoid, 0 AS typsendoid, "
|
"0 AS typreceiveoid, 0 AS typsendoid, "
|
||||||
"0 AS typmodinoid, 0 AS typmodoutoid, "
|
"0 AS typmodinoid, 0 AS typmodoutoid, "
|
||||||
"0 AS typanalyzeoid, "
|
"0 AS typanalyzeoid, "
|
||||||
@ -7586,8 +7568,6 @@ dumpBaseType(Archive *fout, TypeInfo *tyinfo)
|
|||||||
"'-' AS typreceive, '-' AS typsend, "
|
"'-' AS typreceive, '-' AS typsend, "
|
||||||
"'-' AS typmodin, '-' AS typmodout, "
|
"'-' AS typmodin, '-' AS typmodout, "
|
||||||
"'-' AS typanalyze, "
|
"'-' AS typanalyze, "
|
||||||
"typinput::oid AS typinputoid, "
|
|
||||||
"typoutput::oid AS typoutputoid, "
|
|
||||||
"0 AS typreceiveoid, 0 AS typsendoid, "
|
"0 AS typreceiveoid, 0 AS typsendoid, "
|
||||||
"0 AS typmodinoid, 0 AS typmodoutoid, "
|
"0 AS typmodinoid, 0 AS typmodoutoid, "
|
||||||
"0 AS typanalyzeoid, "
|
"0 AS typanalyzeoid, "
|
||||||
@ -7623,8 +7603,6 @@ dumpBaseType(Archive *fout, TypeInfo *tyinfo)
|
|||||||
typmodin = PQgetvalue(res, 0, PQfnumber(res, "typmodin"));
|
typmodin = PQgetvalue(res, 0, PQfnumber(res, "typmodin"));
|
||||||
typmodout = PQgetvalue(res, 0, PQfnumber(res, "typmodout"));
|
typmodout = PQgetvalue(res, 0, PQfnumber(res, "typmodout"));
|
||||||
typanalyze = PQgetvalue(res, 0, PQfnumber(res, "typanalyze"));
|
typanalyze = PQgetvalue(res, 0, PQfnumber(res, "typanalyze"));
|
||||||
typinputoid = atooid(PQgetvalue(res, 0, PQfnumber(res, "typinputoid")));
|
|
||||||
typoutputoid = atooid(PQgetvalue(res, 0, PQfnumber(res, "typoutputoid")));
|
|
||||||
typreceiveoid = atooid(PQgetvalue(res, 0, PQfnumber(res, "typreceiveoid")));
|
typreceiveoid = atooid(PQgetvalue(res, 0, PQfnumber(res, "typreceiveoid")));
|
||||||
typsendoid = atooid(PQgetvalue(res, 0, PQfnumber(res, "typsendoid")));
|
typsendoid = atooid(PQgetvalue(res, 0, PQfnumber(res, "typsendoid")));
|
||||||
typmodinoid = atooid(PQgetvalue(res, 0, PQfnumber(res, "typmodinoid")));
|
typmodinoid = atooid(PQgetvalue(res, 0, PQfnumber(res, "typmodinoid")));
|
||||||
@ -10218,10 +10196,8 @@ dumpCollation(Archive *fout, CollInfo *collinfo)
|
|||||||
PQExpBuffer labelq;
|
PQExpBuffer labelq;
|
||||||
PGresult *res;
|
PGresult *res;
|
||||||
int ntups;
|
int ntups;
|
||||||
int i_collname;
|
|
||||||
int i_collcollate;
|
int i_collcollate;
|
||||||
int i_collctype;
|
int i_collctype;
|
||||||
const char *collname;
|
|
||||||
const char *collcollate;
|
const char *collcollate;
|
||||||
const char *collctype;
|
const char *collctype;
|
||||||
|
|
||||||
@ -10238,7 +10214,7 @@ dumpCollation(Archive *fout, CollInfo *collinfo)
|
|||||||
selectSourceSchema(collinfo->dobj.namespace->dobj.name);
|
selectSourceSchema(collinfo->dobj.namespace->dobj.name);
|
||||||
|
|
||||||
/* Get conversion-specific details */
|
/* Get conversion-specific details */
|
||||||
appendPQExpBuffer(query, "SELECT collname, "
|
appendPQExpBuffer(query, "SELECT "
|
||||||
"collcollate, "
|
"collcollate, "
|
||||||
"collctype "
|
"collctype "
|
||||||
"FROM pg_catalog.pg_collation c "
|
"FROM pg_catalog.pg_collation c "
|
||||||
@ -10259,11 +10235,9 @@ dumpCollation(Archive *fout, CollInfo *collinfo)
|
|||||||
exit_nicely();
|
exit_nicely();
|
||||||
}
|
}
|
||||||
|
|
||||||
i_collname = PQfnumber(res, "collname");
|
|
||||||
i_collcollate = PQfnumber(res, "collcollate");
|
i_collcollate = PQfnumber(res, "collcollate");
|
||||||
i_collctype = PQfnumber(res, "collctype");
|
i_collctype = PQfnumber(res, "collctype");
|
||||||
|
|
||||||
collname = PQgetvalue(res, 0, i_collname);
|
|
||||||
collcollate = PQgetvalue(res, 0, i_collcollate);
|
collcollate = PQgetvalue(res, 0, i_collcollate);
|
||||||
collctype = PQgetvalue(res, 0, i_collctype);
|
collctype = PQgetvalue(res, 0, i_collctype);
|
||||||
|
|
||||||
@ -10323,12 +10297,10 @@ dumpConversion(Archive *fout, ConvInfo *convinfo)
|
|||||||
PQExpBuffer labelq;
|
PQExpBuffer labelq;
|
||||||
PGresult *res;
|
PGresult *res;
|
||||||
int ntups;
|
int ntups;
|
||||||
int i_conname;
|
|
||||||
int i_conforencoding;
|
int i_conforencoding;
|
||||||
int i_contoencoding;
|
int i_contoencoding;
|
||||||
int i_conproc;
|
int i_conproc;
|
||||||
int i_condefault;
|
int i_condefault;
|
||||||
const char *conname;
|
|
||||||
const char *conforencoding;
|
const char *conforencoding;
|
||||||
const char *contoencoding;
|
const char *contoencoding;
|
||||||
const char *conproc;
|
const char *conproc;
|
||||||
@ -10347,7 +10319,7 @@ dumpConversion(Archive *fout, ConvInfo *convinfo)
|
|||||||
selectSourceSchema(convinfo->dobj.namespace->dobj.name);
|
selectSourceSchema(convinfo->dobj.namespace->dobj.name);
|
||||||
|
|
||||||
/* Get conversion-specific details */
|
/* Get conversion-specific details */
|
||||||
appendPQExpBuffer(query, "SELECT conname, "
|
appendPQExpBuffer(query, "SELECT "
|
||||||
"pg_catalog.pg_encoding_to_char(conforencoding) AS conforencoding, "
|
"pg_catalog.pg_encoding_to_char(conforencoding) AS conforencoding, "
|
||||||
"pg_catalog.pg_encoding_to_char(contoencoding) AS contoencoding, "
|
"pg_catalog.pg_encoding_to_char(contoencoding) AS contoencoding, "
|
||||||
"conproc, condefault "
|
"conproc, condefault "
|
||||||
@ -10369,13 +10341,11 @@ dumpConversion(Archive *fout, ConvInfo *convinfo)
|
|||||||
exit_nicely();
|
exit_nicely();
|
||||||
}
|
}
|
||||||
|
|
||||||
i_conname = PQfnumber(res, "conname");
|
|
||||||
i_conforencoding = PQfnumber(res, "conforencoding");
|
i_conforencoding = PQfnumber(res, "conforencoding");
|
||||||
i_contoencoding = PQfnumber(res, "contoencoding");
|
i_contoencoding = PQfnumber(res, "contoencoding");
|
||||||
i_conproc = PQfnumber(res, "conproc");
|
i_conproc = PQfnumber(res, "conproc");
|
||||||
i_condefault = PQfnumber(res, "condefault");
|
i_condefault = PQfnumber(res, "condefault");
|
||||||
|
|
||||||
conname = PQgetvalue(res, 0, i_conname);
|
|
||||||
conforencoding = PQgetvalue(res, 0, i_conforencoding);
|
conforencoding = PQgetvalue(res, 0, i_conforencoding);
|
||||||
contoencoding = PQgetvalue(res, 0, i_contoencoding);
|
contoencoding = PQgetvalue(res, 0, i_contoencoding);
|
||||||
conproc = PQgetvalue(res, 0, i_conproc);
|
conproc = PQgetvalue(res, 0, i_conproc);
|
||||||
@ -11858,7 +11828,6 @@ dumpTableSchema(Archive *fout, TableInfo *tbinfo)
|
|||||||
char *storage;
|
char *storage;
|
||||||
int j,
|
int j,
|
||||||
k;
|
k;
|
||||||
bool toast_set = false;
|
|
||||||
char *srvname;
|
char *srvname;
|
||||||
char *ftoptions = NULL;
|
char *ftoptions = NULL;
|
||||||
|
|
||||||
@ -11866,7 +11835,7 @@ dumpTableSchema(Archive *fout, TableInfo *tbinfo)
|
|||||||
selectSourceSchema(tbinfo->dobj.namespace->dobj.name);
|
selectSourceSchema(tbinfo->dobj.namespace->dobj.name);
|
||||||
|
|
||||||
if (binary_upgrade)
|
if (binary_upgrade)
|
||||||
toast_set = binary_upgrade_set_type_oids_by_rel_oid(q,
|
binary_upgrade_set_type_oids_by_rel_oid(q,
|
||||||
tbinfo->dobj.catId.oid);
|
tbinfo->dobj.catId.oid);
|
||||||
|
|
||||||
/* Is it a table or a view? */
|
/* Is it a table or a view? */
|
||||||
|
@ -91,7 +91,6 @@ main(int argc, char *argv[])
|
|||||||
bool output_clean = false;
|
bool output_clean = false;
|
||||||
bool roles_only = false;
|
bool roles_only = false;
|
||||||
bool tablespaces_only = false;
|
bool tablespaces_only = false;
|
||||||
bool schema_only = false;
|
|
||||||
PGconn *conn;
|
PGconn *conn;
|
||||||
int encoding;
|
int encoding;
|
||||||
const char *std_strings;
|
const char *std_strings;
|
||||||
@ -241,7 +240,6 @@ main(int argc, char *argv[])
|
|||||||
break;
|
break;
|
||||||
|
|
||||||
case 's':
|
case 's':
|
||||||
schema_only = true;
|
|
||||||
appendPQExpBuffer(pgdumpopts, " -s");
|
appendPQExpBuffer(pgdumpopts, " -s");
|
||||||
break;
|
break;
|
||||||
|
|
||||||
@ -632,7 +630,6 @@ dumpRoles(PGconn *conn)
|
|||||||
i_rolinherit,
|
i_rolinherit,
|
||||||
i_rolcreaterole,
|
i_rolcreaterole,
|
||||||
i_rolcreatedb,
|
i_rolcreatedb,
|
||||||
i_rolcatupdate,
|
|
||||||
i_rolcanlogin,
|
i_rolcanlogin,
|
||||||
i_rolconnlimit,
|
i_rolconnlimit,
|
||||||
i_rolpassword,
|
i_rolpassword,
|
||||||
@ -645,7 +642,7 @@ dumpRoles(PGconn *conn)
|
|||||||
if (server_version >= 90100)
|
if (server_version >= 90100)
|
||||||
printfPQExpBuffer(buf,
|
printfPQExpBuffer(buf,
|
||||||
"SELECT oid, rolname, rolsuper, rolinherit, "
|
"SELECT oid, rolname, rolsuper, rolinherit, "
|
||||||
"rolcreaterole, rolcreatedb, rolcatupdate, "
|
"rolcreaterole, rolcreatedb, "
|
||||||
"rolcanlogin, rolconnlimit, rolpassword, "
|
"rolcanlogin, rolconnlimit, rolpassword, "
|
||||||
"rolvaliduntil, rolreplication, "
|
"rolvaliduntil, rolreplication, "
|
||||||
"pg_catalog.shobj_description(oid, 'pg_authid') as rolcomment "
|
"pg_catalog.shobj_description(oid, 'pg_authid') as rolcomment "
|
||||||
@ -654,7 +651,7 @@ dumpRoles(PGconn *conn)
|
|||||||
else if (server_version >= 80200)
|
else if (server_version >= 80200)
|
||||||
printfPQExpBuffer(buf,
|
printfPQExpBuffer(buf,
|
||||||
"SELECT oid, rolname, rolsuper, rolinherit, "
|
"SELECT oid, rolname, rolsuper, rolinherit, "
|
||||||
"rolcreaterole, rolcreatedb, rolcatupdate, "
|
"rolcreaterole, rolcreatedb, "
|
||||||
"rolcanlogin, rolconnlimit, rolpassword, "
|
"rolcanlogin, rolconnlimit, rolpassword, "
|
||||||
"rolvaliduntil, false as rolreplication, "
|
"rolvaliduntil, false as rolreplication, "
|
||||||
"pg_catalog.shobj_description(oid, 'pg_authid') as rolcomment "
|
"pg_catalog.shobj_description(oid, 'pg_authid') as rolcomment "
|
||||||
@ -663,7 +660,7 @@ dumpRoles(PGconn *conn)
|
|||||||
else if (server_version >= 80100)
|
else if (server_version >= 80100)
|
||||||
printfPQExpBuffer(buf,
|
printfPQExpBuffer(buf,
|
||||||
"SELECT oid, rolname, rolsuper, rolinherit, "
|
"SELECT oid, rolname, rolsuper, rolinherit, "
|
||||||
"rolcreaterole, rolcreatedb, rolcatupdate, "
|
"rolcreaterole, rolcreatedb, "
|
||||||
"rolcanlogin, rolconnlimit, rolpassword, "
|
"rolcanlogin, rolconnlimit, rolpassword, "
|
||||||
"rolvaliduntil, false as rolreplication, "
|
"rolvaliduntil, false as rolreplication, "
|
||||||
"null as rolcomment "
|
"null as rolcomment "
|
||||||
@ -676,7 +673,6 @@ dumpRoles(PGconn *conn)
|
|||||||
"true as rolinherit, "
|
"true as rolinherit, "
|
||||||
"usesuper as rolcreaterole, "
|
"usesuper as rolcreaterole, "
|
||||||
"usecreatedb as rolcreatedb, "
|
"usecreatedb as rolcreatedb, "
|
||||||
"usecatupd as rolcatupdate, "
|
|
||||||
"true as rolcanlogin, "
|
"true as rolcanlogin, "
|
||||||
"-1 as rolconnlimit, "
|
"-1 as rolconnlimit, "
|
||||||
"passwd as rolpassword, "
|
"passwd as rolpassword, "
|
||||||
@ -690,7 +686,6 @@ dumpRoles(PGconn *conn)
|
|||||||
"true as rolinherit, "
|
"true as rolinherit, "
|
||||||
"false as rolcreaterole, "
|
"false as rolcreaterole, "
|
||||||
"false as rolcreatedb, "
|
"false as rolcreatedb, "
|
||||||
"false as rolcatupdate, "
|
|
||||||
"false as rolcanlogin, "
|
"false as rolcanlogin, "
|
||||||
"-1 as rolconnlimit, "
|
"-1 as rolconnlimit, "
|
||||||
"null::text as rolpassword, "
|
"null::text as rolpassword, "
|
||||||
@ -710,7 +705,6 @@ dumpRoles(PGconn *conn)
|
|||||||
i_rolinherit = PQfnumber(res, "rolinherit");
|
i_rolinherit = PQfnumber(res, "rolinherit");
|
||||||
i_rolcreaterole = PQfnumber(res, "rolcreaterole");
|
i_rolcreaterole = PQfnumber(res, "rolcreaterole");
|
||||||
i_rolcreatedb = PQfnumber(res, "rolcreatedb");
|
i_rolcreatedb = PQfnumber(res, "rolcreatedb");
|
||||||
i_rolcatupdate = PQfnumber(res, "rolcatupdate");
|
|
||||||
i_rolcanlogin = PQfnumber(res, "rolcanlogin");
|
i_rolcanlogin = PQfnumber(res, "rolcanlogin");
|
||||||
i_rolconnlimit = PQfnumber(res, "rolconnlimit");
|
i_rolconnlimit = PQfnumber(res, "rolconnlimit");
|
||||||
i_rolpassword = PQfnumber(res, "rolpassword");
|
i_rolpassword = PQfnumber(res, "rolpassword");
|
||||||
|
@ -1384,7 +1384,6 @@ char *
|
|||||||
psql_scan_slash_command(PsqlScanState state)
|
psql_scan_slash_command(PsqlScanState state)
|
||||||
{
|
{
|
||||||
PQExpBufferData mybuf;
|
PQExpBufferData mybuf;
|
||||||
int lexresult;
|
|
||||||
|
|
||||||
/* Must be scanning already */
|
/* Must be scanning already */
|
||||||
psql_assert(state->scanbufhandle);
|
psql_assert(state->scanbufhandle);
|
||||||
@ -1404,7 +1403,7 @@ psql_scan_slash_command(PsqlScanState state)
|
|||||||
BEGIN(xslashcmd);
|
BEGIN(xslashcmd);
|
||||||
|
|
||||||
/* And lex. */
|
/* And lex. */
|
||||||
lexresult = yylex();
|
yylex();
|
||||||
|
|
||||||
/* There are no possible errors in this lex state... */
|
/* There are no possible errors in this lex state... */
|
||||||
|
|
||||||
@ -1641,8 +1640,6 @@ psql_scan_slash_option(PsqlScanState state,
|
|||||||
void
|
void
|
||||||
psql_scan_slash_command_end(PsqlScanState state)
|
psql_scan_slash_command_end(PsqlScanState state)
|
||||||
{
|
{
|
||||||
int lexresult;
|
|
||||||
|
|
||||||
/* Must be scanning already */
|
/* Must be scanning already */
|
||||||
psql_assert(state->scanbufhandle);
|
psql_assert(state->scanbufhandle);
|
||||||
|
|
||||||
@ -1658,7 +1655,7 @@ psql_scan_slash_command_end(PsqlScanState state)
|
|||||||
BEGIN(xslashend);
|
BEGIN(xslashend);
|
||||||
|
|
||||||
/* And lex. */
|
/* And lex. */
|
||||||
lexresult = yylex();
|
yylex();
|
||||||
|
|
||||||
/* There are no possible errors in this lex state... */
|
/* There are no possible errors in this lex state... */
|
||||||
}
|
}
|
||||||
|
@ -764,11 +764,8 @@ ECPGdescribe(int line, int compat, bool input, const char *connection_name, cons
|
|||||||
|
|
||||||
for (;;)
|
for (;;)
|
||||||
{
|
{
|
||||||
enum ECPGttype type,
|
enum ECPGttype type;
|
||||||
dummy_type;
|
void *ptr;
|
||||||
void *ptr,
|
|
||||||
*dummy_ptr;
|
|
||||||
long dummy;
|
|
||||||
|
|
||||||
/* variable type */
|
/* variable type */
|
||||||
type = va_arg(args, enum ECPGttype);
|
type = va_arg(args, enum ECPGttype);
|
||||||
@ -778,16 +775,16 @@ ECPGdescribe(int line, int compat, bool input, const char *connection_name, cons
|
|||||||
|
|
||||||
/* rest of variable parameters */
|
/* rest of variable parameters */
|
||||||
ptr = va_arg(args, void *);
|
ptr = va_arg(args, void *);
|
||||||
dummy = va_arg(args, long);
|
va_arg(args, long); /* skip args */
|
||||||
dummy = va_arg(args, long);
|
va_arg(args, long);
|
||||||
dummy = va_arg(args, long);
|
va_arg(args, long);
|
||||||
|
|
||||||
/* variable indicator */
|
/* variable indicator */
|
||||||
dummy_type = va_arg(args, enum ECPGttype);
|
va_arg(args, enum ECPGttype);
|
||||||
dummy_ptr = va_arg(args, void *);
|
va_arg(args, void *); /* skip args */
|
||||||
dummy = va_arg(args, long);
|
va_arg(args, long);
|
||||||
dummy = va_arg(args, long);
|
va_arg(args, long);
|
||||||
dummy = va_arg(args, long);
|
va_arg(args, long);
|
||||||
|
|
||||||
switch (type)
|
switch (type)
|
||||||
{
|
{
|
||||||
|
@ -320,14 +320,13 @@ static void
|
|||||||
pg_GSS_error_int(PQExpBuffer str, const char *mprefix,
|
pg_GSS_error_int(PQExpBuffer str, const char *mprefix,
|
||||||
OM_uint32 stat, int type)
|
OM_uint32 stat, int type)
|
||||||
{
|
{
|
||||||
OM_uint32 lmaj_s,
|
OM_uint32 lmin_s;
|
||||||
lmin_s;
|
|
||||||
gss_buffer_desc lmsg;
|
gss_buffer_desc lmsg;
|
||||||
OM_uint32 msg_ctx = 0;
|
OM_uint32 msg_ctx = 0;
|
||||||
|
|
||||||
do
|
do
|
||||||
{
|
{
|
||||||
lmaj_s = gss_display_status(&lmin_s, stat, type,
|
gss_display_status(&lmin_s, stat, type,
|
||||||
GSS_C_NO_OID, &msg_ctx, &lmsg);
|
GSS_C_NO_OID, &msg_ctx, &lmsg);
|
||||||
appendPQExpBuffer(str, "%s: %s\n", mprefix, (char *) lmsg.value);
|
appendPQExpBuffer(str, "%s: %s\n", mprefix, (char *) lmsg.value);
|
||||||
gss_release_buffer(&lmin_s, &lmsg);
|
gss_release_buffer(&lmin_s, &lmsg);
|
||||||
|
@ -1913,7 +1913,6 @@ exec_stmt_forc(PLpgSQL_execstate *estate, PLpgSQL_stmt_forc *stmt)
|
|||||||
{
|
{
|
||||||
PLpgSQL_var *curvar;
|
PLpgSQL_var *curvar;
|
||||||
char *curname = NULL;
|
char *curname = NULL;
|
||||||
const char *portalname;
|
|
||||||
PLpgSQL_expr *query;
|
PLpgSQL_expr *query;
|
||||||
ParamListInfo paramLI;
|
ParamListInfo paramLI;
|
||||||
Portal portal;
|
Portal portal;
|
||||||
@ -1997,7 +1996,6 @@ exec_stmt_forc(PLpgSQL_execstate *estate, PLpgSQL_stmt_forc *stmt)
|
|||||||
if (portal == NULL)
|
if (portal == NULL)
|
||||||
elog(ERROR, "could not open cursor: %s",
|
elog(ERROR, "could not open cursor: %s",
|
||||||
SPI_result_code_string(SPI_result));
|
SPI_result_code_string(SPI_result));
|
||||||
portalname = portal->name;
|
|
||||||
|
|
||||||
/* don't need paramlist any more */
|
/* don't need paramlist any more */
|
||||||
if (paramLI)
|
if (paramLI)
|
||||||
|
Loading…
x
Reference in New Issue
Block a user