percona/percona-toolkit
1
0
Fork 0
mirror of https://github.com/percona/percona-toolkit.git synced 2025-09-15 07:55:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

support getmore; support find with sort; cleanups

Browse Source
This commit is contained in:
Kamil Dziedzic
2017-10-15 04:14:21 +02:00
parent 9b07eac002
commit 8cf08fd882
219 changed files with 2567 additions and 1696 deletions
Download Patch File Download Diff File Expand all files Collapse all files

57
src/go/mongolib/proto/system.profile.go
View File

@@ -73,38 +73,41 @@ type SystemProfile struct {
} `bson:"acquireCount"`
} `bson:"MMAPV1Journal"`
} `bson:"locks"`
Millis int `bson:"millis"`
Nreturned int `bson:"nreturned"`
Ns string `bson:"ns"`
NumYield int `bson:"numYield"`
Op string `bson:"op"`
Protocol string `bson:"protocol"`
Query BsonD `bson:"query"`
UpdateObj BsonD `bson:"updateobj"`
Command BsonD `bson:"command"`
ResponseLength int `bson:"responseLength"`
Ts time.Time `bson:"ts"`
User string `bson:"user"`
WriteConflicts int `bson:"writeConflicts"`
Millis int `bson:"millis"`
Nreturned int `bson:"nreturned"`
Ns string `bson:"ns"`
NumYield int `bson:"numYield"`
Op string `bson:"op"`
Protocol string `bson:"protocol"`
Query BsonD `bson:"query"`
UpdateObj BsonD `bson:"updateobj"`
Command BsonD `bson:"command"`
OriginatingCommand BsonD `bson:"originatingCommand"`
ResponseLength int `bson:"responseLength"`
Ts time.Time `bson:"ts"`
User string `bson:"user"`
WriteConflicts int `bson:"writeConflicts"`
}
func NewExampleQuery(doc SystemProfile) ExampleQuery {
return ExampleQuery{
Ns: doc.Ns,
Op: doc.Op,
Query: doc.Query,
Command: doc.Command,
UpdateObj: doc.UpdateObj,
Ns: doc.Ns,
Op: doc.Op,
Query: doc.Query,
Command: doc.Command,
OriginatingCommand: doc.OriginatingCommand,
UpdateObj: doc.UpdateObj,
}
}
// ExampleQuery is a subset of SystemProfile
type ExampleQuery struct {
Ns string `bson:"ns" json:"ns"`
Op string `bson:"op" json:"op"`
Query BsonD `bson:"query,omitempty" json:"query,omitempty"`
Command BsonD `bson:"command,omitempty" json:"command,omitempty"`
UpdateObj BsonD `bson:"updateobj,omitempty" json:"updateobj,omitempty"`
Ns string `bson:"ns" json:"ns"`
Op string `bson:"op" json:"op"`
Query BsonD `bson:"query,omitempty" json:"query,omitempty"`
Command BsonD `bson:"command,omitempty" json:"command,omitempty"`
OriginatingCommand BsonD `bson:"originatingCommand,omitempty" json:"originatingCommand,omitempty"`
UpdateObj BsonD `bson:"updateobj,omitempty" json:"updateobj,omitempty"`
}
func (self ExampleQuery) Db() string {
@@ -218,6 +221,14 @@ func (self ExampleQuery) ExplainCmd() bson.D {
{"insert", coll},
}
}
case "getmore":
if self.OriginatingCommand.Len() > 0 {
cmd = self.OriginatingCommand
} else {
cmd = BsonD{
{Name: "getMore", Value: ""},
}
}
case "command":
if cmd.Len() == 0 || cmd[0].Name != "group" {
break