-3

转到版本 1.9.2

go-sql-driver/mysql git commit hash cd4cb90

mysql服务器版本：5.6.15-log MySQL Community Server

操作系统版本：CentOS release 6.7 (Final)

db 打开配置

max_idle_conns = 5

max_open_conns = 30

max_life_time=600

超时=600

mysql配置

+-----------------------------+----------+
| Variable_name               | Value    |
+-----------------------------+----------+
| connect_timeout             | 60       |
| delayed_insert_timeout      | 300      |
| interactive_timeout         | 600      |
| lock_wait_timeout           | 31536000 |
| log_output                  | FILE     |
| net_read_timeout            | 30       |
| net_write_timeout           | 60       |
| wait_timeout                | 600      |
+-----------------------------+----------+

lsof 输出

srv_promo 12672 root 10u sock 0,6 0t0 63382668 无法识别协议

srv_promo 12672 root 11u sock 0,6 0t0 63366850 无法识别协议

srv_promo 12672 root 12u sock 0,6 0t0 63366688 无法识别协议

srv_promo 12672 root 13u sock 0,6 0t0 63366690 无法识别协议

mysql配置

lsof 输出

下面是代码：

包 dbtest

import (
    "database/sql"
    "fmt"
    "github.com/golang/glog"
    "gopkg.in/gorp.v2"
    "log"
    "os"
    "sync"
    "time"
)

type DatabaseConfig struct {
    DBName               string `toml:"dbname"`
    Host                 string `toml:"host"`
    Port                 int    `toml:"port"`
    User                 string `toml:"user"`
    Password             string `toml:"password"`
    Sslmode              string `toml:"sslmode"`
    ShowLog              bool
    DataSaveDir          string
    DataFileSaveLoopSize int
    MaxIdleConns         int `toml:"max_idle_conns"`
    MaxOpenConns         int `toml:"max_open_conns"`
    MaxLifeTime          int `toml:"max_life_time"`
    Timeout              int `toml:"timeout"`
    RTimeout             int `toml:"rtimeout"`
    WTimeout             int `toml:"wtimeout"`
}

func (c DatabaseConfig) MySQLSource() string {
    params := make(map[string]string, 0)
    params["charset"] = "utf8mb4"
    cfg := mysql.Config{}
    cfg.User = c.User
    cfg.Passwd = c.Password
    cfg.DBName = c.DBName
    cfg.ParseTime = true
    cfg.Collation = "utf8mb4_unicode_ci"
    cfg.Params = params
    cfg.Loc, _ = time.LoadLocation("Asia/Chongqing")
    cfg.Timeout = time.Duration(c.Timeout) * time.Second
    cfg.MultiStatements = true
    cfg.ReadTimeout = time.Duration(c.RTimeout) * time.Second
    cfg.WriteTimeout = time.Duration(c.WTimeout) * time.Second
    return cfg.FormatDSN()
}

var (
    dbmap     *gorp.DbMap
    Dbm       *gorp.DbMap
    config    DatabaseConfig
    opened    bool
    openMutex sync.RWMutex
    DB        *sql.DB
)

//Open open the database for passport with config
func Open(cfg DatabaseConfig) {
    if !opened {
        config = cfg
        db, err := sql.Open("mysql", config.MySQLSource())
        glog.Infof("open err %v ", err)
        if err != nil {
            panic(fmt.Errorf("sql.Open failed: %v", err))
        }
        if config.MaxLifeTime > 0 {
            db.SetConnMaxLifetime(time.Duration(config.MaxLifeTime) * time.Second)
        }
        db.SetMaxIdleConns(config.MaxIdleConns)
        db.SetMaxOpenConns(config.MaxOpenConns)
        db.Ping()
        DB = db
        // construct a gorp DbMap
        dbmap = &gorp.DbMap{Db: db, Dialect: gorp.MySQLDialect{"InnoDB", "utf8mb4"}}
        Dbm = dbmap

        err = dbmap.CreateTablesIfNotExists()
        if err != nil {
            panic("create table failed " + err.Error())
        }
        openMutex.Lock()
        opened = true
        openMutex.Unlock()
        if config.ShowLog {
            dbmap.TraceOn("[gorp]", log.New(os.Stdout, schemaName+" ", log.Lmicroseconds))
        }
    }
}

//Close close the database for passport
func Close() {
    if dbmap != nil && opened {
        glog.Infof("close database %s for %s", config.DBName, schemaName)
        dbmap.Db.Close()
        openMutex.Lock()
        opened = false
        openMutex.Unlock()
    }
}
4

1 回答 1

0

（不是答案，但评论太多了。）

两件事情：

  1. 请尝试提出一个MCVE——首先是为您自己，其次（如果仅此一项不能帮助您解决问题）——为我们。

    我的意思是，您的示例中发生了太多事情：您使用gorp的不是 Go 标准库的一部分，而这个包——据说它包装了database/sql机器——在使用数据库。

    这不是处理此类问题的方式。相反，您应该从头开始，首先使用普通database/sql图层，看看它是否有效。如果是这样，问题就出在那个gorp东西上。

    另一个（无论多么次要）的细节是，您不应该使用 3rd-party 软件包在您的 MCVE 中做一些琐碎的事情；在这里，我说的是日志记录：在一个精简的示例中，标准fmt.Print*功能就可以了，或者，如果您觉得不可能完全采用 Enterprise-y，则标准log包将满足您的需求。

  2. Go 中的 SQL 数据库层被明确设计为具有与其他流行语言/框架实现的 SQL 数据库层完全不同的语义。

    Go 的不同之处在于它旨在处理 通常在服务器软件上生成的大量工作负载。除其他外，这意味着

    • 默认情况下，数据库连接是池化的。
    • 它们根据需要被重用，当您执行不在事务中的查询或语句时，您不知道这是否会创建新连接或重用现有连接，如果是，那么究竟是哪一个。
    • 除非在它们上执行某些操作（或调用它们的方法） ，否则新连接实际上不会连接。Ping()
于 2017-11-20T07:24:52.430 回答