Add new columns for tuple statistics on a database level to

pg_stat_database.

1 files changed, 15 insertions, 1 deletions

diff --git a/src/backend/postmaster/pgstat.c b/src/backend/postmaster/pgstat.c
index 486dc6e48bf..378e165707f 100644
--- a/src/backend/postmaster/pgstat.c
+++ b/src/backend/postmaster/pgstat.c
@@ -13,7 +13,7 @@
  *
  *	Copyright (c) 2001-2007, PostgreSQL Global Development Group
  *
- *	$PostgreSQL: pgsql/src/backend/postmaster/pgstat.c,v 1.148 2007/03/01 20:06:56 tgl Exp $
+ *	$PostgreSQL: pgsql/src/backend/postmaster/pgstat.c,v 1.149 2007/03/16 17:57:36 mha Exp $
  * ----------
  */
 #include "postgres.h"
@@ -1970,6 +1970,11 @@ pgstat_get_db_entry(Oid databaseid, bool create)
 		result->n_xact_rollback = 0;
 		result->n_blocks_fetched = 0;
 		result->n_blocks_hit = 0;
+		result->n_tuples_returned = 0;
+		result->n_tuples_fetched = 0;
+		result->n_tuples_inserted = 0;
+		result->n_tuples_updated = 0;
+		result->n_tuples_deleted = 0;
 		result->last_autovac_time = 0;
 
 		memset(&hash_ctl, 0, sizeof(hash_ctl));
@@ -2414,6 +2419,15 @@ pgstat_recv_tabstat(PgStat_MsgTabstat *msg, int len)
 		}
 
 		/*
+		 * Add table stats to the database entry.
+		 */
+		dbentry->n_tuples_returned += tabmsg[i].t_tuples_returned;
+		dbentry->n_tuples_fetched += tabmsg[i].t_tuples_fetched;
+		dbentry->n_tuples_inserted += tabmsg[i].t_tuples_inserted;
+		dbentry->n_tuples_updated += tabmsg[i].t_tuples_updated;
+		dbentry->n_tuples_deleted += tabmsg[i].t_tuples_deleted;
+
+		/*
 		 * And add the block IO to the database entry.
 		 */
 		dbentry->n_blocks_fetched += tabmsg[i].t_blocks_fetched;