golang 下 mongodb 与 postgresql 插入速度的测试
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了golang 下 mongodb 与 postgresql 插入速度的测试，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含1640字，纯文字阅读大概需要3分钟。
内容图文
struct {
Date int32
O, H, L, C, V, A float32
}
mongo 用了mgo 包，插入代码如下：
func ReadHq(conn net.Conn, c *mgo.Collection, Code string) {
var buf [28]byte
var x Stock
var y Kline_Day
for i := 0; ; i++ {
_, err := conn.Read(buf[0:28])
if err == io.EOF {
fmt.Println("此个文件传输结束")
break
}
if err != nil {
fmt.Println(err)
return
}
b_buf := bytes.NewBuffer(buf[0:28])
binary.Read(b_buf, binary.LittleEndian, &x) //binary.LittleEndian 是内存中的字节序的概念，就是把低字节的放到了后面。网络传输一般用BigEndian，内存字节序和cpu有关，编程时要转化。
y.Code = Code
y.A = x.A
y.C = x.C
y.Date = x.Date
y.H = x.H
y.L = x.L
y.O = x.O
y.V = x.V
//fmt.Println(y)
err = c.Insert(&y)
if err != nil {
panic(err)
}
}
return
}
#postgresql 的表结构
CREATE TABLE json_test
(
id serial NOT NULL,
data jsonb,
CONSTRAINT json_test_pkey PRIMARY KEY (id)
)
用了 "github.com/lib/pq" 这个包：
插入代码：
func ReadHq(conn net.Conn, db *sql.DB, Code string) {
var buf [28]byte
var x StockDay
for {
_, err := conn.Read(buf[0:28])
if err == io.EOF {
fmt.Println("此个文件传输结束")
break
}
if err != nil {
fmt.Println(err)
return
}
b_buf := bytes.NewBuffer(buf[0:28])
binary.Read(b_buf, binary.LittleEndian, &x) //binary.LittleEndian 是内存中的字节序的概念，就是把低字节的放到了后面。网络传输一般用BigEndian，内存字节序和cpu有关，编程时要转化。
//fmt.Println(y)
//err = c.Insert(&y)
buf, err := json.Marshal(&x)
//插入数据
stmt, err := db.Prepare("INSERT INTO json_test(data) VALUES($1) RETURNING id")
checkErr(err)
_, err = stmt.Exec(string(buf))
checkErr(err)
}
return
}
golang 下 mongodb 与 postgresql 插入速度的测试
标签：
本文系统来源：http://www.cnblogs.com/wangyanlb/p/4666179.html
内容总结
以上是互联网集市为您收集整理的golang 下 mongodb 与 postgresql 插入速度的测试全部内容，希望文章能够帮你解决golang 下 mongodb 与 postgresql 插入速度的测试所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。
来源：【匿名】