struct {Date int32O, H, L, C, V, A float32 }mongo 用了mgo 包，插入代码如下：func ReadHq(conn net.Conn, c *mgo.Collection, Code string) {var buf [28]bytevar x Stockvar y Kline_Dayfor 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.LittleE...
"database/sql""fmt""log"_ "github.com/lib/pq" // postgres driver )// People - database type People struct {id intname stringage int }type appContext struct {db *sql.DB }// ConnectDB connect specify database func connectDB(driverName string, dbName string) (c *appContext, errorMessage string) {db, err := sql.Open(driverName, dbName)if err != nil {return nil, err.Error()}if err = db.Ping(); err !...
mainimport ("bytes""database/sql""database/sql/driver""fmt"_ "github.com/lib/pq""strconv""strings" )// 自己定义支持类型 type Point struct {X float64 `json:"lat"`Y float64 `json:"lng"` } // 实现driver.Valuer接口 func (p *Point) Value() (driver.Value, error) {buf := new(bytes.Buffer)fmt.Fprintf(buf, "(%f %f)", p.X, p.Y)return buf.Bytes(), nil }func (p *Point) String() string {return fmt.Sprintf("(%v...
package main2 3 import (4 "database/sql"5 "fmt"6 "log"7 "reflect"8 "net/http"9 10 _ "github.com/lib/pq" 11 ) 12 13 type sys_user struct { 14 su_id int 15 su_name string 16 su_gender string 17 su_age int 18 su_address string 19 su_im string 20 su_regtime string 21 } 22 23 func main() { 24 var su []sys_user 25 var Suact...
PostgreSQL和MySQL比较，它更加庞大一点，因为它是用来替代Oracle而设计的。所以在企业应用中采用PostgreSQL是一个明智的选择。 1， 获取数据库驱动 go get https://github.com/bmizerany/pq 2, 创建数据库表 CREATE TABLE userinfo ( uid serial NOT NULL, username character varying(100) NOT NULL, departname character varying(500) NOT NULL, Created date, CONSTRAINT userinfo_pkey PRIMARY KEY (uid) ) WITH (OIDS=FAL...