staticExecutorStart_hook_typeprev_ExecutorStart=NULL;

staticExecutorRun_hook_typeprev_ExecutorRun=NULL;

staticExecutorEnd_hook_typeprev_ExecutorEnd=NULL;

staticProcessUtility_hook_typeprev_ProcessUtility=NULL;

staticpgssSharedState*pgss=NULL;

{

PGSS_TRACK_NONE,/* track no statements */

PGSS_TRACK_TOP,/* only top level statements */

}PGSSTrackLevel;

staticconststructconfig_enum_entrytrack_options[]=

{

staticconststructconfig_enum_entrytrack_options[]= {

{"none",PGSS_TRACK_NONE, false},

{"top",PGSS_TRACK_TOP, false},

{"all",PGSS_TRACK_ALL, false},

staticintpgss_max;/* max # statements to track */

staticintpgss_track;/* tracking level */

staticboolpgss_track_ddl;/* whether to track ddl commands */

staticboolpgss_save;/* whether to save stats across shutdown */

void_PG_init(void);

void_PG_fini(void);

Datumpg_stat_statements_reset(PG_FUNCTION_ARGS);

Datumpg_stat_statements(PG_FUNCTION_ARGS);

ScanDirectiondirection,

longcount);

staticvoidpgss_ExecutorEnd(QueryDesc*queryDesc);

staticvoidpgss_ProcessUtility(Node*parsetree,

constchar*queryString,ParamListInfoparams,boolisTopLevel,

DestReceiver*dest,char*completionTag);

staticuint32pgss_hash_fn(constvoid*key,Sizekeysize);

staticintpgss_match_fn(constvoid*key1,constvoid*key2,Sizekeysize);

staticvoidpgss_store(constchar*query,doubletotal_time,uint64rows);

staticvoidpgss_store(constchar*query,

constInstrumentation*instr,uint32rows);

staticSizepgss_memsize(void);

staticpgssEntry*entry_alloc(pgssHashKey*key);

staticvoidentry_dealloc(void);

NULL,

NULL);

DefineCustomBoolVariable("pg_stat_statements.track_ddl",

"Selects whether DDL commands are tracked by pg_stat_statements.",

NULL,

&pgss_track_ddl,

true,

PGC_SUSET,

0,

NULL,

NULL);

DefineCustomBoolVariable("pg_stat_statements.save",

"Save pg_stat_statements statistics across server shutdowns.",

NULL,

ExecutorRun_hook=pgss_ExecutorRun;

prev_ExecutorEnd=ExecutorEnd_hook;

ExecutorEnd_hook=pgss_ExecutorEnd;

prev_ProcessUtility=ProcessUtility_hook;

ProcessUtility_hook=pgss_ProcessUtility;

}

ExecutorStart_hook=prev_ExecutorStart;

ExecutorRun_hook=prev_ExecutorRun;

ExecutorEnd_hook=prev_ExecutorEnd;

ProcessUtility_hook=prev_ProcessUtility;

shmem_startup_hook=prev_shmem_startup_hook;

}

InstrEndLoop(queryDesc->totaltime);

pgss_store(queryDesc->sourceText,

queryDesc->totaltime->total,

queryDesc->totaltime,

queryDesc->estate->es_processed);

}

standard_ExecutorEnd(queryDesc);

}

pgss_ProcessUtility(Node*parsetree,constchar*queryString,

ParamListInfoparams,boolisTopLevel,

DestReceiver*dest,char*completionTag)

{

if (pgss_track_ddl&&isTopLevel&&pgss_enabled())

{

instr_timestart;

instr_timeduration;

uint64rows=0;

INSTR_TIME_SET_CURRENT(start);

nested_level++;

PG_TRY();

{

if (prev_ProcessUtility)

prev_ProcessUtility(parsetree,queryString,params,isTopLevel,dest,completionTag);

elseif ((nodeTag(parsetree))==T_CopyStmt)

{

rows=DoCopy((CopyStmt*)parsetree,queryString);

if (completionTag)

snprintf(completionTag,COMPLETION_TAG_BUFSIZE,

"COPY "UINT64_FORMAT,rows);

}

standard_ProcessUtility(parsetree,queryString,params,isTopLevel,dest,completionTag);

nested_level--;

}

PG_CATCH();

{

nested_level--;

PG_RE_THROW();

}

PG_END_TRY();

INSTR_TIME_SET_CURRENT(duration);

INSTR_TIME_SUBTRACT(duration,start);

pgss_store(queryString,INSTR_TIME_GET_DOUBLE(duration),rows);

}

{

if (prev_ProcessUtility)

prev_ProcessUtility(parsetree,queryString,params,isTopLevel,dest,completionTag);

standard_ProcessUtility(parsetree,queryString,params,isTopLevel,dest,completionTag);

}

}

pgss_store(constchar*query,doubletotal_time,uint64rows)

pgss_store(constchar*query,constInstrumentation*instr,uint32rows)

{

pgssHashKeykey;

doubleusage;

SpinLockAcquire(&e->mutex);

e->counters.calls+=1;

e->counters.total_time+=total_time;

e->counters.total_time+=instr->total;

e->counters.rows+=rows;

e->counters.usage+=usage;

SpinLockRelease(&e->mutex);

<!-- $PostgreSQL: pgsql/doc/src/sgml/pgstatstatements.sgml,v 1.3 2009/12/0101:08:46 momjian Exp $ -->

<!-- $PostgreSQL: pgsql/doc/src/sgml/pgstatstatements.sgml,v 1.4 2009/12/0102:31:11 momjian Exp $ -->

<sect1 id="pgstatstatements">

<title>pg_stat_statements</title>

</listitem>

</varlistentry>

<varlistentry>

<term>

<varname>pg_stat_statements.track_ddl</varname> (<type>boolean</type>)

</term>

<listitem>

<para>

<varname>pg_stat_statements.track_ddl</varname> controls whether DDL

commands are counted by the module.

Specify <literal>on</> to track DDL commands, which excludes <command>SELECT</>,

<command>INSERT</>, <command>UPDATE</> and <command>DELETE</> statements.

The default value is <literal>on</>.

Only superusers can change this setting.

</para>

</listitem>

</varlistentry>

<varlistentry>

<term>

<varname>pg_stat_statements.save</varname> (<type>boolean</type>)

ProcessUtility_hook_typeProcessUtility_hook=NULL;

ProcessUtility(Node*parsetree,

if (completionTag)

completionTag[0]='\0';

if (ProcessUtility_hook)

(*ProcessUtility_hook) (parsetree,queryString,params,isTopLevel,dest,completionTag);

standard_ProcessUtility(parsetree,queryString,params,isTopLevel,dest,completionTag);

}

standard_ProcessUtility(Node*parsetree,

constchar*queryString,

ParamListInfoparams,

boolisTopLevel,

DestReceiver*dest,

char*completionTag)

{

switch (nodeTag(parsetree))

{

typedefvoid (*ProcessUtility_hook_type) (Node*parsetree,

constchar*queryString,ParamListInfoparams,boolisTopLevel,

DestReceiver*dest,char*completionTag);

externPGDLLIMPORTProcessUtility_hook_typeProcessUtility_hook;

externvoidProcessUtility(Node*parsetree,constchar*queryString,

ParamListInfoparams,boolisTopLevel,

DestReceiver*dest,char*completionTag);

externvoidstandard_ProcessUtility(Node*parsetree,constchar*queryString,

ParamListInfoparams,boolisTopLevel,

DestReceiver*dest,char*completionTag);

externboolUtilityReturnsTuples(Node*parsetree);