-
- {#if result}
- Results: {result.length}
- {/if}
+
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ {#key result}
+
+ {/key}
+
+
+
+
+ {#if result}
+ Results: {result.total || 0}
+ {/if}
+
+
+
+
+
+
diff --git a/frontend/src/organisms/collection-detail/insert.svelte b/frontend/src/organisms/collection-detail/insert.svelte
index 3b77e58..ba0dc97 100644
--- a/frontend/src/organisms/collection-detail/insert.svelte
+++ b/frontend/src/organisms/collection-detail/insert.svelte
@@ -6,10 +6,6 @@
let input = '';
let insertedIds;
- $: if (collection) {
- insertedIds = undefined;
- }
-
async function insert() {
insertedIds = await PerformInsert(collection.hostKey, collection.dbKey, collection.key, input);
}
diff --git a/frontend/src/organisms/collection-detail/stats.svelte b/frontend/src/organisms/collection-detail/stats.svelte
new file mode 100644
index 0000000..208e513
--- /dev/null
+++ b/frontend/src/organisms/collection-detail/stats.svelte
@@ -0,0 +1,19 @@
+
+
+
+
+
+
+
+
diff --git a/frontend/wailsjs/go/main/App.d.ts b/frontend/wailsjs/go/main/App.d.ts
index 424c7e8..e0bbea2 100755
--- a/frontend/wailsjs/go/main/App.d.ts
+++ b/frontend/wailsjs/go/main/App.d.ts
@@ -2,6 +2,7 @@
// This file is automatically generated. DO NOT EDIT
import {map[string]main} from '../models';
import {primitive} from '../models';
+import {main} from '../models';
export function Hosts():Promise
;
@@ -11,6 +12,6 @@ export function OpenConnection(arg1:string):Promise>;
export function OpenDatabase(arg1:string,arg2:string):Promise>;
-export function PerformFind(arg1:string,arg2:string,arg3:string,arg4:string):Promise;
+export function PerformFind(arg1:string,arg2:string,arg3:string,arg4:string):Promise;
export function PerformInsert(arg1:string,arg2:string,arg3:string,arg4:string):Promise;
diff --git a/frontend/wailsjs/go/models.ts b/frontend/wailsjs/go/models.ts
new file mode 100755
index 0000000..7a37ffd
--- /dev/null
+++ b/frontend/wailsjs/go/models.ts
@@ -0,0 +1,19 @@
+export namespace main {
+
+ export class findResult {
+ total: number;
+ results: any;
+
+ static createFrom(source: any = {}) {
+ return new findResult(source);
+ }
+
+ constructor(source: any = {}) {
+ if ('string' === typeof source) source = JSON.parse(source);
+ this.total = source["total"];
+ this.results = source["results"];
+ }
+ }
+
+}
+
diff --git a/main.go b/main.go
index 6f9bef1..37071d1 100644
--- a/main.go
+++ b/main.go
@@ -141,7 +141,13 @@ func (a *App) OpenCollection(hostKey, dbKey, collKey string) (result bson.M) {
return result
}
-func (a *App) PerformFind(hostKey, dbKey, collKey string, formJson string) interface{} {
+type findResult struct {
+ Total int64 `json:"total"`
+ Results interface{} `json:"results"`
+}
+
+func (a *App) PerformFind(hostKey, dbKey, collKey string, formJson string) findResult {
+ var out findResult
var form struct {
Fields string `json:"fields"`
Limit int64 `json:"limit"`
@@ -158,13 +164,13 @@ func (a *App) PerformFind(hostKey, dbKey, collKey string, formJson string) inter
Title: "Couldn't parse form",
Message: err.Error(),
})
- return nil
+ return out
}
client, ctx, close, err := a.connectToHost(hostKey)
if err != nil {
fmt.Println(err.Error())
- return nil
+ return out
}
defer close()
@@ -180,7 +186,7 @@ func (a *App) PerformFind(hostKey, dbKey, collKey string, formJson string) inter
Title: "Invalid query",
Message: err.Error(),
})
- return nil
+ return out
}
err = json.Unmarshal([]byte(form.Fields), &projection)
@@ -191,7 +197,7 @@ func (a *App) PerformFind(hostKey, dbKey, collKey string, formJson string) inter
Title: "Invalid projection",
Message: err.Error(),
})
- return nil
+ return out
}
err = json.Unmarshal([]byte(form.Sort), &sort)
@@ -202,7 +208,7 @@ func (a *App) PerformFind(hostKey, dbKey, collKey string, formJson string) inter
Title: "Invalid sort",
Message: err.Error(),
})
- return nil
+ return out
}
opt := mongoOptions.FindOptions{
@@ -212,7 +218,18 @@ func (a *App) PerformFind(hostKey, dbKey, collKey string, formJson string) inter
Sort: sort,
}
- cur, err := client.Database(dbKey).Collection(collKey).Find(ctx, bson.D{}, &opt)
+ total, err := client.Database(dbKey).Collection(collKey).CountDocuments(ctx, query, nil)
+ if err != nil {
+ fmt.Println(err.Error())
+ runtime.MessageDialog(a.ctx, runtime.MessageDialogOptions{
+ Type: runtime.ErrorDialog,
+ Title: "Encountered an error while counting documents",
+ Message: err.Error(),
+ })
+ return out
+ }
+
+ cur, err := client.Database(dbKey).Collection(collKey).Find(ctx, query, &opt)
if err != nil {
fmt.Println(err.Error())
runtime.MessageDialog(a.ctx, runtime.MessageDialogOptions{
@@ -220,7 +237,7 @@ func (a *App) PerformFind(hostKey, dbKey, collKey string, formJson string) inter
Title: "Encountered an error while performing query",
Message: err.Error(),
})
- return nil
+ return out
}
defer cur.Close(ctx)
@@ -234,10 +251,12 @@ func (a *App) PerformFind(hostKey, dbKey, collKey string, formJson string) inter
Title: "Encountered an error while performing query",
Message: err.Error(),
})
- return nil
+ return out
}
- return results
+ out.Results = results
+ out.Total = total
+ return out
}
func (a *App) PerformInsert(hostKey, dbKey, collKey, jsonData string) interface{} {