从 App Engine（第二代 CloudSQL）GO 连接到 CloudSQL

Question

Love the Stack，我第一次发帖是出于完全的挫败感。谢谢你们！

• 已创建 App Engine 项目
• 在我的 App Engine 项目中创建了第二代 MySQL 实例
• 在 MySQL 实例中创建数据库
• 在 App Engine 中，我激活了 --> Google Cloud Shell

我已经复制了这个基本的 GO 程序来连接我的 MySQL 实例。

我构建并运行它。 去构建 mysqlexample.go ./mysql示例

我无法成功连接。您可以看到我尝试过的所有各种连接字符串，它们的右侧是我得到的响应。

我可以使用 mysql admin 从本地 Windows 机器进行连接。

帮助？

package main

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

func main() {

    const dbIP = "104.xxx.xx.x"
    const dbInstanceName =  "esp-1-dev:us-central1:espdev"
    const dbName = "servpro"
    const dbUserName = "root"
    const dbPassword = "xxxxxxx"

    const dbOpenString = dbUserName + ":" + dbPassword + "@/" + dbInstanceName + "/" + dbName  //GETS RESPONSE default addr for network 'AppEngine:Zone:Project' unknown
    //const dbOpenString = dbUserName + "@cloudsql(" + dbInstanceName + ")/" + dbName   //GETS RESPONSE  dial cloudsql: unknown network cloudsql
    //const dbOpenString = dbUserName + "@/"  //+ "?parseTime=true&loc=UTC"                 //GETS RESPONSE  getsockopt: connection refused
    //const dbOpenString = dbUserName + ":" + dbPassword + "@tcp(" + dbIP + ":3306)/" + dbName  //GETS RESPONSE  dial tcp 104.xxx.xxx.x:3306: getsockopt: connection timed out

    //  Got this from stack overflow.  GoDocs are not updated to reflect 2nd Gen databases.
    //  http://stackoverflow.com/questions/38890022/tls-requested-but-server-does-not-support-tls-error-with-google-cloud-sql-2nd
    //user:password@cloudsql(copiedPastedInstanceConnectionName)/d‌​atabaseName?charset=‌​charset&collation=co‌​llation&tls=tlsConfi‌​gName&parseTime=true
    //First Generation Connection String    
        //username:password@cloudsql(appID:CloudSQLInstance)/databasename?parseTime=true&loc=UTC

    db, err := sql.Open("mysql", dbOpenString);
    defer db.Close()

    log.Println("Attempting Ping of database....")

    err = db.Ping()

    if err != nil {
        log.Println("db.Ping() failed:  " + dbOpenString)
        log.Println(err)
    } else {
        log.Println("Success!")
    }

}

Answer 1

以下是正确的连接字符串，但它们会因您连接的 App Engine 版本而异。

App Engine 标准：

user:password@cloudsql(INSTANCE_CONNECTION_NAME)/dbname

App Engine 灵活：

user:password@unix(/cloudsql/INSTANCE_CONNECTION_NAME)/dbname

Answer 2

如果您要迁移到第二代 Go App Engine (Golang 1.11)，请将您的连接字符串从：

user:password@cloudsql(instanceID)/db

到

user:password@unix(/cloudsql/instanceID)/db

Answer 3

https://cloud.google.com/appengine/docs/flexible/go/using-cloud-sql

对于刚接触 GO、App Engine 和 CloudSQL 的新手来说，仅仅编写最简单的 GO 程序来连接 CloudSQL 2nd Gen 数据库并与之通信是令人沮丧的！

您可以选择，App Eng 或 App Eng Flex，SQL 1st 或 2nd Gen.... 取决于组合，连接字符串会有所不同。当您搜索时，所有 google 的文档都会驱使您使用不带 flex 的第一代 SQL 和 App Engine，因为这主要用于生产。如果您这样做，请确保您正在阅读 Flex 文档。如果这样做，请确保您正在阅读 2nd Gen 文档。有时它们是完全不同的文档，有时文档堆叠在一个页面上，您必须深入到底部才能看到较新的东西 2nd gen sql 和 app eng flex。

CloudShell 很棘手，我仍然无法编译 GO 并在这里与 SQL 2nd 对话。我正在从已部署的应用程序引擎 flex 中成功地与 cloud sql 2nd gen 交谈，并运行 SQL 代理，您必须使用 SQL 代理。您必须在 appengine 和 SQL 上完成此创建用户的设置。

这是我的工作程序。

package main

import (
"database/sql"
_ "github.com/go-sql-driver/mysql"
"log"
"fmt"
"net/http"
)

func healthCheckHandler(w http.ResponseWriter, r *http.Request) {
fmt.Fprint(w, "ok")
}

func main() {
http.HandleFunc("/", handle)
http.HandleFunc("/_cloudshellProxy/_ah/health", healthCheckHandler)
log.Print("Listening on port 8080")
log.Fatal(http.ListenAndServe(":8080", nil))
}


func handle(w http.ResponseWriter, r *http.Request) {

const dbIP = "104.xxx.xxx.x"
const dbInstanceName =  "projectname:us-central1:sqlinstance"
const dbName = "servxxx"
const dbUserName = "sqlproxysuser"
const dbPassword = "xxxRockxxx"


if r.URL.Path != "/" {
    http.NotFound(w, r)
    return
}
fmt.Fprint(w, "Hello SQL!  Hello?")
fmt.Fprint(w, "\n")

const dbOpenString = dbUserName + ":" + dbPassword + "@unix(/cloudsql/" + dbInstanceName + ")/" + dbName 
//const dbOpenString = dbUserName + ":" + dbPassword + "@cloudsql(" + dbInstanceName + ")/" + dbName 

//-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=--=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-
//-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=--=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-
//-=- SQL OPEN Statement,  per docs, DOES NOT return an error ever
//-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=--=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-
//-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-=--=-=-=-=-=-=-=-=-=-=-=-=-=-=-=-
db, err := sql.Open("mysql", dbOpenString);
defer db.Close()

err = db.Ping()
if err != nil {
    fmt.Fprint(w, "Failed Connection" + "  " + dbOpenString)
    fmt.Fprint(w, "\n")
    fmt.Fprint(w, err)
    return
} else {
    fmt.Fprint(w, "SUCCESSFUL CONNECTION" + "  " + dbOpenString)
    fmt.Fprint(w, "\n")
}

_, err = db.Exec("CREATE TABLE IF NOT EXISTS exercisecloudsql101 (id INT NOT NULL AUTO_INCREMENT, name VARCHAR(100) NOT NULL, description TEXT, PRIMARY KEY (id))")
if err != nil {
    fmt.Fprint(w, "CREATE TABLE failed:")
    fmt.Fprint(w, "\n")
    fmt.Fprint(w, err) 
    fmt.Fprint(w, "\n")
} else {
    fmt.Fprint(w, "SUCCESSFUL CreateTable" + "  " + dbOpenString)
    fmt.Fprint(w, "\n")
}

}

Answer 4

在连接到云 SQL 实例时遇到了同样的问题。下面是我在 Windows localhost 环境中工作的一种变体。我的 localhost 的 IP 需要添加到数据库实例的授权网络中。

Windows localhost 通过 tcp 连接：

user:password@tcp(104.xxx.xxx.xxx:3306)/dbname