通过 App Engine 使用 Cloud SQL 时，如何 select 要查询的数据库？

Question

我收到以下错误：

Could not query db: Error 1046: No database selected

我明白错误讯息的意思。但是我没能找到说明如何 select 数据库的文档。

这是我的代码：

package main

import (
    "database/sql"
    "fmt"
    "log"
    "net/http"
    "os"
    "time"

    "google.golang.org/appengine"

    _ "github.com/go-sql-driver/mysql"
)

var db *sql.DB

func main() {
    var (
        connectionName = mustGetenv("CLOUDSQL_CONNECTION_NAME")
        user           = mustGetenv("CLOUDSQL_USER")
        password       = os.Getenv("CLOUDSQL_PASSWORD")
    )

    var err error
    db, err = sql.Open("mysql ", fmt.Sprintf("%s:%s@cloudsql(%s)/", user, password, connectionName))
    if err != nil {
        log.Fatalf("Could not open db: %v", err)
    }

    http.HandleFunc("/", handler)
    appengine.Main()
}

func handler(w http.ResponseWriter, r *http.Request) {
    if r.URL.Path != "/" {
        http.NotFound(w, r)
        return
    }

    w.Header().Set("Content-Type", "text/plain")

    rows, err := db.Query("INSERT INTO ping ( ping ) VALUES ( '" + time.Now().Format("2006-01-02 03:04:05") + "' );")
    if err != nil {
        http.Error(w, fmt.Sprintf("Could not query db: %v", err), 500)
        return
    }
    defer rows.Close()

    w.Write([]byte("OK"))
}

func mustGetenv(k string) string {
    v := os.Getenv(k)
    if v == "" {
        log.Panicf("%s environment variable not set.", k)
    }
    return v
}

Answer 1

您似乎指定了 CONNECTION_NAME，而不是 DB_NAME。根据 the documentation（向下滚动到 "GO > Companion process" 部分），您应该打开连接：

import (
        "github.com/go-sql-driver/mysql"
)

dsn := fmt.Sprintf("%s:%s@tcp(%s)/%s",
       dbUser,
       dbPassword,
       "127.0.0.1:3306",
       dbName)
db, err := sql.Open("mysql", dsn)

这段代码与您的类似，但您没有指定 dbName 参数。请记住，其余配置应与您在代码中共享的配置相同，但您应该将数据库名称附加到 sql.Open() 函数的第二个参数。

在使用GO从App Engine Flexible to Cloud SQL连接的示例中，标识了相同的过程：

db, err = sql.Open("mysql", dbName)

所以我想你应该试试这个改变：

// Old connection opening
db, err = sql.Open("mysql ", fmt.Sprintf("%s:%s@cloudsql(%s)/", user, password, connectionName))
// New connection opening, including dbName
db, err = sql.Open("mysql ", fmt.Sprintf("%s:%s@cloudsql(%s)/%s", user, password, connectionName, dbName))

我自己对 GoLang 不是很熟悉，但是根据文档，那应该可以。

通过 App Engine 使用 Cloud SQL 时，如何 select 要查询的数据库？

How do I select the database to query when using Cloud SQL through App Engine?

mysql

google-app-engine

google-cloud-sql