X-Git-Url: http://git.iain.cx/?a=blobdiff_plain;f=i_s%2Fpl_by_user.go;fp=i_s%2Fpl_by_user.go;h=9ad2c8d60311424bc5cf882ce989bd35b9721e36;hb=52d3c00ce729f908f342e10f48818b112dec0130;hp=0000000000000000000000000000000000000000;hpb=b958730449ac1d927c267373a68b9ae54b72c454;p=pstop.git

diff --git a/i_s/pl_by_user.go b/i_s/pl_by_user.go
new file mode 100644
index 0000000..9ad2c8d
--- /dev/null
+++ b/i_s/pl_by_user.go
@@ -0,0 +1,135 @@
+package i_s
+
+import (
+	"fmt"
+	"sort"
+
+	"github.com/sjmudd/pstop/lib"
+)
+
+/*
+root@localhost [i_s]> show create table i_s\G
+*************************** 1. row ***************************
+CREATE TEMPORARY TABLE `PROCESSLIST` (
+	`ID` bigint(21) unsigned NOT NULL DEFAULT '0',
+	`USER` varchar(16) NOT NULL DEFAULT '',
+	`HOST` varchar(64) NOT NULL DEFAULT '',
+	`DB` varchar(64) DEFAULT NULL, `COMMAND` varchar(16) NOT NULL DEFAULT '', `TIME` int(7) NOT NULL DEFAULT '0', `STATE` varchar(64) DEFAULT NULL,
+	`INFO` longtext
+) ENGINE=MyISAM DEFAULT CHARSET=utf8
+1 row in set (0.02 sec)
+*/
+
+// a summary row of information taken from information_schema.processlist
+type pl_by_user_row struct {
+	username    string
+	runtime     uint64
+	connections uint64
+	active      uint64
+	hosts       uint64
+	dbs         uint64
+	selects     uint64
+	inserts     uint64
+	updates     uint64
+	deletes     uint64
+	other       uint64
+}
+type pl_by_user_rows []pl_by_user_row
+
+/*
+username      |Run Time   %age|Conn Actv|Hosts DBs|Select Insert Update Delete  Other|
+xxxxxxxxxxxxxx|hh:mm:ss 100.0%|9999 9999|9999  999|100.0% 100.0% 100.0% 100.0% 100.0%|
+*/
+
+func (r *pl_by_user_row) headings() string {
+	return fmt.Sprintf("%-14s|%10s %6s|%5s %4s|%4s %3s|%6s %6s %6s %6s %6s|",
+		"username", "Run Time", "%", "Conn", "Actv", "Hosts", "DBs", "Select", "Insert", "Update", "Delete", "Other")
+}
+
+// generate a printable result
+func (r *pl_by_user_row) row_content(totals pl_by_user_row) string {
+	var u string
+	if len(r.username) == 0 {
+		u = ""
+	} else if len(r.username) > 14 {
+		u = r.username[0:14]
+	} else {
+		u = r.username
+	}
+	return fmt.Sprintf("%-14s|%10s %6s|%5s %4s|%4s %3s|%6s %6s %6s %6s %6s|",
+		u,
+		lib.FormatTime(r.runtime),
+		lib.FormatPct(lib.MyDivide(r.runtime, totals.runtime)),
+		lib.FormatAmount(r.connections),
+		lib.FormatAmount(r.active),
+		lib.FormatAmount(r.hosts),
+		lib.FormatAmount(r.dbs),
+		lib.FormatAmount(r.selects),
+		lib.FormatAmount(r.inserts),
+		lib.FormatAmount(r.updates),
+		lib.FormatAmount(r.deletes),
+		lib.FormatAmount(r.other))
+}
+
+// generate a row of totals from a table
+func (t pl_by_user_rows) totals() pl_by_user_row {
+	var totals pl_by_user_row
+	totals.username = "TOTALS"
+
+	for i := range t {
+		totals.runtime += t[i].runtime
+		totals.connections += t[i].connections
+		totals.active += t[i].active
+		//		totals.hosts += t[i].hosts		This needs to be done differently to get the total number of distinct hosts
+		//		totals.dbs += t[i].dbs			This needs to be done differently to get the total number of distinct dbs
+		totals.selects += t[i].selects
+		totals.inserts += t[i].inserts
+		totals.updates += t[i].updates
+		totals.deletes += t[i].deletes
+		totals.other += t[i].other
+	}
+
+	return totals
+}
+
+func (t pl_by_user_rows) Headings() string {
+	var r pl_by_user_row
+	return r.headings()
+}
+
+// describe a whole row
+func (r pl_by_user_row) String() string {
+	return fmt.Sprintf("%v %v %v %v %v %v %v %v %v", r.username, r.runtime, r.connections, r.active, r.hosts, r.dbs, r.selects, r.inserts, r.updates, r.deletes, r.other)
+}
+
+// describe a whole table
+func (t pl_by_user_rows) String() string {
+	s := ""
+	for i := range t {
+		s = s + t[i].String() + "\n"
+	}
+	return s
+}
+
+// for sorting
+type ByRunTime pl_by_user_rows
+
+func (t ByRunTime) Len() int      { return len(t) }
+func (t ByRunTime) Swap(i, j int) { t[i], t[j] = t[j], t[i] }
+func (t ByRunTime) Less(i, j int) bool {
+	return (t[i].runtime > t[j].runtime) ||
+		((t[i].runtime == t[j].runtime) && (t[i].connections > t[j].connections))
+}
+
+func (t pl_by_user_rows) Sort() {
+	sort.Sort(ByRunTime(t))
+}
+
+func (r pl_by_user_row) Description() string {
+	return "no description"
+}
+
+func (t pl_by_user_rows) emptyRowContent() string {
+	var r pl_by_user_row
+	return r.row_content(r)
+}