golang 如何连 mysql 不要每次建立一个连接

zylthinking

@cokeboL, 有没有趟过这个坑？
mysql 自己认最大链接 150,
现在是设置了
       db.SetMaxOpenConns(10);
        db.SetMaxIdleConns(10);

不起作用;
stmt.Close() 也调用了
row.Close() 也调用了

就是不起作用;
一次调用创建一个新连接， 150次准挂

我就不明白了， 这还有救吗



func db_get() (*sql.DB, error) {
    if (db != nil) {
        return db, nil;
    }

    mux.Lock();
    if (db != nil) {
        mux.Unlock();
        return db, nil;
    }

    conf := setting.Conf;
    if (conf == nil) {
        mux.Unlock();
        return nil, errors.New("can't get mysql configuration");
    }

    var buf bytes.Buffer;
    buf.WriteString(conf.Mysql.User);
    buf.WriteByte(':');
    buf.WriteString(conf.Mysql.Passwd);
    buf.WriteString("@tcp(");
    buf.WriteString(conf.Mysql.Addr);
    buf.WriteString(")/db?charset=utf8");
    db, err := sql.Open("mysql", buf.String());
    if (err == nil) {
       db.SetMaxOpenConns(10);
        db.SetMaxIdleConns(10);
    }
    mux.Unlock();
    return db, err;
}

func UserGet(email string) (*Account, error) {
    db, err := db_get();
    if (err != nil) {
        return nil, err;
    }

    stmt, err := db.Prepare("select * from account where email = ?");
    if (err != nil) {
        return nil, err;
    }
    defer stmt.Close();

    row, err:= stmt.Query(email);
    if (err != nil) {
        return nil, err;
    }
    defer row.Close();

    obj, err := fill_row(row, &Account{});
    if (err != nil) {
        return nil, err;
    } else if (obj == nil) {
        return nil, nil;
    }
    return obj.(*Account), nil;
}

zylthinking

靠， 我知道怎么会是了

db, err := sql.Open("mysql", buf.String());
这个声明了一个新的本地变量 db, 而不是全局 db 变量；导致全局 db 永远是 nil, 从而不断创建 db 对象导致的， 坑的你没话说

zylthinking

回复 5# yulihua49

你都没搞清楚是怎么回事，　就开始飙常识．．．．．．．．．．．．．．．．

zylthinking

windoze 发表于 2017-06-26 14:23
你开几个goroutine专门处理MySQL，有数据库请求通过channel发过来给这几个goroutine处理，这样就不会爆了。

sql.DB 本来就是连接池, 之前的错误在于 golang := 语法的一个 trick 导致不断创建新的连接池导致的连接数用尽；　不在于应该不应该使用连接池