mongodb 3.x 客户端开发四：golang根据条件过滤查询mongodb集合数据

daisongwan · · 4309 次点击 · · 开始浏览

这是一个创建于的文章，其中的信息可能已经有所发展或是发生改变。

更多文章

前端输入查询条件，后台根据查询条件，查询mongodb，过滤结果再显示出来。

前端页面：

<html>
<head>
</head>
<body>
<a href=”connect”>返回</a>
<form action=”query” method=”get”>
查询条件：<input type=”text” name = “queryStr” value=”” size=”60″/>
<input type=”submit” value=”查询”/>
</form>
<table border=”1″>
{{range $i, $m := .}}
<tr>
{{range $k, $v := $m}}
<td>
<div>{{$k}}</div>
</td>
<td>
<div>{{$v}}</div>
</td>
{{end}}
</tr>
{{end}}

</table>
</body>
</html>

golang,erlang,java,groovy讨论,QQ群：367583891

golang代码：

func Query(w http.ResponseWriter, r *http.Request) {
	r.ParseForm()
	collections := r.Form["collection"]
	if len(collections) > 0 {
		collection = collections[0]
	}
	fmt.Println("collection:", collection)
	//获取查询条件字符串
	queryStrs := r.Form["queryStr"]
	queryStr := ""
	if len(queryStrs) > 0 {
		queryStr = queryStrs[0]
	}

	session, err := mgo.Dial(url) //连接数据库
	checkError(err)
	defer session.Close()
	session.SetMode(mgo.Monotonic, true)
	db := session.DB("test")
	coll := db.C(collection)

	//查询条件字符串转换成mongodb查询json对象
	var condition map[string]interface{}
	var byt = make([]byte, 0)
	if queryStr != "" {
		byt = []byte(queryStr)
	}

	json.Unmarshal(byt, &condition)

	//根据条件查询
	iter := coll.Find(condition).Limit(100).Iter()
	var rows = make([]bson.M, 0)
	var row interface{}
	for iter.Next(&row) {
		fmt.Println(row.(bson.M)["name"])
		rows = append(rows, row.(bson.M))
	}
	t, err := template.ParseFiles("template/query.html")
	checkError(err)
	err = t.Execute(w, rows)
	checkError(err)
}

有疑问加站长微信联系（非本文作者）